Versions in this module Expand all Collapse all v0 v0.0.2 Aug 8, 2024 Changes in this version + const ExternalProcessor_Process_FullMethodName + var CommonResponse_ResponseStatus_name = map[int32]string + var CommonResponse_ResponseStatus_value = map[string]int32 + var ExternalProcessor_ServiceDesc = grpc.ServiceDesc + var File_envoy_service_ext_proc_v3_external_processor_proto protoreflect.FileDescriptor + func RegisterExternalProcessorServer(s grpc.ServiceRegistrar, srv ExternalProcessorServer) + type BodyMutation struct + Mutation isBodyMutation_Mutation + func (*BodyMutation) Descriptor() ([]byte, []int) + func (*BodyMutation) ProtoMessage() + func (m *BodyMutation) GetMutation() isBodyMutation_Mutation + func (x *BodyMutation) GetBody() []byte + func (x *BodyMutation) GetClearBody() bool + func (x *BodyMutation) ProtoReflect() protoreflect.Message + func (x *BodyMutation) Reset() + func (x *BodyMutation) String() string + type BodyMutation_Body struct + Body []byte + type BodyMutation_ClearBody struct + ClearBody bool + type BodyResponse struct + Response *CommonResponse + func (*BodyResponse) Descriptor() ([]byte, []int) + func (*BodyResponse) ProtoMessage() + func (x *BodyResponse) GetResponse() *CommonResponse + func (x *BodyResponse) ProtoReflect() protoreflect.Message + func (x *BodyResponse) Reset() + func (x *BodyResponse) String() string + type CommonResponse struct + BodyMutation *BodyMutation + ClearRouteCache bool + HeaderMutation *HeaderMutation + Status CommonResponse_ResponseStatus + Trailers *v3.HeaderMap + func (*CommonResponse) Descriptor() ([]byte, []int) + func (*CommonResponse) ProtoMessage() + func (x *CommonResponse) GetBodyMutation() *BodyMutation + func (x *CommonResponse) GetClearRouteCache() bool + func (x *CommonResponse) GetHeaderMutation() *HeaderMutation + func (x *CommonResponse) GetStatus() CommonResponse_ResponseStatus + func (x *CommonResponse) GetTrailers() *v3.HeaderMap + func (x *CommonResponse) ProtoReflect() protoreflect.Message + func (x *CommonResponse) Reset() + func (x *CommonResponse) String() string + type CommonResponse_ResponseStatus int32 + const CommonResponse_CONTINUE + const CommonResponse_CONTINUE_AND_REPLACE + func (CommonResponse_ResponseStatus) Descriptor() protoreflect.EnumDescriptor + func (CommonResponse_ResponseStatus) EnumDescriptor() ([]byte, []int) + func (CommonResponse_ResponseStatus) Type() protoreflect.EnumType + func (x CommonResponse_ResponseStatus) Enum() *CommonResponse_ResponseStatus + func (x CommonResponse_ResponseStatus) Number() protoreflect.EnumNumber + func (x CommonResponse_ResponseStatus) String() string + type ExternalProcessorClient interface + Process func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ProcessingRequest, ProcessingResponse], error) + func NewExternalProcessorClient(cc grpc.ClientConnInterface) ExternalProcessorClient + type ExternalProcessorServer interface + Process func(grpc.BidiStreamingServer[ProcessingRequest, ProcessingResponse]) error + type ExternalProcessor_ProcessClient = grpc.BidiStreamingClient[ProcessingRequest, ProcessingResponse] + type ExternalProcessor_ProcessServer = grpc.BidiStreamingServer[ProcessingRequest, ProcessingResponse] + type GrpcStatus struct + Status uint32 + func (*GrpcStatus) Descriptor() ([]byte, []int) + func (*GrpcStatus) ProtoMessage() + func (x *GrpcStatus) GetStatus() uint32 + func (x *GrpcStatus) ProtoReflect() protoreflect.Message + func (x *GrpcStatus) Reset() + func (x *GrpcStatus) String() string + type HeaderMutation struct + RemoveHeaders []string + SetHeaders []*v3.HeaderValueOption + func (*HeaderMutation) Descriptor() ([]byte, []int) + func (*HeaderMutation) ProtoMessage() + func (x *HeaderMutation) GetRemoveHeaders() []string + func (x *HeaderMutation) GetSetHeaders() []*v3.HeaderValueOption + func (x *HeaderMutation) ProtoReflect() protoreflect.Message + func (x *HeaderMutation) Reset() + func (x *HeaderMutation) String() string + type HeadersResponse struct + Response *CommonResponse + func (*HeadersResponse) Descriptor() ([]byte, []int) + func (*HeadersResponse) ProtoMessage() + func (x *HeadersResponse) GetResponse() *CommonResponse + func (x *HeadersResponse) ProtoReflect() protoreflect.Message + func (x *HeadersResponse) Reset() + func (x *HeadersResponse) String() string + type HttpBody struct + Body []byte + EndOfStream bool + func (*HttpBody) Descriptor() ([]byte, []int) + func (*HttpBody) ProtoMessage() + func (x *HttpBody) GetBody() []byte + func (x *HttpBody) GetEndOfStream() bool + func (x *HttpBody) ProtoReflect() protoreflect.Message + func (x *HttpBody) Reset() + func (x *HttpBody) String() string + type HttpHeaders struct + Attributes map[string]*structpb.Struct + EndOfStream bool + Headers *v3.HeaderMap + func (*HttpHeaders) Descriptor() ([]byte, []int) + func (*HttpHeaders) ProtoMessage() + func (x *HttpHeaders) GetAttributes() map[string]*structpb.Struct + func (x *HttpHeaders) GetEndOfStream() bool + func (x *HttpHeaders) GetHeaders() *v3.HeaderMap + func (x *HttpHeaders) ProtoReflect() protoreflect.Message + func (x *HttpHeaders) Reset() + func (x *HttpHeaders) String() string + type HttpTrailers struct + Trailers *v3.HeaderMap + func (*HttpTrailers) Descriptor() ([]byte, []int) + func (*HttpTrailers) ProtoMessage() + func (x *HttpTrailers) GetTrailers() *v3.HeaderMap + func (x *HttpTrailers) ProtoReflect() protoreflect.Message + func (x *HttpTrailers) Reset() + func (x *HttpTrailers) String() string + type ImmediateResponse struct + Body []byte + Details string + GrpcStatus *GrpcStatus + Headers *HeaderMutation + Status *v32.HttpStatus + func (*ImmediateResponse) Descriptor() ([]byte, []int) + func (*ImmediateResponse) ProtoMessage() + func (x *ImmediateResponse) GetBody() []byte + func (x *ImmediateResponse) GetDetails() string + func (x *ImmediateResponse) GetGrpcStatus() *GrpcStatus + func (x *ImmediateResponse) GetHeaders() *HeaderMutation + func (x *ImmediateResponse) GetStatus() *v32.HttpStatus + func (x *ImmediateResponse) ProtoReflect() protoreflect.Message + func (x *ImmediateResponse) Reset() + func (x *ImmediateResponse) String() string + type ProcessingRequest struct + Attributes map[string]*structpb.Struct + MetadataContext *v3.Metadata + ObservabilityMode bool + Request isProcessingRequest_Request + func (*ProcessingRequest) Descriptor() ([]byte, []int) + func (*ProcessingRequest) ProtoMessage() + func (m *ProcessingRequest) GetRequest() isProcessingRequest_Request + func (x *ProcessingRequest) GetAttributes() map[string]*structpb.Struct + func (x *ProcessingRequest) GetMetadataContext() *v3.Metadata + func (x *ProcessingRequest) GetObservabilityMode() bool + func (x *ProcessingRequest) GetRequestBody() *HttpBody + func (x *ProcessingRequest) GetRequestHeaders() *HttpHeaders + func (x *ProcessingRequest) GetRequestTrailers() *HttpTrailers + func (x *ProcessingRequest) GetResponseBody() *HttpBody + func (x *ProcessingRequest) GetResponseHeaders() *HttpHeaders + func (x *ProcessingRequest) GetResponseTrailers() *HttpTrailers + func (x *ProcessingRequest) ProtoReflect() protoreflect.Message + func (x *ProcessingRequest) Reset() + func (x *ProcessingRequest) String() string + type ProcessingRequest_RequestBody struct + RequestBody *HttpBody + type ProcessingRequest_RequestHeaders struct + RequestHeaders *HttpHeaders + type ProcessingRequest_RequestTrailers struct + RequestTrailers *HttpTrailers + type ProcessingRequest_ResponseBody struct + ResponseBody *HttpBody + type ProcessingRequest_ResponseHeaders struct + ResponseHeaders *HttpHeaders + type ProcessingRequest_ResponseTrailers struct + ResponseTrailers *HttpTrailers + type ProcessingResponse struct + DynamicMetadata *structpb.Struct + ModeOverride *v31.ProcessingMode + OverrideMessageTimeout *durationpb.Duration + Response isProcessingResponse_Response + func (*ProcessingResponse) Descriptor() ([]byte, []int) + func (*ProcessingResponse) ProtoMessage() + func (m *ProcessingResponse) GetResponse() isProcessingResponse_Response + func (x *ProcessingResponse) GetDynamicMetadata() *structpb.Struct + func (x *ProcessingResponse) GetImmediateResponse() *ImmediateResponse + func (x *ProcessingResponse) GetModeOverride() *v31.ProcessingMode + func (x *ProcessingResponse) GetOverrideMessageTimeout() *durationpb.Duration + func (x *ProcessingResponse) GetRequestBody() *BodyResponse + func (x *ProcessingResponse) GetRequestHeaders() *HeadersResponse + func (x *ProcessingResponse) GetRequestTrailers() *TrailersResponse + func (x *ProcessingResponse) GetResponseBody() *BodyResponse + func (x *ProcessingResponse) GetResponseHeaders() *HeadersResponse + func (x *ProcessingResponse) GetResponseTrailers() *TrailersResponse + func (x *ProcessingResponse) ProtoReflect() protoreflect.Message + func (x *ProcessingResponse) Reset() + func (x *ProcessingResponse) String() string + type ProcessingResponse_ImmediateResponse struct + ImmediateResponse *ImmediateResponse + type ProcessingResponse_RequestBody struct + RequestBody *BodyResponse + type ProcessingResponse_RequestHeaders struct + RequestHeaders *HeadersResponse + type ProcessingResponse_RequestTrailers struct + RequestTrailers *TrailersResponse + type ProcessingResponse_ResponseBody struct + ResponseBody *BodyResponse + type ProcessingResponse_ResponseHeaders struct + ResponseHeaders *HeadersResponse + type ProcessingResponse_ResponseTrailers struct + ResponseTrailers *TrailersResponse + type TrailersResponse struct + HeaderMutation *HeaderMutation + func (*TrailersResponse) Descriptor() ([]byte, []int) + func (*TrailersResponse) ProtoMessage() + func (x *TrailersResponse) GetHeaderMutation() *HeaderMutation + func (x *TrailersResponse) ProtoReflect() protoreflect.Message + func (x *TrailersResponse) Reset() + func (x *TrailersResponse) String() string + type UnimplementedExternalProcessorServer struct + func (UnimplementedExternalProcessorServer) Process(grpc.BidiStreamingServer[ProcessingRequest, ProcessingResponse]) error + type UnsafeExternalProcessorServer interface
Go to main page