messaging

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

type Consumer interface {
	Handle(ctx context.Context, msg Message) error
}

type Event interface {
	Name() string
}

type Message struct {
	Name string `json:"name"`
	Data []byte `json:"data"`
}

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

type Worker interface {
	Run(consumer Consumer) func(ctx context.Context, domain string, service string, topic string) error
}