language_agent

package
v0.6.5 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2021 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RefType_name = map[int32]string{
	0: "CrossProcess",
	1: "CrossThread",
}
View Source 
var RefType_value = map[string]int32{
	"CrossProcess": 0,
	"CrossThread":  1,
}
View Source 
var SpanLayer_name = map[int32]string{
	0: "Unknown",
	1: "Database",
	2: "RPCFramework",
	3: "Http",
	4: "MQ",
	5: "Cache",
}
View Source 
var SpanLayer_value = map[string]int32{
	"Unknown":      0,
	"Database":     1,
	"RPCFramework": 2,
	"Http":         3,
	"MQ":           4,
	"Cache":        5,
}
View Source 
var SpanType_name = map[int32]string{
	0: "Entry",
	1: "Exit",
	2: "Local",
}
View Source 
var SpanType_value = map[string]int32{
	"Entry": 0,
	"Exit":  1,
	"Local": 2,
}

Functions

func RegisterTraceSegmentReportServiceServer 

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

Types

type ID 

type ID struct {
	Id                   []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ID) Descriptor 

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

func (*ID) GetId 

func (m *ID) GetId() []string

func (*ID) ProtoMessage 

func (*ID) ProtoMessage()

func (*ID) Reset 

func (m *ID) Reset()

func (*ID) String 

func (m *ID) String() string

func (*ID) XXX_DiscardUnknown 

func (m *ID) XXX_DiscardUnknown()

func (*ID) XXX_Marshal 

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

func (*ID) XXX_Merge 

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

func (*ID) XXX_Size 

func (m *ID) XXX_Size() int

func (*ID) XXX_Unmarshal 

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

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 RefType 

type RefType int32
const (
	RefType_CrossProcess RefType = 0
	RefType_CrossThread  RefType = 1
)

func (RefType) EnumDescriptor 

func (RefType) EnumDescriptor() ([]byte, []int)

func (RefType) String 

func (x RefType) String() string

type SegmentObject 

type SegmentObject struct {
	TraceId              string        `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	TraceSegmentId       string        `protobuf:"bytes,2,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	Spans                []*SpanObject `protobuf:"bytes,3,rep,name=spans,proto3" json:"spans,omitempty"`
	Service              string        `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string        `protobuf:"bytes,5,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	IsSizeLimited        bool          `protobuf:"varint,6,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) GetService 

func (m *SegmentObject) GetService() string

func (*SegmentObject) GetServiceInstance 

func (m *SegmentObject) GetServiceInstance() string

func (*SegmentObject) GetSpans 

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

func (*SegmentObject) GetTraceId 

func (m *SegmentObject) GetTraceId() string

func (*SegmentObject) GetTraceSegmentId 

