nsq

package module
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 24, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	INVALID = internal.INVALID
	UNSET   = internal.UNSET
	PASS    = internal.PASS
	FAIL    = internal.FAIL
	ABORT   = internal.ABORT
)

Variables

This section is empty.

Functions

func Startup

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

func UseErrorHandler

func UseErrorHandler(handler ErrorHandler) host.Middleware

func UseLogging

func UseLogging(service 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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL