controllers

Documentation

Index

• type ControllerConfig
• type ControllerHandlerContextKey
• type ControllerHandlerFunc
• type KindControllerManager
  • func NewKindControllerManager(lockFactory db.LockFactory, events services.EventService) *KindControllerManager
  • func (km *KindControllerManager) Add(config *ControllerConfig)
  • func (km *KindControllerManager) AddEvent(id string)
  • func (km *KindControllerManager) Run(stopCh <-chan struct{})
• type StatusController
  • func NewStatusController(statusEvents services.StatusEventService) *StatusController
  • func (sc *StatusController) Add(handlers map[api.StatusEventType][]StatusHandlerFunc)
  • func (sc *StatusController) AddStatusEvent(id string)
  • func (sc *StatusController) Run(stopCh <-chan struct{})
• type StatusHandlerFunc

Types

type ControllerConfig

type ControllerConfig struct {
	Source   string
	Handlers map[api.EventType][]ControllerHandlerFunc
}

type ControllerHandlerContextKey

type ControllerHandlerContextKey string

const EventID ControllerHandlerContextKey = "event"

const StatusEventID ControllerHandlerContextKey = "status_event"

type ControllerHandlerFunc

type ControllerHandlerFunc func(ctx context.Context, id string) error

type KindControllerManager

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

func NewKindControllerManager

func NewKindControllerManager(lockFactory db.LockFactory, events services.EventService) *KindControllerManager

func (*KindControllerManager) Add

func (km *KindControllerManager) Add(config *ControllerConfig)

func (*KindControllerManager) AddEvent

func (km *KindControllerManager) AddEvent(id string)

func (*KindControllerManager) Run

func (km *KindControllerManager) Run(stopCh <-chan struct{})

type StatusController

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

func NewStatusController

func NewStatusController(statusEvents services.StatusEventService) *StatusController

func (*StatusController) Add

func (sc *StatusController) Add(handlers map[api.StatusEventType][]StatusHandlerFunc)

func (*StatusController) AddStatusEvent

func (sc *StatusController) AddStatusEvent(id string)

AddStatusEvent adds a status event to the queue to be processed.

func (*StatusController) Run

func (sc *StatusController) Run(stopCh <-chan struct{})

type StatusHandlerFunc

type StatusHandlerFunc func(ctx context.Context, eventID, sourceID string) error