event

Documentation

Overview

Package event mediates notification between controllers and recorder

Index

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

Types

type Action

type Action int

Action represents the kind of object change we're notifying

const (
	// Delete is the object deletion Action
	Delete Action = iota

	// Upsert is the update or create Action
	Upsert
)

type Notification

type Notification struct {
	Action Action
	Key    string
	Kind   string
	Object []byte
}

Notification conveys an object delete/upsert notification

type Notifier

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

Notifier mediates notifications between controllers and recorder

type Unbuffered

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

Unbuffered implements Notifier

func New

func New() *Unbuffered

New creates an Unbuffered

func (*Unbuffered) ReadChan

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

ReadChan returns a channel to read Notifications from

func (*Unbuffered) Send

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

Send sends a notification