stream

Documentation

Index

• type EventDataHandler
  • func NewEventDataHandler(w provider.Writer, pr *provider.ParserRegistry) *EventDataHandler
  • func (h *EventDataHandler) Handle(ctx context.Context, payload []byte, headers map[string][]string) error
• type HandlerFunc

Types

type EventDataHandler

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

EventDataHandler is a handler for event data.

func NewEventDataHandler

func NewEventDataHandler(w provider.Writer, pr *provider.ParserRegistry) *EventDataHandler

NewEventDataHandler create a new handler for event data.

func (*EventDataHandler) Handle

func (h *EventDataHandler) Handle(ctx context.Context, payload []byte, headers map[string][]string) error

Handle handles all events that come.

type HandlerFunc

type HandlerFunc func(ctx context.Context, payload []byte, headers map[string][]string) error

Handler is the interface that must be implemented by the handler.