storage

type BackendKernel struct {
	*sessiontree.BackendRepo
	// contains filtered or unexported fields
}

type ForkOperationCommitRequest struct {
	OperationID        string
	RequestFingerprint string
	Plan               json.RawMessage
	Nodes              []sessiontree.ForkOptions
	Result             json.RawMessage
	FinishedAt         time.Time
}

type ForkOperationFailureRequest struct {
	OperationID        string
	RequestFingerprint string
	ErrorCode          string
	ErrorMessage       string
	FinishedAt         time.Time
}

type ForkOperationPlan struct {
	Version            int                     `json:"version"`
	OperationID        string                  `json:"operation_id"`
	RequestFingerprint string                  `json:"request_fingerprint"`
	PreparedAt         time.Time               `json:"prepared_at"`
	Root               ForkOperationPlanNode   `json:"root"`
	TerminalChildren   []ForkOperationPlanNode `json:"terminal_children,omitempty"`
}

type ForkOperationPlanNode struct {
	NodeID              string                           `json:"node_id"`
	SourceThreadID      string                           `json:"source_thread_id"`
	SourceEntryID       string                           `json:"source_entry_id,omitempty"`
	SourceLeafEntryID   string                           `json:"source_leaf_entry_id,omitempty"`
	DestinationThreadID string                           `json:"destination_thread_id"`
	TurnIDMap           map[string]string                `json:"turn_id_map,omitempty"`
	RunIDMap            map[string]string                `json:"run_id_map,omitempty"`
	DestinationMeta     *sessiontree.ForkDestinationMeta `json:"destination_meta,omitempty"`
	ArtifactClosure     artifact.Closure                 `json:"artifact_closure"`
}

type ForkOperationRecord struct {
	OperationID        string
	RequestFingerprint string
	SourceThreadIDs    []string
	AuthorityThreadIDs []string
	State              ForkOperationState
	Plan               json.RawMessage
	Result             json.RawMessage
	ErrorCode          string
	ErrorMessage       string
	CreatedAt          time.Time
	UpdatedAt          time.Time
	FinishedAt         time.Time
}

type ForkOperationState string

type ForkOperationStore interface {
	PrepareForkOperation(context.Context, ForkOperationRecord) (ForkOperationRecord, bool, error)
	ForkOperation(context.Context, string) (ForkOperationRecord, error)
	CommitForkOperation(context.Context, ForkOperationCommitRequest) (ForkOperationRecord, bool, error)
	FailForkOperation(context.Context, ForkOperationFailureRequest) (ForkOperationRecord, bool, error)
}

type MemoryForkOperationStore struct {
	// contains filtered or unexported fields
}

type MetadataRecord struct {
	Namespace string
	ID        string
	CreatedAt time.Time
	UpdatedAt time.Time
	Data      json.RawMessage
}

type MetadataStore interface {
	PutMetadata(context.Context, MetadataRecord) error
	Metadata(context.Context, string, string) (MetadataRecord, error)
	ListMetadata(context.Context, string) ([]MetadataRecord, error)
	DeleteMetadata(context.Context, string, string) error
}

type Store interface {
	sessiontree.Repo
	cache.Store
	MetadataStore
	ForkOperationStore
	sessiontree.ProviderStateStore
	Close() error
}

type StoreLeasePolicyMismatchError struct {
	Configured sessiontree.LeasePolicy
	Persisted  sessiontree.LeasePolicy
}

type StoreSchemaIdentity struct {
	Version     string
	Fingerprint string
}

type StoreSchemaMigrationRequirement string

type StoreSchemaMigrationSource struct {
	Identity    StoreSchemaIdentity
	Requirement StoreSchemaMigrationRequirement
}

type UnsupportedStoreSchemaError struct {
	Observed   StoreSchemaIdentity
	Current    StoreSchemaIdentity
	Migratable []StoreSchemaMigrationSource
}