events

Documentation

Index

• Variables
• type Emitter
• type Event
• type EventBus
  • func NewEventBus(bufferSize uint) (EventBus, error)
• type Listener
  • func NewNeverListener() Listener
• type ListenerFactory
• type Op
• type Predicate
• type ResourceChangedEvent
• type TriggerInsightsComputationEvent

Variables

var ListenerStoppedErr = errors.New("listener closed")

Types

type Emitter

type Emitter interface {
	Send(Event)
}

type Event

type Event interface{}

type EventBus

type EventBus interface {
	Emitter
	ListenerFactory
}

func NewEventBus

func NewEventBus(bufferSize uint) (EventBus, error)

type Listener

type Listener interface {
	Recv() <-chan Event
	Close()
}

func NewNeverListener

func NewNeverListener() Listener

type ListenerFactory

type ListenerFactory interface {
	Subscribe(...Predicate) Listener
}

type Op

type Op int

const (
	Create Op = iota
	Update
	Delete
)

type Predicate

type Predicate = func(event Event) bool

type ResourceChangedEvent

type ResourceChangedEvent struct {
	Operation Op
	Type      model.ResourceType
	Key       model.ResourceKey
	TenantID  string
}

type TriggerInsightsComputationEvent

type TriggerInsightsComputationEvent struct {
	TenantID string
}