events

Documentation

Index

• type Event
• type Events
  • func NewEventsSvc(ps *pubsub.PubSub, tm *taskmanager.TaskManager) (Events, error)
• type Factory
• type Handle
• type Message

Types

type Event

type Event interface {
	Message
	Topic() string
}

type Events

type Events interface {
	RegisterHandler(Factory, Handle)
	Broadcast(context.Context, Event) error
}

func NewEventsSvc

func NewEventsSvc(ps *pubsub.PubSub, tm *taskmanager.TaskManager) (Events, error)

type Factory

type Factory func() Event

type Handle

type Handle func(Event)

type Message

type Message interface {
	Marshal() ([]byte, error)
	Unmarshal([]byte) error
}