Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterExternalProcessorServer(s grpc.ServiceRegistrar, srv ExternalProcessorServer)
- type ExternalProcessorClient
- type ExternalProcessorServer
- type ExternalProcessor_ProcessClient
- type ExternalProcessor_ProcessServer
- type UnimplementedExternalProcessorServer
- type UnsafeExternalProcessorServer
Constants ¶
const (
ExternalProcessor_Process_FullMethodName = "/envoy.service.ext_proc.v3.ExternalProcessor/Process"
)
Variables ¶
var ExternalProcessor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.ext_proc.v3.ExternalProcessor", HandlerType: (*ExternalProcessorServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Process", Handler: _ExternalProcessor_Process_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/ext_proc/v3/external_processor.proto", }
ExternalProcessor_ServiceDesc is the grpc.ServiceDesc for ExternalProcessor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterExternalProcessorServer ¶
func RegisterExternalProcessorServer(s grpc.ServiceRegistrar, srv ExternalProcessorServer)
Types ¶
type ExternalProcessorClient ¶
type ExternalProcessorClient interface { // This begins the bidirectional stream that Envoy will use to // give the server control over what the filter does. The actual // protocol is described by the ProcessingRequest and ProcessingResponse // messages below. Process(ctx context.Context, opts ...grpc.CallOption) (ExternalProcessor_ProcessClient, error) }
ExternalProcessorClient is the client API for ExternalProcessor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewExternalProcessorClient ¶
func NewExternalProcessorClient(cc grpc.ClientConnInterface) ExternalProcessorClient
type ExternalProcessorServer ¶
type ExternalProcessorServer interface { // This begins the bidirectional stream that Envoy will use to // give the server control over what the filter does. The actual // protocol is described by the ProcessingRequest and ProcessingResponse // messages below. Process(ExternalProcessor_ProcessServer) error }
ExternalProcessorServer is the server API for ExternalProcessor service. All implementations should embed UnimplementedExternalProcessorServer for forward compatibility
type ExternalProcessor_ProcessClient ¶
type ExternalProcessor_ProcessClient interface { Send(*v3.ProcessingRequest) error Recv() (*v3.ProcessingResponse, error) grpc.ClientStream }
type ExternalProcessor_ProcessServer ¶
type ExternalProcessor_ProcessServer interface { Send(*v3.ProcessingResponse) error Recv() (*v3.ProcessingRequest, error) grpc.ServerStream }
type UnimplementedExternalProcessorServer ¶
type UnimplementedExternalProcessorServer struct { }
UnimplementedExternalProcessorServer should be embedded to have forward compatible implementations.
func (UnimplementedExternalProcessorServer) Process ¶
func (UnimplementedExternalProcessorServer) Process(ExternalProcessor_ProcessServer) error
type UnsafeExternalProcessorServer ¶
type UnsafeExternalProcessorServer interface {
// contains filtered or unexported methods
}
UnsafeExternalProcessorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExternalProcessorServer will result in compilation errors.