storage

type ForkOperationRecord struct {
	OperationID        string
	RequestFingerprint 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)
	UpdateForkOperation(context.Context, ForkOperationRecord) error
}

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

type MemoryProviderStateStore 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 ProviderStateRecord struct {
	ThreadID         string
	LeafEntryID      string
	CompatibilityKey string
	State            provider.State
	CreatedByRunID   string
	CreatedByTurnID  string
	UpdatedAt        time.Time
}

type ProviderStateStore interface {
	ProviderState(context.Context, string) (ProviderStateRecord, error)
	PutProviderState(context.Context, ProviderStateRecord) error
	DeleteProviderState(context.Context, string) error
}

type Store interface {
	sessiontree.Repo
	cache.Store
	MetadataStore
	ForkOperationStore
	ProviderStateStore
	DeleteThreadTreeData(context.Context, string) ([]string, error)
	Close() error
}