nsq

Documentation

Index

• Constants
• func Startup(app interface{}) *host.Starter
• func UseErrorHandler(handler ErrorHandler) host.Middleware
• func UseLogging(services ...LoggingService) host.Middleware
• func UseMessageManager(messageManager interface{}) host.Middleware
• func UseMessageObserverManager(messageObserverManager interface{}) host.Middleware
• func UseTracing(enabled bool) host.Middleware
• type Config
  • func NewConfig() *Config
• type Context
• type ErrorHandler
• type EventEvidence
• type EventLog
• type Forwarder
  • func NewForwarder(config *ProducerConfig) (*Forwarder, error)
• type LoggingService
• type Message
• type MessageContent
• type MessageHandler
• type MessageObserver
• type MessageObserverAffair
• type Producer
• type ProducerConfig
• type ReplyCode
• type Worker

Constants

const (
	StatusInvalid = internal.INVALID
	StatusUnset   = internal.UNSET
	StatusPass    = internal.PASS
	StatusFail    = internal.FAIL
	StatusAbort   = internal.ABORT
)

Functions

func Startup

func Startup(app interface{}) *host.Starter

func UseErrorHandler

func UseErrorHandler(handler ErrorHandler) host.Middleware

func UseLogging

func UseLogging(services ...LoggingService) host.Middleware

func UseMessageManager

func UseMessageManager(messageManager interface{}) host.Middleware

func UseMessageObserverManager

func UseMessageObserverManager(messageObserverManager interface{}) host.Middleware

func UseTracing

func UseTracing(enabled bool) host.Middleware

Types

type Config

type Config = nsq.Config

func NewConfig

func NewConfig() *Config

type Context

type Context = internal.Context

type ErrorHandler

type ErrorHandler = internal.ErrorHandler

type EventEvidence

type EventEvidence = middleware.EventEvidence

type EventLog

type EventLog = middleware.EventLog

type Forwarder

type Forwarder = nsq.Forwarder

func NewForwarder

func NewForwarder(config *ProducerConfig) (*Forwarder, error)

type LoggingService

type LoggingService = middleware.LoggingService

type Message

type Message = nsq.Message

type MessageContent

type MessageContent = nsq.MessageContent

type MessageHandler

type MessageHandler = internal.MessageHandler

type MessageObserver

type MessageObserver = internal.MessageObserver

type MessageObserverAffair

type MessageObserverAffair = internal.MessageObserverAffair

type Producer

type Producer = nsq.Producer

type ProducerConfig

type ProducerConfig = nsq.ProducerConfig

type ReplyCode

type ReplyCode = internal.ReplyCode

type Worker

type Worker = internal.NsqWorker