messagequeue

type Consumer interface {
	Consume(ctx context.Context, stopChan chan bool, errors chan error)
}

type ConsumerFunc func(context.Context, []byte) error

type ConsumerProvider interface {
	ProvideConsumer(ctx context.Context, topic string, handlerFunc ConsumerFunc) (Consumer, error)
}

type Publisher interface {
	// Stop halts all publishing.
	Stop()
	// Publish writes a message onto a message queue.
	Publish(ctx context.Context, data any) error
	// PublishAsync writes a message onto a message queue, but logs any encountered errors instead of returning them.
	PublishAsync(ctx context.Context, data any)
}

type PublisherProvider interface {
	Close()
	Ping(ctx context.Context) error
	ProvidePublisher(ctx context.Context, topic string) (Publisher, error)
}