v3

package
v0.0.0-...-5b17d3f Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GCPhrase_name = map[int32]string{
	0: "NEW",
	1: "OLD",
}
View Source 
var GCPhrase_value = map[string]int32{
	"NEW": 0,
	"OLD": 1,
}
View Source 
var PoolType_name = map[int32]string{
	0: "CODE_CACHE_USAGE",
	1: "NEWGEN_USAGE",
	2: "OLDGEN_USAGE",
	3: "SURVIVOR_USAGE",
	4: "PERMGEN_USAGE",
	5: "METASPACE_USAGE",
}
View Source 
var PoolType_value = map[string]int32{
	"CODE_CACHE_USAGE": 0,
	"NEWGEN_USAGE":     1,
	"OLDGEN_USAGE":     2,
	"SURVIVOR_USAGE":   3,
	"PERMGEN_USAGE":    4,
	"METASPACE_USAGE":  5,
}
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 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 CLRMetric 

type CLRMetric struct {
	Time                 int64      `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu                  *v3.CPU    `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Gc                   *ClrGC     `protobuf:"bytes,3,opt,name=gc,proto3" json:"gc,omitempty"`
	Thread               *ClrThread `protobuf:"bytes,4,opt,name=thread,proto3" json:"thread,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CLRMetric) Descriptor 

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

func (*CLRMetric) GetCpu 

func (m *CLRMetric) GetCpu() *v3.CPU

func (*CLRMetric) GetGc 

func (m *CLRMetric) GetGc() *ClrGC

func (*CLRMetric) GetThread 

func (m *CLRMetric) GetThread() *ClrThread

func (*CLRMetric) GetTime 

func (m *CLRMetric) GetTime() int64

func (*CLRMetric) ProtoMessage 

func (*CLRMetric) ProtoMessage()

func (*CLRMetric) Reset 

func (m *CLRMetric) Reset()

func (*CLRMetric) String 

func (m *CLRMetric) String() string

func (*CLRMetric) XXX_DiscardUnknown 

func (m *CLRMetric) XXX_DiscardUnknown()

func (*CLRMetric) XXX_Marshal 

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

func (*CLRMetric) XXX_Merge 

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

func (*CLRMetric) XXX_Size 

func (m *CLRMetric) XXX_Size() int

func (*CLRMetric) XXX_Unmarshal 

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

type CLRMetricCollection 

type CLRMetricCollection struct {
	Metrics              []*CLRMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Service              string       `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string       `protobuf:"bytes,3,opt,name=serviceInstance,proto3" json:"serviceInstance,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() []*CLRMetric

func (*CLRMetricCollection) GetService 

func (m *CLRMetricCollection) GetService() string

func (*CLRMetricCollection) GetServiceInstance 

func (m *CLRMetricCollection) GetServiceInstance() string

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) (*v3.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) (*v3.Commands, error)
}

CLRMetricReportServiceServer is the server API for CLRMetricReportService service.

type ClrGC 

type ClrGC struct {
	Gen0CollectCount     int64    `protobuf:"varint,1,opt,name=Gen0CollectCount,proto3" json:"Gen0CollectCount,omitempty"`
	Gen1CollectCount     int64    `protobuf:"varint,2,opt,name=Gen1CollectCount,proto3" json:"Gen1CollectCount,omitempty"`
	Gen2CollectCount     int64    `protobuf:"varint,3,opt,name=Gen2CollectCount,proto3" json:"Gen2CollectCount,omitempty"`
	HeapMemory           int64    `protobuf:"varint,4,opt,name=HeapMemory,proto3" json:"HeapMemory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClrGC) Descriptor 

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

func (*ClrGC) GetGen0CollectCount 

func (m *ClrGC) GetGen0CollectCount() int64

func (*ClrGC) GetGen1CollectCount 

func (m *ClrGC) GetGen1CollectCount() int64

func (*ClrGC) GetGen2CollectCount 

func (m *ClrGC) GetGen2CollectCount() int64

func (*ClrGC) GetHeapMemory 

func (m *ClrGC) GetHeapMemory() int64

func (*ClrGC) ProtoMessage 

func (*ClrGC) ProtoMessage()

func (*ClrGC) Reset 

func (m *ClrGC) Reset()

func (*ClrGC) String 

func (m *ClrGC) String() string

func (*ClrGC) XXX_DiscardUnknown 

func (m *ClrGC) XXX_DiscardUnknown()

func (*ClrGC) XXX_Marshal 

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

func (*ClrGC) XXX_Merge 

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

func (*ClrGC) XXX_Size 

func (m *ClrGC) XXX_Size() int

func (*ClrGC) XXX_Unmarshal 

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

type ClrThread 

type ClrThread struct {
	AvailableCompletionPortThreads int32    `protobuf:"varint,1,opt,name=AvailableCompletionPortThreads,proto3" json:"AvailableCompletionPortThreads,omitempty"`
	AvailableWorkerThreads         int32    `protobuf:"varint,2,opt,name=AvailableWorkerThreads,proto3" json:"AvailableWorkerThreads,omitempty"`
	MaxCompletionPortThreads       int32    `protobuf:"varint,3,opt,name=MaxCompletionPortThreads,proto3" json:"MaxCompletionPortThreads,omitempty"`
	MaxWorkerThreads               int32    `protobuf:"varint,4,opt,name=MaxWorkerThreads,proto3" json:"MaxWorkerThreads,omitempty"`
	XXX_NoUnkeyedLiteral           struct{} `json:"-"`
	XXX_unrecognized               []byte   `json:"-"`
	XXX_sizecache                  int32    `json:"-"`
}

func (*ClrThread) Descriptor 

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

func (*ClrThread) GetAvailableCompletionPortThreads 

func (m *ClrThread) GetAvailableCompletionPortThreads() int32

func (*ClrThread) GetAvailableWorkerThreads 

func (m *ClrThread) GetAvailableWorkerThreads() int32

func (*ClrThread) GetMaxCompletionPortThreads 

func (m *ClrThread) GetMaxCompletionPortThreads() int32

func (*ClrThread) GetMaxWorkerThreads 

func (m *ClrThread) GetMaxWorkerThreads() int32

func (*ClrThread) ProtoMessage 

func (*ClrThread) ProtoMessage()

func (*ClrThread) Reset 

func (m *ClrThread) Reset()

func (*ClrThread) String 

func (m *ClrThread) String() string

func (*ClrThread) XXX_DiscardUnknown 

func (m *ClrThread) XXX_DiscardUnknown()

func (*ClrThread) XXX_Marshal 

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

func (*ClrThread) XXX_Merge 

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

func (*ClrThread) XXX_Size 

func (m *ClrThread) XXX_Size() int

func (*ClrThread) XXX_Unmarshal 

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

type GC 

type GC struct {
	Phrase               GCPhrase `protobuf:"varint,1,opt,name=phrase,proto3,enum=GCPhrase" json:"phrase,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Time                 int64    `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GC) Descriptor 

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

func (*GC) GetCount 

func (m *GC) GetCount() int64

func (*GC) GetPhrase 

func (m *GC) GetPhrase() GCPhrase

func (*GC) GetTime 

func (m *GC) GetTime() int64

func (*GC) ProtoMessage 

func (*GC) ProtoMessage()

func (*GC) Reset 

func (m *GC) Reset()

func (*GC) String 

func (m *GC) String() string

func (*GC) XXX_DiscardUnknown 

func (m *GC) XXX_DiscardUnknown()

func (*GC) XXX_Marshal 

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

func (*GC) XXX_Merge 

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

func (*GC) XXX_Size 

func (m *GC) XXX_Size() int

func (*GC) XXX_Unmarshal 

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

type GCPhrase 

type GCPhrase int32
const (
	GCPhrase_NEW GCPhrase = 0
	GCPhrase_OLD GCPhrase = 1
)

func (GCPhrase) EnumDescriptor 

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

func (GCPhrase) String 

func (x GCPhrase) String() string

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 JVMMetric 

type JVMMetric struct {
	Time                 int64         `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu                  *v3.CPU       `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory               []*Memory     `protobuf:"bytes,3,rep,name=memory,proto3" json:"memory,omitempty"`
	MemoryPool           []*MemoryPool `protobuf:"bytes,4,rep,name=memoryPool,proto3" json:"memoryPool,omitempty"`
	Gc                   []*GC         `protobuf:"bytes,5,rep,name=gc,proto3" json:"gc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*JVMMetric) Descriptor 

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

func (*JVMMetric) GetCpu 

func (m *JVMMetric) GetCpu() *v3.CPU

func (*JVMMetric) GetGc 

func (m *JVMMetric) GetGc() []*GC

func (*JVMMetric) GetMemory 

func (m *JVMMetric) GetMemory() []*Memory

func (*JVMMetric) GetMemoryPool 

func (m *JVMMetric) GetMemoryPool() []*MemoryPool

func (*JVMMetric) GetTime 

func (m *JVMMetric) GetTime() int64

func (*JVMMetric) ProtoMessage 

func (*JVMMetric) ProtoMessage()

func (*JVMMetric) Reset 

func (m *JVMMetric) Reset()

func (*JVMMetric) String 

func (m *JVMMetric) String() string

func (*JVMMetric) XXX_DiscardUnknown 

func (m *JVMMetric) XXX_DiscardUnknown()

func (*JVMMetric) XXX_Marshal 

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

func (*JVMMetric) XXX_Merge 

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

func (*JVMMetric) XXX_Size 

func (m *JVMMetric) XXX_Size() int

func (*JVMMetric) XXX_Unmarshal 

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

type JVMMetricCollection 

type JVMMetricCollection struct {
	Metrics              []*JVMMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Service              string       `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string       `protobuf:"bytes,3,opt,name=serviceInstance,proto3" json:"serviceInstance,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() []*JVMMetric

func (*JVMMetricCollection) GetService 

func (m *JVMMetricCollection) GetService() string

func (*JVMMetricCollection) GetServiceInstance 

func (m *JVMMetricCollection) GetServiceInstance() string

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) (*v3.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) (*v3.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                 []*v3.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() []*v3.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 Memory 

type Memory struct {
	IsHeap               bool     `protobuf:"varint,1,opt,name=isHeap,proto3" json:"isHeap,omitempty"`
	Init                 int64    `protobuf:"varint,2,opt,name=init,proto3" json:"init,omitempty"`
	Max                  int64    `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Used                 int64    `protobuf:"varint,4,opt,name=used,proto3" json:"used,omitempty"`
	Committed            int64    `protobuf:"varint,5,opt,name=committed,proto3" json:"committed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Memory) Descriptor 

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

func (*Memory) GetCommitted 

func (m *Memory) GetCommitted() int64

func (*Memory) GetInit 

func (m *Memory) GetInit() int64

func (*Memory) GetIsHeap 

func (m *Memory) GetIsHeap() bool

func (*Memory) GetMax 

func (m *Memory) GetMax() int64

func (*Memory) GetUsed 

func (m *Memory) GetUsed() int64

func (*Memory) ProtoMessage 

func (*Memory) ProtoMessage()

func (*Memory) Reset 

func (m *Memory) Reset()

func (*Memory) String 

func (m *Memory) String() string

func (*Memory) XXX_DiscardUnknown 

func (m *Memory) XXX_DiscardUnknown()

func (*Memory) XXX_Marshal 

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

func (*Memory) XXX_Merge 

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

func (*Memory) XXX_Size 

func (m *Memory) XXX_Size() int

func (*Memory) XXX_Unmarshal 

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

type MemoryPool 

type MemoryPool struct {
	Type                 PoolType `protobuf:"varint,1,opt,name=type,proto3,enum=PoolType" json:"type,omitempty"`
	Init                 int64    `protobuf:"varint,2,opt,name=init,proto3" json:"init,omitempty"`
	Max                  int64    `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Used                 int64    `protobuf:"varint,4,opt,name=used,proto3" json:"used,omitempty"`
	Committed            int64    `protobuf:"varint,5,opt,name=committed,proto3" json:"committed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MemoryPool) Descriptor 

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

func (*MemoryPool) GetCommitted 

func (m *MemoryPool) GetCommitted() int64

func (*MemoryPool) GetInit 

func (m *MemoryPool) GetInit() int64

func (*MemoryPool) GetMax 

func (m *MemoryPool) GetMax() int64

func (*MemoryPool) GetType 

func (m *MemoryPool) GetType() PoolType

func (*MemoryPool) GetUsed 

func (m *MemoryPool) GetUsed() int64

func (*MemoryPool) ProtoMessage 

func (*MemoryPool) ProtoMessage()

func (*MemoryPool) Reset 

func (m *MemoryPool) Reset()

func (*MemoryPool) String 

func (m *MemoryPool) String() string

func (*MemoryPool) XXX_DiscardUnknown 

func (m *MemoryPool) XXX_DiscardUnknown()

func (*MemoryPool) XXX_Marshal 

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

func (*MemoryPool) XXX_Merge 

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

func (*MemoryPool) XXX_Size 

func (m *MemoryPool) XXX_Size() int

func (*MemoryPool) XXX_Unmarshal 

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

type PoolType 

type PoolType int32
const (
	PoolType_CODE_CACHE_USAGE PoolType = 0
	PoolType_NEWGEN_USAGE     PoolType = 1
	PoolType_OLDGEN_USAGE     PoolType = 2
	PoolType_SURVIVOR_USAGE   PoolType = 3
	PoolType_PERMGEN_USAGE    PoolType = 4
	PoolType_METASPACE_USAGE  PoolType = 5
)

func (PoolType) EnumDescriptor 

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

func (PoolType) String 

func (x PoolType) String() string

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                 []*v3.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() []*v3.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() (*v3.Commands, error)
	grpc.ClientStream
}

type TraceSegmentReportService_CollectServer 

type TraceSegmentReportService_CollectServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*SegmentObject, 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) (*v3.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) (*v3.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

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.