21 lines
624 B
Go
21 lines
624 B
Go
package ports
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"time"
|
|
|
|
"git.cin.su/m/Assistant/contracts/work"
|
|
)
|
|
|
|
var ErrAgentExecutorUnavailable = errors.New("agent executor unavailable")
|
|
|
|
type WorkerStore interface {
|
|
ExecutionStore
|
|
LoadDispatchIntent(context.Context, string) (work.AgentDispatchIntent, error)
|
|
ClaimNextDispatch(context.Context, string, int64) (work.AgentDispatchQueueItem, error)
|
|
CompleteDispatch(context.Context, string, string, work.AgentDispatchQueueState, int64) error
|
|
RetryDispatch(context.Context, string, string, int64, time.Duration) error
|
|
RecoverStaleClaims(context.Context, int64, int64) (int64, error)
|
|
}
|