channelq

Documentation

Index

• func GetMessageDeletionTimestamp(msg *beehiveModel.Message) (*metav1.Time, error)
• func GetMessageUID(msg beehiveModel.Message) (string, error)
• func GetNodeID(msg *beehiveModel.Message) (string, error)
• type ChannelMessageQueue
  • func NewChannelMessageQueue(objectSyncLister reliablesyncslisters.ObjectSyncLister, ...) *ChannelMessageQueue
  • func (q *ChannelMessageQueue) Close(info *model.HubInfo)
  • func (q *ChannelMessageQueue) Connect(info *model.HubInfo)
  • func (q *ChannelMessageQueue) DispatchMessage()
  • func (q *ChannelMessageQueue) GetNodeListQueue(nodeID string) workqueue.RateLimitingInterface
  • func (q *ChannelMessageQueue) GetNodeListStore(nodeID string) cache.Store
  • func (q *ChannelMessageQueue) GetNodeQueue(nodeID string) workqueue.RateLimitingInterface
  • func (q *ChannelMessageQueue) GetNodeStore(nodeID string) cache.Store
  • func (q *ChannelMessageQueue) Publish(msg *beehiveModel.Message) error

Functions

func GetMessageDeletionTimestamp

func GetMessageDeletionTimestamp(msg *beehiveModel.Message) (*metav1.Time, error)

GetMessageDeletionTimestamp returns the deletionTimestamp of the object in message

func GetMessageUID

func GetMessageUID(msg beehiveModel.Message) (string, error)

GetMessageUID returns the UID of the object in message

func GetNodeID

func GetNodeID(msg *beehiveModel.Message) (string, error)

GetNodeID from "beehive/pkg/core/model".Message.Router.Resource

Types

type ChannelMessageQueue

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

ChannelMessageQueue is the channel implementation of MessageQueue

func NewChannelMessageQueue

func NewChannelMessageQueue(objectSyncLister reliablesyncslisters.ObjectSyncLister, clusterObjectSyncLister reliablesyncslisters.ClusterObjectSyncLister, crdClient crdClientset.Interface) *ChannelMessageQueue

NewChannelMessageQueue initializes a new ChannelMessageQueue

func (*ChannelMessageQueue) Close

func (q *ChannelMessageQueue) Close(info *model.HubInfo)

Close closes queues and stores for given node

func (*ChannelMessageQueue) Connect

func (q *ChannelMessageQueue) Connect(info *model.HubInfo)

Connect allocates the queues and stores for given node

func (*ChannelMessageQueue) DispatchMessage

func (q *ChannelMessageQueue) DispatchMessage()

DispatchMessage gets the message from the cloud, extracts the node id from it, gets the message associated with the node and pushes the message to the queue

func (*ChannelMessageQueue) GetNodeListQueue

func (q *ChannelMessageQueue) GetNodeListQueue(nodeID string) workqueue.RateLimitingInterface

GetNodeListQueue returns the listQueue for given node

func (*ChannelMessageQueue) GetNodeListStore

func (q *ChannelMessageQueue) GetNodeListStore(nodeID string) cache.Store

GetNodeListStore returns the listStore for given node

func (*ChannelMessageQueue) GetNodeQueue

func (q *ChannelMessageQueue) GetNodeQueue(nodeID string) workqueue.RateLimitingInterface

GetNodeQueue returns the queue for given node

func (*ChannelMessageQueue) GetNodeStore

func (q *ChannelMessageQueue) GetNodeStore(nodeID string) cache.Store

GetNodeStore returns the store for given node

func (*ChannelMessageQueue) Publish

func (q *ChannelMessageQueue) Publish(msg *beehiveModel.Message) error

Publish sends message via the channel to Controllers