nsqproducer

README

Package nsqproducer v1.1.2

nsqproducer is a private package used by nsqlbproducer. It should NEVER be directly used! Please use the nsqlbproducer package.

nsqproducer contains the code to publish a message to a single nsqd instance. This is not good for high availability.

Documentation

Index

• func NsqConfigFromEnv(E map[string]string) (*nsq.Config, error)
• type NsqMessageSerialize
• type NsqProducer
  • func FromEnv() (*NsqProducer, error)
  • func New(opts ProducerOpts) (*NsqProducer, error)
  • func (p *NsqProducer) DeferredPublish(ctx context.Context, topic string, delay int64, message NsqMessageSerialize) error
  • func (p *NsqProducer) Ping() error
  • func (p *NsqProducer) Publish(ctx context.Context, topic string, message NsqMessageSerialize) error
  • func (p *NsqProducer) Stop()
• type Producer
• type ProducerOpts
• type WithLoggableFields

Functions

func NsqConfigFromEnv

func NsqConfigFromEnv(E map[string]string) (*nsq.Config, error)

Types

type NsqMessageSerialize

type NsqMessageSerialize struct {
	At      int64       `json:"at"`
	Type    string      `json:"type"`
	Payload interface{} `json:"payload"`

	// Automatically set by context if existing, generated otherwise
	RequestID string `json:"request_id"`
}

type NsqProducer

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

func FromEnv

func FromEnv() (*NsqProducer, error)

func New

func New(opts ProducerOpts) (*NsqProducer, error)

func (*NsqProducer) DeferredPublish

func (p *NsqProducer) DeferredPublish(ctx context.Context, topic string, delay int64, message NsqMessageSerialize) error

func (*NsqProducer) Ping

func (p *NsqProducer) Ping() error

func (*NsqProducer) Publish

func (p *NsqProducer) Publish(ctx context.Context, topic string, message NsqMessageSerialize) error

func (*NsqProducer) Stop

func (p *NsqProducer) Stop()

type Producer

type Producer interface {
	Publish(ctx context.Context, topic string, message NsqMessageSerialize) error
	DeferredPublish(ctx context.Context, topic string, delay int64, message NsqMessageSerialize) error
	Stop()
}

type ProducerOpts

type ProducerOpts struct {
	Host       string
	Port       string
	NsqConfig  *nsq.Config
	SkipLogSet map[string]bool
}

type WithLoggableFields

type WithLoggableFields interface {
	LoggableFields() logrus.Fields
}