Documentation ¶
Index ¶
- Variables
- func RegisterCaptureServer(s grpc.ServiceRegistrar, srv CaptureServer)
- type CaptureClient
- type CaptureServer
- type FlushRequest
- type FlushResponse
- type Recording
- type UnaryCall
- func (*UnaryCall) Descriptor() ([]byte, []int)deprecated
- func (x *UnaryCall) GetErr() string
- func (x *UnaryCall) GetMethod() string
- func (x *UnaryCall) GetRequest() *anypb.Any
- func (x *UnaryCall) GetResponse() *anypb.Any
- func (*UnaryCall) ProtoMessage()
- func (x *UnaryCall) ProtoReflect() protoreflect.Message
- func (x *UnaryCall) Reset()
- func (x *UnaryCall) String() string
- type UnimplementedCaptureServer
- type UnsafeCaptureServer
Constants ¶
This section is empty.
Variables ¶
var Capture_ServiceDesc = grpc.ServiceDesc{ ServiceName: "magma.capture.Capture", HandlerType: (*CaptureServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Flush", Handler: _Capture_Flush_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "capture.proto", }
Capture_ServiceDesc is the grpc.ServiceDesc for Capture service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_capture_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCaptureServer ¶
func RegisterCaptureServer(s grpc.ServiceRegistrar, srv CaptureServer)
Types ¶
type CaptureClient ¶
type CaptureClient interface {
Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
}
CaptureClient is the client API for Capture 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 NewCaptureClient ¶
func NewCaptureClient(cc grpc.ClientConnInterface) CaptureClient
type CaptureServer ¶
type CaptureServer interface { Flush(context.Context, *FlushRequest) (*FlushResponse, error) // contains filtered or unexported methods }
CaptureServer is the server API for Capture service. All implementations must embed UnimplementedCaptureServer for forward compatibility
type FlushRequest ¶
type FlushRequest struct {
// contains filtered or unexported fields
}
func (*FlushRequest) Descriptor
deprecated
func (*FlushRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.
func (*FlushRequest) ProtoMessage ¶
func (*FlushRequest) ProtoMessage()
func (*FlushRequest) ProtoReflect ¶
func (x *FlushRequest) ProtoReflect() protoreflect.Message
func (*FlushRequest) Reset ¶
func (x *FlushRequest) Reset()
func (*FlushRequest) String ¶
func (x *FlushRequest) String() string
type FlushResponse ¶
type FlushResponse struct { Recording *Recording `protobuf:"bytes,1,opt,name=recording,proto3" json:"recording,omitempty"` // contains filtered or unexported fields }
func (*FlushResponse) Descriptor
deprecated
func (*FlushResponse) Descriptor() ([]byte, []int)
Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.
func (*FlushResponse) GetRecording ¶
func (x *FlushResponse) GetRecording() *Recording
func (*FlushResponse) ProtoMessage ¶
func (*FlushResponse) ProtoMessage()
func (*FlushResponse) ProtoReflect ¶
func (x *FlushResponse) ProtoReflect() protoreflect.Message
func (*FlushResponse) Reset ¶
func (x *FlushResponse) Reset()
func (*FlushResponse) String ¶
func (x *FlushResponse) String() string
type Recording ¶
type Recording struct { UnaryCalls []*UnaryCall `protobuf:"bytes,1,rep,name=unary_calls,json=unaryCalls,proto3" json:"unary_calls,omitempty"` // contains filtered or unexported fields }
Recording represents a recorded series of unary_calls.
func (*Recording) Descriptor
deprecated
func (*Recording) GetUnaryCalls ¶
func (*Recording) ProtoMessage ¶
func (*Recording) ProtoMessage()
func (*Recording) ProtoReflect ¶
func (x *Recording) ProtoReflect() protoreflect.Message
type UnaryCall ¶
type UnaryCall struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Request *anypb.Any `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` Response *anypb.Any `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"` Err string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"` // contains filtered or unexported fields }
UnaryCall represents a single unary rpc call.
func (*UnaryCall) Descriptor
deprecated
func (*UnaryCall) GetRequest ¶
func (*UnaryCall) GetResponse ¶
func (*UnaryCall) ProtoMessage ¶
func (*UnaryCall) ProtoMessage()
func (*UnaryCall) ProtoReflect ¶
func (x *UnaryCall) ProtoReflect() protoreflect.Message
type UnimplementedCaptureServer ¶
type UnimplementedCaptureServer struct { }
UnimplementedCaptureServer must be embedded to have forward compatible implementations.
func (UnimplementedCaptureServer) Flush ¶
func (UnimplementedCaptureServer) Flush(context.Context, *FlushRequest) (*FlushResponse, error)
type UnsafeCaptureServer ¶
type UnsafeCaptureServer interface {
// contains filtered or unexported methods
}
UnsafeCaptureServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CaptureServer will result in compilation errors.