keel

Mar 4, 2024

Changes in this version

+ const MetadataEventName

+ var ErrClosed = errors.New("subscriber already closed")

+ var ErrContextCanceled = errors.New("request stopped without ACK received")

+ var ErrMessageNacked = errors.New("message nacked")

+ var ErrMissingEventName = errors.New("missing event name")

+ type Subscriber struct

+ func NewSubscriber(l *zap.Logger, opts ...SubscriberOption) *Subscriber

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

+ type SubscriberHandler func(l *zap.Logger, r *http.Request, event *mpv2.Event) error

+ type SubscriberMiddleware func(next SubscriberHandler) SubscriberHandler

+ type SubscriberOption func(*Subscriber)

+ func SubscriberWithLogger(fields ...zap.Field) SubscriberOption

+ func SubscriberWithMiddlewares(v ...SubscriberMiddleware) SubscriberOption

+ func SubscriberWithRequireEventName() SubscriberOption

+ func SubscriberWithUUIDFunc(v func() string) SubscriberOption