internal

package

Go to main page

Versions in this module

v0

v0.3.3

Nov 29, 2024

Changes in this version

+ var GlobalMessageDelegateHelper MessageDelegateHelper = MessageDelegateHelper

+ var GlobalNoopMessageDelegate nsq.MessageDelegate = NoopMessageDelegate(0)

type Context

+ func (c *Context) CatchErr(err error)

+ type MessageDelegateHelper struct

+ func (MessageDelegateHelper) IsRestricted(msg *Message) (bool, error)

+ func (MessageDelegateHelper) Restrict(msg *Message) error

+ func (MessageDelegateHelper) Unrestrict(msg *Message) error

v0.3.2

Oct 31, 2024

Changes in this version

+ func IsMessageHandler(rv reflect.Value) bool

+ func IsMessageHandlerType(rt reflect.Type) bool

type MessageHandler

+ func AsMessageHandler(rv reflect.Value) MessageHandler

type TracerManager

+ func (m *TracerManager) UndefinedTracer() *trace.SeverityTracer

v0.3.1

Oct 31, 2024

Changes in this version

type Context

+ func (c *Context) IsRecordingLog() bool

+ func (c *Context) RecordingLog(v bool)

+ func (c *Context) Status() StatusCode

type ContextHelper

+ func (ContextHelper) InjectReplyCodeSafe(ctx *Context, reply ReplyCode)

type RouteComponent

+ HandlerType reflect.Type

type Router

+ func (r Router) FindHandlerType(topic string) reflect.Type

+ type StatusCode = ReplyCode

v0.3.0

Jul 7, 2024

Changes in this version

type Context

+ func (c *Context) Pause(topic ...string) error

+ func (c *Context) Resume(topic ...string) error

v0.2.0

Sep 24, 2023

Changes in this version

+ const LOGGER_PREFIX

+ const RestrictedForwardMessage_InvalidOperation

+ const RestrictedForwardMessage_Recursive

+ var GlobalContextHelper ContextHelper = ContextHelper

+ var GlobalRestrictedMessageDelegate nsq.MessageDelegate = RestrictedMessageDelegate(0)

+ var GlobalTracerManager *TracerManager

+ var NsqWorkerLogger *log.Logger = log.New(os.Stdout, LOGGER_PREFIX, log.LstdFlags | log.Lmsgprefix)

+ var NsqWorkerModuleInstance = NsqWorkerModule

+ func StopRecursiveForwardMessageHandler(ctx *Context, msg *Message) error

+ type CompositeMessageObserver []MessageObserver

+ func (o CompositeMessageObserver) OnFinish(ctx *Context, message *nsq.Message)

+ func (o CompositeMessageObserver) OnRequeue(ctx *Context, message *nsq.Message)

+ func (o CompositeMessageObserver) OnTouch(ctx *Context, message *nsq.Message)

+ func (o CompositeMessageObserver) Type() reflect.Type

+ type Config = nsq.Config

+ type Context struct

+ Channel string

+ func (*Context) Deadline() (deadline time.Time, ok bool)

+ func (*Context) Done() <-chan struct{}

+ func (*Context) Err() error

+ func (c *Context) InvalidMessage(message *Message) error

+ func (c *Context) Logger() *log.Logger

+ func (c *Context) SetValue(key, value interface{})

+ func (c *Context) Value(key interface{}) interface{}

+ type ContextHelper struct

+ func (ContextHelper) ExtractReplyCode(ctx *Context) ReplyCode

+ func (ContextHelper) InjectReplyCode(ctx *Context, reply ReplyCode)

+ type ContextMessageDelegate struct

+ func NewContextMessageDelegate(ctx *Context) *ContextMessageDelegate

+ func (d *ContextMessageDelegate) OnFinish(msg *nsq.Message)

+ func (d *ContextMessageDelegate) OnRequeue(msg *nsq.Message, delay time.Duration, backoff bool)

+ func (d *ContextMessageDelegate) OnTouch(msg *nsq.Message)

+ type Defer struct

+ func (d *Defer) Do(do func(f Finalizer) error) error

+ type ErrorHandler func(ctx *Context, message *Message, err interface{})

+ type Finalizer struct

+ func (f Finalizer) Add(actions ...func(err interface{}))

+ type Message = nsq.Message

+ type MessageDispatcher struct

+ ErrorHandler ErrorHandler

+ InvalidMessageHandler MessageHandler

+ MessageHandleService *MessageHandleService

+ MessageObserverService *MessageObserverService

+ MessageTracerService *MessageTracerService

+ OnHostErrorProc OnHostErrorHandler

+ Router Router

+ func (d *MessageDispatcher) ProcessMessage(ctx *Context, message *Message) error

+ func (d *MessageDispatcher) Topics() []string

+ type MessageHandleModule interface

+ CanSetSuccessor func() bool

+ OnInitComplete func()

+ OnStart func(ctx context.Context) error

+ OnStop func(ctx context.Context) error

+ ProcessMessage func(ctx *Context, message *Message, state ProcessingState, recover *Recover) error

+ SetSuccessor func(successor MessageHandleModule)

+ type MessageHandleProc func(ctx *Context, message *Message) error

+ func (proc MessageHandleProc) ProcessMessage(ctx *Context, message *Message) error

+ type MessageHandleService struct

+ func NewMessageHandleService() *MessageHandleService

+ func (s *MessageHandleService) ProcessMessage(ctx *Context, message *Message, state ProcessingState, recover *Recover) error

