broker

type Broker interface {
	Publisher
	Subscriber
}

type Message interface {
	GetId() string
	GetMetadata() map[string]string
	GetPayload() []byte
}

type Publisher interface {
	// Publish sends messages to a topic.
	Publish(ctx context.Context, topic string, messages ...Message) error
	// Close terminates the publisher's connection.
	Close() error
}

type Subscriber interface {
	// Subscribe returns a channel of messages for a given topic.
	Subscribe(ctx context.Context, topic string) (<-chan Message, error)
	// Close terminates the subscriber's connection.
	Close() error
}