interceptor

Documentation

Index

• Constants
• Variables
• type Interceptor
  • func NewRequestIDInterceptor(allowEmptyRequestID bool, logger *slog.Logger) *Interceptor
  • func (i *Interceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (i *Interceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (i *Interceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

Constants

const HeaderXRequestID = "x-request-id"

Variables

var (
	ErrorRequestIDMissing     = errors.New("x-request-id header is missing")
	ErrorFailedToSetRequestID = errors.New("failed to set x-request-id header")
	ErrorInvalidRequestID     = errors.New("invalid x-request-id provided")
)

Types

type Interceptor

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

func NewRequestIDInterceptor

func NewRequestIDInterceptor(allowEmptyRequestID bool, logger *slog.Logger) *Interceptor

NewRequestIDInterceptor creates a new Interceptor instance.

func (*Interceptor) WrapStreamingClient

func (i *Interceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient wraps a streaming client function with request ID validation.

func (*Interceptor) WrapStreamingHandler

func (i *Interceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler wraps a streaming handler function with request ID validation.

func (*Interceptor) WrapUnary

func (i *Interceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

WrapUnary wraps a unary function with request ID validation.