controller

Documentation

Index

• type Controller
  • func NewController(store entitystore.EntityStore, options Options) Controller
• type DefaultController
  • func (dc *DefaultController) AddEntityHandler(h EntityHandler)
  • func (dc *DefaultController) Shutdown()
  • func (dc *DefaultController) Start()
  • func (dc *DefaultController) Watcher() Watcher
• type EntityHandler
• type Options
• type Watcher
  • func (w *Watcher) OnAction(e entitystore.Entity)

Types

type Controller

type Controller interface {
	Start()
	Shutdown()

	Watcher() Watcher

	AddEntityHandler(h EntityHandler)
}

Controller defines an interface for a generic controller

func NewController

func NewController(store entitystore.EntityStore, options Options) Controller

NewController creates a new controller

type DefaultController

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

DefaultController defines a struct for a generic controller

func (*DefaultController) AddEntityHandler

func (dc *DefaultController) AddEntityHandler(h EntityHandler)

AddEntityHandler adds entity handlers

func (*DefaultController) Shutdown

func (dc *DefaultController) Shutdown()

Shutdown stops the controller loop

func (*DefaultController) Start

func (dc *DefaultController) Start()

Start starts the controller watch loop

func (*DefaultController) Watcher

func (dc *DefaultController) Watcher() Watcher

type EntityHandler

type EntityHandler interface {
	Type() reflect.Type
	Add(obj entitystore.Entity) error
	Update(obj entitystore.Entity) error
	Delete(obj entitystore.Entity) error
	Error(obj entitystore.Entity) error
}

EntityHandler define an interface for entity operations of a generic controller

type Options

type Options struct {
	OrganizationID string
	Namespace      string

	ResyncPeriod time.Duration
	Workers      int
}

Options defines controller configuration

type Watcher

type Watcher chan<- entitystore.Entity

func (*Watcher) OnAction

func (w *Watcher) OnAction(e entitystore.Entity)