eventbus

Documentation

Index

• type Bus
  • func New(cfg config.EventsConfig, numWorkers int) Bus
• type Event
• type EventBus
  • func (b *EventBus) Publish(topic string, cameraID string, data any)
  • func (b *EventBus) Stop()

Types

type Bus

type Bus interface {
	Publish(topic string, cameraID string, data any)
	Stop()
}

func New

func New(cfg config.EventsConfig, numWorkers int) Bus

New создает новую шину событий и запускает воркеры.

type Event

type Event struct {
	ID          string `json:"id"`
	TimestampMs int64  `json:"timestamp_ms"`
	Topic       string `json:"topic"`
	CameraID    string `json:"camera_id,omitempty"`
	Data        any    `json:"data,omitempty"`
}

Event представляет единицу события в системе

type EventBus

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

func (*EventBus) Publish

func (b *EventBus) Publish(topic string, cameraID string, data any)

func (*EventBus) Stop

func (b *EventBus) Stop()