server

Documentation

Index

• type CalloutServer
  • func NewCalloutServer(config Config) *CalloutServer
  • func (s *CalloutServer) StartGRPC(service extproc.ExternalProcessorServer)
  • func (s *CalloutServer) StartHealthCheck()
  • func (s *CalloutServer) StartInsecureGRPC(service extproc.ExternalProcessorServer)
• type Config
• type GRPCCalloutService
  • func (s *GRPCCalloutService) HandleRequestBody(body *extproc.HttpBody) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) HandleRequestHeaders(headers *extproc.HttpHeaders) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) HandleRequestTrailers(trailers *extproc.HttpTrailers) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) HandleResponseBody(body *extproc.HttpBody) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) HandleResponseHeaders(headers *extproc.HttpHeaders) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) HandleResponseTrailers(trailers *extproc.HttpTrailers) (*extproc.ProcessingResponse, error)
  • func (s *GRPCCalloutService) Process(stream extproc.ExternalProcessor_ProcessServer) error
• type HandlerRegistry
• type RequestBodyHandler
• type RequestHeadersHandler
• type RequestTrailersHandler
• type ResponseBodyHandler
• type ResponseHeadersHandler
• type ResponseTrailersHandler

Types

type CalloutServer

type CalloutServer struct {
	Config Config
	Cert   tls.Certificate
}

CalloutServer represents a server that handles callouts.

func NewCalloutServer

func NewCalloutServer(config Config) *CalloutServer

NewCalloutServer creates a new CalloutServer with the given configuration.

func (*CalloutServer) StartGRPC

func (s *CalloutServer) StartGRPC(service extproc.ExternalProcessorServer)

StartGRPC starts the gRPC server with the specified service.

func (*CalloutServer) StartHealthCheck

func (s *CalloutServer) StartHealthCheck()

StartHealthCheck starts a health check server.

func (*CalloutServer) StartInsecureGRPC

func (s *CalloutServer) StartInsecureGRPC(service extproc.ExternalProcessorServer)

StartInsecureGRPC starts the gRPC server without TLS.

type Config

type Config struct {
	Address              string
	InsecureAddress      string
	HealthCheckAddress   string
	CertFile             string
	KeyFile              string
	EnableInsecureServer bool
}

Config holds the server configuration parameters.

type GRPCCalloutService

type GRPCCalloutService struct {
	extproc.UnimplementedExternalProcessorServer
	Handlers HandlerRegistry
}

GRPCCalloutService implements the gRPC ExternalProcessorServer.

func (*GRPCCalloutService) HandleRequestBody

func (s *GRPCCalloutService) HandleRequestBody(body *extproc.HttpBody) (*extproc.ProcessingResponse, error)

HandleRequestBody handles request bodies.

func (*GRPCCalloutService) HandleRequestHeaders

func (s *GRPCCalloutService) HandleRequestHeaders(headers *extproc.HttpHeaders) (*extproc.ProcessingResponse, error)

HandleRequestHeaders handles request headers.

func (*GRPCCalloutService) HandleRequestTrailers

func (s *GRPCCalloutService) HandleRequestTrailers(trailers *extproc.HttpTrailers) (*extproc.ProcessingResponse, error)

HandleRequestTrailers handles request trailers.

func (*GRPCCalloutService) HandleResponseBody

func (s *GRPCCalloutService) HandleResponseBody(body *extproc.HttpBody) (*extproc.ProcessingResponse, error)

HandleResponseBody handles response bodies.

func (*GRPCCalloutService) HandleResponseHeaders

func (s *GRPCCalloutService) HandleResponseHeaders(headers *extproc.HttpHeaders) (*extproc.ProcessingResponse, error)

HandleResponseHeaders handles response headers.

func (*GRPCCalloutService) HandleResponseTrailers

func (s *GRPCCalloutService) HandleResponseTrailers(trailers *extproc.HttpTrailers) (*extproc.ProcessingResponse, error)

HandleResponseTrailers handles response trailers.

func (*GRPCCalloutService) Process

func (s *GRPCCalloutService) Process(stream extproc.ExternalProcessor_ProcessServer) error

Process processes incoming gRPC streams.

type HandlerRegistry

type HandlerRegistry struct {
	RequestHeadersHandler   RequestHeadersHandler
	ResponseHeadersHandler  ResponseHeadersHandler
	RequestBodyHandler      RequestBodyHandler
	ResponseBodyHandler     ResponseBodyHandler
	RequestTrailersHandler  RequestTrailersHandler
	ResponseTrailersHandler ResponseTrailersHandler
}

HandlerRegistry registers various handlers.

type RequestBodyHandler

type RequestBodyHandler func(*extproc.HttpBody) (*extproc.ProcessingResponse, error)

RequestBodyHandler handles request bodies.

type RequestHeadersHandler

type RequestHeadersHandler func(*extproc.HttpHeaders) (*extproc.ProcessingResponse, error)

RequestHeadersHandler handles request headers.

type RequestTrailersHandler

type RequestTrailersHandler func(*extproc.HttpTrailers) (*extproc.ProcessingResponse, error)

RequestTrailersHandler handles request trailers.

type ResponseBodyHandler

type ResponseBodyHandler func(*extproc.HttpBody) (*extproc.ProcessingResponse, error)

ResponseBodyHandler handles response bodies.

type ResponseHeadersHandler

type ResponseHeadersHandler func(*extproc.HttpHeaders) (*extproc.ProcessingResponse, error)

ResponseHeadersHandler handles response headers.

type ResponseTrailersHandler

type ResponseTrailersHandler func(*extproc.HttpTrailers) (*extproc.ProcessingResponse, error)

ResponseTrailersHandler handles response trailers.