language_agent_v2

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCLRMetricReportServiceServer 

func RegisterCLRMetricReportServiceServer(s *grpc.Server, srv CLRMetricReportServiceServer)

func RegisterJVMMetricReportServiceServer 

func RegisterJVMMetricReportServiceServer(s *grpc.Server, srv JVMMetricReportServiceServer)

func RegisterTraceSegmentReportServiceServer 

func RegisterTraceSegmentReportServiceServer(s *grpc.Server, srv TraceSegmentReportServiceServer)

Types

type CLRMetricCollection 

type CLRMetricCollection struct {
	Metrics              []*common.CLRMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ServiceInstanceId    int32               `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CLRMetricCollection) Descriptor 

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

func (*CLRMetricCollection) GetMetrics 

func (m *CLRMetricCollection) GetMetrics() []*common.CLRMetric

func (*CLRMetricCollection) GetServiceInstanceId 

func (m *CLRMetricCollection) GetServiceInstanceId() int32

func (*CLRMetricCollection) ProtoMessage 

func (*CLRMetricCollection) ProtoMessage()

func (*CLRMetricCollection) Reset 

func (m *CLRMetricCollection) Reset()

func (*CLRMetricCollection) String 

func (m *CLRMetricCollection) String() string

func (*CLRMetricCollection) XXX_DiscardUnknown 

func (m *CLRMetricCollection) XXX_DiscardUnknown()

func (*CLRMetricCollection) XXX_Marshal 

func (m *CLRMetricCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CLRMetricCollection) XXX_Merge 

func (m *CLRMetricCollection) XXX_Merge(src proto.Message)

func (*CLRMetricCollection) XXX_Size 

func (m *CLRMetricCollection) XXX_Size() int

func (*CLRMetricCollection) XXX_Unmarshal 

func (m *CLRMetricCollection) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCLRMetricReportServiceClient 

func NewCLRMetricReportServiceClient(cc *grpc.ClientConn) CLRMetricReportServiceClient

type CLRMetricReportServiceServer 

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

CLRMetricReportServiceServer is the server API for CLRMetricReportService service.

type JVMMetricCollection 

type JVMMetricCollection struct {
	Metrics              []*common.JVMMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ServiceInstanceId    int32               `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*JVMMetricCollection) Descriptor 

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

func (*JVMMetricCollection) GetMetrics 

func (m *JVMMetricCollection) GetMetrics() []*common.JVMMetric

func (*JVMMetricCollection) GetServiceInstanceId 

func (m *JVMMetricCollection) GetServiceInstanceId() int32

func (*JVMMetricCollection) ProtoMessage 

func (*JVMMetricCollection) ProtoMessage()

func (*JVMMetricCollection) Reset 

func (m *JVMMetricCollection) Reset()

func (*JVMMetricCollection) String 

func (m *JVMMetricCollection) String() string

func (*JVMMetricCollection) XXX_DiscardUnknown 

func (m *JVMMetricCollection) XXX_DiscardUnknown()

func (*JVMMetricCollection) XXX_Marshal 

func (m *JVMMetricCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JVMMetricCollection) XXX_Merge 

func (m *JVMMetricCollection) XXX_Merge(src proto.Message)

func (*JVMMetricCollection) XXX_Size 

func (m *JVMMetricCollection) XXX_Size() int

func (*JVMMetricCollection) XXX_Unmarshal 

func (m *JVMMetricCollection) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJVMMetricReportServiceClient 

func NewJVMMetricReportServiceClient(cc *grpc.ClientConn) JVMMetricReportServiceClient

type JVMMetricReportServiceServer 

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

JVMMetricReportServiceServer is the server API for JVMMetricReportService service.

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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Log) Descriptor 

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

func (*Log) GetData 

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

func (*Log) GetTime 

func (m *Log) GetTime() int64

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) String 

func (m *Log) String() string

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Log) XXX_Merge 

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

func (m *Log) XXX_Unmarshal(b []byte) error

type SegmentObject 

