events

type Backend interface {
	Publisher() message.Publisher
	Subscriber() message.Subscriber
	Shutdown(ctx context.Context) error
}

type DeliveryPolicy struct {
	MaxRetries            int
	InitialBackoff        time.Duration
	MaxBackoff            time.Duration
	DeadLetterTopicSuffix string
	CloseTimeout          time.Duration
}

type NoopEngine struct{}

type Option func(*Router)

type Publisher interface {
	Publish(topic string, event []byte) error
}

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

type Subscriber interface {
	Subscribe(
		topic string,
		handler func(ctx context.Context, event []byte) error,
	) error
}

type TopicInitializer interface {
	InitializeTopic(topic string) error
}