go_datacollector_svr

Documentation

Index

• Variables
• func RegisterGoDatacollectorSvrServer(s grpc.ServiceRegistrar, srv GoDatacollectorSvrServer)
• type GoDatacollectorSvrClient
  • func NewGoDatacollectorSvrClient(cc grpc.ClientConnInterface) GoDatacollectorSvrClient
• type GoDatacollectorSvrServer
• type ReportTraceReq
  • func (*ReportTraceReq) Descriptor() ([]byte, []int)
  • func (x *ReportTraceReq) GetCmd() string
  • func (x *ReportTraceReq) GetErrcode() int64
  • func (x *ReportTraceReq) GetErrmsg() string
  • func (x *ReportTraceReq) GetPatentSpanId() int64
  • func (x *ReportTraceReq) GetProject() string
  • func (x *ReportTraceReq) GetReqbody() string
  • func (x *ReportTraceReq) GetServerIp() string
  • func (x *ReportTraceReq) GetSource() string
  • func (x *ReportTraceReq) GetSpanId() int64
  • func (x *ReportTraceReq) GetTimecost() int64
  • func (x *ReportTraceReq) GetTimestamp() int64
  • func (x *ReportTraceReq) GetTraceId() string
  • func (*ReportTraceReq) ProtoMessage()
  • func (x *ReportTraceReq) ProtoReflect() protoreflect.Message
  • func (x *ReportTraceReq) Reset()
  • func (x *ReportTraceReq) String() string
• type ReportTraceRsp
  • func (*ReportTraceRsp) Descriptor() ([]byte, []int)
  • func (*ReportTraceRsp) ProtoMessage()
  • func (x *ReportTraceRsp) ProtoReflect() protoreflect.Message
  • func (x *ReportTraceRsp) Reset()
  • func (x *ReportTraceRsp) String() string
• type UnimplementedGoDatacollectorSvrServer
  • func (UnimplementedGoDatacollectorSvrServer) ReportTrace(context.Context, *ReportTraceReq) (*ReportTraceRsp, error)
• type UnsafeGoDatacollectorSvrServer

Variables

var File_go_datacollector_svr_proto protoreflect.FileDescriptor

var GoDatacollectorSvr_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "go_datacollector_svr.go_datacollector_svr",
	HandlerType: (*GoDatacollectorSvrServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportTrace",
			Handler:    _GoDatacollectorSvr_ReportTrace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go_datacollector_svr.proto",
}

GoDatacollectorSvr_ServiceDesc is the grpc.ServiceDesc for GoDatacollectorSvr service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGoDatacollectorSvrServer

func RegisterGoDatacollectorSvrServer(s grpc.ServiceRegistrar, srv GoDatacollectorSvrServer)

Types

type GoDatacollectorSvrClient

type GoDatacollectorSvrClient interface {
	// 上报链路数据
	ReportTrace(ctx context.Context, in *ReportTraceReq, opts ...grpc.CallOption) (*ReportTraceRsp, error)
}

GoDatacollectorSvrClient is the client API for GoDatacollectorSvr 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 NewGoDatacollectorSvrClient

func NewGoDatacollectorSvrClient(cc grpc.ClientConnInterface) GoDatacollectorSvrClient

type GoDatacollectorSvrServer

type GoDatacollectorSvrServer interface {
	// 上报链路数据
	ReportTrace(context.Context, *ReportTraceReq) (*ReportTraceRsp, error)
}

GoDatacollectorSvrServer is the server API for GoDatacollectorSvr service. All implementations should embed UnimplementedGoDatacollectorSvrServer for forward compatibility

type ReportTraceReq

