Documentation
¶
Index ¶
- Variables
- type ExecutionRecord
- type Inspector
- type MemoryOrchestrator
- func (o *MemoryOrchestrator) Execute(_ context.Context, plan Plan) error
- func (o *MemoryOrchestrator) ForceCleanup(ctx context.Context, pluginInstanceID string) error
- func (o *MemoryOrchestrator) ListExecutions(_ context.Context, pluginInstanceID string) ([]ExecutionRecord, error)
- func (o *MemoryOrchestrator) PlanUninstall(_ context.Context, pluginInstanceID string, deleteData bool) (Plan, error)
- type Orchestrator
- type Phase
- type Plan
- type SQLiteOrchestrator
- func (o *SQLiteOrchestrator) Close() error
- func (o *SQLiteOrchestrator) Execute(ctx context.Context, plan Plan) error
- func (o *SQLiteOrchestrator) ForceCleanup(ctx context.Context, pluginInstanceID string) error
- func (o *SQLiteOrchestrator) ListExecutions(ctx context.Context, pluginInstanceID string) ([]ExecutionRecord, error)
- func (o *SQLiteOrchestrator) PlanUninstall(_ context.Context, pluginInstanceID string, deleteData bool) (Plan, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidPlan = errors.New("cleanup plan is invalid")
Functions ¶
This section is empty.
Types ¶
type ExecutionRecord ¶
type Inspector ¶
type Inspector interface {
ListExecutions(ctx context.Context, pluginInstanceID string) ([]ExecutionRecord, error)
}
type MemoryOrchestrator ¶
type MemoryOrchestrator struct {
// contains filtered or unexported fields
}
func NewMemoryOrchestrator ¶
func NewMemoryOrchestrator() *MemoryOrchestrator
func (*MemoryOrchestrator) Execute ¶
func (o *MemoryOrchestrator) Execute(_ context.Context, plan Plan) error
func (*MemoryOrchestrator) ForceCleanup ¶
func (o *MemoryOrchestrator) ForceCleanup(ctx context.Context, pluginInstanceID string) error
func (*MemoryOrchestrator) ListExecutions ¶
func (o *MemoryOrchestrator) ListExecutions(_ context.Context, pluginInstanceID string) ([]ExecutionRecord, error)
func (*MemoryOrchestrator) PlanUninstall ¶
type Orchestrator ¶
type SQLiteOrchestrator ¶
type SQLiteOrchestrator struct {
// contains filtered or unexported fields
}
func NewSQLiteOrchestrator ¶
func NewSQLiteOrchestrator(ctx context.Context, path string) (*SQLiteOrchestrator, error)
func (*SQLiteOrchestrator) Close ¶
func (o *SQLiteOrchestrator) Close() error
func (*SQLiteOrchestrator) Execute ¶
func (o *SQLiteOrchestrator) Execute(ctx context.Context, plan Plan) error
func (*SQLiteOrchestrator) ForceCleanup ¶
func (o *SQLiteOrchestrator) ForceCleanup(ctx context.Context, pluginInstanceID string) error
func (*SQLiteOrchestrator) ListExecutions ¶
func (o *SQLiteOrchestrator) ListExecutions(ctx context.Context, pluginInstanceID string) ([]ExecutionRecord, error)
func (*SQLiteOrchestrator) PlanUninstall ¶
Click to show internal directories.
Click to hide internal directories.