handlers

Documentation

Index

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

Constants

const BROKER_PAYLOAD_ERROR = "could not extract broker payload"

const FIND_BROKER_WITH_NAME_FORMAT = "Attempting to find platform broker with name %s in platform..."

const PLATFORM_CREDENTIALS_UPDATE_ERROR = "Could not update broker platform credentials for broker (%s): %s"

const VISIBILITY_PAYLOAD_ERROR = "error validating visibility payload"

Types

type BrokerResourceNotificationsHandler

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

	DefaultBrokerUsername string
	DefaultBrokerPassword string

	ProxyPrefix string
	SMPath      string

	BrokerBlacklist          []string
	TakeoverEnabled          bool
	BrokerCredentialsEnabled 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
	BrokerClient    platform.BrokerClient
	Resyncer        reconcile.Resyncer
}

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