ext_procv3

package
v1.36.4-20230601201642... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

View Source 
const BodyMutation_Body_case case_BodyMutation_Mutation = 1
View Source 
const BodyMutation_ClearBody_case case_BodyMutation_Mutation = 2
View Source 
const BodyMutation_Mutation_not_set_case case_BodyMutation_Mutation = 0
View Source 
const ProcessingRequest_RequestBody_case case_ProcessingRequest_Request = 4
View Source 
const ProcessingRequest_RequestHeaders_case case_ProcessingRequest_Request = 2
View Source 
const ProcessingRequest_RequestTrailers_case case_ProcessingRequest_Request = 6
View Source 
const ProcessingRequest_Request_not_set_case case_ProcessingRequest_Request = 0
View Source 
const ProcessingRequest_ResponseBody_case case_ProcessingRequest_Request = 5
View Source 
const ProcessingRequest_ResponseHeaders_case case_ProcessingRequest_Request = 3
View Source 
const ProcessingRequest_ResponseTrailers_case case_ProcessingRequest_Request = 7
View Source 
const ProcessingResponse_ImmediateResponse_case case_ProcessingResponse_Response = 7
View Source 
const ProcessingResponse_RequestBody_case case_ProcessingResponse_Response = 3
View Source 
const ProcessingResponse_RequestHeaders_case case_ProcessingResponse_Response = 1
View Source 
const ProcessingResponse_RequestTrailers_case case_ProcessingResponse_Response = 5
View Source 
const ProcessingResponse_ResponseBody_case case_ProcessingResponse_Response = 4
View Source 
const ProcessingResponse_ResponseHeaders_case case_ProcessingResponse_Response = 2
View Source 
const ProcessingResponse_ResponseTrailers_case case_ProcessingResponse_Response = 6
View Source 
const ProcessingResponse_Response_not_set_case case_ProcessingResponse_Response = 0

Variables

View Source 
var (
	CommonResponse_ResponseStatus_name = map[int32]string{
		0: "CONTINUE",
		1: "CONTINUE_AND_REPLACE",
	}
	CommonResponse_ResponseStatus_value = map[string]int32{
		"CONTINUE":             0,
		"CONTINUE_AND_REPLACE": 1,
	}
)

Enum value maps for CommonResponse_ResponseStatus.

View Source 
var File_envoy_service_ext_proc_v3_external_processor_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BodyMutation 

type BodyMutation struct {

	// Types that are valid to be assigned to Mutation:
	//
	//	*BodyMutation_Body
	//	*BodyMutation_ClearBody
	Mutation isBodyMutation_Mutation `protobuf_oneof:"mutation"`
	// contains filtered or unexported fields
}

Replace the entire message body chunk received in the corresponding HttpBody message with this new body, or clear the body.

func (*BodyMutation) ClearClearBody 

func (x *BodyMutation) ClearClearBody()

func (*BodyMutation) ClearMutation 

func (x *BodyMutation) ClearMutation()

func (*BodyMutation) Clear_Body 

func (x *BodyMutation) Clear_Body()

func (*BodyMutation) GetBody deprecated 

func (x *BodyMutation) GetBody() []byte

Deprecated: Use Get_Body instead.

func (*BodyMutation) GetClearBody 

func (x *BodyMutation) GetClearBody() bool

func (*BodyMutation) GetMutation 

func (x *BodyMutation) GetMutation() isBodyMutation_Mutation

func (*BodyMutation) Get_Body 

func (x *BodyMutation) Get_Body() []byte

func (*BodyMutation) HasClearBody 

func (x *BodyMutation) HasClearBody() bool

func (*BodyMutation) HasMutation 

func (x *BodyMutation) HasMutation() bool

func (*BodyMutation) Has_Body 

func (x *BodyMutation) Has_Body() bool

func (*BodyMutation) ProtoMessage 

func (*BodyMutation) ProtoMessage()

func (*BodyMutation) ProtoReflect 

func (x *BodyMutation) ProtoReflect() protoreflect.Message

func (*BodyMutation) Reset 

func (x *BodyMutation) Reset()

func (*BodyMutation) SetClearBody 

func (x *BodyMutation) SetClearBody(v bool)

func (*BodyMutation) Set_Body 

func (x *BodyMutation) Set_Body(v []byte)

func (*BodyMutation) String 

func (x *BodyMutation) String() string

func (*BodyMutation) WhichMutation 

func (x *BodyMutation) WhichMutation() case_BodyMutation_Mutation

type BodyMutation_Body 

type BodyMutation_Body struct {
	// The entire body to replace
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3,oneof"`
}

type BodyMutation_ClearBody 

type BodyMutation_ClearBody struct {
	// Clear the corresponding body chunk
	ClearBody bool `protobuf:"varint,2,opt,name=clear_body,json=clearBody,proto3,oneof"`
}

type BodyMutation_builder 

type BodyMutation_builder struct {

	// Fields of oneof Mutation:
	// The entire body to replace
	Body []byte
	// Clear the corresponding body chunk
	ClearBody *bool
	// contains filtered or unexported fields
}

func (BodyMutation_builder) Build 

func (b0 BodyMutation_builder) Build() *BodyMutation

type BodyResponse 

