keel

Documentation

Index

• Constants
• Variables
• type Subscriber
  • 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
• type SubscriberMiddleware
• type SubscriberOption
  • func SubscriberWithLogger(fields ...zap.Field) SubscriberOption
  • func SubscriberWithMiddlewares(v ...SubscriberMiddleware) SubscriberOption
  • func SubscriberWithRequireEventName() SubscriberOption
  • func SubscriberWithUUIDFunc(v func() string) SubscriberOption

Constants

const (
	MetadataEventName = "X-Event-Name"
)

Variables

var (
	ErrMissingEventName = errors.New("missing event name")
	ErrContextCanceled  = errors.New("request stopped without ACK received")
	ErrMessageNacked    = errors.New("message nacked")
	ErrClosed           = errors.New("subscriber already closed")
)

Types

type Subscriber

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

func NewSubscriber

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

func (*Subscriber) Close

func (s *Subscriber) Close() error

Close closes all subscriptions with their output channels and flush offsets etc. when needed.

func (*Subscriber) ServeHTTP

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

func (*Subscriber) Subscribe

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

type SubscriberHandler

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

type SubscriberMiddleware

type SubscriberMiddleware func(next SubscriberHandler) SubscriberHandler

type SubscriberOption

type SubscriberOption func(*Subscriber)

func SubscriberWithLogger

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

func SubscriberWithMiddlewares

func SubscriberWithMiddlewares(v ...SubscriberMiddleware) SubscriberOption

func SubscriberWithRequireEventName

func SubscriberWithRequireEventName() SubscriberOption

func SubscriberWithUUIDFunc

func SubscriberWithUUIDFunc(v func() string) SubscriberOption