internal

type Collection struct {

	// PlanFunc returns a plan based on the intent
	PlanFunc func(controller.Operation, types.Spec) (controller.Plan, error) `json:"-"`

	// StartFunc begins the actual processing. This will be called synchronously
	// so the body needs to start goroutines.
	StartFunc func(context.Context) `json:"-"`

	// UpdateSpecFunc is called when a new spec is posted.  This will be executed
	// with exclusive lock on the collection.
	UpdateSpecFunc func(cur types.Spec, prev *types.Spec) error `json:"-"`

	// PauseFunc is called when the controller tries to pause.
	PauseFunc func(bool) `json:"-"`

	// StopFunc is called when the collection is stopped terminally.
	StopFunc func() error `json:"-"`

	// TerminateFunc is called when this collection is to be destroyed / terminated.
	// This is not the same as Stop, which stops monitoring.
	TerminateFunc func() error `json:"-"`

	types.Spec
	// contains filtered or unexported fields
}

type ControlLoop interface {
	Start()
	Running() bool
	Stop() error
}

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

type InstanceAccess struct {
	*InstanceObserver `json:",inline" yaml:",inline"`

	// Spec is the spec to use when provisioning the instance
	instance.Spec `json:",inline" yaml:",inline"`
}

type InstanceObserver struct {
	instance.Plugin

	// Name is the name of the instance plugin
	Name plugin.Name `json:"plugin" yaml:"plugin"`

	// Select are the labels to use when querying for instances. This is the namespace.
	Select map[string]string

	// ObserveInterval is the polling interval for making an observation
	ObserveInterval types.Duration

	// CacheDescribeInstances is true to turn on caching with ttl equal to the ObserveInterval
	CacheDescribeInstances bool

	// KeySelector is a string template for selecting the join key from
	// an instance's instance.Description. This selector template should use escapes
	// so that the template {{ and }} are preserved.  For example,
	// SourceKeySelector: \{\{ .ID \}\}  # selects the ID field.
	KeySelector string
	// contains filtered or unexported fields
}

type Item struct {
	Key     string
	Ordinal int
	State   stateMachine
	Data    map[string]interface{} `json:",omitempty"`
}

type Managed interface {
	ControlLoop

	CurrentSpec() types.Spec
	SetPrevSpec(types.Spec)
	GetPrevSpec() *types.Spec // optional since the first one will not have it set

	Metadata() metadata.Plugin
	Events() event.Plugin

	Plan(controller.Operation, types.Spec) (*types.Object, *controller.Plan, error)
	Enforce(types.Spec) (*types.Object, error)
	Inspect() (*types.Object, error)
	Free() (*types.Object, error)
	Terminate() (*types.Object, error)
}

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