type BodyResponse struct {
	Response *CommonResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

This message must be sent in response to an HttpBody message.

func (*BodyResponse) ClearResponse 

func (x *BodyResponse) ClearResponse()

func (*BodyResponse) GetResponse 

func (x *BodyResponse) GetResponse() *CommonResponse

func (*BodyResponse) HasResponse 

func (x *BodyResponse) HasResponse() bool

func (*BodyResponse) ProtoMessage 

func (*BodyResponse) ProtoMessage()

func (*BodyResponse) ProtoReflect 

func (x *BodyResponse) ProtoReflect() protoreflect.Message

func (*BodyResponse) Reset 

func (x *BodyResponse) Reset()

func (*BodyResponse) SetResponse 

func (x *BodyResponse) SetResponse(v *CommonResponse)

func (*BodyResponse) String 

func (x *BodyResponse) String() string

type BodyResponse_builder 

type BodyResponse_builder struct {
	Response *CommonResponse
	// contains filtered or unexported fields
}

func (BodyResponse_builder) Build 

func (b0 BodyResponse_builder) Build() *BodyResponse

type CommonResponse 

type CommonResponse struct {

	// If set, provide additional direction on how the Envoy proxy should
	// handle the rest of the HTTP filter chain.
	Status CommonResponse_ResponseStatus `` /* 127-byte string literal not displayed */
	// Instructions on how to manipulate the headers. When responding to an
	// HttpBody request, header mutations will only take effect if
	// the current processing mode for the body is BUFFERED.
	HeaderMutation *HeaderMutation `protobuf:"bytes,2,opt,name=header_mutation,json=headerMutation,proto3" json:"header_mutation,omitempty"`
	// Replace the body of the last message sent to the remote server on this
	// stream. If responding to an HttpBody request, simply replace or clear
	// the body chunk that was sent with that request. Body mutations only take
	// effect in response to “body“ messages and are ignored otherwise.
	BodyMutation *BodyMutation `protobuf:"bytes,3,opt,name=body_mutation,json=bodyMutation,proto3" json:"body_mutation,omitempty"`
	// [#not-implemented-hide:]
	// Add new trailers to the message. This may be used when responding to either a
	// HttpHeaders or HttpBody message, but only if this message is returned
	// along with the CONTINUE_AND_REPLACE status.
	Trailers *v31.HeaderMap `protobuf:"bytes,4,opt,name=trailers,proto3" json:"trailers,omitempty"`
	// Clear the route cache for the current request.
	// This is necessary if the remote server
	// modified headers that are used to calculate the route.
	ClearRouteCache bool `protobuf:"varint,5,opt,name=clear_route_cache,json=clearRouteCache,proto3" json:"clear_route_cache,omitempty"`
	// contains filtered or unexported fields
}

This message contains common fields between header and body responses. [#next-free-field: 6]

func (*CommonResponse) ClearBodyMutation 

func (x *CommonResponse) ClearBodyMutation()

func (*CommonResponse) ClearHeaderMutation 

func (x *CommonResponse) ClearHeaderMutation()

func (*CommonResponse) ClearTrailers 

func (x *CommonResponse) ClearTrailers()

func (*CommonResponse) GetBodyMutation 

func (x *CommonResponse) GetBodyMutation() *BodyMutation

func (*CommonResponse) GetClearRouteCache 

func (x *CommonResponse) GetClearRouteCache() bool

func (*CommonResponse) GetHeaderMutation 

func (x *CommonResponse) GetHeaderMutation() *HeaderMutation

func (*CommonResponse) GetStatus 

func (x *CommonResponse) GetStatus() CommonResponse_ResponseStatus

func (*CommonResponse) GetTrailers 

func (x *CommonResponse) GetTrailers() *v31.HeaderMap

func (*CommonResponse) HasBodyMutation 

func (x *CommonResponse) HasBodyMutation() bool

func (*CommonResponse) HasHeaderMutation 

func (x *CommonResponse) HasHeaderMutation() bool

func (*CommonResponse) HasTrailers 

func (x *CommonResponse) HasTrailers() bool

func (*CommonResponse) ProtoMessage 

func (*CommonResponse) ProtoMessage()

func (*CommonResponse) ProtoReflect 

func (x *CommonResponse) ProtoReflect() protoreflect.Message

func (*CommonResponse) Reset 

func (x *CommonResponse) Reset()

func (*CommonResponse) SetBodyMutation 

func (x *CommonResponse) SetBodyMutation(v *BodyMutation)

func (*CommonResponse) SetClearRouteCache 

func (x *CommonResponse) SetClearRouteCache(v bool)

func (*CommonResponse) SetHeaderMutation 

func (x *CommonResponse) SetHeaderMutation(v *HeaderMutation)

func (*CommonResponse) SetStatus 

func (x *CommonResponse) SetStatus(v CommonResponse_ResponseStatus)

func (*CommonResponse) SetTrailers 

func (x *CommonResponse) SetTrailers(v *v31.HeaderMap)

func (*CommonResponse) String 

func (x *CommonResponse) String() string

type CommonResponse_ResponseStatus 

type CommonResponse_ResponseStatus int32
const (
	// Apply the mutation instructions in this message to the
	// request or response, and then continue processing the filter
	// stream as normal. This is the default.
	CommonResponse_CONTINUE CommonResponse_ResponseStatus = 0
	// Apply the specified header mutation, replace the body with the body
	// specified in the body mutation (if present), and do not send any
	// further messages for this request or response even if the processing
	// mode is configured to do so.
	//
	// When used in response to a request_headers or response_headers message,
	// this status makes it possible to either completely replace the body
	// while discarding the original body, or to add a body to a message that
	// formerly did not have one.
	//
	// In other words, this response makes it possible to turn an HTTP GET
	// into a POST, PUT, or PATCH.
	CommonResponse_CONTINUE_AND_REPLACE CommonResponse_ResponseStatus = 1
)

func (CommonResponse_ResponseStatus) Descriptor 

func (CommonResponse_ResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (CommonResponse_ResponseStatus) Enum 

func (x CommonResponse_ResponseStatus) Enum() *CommonResponse_ResponseStatus

func (CommonResponse_ResponseStatus) Number 

func (x CommonResponse_ResponseStatus) Number() protoreflect.EnumNumber

func (CommonResponse_ResponseStatus) String 

func (x CommonResponse_ResponseStatus) String() string

func (CommonResponse_ResponseStatus) Type 

func (CommonResponse_ResponseStatus) Type() protoreflect.EnumType

type CommonResponse_builder 

type CommonResponse_builder struct {

	// If set, provide additional direction on how the Envoy proxy should
	// handle the rest of the HTTP filter chain.
	Status CommonResponse_ResponseStatus
	// Instructions on how to manipulate the headers. When responding to an
	// HttpBody request, header mutations will only take effect if
	// the current processing mode for the body is BUFFERED.
	HeaderMutation *HeaderMutation
	// Replace the body of the last message sent to the remote server on this
	// stream. If responding to an HttpBody request, simply replace or clear
	// the body chunk that was sent with that request. Body mutations only take
	// effect in response to “body“ messages and are ignored otherwise.
	BodyMutation *BodyMutation
	// [#not-implemented-hide:]
	// Add new trailers to the message. This may be used when responding to either a
	// HttpHeaders or HttpBody message, but only if this message is returned
	// along with the CONTINUE_AND_REPLACE status.
	Trailers *v31.HeaderMap
	// Clear the route cache for the current request.
	// This is necessary if the remote server
	// modified headers that are used to calculate the route.
	ClearRouteCache bool
	// contains filtered or unexported fields
}

func (CommonResponse_builder) Build 

func (b0 CommonResponse_builder) Build() *CommonResponse

type GrpcStatus 

type GrpcStatus struct {

	// The actual gRPC status
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

This message specifies a gRPC status for an ImmediateResponse message.

func (*GrpcStatus) GetStatus 

func (x *GrpcStatus) GetStatus() uint32

func (*GrpcStatus) ProtoMessage 

func (*GrpcStatus) ProtoMessage()

func (*GrpcStatus) ProtoReflect 

func (x *GrpcStatus) ProtoReflect() protoreflect.Message

func (*GrpcStatus) Reset 

func (x *GrpcStatus) Reset()

func (*GrpcStatus) SetStatus 

func (x *GrpcStatus) SetStatus(v uint32)

func (*GrpcStatus) String 

func (x *GrpcStatus) String() string

type GrpcStatus_builder 

type GrpcStatus_builder struct {

	// The actual gRPC status
	Status uint32
	// contains filtered or unexported fields
}

func (GrpcStatus_builder) Build 

func (b0 GrpcStatus_builder) Build() *GrpcStatus

type HeaderMutation 

type HeaderMutation struct {

	// Add or replace HTTP headers. Attempts to set the value of
	// any “x-envoy“ header, and attempts to set the “:method“,
	// “:authority“, “:scheme“, or “host“ headers will be ignored.
	SetHeaders []*v31.HeaderValueOption `protobuf:"bytes,1,rep,name=set_headers,json=setHeaders,proto3" json:"set_headers,omitempty"`
	// Remove these HTTP headers. Attempts to remove system headers --
	// any header starting with “:“, plus “host“ -- will be ignored.
	RemoveHeaders []string `protobuf:"bytes,2,rep,name=remove_headers,json=removeHeaders,proto3" json:"remove_headers,omitempty"`
	// contains filtered or unexported fields
}

Change HTTP headers or trailers by appending, replacing, or removing headers.

func (*HeaderMutation) GetRemoveHeaders 

func (x *HeaderMutation) GetRemoveHeaders() []string

func (*HeaderMutation) GetSetHeaders 

func (x *HeaderMutation) GetSetHeaders() []*v31.HeaderValueOption

func (*HeaderMutation) ProtoMessage 

func (*HeaderMutation) ProtoMessage()

func (*HeaderMutation) ProtoReflect 

func (x *HeaderMutation) ProtoReflect() protoreflect.Message

func (*HeaderMutation) Reset 

func (x *HeaderMutation) Reset()

func (*HeaderMutation) SetRemoveHeaders 

func (x *HeaderMutation) SetRemoveHeaders(v []string)

func (*HeaderMutation) SetSetHeaders 

func (x *HeaderMutation) SetSetHeaders(v []*v31.HeaderValueOption)

func (*HeaderMutation) String 

func (x *HeaderMutation) String() string

type HeaderMutation_builder 

type HeaderMutation_builder struct {

	// Add or replace HTTP headers. Attempts to set the value of
	// any “x-envoy“ header, and attempts to set the “:method“,
	// “:authority“, “:scheme“, or “host“ headers will be ignored.
	SetHeaders []*v31.HeaderValueOption
	// Remove these HTTP headers. Attempts to remove system headers --
	// any header starting with “:“, plus “host“ -- will be ignored.
	RemoveHeaders []string
	// contains filtered or unexported fields
}

func (HeaderMutation_builder) Build 

func (b0 HeaderMutation_builder) Build() *HeaderMutation

type HeadersResponse 

type HeadersResponse struct {
	Response *CommonResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

This message must be sent in response to an HttpHeaders message.

func (*HeadersResponse) ClearResponse 

func (x *HeadersResponse) ClearResponse()

func (*HeadersResponse) GetResponse 

func (x *HeadersResponse) GetResponse() *CommonResponse

func (*HeadersResponse) HasResponse 

func (x *HeadersResponse) HasResponse() bool

func (*HeadersResponse) ProtoMessage 

func (*HeadersResponse) ProtoMessage()

func (*HeadersResponse) ProtoReflect 

func (x *HeadersResponse) ProtoReflect() protoreflect.Message

func (*HeadersResponse) Reset 

func (x *HeadersResponse) Reset()

func (*HeadersResponse) SetResponse 

func (x *HeadersResponse) SetResponse(v *CommonResponse)

func (*HeadersResponse) String 

func (x *HeadersResponse) String() string

type HeadersResponse_builder 

type HeadersResponse_builder struct {
	Response *CommonResponse
	// contains filtered or unexported fields
}

func (HeadersResponse_builder) Build 

func (b0 HeadersResponse_builder) Build() *HeadersResponse

type HttpBody 

type HttpBody struct {
	Body        []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	EndOfStream bool   `protobuf:"varint,2,opt,name=end_of_stream,json=endOfStream,proto3" json:"end_of_stream,omitempty"`
	// contains filtered or unexported fields
}

This message contains the message body that Envoy sends to the external server.

func (*HttpBody) GetBody 

func (x *HttpBody) GetBody() []byte

func (*HttpBody) GetEndOfStream 

func (x *HttpBody) GetEndOfStream() bool

func (*HttpBody) ProtoMessage 

func (*HttpBody) ProtoMessage()

func (*HttpBody) ProtoReflect 

func (x *HttpBody) ProtoReflect() protoreflect.Message

func (*HttpBody) Reset 

func (x *HttpBody) Reset()

func (*HttpBody) SetBody 

func (x *HttpBody) SetBody(v []byte)

func (*HttpBody) SetEndOfStream 

func (x *HttpBody) SetEndOfStream(v bool)

func (*HttpBody) String 

func (x *HttpBody) String() string

type HttpBody_builder 

type HttpBody_builder struct {
	Body        []byte
	EndOfStream bool
	// contains filtered or unexported fields
}

func (HttpBody_builder) Build 

func (b0 HttpBody_builder) Build() *HttpBody

type HttpHeaders 

type HttpHeaders struct {

	// The HTTP request headers. All header keys will be
	// lower-cased, because HTTP header keys are case-insensitive.
	Headers *v31.HeaderMap `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers,omitempty"`
	// [#not-implemented-hide:]
	// The values of properties selected by the “request_attributes“
	// or “response_attributes“ list in the configuration. Each entry
	// in the list is populated
	// from the standard :ref:`attributes <arch_overview_attributes>`
	// supported across Envoy.
	Attributes map[string]*structpb.Struct `` /* 147-byte string literal not displayed */
	// If true, then there is no message body associated with this
	// request or response.
	EndOfStream bool `protobuf:"varint,3,opt,name=end_of_stream,json=endOfStream,proto3" json:"end_of_stream,omitempty"`
	// contains filtered or unexported fields
}

This message is sent to the external server when the HTTP request and responses are first received.

func (*HttpHeaders) ClearHeaders 

func (x *HttpHeaders) ClearHeaders()

func (*HttpHeaders) GetAttributes 

func (x *HttpHeaders) GetAttributes() map[string]*structpb.Struct

func (*HttpHeaders) GetEndOfStream 

func (x *HttpHeaders) GetEndOfStream() bool

func (*HttpHeaders) GetHeaders 

func (x *HttpHeaders) GetHeaders() *v31.HeaderMap

func (*HttpHeaders) HasHeaders 

func (x *HttpHeaders) HasHeaders() bool

func (*HttpHeaders) ProtoMessage 

func (*HttpHeaders) ProtoMessage()

func (*HttpHeaders) ProtoReflect 

func (x *HttpHeaders) ProtoReflect() protoreflect.Message

func (*HttpHeaders) Reset 

func (x *HttpHeaders) Reset()

func (*HttpHeaders) SetAttributes 

func (x *HttpHeaders) SetAttributes(v map[string]*structpb.Struct)

func (*HttpHeaders) SetEndOfStream 

func (x *HttpHeaders) SetEndOfStream(v bool)

func (*HttpHeaders) SetHeaders 

func (x *HttpHeaders) SetHeaders(v *v31.HeaderMap)

func (*HttpHeaders) String 

func (x *HttpHeaders) String() string

type HttpHeaders_builder 

type HttpHeaders_builder struct {

	// The HTTP request headers. All header keys will be
	// lower-cased, because HTTP header keys are case-insensitive.
	Headers *v31.HeaderMap
	// [#not-implemented-hide:]
	// The values of properties selected by the “request_attributes“
	// or “response_attributes“ list in the configuration. Each entry
	// in the list is populated
	// from the standard :ref:`attributes <arch_overview_attributes>`
	// supported across Envoy.
	Attributes map[string]*structpb.Struct
	// If true, then there is no message body associated with this
	// request or response.
	EndOfStream bool
	// contains filtered or unexported fields
}

func (HttpHeaders_builder) Build 

func (b0 HttpHeaders_builder) Build() *HttpHeaders

type HttpTrailers 

type HttpTrailers struct {
	Trailers *v31.HeaderMap `protobuf:"bytes,1,opt,name=trailers,proto3" json:"trailers,omitempty"`
	// contains filtered or unexported fields
}

This message contains the trailers.

func (*HttpTrailers) ClearTrailers 

func (x *HttpTrailers) ClearTrailers()

func (*HttpTrailers) GetTrailers 

func (x *HttpTrailers) GetTrailers() *v31.HeaderMap

func (*HttpTrailers) HasTrailers 

func (x *HttpTrailers) HasTrailers() bool

func (*HttpTrailers) ProtoMessage 

func (*HttpTrailers) ProtoMessage()

func (*HttpTrailers) ProtoReflect 

func (x *HttpTrailers) ProtoReflect() protoreflect.Message

func (*HttpTrailers) Reset 

func (x *HttpTrailers) Reset()

func (*HttpTrailers) SetTrailers 

func (x *HttpTrailers) SetTrailers(v *v31.HeaderMap)

func (*HttpTrailers) String 

func (x *HttpTrailers) String() string

type HttpTrailers_builder 

type HttpTrailers_builder struct {
	Trailers *v31.HeaderMap
	// contains filtered or unexported fields
}

func (HttpTrailers_builder) Build 

func (b0 HttpTrailers_builder) Build() *HttpTrailers

type ImmediateResponse 

type ImmediateResponse struct {

	// The response code to return
	Status *v32.HttpStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Apply changes to the default headers, which will include content-type.
	Headers *HeaderMutation `protobuf:"bytes,2,opt,name=headers,proto3" json:"headers,omitempty"`
	// The message body to return with the response which is sent using the
	// text/plain content type, or encoded in the grpc-message header.
	Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// If set, then include a gRPC status trailer.
	GrpcStatus *GrpcStatus `protobuf:"bytes,4,opt,name=grpc_status,json=grpcStatus,proto3" json:"grpc_status,omitempty"`
	// A string detailing why this local reply was sent, which may be included
	// in log and debug output (e.g. this populates the %RESPONSE_CODE_DETAILS%
	// command operator field for use in access logging).
	Details string `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

This message causes the filter to attempt to create a locally generated response, send it downstream, stop processing additional filters, and ignore any additional messages received from the remote server for this request or response. If a response has already started, then this will either ship the reply directly to the downstream codec, or reset the stream. [#next-free-field: 6]

func (*ImmediateResponse) ClearGrpcStatus 

func (x *ImmediateResponse) ClearGrpcStatus()

func (*ImmediateResponse) ClearHeaders 

func (x *ImmediateResponse) ClearHeaders()

func (*ImmediateResponse) ClearStatus 

func (x *ImmediateResponse) ClearStatus()

func (*ImmediateResponse) GetBody 

func (x *ImmediateResponse) GetBody() string

func (*ImmediateResponse) GetDetails 

func (x *ImmediateResponse) GetDetails() string

func (*ImmediateResponse) GetGrpcStatus 

func (x *ImmediateResponse) GetGrpcStatus() *GrpcStatus

func (*ImmediateResponse) GetHeaders 

func (x *ImmediateResponse) GetHeaders() *HeaderMutation

func (*ImmediateResponse) GetStatus 

func (x *ImmediateResponse) GetStatus() *v32.HttpStatus

func (*ImmediateResponse) HasGrpcStatus 

func (x *ImmediateResponse) HasGrpcStatus() bool

func (*ImmediateResponse) HasHeaders 

func (x *ImmediateResponse) HasHeaders() bool

func (*ImmediateResponse) HasStatus 

func (x *ImmediateResponse) HasStatus() bool

func (*ImmediateResponse) ProtoMessage 

func (*ImmediateResponse) ProtoMessage()

func (*ImmediateResponse) ProtoReflect 

func (x *ImmediateResponse) ProtoReflect() protoreflect.Message

func (*ImmediateResponse) Reset 

func (x *ImmediateResponse) Reset()

func (*ImmediateResponse) SetBody 

func (x *ImmediateResponse) SetBody(v string)

func (*ImmediateResponse) SetDetails 

func (x *ImmediateResponse) SetDetails(v string)

func (*ImmediateResponse) SetGrpcStatus 

func (x *ImmediateResponse) SetGrpcStatus(v *GrpcStatus)

func (*ImmediateResponse) SetHeaders 

func (x *ImmediateResponse) SetHeaders(v *HeaderMutation)

func (*ImmediateResponse) SetStatus 

func (x *ImmediateResponse) SetStatus(v *v32.HttpStatus)

func (*ImmediateResponse) String 

func (x *ImmediateResponse) String() string

type ImmediateResponse_builder 

type ImmediateResponse_builder struct {

	// The response code to return
	Status *v32.HttpStatus
	// Apply changes to the default headers, which will include content-type.
	Headers *HeaderMutation
	// The message body to return with the response which is sent using the
	// text/plain content type, or encoded in the grpc-message header.
	Body string
	// If set, then include a gRPC status trailer.
	GrpcStatus *GrpcStatus
	// A string detailing why this local reply was sent, which may be included
	// in log and debug output (e.g. this populates the %RESPONSE_CODE_DETAILS%
	// command operator field for use in access logging).
	Details string
	// contains filtered or unexported fields
}

func (ImmediateResponse_builder) Build 

func (b0 ImmediateResponse_builder) Build() *ImmediateResponse

type ProcessingRequest 

type ProcessingRequest struct {

	// Specify whether the filter that sent this request is running in synchronous
	// or asynchronous mode. The choice of synchronous or asynchronous mode
	// can be set in the filter configuration, and defaults to false.
	//
	//   - A value of “false“ indicates that the server must respond
	//     to this message by either sending back a matching ProcessingResponse message,
	//     or by closing the stream.
	//   - A value of “true“ indicates that the server must not respond to this
	//     message, although it may still close the stream to indicate that no more messages
	//     are needed.
	AsyncMode bool `protobuf:"varint,1,opt,name=async_mode,json=asyncMode,proto3" json:"async_mode,omitempty"`
	// Each request message will include one of the following sub-messages. Which
	// ones are set for a particular HTTP request/response depend on the
	// processing mode.
	//
	// Types that are valid to be assigned to Request:
	//
	//	*ProcessingRequest_RequestHeaders
	//	*ProcessingRequest_ResponseHeaders
	//	*ProcessingRequest_RequestBody
	//	*ProcessingRequest_ResponseBody
	//	*ProcessingRequest_RequestTrailers
	//	*ProcessingRequest_ResponseTrailers
	Request isProcessingRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

This represents the different types of messages that Envoy can send to an external processing server. [#next-free-field: 8]

func (*ProcessingRequest) ClearRequest 

func (x *ProcessingRequest) ClearRequest()

func (*ProcessingRequest) ClearRequestBody 

func (x *ProcessingRequest) ClearRequestBody()

func (*ProcessingRequest) ClearRequestHeaders 

func (x *ProcessingRequest) ClearRequestHeaders()

func (*ProcessingRequest) ClearRequestTrailers 

func (x *ProcessingRequest) ClearRequestTrailers()

func (*ProcessingRequest) ClearResponseBody 

func (x *ProcessingRequest) ClearResponseBody()

func (*ProcessingRequest) ClearResponseHeaders 

func (x *ProcessingRequest) ClearResponseHeaders()

func (*ProcessingRequest) ClearResponseTrailers 

func (x *ProcessingRequest) ClearResponseTrailers()

func (*ProcessingRequest) GetAsyncMode 

func (x *ProcessingRequest) GetAsyncMode() bool

func (*ProcessingRequest) GetRequest 

func (x *ProcessingRequest) GetRequest() isProcessingRequest_Request

func (*ProcessingRequest) GetRequestBody 

func (x *ProcessingRequest) GetRequestBody() *HttpBody

func (*ProcessingRequest) GetRequestHeaders 

func (x *ProcessingRequest) GetRequestHeaders() *HttpHeaders

func (*ProcessingRequest) GetRequestTrailers 

func (x *ProcessingRequest) GetRequestTrailers() *HttpTrailers

func (*ProcessingRequest) GetResponseBody 

func (x *ProcessingRequest) GetResponseBody() *HttpBody

func (*ProcessingRequest) GetResponseHeaders 

func (x *ProcessingRequest) GetResponseHeaders() *HttpHeaders

func (*ProcessingRequest) GetResponseTrailers 

func (x *ProcessingRequest) GetResponseTrailers() *HttpTrailers

func (*ProcessingRequest) HasRequest 

func (x *ProcessingRequest) HasRequest() bool

func (*ProcessingRequest) HasRequestBody 

func (x *ProcessingRequest) HasRequestBody() bool

func (*ProcessingRequest) HasRequestHeaders 

func (x *ProcessingRequest) HasRequestHeaders() bool

func (*ProcessingRequest) HasRequestTrailers 

func (x *ProcessingRequest) HasRequestTrailers() bool

func (*ProcessingRequest) HasResponseBody 

func (x *ProcessingRequest) HasResponseBody() bool

func (*ProcessingRequest) HasResponseHeaders 

func (x *ProcessingRequest) HasResponseHeaders() bool

func (*ProcessingRequest) HasResponseTrailers 

func (x *ProcessingRequest) HasResponseTrailers() bool

func (*ProcessingRequest) ProtoMessage 

func (*ProcessingRequest) ProtoMessage()

func (*ProcessingRequest) ProtoReflect 

func (x *ProcessingRequest) ProtoReflect() protoreflect.Message

func (*ProcessingRequest) Reset 

func (x *ProcessingRequest) Reset()

func (*ProcessingRequest) SetAsyncMode 

func (x *ProcessingRequest) SetAsyncMode(v bool)

func (*ProcessingRequest) SetRequestBody 

func (x *ProcessingRequest) SetRequestBody(v *HttpBody)

func (*ProcessingRequest) SetRequestHeaders 

func (x *ProcessingRequest) SetRequestHeaders(v *HttpHeaders)

func (*ProcessingRequest) SetRequestTrailers 

func (x *ProcessingRequest) SetRequestTrailers(v *HttpTrailers)

func (*ProcessingRequest) SetResponseBody 

func (x *ProcessingRequest) SetResponseBody(v *HttpBody)

func (*ProcessingRequest) SetResponseHeaders 

func (x *ProcessingRequest) SetResponseHeaders(v *HttpHeaders)

func (*ProcessingRequest) SetResponseTrailers 

func (x *ProcessingRequest) SetResponseTrailers(v *HttpTrailers)

func (*ProcessingRequest) String 

func (x *ProcessingRequest) String() string

func (*ProcessingRequest) WhichRequest 

func (x *ProcessingRequest) WhichRequest() case_ProcessingRequest_Request

type ProcessingRequest_RequestBody 

type ProcessingRequest_RequestBody struct {
	// A chunk of the HTTP request body. Unless “async_mode“ is true, the server must send back
	// a BodyResponse message, an ImmediateResponse message, or close the stream.
	RequestBody *HttpBody `protobuf:"bytes,4,opt,name=request_body,json=requestBody,proto3,oneof"`
}

type ProcessingRequest_RequestHeaders 

type ProcessingRequest_RequestHeaders struct {
	// Information about the HTTP request headers, as well as peer info and additional
	// properties. Unless “async_mode“ is “true“, the server must send back a
	// HeaderResponse message, an ImmediateResponse message, or close the stream.
	RequestHeaders *HttpHeaders `protobuf:"bytes,2,opt,name=request_headers,json=requestHeaders,proto3,oneof"`
}

type ProcessingRequest_RequestTrailers 

type ProcessingRequest_RequestTrailers struct {
	// The HTTP trailers for the request path. Unless “async_mode“ is “true“, the server
	// must send back a TrailerResponse message or close the stream.
	//
	// This message is only sent if the trailers processing mode is set to “SEND“.
	// If there are no trailers on the original downstream request, then this message
	// will only be sent (with empty trailers waiting to be populated) if the
	// processing mode is set before the request headers are sent, such as
	// in the filter configuration.
	RequestTrailers *HttpTrailers `protobuf:"bytes,6,opt,name=request_trailers,json=requestTrailers,proto3,oneof"`
}

type ProcessingRequest_ResponseBody 

type ProcessingRequest_ResponseBody struct {
	// A chunk of the HTTP request body. Unless “async_mode“ is “true“, the server must send back
	// a BodyResponse message or close the stream.
	ResponseBody *HttpBody `protobuf:"bytes,5,opt,name=response_body,json=responseBody,proto3,oneof"`
}

type ProcessingRequest_ResponseHeaders 

type ProcessingRequest_ResponseHeaders struct {
	// Information about the HTTP response headers, as well as peer info and additional
	// properties. Unless “async_mode“ is “true“, the server must send back a
	// HeaderResponse message or close the stream.
	ResponseHeaders *HttpHeaders `protobuf:"bytes,3,opt,name=response_headers,json=responseHeaders,proto3,oneof"`
}

type ProcessingRequest_ResponseTrailers 

type ProcessingRequest_ResponseTrailers struct {
	// The HTTP trailers for the response path. Unless “async_mode“ is “true“, the server
	// must send back a TrailerResponse message or close the stream.
	//
	// This message is only sent if the trailers processing mode is set to “SEND“.
	// If there are no trailers on the original downstream request, then this message
	// will only be sent (with empty trailers waiting to be populated) if the
	// processing mode is set before the request headers are sent, such as
	// in the filter configuration.
	ResponseTrailers *HttpTrailers `protobuf:"bytes,7,opt,name=response_trailers,json=responseTrailers,proto3,oneof"`
}

type ProcessingRequest_builder 

type ProcessingRequest_builder struct {

	// Specify whether the filter that sent this request is running in synchronous
	// or asynchronous mode. The choice of synchronous or asynchronous mode
	// can be set in the filter configuration, and defaults to false.
	//
	//   - A value of “false“ indicates that the server must respond
	//     to this message by either sending back a matching ProcessingResponse message,
	//     or by closing the stream.
	//   - A value of “true“ indicates that the server must not respond to this
	//     message, although it may still close the stream to indicate that no more messages
	//     are needed.
	AsyncMode bool

	// Fields of oneof Request:
	// Information about the HTTP request headers, as well as peer info and additional
	// properties. Unless “async_mode“ is “true“, the server must send back a
	// HeaderResponse message, an ImmediateResponse message, or close the stream.
	RequestHeaders *HttpHeaders
	// Information about the HTTP response headers, as well as peer info and additional
	// properties. Unless “async_mode“ is “true“, the server must send back a
	// HeaderResponse message or close the stream.
	ResponseHeaders *HttpHeaders
	// A chunk of the HTTP request body. Unless “async_mode“ is true, the server must send back
	// a BodyResponse message, an ImmediateResponse message, or close the stream.
	RequestBody *HttpBody
	// A chunk of the HTTP request body. Unless “async_mode“ is “true“, the server must send back
	// a BodyResponse message or close the stream.
	ResponseBody *HttpBody
	// The HTTP trailers for the request path. Unless “async_mode“ is “true“, the server
	// must send back a TrailerResponse message or close the stream.
	//
	// This message is only sent if the trailers processing mode is set to “SEND“.
	// If there are no trailers on the original downstream request, then this message
	// will only be sent (with empty trailers waiting to be populated) if the
	// processing mode is set before the request headers are sent, such as
	// in the filter configuration.
	RequestTrailers *HttpTrailers
	// The HTTP trailers for the response path. Unless “async_mode“ is “true“, the server
	// must send back a TrailerResponse message or close the stream.
	//
	// This message is only sent if the trailers processing mode is set to “SEND“.
	// If there are no trailers on the original downstream request, then this message
	// will only be sent (with empty trailers waiting to be populated) if the
	// processing mode is set before the request headers are sent, such as
	// in the filter configuration.
	ResponseTrailers *HttpTrailers
	// contains filtered or unexported fields
}

func (ProcessingRequest_builder) Build 

func (b0 ProcessingRequest_builder) Build() *ProcessingRequest

type ProcessingResponse 

type ProcessingResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*ProcessingResponse_RequestHeaders
	//	*ProcessingResponse_ResponseHeaders
	//	*ProcessingResponse_RequestBody
	//	*ProcessingResponse_ResponseBody
	//	*ProcessingResponse_RequestTrailers
	//	*ProcessingResponse_ResponseTrailers
	//	*ProcessingResponse_ImmediateResponse
	Response isProcessingResponse_Response `protobuf_oneof:"response"`
	// [#not-implemented-hide:]
	// Optional metadata that will be emitted as dynamic metadata to be consumed by the next
	// filter. This metadata will be placed in the namespace “envoy.filters.http.ext_proc“.
	DynamicMetadata *structpb.Struct `protobuf:"bytes,8,opt,name=dynamic_metadata,json=dynamicMetadata,proto3" json:"dynamic_metadata,omitempty"`
	// Override how parts of the HTTP request and response are processed
	// for the duration of this particular request/response only. Servers
	// may use this to intelligently control how requests are processed
	// based on the headers and other metadata that they see.
	ModeOverride *v3.ProcessingMode `protobuf:"bytes,9,opt,name=mode_override,json=modeOverride,proto3" json:"mode_override,omitempty"`
	// When ext_proc server receives a request message, in case it needs more
	// time to process the message, it sends back a ProcessingResponse message
	// with a new timeout value. When Envoy receives this response message,
	// it ignores other fields in the response, just stop the original timer,
	// which has the timeout value specified in
	// :ref:`message_timeout
	// <envoy_v3_api_field_extensions.filters.http.ext_proc.v3.ExternalProcessor.message_timeout>`
	// and start a new timer with this “override_message_timeout“ value and keep the
	// Envoy ext_proc filter state machine intact.
	// Has to be >= 1ms and <=
	// :ref:`max_message_timeout <envoy_v3_api_field_extensions.filters.http.ext_proc.v3.ExternalProcessor.max_message_timeout>`
	// Such message can be sent at most once in a particular Envoy ext_proc filter processing state.
	// To enable this API, one has to set “max_message_timeout“ to a number >= 1ms.
	OverrideMessageTimeout *durationpb.Duration `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

For every ProcessingRequest received by the server with the “async_mode“ field set to false, the server must send back exactly one ProcessingResponse message. [#next-free-field: 11]

func (*ProcessingResponse) ClearDynamicMetadata 

func (x *ProcessingResponse) ClearDynamicMetadata()

func (*ProcessingResponse) ClearImmediateResponse 

func (x *ProcessingResponse) ClearImmediateResponse()

func (*ProcessingResponse) ClearModeOverride 

func (x *ProcessingResponse) ClearModeOverride()

func (*ProcessingResponse) ClearOverrideMessageTimeout 

func (x *ProcessingResponse) ClearOverrideMessageTimeout()

func (*ProcessingResponse) ClearRequestBody 

func (x *ProcessingResponse) ClearRequestBody()

func (*ProcessingResponse) ClearRequestHeaders 

func (x *ProcessingResponse) ClearRequestHeaders()

func (*ProcessingResponse) ClearRequestTrailers 

func (x *ProcessingResponse) ClearRequestTrailers()

func (*ProcessingResponse) ClearResponse 

func (x *ProcessingResponse) ClearResponse()

func (*ProcessingResponse) ClearResponseBody 

func (x *ProcessingResponse) ClearResponseBody()

func (*ProcessingResponse) ClearResponseHeaders 

func (x *ProcessingResponse) ClearResponseHeaders()

func (*ProcessingResponse) ClearResponseTrailers 

func (x *ProcessingResponse) ClearResponseTrailers()

func (*ProcessingResponse) GetDynamicMetadata 

func (x *ProcessingResponse) GetDynamicMetadata() *structpb.Struct

func (*ProcessingResponse) GetImmediateResponse 

func (x *ProcessingResponse) GetImmediateResponse() *ImmediateResponse

func (*ProcessingResponse) GetModeOverride 

func (x *ProcessingResponse) GetModeOverride() *v3.ProcessingMode

func (*ProcessingResponse) GetOverrideMessageTimeout 

func (x *ProcessingResponse) GetOverrideMessageTimeout() *durationpb.Duration

func (*ProcessingResponse) GetRequestBody 

func (x *ProcessingResponse) GetRequestBody() *BodyResponse

func (*ProcessingResponse) GetRequestHeaders 

func (x *ProcessingResponse) GetRequestHeaders() *HeadersResponse

func (*ProcessingResponse) GetRequestTrailers 

func (x *ProcessingResponse) GetRequestTrailers() *TrailersResponse

func (*ProcessingResponse) GetResponse 

func (x *ProcessingResponse) GetResponse() isProcessingResponse_Response

func (*ProcessingResponse) GetResponseBody 

func (x *ProcessingResponse) GetResponseBody() *BodyResponse

func (*ProcessingResponse) GetResponseHeaders 

func (x *ProcessingResponse) GetResponseHeaders() *HeadersResponse

func (*ProcessingResponse) GetResponseTrailers 

func (x *ProcessingResponse) GetResponseTrailers() *TrailersResponse

func (*ProcessingResponse) HasDynamicMetadata 

func (x *ProcessingResponse) HasDynamicMetadata() bool

func (*ProcessingResponse) HasImmediateResponse 

func (x *ProcessingResponse) HasImmediateResponse() bool

func (*ProcessingResponse) HasModeOverride 

func (x *ProcessingResponse) HasModeOverride() bool

func (*ProcessingResponse) HasOverrideMessageTimeout 

func (x *ProcessingResponse) HasOverrideMessageTimeout() bool

func (*ProcessingResponse) HasRequestBody 

func (x *ProcessingResponse) HasRequestBody() bool

func (*ProcessingResponse) HasRequestHeaders 

func (x *ProcessingResponse) HasRequestHeaders() bool

func (*ProcessingResponse) HasRequestTrailers 

func (x *ProcessingResponse) HasRequestTrailers() bool

func (*ProcessingResponse) HasResponse 

func (x *ProcessingResponse) HasResponse() bool

func (*ProcessingResponse) HasResponseBody 

func (x *ProcessingResponse) HasResponseBody() bool

func (*ProcessingResponse) HasResponseHeaders 

func (x *ProcessingResponse) HasResponseHeaders() bool

func (*ProcessingResponse) HasResponseTrailers 

func (x *ProcessingResponse) HasResponseTrailers() bool

func (*ProcessingResponse) ProtoMessage 

func (*ProcessingResponse) ProtoMessage()

func (*ProcessingResponse) ProtoReflect 

func (x *ProcessingResponse) ProtoReflect() protoreflect.Message

func (*ProcessingResponse) Reset 

func (x *ProcessingResponse) Reset()

func (*ProcessingResponse) SetDynamicMetadata 

func (x *ProcessingResponse) SetDynamicMetadata(v *structpb.Struct)

func (*ProcessingResponse) SetImmediateResponse 

func (x *ProcessingResponse) SetImmediateResponse(v *ImmediateResponse)

func (*ProcessingResponse) SetModeOverride 

func (x *ProcessingResponse) SetModeOverride(v *v3.ProcessingMode)

func (*ProcessingResponse) SetOverrideMessageTimeout 

func (x *ProcessingResponse) SetOverrideMessageTimeout(v *durationpb.Duration)

func (*ProcessingResponse) SetRequestBody 

func (x *ProcessingResponse) SetRequestBody(v *BodyResponse)

func (*ProcessingResponse) SetRequestHeaders 

func (x *ProcessingResponse) SetRequestHeaders(v *HeadersResponse)

func (*ProcessingResponse) SetRequestTrailers 

func (x *ProcessingResponse) SetRequestTrailers(v *TrailersResponse)

func (*ProcessingResponse) SetResponseBody 

func (x *ProcessingResponse) SetResponseBody(v *BodyResponse)

func (*ProcessingResponse) SetResponseHeaders 

func (x *ProcessingResponse) SetResponseHeaders(v *HeadersResponse)

func (*ProcessingResponse) SetResponseTrailers 

func (x *ProcessingResponse) SetResponseTrailers(v *TrailersResponse)

func (*ProcessingResponse) String 

func (x *ProcessingResponse) String() string

func (*ProcessingResponse) WhichResponse 

func (x *ProcessingResponse) WhichResponse() case_ProcessingResponse_Response

type ProcessingResponse_ImmediateResponse 

type ProcessingResponse_ImmediateResponse struct {
	// If specified, attempt to create a locally generated response, send it
	// downstream, and stop processing additional filters and ignore any
	// additional messages received from the remote server for this request or
	// response. If a response has already started -- for example, if this
	// message is sent response to a “response_body“ message -- then
	// this will either ship the reply directly to the downstream codec,
	// or reset the stream.
	ImmediateResponse *ImmediateResponse `protobuf:"bytes,7,opt,name=immediate_response,json=immediateResponse,proto3,oneof"`
}

type ProcessingResponse_RequestBody 

type ProcessingResponse_RequestBody struct {
	// The server must send back this message in response to a message with
	// the “request_body“ field set.
	RequestBody *BodyResponse `protobuf:"bytes,3,opt,name=request_body,json=requestBody,proto3,oneof"`
}

type ProcessingResponse_RequestHeaders 

type ProcessingResponse_RequestHeaders struct {
	// The server must send back this message in response to a message with the
	// “request_headers“ field set.
	RequestHeaders *HeadersResponse `protobuf:"bytes,1,opt,name=request_headers,json=requestHeaders,proto3,oneof"`
}

type ProcessingResponse_RequestTrailers 

type ProcessingResponse_RequestTrailers struct {
	// The server must send back this message in response to a message with
	// the “request_trailers“ field set.
	RequestTrailers *TrailersResponse `protobuf:"bytes,5,opt,name=request_trailers,json=requestTrailers,proto3,oneof"`
}

type ProcessingResponse_ResponseBody 

type ProcessingResponse_ResponseBody struct {
	// The server must send back this message in response to a message with
	// the “response_body“ field set.
	ResponseBody *BodyResponse `protobuf:"bytes,4,opt,name=response_body,json=responseBody,proto3,oneof"`
}

type ProcessingResponse_ResponseHeaders 

type ProcessingResponse_ResponseHeaders struct {
	// The server must send back this message in response to a message with the
	// “response_headers“ field set.
	ResponseHeaders *HeadersResponse `protobuf:"bytes,2,opt,name=response_headers,json=responseHeaders,proto3,oneof"`
}

type ProcessingResponse_ResponseTrailers 

type ProcessingResponse_ResponseTrailers struct {
	// The server must send back this message in response to a message with
	// the “response_trailers“ field set.
	ResponseTrailers *TrailersResponse `protobuf:"bytes,6,opt,name=response_trailers,json=responseTrailers,proto3,oneof"`
}

type ProcessingResponse_builder 

type ProcessingResponse_builder struct {

	// Fields of oneof Response:
	// The server must send back this message in response to a message with the
	// “request_headers“ field set.
	RequestHeaders *HeadersResponse
	// The server must send back this message in response to a message with the
	// “response_headers“ field set.
	ResponseHeaders *HeadersResponse
	// The server must send back this message in response to a message with
	// the “request_body“ field set.
	RequestBody *BodyResponse
	// The server must send back this message in response to a message with
	// the “response_body“ field set.
	ResponseBody *BodyResponse
	// The server must send back this message in response to a message with
	// the “request_trailers“ field set.
	RequestTrailers *TrailersResponse
	// The server must send back this message in response to a message with
	// the “response_trailers“ field set.
	ResponseTrailers *TrailersResponse
	// If specified, attempt to create a locally generated response, send it
	// downstream, and stop processing additional filters and ignore any
	// additional messages received from the remote server for this request or
	// response. If a response has already started -- for example, if this
	// message is sent response to a “response_body“ message -- then
	// this will either ship the reply directly to the downstream codec,
	// or reset the stream.
	ImmediateResponse *ImmediateResponse
	// -- end of Response
	// [#not-implemented-hide:]
	// Optional metadata that will be emitted as dynamic metadata to be consumed by the next
	// filter. This metadata will be placed in the namespace “envoy.filters.http.ext_proc“.
	DynamicMetadata *structpb.Struct
	// Override how parts of the HTTP request and response are processed
	// for the duration of this particular request/response only. Servers
	// may use this to intelligently control how requests are processed
	// based on the headers and other metadata that they see.
	ModeOverride *v3.ProcessingMode
	// When ext_proc server receives a request message, in case it needs more
	// time to process the message, it sends back a ProcessingResponse message
	// with a new timeout value. When Envoy receives this response message,
	// it ignores other fields in the response, just stop the original timer,
	// which has the timeout value specified in
	// :ref:`message_timeout
	// <envoy_v3_api_field_extensions.filters.http.ext_proc.v3.ExternalProcessor.message_timeout>`
	// and start a new timer with this “override_message_timeout“ value and keep the
	// Envoy ext_proc filter state machine intact.
	// Has to be >= 1ms and <=
	// :ref:`max_message_timeout <envoy_v3_api_field_extensions.filters.http.ext_proc.v3.ExternalProcessor.max_message_timeout>`
	// Such message can be sent at most once in a particular Envoy ext_proc filter processing state.
	// To enable this API, one has to set “max_message_timeout“ to a number >= 1ms.
	OverrideMessageTimeout *durationpb.Duration
	// contains filtered or unexported fields
}

func (ProcessingResponse_builder) Build 

func (b0 ProcessingResponse_builder) Build() *ProcessingResponse

type TrailersResponse 

type TrailersResponse struct {

	// Instructions on how to manipulate the trailers
	HeaderMutation *HeaderMutation `protobuf:"bytes,1,opt,name=header_mutation,json=headerMutation,proto3" json:"header_mutation,omitempty"`
	// contains filtered or unexported fields
}

This message must be sent in response to an HttpTrailers message.

func (*TrailersResponse) ClearHeaderMutation 

func (x *TrailersResponse) ClearHeaderMutation()

func (*TrailersResponse) GetHeaderMutation 

func (x *TrailersResponse) GetHeaderMutation() *HeaderMutation

func (*TrailersResponse) HasHeaderMutation 

func (x *TrailersResponse) HasHeaderMutation() bool

func (*TrailersResponse) ProtoMessage 

func (*TrailersResponse) ProtoMessage()

func (*TrailersResponse) ProtoReflect 

func (x *TrailersResponse) ProtoReflect() protoreflect.Message

func (*TrailersResponse) Reset 

func (x *TrailersResponse) Reset()

func (*TrailersResponse) SetHeaderMutation 

func (x *TrailersResponse) SetHeaderMutation(v *HeaderMutation)

func (*TrailersResponse) String 

func (x *TrailersResponse) String() string

type TrailersResponse_builder 

type TrailersResponse_builder struct {

	// Instructions on how to manipulate the trailers
	HeaderMutation *HeaderMutation
	// contains filtered or unexported fields
}

func (TrailersResponse_builder) Build 

func (b0 TrailersResponse_builder) Build() *TrailersResponse

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.