bus

type Event[Payload proto.Message] struct {
	EventKey     EventKey
	EventPayload Payload
}

type EventFilter string

type EventKey string

type EventName string

type EventVersion int

type Publisher[Payload proto.Message] interface {
	// Publish serializes passed events to protobuf and publishes passed events in same order as it was passed to method call.
	Publish(ctx context.Context, events []Event[Payload]) error
	// Stop releases resources allocated for Publisher.
	Stop() error
}

type PublisherEndpoint string

type PublishersRegistry interface {
	// Register adds record about publisher endpoint to registry and returns unregister function which removes registered publisher from registry.
	Register(eventName EventName, eventVersion EventVersion, host string, port int) (unregister func() error, err error)
	// Watch creates watcher for publishers endpoints list updates and returns function for stop created watcher.
	Watch(eventName EventName, eventVersion EventVersion, handler func([]PublisherEndpoint)) (stop func() error, err error)
}

type Subscriber[Payload proto.Message] interface {
	// EventsChan returns channel for receiving events matched with EventFilter.
	EventsChan() <-chan Event[Payload]
	// Stop removes subscriptions and releases resources allocated for Subscriber.
	Stop() error
	// Subscribe creates subscription for EventFilter.
	Subscribe(eventFilter EventFilter) error
	// Unsubscribe removes subscription for EventFilter.
	Unsubscribe(eventFilter EventFilter) error
}