+ func (s *MessageHandleService) Register(module MessageHandleModule)

+ type MessageHandler interface

+ ProcessMessage func(ctx *Context, message *Message) error

+ type MessageObserver interface

+ OnFinish func(ctx *Context, message *Message)

+ OnRequeue func(ctx *Context, message *Message)

+ OnTouch func(ctx *Context, message *Message)

+ Type func() reflect.Type

+ type MessageObserverAffair interface

+ MessageObserverTypes func() []reflect.Type

+ type MessageObserverService struct

+ MessageObservers map[reflect.Type]MessageObserver

+ func (s *MessageObserverService) RegisterMessageObservers(msg *Message, handlerID string)

+ func (s *MessageObserverService) UnregisterAllMessageObservers(msg *Message)

+ type MessageTracerService struct

+ Enabled bool

+ InvalidMessageHandlerComponentID string

+ TracerManager *TracerManager

+ func (s *MessageTracerService) TextMapPropagator() propagation.TextMapPropagator

+ func (s *MessageTracerService) Tracer(id string) *trace.SeverityTracer

+ type NoopMessageDelegate int

+ func (NoopMessageDelegate) OnFinish(*nsq.Message)

+ func (NoopMessageDelegate) OnRequeue(m *nsq.Message, delay time.Duration, backoff bool)

+ func (NoopMessageDelegate) OnTouch(*nsq.Message)

+ type NsqWorker struct

+ Channel string

+ Config *Config

+ HandlerConcurrency int

+ NsqAddress string

+ func (w *NsqWorker) Logger() *log.Logger

+ func (w *NsqWorker) Start(ctx context.Context)

+ func (w *NsqWorker) Stop(ctx context.Context) error

+ type NsqWorkerModule struct

+ func (NsqWorkerModule) ConfigureLogger(logflags int, w io.Writer)

+ func (NsqWorkerModule) DescribeHostType() reflect.Type

+ func (NsqWorkerModule) Init(h host.Host, app *host.AppModule)

+ func (NsqWorkerModule) InitComplete(h host.Host, app *host.AppModule)

+ type NsqWorkerRegistrar struct

+ func NewNsqWorkerRegistrar(worker *NsqWorker) *NsqWorkerRegistrar

+ func (r *NsqWorkerRegistrar) AddRouter(topic string, handler MessageHandler, handlerComponentID string)

+ func (r *NsqWorkerRegistrar) EnableTracer(enabled bool)

+ func (r *NsqWorkerRegistrar) RegisterMessageHandleModule(module MessageHandleModule)

+ func (r *NsqWorkerRegistrar) RegisterMessageObserver(v MessageObserver)

+ func (r *NsqWorkerRegistrar) SetErrorHandler(handler ErrorHandler)

+ func (r *NsqWorkerRegistrar) SetInvalidMessageHandler(handler MessageHandler)

+ func (r *NsqWorkerRegistrar) SetMessageManager(messageManager interface{})

+ type OnHostErrorHandler func(err error) (disposed bool)

+ type ProcessingState struct

+ Span *trace.SeveritySpan

+ Topic string

+ Tracer *trace.SeverityTracer

+ type Recover struct

+ func (s *Recover) Defer(catch func(err interface{})) *Defer

+ type ReplyCode int

+ const ABORT

+ const FAIL

+ const INVALID

+ const PASS

+ const UNSET

+ func (code ReplyCode) String() string

+ type RestrictedForwardMessageHandler int

+ func (h RestrictedForwardMessageHandler) ProcessMessage(ctx *Context, message *Message) error

+ type RestrictedMessageDelegate int

+ func (RestrictedMessageDelegate) OnFinish(*nsq.Message)

+ func (RestrictedMessageDelegate) OnRequeue(m *nsq.Message, delay time.Duration, backoff bool)

+ func (RestrictedMessageDelegate) OnTouch(*nsq.Message)

+ type RestrictedOperationError string

+ func (e RestrictedOperationError) Error() string

+ type RouteComponent struct

+ HandlerComponentID string

+ MessageHandler MessageHandler

+ type Router map[string]RouteComponent

+ func (r Router) Add(topic string, handler MessageHandler, handlerComponentID string)

+ func (r Router) FindHandlerComponentID(topic string) string

+ func (r Router) Get(topic string) MessageHandler

+ func (r Router) Has(topic string) bool

+ func (r Router) Remove(topic string)

+ type StdMessageHandleModule struct

+ func NewStdMessageHandleModule(dispatcher *MessageDispatcher) *StdMessageHandleModule

+ func (*StdMessageHandleModule) CanSetSuccessor() bool

+ func (*StdMessageHandleModule) OnInitComplete()

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

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

+ func (*StdMessageHandleModule) SetSuccessor(successor MessageHandleModule)

+ func (m *StdMessageHandleModule) ProcessMessage(ctx *Context, message *Message, state ProcessingState, recover *Recover) error

+ type StopError struct

+ func (e *StopError) Error() string

+ func (e *StopError) Unwrap() error

+ type TracerManager struct

+ TextMapPropagator propagation.TextMapPropagator

+ TracerProvider *trace.SeverityTracerProvider

+ func NewTraceManager() *TracerManager

+ func (m *TracerManager) GenerateManagedTracer(v interface{}) *trace.SeverityTracer

v0.1.1

Oct 2, 2022

v0.1.0

Jun 21, 2022

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