utils

package
Version: v0.11.20 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

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