Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.