v2

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 GCPhraseV2_name = map[int32]string{
	0: "NEW",
	1: "OLD",
}
View Source 
var GCPhraseV2_value = map[string]int32{
	"NEW": 0,
	"OLD": 1,
}
View Source 
var PoolTypeV2_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 PoolTypeV2_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 RefTypeV2_name = map[int32]string{
	0: "CrossProcess",
	1: "CrossThread",
}
View Source 
var RefTypeV2_value = map[string]int32{
	"CrossProcess": 0,
	"CrossThread":  1,
}
View Source 
var SpanLayerV2_name = map[int32]string{
	0: "Unknown",
	1: "Database",
	2: "RPCFramework",
	3: "Http",
	4: "MQ",
	5: "Cache",
}
View Source 
var SpanLayerV2_value = map[string]int32{
	"Unknown":      0,
	"Database":     1,
	"RPCFramework": 2,
	"Http":         3,
	"MQ":           4,
	"Cache":        5,
}
View Source 
var SpanTypeV2_name = map[int32]string{
	0: "Entry",
	1: "Exit",
	2: "Local",
}
View Source 
var SpanTypeV2_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 CLRMetricCollectionV2 

type CLRMetricCollectionV2 struct {
	Metrics              []*CLRMetricV2 `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 (*CLRMetricCollectionV2) Descriptor 

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

func (*CLRMetricCollectionV2) GetMetrics 

func (m *CLRMetricCollectionV2) GetMetrics() []*CLRMetricV2

func (*CLRMetricCollectionV2) GetServiceInstanceId 

func (m *CLRMetricCollectionV2) GetServiceInstanceId() int32

func (*CLRMetricCollectionV2) ProtoMessage 

func (*CLRMetricCollectionV2) ProtoMessage()

func (*CLRMetricCollectionV2) Reset 

func (m *CLRMetricCollectionV2) Reset()

func (*CLRMetricCollectionV2) String 

func (m *CLRMetricCollectionV2) String() string

func (*CLRMetricCollectionV2) XXX_DiscardUnknown 

func (m *CLRMetricCollectionV2) XXX_DiscardUnknown()

func (*CLRMetricCollectionV2) XXX_Marshal 

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

func (*CLRMetricCollectionV2) XXX_Merge 

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

func (*CLRMetricCollectionV2) XXX_Size 

func (m *CLRMetricCollectionV2) XXX_Size() int

func (*CLRMetricCollectionV2) XXX_Unmarshal 

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

type CLRMetricReportServiceClient 

type CLRMetricReportServiceClient interface {
	Collect(ctx context.Context, in *CLRMetricCollectionV2, opts ...grpc.CallOption) (*v2.CommandsV2, 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, *CLRMetricCollectionV2) (*v2.CommandsV2, error)
}

CLRMetricReportServiceServer is the server API for CLRMetricReportService service.

type CLRMetricV2 

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

func (*CLRMetricV2) Descriptor 

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

func (*CLRMetricV2) GetCpu 

func (m *CLRMetricV2) GetCpu() *v2.CPUV2

func (*CLRMetricV2) GetGc 

func (m *CLRMetricV2) GetGc() *ClrGCV2

func (*CLRMetricV2) GetThread 

func (m *CLRMetricV2) GetThread() *ClrThreadV2

func (*CLRMetricV2) GetTime 

func (m *CLRMetricV2) GetTime() int64

func (*CLRMetricV2) ProtoMessage 

func (*CLRMetricV2) ProtoMessage()

func (*CLRMetricV2) Reset 

func (m *CLRMetricV2) Reset()

func (*CLRMetricV2) String 

func (m *CLRMetricV2) String() string

func (*CLRMetricV2) XXX_DiscardUnknown 

func (m *CLRMetricV2) XXX_DiscardUnknown()

func (*CLRMetricV2) XXX_Marshal 

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

func (*CLRMetricV2) XXX_Merge 

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

func (*CLRMetricV2) XXX_Size 

func (m *CLRMetricV2) XXX_Size() int

func (*CLRMetricV2) XXX_Unmarshal 

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

type ClrGCV2 

type ClrGCV2 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 (*ClrGCV2) Descriptor 

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

func (*ClrGCV2) GetGen0CollectCount 

func (m *ClrGCV2) GetGen0CollectCount() int64

func (*ClrGCV2) GetGen1CollectCount 

func (m *ClrGCV2) GetGen1CollectCount() int64

func (*ClrGCV2) GetGen2CollectCount 

func (m *ClrGCV2) GetGen2CollectCount() int64

func (*ClrGCV2) GetHeapMemory 

func (m *ClrGCV2) GetHeapMemory() int64

func (*ClrGCV2) ProtoMessage 

func (*ClrGCV2) ProtoMessage()

func (*ClrGCV2) Reset 

func (m *ClrGCV2) Reset()

func (*ClrGCV2) String 

func (m *ClrGCV2) String() string

func (*ClrGCV2) XXX_DiscardUnknown 

func (m *ClrGCV2) XXX_DiscardUnknown()

func (*ClrGCV2) XXX_Marshal 

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

func (*ClrGCV2) XXX_Merge 

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

func (*ClrGCV2) XXX_Size 

func (m *ClrGCV2) XXX_Size() int

func (*ClrGCV2) XXX_Unmarshal 

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

type ClrThreadV2 

type ClrThreadV2 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 (*ClrThreadV2) Descriptor 

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

func (*ClrThreadV2) GetAvailableCompletionPortThreads 

func (m *ClrThreadV2) GetAvailableCompletionPortThreads() int32

func (*ClrThreadV2) GetAvailableWorkerThreads 

func (m *ClrThreadV2) GetAvailableWorkerThreads() int32

func (*ClrThreadV2) GetMaxCompletionPortThreads 

func (m *ClrThreadV2) GetMaxCompletionPortThreads() int32

func (*ClrThreadV2) GetMaxWorkerThreads 

func (m *ClrThreadV2) GetMaxWorkerThreads() int32

func (*ClrThreadV2) ProtoMessage 

func (*ClrThreadV2) ProtoMessage()

func (*ClrThreadV2) Reset 

func (m *ClrThreadV2) Reset()

func (*ClrThreadV2) String 

func (m *ClrThreadV2) String() string

func (*ClrThreadV2) XXX_DiscardUnknown 

func (m *ClrThreadV2) XXX_DiscardUnknown()

func (*ClrThreadV2) XXX_Marshal 

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

func (*ClrThreadV2) XXX_Merge 

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

func (*ClrThreadV2) XXX_Size 

func (m *ClrThreadV2) XXX_Size() int

func (*ClrThreadV2) XXX_Unmarshal 

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

type GCPhraseV2 

type GCPhraseV2 int32
const (
	GCPhraseV2_NEW GCPhraseV2 = 0
	GCPhraseV2_OLD GCPhraseV2 = 1
)

func (GCPhraseV2) EnumDescriptor 

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

func (GCPhraseV2) String 

func (x GCPhraseV2) String() string

type GCV2 

type GCV2 struct {
	Phrase               GCPhraseV2 `protobuf:"varint,1,opt,name=phrase,proto3,enum=GCPhraseV2" 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 (*GCV2) Descriptor 

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

func (*GCV2) GetCount 

func (m *GCV2) GetCount() int64

func (*GCV2) GetPhrase 

func (m *GCV2) GetPhrase() GCPhraseV2

func (*GCV2) GetTime 

func (m *GCV2) GetTime() int64

func (*GCV2) ProtoMessage 

func (*GCV2) ProtoMessage()

func (*GCV2) Reset 

func (m *GCV2) Reset()

func (*GCV2) String 

func (m *GCV2) String() string

func (*GCV2) XXX_DiscardUnknown 

func (m *GCV2) XXX_DiscardUnknown()

func (*GCV2) XXX_Marshal 

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

func (*GCV2) XXX_Merge 

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

func (*GCV2) XXX_Size 

func (m *GCV2) XXX_Size() int

func (*GCV2) XXX_Unmarshal 

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

type JVMMetricCollectionV2 

type JVMMetricCollectionV2 struct {
	Metrics              []*JVMMetricV2 `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 (*JVMMetricCollectionV2) Descriptor 

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

func (*JVMMetricCollectionV2) GetMetrics 

func (m *JVMMetricCollectionV2) GetMetrics() []*JVMMetricV2

func (*JVMMetricCollectionV2) GetServiceInstanceId 

func (m *JVMMetricCollectionV2) GetServiceInstanceId() int32

func (*JVMMetricCollectionV2) ProtoMessage 

func (*JVMMetricCollectionV2) ProtoMessage()

func (*JVMMetricCollectionV2) Reset 

func (m *JVMMetricCollectionV2) Reset()

func (*JVMMetricCollectionV2) String 

func (m *JVMMetricCollectionV2) String() string

func (*JVMMetricCollectionV2) XXX_DiscardUnknown 

func (m *JVMMetricCollectionV2) XXX_DiscardUnknown()

func (*JVMMetricCollectionV2) XXX_Marshal 

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

func (*JVMMetricCollectionV2) XXX_Merge 

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

func (*JVMMetricCollectionV2) XXX_Size 

func (m *JVMMetricCollectionV2) XXX_Size() int

func (*JVMMetricCollectionV2) XXX_Unmarshal 

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

type JVMMetricReportServiceClient 

type JVMMetricReportServiceClient interface {
	Collect(ctx context.Context, in *JVMMetricCollectionV2, opts ...grpc.CallOption) (*v2.CommandsV2, 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, *JVMMetricCollectionV2) (*v2.CommandsV2, error)
}

JVMMetricReportServiceServer is the server API for JVMMetricReportService service.

type JVMMetricV2 

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

func (*JVMMetricV2) Descriptor 

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

func (*JVMMetricV2) GetCpu 

func (m *JVMMetricV2) GetCpu() *v2.CPUV2

func (*JVMMetricV2) GetGc 

func (m *JVMMetricV2) GetGc() []*GCV2

func (*JVMMetricV2) GetMemory 

func (m *JVMMetricV2) GetMemory() []*MemoryV2

func (*JVMMetricV2) GetMemoryPool 

func (m *JVMMetricV2) GetMemoryPool() []*MemoryPoolV2

func (*JVMMetricV2) GetTime 

func (m *JVMMetricV2) GetTime() int64

func (*JVMMetricV2) ProtoMessage 

func (*JVMMetricV2) ProtoMessage()

func (*JVMMetricV2) Reset 

func (m *JVMMetricV2) Reset()

func (*JVMMetricV2) String 

func (m *JVMMetricV2) String() string

func (*JVMMetricV2) XXX_DiscardUnknown 

func (m *JVMMetricV2) XXX_DiscardUnknown()

func (*JVMMetricV2) XXX_Marshal 

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

func (*JVMMetricV2) XXX_Merge 

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

func (*JVMMetricV2) XXX_Size 

func (m *JVMMetricV2) XXX_Size() int

func (*JVMMetricV2) XXX_Unmarshal 

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

type LogV2 

type LogV2 struct {
	Time                 int64                      `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Data                 []*v2.KeyStringValuePairV2 `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*LogV2) Descriptor 

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

func (*LogV2) GetData 

func (m *LogV2) GetData() []*v2.KeyStringValuePairV2

func (*LogV2) GetTime 

func (m *LogV2) GetTime() int64

func (*LogV2) ProtoMessage 

func (*LogV2) ProtoMessage()

func (*LogV2) Reset 

func (m *LogV2) Reset()

func (*LogV2) String 

func (m *LogV2) String() string

func (*LogV2) XXX_DiscardUnknown 

func (m *LogV2) XXX_DiscardUnknown()

func (*LogV2) XXX_Marshal 

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

func (*LogV2) XXX_Merge 

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

func (*LogV2) XXX_Size 

func (m *LogV2) XXX_Size() int

func (*LogV2) XXX_Unmarshal 

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

type MemoryPoolV2 

type MemoryPoolV2 struct {
	Type                 PoolTypeV2 `protobuf:"varint,1,opt,name=type,proto3,enum=PoolTypeV2" 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"`
	Commited             int64      `protobuf:"varint,5,opt,name=commited,proto3" json:"commited,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MemoryPoolV2) Descriptor 

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

func (*MemoryPoolV2) GetCommited 

func (m *MemoryPoolV2) GetCommited() int64

func (*MemoryPoolV2) GetInit 

func (m *MemoryPoolV2) GetInit() int64

func (*MemoryPoolV2) GetMax 

func (m *MemoryPoolV2) GetMax() int64

func (*MemoryPoolV2) GetType 

func (m *MemoryPoolV2) GetType() PoolTypeV2

func (*MemoryPoolV2) GetUsed 

func (m *MemoryPoolV2) GetUsed() int64

func (*MemoryPoolV2) ProtoMessage 

func (*MemoryPoolV2) ProtoMessage()

func (*MemoryPoolV2) Reset 

func (m *MemoryPoolV2) Reset()

func (*MemoryPoolV2) String 

func (m *MemoryPoolV2) String() string

func (*MemoryPoolV2) XXX_DiscardUnknown 

func (m *MemoryPoolV2) XXX_DiscardUnknown()

func (*MemoryPoolV2) XXX_Marshal 

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

func (*MemoryPoolV2) XXX_Merge 

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

func (*MemoryPoolV2) XXX_Size 

func (m *MemoryPoolV2) XXX_Size() int

func (*MemoryPoolV2) XXX_Unmarshal 

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

type MemoryV2 

type MemoryV2 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 (*MemoryV2) Descriptor 

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

func (*MemoryV2) GetCommitted 

func (m *MemoryV2) GetCommitted() int64

func (*MemoryV2) GetInit 

func (m *MemoryV2) GetInit() int64

func (*MemoryV2) GetIsHeap 

func (m *MemoryV2) GetIsHeap() bool

func (*MemoryV2) GetMax 

func (m *MemoryV2) GetMax() int64

func (*MemoryV2) GetUsed 

func (m *MemoryV2) GetUsed() int64

func (*MemoryV2) ProtoMessage 

func (*MemoryV2) ProtoMessage()

func (*MemoryV2) Reset 

func (m *MemoryV2) Reset()

func (*MemoryV2) String 

func (m *MemoryV2) String() string

func (*MemoryV2) XXX_DiscardUnknown 

func (m *MemoryV2) XXX_DiscardUnknown()

func (*MemoryV2) XXX_Marshal 

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

func (*MemoryV2) XXX_Merge 

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

func (*MemoryV2) XXX_Size 

func (m *MemoryV2) XXX_Size() int

func (*MemoryV2) XXX_Unmarshal 

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

type PoolTypeV2 

type PoolTypeV2 int32
const (
	PoolTypeV2_CODE_CACHE_USAGE PoolTypeV2 = 0
	PoolTypeV2_NEWGEN_USAGE     PoolTypeV2 = 1
	PoolTypeV2_OLDGEN_USAGE     PoolTypeV2 = 2
	PoolTypeV2_SURVIVOR_USAGE   PoolTypeV2 = 3
	PoolTypeV2_PERMGEN_USAGE    PoolTypeV2 = 4
	PoolTypeV2_METASPACE_USAGE  PoolTypeV2 = 5
)

func (PoolTypeV2) EnumDescriptor 

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

func (PoolTypeV2) String 

func (x PoolTypeV2) String() string

type RefTypeV2 

type RefTypeV2 int32
const (
	RefTypeV2_CrossProcess RefTypeV2 = 0
	RefTypeV2_CrossThread  RefTypeV2 = 1
)

func (RefTypeV2) EnumDescriptor 

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

func (RefTypeV2) String 

func (x RefTypeV2) String() string

type SegmentObjectV2 

type SegmentObjectV2 struct {
	TraceSegmentId       *UniqueIdV2     `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 (*SegmentObjectV2) Descriptor 

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

func (*SegmentObjectV2) GetIsSizeLimited 

func (m *SegmentObjectV2) GetIsSizeLimited() bool

func (*SegmentObjectV2) GetServiceId 

func (m *SegmentObjectV2) GetServiceId() int32

func (*SegmentObjectV2) GetServiceInstanceId 

func (m *SegmentObjectV2) GetServiceInstanceId() int32

func (*SegmentObjectV2) GetSpans 

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

func (*SegmentObjectV2) GetTraceSegmentId 

func (m *SegmentObjectV2) GetTraceSegmentId() *UniqueIdV2

func (*SegmentObjectV2) ProtoMessage 

func (*SegmentObjectV2) ProtoMessage()

func (*SegmentObjectV2) Reset 

func (m *SegmentObjectV2) Reset()

func (*SegmentObjectV2) String 

func (m *SegmentObjectV2) String() string

func (*SegmentObjectV2) XXX_DiscardUnknown 

func (m *SegmentObjectV2) XXX_DiscardUnknown()

func (*SegmentObjectV2) XXX_Marshal 

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

func (*SegmentObjectV2) XXX_Merge 

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

func (*SegmentObjectV2) XXX_Size 

func (m *SegmentObjectV2) XXX_Size() int

func (*SegmentObjectV2) XXX_Unmarshal 

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

type SegmentReferenceV2 

type SegmentReferenceV2 struct {
	RefType                 RefTypeV2   `protobuf:"varint,1,opt,name=refType,proto3,enum=RefTypeV2" json:"refType,omitempty"`
	ParentTraceSegmentId    *UniqueIdV2 `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 (*SegmentReferenceV2) Descriptor 

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

func (*SegmentReferenceV2) GetEntryEndpoint 

func (m *SegmentReferenceV2) GetEntryEndpoint() string

func (*SegmentReferenceV2) GetEntryEndpointId 

func (m *SegmentReferenceV2) GetEntryEndpointId() int32

func (*SegmentReferenceV2) GetEntryServiceInstanceId 

func (m *SegmentReferenceV2) GetEntryServiceInstanceId() int32

func (*SegmentReferenceV2) GetNetworkAddress 

func (m *SegmentReferenceV2) GetNetworkAddress() string

func (*SegmentReferenceV2) GetNetworkAddressId 

func (m *SegmentReferenceV2) GetNetworkAddressId() int32

func (*SegmentReferenceV2) GetParentEndpoint 

func (m *SegmentReferenceV2) GetParentEndpoint() string

func (*SegmentReferenceV2) GetParentEndpointId 

func (m *SegmentReferenceV2) GetParentEndpointId() int32

func (*SegmentReferenceV2) GetParentServiceInstanceId 

func (m *SegmentReferenceV2) GetParentServiceInstanceId() int32

func (*SegmentReferenceV2) GetParentSpanId 

func (m *SegmentReferenceV2) GetParentSpanId() int32

func (*SegmentReferenceV2) GetParentTraceSegmentId 

func (m *SegmentReferenceV2) GetParentTraceSegmentId() *UniqueIdV2

func (*SegmentReferenceV2) GetRefType 

func (m *SegmentReferenceV2) GetRefType() RefTypeV2

func (*SegmentReferenceV2) ProtoMessage 

func (*SegmentReferenceV2) ProtoMessage()

func (*SegmentReferenceV2) Reset 

func (m *SegmentReferenceV2) Reset()

func (*SegmentReferenceV2) String 

func (m *SegmentReferenceV2) String() string

func (*SegmentReferenceV2) XXX_DiscardUnknown 

func (m *SegmentReferenceV2) XXX_DiscardUnknown()

func (*SegmentReferenceV2) XXX_Marshal 

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

func (*SegmentReferenceV2) XXX_Merge 

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

func (*SegmentReferenceV2) XXX_Size 

func (m *SegmentReferenceV2) XXX_Size() int

func (*SegmentReferenceV2) XXX_Unmarshal 

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

type SpanLayerV2 

type SpanLayerV2 int32
const (
	SpanLayerV2_Unknown      SpanLayerV2 = 0
	SpanLayerV2_Database     SpanLayerV2 = 1
	SpanLayerV2_RPCFramework SpanLayerV2 = 2
	SpanLayerV2_Http         SpanLayerV2 = 3
	SpanLayerV2_MQ           SpanLayerV2 = 4
	SpanLayerV2_Cache        SpanLayerV2 = 5
)

func (SpanLayerV2) EnumDescriptor 

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

func (SpanLayerV2) String 

func (x SpanLayerV2) 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                 []*SegmentReferenceV2      `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             SpanTypeV2                 `protobuf:"varint,10,opt,name=spanType,proto3,enum=SpanTypeV2" json:"spanType,omitempty"`
	SpanLayer            SpanLayerV2                `protobuf:"varint,11,opt,name=spanLayer,proto3,enum=SpanLayerV2" 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                 []*v2.KeyStringValuePairV2 `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs                 []*LogV2                   `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() []*LogV2

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() []*SegmentReferenceV2

func (*SpanObjectV2) GetSpanId 

func (m *SpanObjectV2) GetSpanId() int32

func (*SpanObjectV2) GetSpanLayer 

func (m *SpanObjectV2) GetSpanLayer() SpanLayerV2

func (*SpanObjectV2) GetSpanType 

func (m *SpanObjectV2) GetSpanType() SpanTypeV2

func (*SpanObjectV2) GetStartTime 

func (m *SpanObjectV2) GetStartTime() int64

func (*SpanObjectV2) GetTags 

func (m *SpanObjectV2) GetTags() []*v2.KeyStringValuePairV2

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 SpanTypeV2 

type SpanTypeV2 int32
const (
	SpanTypeV2_Entry SpanTypeV2 = 0
	SpanTypeV2_Exit  SpanTypeV2 = 1
	SpanTypeV2_Local SpanTypeV2 = 2
)

func (SpanTypeV2) EnumDescriptor 

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

func (SpanTypeV2) String 

func (x SpanTypeV2) 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(*UpstreamSegmentV2) error
	CloseAndRecv() (*v2.CommandsV2, error)
	grpc.ClientStream
}

type TraceSegmentReportService_CollectServer 

type TraceSegmentReportService_CollectServer interface {
	SendAndClose(*v2.CommandsV2) error
	Recv() (*UpstreamSegmentV2, 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 *CLRMetricCollectionV2) (*v2.CommandsV2, 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 *JVMMetricCollectionV2) (*v2.CommandsV2, 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

type UniqueIdV2 

type UniqueIdV2 struct {
	IdParts              []int64  `protobuf:"varint,1,rep,packed,name=idParts,proto3" json:"idParts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UniqueIdV2) Descriptor 

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

func (*UniqueIdV2) GetIdParts 

func (m *UniqueIdV2) GetIdParts() []int64

func (*UniqueIdV2) ProtoMessage 

func (*UniqueIdV2) ProtoMessage()

func (*UniqueIdV2) Reset 

func (m *UniqueIdV2) Reset()

func (*UniqueIdV2) String 

func (m *UniqueIdV2) String() string

func (*UniqueIdV2) XXX_DiscardUnknown 

func (m *UniqueIdV2) XXX_DiscardUnknown()

func (*UniqueIdV2) XXX_Marshal 

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

func (*UniqueIdV2) XXX_Merge 

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

func (*UniqueIdV2) XXX_Size 

func (m *UniqueIdV2) XXX_Size() int

func (*UniqueIdV2) XXX_Unmarshal 

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

type UpstreamSegmentV2 

type UpstreamSegmentV2 struct {
	GlobalTraceIds       []*UniqueIdV2 `protobuf:"bytes,1,rep,name=globalTraceIds,proto3" json:"globalTraceIds,omitempty"`
	Segment              []byte        `protobuf:"bytes,2,opt,name=segment,proto3" json:"segment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UpstreamSegmentV2) Descriptor 

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

func (*UpstreamSegmentV2) GetGlobalTraceIds 

func (m *UpstreamSegmentV2) GetGlobalTraceIds() []*UniqueIdV2

func (*UpstreamSegmentV2) GetSegment 

func (m *UpstreamSegmentV2) GetSegment() []byte

func (*UpstreamSegmentV2) ProtoMessage 

func (*UpstreamSegmentV2) ProtoMessage()

func (*UpstreamSegmentV2) Reset 

func (m *UpstreamSegmentV2) Reset()

func (*UpstreamSegmentV2) String 

func (m *UpstreamSegmentV2) String() string

func (*UpstreamSegmentV2) XXX_DiscardUnknown 

func (m *UpstreamSegmentV2) XXX_DiscardUnknown()

func (*UpstreamSegmentV2) XXX_Marshal 

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

func (*UpstreamSegmentV2) XXX_Merge 

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

func (*UpstreamSegmentV2) XXX_Size 

func (m *UpstreamSegmentV2) XXX_Size() int

func (*UpstreamSegmentV2) XXX_Unmarshal 

func (m *UpstreamSegmentV2) XXX_Unmarshal(b []byte) 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.