func (m *SegmentObject) GetTraceSegmentId() string

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                  RefType  `protobuf:"varint,1,opt,name=refType,proto3,enum=RefType" json:"refType,omitempty"`
	TraceId                  string   `protobuf:"bytes,2,opt,name=traceId,proto3" json:"traceId,omitempty"`
	ParentTraceSegmentId     string   `protobuf:"bytes,3,opt,name=parentTraceSegmentId,proto3" json:"parentTraceSegmentId,omitempty"`
	ParentSpanId             int32    `protobuf:"varint,4,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	ParentService            string   `protobuf:"bytes,5,opt,name=parentService,proto3" json:"parentService,omitempty"`
	ParentServiceInstance    string   `protobuf:"bytes,6,opt,name=parentServiceInstance,proto3" json:"parentServiceInstance,omitempty"`
	ParentEndpoint           string   `protobuf:"bytes,7,opt,name=parentEndpoint,proto3" json:"parentEndpoint,omitempty"`
	NetworkAddressUsedAtPeer string   `protobuf:"bytes,8,opt,name=networkAddressUsedAtPeer,proto3" json:"networkAddressUsedAtPeer,omitempty"`
	XXX_NoUnkeyedLiteral     struct{} `json:"-"`
	XXX_unrecognized         []byte   `json:"-"`
	XXX_sizecache            int32    `json:"-"`
}

func (*SegmentReference) Descriptor 

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

func (*SegmentReference) GetNetworkAddressUsedAtPeer 

func (m *SegmentReference) GetNetworkAddressUsedAtPeer() string

func (*SegmentReference) GetParentEndpoint 

func (m *SegmentReference) GetParentEndpoint() string

func (*SegmentReference) GetParentService 

func (m *SegmentReference) GetParentService() string

func (*SegmentReference) GetParentServiceInstance 

func (m *SegmentReference) GetParentServiceInstance() string

func (*SegmentReference) GetParentSpanId 

func (m *SegmentReference) GetParentSpanId() int32

func (*SegmentReference) GetParentTraceSegmentId 

func (m *SegmentReference) GetParentTraceSegmentId() string

func (*SegmentReference) GetRefType 

func (m *SegmentReference) GetRefType() RefType

func (*SegmentReference) GetTraceId 

func (m *SegmentReference) GetTraceId() string

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 SpanLayer 

type SpanLayer int32
const (
	SpanLayer_Unknown      SpanLayer = 0
	SpanLayer_Database     SpanLayer = 1
	SpanLayer_RPCFramework SpanLayer = 2
	SpanLayer_Http         SpanLayer = 3
	SpanLayer_MQ           SpanLayer = 4
	SpanLayer_Cache        SpanLayer = 5
)

func (SpanLayer) EnumDescriptor 

func (SpanLayer) EnumDescriptor() ([]byte, []int)

func (SpanLayer) String 

func (x SpanLayer) String() string

type SpanObject 

type SpanObject 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"`
	OperationName        string                       `protobuf:"bytes,6,opt,name=operationName,proto3" json:"operationName,omitempty"`
	Peer                 string                       `protobuf:"bytes,7,opt,name=peer,proto3" json:"peer,omitempty"`
	SpanType             SpanType                     `protobuf:"varint,8,opt,name=spanType,proto3,enum=SpanType" json:"spanType,omitempty"`
	SpanLayer            SpanLayer                    `protobuf:"varint,9,opt,name=spanLayer,proto3,enum=SpanLayer" json:"spanLayer,omitempty"`
	ComponentId          int32                        `protobuf:"varint,10,opt,name=componentId,proto3" json:"componentId,omitempty"`
	IsError              bool                         `protobuf:"varint,11,opt,name=isError,proto3" json:"isError,omitempty"`
	Tags                 []*common.KeyStringValuePair `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs                 []*Log                       `protobuf:"bytes,13,rep,name=logs,proto3" json:"logs,omitempty"`
	SkipAnalysis         bool                         `protobuf:"varint,14,opt,name=skipAnalysis,proto3" json:"skipAnalysis,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*SpanObject) Descriptor 

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

func (*SpanObject) GetComponentId 

func (m *SpanObject) GetComponentId() int32

func (*SpanObject) GetEndTime 

func (m *SpanObject) GetEndTime() int64

func (*SpanObject) GetIsError 

func (m *SpanObject) GetIsError() bool

func (*SpanObject) GetLogs 

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

func (*SpanObject) GetOperationName 

func (m *SpanObject) GetOperationName() string

func (*SpanObject) GetParentSpanId 

func (m *SpanObject) GetParentSpanId() int32

func (*SpanObject) GetPeer 

func (m *SpanObject) GetPeer() string

func (*SpanObject) GetRefs 

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

func (*SpanObject) GetSkipAnalysis 

func (m *SpanObject) GetSkipAnalysis() bool

func (*SpanObject) GetSpanId 

func (m *SpanObject) GetSpanId() int32

func (*SpanObject) GetSpanLayer 

func (m *SpanObject) GetSpanLayer() SpanLayer

func (*SpanObject) GetSpanType 

func (m *SpanObject) GetSpanType() SpanType

func (*SpanObject) GetStartTime 

func (m *SpanObject) GetStartTime() int64

func (*SpanObject) GetTags 

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

func (*SpanObject) ProtoMessage 

func (*SpanObject) ProtoMessage()

func (*SpanObject) Reset 

func (m *SpanObject) Reset()

func (*SpanObject) String 

func (m *SpanObject) String() string

func (*SpanObject) XXX_DiscardUnknown 

func (m *SpanObject) XXX_DiscardUnknown()

func (*SpanObject) XXX_Marshal 

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

func (*SpanObject) XXX_Merge 

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

func (*SpanObject) XXX_Size 

func (m *SpanObject) XXX_Size() int

func (*SpanObject) XXX_Unmarshal 

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

type SpanType 

type SpanType int32
const (
	SpanType_Entry SpanType = 0
	SpanType_Exit  SpanType = 1
	SpanType_Local SpanType = 2
)

func (SpanType) EnumDescriptor 

func (SpanType) EnumDescriptor() ([]byte, []int)

func (SpanType) String 

func (x SpanType) 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://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(*SegmentObject) error
	CloseAndRecv() (*common.Commands, error)
	grpc.ClientStream
}

type TraceSegmentReportService_CollectServer 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock_language_agent is a generated GoMock package.
 Package mock_language_agent 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.