handlers

Documentation

Index

• type MessageHandlerFactory
  • func NewMessageHandlerFactory(opts *opts.Options, tracer *trc.Tracer) *MessageHandlerFactory
  • func (mhf *MessageHandlerFactory) NewMsgHandler(sub *v1alpha1.Subscription, opts *opts.Options, ...) func(msg *stan.Msg)

Types

type MessageHandlerFactory

type MessageHandlerFactory struct {
	// contains filtered or unexported fields
}

func NewMessageHandlerFactory

func NewMessageHandlerFactory(opts *opts.Options, tracer *trc.Tracer) *MessageHandlerFactory

func (*MessageHandlerFactory) NewMsgHandler

func (mhf *MessageHandlerFactory) NewMsgHandler(sub *v1alpha1.Subscription, opts *opts.Options, requestProvider common.RequestProvider) func(msg *stan.Msg)