tap

Documentation

Index

• func NewTapService(msgService messaging.MessagingService, registrations []TapHandlerRegistration) (envoy_v3_ext_proc_pb.ExternalProcessorServer, error)
• type TapHandler
• type TapHandlerChain
• type TapHandlerRegistration
  • func NewTapEventPublisherRegistration(msgService messaging.MessagingService) TapHandlerRegistration

Functions

func NewTapService

func NewTapService(msgService messaging.MessagingService,
	registrations []TapHandlerRegistration) (envoy_v3_ext_proc_pb.ExternalProcessorServer, error)

Types

type TapHandler

type TapHandler interface {
	HandleRequestHeaders(context.Context,
		*envoy_v3_ext_proc_pb.ProcessingRequest_RequestHeaders) error
	HandleResponseHeaders(context.Context,
		*envoy_v3_ext_proc_pb.ProcessingRequest_ResponseHeaders) error
}

type TapHandlerChain

type TapHandlerChain struct {
	Handlers []TapHandlerRegistration
}

type TapHandlerRegistration

type TapHandlerRegistration struct {
	ContinueOnError bool
	Handler         TapHandler
}

func NewTapEventPublisherRegistration

func NewTapEventPublisherRegistration(msgService messaging.MessagingService) TapHandlerRegistration