notifiers

Documentation

Index

• type CronJobNotifier
  • func NewCronJobNotifier(log logr.Logger, clientset *kubernetes.Clientset, cronjobName string) (CronJobNotifier, error)
  • func (d CronJobNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error
• type EndpointNotifier
  • func NewEndpointNotifier(log logr.Logger, endpoint string) (*EndpointNotifier, error)
  • func (e EndpointNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error
• type LabelNotifier
• type LabelUpdateNotification
• type LogNotifier
  • func (l LogNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error

Types

type CronJobNotifier

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

func NewCronJobNotifier

func NewCronJobNotifier(log logr.Logger, clientset *kubernetes.Clientset, cronjobName string) (CronJobNotifier, error)

func (CronJobNotifier) Notify

func (d CronJobNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error

type EndpointNotifier

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

REST Endpoint Notifier

func NewEndpointNotifier

func NewEndpointNotifier(log logr.Logger, endpoint string) (*EndpointNotifier, error)

func (EndpointNotifier) Notify

func (e EndpointNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error

type LabelNotifier

type LabelNotifier interface {
	Notify(log logr.Logger, notification LabelUpdateNotification) error
}

type LabelUpdateNotification

type LabelUpdateNotification struct {
	Node    string            `json:"node"`
	Added   map[string]string `json:"labelsAdded"`
	Deleted []string          `json:"labelsDeleted"`
	Updated map[string]string `json:"labelsUpdated"`
}

type LogNotifier

type LogNotifier struct{}

Default log-based notifier

func (LogNotifier) Notify

func (l LogNotifier) Notify(log logr.Logger, notification LabelUpdateNotification) error