Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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)
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.