v2

package
v1.8.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 2, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CLRMetricReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "CLRMetricReportService",
	HandlerType: (*CLRMetricReportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collect",
			Handler:    _CLRMetricReportService_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent-v2/CLRMetric.proto",
}

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

View Source 
var File_language_agent_v2_CLRMetric_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_v2_JVMMetric_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_v2_trace_proto protoreflect.FileDescriptor
View Source 
var JVMMetricReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "JVMMetricReportService",
	HandlerType: (*JVMMetricReportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collect",
			Handler:    _JVMMetricReportService_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent-v2/JVMMetric.proto",
}

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

View Source 
var TraceSegmentReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TraceSegmentReportService",
	HandlerType: (*TraceSegmentReportServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collect",
			Handler:       _TraceSegmentReportService_Collect_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "language-agent-v2/trace.proto",
}

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

Functions

func RegisterCLRMetricReportServiceServer 

func RegisterCLRMetricReportServiceServer(s grpc.ServiceRegistrar, srv CLRMetricReportServiceServer)

func RegisterJVMMetricReportServiceServer 

func RegisterJVMMetricReportServiceServer(s grpc.ServiceRegistrar, srv JVMMetricReportServiceServer)

func RegisterTraceSegmentReportServiceServer 

func RegisterTraceSegmentReportServiceServer(s grpc.ServiceRegistrar, srv TraceSegmentReportServiceServer)

Types

type CLRMetricCollection 

type CLRMetricCollection struct {
	Metrics           []*agent.CLRMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ServiceInstanceId int32              `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*CLRMetricCollection) Descriptor deprecated 

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

Deprecated: Use CLRMetricCollection.ProtoReflect.Descriptor instead.

func (*CLRMetricCollection) GetMetrics 

func (x *CLRMetricCollection) GetMetrics() []*agent.CLRMetric

func (*CLRMetricCollection) GetServiceInstanceId 

func (x *CLRMetricCollection) GetServiceInstanceId() int32

func (*CLRMetricCollection) ProtoMessage 

func (*CLRMetricCollection) ProtoMessage()

func (*CLRMetricCollection) ProtoReflect 

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

func (*CLRMetricCollection) Reset 

func (x *CLRMetricCollection) Reset()

func (*CLRMetricCollection) String 

func (x *CLRMetricCollection) String() string

type CLRMetricReportServiceClient 

type CLRMetricReportServiceClient interface {
	Collect(ctx context.Context, in *CLRMetricCollection, opts ...grpc.CallOption) (*common.Commands, error)
}

CLRMetricReportServiceClient is the client API for CLRMetricReportService 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 NewCLRMetricReportServiceClient 

func NewCLRMetricReportServiceClient(cc grpc.ClientConnInterface) CLRMetricReportServiceClient

type CLRMetricReportServiceServer 

type CLRMetricReportServiceServer interface {
	Collect(context.Context, *CLRMetricCollection) (*common.Commands, error)
}

CLRMetricReportServiceServer is the server API for CLRMetricReportService service. All implementations should embed UnimplementedCLRMetricReportServiceServer for forward compatibility

type JVMMetricCollection 

type JVMMetricCollection struct {
	Metrics           []*agent.JVMMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ServiceInstanceId int32              `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*JVMMetricCollection) Descriptor deprecated 

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

Deprecated: Use JVMMetricCollection.ProtoReflect.Descriptor instead.

func (*JVMMetricCollection) GetMetrics 

func (x *JVMMetricCollection) GetMetrics() []*agent.JVMMetric

func (*JVMMetricCollection) GetServiceInstanceId 

func (x *JVMMetricCollection) GetServiceInstanceId() int32

func (*JVMMetricCollection) ProtoMessage 

func (*JVMMetricCollection) ProtoMessage()

func (*JVMMetricCollection) ProtoReflect 

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

func (*JVMMetricCollection) Reset 

func (x *JVMMetricCollection) Reset()

func (*JVMMetricCollection) String 

func (x *JVMMetricCollection) String() string

type JVMMetricReportServiceClient 

