service

package
v0.0.0-...-940c498 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 16, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TraceMessageOperationName = "grpc.message"
)

Variables

View Source
var (
	RequestHeadersResourceName   = "RequestHeaders"
	RequestBodyResourceName      = "RequestBody"
	RequestTrailersResourceName  = "RequestTrailers"
	ResponseHeadersResourceName  = "ResponseHeaders"
	ResponseBodyResourceName     = "ResponseBody"
	ResponseTrailersResourceName = "ResponseTrailers"
	StreamCompleteResourceName   = "StreamComplete"
)

Functions

func IgnoreCanceled

func IgnoreCanceled(err error) error

IgnoreCanceled returns nil if the error is a context.Canceled error or an io.EOF error.

Types

type ExtProcessor

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

func New

func New(options ...Option) *ExtProcessor

func (*ExtProcessor) Process

Process is the main entry point for the ExternalProcessor service. The protocol itself is based on a bidirectional gRPC stream. Envoy will send the server ProcessingRequest messages, and the server must reply with ProcessingResponse. https://www.envoyproxy.io/docs/envoy/latest/api-v3/extensions/filters/http/ext_proc/v3/ext_proc.proto#envoy-v3-api-msg-extensions-filters-http-ext-proc-v3-externalfilter

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithFilters

func WithFilters(filters ...filter.Filter) Option

func WithLogger

func WithLogger(log logr.Logger) Option

func WithTracer

func WithTracer(tracer trace.Tracer) Option

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL