libmq

Documentation

Index

• Variables
• type MQ
  • func NewMQ() (*MQ, func(), error)
  • func (a *MQ) Publish(ctx context.Context, topic string, payload []byte) error
  • func (a *MQ) RegisterTopic(topic Topic) error
  • func (a *MQ) Start(ctx context.Context) error
  • func (a *MQ) Stop(ctx context.Context) error
• type MQLogger
  • func (l *MQLogger) Debug(msg string, fields watermill.LogFields)
  • func (l *MQLogger) Error(msg string, err error, fields watermill.LogFields)
  • func (l *MQLogger) Info(msg string, fields watermill.LogFields)
  • func (l *MQLogger) Trace(msg string, fields watermill.LogFields)
  • func (l *MQLogger) With(fields watermill.LogFields) watermill.LoggerAdapter
• type Topic
• type TopicImpl
  • func NewTopic[T any](topic string, payloadFunc func() T, ...) *TopicImpl[T]
  • func (t *TopicImpl[T]) Consume(ctx context.Context, i []byte) error
  • func (t *TopicImpl[T]) Name() string
  • func (t *TopicImpl[T]) Payload() T
  • func (t *TopicImpl[T]) Publish(ctx context.Context, i T) error
  • func (t *TopicImpl[T]) SetMQ(mq *MQ)

Variables

var ProviderSet = wire.NewSet(NewMQ)

Types

type MQ

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

func NewMQ

func NewMQ() (*MQ, func(), error)

func (*MQ) Publish

func (a *MQ) Publish(ctx context.Context, topic string, payload []byte) error

func (*MQ) RegisterTopic

func (a *MQ) RegisterTopic(topic Topic) error

func (*MQ) Start

func (a *MQ) Start(ctx context.Context) error

func (*MQ) Stop

func (a *MQ) Stop(ctx context.Context) error

type MQLogger

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

func (*MQLogger) Debug

func (l *MQLogger) Debug(msg string, fields watermill.LogFields)

func (*MQLogger) Error

func (l *MQLogger) Error(msg string, err error, fields watermill.LogFields)

func (*MQLogger) Info

func (l *MQLogger) Info(msg string, fields watermill.LogFields)

func (*MQLogger) Trace

func (l *MQLogger) Trace(msg string, fields watermill.LogFields)

func (*MQLogger) With

func (l *MQLogger) With(fields watermill.LogFields) watermill.LoggerAdapter

type Topic

type Topic interface {
	Name() string
	Consume(context.Context, []byte) error
	SetMQ(*MQ)
}

type TopicImpl

type TopicImpl[T any] struct {
	// contains filtered or unexported fields
}

func NewTopic

func NewTopic[T any](topic string, payloadFunc func() T, consumerFunc func(context.Context, T) error) *TopicImpl[T]

func (*TopicImpl[T]) Consume

func (t *TopicImpl[T]) Consume(ctx context.Context, i []byte) error

func (*TopicImpl[T]) Name

func (t *TopicImpl[T]) Name() string

func (*TopicImpl[T]) Payload

func (t *TopicImpl[T]) Payload() T

func (*TopicImpl[T]) Publish

func (t *TopicImpl[T]) Publish(ctx context.Context, i T) error

func (*TopicImpl[T]) SetMQ

func (t *TopicImpl[T]) SetMQ(mq *MQ)