mqx

Documentation

Index

• type GeneralProducer
  • func NewGeneralProducer[T any](q mq.MQ, topic string) (*GeneralProducer[T], error)
  • func (p *GeneralProducer[T]) Produce(ctx context.Context, evt T) error
• type Producer

Types

type GeneralProducer

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

func NewGeneralProducer

func NewGeneralProducer[T any](q mq.MQ, topic string) (*GeneralProducer[T], error)

func (*GeneralProducer[T]) Produce

func (p *GeneralProducer[T]) Produce(ctx context.Context, evt T) error

type Producer

type Producer[T any] interface {
	Produce(ctx context.Context, evt T) error
}