Versions in this module Expand all Collapse all v1 v1.0.1 Nov 17, 2024 Changes in this version + type ConsumerManger interface + Consume func(context.Context, jetstream.Consumer, consumerMessageHandler) error + NewConsumer func(context.Context, func(*jetstream.ConsumerConfig) error, consumerMessageHandler) (jetstream.Consumer, error) + ReConsume func(ctx context.Context, consumerName string, msg *jetstream.RawStreamMsg) error + UpdateAllConsumerConfig func(func(*jetstream.ConsumerConfig) error, context.Context) error + func NewConsumerManger(_ context.Context, stream jetstream.Stream, consumer jetstream.Consumer, ...) (ConsumerManger, error) v1.0.0 Oct 29, 2024 Changes in this version + var DlqManage DlqManager + var ErrMsgHandlerNotExist = errors.New("msg handler not exist") + var ErrStreamNotExist = errors.New("stream not exist") + var EventManage EventManager + var TaskManage TaskManager + func UpdateTestBackOff() + type DlqManager interface + RepublishBatch func(batch int, ctx context.Context) (int, error) + type Event string + const EventRetryTriggerTask + type EventManager interface + Publish func(event Event, payload []byte) bool + Subscribe func(event Event, triggerTask Task, ...) + SubscribeToNewConsumer func(event Event, name string, handler MessageHandler) + type MessageHandler func(payload []byte) error + type MsgType interface + type RetryTriggerTask struct + Data []byte + Task Task + type Task string + type TaskManager interface + GetMessageHandler func(task Task) (MessageHandler, error) + Publish func(task Task, payload []byte) bool + Subscribe func(task Task, handler MessageHandler)
Go to main page