Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPool ¶
func NewPool(poolName string, groups []EnsuredGroup, svc ComputesService) infra.Pool
Types ¶
type Cleanupper ¶
type ComputesService ¶
type EnsuredGroup ¶
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func NewExecutor ¶
func NewExecutor(listersInCleanupOrder [][]Cleanupper) *Executor
NewExecutor - inner cleanuppers are executed concurrently,
cleanupper slices are executed sequentially
type ResourceFactory ¶
type ResourceFactory struct {
// contains filtered or unexported fields
}
func NewResourceFactory ¶
func NewResourceFactory(logger logging.Logger, operatorID string) *ResourceFactory
func (*ResourceFactory) IsOperatorManaged ¶
func (i *ResourceFactory) IsOperatorManaged(id *string) bool
func (*ResourceFactory) New ¶
func (i *ResourceFactory) New(service ResourceService, payload interface{}, dependencies []*Resource, ensured func(interface{}) error) *Resource
type ResourceService ¶
type ResourceService interface { // Neighter include dependencies nor an ID in interface{} Abbreviate() string Desire(payload interface{}) (interface{}, error) Ensure(id string, desired interface{}, ensuredDependencies []interface{}) (interface{}, error) Cleanupper }
Click to show internal directories.
Click to hide internal directories.