internal

Documentation

Index

• type MessageQueue
  • func NewMessageQueue(kafkaMQ miface.MessageQueue, natsMQ miface.MessageQueue, ...) *MessageQueue
  • func (m *MessageQueue) Publish(topic string, opts ...miface.PubOption) error
  • func (m *MessageQueue) Subscribe(ctx context.Context, topic string, handler miface.SubResponseHandler, ...) (miface.Subscription, error)

Types

type MessageQueue

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

func NewMessageQueue

func NewMessageQueue(
	kafkaMQ miface.MessageQueue,
	natsMQ miface.MessageQueue,
	nsqMQ miface.MessageQueue,
	localMQ miface.MessageQueue,
) *MessageQueue

func (*MessageQueue) Publish

func (m *MessageQueue) Publish(topic string, opts ...miface.PubOption) error

func (*MessageQueue) Subscribe

func (m *MessageQueue) Subscribe(
	ctx context.Context,
	topic string,
	handler miface.SubResponseHandler,
	opts ...miface.SubOption,
) (miface.Subscription, error)