type JVMMetricReportServiceClient interface {
	Collect(ctx context.Context, in *JVMMetricCollection, opts ...grpc.CallOption) (*common.Commands, error)
}

JVMMetricReportServiceClient is the client API for JVMMetricReportService 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 NewJVMMetricReportServiceClient 

func NewJVMMetricReportServiceClient(cc grpc.ClientConnInterface) JVMMetricReportServiceClient

type JVMMetricReportServiceServer 

type JVMMetricReportServiceServer interface {
	Collect(context.Context, *JVMMetricCollection) (*common.Commands, error)
}

JVMMetricReportServiceServer is the server API for JVMMetricReportService service. All implementations should embed UnimplementedJVMMetricReportServiceServer for forward compatibility

type Log 

type Log struct {
	Time int64                        `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Data []*common.KeyStringValuePair `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetData 

func (x *Log) GetData() []*common.KeyStringValuePair

func (*Log) GetTime 

func (x *Log) GetTime() int64

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type SegmentObject 

type SegmentObject struct {
	TraceSegmentId    *agent.UniqueId `protobuf:"bytes,1,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	Spans             []*SpanObjectV2 `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	ServiceId         int32           `protobuf:"varint,3,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	ServiceInstanceId int32           `protobuf:"varint,4,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	IsSizeLimited     bool            `protobuf:"varint,5,opt,name=isSizeLimited,proto3" json:"isSizeLimited,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentObject) Descriptor deprecated 

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

Deprecated: Use SegmentObject.ProtoReflect.Descriptor instead.

func (*SegmentObject) GetIsSizeLimited 

func (x *SegmentObject) GetIsSizeLimited() bool

func (*SegmentObject) GetServiceId 

func (x *SegmentObject) GetServiceId() int32

func (*SegmentObject) GetServiceInstanceId 

func (x *SegmentObject) GetServiceInstanceId() int32

func (*SegmentObject) GetSpans 

func (x *SegmentObject) GetSpans() []*SpanObjectV2

func (*SegmentObject) GetTraceSegmentId 

func (x *SegmentObject) GetTraceSegmentId() *agent.UniqueId

func (*SegmentObject) ProtoMessage 

func (*SegmentObject) ProtoMessage()

func (*SegmentObject) ProtoReflect 

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

func (*SegmentObject) Reset 

func (x *SegmentObject) Reset()

func (*SegmentObject) String 

func (x *SegmentObject) String() string

type SegmentReference 

type SegmentReference struct {
	RefType                 agent.RefType   `protobuf:"varint,1,opt,name=refType,proto3,enum=RefType" json:"refType,omitempty"`
	ParentTraceSegmentId    *agent.UniqueId `protobuf:"bytes,2,opt,name=parentTraceSegmentId,proto3" json:"parentTraceSegmentId,omitempty"`
	ParentSpanId            int32           `protobuf:"varint,3,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	ParentServiceInstanceId int32           `protobuf:"varint,4,opt,name=parentServiceInstanceId,proto3" json:"parentServiceInstanceId,omitempty"`
	NetworkAddress          string          `protobuf:"bytes,5,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
	NetworkAddressId        int32           `protobuf:"varint,6,opt,name=networkAddressId,proto3" json:"networkAddressId,omitempty"`
	EntryServiceInstanceId  int32           `protobuf:"varint,7,opt,name=entryServiceInstanceId,proto3" json:"entryServiceInstanceId,omitempty"`
	EntryEndpoint           string          `protobuf:"bytes,8,opt,name=entryEndpoint,proto3" json:"entryEndpoint,omitempty"`
	EntryEndpointId         int32           `protobuf:"varint,9,opt,name=entryEndpointId,proto3" json:"entryEndpointId,omitempty"`
	ParentEndpoint          string          `protobuf:"bytes,10,opt,name=parentEndpoint,proto3" json:"parentEndpoint,omitempty"`
	ParentEndpointId        int32           `protobuf:"varint,11,opt,name=parentEndpointId,proto3" json:"parentEndpointId,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentReference) Descriptor deprecated 

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

Deprecated: Use SegmentReference.ProtoReflect.Descriptor instead.

func (*SegmentReference) GetEntryEndpoint 

func (x *SegmentReference) GetEntryEndpoint() string

func (*SegmentReference) GetEntryEndpointId 

func (x *SegmentReference) GetEntryEndpointId() int32

func (*SegmentReference) GetEntryServiceInstanceId 

func (x *SegmentReference) GetEntryServiceInstanceId() int32

func (*SegmentReference) GetNetworkAddress 

func (x *SegmentReference) GetNetworkAddress() string

func (*SegmentReference) GetNetworkAddressId 

func (x *SegmentReference) GetNetworkAddressId() int32

func (*SegmentReference) GetParentEndpoint 

func (x *SegmentReference) GetParentEndpoint() string

func (*SegmentReference) GetParentEndpointId 

func (x *SegmentReference) GetParentEndpointId() int32

func (*SegmentReference) GetParentServiceInstanceId 

func (x *SegmentReference) GetParentServiceInstanceId() int32

func (*SegmentReference) GetParentSpanId 

func (x *SegmentReference) GetParentSpanId() int32

func (*SegmentReference) GetParentTraceSegmentId 

func (x *SegmentReference) GetParentTraceSegmentId() *agent.UniqueId

func (*SegmentReference) GetRefType 

func (x *SegmentReference) GetRefType() agent.RefType

func (*SegmentReference) ProtoMessage 

func (*SegmentReference) ProtoMessage()

func (*SegmentReference) ProtoReflect 

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

func (*SegmentReference) Reset 

func (x *SegmentReference) Reset()

func (*SegmentReference) String 

func (x *SegmentReference) String() string

type SpanObjectV2 

type SpanObjectV2 struct {
	SpanId          int32                        `protobuf:"varint,1,opt,name=spanId,proto3" json:"spanId,omitempty"`
	ParentSpanId    int32                        `protobuf:"varint,2,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	StartTime       int64                        `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime         int64                        `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Refs            []*SegmentReference          `protobuf:"bytes,5,rep,name=refs,proto3" json:"refs,omitempty"`
	OperationNameId int32                        `protobuf:"varint,6,opt,name=operationNameId,proto3" json:"operationNameId,omitempty"`
	OperationName   string                       `protobuf:"bytes,7,opt,name=operationName,proto3" json:"operationName,omitempty"`
	PeerId          int32                        `protobuf:"varint,8,opt,name=peerId,proto3" json:"peerId,omitempty"`
	Peer            string                       `protobuf:"bytes,9,opt,name=peer,proto3" json:"peer,omitempty"`
	SpanType        agent.SpanType               `protobuf:"varint,10,opt,name=spanType,proto3,enum=SpanType" json:"spanType,omitempty"`
	SpanLayer       agent.SpanLayer              `protobuf:"varint,11,opt,name=spanLayer,proto3,enum=SpanLayer" json:"spanLayer,omitempty"`
	ComponentId     int32                        `protobuf:"varint,12,opt,name=componentId,proto3" json:"componentId,omitempty"`
	Component       string                       `protobuf:"bytes,13,opt,name=component,proto3" json:"component,omitempty"`
	IsError         bool                         `protobuf:"varint,14,opt,name=isError,proto3" json:"isError,omitempty"`
	Tags            []*common.KeyStringValuePair `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs            []*Log                       `protobuf:"bytes,16,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanObjectV2) Descriptor deprecated 

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

Deprecated: Use SpanObjectV2.ProtoReflect.Descriptor instead.

func (*SpanObjectV2) GetComponent 

func (x *SpanObjectV2) GetComponent() string

func (*SpanObjectV2) GetComponentId 

func (x *SpanObjectV2) GetComponentId() int32

func (*SpanObjectV2) GetEndTime 

func (x *SpanObjectV2) GetEndTime() int64

func (*SpanObjectV2) GetIsError 

func (x *SpanObjectV2) GetIsError() bool

func (*SpanObjectV2) GetLogs 

func (x *SpanObjectV2) GetLogs() []*Log

func (*SpanObjectV2) GetOperationName 

func (x *SpanObjectV2) GetOperationName() string

func (*SpanObjectV2) GetOperationNameId 

func (x *SpanObjectV2) GetOperationNameId() int32

func (*SpanObjectV2) GetParentSpanId 

func (x *SpanObjectV2) GetParentSpanId() int32

func (*SpanObjectV2) GetPeer 

func (x *SpanObjectV2) GetPeer() string

func (*SpanObjectV2) GetPeerId 

func (x *SpanObjectV2) GetPeerId() int32

func (*SpanObjectV2) GetRefs 

func (x *SpanObjectV2) GetRefs() []*SegmentReference

func (*SpanObjectV2) GetSpanId 

func (x *SpanObjectV2) GetSpanId() int32

func (*SpanObjectV2) GetSpanLayer 

func (x *SpanObjectV2) GetSpanLayer() agent.SpanLayer

func (*SpanObjectV2) GetSpanType 

func (x *SpanObjectV2) GetSpanType() agent.SpanType

func (*SpanObjectV2) GetStartTime 

func (x *SpanObjectV2) GetStartTime() int64

func (*SpanObjectV2) GetTags 

func (x *SpanObjectV2) GetTags() []*common.KeyStringValuePair

func (*SpanObjectV2) ProtoMessage 

func (*SpanObjectV2) ProtoMessage()

func (*SpanObjectV2) ProtoReflect 

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

func (*SpanObjectV2) Reset 

func (x *SpanObjectV2) Reset()

func (*SpanObjectV2) String 

func (x *SpanObjectV2) String() string

type TraceSegmentReportServiceClient 

type TraceSegmentReportServiceClient interface {
	Collect(ctx context.Context, opts ...grpc.CallOption) (TraceSegmentReportService_CollectClient, error)
}

TraceSegmentReportServiceClient is the client API for TraceSegmentReportService 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 NewTraceSegmentReportServiceClient 

func NewTraceSegmentReportServiceClient(cc grpc.ClientConnInterface) TraceSegmentReportServiceClient

type TraceSegmentReportServiceServer 

type TraceSegmentReportServiceServer interface {
	Collect(TraceSegmentReportService_CollectServer) error
}

TraceSegmentReportServiceServer is the server API for TraceSegmentReportService service. All implementations should embed UnimplementedTraceSegmentReportServiceServer for forward compatibility

type TraceSegmentReportService_CollectClient 

type TraceSegmentReportService_CollectClient interface {
	Send(*agent.UpstreamSegment) error
	CloseAndRecv() (*common.Commands, error)
	grpc.ClientStream
}

type TraceSegmentReportService_CollectServer 

type TraceSegmentReportService_CollectServer interface {
	SendAndClose(*common.Commands) error
	Recv() (*agent.UpstreamSegment, error)
	grpc.ServerStream
}

type UnimplementedCLRMetricReportServiceServer 

type UnimplementedCLRMetricReportServiceServer struct {
}

UnimplementedCLRMetricReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCLRMetricReportServiceServer) Collect 

func (UnimplementedCLRMetricReportServiceServer) Collect(context.Context, *CLRMetricCollection) (*common.Commands, error)

type UnimplementedJVMMetricReportServiceServer 

type UnimplementedJVMMetricReportServiceServer struct {
}

UnimplementedJVMMetricReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedJVMMetricReportServiceServer) Collect 

func (UnimplementedJVMMetricReportServiceServer) Collect(context.Context, *JVMMetricCollection) (*common.Commands, error)

type UnimplementedTraceSegmentReportServiceServer 

type UnimplementedTraceSegmentReportServiceServer struct {
}

UnimplementedTraceSegmentReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTraceSegmentReportServiceServer) Collect 

func (UnimplementedTraceSegmentReportServiceServer) Collect(TraceSegmentReportService_CollectServer) error

type UnsafeCLRMetricReportServiceServer 

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

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

type UnsafeJVMMetricReportServiceServer 

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

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

type UnsafeTraceSegmentReportServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.