Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

middleware

package

Go to main page

Versions in this module

v0

v0.3.0

May 14, 2024

v0.2.2

Sep 7, 2023

Changes in this version

+ var TAG_OPT_MESSAGE_STATE_KEY_PREFIX = "@MessageStateKeyPrefix"

v0.2.2-alpha.20240430101832

Apr 30, 2024

v0.2.1

Aug 4, 2023

v0.2.0

Aug 4, 2023

Changes in this version

+ const INVALID_MESSAGE_HANDLER_TOPIC_SYMBOL

+ var NoopEventLogSingleton = NoopEventLog(0)

+ var NoopLoggingServiceSingleton = NoopLoggingService

+ var TAG_OFFSET = "offset"

+ var TAG_OPT_EXPAND_ENV = "@ExpandEnv"

+ var TAG_STREAM = "stream"

+ func StreamTagResolve(fieldname, token string) (*structproto.Tag, error)

+ type CompositeEventLog struct

+ func (l CompositeEventLog) Flush()

+ func (l CompositeEventLog) OnError(message *redis.Message, err interface{}, stackTrace []byte)

+ func (l CompositeEventLog) OnProcessMessage(message *redis.Message)

+ func (l CompositeEventLog) OnProcessMessageComplete(message *redis.Message, reply internal.ReplyCode)

+ type CompositeLoggingService struct

+ func NewCompositeLoggingService(services ...LoggingService) *CompositeLoggingService

+ func (s *CompositeLoggingService) ConfigureLogger(l *log.Logger)

+ func (s *CompositeLoggingService) CreateEventLog(ev EventEvidence) EventLog

+ type ConfigureInvalidMessageHandleProc func(handler internal.MessageHandler)

+ type ConfigureStream func(stream internal.StreamOffset)

+ type ErrorHandlerMiddleware struct

+ Handler ErrorHandler

+ func (m *ErrorHandlerMiddleware) Init(app *host.AppModule)

+ type EventEvidence struct

+ func (e EventEvidence) ProcessingSpanID() trace.SpanID

+ func (e EventEvidence) ProcessingTraceID() trace.TraceID

+ func (e EventEvidence) Stream() string

+ type EventLog interface

+ Flush func()

+ OnError func(message *internal.Message, err interface{}, stackTrace []byte)

+ OnProcessMessage func(message *internal.Message)

+ OnProcessMessageComplete func(message *internal.Message, reply internal.ReplyCode)

+ type LoggingHandleModule struct

+ func (*LoggingHandleModule) CanSetSuccessor() bool

+ func (*LoggingHandleModule) OnInitComplete()

+ func (*LoggingHandleModule) OnStart(ctx context.Context) error

+ func (*LoggingHandleModule) OnStop(ctx context.Context) error

+ func (m *LoggingHandleModule) ProcessMessage(ctx *internal.Context, message *redis.Message, state internal.ProcessingState, ...)

+ func (m *LoggingHandleModule) SetSuccessor(successor internal.MessageHandleModule)

+ type LoggingMiddleware struct

+ LoggingService LoggingService

+ func (m *LoggingMiddleware) Init(app *host.AppModule)

+ type LoggingService interface

+ ConfigureLogger func(l *log.Logger)

+ CreateEventLog func(ev EventEvidence) EventLog

+ type MessageHandlerBinder struct

+ func (b *MessageHandlerBinder) Bind(field structproto.FieldInfo, target reflect.Value) error

+ func (b *MessageHandlerBinder) Deinit(context *structproto.StructProtoContext) error

+ func (b *MessageHandlerBinder) Init(context *structproto.StructProtoContext) error

+ type MessageManagerBinder struct

+ func (b *MessageManagerBinder) Bind(field structproto.FieldInfo, rv reflect.Value) error

+ func (b *MessageManagerBinder) Deinit(context *structproto.StructProtoContext) error

+ func (b *MessageManagerBinder) Init(context *structproto.StructProtoContext) error

+ type MessageManagerMiddleware struct

+ MessageManager interface{}

+ func (m *MessageManagerMiddleware) Init(app *host.AppModule)

+ type MessageObserverBinder struct

+ func (*MessageObserverBinder) Init(context *structproto.StructProtoContext) error

+ func (b *MessageObserverBinder) Bind(field structproto.FieldInfo, target reflect.Value) error

+ func (b *MessageObserverBinder) Deinit(context *structproto.StructProtoContext) error

+ type MessageObserverManagerBinder struct

+ func (*MessageObserverManagerBinder) Deinit(context *structproto.StructProtoContext) error

+ func (*MessageObserverManagerBinder) Init(context *structproto.StructProtoContext) error

+ func (b *MessageObserverManagerBinder) Bind(field structproto.FieldInfo, rv reflect.Value) error

+ type MessageObserverManagerMiddleware struct

+ MessageObserverManager interface{}

+ func (m *MessageObserverManagerMiddleware) Init(app *host.AppModule)

+ type NoopEventLog int

+ func (NoopEventLog) Flush()

+ func (NoopEventLog) OnError(*redis.Message, interface{}, []byte)

+ func (NoopEventLog) OnProcessMessage(*redis.Message)

+ func (NoopEventLog) OnProcessMessageComplete(*redis.Message, internal.ReplyCode)

+ type NoopLoggingService struct

+ func (NoopLoggingService) ConfigureLogger(*log.Logger)

+ func (NoopLoggingService) CreateEventLog(EventEvidence) EventLog

+ type TracingMiddleware struct

+ Enabled bool

+ func (m *TracingMiddleware) Init(app *host.AppModule)

v0.1.1

Oct 2, 2022

v0.1.0

Jun 23, 2022