channelq

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 4, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMessageDeletionTimestamp added in v1.6.1

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

GetMessageDeletionTimestamp returns the deletionTimestamp of the object in message

func GetMessageUID added in v1.6.1

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

GetMessageUID returns the UID of the object in message

func GetNodeID added in v1.6.1

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

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

Types

type ChannelMessageQueue added in v1.6.1

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

ChannelMessageQueue is the channel implementation of MessageQueue

func NewChannelMessageQueue added in v1.6.1

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

NewChannelMessageQueue initializes a new ChannelMessageQueue

func (*ChannelMessageQueue) Close added in v1.6.1

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

Close closes queues and stores for given node

func (*ChannelMessageQueue) Connect added in v1.6.1

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

Connect allocates the queues and stores for given node

func (*ChannelMessageQueue) DispatchMessage added in v1.6.1

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 added in v1.6.1

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

GetNodeListQueue returns the listQueue for given node

func (*ChannelMessageQueue) GetNodeListStore added in v1.6.1

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

GetNodeListStore returns the listStore for given node

func (*ChannelMessageQueue) GetNodeQueue added in v1.6.1

GetNodeQueue returns the queue for given node

func (*ChannelMessageQueue) GetNodeStore added in v1.6.1

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

GetNodeStore returns the store for given node

func (*ChannelMessageQueue) Publish added in v1.6.1

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

Publish sends message via the channel to Controllers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL