core

Documentation

Index

• func NewPool(poolName string, groups []EnsuredGroup, svc MachinesService) infra.Pool
• func Validate(lbs map[string]*infra.Ingress, pools []string) error
• type Cleanupper
• type EnsuredGroup
• type Executor
  • func NewExecutor(listersInCleanupOrder [][]Cleanupper) *Executor
  • func (e *Executor) Plan(root *Resource) error
  • func (e *Executor) Run() (chan error, error)
• type MachinesService
• type Resource
  • func (i *Resource) ID() (*string, error)
• type ResourceFactory
  • func NewResourceFactory(monitor mntr.Monitor, operatorID string) *ResourceFactory
  • func (i *ResourceFactory) IsOperatorManaged(id *string) bool
  • func (i *ResourceFactory) New(service ResourceService, payload interface{}, dependencies []*Resource, ...) *Resource
• type ResourceService

Functions

func NewPool

func NewPool(poolName string, groups []EnsuredGroup, svc MachinesService) infra.Pool

func Validate

func Validate(lbs map[string]*infra.Ingress, pools []string) error

Types

type Cleanupper

type Cleanupper interface {
	AllExisting() ([]string, error)
	Delete(id string) error
}

type EnsuredGroup

type EnsuredGroup interface {
	EnsureMembers(machine []infra.Machine) error
	AddMember(machine infra.Machine) error
}

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

func (*Executor) Plan

func (e *Executor) Plan(root *Resource) error

func (*Executor) Run

func (e *Executor) Run() (chan error, error)

type MachinesService

type MachinesService interface {
	ListPools() ([]string, error)
	List(poolName string, active bool) (infra.Machines, error)
	Create(poolName string) (infra.Machine, error)
}

type Resource

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

func (*Resource) ID

func (i *Resource) ID() (*string, error)

type ResourceFactory

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

func NewResourceFactory

func NewResourceFactory(monitor mntr.Monitor, 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
}