utils

May 4, 2021

Changes in this version

+ func BrokerProxyName(client interface{}, brokerName string, brokerID string, proxyPrefix string) string

+ func LabelChangesToLabels(changes types.LabelChanges) (types.Labels, types.Labels)

+ type FakeConsumer struct

+ func (c *FakeConsumer) Consume(ctx context.Context, notification *types.Notification)

+ func (c *FakeConsumer) GetConsumedNotifications() []*types.Notification

+ type FakeResyncer struct

+ func (r *FakeResyncer) GetResyncCount() int

+ func (r *FakeResyncer) Resync(ctx context.Context, resyncVisibilities bool)