messagelayer

Documentation

Index

• type ContextMessageLayer
  • func (cml *ContextMessageLayer) Done() <-chan struct{}
  • func (cml *ContextMessageLayer) ReceiveResourceUpdate() (*ResourceUpdateSpec, error)
  • func (cml *ContextMessageLayer) SendResourceObject(nodeName string, eventType watch.EventType, obj interface{}) error
• type MessageLayer
  • func NewContextMessageLayer() MessageLayer
• type ResourceUpdateSpec

Types

type ContextMessageLayer

type ContextMessageLayer struct {
}

ContextMessageLayer build on context

func (*ContextMessageLayer) Done

func (cml *ContextMessageLayer) Done() <-chan struct{}

Done signals the message layer is done

func (*ContextMessageLayer) ReceiveResourceUpdate

func (cml *ContextMessageLayer) ReceiveResourceUpdate() (*ResourceUpdateSpec, error)

ReceiveResourceUpdate receives and handles the update

func (*ContextMessageLayer) SendResourceObject

func (cml *ContextMessageLayer) SendResourceObject(nodeName string, eventType watch.EventType, obj interface{}) error

SendResourceObject message to the node with resource object and event type

type MessageLayer

type MessageLayer interface {
	SendResourceObject(nodeName string, eventType watch.EventType, obj interface{}) error
	ReceiveResourceUpdate() (*ResourceUpdateSpec, error)
	Done() <-chan struct{}
}

MessageLayer define all functions that message layer must implement

func NewContextMessageLayer

func NewContextMessageLayer() MessageLayer

NewContextMessageLayer create a ContextMessageLayer

type ResourceUpdateSpec

type ResourceUpdateSpec struct {
	Kind      string
	Namespace string
	Name      string
	Operation string
	Content   []byte
}

ResourceUpdateSpec describes the resource update from upstream