store

type NodeSpec struct {
	ID    string
	Task  string
	Input model.NodeInput
}

type PublishPackageParams struct {
	Package   string
	Contracts []PublishTaskContractParams
	Graphs    []RegisterGraphParams
}

type PublishPackageResult struct {
	Contracts map[string]string
	Graphs    map[string]string
}

type PublishTaskContractParams struct {
	Task         string
	OwnerPackage string
	InputSchema  json.RawMessage
	OutputSchema json.RawMessage
}

type RegisterGraphParams struct {
	Name  string
	Nodes []NodeSpec
}

type Store interface {
	PublishTaskContract(context.Context, PublishTaskContractParams) (model.TaskContract, error)
	LoadTaskContract(context.Context, string, string) (model.TaskContract, error)
	LoadTaskContractHead(context.Context, string) (model.TaskContractHead, error)
	ListTaskContractHeadsByOwner(context.Context, string) ([]model.TaskContractHead, error)
	RegisterGraph(context.Context, RegisterGraphParams) (model.GraphDefinition, error)
	PublishPackage(context.Context, PublishPackageParams) (PublishPackageResult, error)
	LoadGraph(context.Context, string) (model.GraphDefinition, error)
	LoadGraphHead(context.Context, string) (string, error)
	CreateRunForGraph(context.Context, string, json.RawMessage) (model.RunRecord, error)
	LoadRunRecord(context.Context, string) (model.RunRecord, error)
	ListActiveRunIDs(context.Context) ([]string, error)
	ClaimAttempt(context.Context, string, string, time.Time, time.Time) (model.Attempt, bool, error)
	LoadAttempt(context.Context, string) (model.Attempt, error)
	RenewAttempt(context.Context, string, time.Time) (bool, error)
	ListAttempts(context.Context, string, *string) ([]model.Attempt, error)
	RetryNode(context.Context, string, string) (bool, error)
	CommitSuccess(context.Context, string, string, string, time.Time, json.RawMessage) (bool, error)
	CommitFailure(context.Context, string, string, string, time.Time, string) (bool, error)
	CommitRetry(context.Context, string, string, string, time.Time, string, int, time.Time) (bool, error)
	SaveExecutionBinding(context.Context, model.ExecutionBinding) (model.ExecutionBinding, error)
	LoadExecutionBinding(context.Context, string, string) (model.ExecutionBinding, error)
	DeleteExecutionBinding(context.Context, string, string) (bool, error)
	ListArtifacts(context.Context, string) ([]model.ArtifactRecord, error)
	AcknowledgeArtifactReleased(context.Context, string, time.Time) (model.ArtifactRecord, error)
	Close() error
}

type StoreProvider interface {
	DefaultStore(context.Context) (Store, error)
	ForTenant(context.Context, TenantID) (Store, error)
	Close() error
}

type TenantID string