type SegmentObject struct {
	TraceSegmentId       *common.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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SegmentObject) Descriptor 

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

func (*SegmentObject) GetIsSizeLimited 

func (m *SegmentObject) GetIsSizeLimited() bool

func (*SegmentObject) GetServiceId 

func (m *SegmentObject) GetServiceId() int32

func (*SegmentObject) GetServiceInstanceId 

func (m *SegmentObject) GetServiceInstanceId() int32

func (*SegmentObject) GetSpans 

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

func (*SegmentObject) GetTraceSegmentId 

func (m *SegmentObject) GetTraceSegmentId() *common.UniqueId

func (*SegmentObject) ProtoMessage 

func (*SegmentObject) ProtoMessage()

func (*SegmentObject) Reset 

func (m *SegmentObject) Reset()

func (*SegmentObject) String 

func (m *SegmentObject) String() string

func (*SegmentObject) XXX_DiscardUnknown 

func (m *SegmentObject) XXX_DiscardUnknown()

func (*SegmentObject) XXX_Marshal 

func (m *SegmentObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SegmentObject) XXX_Merge 

func (m *SegmentObject) XXX_Merge(src proto.Message)

func (*SegmentObject) XXX_Size 

func (m *SegmentObject) XXX_Size() int

func (*SegmentObject) XXX_Unmarshal 

func (m *SegmentObject) XXX_Unmarshal(b []byte) error

type SegmentReference 

type SegmentReference struct {
	RefType                 common.RefType   `protobuf:"varint,1,opt,name=refType,proto3,enum=RefType" json:"refType,omitempty"`
	ParentTraceSegmentId    *common.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"`
	XXX_NoUnkeyedLiteral    struct{}         `json:"-"`
	XXX_unrecognized        []byte           `json:"-"`
	XXX_sizecache           int32            `json:"-"`
}

func (*SegmentReference) Descriptor 

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

func (*SegmentReference) GetEntryEndpoint 

func (m *SegmentReference) GetEntryEndpoint() string

func (*SegmentReference) GetEntryEndpointId 

func (m *SegmentReference) GetEntryEndpointId() int32

func (*SegmentReference) GetEntryServiceInstanceId 

func (m *SegmentReference) GetEntryServiceInstanceId() int32

func (*SegmentReference) GetNetworkAddress 

func (m *SegmentReference) GetNetworkAddress() string

func (*SegmentReference) GetNetworkAddressId 

func (m *SegmentReference) GetNetworkAddressId() int32

func (*SegmentReference) GetParentEndpoint 

func (m *SegmentReference) GetParentEndpoint() string

func (*SegmentReference) GetParentEndpointId 

func (m *SegmentReference) GetParentEndpointId() int32

func (*SegmentReference) GetParentServiceInstanceId 

func (m *SegmentReference) GetParentServiceInstanceId() int32

func (*SegmentReference) GetParentSpanId 

func (m *SegmentReference) GetParentSpanId() int32

func (*SegmentReference) GetParentTraceSegmentId 

func (m *SegmentReference) GetParentTraceSegmentId() *common.UniqueId

func (*SegmentReference) GetRefType 

func (m *SegmentReference) GetRefType() common.RefType

func (*SegmentReference) ProtoMessage 

func (*SegmentReference) ProtoMessage()

func (*SegmentReference) Reset 

func (m *SegmentReference) Reset()

func (*SegmentReference) String 

func (m *SegmentReference) String() string

func (*SegmentReference) XXX_DiscardUnknown 

func (m *SegmentReference) XXX_DiscardUnknown()

func (*SegmentReference) XXX_Marshal 

func (m *SegmentReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SegmentReference) XXX_Merge 

func (m *SegmentReference) XXX_Merge(src proto.Message)

func (*SegmentReference) XXX_Size 

func (m *SegmentReference) XXX_Size() int

func (*SegmentReference) XXX_Unmarshal 

func (m *SegmentReference) XXX_Unmarshal(b []byte) error

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             common.SpanType              `protobuf:"varint,10,opt,name=spanType,proto3,enum=SpanType" json:"spanType,omitempty"`
	SpanLayer            common.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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*SpanObjectV2) Descriptor 

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

