informers

Documentation

Index

• func EventType(name string) events.EventType
• func Filter(n *Notification, reducer func(n *Notification) bool) bool
• func Reduce(req *events.WatchRequest) func(n *Notification) bool
• func ResourceType(name string) events.ResourceType
• type Informer
  • func New() Informer
• type Notification
  • func (n *Notification) Prefix()
  • func (n Notification) ToEvent() (*events.Event, error)

Functions

func EventType

func EventType(name string) events.EventType

EventType returns events.EventType for a given key

func Filter

func Filter(n *Notification, reducer func(n *Notification) bool) bool

Filter a notification based on given reducer.

func Reduce

func Reduce(req *events.WatchRequest) func(n *Notification) bool

Reduce returns a closure to filter notifications.

func ResourceType

func ResourceType(name string) events.ResourceType

ResourceType returns events.ResourceType for a given key

Types

type Informer

type Informer interface {
	Start(ctx context.Context, req *events.WatchRequest, fn func(e *events.Event) error) error
}

Informer is the base informer

func New

func New() Informer

New returns an instance of event informer

type Notification

type Notification struct {
	ID           string      `json:"id,omitempty"`
	ResourceID   string      `json:"resource_id,omitempty"`
	ResourceType string      `json:"resource_type,omitempty"`
	EventType    string      `json:"event_type,omitempty"`
	Data         interface{} `json:"data,omitempty"`
	CreatedAt    *time.Time  `json:"created_at,omitempty"`
}

Notification represents an event notification

func (*Notification) Prefix

func (n *Notification) Prefix()

Prefix adds prefix to notification's resource and event type

func (Notification) ToEvent

func (n Notification) ToEvent() (*events.Event, error)

ToEvent converts a notification into events.Event type