Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterNecoPerfServer(s grpc.ServiceRegistrar, srv NecoPerfServer)
- type NecoPerfClient
- type NecoPerfServer
- type NecoPerf_ProfileClient
- type NecoPerf_ProfileServer
- type PerfProfileRequest
- func (*PerfProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PerfProfileRequest) GetContainerId() string
- func (x *PerfProfileRequest) GetTimeout() *durationpb.Duration
- func (*PerfProfileRequest) ProtoMessage()
- func (x *PerfProfileRequest) ProtoReflect() protoreflect.Message
- func (x *PerfProfileRequest) Reset()
- func (x *PerfProfileRequest) String() string
- type PerfProfileResponse
- func (*PerfProfileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PerfProfileResponse) GetData() []byte
- func (*PerfProfileResponse) ProtoMessage()
- func (x *PerfProfileResponse) ProtoReflect() protoreflect.Message
- func (x *PerfProfileResponse) Reset()
- func (x *PerfProfileResponse) String() string
- type UnimplementedNecoPerfServer
- type UnsafeNecoPerfServer
Constants ¶
const (
NecoPerf_Profile_FullMethodName = "/necoperf.NecoPerf/Profile"
)
Variables ¶
var File_internal_rpc_necoperf_proto protoreflect.FileDescriptor
var NecoPerf_ServiceDesc = grpc.ServiceDesc{ ServiceName: "necoperf.NecoPerf", HandlerType: (*NecoPerfServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Profile", Handler: _NecoPerf_Profile_Handler, ServerStreams: true, }, }, Metadata: "internal/rpc/necoperf.proto", }
NecoPerf_ServiceDesc is the grpc.ServiceDesc for NecoPerf service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNecoPerfServer ¶
func RegisterNecoPerfServer(s grpc.ServiceRegistrar, srv NecoPerfServer)
Types ¶
type NecoPerfClient ¶
type NecoPerfClient interface {
Profile(ctx context.Context, in *PerfProfileRequest, opts ...grpc.CallOption) (NecoPerf_ProfileClient, error)
}
NecoPerfClient is the client API for NecoPerf 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 NewNecoPerfClient ¶
func NewNecoPerfClient(cc grpc.ClientConnInterface) NecoPerfClient
type NecoPerfServer ¶
type NecoPerfServer interface { Profile(*PerfProfileRequest, NecoPerf_ProfileServer) error // contains filtered or unexported methods }
NecoPerfServer is the server API for NecoPerf service. All implementations must embed UnimplementedNecoPerfServer for forward compatibility
type NecoPerf_ProfileClient ¶
type NecoPerf_ProfileClient interface { Recv() (*PerfProfileResponse, error) grpc.ClientStream }
type NecoPerf_ProfileServer ¶
type NecoPerf_ProfileServer interface { Send(*PerfProfileResponse) error grpc.ServerStream }
type PerfProfileRequest ¶
type PerfProfileRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*PerfProfileRequest) Descriptor
deprecated
func (*PerfProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use PerfProfileRequest.ProtoReflect.Descriptor instead.
func (*PerfProfileRequest) GetContainerId ¶
func (x *PerfProfileRequest) GetContainerId() string
func (*PerfProfileRequest) GetTimeout ¶
func (x *PerfProfileRequest) GetTimeout() *durationpb.Duration
func (*PerfProfileRequest) ProtoMessage ¶
func (*PerfProfileRequest) ProtoMessage()
func (*PerfProfileRequest) ProtoReflect ¶
func (x *PerfProfileRequest) ProtoReflect() protoreflect.Message
func (*PerfProfileRequest) Reset ¶
func (x *PerfProfileRequest) Reset()
func (*PerfProfileRequest) String ¶
func (x *PerfProfileRequest) String() string
type PerfProfileResponse ¶
type PerfProfileResponse struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*PerfProfileResponse) Descriptor
deprecated
func (*PerfProfileResponse) Descriptor() ([]byte, []int)
Deprecated: Use PerfProfileResponse.ProtoReflect.Descriptor instead.
func (*PerfProfileResponse) GetData ¶
func (x *PerfProfileResponse) GetData() []byte
func (*PerfProfileResponse) ProtoMessage ¶
func (*PerfProfileResponse) ProtoMessage()
func (*PerfProfileResponse) ProtoReflect ¶
func (x *PerfProfileResponse) ProtoReflect() protoreflect.Message
func (*PerfProfileResponse) Reset ¶
func (x *PerfProfileResponse) Reset()
func (*PerfProfileResponse) String ¶
func (x *PerfProfileResponse) String() string
type UnimplementedNecoPerfServer ¶
type UnimplementedNecoPerfServer struct { }
UnimplementedNecoPerfServer must be embedded to have forward compatible implementations.
func (UnimplementedNecoPerfServer) Profile ¶
func (UnimplementedNecoPerfServer) Profile(*PerfProfileRequest, NecoPerf_ProfileServer) error
type UnsafeNecoPerfServer ¶
type UnsafeNecoPerfServer interface {
// contains filtered or unexported methods
}
UnsafeNecoPerfServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NecoPerfServer will result in compilation errors.