handlers

Documentation

Index

• 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 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