type ReportTraceReq struct {
	TraceId      string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                    // 全链路ID
	Cmd          string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`                                           // 命令字
	Project      string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`                                   // 被调方
	Source       string `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`                                     // 调用方
	ServerIp     string `protobuf:"bytes,6,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"`                 // 服务器IP
	Errcode      int64  `protobuf:"varint,7,opt,name=errcode,proto3" json:"errcode,omitempty"`                                  // 错误码
	Errmsg       string `protobuf:"bytes,8,opt,name=errmsg,proto3" json:"errmsg,omitempty"`                                     // 异常消息
	Timestamp    int64  `protobuf:"varint,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                              // 时间戳
	Timecost     int64  `protobuf:"varint,10,opt,name=timecost,proto3" json:"timecost,omitempty"`                               // 耗时，单位：ms
	Reqbody      string `protobuf:"bytes,11,opt,name=reqbody,proto3" json:"reqbody,omitempty"`                                  // 请求参数
	SpanId       int64  `protobuf:"varint,12,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`                     // SpanID
	PatentSpanId int64  `protobuf:"varint,13,opt,name=patent_span_id,json=patentSpanId,proto3" json:"patent_span_id,omitempty"` // 父 SpanID
	// contains filtered or unexported fields
}

func (*ReportTraceReq) Descriptor

func (*ReportTraceReq) Descriptor() ([]byte, []int)

Deprecated: Use ReportTraceReq.ProtoReflect.Descriptor instead.

func (*ReportTraceReq) GetCmd

func (x *ReportTraceReq) GetCmd() string

func (*ReportTraceReq) GetErrcode

func (x *ReportTraceReq) GetErrcode() int64

func (*ReportTraceReq) GetErrmsg

func (x *ReportTraceReq) GetErrmsg() string

func (*ReportTraceReq) GetPatentSpanId

func (x *ReportTraceReq) GetPatentSpanId() int64

func (*ReportTraceReq) GetProject

func (x *ReportTraceReq) GetProject() string

func (*ReportTraceReq) GetReqbody

func (x *ReportTraceReq) GetReqbody() string

func (*ReportTraceReq) GetServerIp

func (x *ReportTraceReq) GetServerIp() string

func (*ReportTraceReq) GetSource

func (x *ReportTraceReq) GetSource() string

func (*ReportTraceReq) GetSpanId

func (x *ReportTraceReq) GetSpanId() int64

func (*ReportTraceReq) GetTimecost

func (x *ReportTraceReq) GetTimecost() int64

func (*ReportTraceReq) GetTimestamp

func (x *ReportTraceReq) GetTimestamp() int64

func (*ReportTraceReq) GetTraceId

func (x *ReportTraceReq) GetTraceId() string

func (*ReportTraceReq) ProtoMessage

func (*ReportTraceReq) ProtoMessage()

func (*ReportTraceReq) ProtoReflect

func (x *ReportTraceReq) ProtoReflect() protoreflect.Message

func (*ReportTraceReq) Reset

func (x *ReportTraceReq) Reset()

func (*ReportTraceReq) String

func (x *ReportTraceReq) String() string

type ReportTraceRsp

type ReportTraceRsp struct {
	// contains filtered or unexported fields
}

func (*ReportTraceRsp) Descriptor

func (*ReportTraceRsp) Descriptor() ([]byte, []int)

Deprecated: Use ReportTraceRsp.ProtoReflect.Descriptor instead.

func (*ReportTraceRsp) ProtoMessage

func (*ReportTraceRsp) ProtoMessage()

func (*ReportTraceRsp) ProtoReflect

func (x *ReportTraceRsp) ProtoReflect() protoreflect.Message

func (*ReportTraceRsp) Reset

func (x *ReportTraceRsp) Reset()

func (*ReportTraceRsp) String

func (x *ReportTraceRsp) String() string

type UnimplementedGoDatacollectorSvrServer

type UnimplementedGoDatacollectorSvrServer struct {
}

UnimplementedGoDatacollectorSvrServer should be embedded to have forward compatible implementations.

func (UnimplementedGoDatacollectorSvrServer) ReportTrace

func (UnimplementedGoDatacollectorSvrServer) ReportTrace(context.Context, *ReportTraceReq) (*ReportTraceRsp, error)

type UnsafeGoDatacollectorSvrServer

type UnsafeGoDatacollectorSvrServer interface {
	// contains filtered or unexported methods
}

UnsafeGoDatacollectorSvrServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GoDatacollectorSvrServer will result in compilation errors.