events

package

v1.8.1 Latest Latest Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

type Emitter interface {
	Send(Event)
}

type Event interface{}

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

func NewEventBus() *EventBus

func (b *EventBus) New() Listener

func (b *EventBus) Send(event Event)

type Listener interface {
	Recv(stop <-chan struct{}) (Event, error)
}

type ListenerFactory interface {
	New() Listener
}

type Op int

const (
	Create Op = iota
	Update
	Delete
)

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