utils

Documentation

Index

• func BrokerProxyName(client interface{}, brokerName string, brokerID string, proxyPrefix string) string
• func LabelChangesToLabels(changes types.LabelChanges) (types.Labels, types.Labels)
• type FakeConsumer
  • func (c *FakeConsumer) Consume(ctx context.Context, notification *types.Notification)
  • func (c *FakeConsumer) GetConsumedNotifications() []*types.Notification
• type FakeResyncer
  • func (r *FakeResyncer) GetResyncCount() int
  • func (r *FakeResyncer) Resync(ctx context.Context, resyncVisibilities bool)

Functions

func BrokerProxyName

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

BrokerProxyName creates the service-manager name format for the broker. If the platform enforces any constraints via GetBrokerPlatformName, the name will first be altered accordingly.

func LabelChangesToLabels

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

LabelChangesToLabels transforms the specified label changes into two groups of labels - one for creation and one for deletion

Types

type FakeConsumer

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

func (*FakeConsumer) Consume

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

func (*FakeConsumer) GetConsumedNotifications

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

type FakeResyncer

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

func (*FakeResyncer) GetResyncCount

func (r *FakeResyncer) GetResyncCount() int

func (*FakeResyncer) Resync

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