handlers

Documentation

Index

• type ComponentsHandler
  • func NewComponentsHandler(client kubernetes.Interface) *ComponentsHandler
  • func (c *ComponentsHandler) Init() error
  • func (c *ComponentsHandler) ObjectCreated(obj interface{})
  • func (c *ComponentsHandler) ObjectDeleted(obj interface{})
  • func (c *ComponentsHandler) ObjectUpdated(old interface{}, new interface{})
• type DaprHandler
  • func NewDaprHandler(kubeAPI *kubernetes.API) *DaprHandler
  • func (h *DaprHandler) Init() error
  • func (h *DaprHandler) ObjectCreated(obj interface{})
  • func (h *DaprHandler) ObjectDeleted(obj interface{})
  • func (h *DaprHandler) ObjectUpdated(old interface{}, new interface{})
• type Handler

Types

type ComponentsHandler

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

ComponentsHandler handles the lifetime management of Component CRDs

func NewComponentsHandler

func NewComponentsHandler(client kubernetes.Interface) *ComponentsHandler

NewComponentsHandler returns a new component handler

func (*ComponentsHandler) Init

func (c *ComponentsHandler) Init() error

Init performs any startup tasks needed

func (*ComponentsHandler) ObjectCreated

func (c *ComponentsHandler) ObjectCreated(obj interface{})

ObjectCreated handles created crd operations

func (*ComponentsHandler) ObjectDeleted

func (c *ComponentsHandler) ObjectDeleted(obj interface{})

ObjectDeleted handles deleted crd operations

func (*ComponentsHandler) ObjectUpdated

func (c *ComponentsHandler) ObjectUpdated(old interface{}, new interface{})

ObjectUpdated handles updated crd operations

type DaprHandler

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

DaprHandler handles the lifetime for Dapr CRDs

func NewDaprHandler

func NewDaprHandler(kubeAPI *kubernetes.API) *DaprHandler

NewDaprHandler returns a new Dapr handler

func (*DaprHandler) Init

func (h *DaprHandler) Init() error

Init allows for various startup tasks

func (*DaprHandler) ObjectCreated

func (h *DaprHandler) ObjectCreated(obj interface{})

ObjectCreated handles Dapr enabled deployment state changes

func (*DaprHandler) ObjectDeleted

func (h *DaprHandler) ObjectDeleted(obj interface{})

ObjectDeleted handles Dapr crd deletion

func (*DaprHandler) ObjectUpdated

func (h *DaprHandler) ObjectUpdated(old interface{}, new interface{})

ObjectUpdated handles Dapr crd updates

type Handler

type Handler interface {
	Init() error
	ObjectCreated(obj interface{})
	ObjectUpdated(old interface{}, new interface{})
	ObjectDeleted(obj interface{})
}

Handler is the interface for dealing with Dapr CRDs state changes