Documentation ¶
Index ¶
- Variables
- func RegisterTracesServer(s grpc.ServiceRegistrar, srv TracesServer)
- type TraceRequest
- func (*TraceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TraceRequest) GetCommandName() string
- func (x *TraceRequest) GetPid() uint32
- func (x *TraceRequest) GetUid() uint32
- func (*TraceRequest) ProtoMessage()
- func (x *TraceRequest) ProtoReflect() protoreflect.Message
- func (x *TraceRequest) Reset()
- func (x *TraceRequest) String() string
- type TraceResponse
- func (*TraceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TraceResponse) GetContext() *core.CommandContext
- func (x *TraceResponse) GetMessage() string
- func (x *TraceResponse) GetValues() map[string]string
- func (*TraceResponse) ProtoMessage()
- func (x *TraceResponse) ProtoReflect() protoreflect.Message
- func (x *TraceResponse) Reset()
- func (x *TraceResponse) String() string
- type TracesClient
- type TracesServer
- type Traces_TraceClient
- type Traces_TraceServer
- type UnimplementedTracesServer
- type UnsafeTracesServer
Constants ¶
This section is empty.
Variables ¶
var File_v1_agent_trace_trace_proto protoreflect.FileDescriptor
var Traces_ServiceDesc = grpc.ServiceDesc{ ServiceName: "camblet.api.v1.agent.trace.Traces", HandlerType: (*TracesServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Trace", Handler: _Traces_Trace_Handler, ServerStreams: true, }, }, Metadata: "v1/agent/trace/trace.proto", }
Traces_ServiceDesc is the grpc.ServiceDesc for Traces service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTracesServer ¶
func RegisterTracesServer(s grpc.ServiceRegistrar, srv TracesServer)
Types ¶
type TraceRequest ¶
type TraceRequest struct { Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` Uid *uint32 `protobuf:"varint,2,opt,name=uid,proto3,oneof" json:"uid,omitempty"` CommandName string `protobuf:"bytes,3,opt,name=command_name,json=commandName,proto3" json:"command_name,omitempty"` // contains filtered or unexported fields }
func (*TraceRequest) Descriptor
deprecated
func (*TraceRequest) Descriptor() ([]byte, []int)
Deprecated: Use TraceRequest.ProtoReflect.Descriptor instead.
func (*TraceRequest) GetCommandName ¶
func (x *TraceRequest) GetCommandName() string
func (*TraceRequest) GetPid ¶
func (x *TraceRequest) GetPid() uint32
func (*TraceRequest) GetUid ¶
func (x *TraceRequest) GetUid() uint32
func (*TraceRequest) ProtoMessage ¶
func (*TraceRequest) ProtoMessage()
func (*TraceRequest) ProtoReflect ¶
func (x *TraceRequest) ProtoReflect() protoreflect.Message
func (*TraceRequest) Reset ¶
func (x *TraceRequest) Reset()
func (*TraceRequest) String ¶
func (x *TraceRequest) String() string
type TraceResponse ¶
type TraceResponse struct { Context *core.CommandContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Values map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TraceResponse) Descriptor
deprecated
func (*TraceResponse) Descriptor() ([]byte, []int)
Deprecated: Use TraceResponse.ProtoReflect.Descriptor instead.
func (*TraceResponse) GetContext ¶
func (x *TraceResponse) GetContext() *core.CommandContext
func (*TraceResponse) GetMessage ¶
func (x *TraceResponse) GetMessage() string
func (*TraceResponse) GetValues ¶
func (x *TraceResponse) GetValues() map[string]string
func (*TraceResponse) ProtoMessage ¶
func (*TraceResponse) ProtoMessage()
func (*TraceResponse) ProtoReflect ¶
func (x *TraceResponse) ProtoReflect() protoreflect.Message
func (*TraceResponse) Reset ¶
func (x *TraceResponse) Reset()
func (*TraceResponse) String ¶
func (x *TraceResponse) String() string
type TracesClient ¶
type TracesClient interface {
Trace(ctx context.Context, in *TraceRequest, opts ...grpc.CallOption) (Traces_TraceClient, error)
}
TracesClient is the client API for Traces 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 NewTracesClient ¶
func NewTracesClient(cc grpc.ClientConnInterface) TracesClient
type TracesServer ¶
type TracesServer interface { Trace(*TraceRequest, Traces_TraceServer) error // contains filtered or unexported methods }
TracesServer is the server API for Traces service. All implementations must embed UnimplementedTracesServer for forward compatibility
type Traces_TraceClient ¶
type Traces_TraceClient interface { Recv() (*TraceResponse, error) grpc.ClientStream }
type Traces_TraceServer ¶
type Traces_TraceServer interface { Send(*TraceResponse) error grpc.ServerStream }
type UnimplementedTracesServer ¶
type UnimplementedTracesServer struct { }
UnimplementedTracesServer must be embedded to have forward compatible implementations.
func (UnimplementedTracesServer) Trace ¶
func (UnimplementedTracesServer) Trace(*TraceRequest, Traces_TraceServer) error
type UnsafeTracesServer ¶
type UnsafeTracesServer interface {
// contains filtered or unexported methods
}
UnsafeTracesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TracesServer will result in compilation errors.