libmq

Documentation

Index

• Variables
• type MQ
  • func NewMQ(c *conf.MQ, app *libapp.Settings) (*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 Topic
• type TopicImpl
  • func NewTopic[T any](topic string, 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]) 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(c *conf.MQ, app *libapp.Settings) (*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 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, 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]) Publish

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

func (*TopicImpl[T]) SetMQ

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