redis

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
  • func NewAdminClient(opt *UniversalOptions) (*AdminClient, error)
• type Context
• type ErrorHandler
• type EventEvidence
• type EventLog
• type Forwarder
  • func NewForwarder(config *ProducerConfig) (*Forwarder, error)
• 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

const (
	StreamAsteriskID           = redis.StreamAsteriskID
	StreamLastDeliveredID      = redis.StreamLastDeliveredID
	StreamZeroID               = redis.StreamZeroID
	StreamZeroOffset           = redis.StreamZeroOffset
	StreamNeverDeliveredOffset = redis.StreamNeverDeliveredOffset
)

Functions

func ContextBuilder

func ContextBuilder() *internal.ContextBuilder

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 AdminClient

type AdminClient = redis.AdminClient

func NewAdminClient

func NewAdminClient(opt *UniversalOptions) (*AdminClient, error)

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 = redis.Forwarder

func NewForwarder

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

type ForwarderRunner

type ForwarderRunner = redis.ForwarderRunner

type LoggingService

type LoggingService = middleware.LoggingService

type Message

type Message = redis.Message

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 Producer

type Producer = redis.Producer

type ProducerConfig

type ProducerConfig = redis.ProducerConfig

type ReplyCode

type ReplyCode = internal.ReplyCode

type UniversalOptions

type UniversalOptions = redis.UniversalOptions

type Worker

type Worker = internal.RedisWorker