local

Documentation

Index

• type MessageQueue
  • func NewMessageQueue(logger *zap.Logger, bufferSize int64, persistent bool, isBlocked bool) *MessageQueue
  • func (m *MessageQueue) Publish(topic string, pOpts ...miface.PubOption) error
  • func (m *MessageQueue) Subscribe(ctx context.Context, topic string, handler miface.SubResponseHandler, ...) (miface.Subscription, error)
• type Subscription
  • func CreateSubscription(ctx context.Context, topic string, handler miface.SubResponseHandler, ...) (*Subscription, error)
  • func (s *Subscription) IsValid() bool
  • func (s *Subscription) Unsubscribe() error

Types

type MessageQueue

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

func NewMessageQueue

func NewMessageQueue(logger *zap.Logger, bufferSize int64, persistent bool, isBlocked bool) *MessageQueue

func (*MessageQueue) Publish

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

func (*MessageQueue) Subscribe

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

type Subscription

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

func CreateSubscription

func CreateSubscription(
	ctx context.Context,
	topic string,
	handler miface.SubResponseHandler,
	subscriber message.Subscriber,
) (*Subscription, error)

func (*Subscription) IsValid

func (s *Subscription) IsValid() bool

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe() error