libmq

package

v0.0.6 Latest Latest Go to latest Published: Feb 28, 2023 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewMQ)

This section is empty.

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

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 struct {
	// contains filtered or unexported fields
}

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 interface {
	Name() string
	Consume(context.Context, []byte) error
	SetMQ(*MQ)
}

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

func NewTopic[T any](topic string, payloadFunc func() T, consumerFunc func(context.Context, T) error) *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)