event

Documentation

Index

• type Notification
• type Notifier
• type Unbuffered
  • func New() *Unbuffered
  • func (n *Unbuffered) ReadChan() <-chan Notification
  • func (n *Unbuffered) Send(notif *Notification)

Types

type Notification

type Notification struct {
	EventType     watch.EventType
	Endpoints     *corev1.Endpoints
	ClusterName   string
	Labels        map[string]string
	EndpointsName string
}

type Notifier

type Notifier interface {
	Send(notif *Notification)
	ReadChan() <-chan Notification
}

type Unbuffered

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

func New

func New() *Unbuffered

func (*Unbuffered) ReadChan

func (n *Unbuffered) ReadChan() <-chan Notification

func (*Unbuffered) Send

func (n *Unbuffered) Send(notif *Notification)