eventbus

Documentation

Index

• Constants
• type EventBus
  • func NewEventBus(nodeID string, dsn string, log *zap.SugaredLogger) *EventBus
  • func (bus *EventBus) Start() error
  • func (bus *EventBus) Stop() error
  • func (bus *EventBus) Subscribe(channel string, fn func(data []byte))
• type EventPayload

Constants

const (
	EventInvalidation = "invalidation"
)

Types

type EventBus

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

func NewEventBus

func NewEventBus(nodeID string, dsn string, log *zap.SugaredLogger) *EventBus

func (*EventBus) Start

func (bus *EventBus) Start() error

func (*EventBus) Stop

func (bus *EventBus) Stop() error

func (*EventBus) Subscribe

func (bus *EventBus) Subscribe(channel string, fn func(data []byte))

type EventPayload

type EventPayload struct {
	Event string          `json:"event"`
	Data  json.RawMessage `json:"data"`
	Time  int64           `json:"time"`
	Node  string          `json:"node"`
}