executor

Jun 19, 2026

Changes in this version

+ type ErrorList struct

+ func (e *ErrorList) Add(err error)

+ func (e *ErrorList) Addf(format string, args ...interface{})

+ func (e *ErrorList) Join(sep string) string

+ func (e *ErrorList) Len() int

May 22, 2026

Changes in this version

+ type ReportStateCallback func(key string, value interface{}) error

+ type Result struct

+ ElapsedMs int64

+ Message string

type Spec

+ ReportStateCallback ReportStateCallback

Feb 12, 2026

Changes in this version

+ var DefaultRegistry = NewRegistry()

+ func Register(executor Executor)

+ type AWSConnectorConfig = awsutil.AWSConnectorConfig

+ type ConnectorConfig struct

+ AWS *AWSConnectorConfig

+ K8S *K8SConnectorConfig

+ type Executor interface

+ Shutdown func(ctx context.Context, log logr.Logger, spec Spec) error

+ Type func() string

+ Validate func(spec Spec) error

+ WakeUp func(ctx context.Context, log logr.Logger, spec Spec, restore RestoreData) error

+ func Get(executorType string) (Executor, bool)

+ type K8SConnectorConfig = k8sutil.K8SConnectorConfig

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Get(executorType string) (Executor, bool)

+ func (r *Registry) List() []string

+ func (r *Registry) Register(executor Executor)

+ type RestoreData struct

+ Data map[string]json.RawMessage

+ IsLive bool

+ Type string

+ type SaveRestoreDataFunc func(key string, value interface{}, isLive bool) error

+ type Spec struct

+ ConnectorConfig ConnectorConfig

+ Parameters json.RawMessage

+ SaveRestoreData SaveRestoreDataFunc

+ TargetName string

+ TargetType string