Versions in this module Expand all Collapse all v0 v0.4.0 May 8, 2022 Changes in this version + type AckIndication struct + Consumer string + SeqNum AckSeqNum + Stream string + func (m AckIndication) String() string + type AckSeqNum struct + Consumer uint64 + Stream uint64 + type AlertOnErrorCB func(err error) + type ForwardMessageHandlerCB func(ctxt context.Context, msg *nats.Msg) error + type JetStreamACKBroadcaster interface + BroadcastACK func(ctxt context.Context, ack AckIndication) error + func GetJetStreamACKBroadcaster(natsClient *core.NatsClient, instance string) (JetStreamACKBroadcaster, error) + type JetStreamACKReceiver interface + SubscribeForACKs func(wg *sync.WaitGroup, handler JetStreamAckHandler) error + type JetStreamAckHandler func(context.Context, AckIndication) + type JetStreamInflightMsgProcessor interface + HandlerMsgACK func(callCtxt context.Context, ack AckIndication, blocking bool) error + RecordInflightMessage func(callCtxt context.Context, msg *nats.Msg, blocking bool) error + type JetStreamPublisher interface + Publish func(ctxt context.Context, subject string, msg []byte) error + func GetJetStreamPublisher(natsClient *core.NatsClient, instance string) (JetStreamPublisher, error) + type JetStreamPushSubscriber interface + StartReading func(forwardCB ForwardMessageHandlerCB, errorCB AlertOnErrorCB, wg *sync.WaitGroup) error + type MessageDispatcher interface + Start func(msgOutput ForwardMessageHandlerCB, errorCB AlertOnErrorCB) error + func GetPushMessageDispatcher(ctxt context.Context, natsClient *core.NatsClient, ...) (MessageDispatcher, error) + type MsgToDeliver struct + Consumer string + Message []byte + Sequence MsgToDeliverSeq + Stream string + Subject string + func ConvertJSMessageDeliver(subject string, msg *nats.Msg) (MsgToDeliver, error) + func (m MsgToDeliver) String() string + type MsgToDeliverSeq struct + Consumer uint64 + Stream uint64
Go to main page