Documentation
¶
Index ¶
- Constants
- func ContextBuilder() *internal.ContextBuilder
- 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 AdminClient
- type Context
- type ErrorHandler
- type EventEvidence
- type EventLog
- type Forwarder
- type ForwarderRunner
- type LoggingService
- type Message
- type MessageContent
- type MessageHandler
- type MessageObserver
- type MessageObserverAffair
- type Producer
- type ProducerConfig
- type ReplyCode
- type UniversalOptions
- type Worker
Constants ¶
View Source
const ( StreamAsteriskID = redis.StreamAsteriskID StreamLastDeliveredID = redis.StreamLastDeliveredID StreamZeroID = redis.StreamZeroID StreamZeroOffset = redis.StreamZeroOffset StreamNeverDeliveredOffset = redis.StreamNeverDeliveredOffset )
Variables ¶
This section is empty.
Functions ¶
func ContextBuilder ¶
func ContextBuilder() *internal.ContextBuilder
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 AdminClient ¶
type AdminClient = redis.AdminClient
func NewAdminClient ¶
func NewAdminClient(opt *UniversalOptions) (*AdminClient, error)
type ErrorHandler ¶
type ErrorHandler = internal.ErrorHandler
type EventEvidence ¶
type EventEvidence = middleware.EventEvidence
type EventLog ¶
type EventLog = middleware.EventLog
type Forwarder ¶
func NewForwarder ¶
func NewForwarder(config *ProducerConfig) (*Forwarder, error)
type ForwarderRunner ¶
type ForwarderRunner = redis.ForwarderRunner
type LoggingService ¶
type LoggingService = middleware.LoggingService
type MessageContent ¶
type MessageContent = redis.MessageContent
type MessageHandler ¶
type MessageHandler = internal.MessageHandler
type MessageObserver ¶
type MessageObserver = internal.MessageObserver
type MessageObserverAffair ¶
type MessageObserverAffair = internal.MessageObserverAffair
type ProducerConfig ¶
type ProducerConfig = redis.ProducerConfig
type UniversalOptions ¶
type UniversalOptions = redis.UniversalOptions
type Worker ¶
type Worker = internal.RedisWorker
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.