handlers

Documentation

Index

• func BrokerProxyName(client interface{}, brokerName string, brokerID string, proxyPrefix string) string
• func LabelChangesToLabels(changes types.LabelChanges) (types.Labels, types.Labels)
• type BrokerResourceNotificationsHandler
  • func (bnh *BrokerResourceNotificationsHandler) OnCreate(ctx context.Context, notification *types.Notification)
  • func (bnh *BrokerResourceNotificationsHandler) OnDelete(ctx context.Context, notification *types.Notification)
  • func (bnh *BrokerResourceNotificationsHandler) OnUpdate(ctx context.Context, notification *types.Notification)
• type VisibilityResourceNotificationsHandler
  • func (vnh *VisibilityResourceNotificationsHandler) OnCreate(ctx context.Context, notification *types.Notification)
  • func (vnh *VisibilityResourceNotificationsHandler) OnDelete(ctx context.Context, notification *types.Notification)
  • func (vnh *VisibilityResourceNotificationsHandler) OnUpdate(ctx context.Context, notification *types.Notification)

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 BrokerResourceNotificationsHandler

type BrokerResourceNotificationsHandler struct {
	SMClient       sm.Client
	BrokerClient   platform.BrokerClient
	CatalogFetcher platform.CatalogFetcher

	ProxyPrefix string
	SMPath      string

	BrokerBlacklist []string
	TakeoverEnabled bool
}

BrokerResourceNotificationsHandler handles notifications for brokers

func (*BrokerResourceNotificationsHandler) OnCreate

func (bnh *BrokerResourceNotificationsHandler) OnCreate(ctx context.Context, notification *types.Notification)

OnCreate creates brokers from the specified notification payload by invoking the proper platform clients

func (*BrokerResourceNotificationsHandler) OnDelete

func (bnh *BrokerResourceNotificationsHandler) OnDelete(ctx context.Context, notification *types.Notification)

OnDelete deletes brokers from the provided notification payload by invoking the proper platform clients

func (*BrokerResourceNotificationsHandler) OnUpdate

func (bnh *BrokerResourceNotificationsHandler) OnUpdate(ctx context.Context, notification *types.Notification)

OnUpdate modifies brokers from the specified notification payload by invoking the proper platform clients

type VisibilityResourceNotificationsHandler

type VisibilityResourceNotificationsHandler struct {
	VisibilityClient platform.VisibilityClient

	ProxyPrefix     string
	BrokerBlacklist []string
}

VisibilityResourceNotificationsHandler handles notifications for visibilities

func (*VisibilityResourceNotificationsHandler) OnCreate

func (vnh *VisibilityResourceNotificationsHandler) OnCreate(ctx context.Context, notification *types.Notification)

OnCreate creates visibilities from the specified notification payload by invoking the proper platform clients

func (*VisibilityResourceNotificationsHandler) OnDelete

func (vnh *VisibilityResourceNotificationsHandler) OnDelete(ctx context.Context, notification *types.Notification)

OnDelete deletes visibilities from the provided notification payload by invoking the proper platform clients

func (*VisibilityResourceNotificationsHandler) OnUpdate

func (vnh *VisibilityResourceNotificationsHandler) OnUpdate(ctx context.Context, notification *types.Notification)

OnUpdate modifies visibilities from the specified notification payload by invoking the proper platform clients