nsqd

Documentation

Index

• func NewMessageHandler(consumer defs.IConsumer, provider opentelemetry.OpenTelemetryIOCInterface, ...) nsq.Handler
• type NsqProducer
  • func GetNsqProducerSingleton() (*NsqProducer, error)
  • func (n *NsqProducer) CreatePublisher(producerAddr string) (bool, error)
  • func (n *NsqProducer) Publish(ctx context.Context, topic string, body []byte) (err error)
• type NsqProducerIOCInterface
  • func GetNsqProducerIOCInterfaceSingleton() (NsqProducerIOCInterface, error)
• type ThisNsqProducer
  • func (t *ThisNsqProducer) This() NsqProducerIOCInterface

Functions

func NewMessageHandler

func NewMessageHandler(consumer defs.IConsumer, provider opentelemetry.OpenTelemetryIOCInterface, dbFactory uorm.DBFactoryIOCInterface) nsq.Handler

Types

type NsqProducer

type NsqProducer struct {
	OpenTelemetry opentelemetry.OpenTelemetryIOCInterface `singleton:""`
	// contains filtered or unexported fields
}

func GetNsqProducerSingleton

func GetNsqProducerSingleton() (*NsqProducer, error)

func (*NsqProducer) CreatePublisher

func (n *NsqProducer) CreatePublisher(producerAddr string) (bool, error)

func (*NsqProducer) Publish

func (n *NsqProducer) Publish(ctx context.Context, topic string, body []byte) (err error)

type NsqProducerIOCInterface

type NsqProducerIOCInterface interface {
	CreatePublisher(producerAddr string) (bool, error)
	Publish(ctx contextx.Context, topic string, body []byte) (err error)
}

func GetNsqProducerIOCInterfaceSingleton

func GetNsqProducerIOCInterfaceSingleton() (NsqProducerIOCInterface, error)

type ThisNsqProducer

type ThisNsqProducer struct {
}

func (*ThisNsqProducer) This

func (t *ThisNsqProducer) This() NsqProducerIOCInterface