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.3

Nov 29, 2024

Changes in this version

+ var NoopEventLogSingleton = NoopEventLog(0)

+ var NoopLoggingServiceSingleton = NoopLoggingService

+ type CompositeEventLog struct

+ func (l CompositeEventLog) Flush()

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

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

+ func (l CompositeEventLog) OnProcessMessageComplete(message *nsq.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 NoopEventLog int

+ func (n NoopEventLog) Flush()

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

+ func (n NoopEventLog) OnProcessMessage(message *nsq.Message)

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

+ type NoopLoggingService struct

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

+ func (n NoopLoggingService) CreateEventLog(ev EventEvidence) EventLog

v0.3.2

Oct 31, 2024

v0.3.1

Oct 31, 2024

v0.3.0

Jul 7, 2024

v0.2.0

Sep 24, 2023

Changes in this version

+ const INVALID_MESSAGE_HANDLER_TOPIC_SYMBOL

+ const OPT_OFF

+ const OPT_ON

+ const TAG_OPT_EXPAND_ENV

+ const TAG_TOPIC

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

+ 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) Topic() 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 *nsq.Message, state internal.ProcessingState, ...) error

+ 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 TracingMiddleware struct

+ Enabled bool

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

v0.1.1

Oct 2, 2022

v0.1.0

Jun 21, 2022