func (*SpanObjectV2) GetComponent 

func (m *SpanObjectV2) GetComponent() string

func (*SpanObjectV2) GetComponentId 

func (m *SpanObjectV2) GetComponentId() int32

func (*SpanObjectV2) GetEndTime 

func (m *SpanObjectV2) GetEndTime() int64

func (*SpanObjectV2) GetIsError 

func (m *SpanObjectV2) GetIsError() bool

func (*SpanObjectV2) GetLogs 

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

func (*SpanObjectV2) GetOperationName 

func (m *SpanObjectV2) GetOperationName() string

func (*SpanObjectV2) GetOperationNameId 

func (m *SpanObjectV2) GetOperationNameId() int32

func (*SpanObjectV2) GetParentSpanId 

func (m *SpanObjectV2) GetParentSpanId() int32

func (*SpanObjectV2) GetPeer 

func (m *SpanObjectV2) GetPeer() string

func (*SpanObjectV2) GetPeerId 

func (m *SpanObjectV2) GetPeerId() int32

func (*SpanObjectV2) GetRefs 

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

func (*SpanObjectV2) GetSpanId 

func (m *SpanObjectV2) GetSpanId() int32

func (*SpanObjectV2) GetSpanLayer 

func (m *SpanObjectV2) GetSpanLayer() common.SpanLayer

func (*SpanObjectV2) GetSpanType 

func (m *SpanObjectV2) GetSpanType() common.SpanType

func (*SpanObjectV2) GetStartTime 

func (m *SpanObjectV2) GetStartTime() int64

func (*SpanObjectV2) GetTags 

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

func (*SpanObjectV2) ProtoMessage 

func (*SpanObjectV2) ProtoMessage()

func (*SpanObjectV2) Reset 

func (m *SpanObjectV2) Reset()

func (*SpanObjectV2) String 

func (m *SpanObjectV2) String() string

func (*SpanObjectV2) XXX_DiscardUnknown 

func (m *SpanObjectV2) XXX_DiscardUnknown()

func (*SpanObjectV2) XXX_Marshal 

func (m *SpanObjectV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpanObjectV2) XXX_Merge 

func (m *SpanObjectV2) XXX_Merge(src proto.Message)

func (*SpanObjectV2) XXX_Size 

func (m *SpanObjectV2) XXX_Size() int

func (*SpanObjectV2) XXX_Unmarshal 

func (m *SpanObjectV2) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTraceSegmentReportServiceClient 

func NewTraceSegmentReportServiceClient(cc *grpc.ClientConn) TraceSegmentReportServiceClient

type TraceSegmentReportServiceServer 

type TraceSegmentReportServiceServer interface {
	Collect(TraceSegmentReportService_CollectServer) error
}

TraceSegmentReportServiceServer is the server API for TraceSegmentReportService service.

type TraceSegmentReportService_CollectClient 

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

type TraceSegmentReportService_CollectServer 

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

type UnimplementedCLRMetricReportServiceServer 

type UnimplementedCLRMetricReportServiceServer struct {
}

UnimplementedCLRMetricReportServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCLRMetricReportServiceServer) Collect 

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

type UnimplementedJVMMetricReportServiceServer 

type UnimplementedJVMMetricReportServiceServer struct {
}

UnimplementedJVMMetricReportServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJVMMetricReportServiceServer) Collect 

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

type UnimplementedTraceSegmentReportServiceServer 

type UnimplementedTraceSegmentReportServiceServer struct {
}

UnimplementedTraceSegmentReportServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTraceSegmentReportServiceServer) Collect 

func (*UnimplementedTraceSegmentReportServiceServer) Collect(srv TraceSegmentReportService_CollectServer) error

Source Files

View all Source files

Directories

Path Synopsis
Package mock_language_agent_v2 is a generated GoMock package.
 Package mock_language_agent_v2 is a generated GoMock package.

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.