events

package

v0.1.4 Latest Latest Go to latest Published: Jul 16, 2025 License: Apache-2.0 Imports: 4 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 interface {
	Emitter
	ListenerFactory
}

func NewEventBus(bufferSize uint) (EventBus, error)

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

func NewNeverListener() Listener

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

type Op int

const (
	Create Op = iota
	Update
	Delete
)

type Predicate = func(event Event) bool

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

type TriggerInsightsComputationEvent struct {
	TenantID string
}