operation

type CancelRequest struct {
	OperationID string    `json:"operation_id"`
	Reason      string    `json:"reason,omitempty"`
	Now         time.Time `json:"-"`
}

type Cursor struct {
	CreatedAt   time.Time
	OperationID string
}

type FinishRequest struct {
	OperationID string                          `json:"operation_id"`
	Status      Status                          `json:"status"`
	FailureCode capability.ExecutionFailureCode `json:"failure_code,omitempty"`
	Reason      string                          `json:"reason,omitempty"`
	Now         time.Time                       `json:"-"`
}

type ListRequest struct {
	PluginInstanceID string `json:"plugin_instance_id,omitempty"`
	Cursor           *Cursor
	Limit            int        `json:"limit"`
	Owner            OwnerScope `json:"-"`
	AllOwners        bool       `json:"-"`
}

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

type OwnerScope = capability.ExecutionOwnerScope

type Page struct {
	Records    []Record
	NextCursor *Cursor
}

type PluginTransitionRequest struct {
	PluginInstanceID string                   `json:"plugin_instance_id"`
	ResourceScope    sessionctx.ResourceScope `json:"-"`
	Reason           string                   `json:"reason,omitempty"`
	Now              time.Time                `json:"-"`
}

type ProgressRequest struct {
	OperationID string
	Progress    capability.OperationProgress
	Now         time.Time `json:"-"`
}

type PruneRequest struct {
	Before                      time.Time `json:"before"`
	Limit                       int       `json:"limit,omitempty"`
	MaxTerminalRecordsPerPlugin int       `json:"max_terminal_records_per_plugin,omitempty"`
}

type PruneResult struct {
	Deleted int `json:"deleted"`
}

type Record struct {
	OperationID string `json:"operation_id"`
	capability.ExecutionBinding
	Status             Status                          `json:"status"`
	Cancelable         bool                            `json:"cancelable"`
	CancelAckTimeoutMS int                             `json:"cancel_ack_timeout_ms,omitempty"`
	DisableBehavior    string                          `json:"disable_behavior,omitempty"`
	UninstallBehavior  string                          `json:"uninstall_behavior,omitempty"`
	FailureCode        capability.ExecutionFailureCode `json:"failure_code,omitempty"`
	Reason             string                          `json:"reason,omitempty"`
	CreatedAt          time.Time                       `json:"created_at"`
	UpdatedAt          time.Time                       `json:"updated_at"`
	CancelRequestedAt  *time.Time                      `json:"cancel_requested_at,omitempty"`
	OrphanedAt         *time.Time                      `json:"orphaned_at,omitempty"`
	TerminalAt         *time.Time                      `json:"terminal_at,omitempty"`
	Progress           *capability.OperationProgress   `json:"progress,omitempty"`
}

type RegisterRequest struct {
	OperationID        string                      `json:"operation_id"`
	ExecutionBinding   capability.ExecutionBinding `json:"execution_binding"`
	Cancelable         *bool                       `json:"cancelable,omitempty"`
	CancelAckTimeoutMS int                         `json:"cancel_ack_timeout_ms,omitempty"`
	DisableBehavior    string                      `json:"disable_behavior,omitempty"`
	UninstallBehavior  string                      `json:"uninstall_behavior,omitempty"`
	Now                time.Time                   `json:"-"`
}

type RevokeSessionScopeRequest struct {
	SessionScope sessionctx.SessionScope `json:"-"`
	Now          time.Time               `json:"-"`
}

type RevokeSessionScopeResult struct {
	Revoked int `json:"revoked"`
}

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

type Status string

type Store interface {
	Durable() bool
	Register(ctx context.Context, req RegisterRequest) (Record, error)
	List(ctx context.Context, req ListRequest) (Page, error)
	Get(ctx context.Context, operationID string) (Record, error)
	ReportProgress(ctx context.Context, req ProgressRequest) (Record, error)
	RequestCancel(ctx context.Context, req CancelRequest) (Record, error)
	Finish(ctx context.Context, req FinishRequest) (Record, error)
	MarkPluginDisabled(ctx context.Context, req PluginTransitionRequest) ([]Record, error)
	MarkPluginUninstalled(ctx context.Context, req PluginTransitionRequest) ([]Record, error)
	RevokeSessionScope(ctx context.Context, req RevokeSessionScopeRequest) (RevokeSessionScopeResult, error)
	Prune(ctx context.Context, req PruneRequest) (PruneResult, error)
}