30 lines
919 B
Go
30 lines
919 B
Go
package ports
|
|
|
|
import (
|
|
"context"
|
|
|
|
"git.cin.su/m/Assistant/contracts/capability"
|
|
"git.cin.su/m/Assistant/contracts/work"
|
|
)
|
|
|
|
type GraphStore interface {
|
|
SaveWorkGraph(context.Context, work.WorkGraph) error
|
|
LoadWorkGraph(context.Context, string, int64) (work.WorkGraph, error)
|
|
SaveDispatchIntent(context.Context, work.AgentDispatchIntent) error
|
|
EnqueueDispatch(context.Context, work.AgentDispatchQueueItem) error
|
|
}
|
|
|
|
type GraphResultStore interface {
|
|
SaveGraphSynthesis(context.Context, work.ConflictSet, []work.ResultCandidate, work.GraphSynthesisCandidate) error
|
|
}
|
|
|
|
type GraphCandidateStore interface {
|
|
SaveGraphResultCandidate(context.Context, work.ResultCandidate) error
|
|
}
|
|
|
|
// TaskEvaluationSink is a remote-capable boundary to Capability's owner.
|
|
// Work never writes the capability schema directly.
|
|
type TaskEvaluationSink interface {
|
|
SaveTaskEvaluation(context.Context, capability.TaskEvaluation) error
|
|
}
|