controller

Mar 15, 2019

Changes in this version

type Option

+ func WithContextPerSubscription(b bool) Option

+ func WithInitiallySuppressedRoles(r []string) Option

Jul 24, 2018

Changes in this version

+ func AckOperationUpdates(caller calls.Caller) Rule

+ func AckOperationUpdatesF(callerLookup func() calls.Caller) Rule

Sep 13, 2017

Changes in this version

+ const DefaultEventLabel

+ func AckStatusUpdates(caller calls.Caller) Rule

+ func AckStatusUpdatesF(callerLookup func() calls.Caller) Rule

+ func DefaultEventLogger(eventLabel string) func(*scheduler.Event)

+ func LiftErrors() Rule

+ func LogEvents(f func(*scheduler.Event)) Rule

+ func Run(ctx context.Context, framework *mesos.FrameworkInfo, caller calls.Caller, ...) (lastErr error)

+ func TrackSubscription(frameworkIDStore store.Singleton, failoverTimeout time.Duration) Rule

+ type Option func(*Config) Option

+ func WithEventHandler(handler events.Handler) Option

+ func WithFrameworkID(frameworkIDFunc func() string) Option

+ func WithRegistrationTokens(registrationTokens <-chan struct{}) Option

+ func WithSubscriptionTerminated(handler func(error)) Option

+ type StateError string

+ func (err StateError) Error() string

Jun 19, 2017

Changes in this version

+ func DefaultHandler(e *scheduler.Event) (err error)

+ type Config struct

+ Caller calls.Caller

+ Context Context

+ Framework *mesos.FrameworkInfo

+ Handler events.Handler

+ RegistrationTokens <-chan struct{}

+ type Context interface

+ Done func() bool

+ Error func(error)

+ FrameworkID func() string

+ type ContextAdapter struct

+ DoneFunc func() bool

+ ErrorFunc func(error)

+ FrameworkIDFunc func() string

+ func (ca *ContextAdapter) Done() bool

+ func (ca *ContextAdapter) Error(err error)

+ func (ca *ContextAdapter) FrameworkID() (id string)

+ type Controller interface

+ Run func(Config) error

+ func New() Controller

+ type ControllerFunc func(Config) error

+ func (cf ControllerFunc) Run(config Config) error

+ type ErrEvent string

+ func (e ErrEvent) Error() string