v3

package
v0.0.0-...-6cb6b35 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 2023 License: MIT Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrorCategory_name = map[int32]string{
		0: "ajax",
		1: "resource",
		2: "vue",
		3: "promise",
		4: "js",
		5: "unknown",
	}
	ErrorCategory_value = map[string]int32{
		"ajax":     0,
		"resource": 1,
		"vue":      2,
		"promise":  3,
		"js":       4,
		"unknown":  5,
	}
)

Enum value maps for ErrorCategory.

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",
	}
	PoolType_value = map[string]int32{
		"CODE_CACHE_USAGE": 0,
		"NEWGEN_USAGE":     1,
		"OLDGEN_USAGE":     2,
		"SURVIVOR_USAGE":   3,
		"PERMGEN_USAGE":    4,
		"METASPACE_USAGE":  5,
	}
)

Enum value maps for PoolType.

View Source
var (
	GCPhase_name = map[int32]string{
		0: "NEW",
		1: "OLD",
		2: "NORMAL",
	}
	GCPhase_value = map[string]int32{
		"NEW":    0,
		"OLD":    1,
		"NORMAL": 2,
	}
)

Enum value maps for GCPhase.

View Source
var (
	SpanType_name = map[int32]string{
		0: "Entry",
		1: "Exit",
		2: "Local",
	}
	SpanType_value = map[string]int32{
		"Entry": 0,
		"Exit":  1,
		"Local": 2,
	}
)

Enum value maps for SpanType.

View Source
var (
	RefType_name = map[int32]string{
		0: "CrossProcess",
		1: "CrossThread",
	}
	RefType_value = map[string]int32{
		"CrossProcess": 0,
		"CrossThread":  1,
	}
)

Enum value maps for RefType.

View Source
var (
	SpanLayer_name = map[int32]string{
		0: "Unknown",
		1: "Database",
		2: "RPCFramework",
		3: "Http",
		4: "MQ",
		5: "Cache",
		6: "FAAS",
	}
	SpanLayer_value = map[string]int32{
		"Unknown":      0,
		"Database":     1,
		"RPCFramework": 2,
		"Http":         3,
		"MQ":           4,
		"Cache":        5,
		"FAAS":         6,
	}
)

Enum value maps for SpanLayer.

View Source
var (
	SpanAttachedEvent_SpanReferenceType_name = map[int32]string{
		0: "SKYWALKING",
		1: "ZIPKIN",
	}
	SpanAttachedEvent_SpanReferenceType_value = map[string]int32{
		"SKYWALKING": 0,
		"ZIPKIN":     1,
	}
)

Enum value maps for SpanAttachedEvent_SpanReferenceType.

View Source
var File_browser_BrowserPerf_proto protoreflect.FileDescriptor
View Source
var File_language_agent_CLRMetric_proto protoreflect.FileDescriptor
View Source
var File_language_agent_JVMMetric_proto protoreflect.FileDescriptor
View Source
var File_language_agent_Meter_proto protoreflect.FileDescriptor
View Source
var File_language_agent_Tracing_proto protoreflect.FileDescriptor

Functions

func RegisterBrowserPerfServiceServer

func RegisterBrowserPerfServiceServer(s grpc.ServiceRegistrar, srv BrowserPerfServiceServer)

func RegisterCLRMetricReportServiceServer

func RegisterCLRMetricReportServiceServer(s grpc.ServiceRegistrar, srv CLRMetricReportServiceServer)

func RegisterJVMMetricReportServiceServer

func RegisterJVMMetricReportServiceServer(s grpc.ServiceRegistrar, srv JVMMetricReportServiceServer)

func RegisterMeterReportServiceServer

func RegisterMeterReportServiceServer(s grpc.ServiceRegistrar, srv MeterReportServiceServer)

func RegisterSpanAttachedEventReportServiceServer

func RegisterSpanAttachedEventReportServiceServer(s grpc.ServiceRegistrar, srv SpanAttachedEventReportServiceServer)

func RegisterTraceSegmentReportServiceServer

func RegisterTraceSegmentReportServiceServer(s grpc.ServiceRegistrar, srv TraceSegmentReportServiceServer)

Types

type BrowserErrorLog

type BrowserErrorLog struct {

	// UUID
	UniqueId string `protobuf:"bytes,1,opt,name=uniqueId,proto3" json:"uniqueId,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Service version in browser is the Instance concept in the backend.
	ServiceVersion string `protobuf:"bytes,3,opt,name=serviceVersion,proto3" json:"serviceVersion,omitempty"`
	// Error log time, set by the backend side.
	Time int64 `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	// Page path in browser is the endpoint concept in the backend
	// Page path in the browser, mostly it is URI, without parameter
	PagePath string        `protobuf:"bytes,5,opt,name=pagePath,proto3" json:"pagePath,omitempty"`
	Category ErrorCategory `protobuf:"varint,6,opt,name=category,proto3,enum=skywalking.v3.ErrorCategory" json:"category,omitempty"`
	Grade    string        `protobuf:"bytes,7,opt,name=grade,proto3" json:"grade,omitempty"`
	Message  string        `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"`
	Line     int32         `protobuf:"varint,9,opt,name=line,proto3" json:"line,omitempty"`
	Col      int32         `protobuf:"varint,10,opt,name=col,proto3" json:"col,omitempty"`
	Stack    string        `protobuf:"bytes,11,opt,name=stack,proto3" json:"stack,omitempty"`
	ErrorUrl string        `protobuf:"bytes,12,opt,name=errorUrl,proto3" json:"errorUrl,omitempty"`
	// Then the PV with error is only calculated when firstReportedError is true.
	FirstReportedError bool `protobuf:"varint,13,opt,name=firstReportedError,proto3" json:"firstReportedError,omitempty"`
	// contains filtered or unexported fields
}

func (*BrowserErrorLog) Descriptor deprecated

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

Deprecated: Use BrowserErrorLog.ProtoReflect.Descriptor instead.

func (*BrowserErrorLog) GetCategory

func (x *BrowserErrorLog) GetCategory() ErrorCategory

func (*BrowserErrorLog) GetCol

func (x *BrowserErrorLog) GetCol() int32

func (*BrowserErrorLog) GetErrorUrl

func (x *BrowserErrorLog) GetErrorUrl() string

func (*BrowserErrorLog) GetFirstReportedError

func (x *BrowserErrorLog) GetFirstReportedError() bool

func (*BrowserErrorLog) GetGrade

func (x *BrowserErrorLog) GetGrade() string

func (*BrowserErrorLog) GetLine

func (x *BrowserErrorLog) GetLine() int32

func (*BrowserErrorLog) GetMessage

func (x *BrowserErrorLog) GetMessage() string

func (*BrowserErrorLog) GetPagePath

func (x *BrowserErrorLog) GetPagePath() string

func (*BrowserErrorLog) GetService

func (x *BrowserErrorLog) GetService() string

func (*BrowserErrorLog) GetServiceVersion

func (x *BrowserErrorLog) GetServiceVersion() string

func (*BrowserErrorLog) GetStack

func (x *BrowserErrorLog) GetStack() string

func (*BrowserErrorLog) GetTime

func (x *BrowserErrorLog) GetTime() int64

func (*BrowserErrorLog) GetUniqueId

func (x *BrowserErrorLog) GetUniqueId() string

func (*BrowserErrorLog) ProtoMessage

func (*BrowserErrorLog) ProtoMessage()

func (*BrowserErrorLog) ProtoReflect

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

func (*BrowserErrorLog) Reset

func (x *BrowserErrorLog) Reset()

func (*BrowserErrorLog) String

func (x *BrowserErrorLog) String() string

type BrowserPerfData

type BrowserPerfData struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Service version in browser is the Instance concept in the backend.
	ServiceVersion string `protobuf:"bytes,2,opt,name=serviceVersion,proto3" json:"serviceVersion,omitempty"`
	// Perf data time, set by the backend side.
	Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// Page path in browser is the endpoint concept in the backend
	// Page path in the browser, mostly it is URI, without parameter
	PagePath string `protobuf:"bytes,4,opt,name=pagePath,proto3" json:"pagePath,omitempty"`
	// Unit of all time related field should be `ms`.
	RedirectTime int32 `protobuf:"varint,5,opt,name=redirectTime,proto3" json:"redirectTime,omitempty"`
	// DNS query time
	DnsTime int32 `protobuf:"varint,6,opt,name=dnsTime,proto3" json:"dnsTime,omitempty"`
	// Time to first Byte
	TtfbTime int32 `protobuf:"varint,7,opt,name=ttfbTime,proto3" json:"ttfbTime,omitempty"`
	//  TCP connection time
	TcpTime int32 `protobuf:"varint,8,opt,name=tcpTime,proto3" json:"tcpTime,omitempty"`
	// Content transfer time
	TransTime int32 `protobuf:"varint,9,opt,name=transTime,proto3" json:"transTime,omitempty"`
	// Dom parsing time
	DomAnalysisTime int32 `protobuf:"varint,10,opt,name=domAnalysisTime,proto3" json:"domAnalysisTime,omitempty"`
	// First paint time or blank screen time
	FptTime int32 `protobuf:"varint,11,opt,name=fptTime,proto3" json:"fptTime,omitempty"`
	// Dom ready time
	DomReadyTime int32 `protobuf:"varint,12,opt,name=domReadyTime,proto3" json:"domReadyTime,omitempty"`
	// Page full load time
	LoadPageTime int32 `protobuf:"varint,13,opt,name=loadPageTime,proto3" json:"loadPageTime,omitempty"`
	// Synchronous load resources in the page
	ResTime int32 `protobuf:"varint,14,opt,name=resTime,proto3" json:"resTime,omitempty"`
	// Only valid for HTTPS
	SslTime int32 `protobuf:"varint,15,opt,name=sslTime,proto3" json:"sslTime,omitempty"`
	// Time to interact
	TtlTime int32 `protobuf:"varint,16,opt,name=ttlTime,proto3" json:"ttlTime,omitempty"`
	// First pack time
	FirstPackTime int32 `protobuf:"varint,17,opt,name=firstPackTime,proto3" json:"firstPackTime,omitempty"`
	// First Meaningful Paint
	FmpTime int32 `protobuf:"varint,18,opt,name=fmpTime,proto3" json:"fmpTime,omitempty"`
	// contains filtered or unexported fields
}

func (*BrowserPerfData) Descriptor deprecated

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

Deprecated: Use BrowserPerfData.ProtoReflect.Descriptor instead.

func (*BrowserPerfData) GetDnsTime

func (x *BrowserPerfData) GetDnsTime() int32

func (*BrowserPerfData) GetDomAnalysisTime

func (x *BrowserPerfData) GetDomAnalysisTime() int32

func (*BrowserPerfData) GetDomReadyTime

func (x *BrowserPerfData) GetDomReadyTime() int32

func (*BrowserPerfData) GetFirstPackTime

func (x *BrowserPerfData) GetFirstPackTime() int32

func (*BrowserPerfData) GetFmpTime

func (x *BrowserPerfData) GetFmpTime() int32

func (*BrowserPerfData) GetFptTime

func (x *BrowserPerfData) GetFptTime() int32

func (*BrowserPerfData) GetLoadPageTime

func (x *BrowserPerfData) GetLoadPageTime() int32

func (*BrowserPerfData) GetPagePath

func (x *BrowserPerfData) GetPagePath() string

func (*BrowserPerfData) GetRedirectTime

func (x *BrowserPerfData) GetRedirectTime() int32

func (*BrowserPerfData) GetResTime

func (x *BrowserPerfData) GetResTime() int32

func (*BrowserPerfData) GetService

func (x *BrowserPerfData) GetService() string

func (*BrowserPerfData) GetServiceVersion

func (x *BrowserPerfData) GetServiceVersion() string

func (*BrowserPerfData) GetSslTime

func (x *BrowserPerfData) GetSslTime() int32

func (*BrowserPerfData) GetTcpTime

func (x *BrowserPerfData) GetTcpTime() int32

func (*BrowserPerfData) GetTime

func (x *BrowserPerfData) GetTime() int64

func (*BrowserPerfData) GetTransTime

func (x *BrowserPerfData) GetTransTime() int32

func (*BrowserPerfData) GetTtfbTime

func (x *BrowserPerfData) GetTtfbTime() int32

func (*BrowserPerfData) GetTtlTime

func (x *BrowserPerfData) GetTtlTime() int32

func (*BrowserPerfData) ProtoMessage

func (*BrowserPerfData) ProtoMessage()

func (*BrowserPerfData) ProtoReflect

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

func (*BrowserPerfData) Reset

func (x *BrowserPerfData) Reset()

func (*BrowserPerfData) String

func (x *BrowserPerfData) String() string

type BrowserPerfServiceClient

type BrowserPerfServiceClient interface {
	// report once per page
	CollectPerfData(ctx context.Context, in *BrowserPerfData, opts ...grpc.CallOption) (*v3.Commands, error)
	// report one or more error logs for pages, could report multiple times.
	CollectErrorLogs(ctx context.Context, opts ...grpc.CallOption) (BrowserPerfService_CollectErrorLogsClient, error)
}

BrowserPerfServiceClient is the client API for BrowserPerfService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type BrowserPerfServiceServer

type BrowserPerfServiceServer interface {
	// report once per page
	CollectPerfData(context.Context, *BrowserPerfData) (*v3.Commands, error)
	// report one or more error logs for pages, could report multiple times.
	CollectErrorLogs(BrowserPerfService_CollectErrorLogsServer) error
	// contains filtered or unexported methods
}

BrowserPerfServiceServer is the server API for BrowserPerfService service. All implementations must embed UnimplementedBrowserPerfServiceServer for forward compatibility

type BrowserPerfService_CollectErrorLogsClient

type BrowserPerfService_CollectErrorLogsClient interface {
	Send(*BrowserErrorLog) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type BrowserPerfService_CollectErrorLogsServer

type BrowserPerfService_CollectErrorLogsServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*BrowserErrorLog, error)
	grpc.ServerStream
}

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"`
	// contains filtered or unexported fields
}

func (*CLRMetric) Descriptor deprecated

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

Deprecated: Use CLRMetric.ProtoReflect.Descriptor instead.

func (*CLRMetric) GetCpu

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

func (*CLRMetric) GetGc

func (x *CLRMetric) GetGc() *ClrGC

func (*CLRMetric) GetThread

func (x *CLRMetric) GetThread() *ClrThread

func (*CLRMetric) GetTime

func (x *CLRMetric) GetTime() int64

func (*CLRMetric) ProtoMessage

func (*CLRMetric) ProtoMessage()

func (*CLRMetric) ProtoReflect

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

func (*CLRMetric) Reset

func (x *CLRMetric) Reset()

func (*CLRMetric) String

func (x *CLRMetric) String() string

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"`
	// contains filtered or unexported fields
}

func (*CLRMetricCollection) Descriptor deprecated

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

Deprecated: Use CLRMetricCollection.ProtoReflect.Descriptor instead.

func (*CLRMetricCollection) GetMetrics

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

func (*CLRMetricCollection) GetService

func (x *CLRMetricCollection) GetService() string

func (*CLRMetricCollection) GetServiceInstance

func (x *CLRMetricCollection) GetServiceInstance() string

func (*CLRMetricCollection) ProtoMessage

func (*CLRMetricCollection) ProtoMessage()

func (*CLRMetricCollection) ProtoReflect

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

func (*CLRMetricCollection) Reset

func (x *CLRMetricCollection) Reset()

func (*CLRMetricCollection) String

func (x *CLRMetricCollection) String() string

type CLRMetricReportServiceClient

type CLRMetricReportServiceClient interface {
	Collect(ctx context.Context, in *CLRMetricCollection, opts ...grpc.CallOption) (*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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type CLRMetricReportServiceServer

type CLRMetricReportServiceServer interface {
	Collect(context.Context, *CLRMetricCollection) (*v3.Commands, error)
	// contains filtered or unexported methods
}

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

type Class

type Class struct {
	LoadedClassCount        int64 `protobuf:"varint,1,opt,name=loadedClassCount,proto3" json:"loadedClassCount,omitempty"`
	TotalUnloadedClassCount int64 `protobuf:"varint,2,opt,name=totalUnloadedClassCount,proto3" json:"totalUnloadedClassCount,omitempty"`
	TotalLoadedClassCount   int64 `protobuf:"varint,3,opt,name=totalLoadedClassCount,proto3" json:"totalLoadedClassCount,omitempty"`
	// contains filtered or unexported fields
}

See: https://docs.oracle.com/javase/8/docs/api/java/lang/management/ClassLoadingMXBean.html

func (*Class) Descriptor deprecated

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

Deprecated: Use Class.ProtoReflect.Descriptor instead.

func (*Class) GetLoadedClassCount

func (x *Class) GetLoadedClassCount() int64

func (*Class) GetTotalLoadedClassCount

func (x *Class) GetTotalLoadedClassCount() int64

func (*Class) GetTotalUnloadedClassCount

func (x *Class) GetTotalUnloadedClassCount() int64

func (*Class) ProtoMessage

func (*Class) ProtoMessage()

func (*Class) ProtoReflect

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

func (*Class) Reset

func (x *Class) Reset()

func (*Class) String

func (x *Class) String() string

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"`
	// contains filtered or unexported fields
}

func (*ClrGC) Descriptor deprecated

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

Deprecated: Use ClrGC.ProtoReflect.Descriptor instead.

func (*ClrGC) GetGen0CollectCount

func (x *ClrGC) GetGen0CollectCount() int64

func (*ClrGC) GetGen1CollectCount

func (x *ClrGC) GetGen1CollectCount() int64

func (*ClrGC) GetGen2CollectCount

func (x *ClrGC) GetGen2CollectCount() int64

func (*ClrGC) GetHeapMemory

func (x *ClrGC) GetHeapMemory() int64

func (*ClrGC) ProtoMessage

func (*ClrGC) ProtoMessage()

func (*ClrGC) ProtoReflect

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

func (*ClrGC) Reset

func (x *ClrGC) Reset()

func (*ClrGC) String

func (x *ClrGC) String() string

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"`
	// contains filtered or unexported fields
}

func (*ClrThread) Descriptor deprecated

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

Deprecated: Use ClrThread.ProtoReflect.Descriptor instead.

func (*ClrThread) GetAvailableCompletionPortThreads

func (x *ClrThread) GetAvailableCompletionPortThreads() int32

func (*ClrThread) GetAvailableWorkerThreads

func (x *ClrThread) GetAvailableWorkerThreads() int32

func (*ClrThread) GetMaxCompletionPortThreads

func (x *ClrThread) GetMaxCompletionPortThreads() int32

func (*ClrThread) GetMaxWorkerThreads

func (x *ClrThread) GetMaxWorkerThreads() int32

func (*ClrThread) ProtoMessage

func (*ClrThread) ProtoMessage()

func (*ClrThread) ProtoReflect

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

func (*ClrThread) Reset

func (x *ClrThread) Reset()

func (*ClrThread) String

func (x *ClrThread) String() string

type ErrorCategory

type ErrorCategory int32
const (
	ErrorCategory_ajax     ErrorCategory = 0
	ErrorCategory_resource ErrorCategory = 1
	ErrorCategory_vue      ErrorCategory = 2
	ErrorCategory_promise  ErrorCategory = 3
	ErrorCategory_js       ErrorCategory = 4
	ErrorCategory_unknown  ErrorCategory = 5
)

func (ErrorCategory) Descriptor

func (ErrorCategory) Enum

func (x ErrorCategory) Enum() *ErrorCategory

func (ErrorCategory) EnumDescriptor deprecated

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

Deprecated: Use ErrorCategory.Descriptor instead.

func (ErrorCategory) Number

func (ErrorCategory) String

func (x ErrorCategory) String() string

func (ErrorCategory) Type

type GC

type GC struct {
	Phase GCPhase `protobuf:"varint,1,opt,name=phase,proto3,enum=skywalking.v3.GCPhase" json:"phase,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"`
	// contains filtered or unexported fields
}

func (*GC) Descriptor deprecated

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

Deprecated: Use GC.ProtoReflect.Descriptor instead.

func (*GC) GetCount

func (x *GC) GetCount() int64

func (*GC) GetPhase

func (x *GC) GetPhase() GCPhase

func (*GC) GetTime

func (x *GC) GetTime() int64

func (*GC) ProtoMessage

func (*GC) ProtoMessage()

func (*GC) ProtoReflect

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

func (*GC) Reset

func (x *GC) Reset()

func (*GC) String

func (x *GC) String() string

type GCPhase

type GCPhase int32
const (
	GCPhase_NEW    GCPhase = 0
	GCPhase_OLD    GCPhase = 1
	GCPhase_NORMAL GCPhase = 2 // The type of GC doesn't have new and old phases, like Z Garbage
)

func (GCPhase) Descriptor

func (GCPhase) Descriptor() protoreflect.EnumDescriptor

func (GCPhase) Enum

func (x GCPhase) Enum() *GCPhase

func (GCPhase) EnumDescriptor deprecated

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

Deprecated: Use GCPhase.Descriptor instead.

func (GCPhase) Number

func (x GCPhase) Number() protoreflect.EnumNumber

func (GCPhase) String

func (x GCPhase) String() string

func (GCPhase) Type

func (GCPhase) Type() protoreflect.EnumType

type ID

type ID struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A ID could be represented by multiple string sections.

func (*ID) Descriptor deprecated

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

Deprecated: Use ID.ProtoReflect.Descriptor instead.

func (*ID) GetId

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

func (*ID) ProtoMessage

func (*ID) ProtoMessage()

func (*ID) ProtoReflect

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

func (*ID) Reset

func (x *ID) Reset()

func (*ID) String

func (x *ID) String() string

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"`
	Thread     *Thread       `protobuf:"bytes,6,opt,name=thread,proto3" json:"thread,omitempty"`
	Clazz      *Class        `protobuf:"bytes,7,opt,name=clazz,proto3" json:"clazz,omitempty"`
	// contains filtered or unexported fields
}

func (*JVMMetric) Descriptor deprecated

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

Deprecated: Use JVMMetric.ProtoReflect.Descriptor instead.

func (*JVMMetric) GetClazz

func (x *JVMMetric) GetClazz() *Class

func (*JVMMetric) GetCpu

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

func (*JVMMetric) GetGc

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

func (*JVMMetric) GetMemory

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

func (*JVMMetric) GetMemoryPool

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

func (*JVMMetric) GetThread

func (x *JVMMetric) GetThread() *Thread

func (*JVMMetric) GetTime

func (x *JVMMetric) GetTime() int64

func (*JVMMetric) ProtoMessage

func (*JVMMetric) ProtoMessage()

func (*JVMMetric) ProtoReflect

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

func (*JVMMetric) Reset

func (x *JVMMetric) Reset()

func (*JVMMetric) String

func (x *JVMMetric) String() string

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"`
	// contains filtered or unexported fields
}

func (*JVMMetricCollection) Descriptor deprecated

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

Deprecated: Use JVMMetricCollection.ProtoReflect.Descriptor instead.

func (*JVMMetricCollection) GetMetrics

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

func (*JVMMetricCollection) GetService

func (x *JVMMetricCollection) GetService() string

func (*JVMMetricCollection) GetServiceInstance

func (x *JVMMetricCollection) GetServiceInstance() string

func (*JVMMetricCollection) ProtoMessage

func (*JVMMetricCollection) ProtoMessage()

func (*JVMMetricCollection) ProtoReflect

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

func (*JVMMetricCollection) Reset

func (x *JVMMetricCollection) Reset()

func (*JVMMetricCollection) String

func (x *JVMMetricCollection) String() string

type JVMMetricReportServiceClient

type JVMMetricReportServiceClient interface {
	Collect(ctx context.Context, in *JVMMetricCollection, opts ...grpc.CallOption) (*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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type JVMMetricReportServiceServer

type JVMMetricReportServiceServer interface {
	Collect(context.Context, *JVMMetricCollection) (*v3.Commands, error)
	// contains filtered or unexported methods
}

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

type Label

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Label of the meter

func (*Label) Descriptor deprecated

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetName

func (x *Label) GetName() string

func (*Label) GetValue

func (x *Label) GetValue() string

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) ProtoReflect

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

func (*Label) Reset

func (x *Label) Reset()

func (*Label) String

func (x *Label) String() string

type Log

type Log struct {

	// The timestamp in milliseconds of this event.,
	// measured between the current time and midnight, January 1, 1970 UTC.
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	// String key, String value pair.
	Data []*v3.KeyStringValuePair `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetData

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

func (*Log) GetTime

func (x *Log) GetTime() int64

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

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

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

type 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"`
	// contains filtered or unexported fields
}

func (*Memory) Descriptor deprecated

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

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetCommitted

func (x *Memory) GetCommitted() int64

func (*Memory) GetInit

func (x *Memory) GetInit() int64

func (*Memory) GetIsHeap

func (x *Memory) GetIsHeap() bool

func (*Memory) GetMax

func (x *Memory) GetMax() int64

func (*Memory) GetUsed

func (x *Memory) GetUsed() int64

func (*Memory) ProtoMessage

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect

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

func (*Memory) Reset

func (x *Memory) Reset()

func (*Memory) String

func (x *Memory) String() string

type MemoryPool

type MemoryPool struct {
	Type      PoolType `protobuf:"varint,1,opt,name=type,proto3,enum=skywalking.v3.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"`
	// contains filtered or unexported fields
}

func (*MemoryPool) Descriptor deprecated

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

Deprecated: Use MemoryPool.ProtoReflect.Descriptor instead.

func (*MemoryPool) GetCommitted

func (x *MemoryPool) GetCommitted() int64

func (*MemoryPool) GetInit

func (x *MemoryPool) GetInit() int64

func (*MemoryPool) GetMax

func (x *MemoryPool) GetMax() int64

func (*MemoryPool) GetType

func (x *MemoryPool) GetType() PoolType

func (*MemoryPool) GetUsed

func (x *MemoryPool) GetUsed() int64

func (*MemoryPool) ProtoMessage

func (*MemoryPool) ProtoMessage()

func (*MemoryPool) ProtoReflect

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

func (*MemoryPool) Reset

func (x *MemoryPool) Reset()

func (*MemoryPool) String

func (x *MemoryPool) String() string

type MeterBucketValue

type MeterBucketValue struct {

	// The value represents the min value of the bucket,
	// the  upper boundary is determined by next MeterBucketValue$bucket,
	// if it doesn't exist, the upper boundary is positive infinity.
	Bucket float64 `protobuf:"fixed64,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Count  int64   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// If is negative infinity, the value of the bucket is invalid
	IsNegativeInfinity bool `protobuf:"varint,3,opt,name=isNegativeInfinity,proto3" json:"isNegativeInfinity,omitempty"`
	// contains filtered or unexported fields
}

The histogram element definition. It includes the bucket lower boundary and the count in the bucket.

func (*MeterBucketValue) Descriptor deprecated

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

Deprecated: Use MeterBucketValue.ProtoReflect.Descriptor instead.

func (*MeterBucketValue) GetBucket

func (x *MeterBucketValue) GetBucket() float64

func (*MeterBucketValue) GetCount

func (x *MeterBucketValue) GetCount() int64

func (*MeterBucketValue) GetIsNegativeInfinity

func (x *MeterBucketValue) GetIsNegativeInfinity() bool

func (*MeterBucketValue) ProtoMessage

func (*MeterBucketValue) ProtoMessage()

func (*MeterBucketValue) ProtoReflect

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

func (*MeterBucketValue) Reset

func (x *MeterBucketValue) Reset()

func (*MeterBucketValue) String

func (x *MeterBucketValue) String() string

type MeterData

type MeterData struct {

	// Meter data could be a single value or histogram.
	//
	// Types that are assignable to Metric:
	//	*MeterData_SingleValue
	//	*MeterData_Histogram
	Metric isMeterData_Metric `protobuf_oneof:"metric"`
	// Service name, be set value in the first element in the stream-call.
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// Service instance name, be set value in the first element in the
	// stream-call.
	ServiceInstance string `protobuf:"bytes,4,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	// Meter data report time, be set value in the first element in the
	// stream-call.
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Single meter data, if the same metrics have a different label, they will separate.

func (*MeterData) Descriptor deprecated

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

Deprecated: Use MeterData.ProtoReflect.Descriptor instead.

func (*MeterData) GetHistogram

func (x *MeterData) GetHistogram() *MeterHistogram

func (*MeterData) GetMetric

func (m *MeterData) GetMetric() isMeterData_Metric

func (*MeterData) GetService

func (x *MeterData) GetService() string

func (*MeterData) GetServiceInstance

func (x *MeterData) GetServiceInstance() string

func (*MeterData) GetSingleValue

func (x *MeterData) GetSingleValue() *MeterSingleValue

func (*MeterData) GetTimestamp

func (x *MeterData) GetTimestamp() int64

func (*MeterData) ProtoMessage

func (*MeterData) ProtoMessage()

func (*MeterData) ProtoReflect

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

func (*MeterData) Reset

func (x *MeterData) Reset()

func (*MeterData) String

func (x *MeterData) String() string

type MeterDataCollection

type MeterDataCollection struct {
	MeterData []*MeterData `protobuf:"bytes,1,rep,name=meterData,proto3" json:"meterData,omitempty"`
	// contains filtered or unexported fields
}

func (*MeterDataCollection) Descriptor deprecated

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

Deprecated: Use MeterDataCollection.ProtoReflect.Descriptor instead.

func (*MeterDataCollection) GetMeterData

func (x *MeterDataCollection) GetMeterData() []*MeterData

func (*MeterDataCollection) ProtoMessage

func (*MeterDataCollection) ProtoMessage()

func (*MeterDataCollection) ProtoReflect

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

func (*MeterDataCollection) Reset

func (x *MeterDataCollection) Reset()

func (*MeterDataCollection) String

func (x *MeterDataCollection) String() string

type MeterData_Histogram

type MeterData_Histogram struct {
	Histogram *MeterHistogram `protobuf:"bytes,2,opt,name=histogram,proto3,oneof"`
}

type MeterData_SingleValue

type MeterData_SingleValue struct {
	SingleValue *MeterSingleValue `protobuf:"bytes,1,opt,name=singleValue,proto3,oneof"`
}

type MeterHistogram

type MeterHistogram struct {

	// Meter name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Labels
	Labels []*Label `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	// Customize the buckets
	Values []*MeterBucketValue `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Histogram

func (*MeterHistogram) Descriptor deprecated

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

Deprecated: Use MeterHistogram.ProtoReflect.Descriptor instead.

func (*MeterHistogram) GetLabels

func (x *MeterHistogram) GetLabels() []*Label

func (*MeterHistogram) GetName

func (x *MeterHistogram) GetName() string

func (*MeterHistogram) GetValues

func (x *MeterHistogram) GetValues() []*MeterBucketValue

func (*MeterHistogram) ProtoMessage

func (*MeterHistogram) ProtoMessage()

func (*MeterHistogram) ProtoReflect

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

func (*MeterHistogram) Reset

func (x *MeterHistogram) Reset()

func (*MeterHistogram) String

func (x *MeterHistogram) String() string

type MeterReportServiceClient

type MeterReportServiceClient interface {
	// Meter data is reported in a certain period. The agent/SDK should report all
	// collected metrics in this period through one stream. The whole stream is an
	// input data set, client should onComplete the stream per report period.
	Collect(ctx context.Context, opts ...grpc.CallOption) (MeterReportService_CollectClient, error)
	// Reporting meter data in bulk mode as MeterDataCollection.
	// By using this, each one in the stream would be treated as a complete input
	// for MAL engine, comparing to `collect (stream MeterData)`, which is using
	// one stream as an input data set.
	CollectBatch(ctx context.Context, opts ...grpc.CallOption) (MeterReportService_CollectBatchClient, error)
}

MeterReportServiceClient is the client API for MeterReportService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type MeterReportServiceServer

type MeterReportServiceServer interface {
	// Meter data is reported in a certain period. The agent/SDK should report all
	// collected metrics in this period through one stream. The whole stream is an
	// input data set, client should onComplete the stream per report period.
	Collect(MeterReportService_CollectServer) error
	// Reporting meter data in bulk mode as MeterDataCollection.
	// By using this, each one in the stream would be treated as a complete input
	// for MAL engine, comparing to `collect (stream MeterData)`, which is using
	// one stream as an input data set.
	CollectBatch(MeterReportService_CollectBatchServer) error
	// contains filtered or unexported methods
}

MeterReportServiceServer is the server API for MeterReportService service. All implementations must embed UnimplementedMeterReportServiceServer for forward compatibility

type MeterReportService_CollectBatchClient

type MeterReportService_CollectBatchClient interface {
	Send(*MeterDataCollection) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type MeterReportService_CollectBatchServer

type MeterReportService_CollectBatchServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*MeterDataCollection, error)
	grpc.ServerStream
}

type MeterReportService_CollectClient

type MeterReportService_CollectClient interface {
	Send(*MeterData) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type MeterReportService_CollectServer

type MeterReportService_CollectServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*MeterData, error)
	grpc.ServerStream
}

type MeterSingleValue

type MeterSingleValue struct {

	// Meter name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Labels
	Labels []*Label `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	// Single value
	Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Meter single value

func (*MeterSingleValue) Descriptor deprecated

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

Deprecated: Use MeterSingleValue.ProtoReflect.Descriptor instead.

func (*MeterSingleValue) GetLabels

func (x *MeterSingleValue) GetLabels() []*Label

func (*MeterSingleValue) GetName

func (x *MeterSingleValue) GetName() string

func (*MeterSingleValue) GetValue

func (x *MeterSingleValue) GetValue() float64

func (*MeterSingleValue) ProtoMessage

func (*MeterSingleValue) ProtoMessage()

func (*MeterSingleValue) ProtoReflect

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

func (*MeterSingleValue) Reset

func (x *MeterSingleValue) Reset()

func (*MeterSingleValue) String

func (x *MeterSingleValue) String() string

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) Descriptor

func (PoolType) Descriptor() protoreflect.EnumDescriptor

func (PoolType) Enum

func (x PoolType) Enum() *PoolType

func (PoolType) EnumDescriptor deprecated

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

Deprecated: Use PoolType.Descriptor instead.

func (PoolType) Number

func (x PoolType) Number() protoreflect.EnumNumber

func (PoolType) String

func (x PoolType) String() string

func (PoolType) Type

type RefType

type RefType int32

Type of the reference

const (
	// Map to the reference targeting the segment in another OS process.
	RefType_CrossProcess RefType = 0
	// Map to the reference targeting the segment in the same process of the
	// current one, just across thread. This is only used when the coding language
	// has the thread concept.
	RefType_CrossThread RefType = 1
)

func (RefType) Descriptor

func (RefType) Descriptor() protoreflect.EnumDescriptor

func (RefType) Enum

func (x RefType) Enum() *RefType

func (RefType) EnumDescriptor deprecated

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

Deprecated: Use RefType.Descriptor instead.

func (RefType) Number

func (x RefType) Number() protoreflect.EnumNumber

func (RefType) String

func (x RefType) String() string

func (RefType) Type

func (RefType) Type() protoreflect.EnumType

type SegmentCollection

type SegmentCollection struct {
	Segments []*SegmentObject `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

The segment collections for trace report in batch and sync mode.

func (*SegmentCollection) Descriptor deprecated

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

Deprecated: Use SegmentCollection.ProtoReflect.Descriptor instead.

func (*SegmentCollection) GetSegments

func (x *SegmentCollection) GetSegments() []*SegmentObject

func (*SegmentCollection) ProtoMessage

func (*SegmentCollection) ProtoMessage()

func (*SegmentCollection) ProtoReflect

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

func (*SegmentCollection) Reset

func (x *SegmentCollection) Reset()

func (*SegmentCollection) String

func (x *SegmentCollection) String() string

type SegmentObject

type SegmentObject struct {

	// A string id represents the whole trace.
	TraceId string `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	// A unique id represents this segment. Other segments could use this id to
	// reference as a child segment.
	TraceSegmentId string `protobuf:"bytes,2,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	// Span collections included in this segment.
	Spans []*SpanObject `protobuf:"bytes,3,rep,name=spans,proto3" json:"spans,omitempty"`
	// **Service**. Represents a set/group of workloads which provide the same
	// behaviours for incoming requests.
	//
	// The logic name represents the service. This would show as a separate node
	// in the topology. The metrics analyzed from the spans, would be aggregated
	// for this entity as the service level.
	Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	// **Service Instance**. Each individual workload in the Service group is
	// known as an instance. Like `pods` in Kubernetes, it doesn't need to be a
	// single OS process, however, if you are using instrument agents, an instance
	// is actually a real OS process.
	//
	// The logic name represents the service instance. This would show as a
	// separate node in the instance relationship. The metrics analyzed from the
	// spans, would be aggregated for this entity as the service instance level.
	ServiceInstance string `protobuf:"bytes,5,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	// Whether the segment includes all tracked spans.
	// In the production environment tracked, some tasks could include too many
	// spans for one request context, such as a batch update for a cache, or an
	// async job. The agent/SDK could optimize or ignore some tracked spans for
	// better performance. In this case, the value should be flagged as TRUE.
	IsSizeLimited bool `protobuf:"varint,6,opt,name=isSizeLimited,proto3" json:"isSizeLimited,omitempty"`
	// contains filtered or unexported fields
}

The segment is a collection of spans. It includes all collected spans in a simple one request context, such as a HTTP request process.

We recommend the agent/SDK report all tracked data of one request once for all. Typically, such as in Java, one segment represent all tracked operations(spans) of one request context in the same thread. At the same time, in some language there is not a clear `thread` concept like golang. Then, it could represent all tracked operations of one request context cross threads/goroutines.

func (*SegmentObject) Descriptor deprecated

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

Deprecated: Use SegmentObject.ProtoReflect.Descriptor instead.

func (*SegmentObject) GetIsSizeLimited

func (x *SegmentObject) GetIsSizeLimited() bool

func (*SegmentObject) GetService

func (x *SegmentObject) GetService() string

func (*SegmentObject) GetServiceInstance

func (x *SegmentObject) GetServiceInstance() string

func (*SegmentObject) GetSpans

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

func (*SegmentObject) GetTraceId

func (x *SegmentObject) GetTraceId() string

func (*SegmentObject) GetTraceSegmentId

func (x *SegmentObject) GetTraceSegmentId() string

func (*SegmentObject) ProtoMessage

func (*SegmentObject) ProtoMessage()

func (*SegmentObject) ProtoReflect

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

func (*SegmentObject) Reset

func (x *SegmentObject) Reset()

func (*SegmentObject) String

func (x *SegmentObject) String() string

type SegmentReference

type SegmentReference struct {

	// Represent the reference type. It could be across thread or across process.
	// Across process means there is a downstream RPC call for this.
	// Typically, refType == CrossProcess means SpanObject#spanType = entry.
	RefType RefType `protobuf:"varint,1,opt,name=refType,proto3,enum=skywalking.v3.RefType" json:"refType,omitempty"`
	// A string id represents the whole trace.
	TraceId string `protobuf:"bytes,2,opt,name=traceId,proto3" json:"traceId,omitempty"`
	// Another segment id as the parent.
	ParentTraceSegmentId string `protobuf:"bytes,3,opt,name=parentTraceSegmentId,proto3" json:"parentTraceSegmentId,omitempty"`
	// The span id in the parent trace segment.
	ParentSpanId int32 `protobuf:"varint,4,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	// The service logic name of the parent segment.
	// If refType == CrossThread, this name is as same as the trace segment.
	ParentService string `protobuf:"bytes,5,opt,name=parentService,proto3" json:"parentService,omitempty"`
	// The service logic name instance of the parent segment.
	// If refType == CrossThread, this name is as same as the trace segment.
	ParentServiceInstance string `protobuf:"bytes,6,opt,name=parentServiceInstance,proto3" json:"parentServiceInstance,omitempty"`
	// The endpoint name of the parent segment.
	// **Endpoint**. A path in a service for incoming requests, such as an HTTP
	// URI path or a gRPC service class + method signature. In a trace segment,
	// the endpoint name is the name of first entry span.
	ParentEndpoint string `protobuf:"bytes,7,opt,name=parentEndpoint,proto3" json:"parentEndpoint,omitempty"`
	// The network address, including ip/hostname and port, which is used in the
	// client side. Such as Client --> use 127.0.11.8:913 -> Server then, in the
	// reference of entry span reported by Server, the value of this field is
	// 127.0.11.8:913. This plays the important role in the SkyWalking
	// STAM(Streaming Topology Analysis Method) For more details, read
	// https://wu-sheng.github.io/STAM/
	NetworkAddressUsedAtPeer string `protobuf:"bytes,8,opt,name=networkAddressUsedAtPeer,proto3" json:"networkAddressUsedAtPeer,omitempty"`
	// contains filtered or unexported fields
}

Segment reference represents the link between two existing segment.

func (*SegmentReference) Descriptor deprecated

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

Deprecated: Use SegmentReference.ProtoReflect.Descriptor instead.

func (*SegmentReference) GetNetworkAddressUsedAtPeer

func (x *SegmentReference) GetNetworkAddressUsedAtPeer() string

func (*SegmentReference) GetParentEndpoint

func (x *SegmentReference) GetParentEndpoint() string

func (*SegmentReference) GetParentService

func (x *SegmentReference) GetParentService() string

func (*SegmentReference) GetParentServiceInstance

func (x *SegmentReference) GetParentServiceInstance() string

func (*SegmentReference) GetParentSpanId

func (x *SegmentReference) GetParentSpanId() int32

func (*SegmentReference) GetParentTraceSegmentId

func (x *SegmentReference) GetParentTraceSegmentId() string

func (*SegmentReference) GetRefType

func (x *SegmentReference) GetRefType() RefType

func (*SegmentReference) GetTraceId

func (x *SegmentReference) GetTraceId() string

func (*SegmentReference) ProtoMessage

func (*SegmentReference) ProtoMessage()

func (*SegmentReference) ProtoReflect

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

func (*SegmentReference) Reset

func (x *SegmentReference) Reset()

func (*SegmentReference) String

func (x *SegmentReference) String() string

type SpanAttachedEvent

type SpanAttachedEvent struct {

	// The nanosecond timestamp of the event's start time.
	// Notice, most unit of timestamp in SkyWalking is milliseconds, but
	// NANO-SECOND is required here. Because the attached event happens in the OS
	// syscall level, most of them are executed rapidly.
	StartTime *v3.Instant `protobuf:"bytes,1,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// The official event name.
	// For example, the event name is a method signature from syscall stack.
	Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// [Optional] The nanosecond timestamp of the event's end time.
	EndTime *v3.Instant `protobuf:"bytes,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// The tags for this event includes some extra OS level information,
	// such as
	// 1. net_device used for this exit span.
	// 2. network L7 protocol
	Tags []*v3.KeyStringValuePair `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// The summary of statistics during this event.
	// Each statistic provides a name(metric name) to represent the name, and an
	// int64/long as the value.
	Summary []*v3.KeyIntValuePair `protobuf:"bytes,5,rep,name=summary,proto3" json:"summary,omitempty"`
	// Refer to a trace context decoded from `sw8` header through network, such as
	// HTTP header, MQ metadata
	// https://skywalking.apache.org/docs/main/next/en/protocols/skywalking-cross-process-propagation-headers-protocol-v3/#standard-header-item
	TraceContext *SpanAttachedEvent_SpanReference `protobuf:"bytes,6,opt,name=traceContext,proto3" json:"traceContext,omitempty"`
	// contains filtered or unexported fields
}

SpanAttachedEvent represents an attached event for a traced RPC.

When an RPC is being traced by the in-process language agent, a span would be reported by the client-side agent. And the rover would be aware of this RPC due to the existing tracing header. Then, the rover agent collects extra information from the OS level to provide assistance information to diagnose network performance.

func (*SpanAttachedEvent) Descriptor deprecated

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

Deprecated: Use SpanAttachedEvent.ProtoReflect.Descriptor instead.

func (*SpanAttachedEvent) GetEndTime

func (x *SpanAttachedEvent) GetEndTime() *v3.Instant

func (*SpanAttachedEvent) GetEvent

func (x *SpanAttachedEvent) GetEvent() string

func (*SpanAttachedEvent) GetStartTime

func (x *SpanAttachedEvent) GetStartTime() *v3.Instant

func (*SpanAttachedEvent) GetSummary

func (x *SpanAttachedEvent) GetSummary() []*v3.KeyIntValuePair

func (*SpanAttachedEvent) GetTags

func (x *SpanAttachedEvent) GetTags() []*v3.KeyStringValuePair

func (*SpanAttachedEvent) GetTraceContext

func (x *SpanAttachedEvent) GetTraceContext() *SpanAttachedEvent_SpanReference

func (*SpanAttachedEvent) ProtoMessage

func (*SpanAttachedEvent) ProtoMessage()

func (*SpanAttachedEvent) ProtoReflect

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

func (*SpanAttachedEvent) Reset

func (x *SpanAttachedEvent) Reset()

func (*SpanAttachedEvent) String

func (x *SpanAttachedEvent) String() string

type SpanAttachedEventReportServiceClient

type SpanAttachedEventReportServiceClient interface {
	// Collect SpanAttachedEvent to the OAP server in the streaming mode.
	Collect(ctx context.Context, opts ...grpc.CallOption) (SpanAttachedEventReportService_CollectClient, error)
}

SpanAttachedEventReportServiceClient is the client API for SpanAttachedEventReportService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SpanAttachedEventReportServiceServer

type SpanAttachedEventReportServiceServer interface {
	// Collect SpanAttachedEvent to the OAP server in the streaming mode.
	Collect(SpanAttachedEventReportService_CollectServer) error
	// contains filtered or unexported methods
}

SpanAttachedEventReportServiceServer is the server API for SpanAttachedEventReportService service. All implementations must embed UnimplementedSpanAttachedEventReportServiceServer for forward compatibility

type SpanAttachedEventReportService_CollectClient

type SpanAttachedEventReportService_CollectClient interface {
	Send(*SpanAttachedEvent) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type SpanAttachedEventReportService_CollectServer

type SpanAttachedEventReportService_CollectServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*SpanAttachedEvent, error)
	grpc.ServerStream
}

type SpanAttachedEvent_SpanReference

type SpanAttachedEvent_SpanReference struct {
	Type SpanAttachedEvent_SpanReferenceType `protobuf:"varint,1,opt,name=type,proto3,enum=skywalking.v3.SpanAttachedEvent_SpanReferenceType" json:"type,omitempty"`
	// [Optional] A string id represents the whole trace.
	TraceId string `protobuf:"bytes,2,opt,name=traceId,proto3" json:"traceId,omitempty"`
	// A unique id represents this segment. Other segments could use this id to
	// reference as a child segment. [Optional] when this span reference
	TraceSegmentId string `protobuf:"bytes,3,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	// If type == SKYWALKING
	// The number id of the span. Should be unique in the whole segment.
	// Starting at 0
	//
	// If type == ZIPKIN
	// The type of span ID is string.
	SpanId string `protobuf:"bytes,4,opt,name=spanId,proto3" json:"spanId,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanAttachedEvent_SpanReference) Descriptor deprecated

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

Deprecated: Use SpanAttachedEvent_SpanReference.ProtoReflect.Descriptor instead.

func (*SpanAttachedEvent_SpanReference) GetSpanId

func (x *SpanAttachedEvent_SpanReference) GetSpanId() string

func (*SpanAttachedEvent_SpanReference) GetTraceId

func (x *SpanAttachedEvent_SpanReference) GetTraceId() string

func (*SpanAttachedEvent_SpanReference) GetTraceSegmentId

func (x *SpanAttachedEvent_SpanReference) GetTraceSegmentId() string

func (*SpanAttachedEvent_SpanReference) GetType

func (*SpanAttachedEvent_SpanReference) ProtoMessage

func (*SpanAttachedEvent_SpanReference) ProtoMessage()

func (*SpanAttachedEvent_SpanReference) ProtoReflect

func (*SpanAttachedEvent_SpanReference) Reset

func (*SpanAttachedEvent_SpanReference) String

type SpanAttachedEvent_SpanReferenceType

type SpanAttachedEvent_SpanReferenceType int32
const (
	SpanAttachedEvent_SKYWALKING SpanAttachedEvent_SpanReferenceType = 0
	SpanAttachedEvent_ZIPKIN     SpanAttachedEvent_SpanReferenceType = 1
)

func (SpanAttachedEvent_SpanReferenceType) Descriptor

func (SpanAttachedEvent_SpanReferenceType) Enum

func (SpanAttachedEvent_SpanReferenceType) EnumDescriptor deprecated

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

Deprecated: Use SpanAttachedEvent_SpanReferenceType.Descriptor instead.

func (SpanAttachedEvent_SpanReferenceType) Number

func (SpanAttachedEvent_SpanReferenceType) String

func (SpanAttachedEvent_SpanReferenceType) Type

type SpanLayer

type SpanLayer int32

Map to the layer of span

const (
	// Unknown layer. Could be anything.
	SpanLayer_Unknown SpanLayer = 0
	// A database layer, used in tracing the database client component.
	SpanLayer_Database SpanLayer = 1
	// A RPC layer, used in both client and server sides of RPC component.
	SpanLayer_RPCFramework SpanLayer = 2
	// HTTP is a more specific RPCFramework.
	SpanLayer_Http SpanLayer = 3
	// A MQ layer, used in both producer and consuer sides of the MQ component.
	SpanLayer_MQ SpanLayer = 4
	// A cache layer, used in tracing the cache client component.
	SpanLayer_Cache SpanLayer = 5
	// A FAAS layer, used in function-as-a-Service platform.
	SpanLayer_FAAS SpanLayer = 6
)

func (SpanLayer) Descriptor

func (SpanLayer) Descriptor() protoreflect.EnumDescriptor

func (SpanLayer) Enum

func (x SpanLayer) Enum() *SpanLayer

func (SpanLayer) EnumDescriptor deprecated

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

Deprecated: Use SpanLayer.Descriptor instead.

func (SpanLayer) Number

func (x SpanLayer) Number() protoreflect.EnumNumber

func (SpanLayer) String

func (x SpanLayer) String() string

func (SpanLayer) Type

type SpanObject

type SpanObject struct {

	// The number id of the span. Should be unique in the whole segment.
	// Starting at 0.
	SpanId int32 `protobuf:"varint,1,opt,name=spanId,proto3" json:"spanId,omitempty"`
	// The number id of the parent span in the whole segment.
	// -1 represents no parent span.
	// Also, be known as the root/first span of the segment.
	ParentSpanId int32 `protobuf:"varint,2,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	// Start timestamp in milliseconds of this span,
	// measured between the current time and midnight, January 1, 1970 UTC.
	StartTime int64 `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// End timestamp in milliseconds of this span,
	// measured between the current time and midnight, January 1, 1970 UTC.
	EndTime int64 `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// <Optional>
	// In the across thread and across process, these references targeting the
	// parent segments. The references usually have only one element, but in batch
	// consumer case, such as in MQ or async batch process, it could be multiple.
	Refs []*SegmentReference `protobuf:"bytes,5,rep,name=refs,proto3" json:"refs,omitempty"`
	// A logic name represents this span.
	//
	// We don't recommend to include the parameter, such as HTTP request
	// parameters, as a part of the operation, especially this is the name of the
	// entry span. All statistic for the endpoints are aggregated base on this
	// name. Those parameters should be added in the tags if necessary. If in some
	// cases, it have to be a part of the operation name, users should use the
	// Group Parameterized Endpoints capability at the backend to get the
	// meaningful metrics. Read
	// https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/endpoint-grouping-rules.md
	OperationName string `protobuf:"bytes,6,opt,name=operationName,proto3" json:"operationName,omitempty"`
	// Remote address of the peer in RPC/MQ case.
	// This is required when spanType = Exit, as it is a part of the SkyWalking
	// STAM(Streaming Topology Analysis Method). For more details, read
	// https://wu-sheng.github.io/STAM/
	Peer string `protobuf:"bytes,7,opt,name=peer,proto3" json:"peer,omitempty"`
	// Span type represents the role in the RPC context.
	SpanType SpanType `protobuf:"varint,8,opt,name=spanType,proto3,enum=skywalking.v3.SpanType" json:"spanType,omitempty"`
	// Span layer represent the component tech stack, related to the network tech.
	SpanLayer SpanLayer `protobuf:"varint,9,opt,name=spanLayer,proto3,enum=skywalking.v3.SpanLayer" json:"spanLayer,omitempty"`
	// Component id is a predefinited number id in the SkyWalking.
	// It represents the framework, tech stack used by this tracked span, such as
	// Spring. All IDs are defined in the
	// https://github.com/apache/skywalking/blob/master/oap-server/server-bootstrap/src/main/resources/component-libraries.yml
	// Send a pull request if you want to add languages, components or mapping
	// defintions, all public components could be accepted. Follow this doc for
	// more details,
	// https://github.com/apache/skywalking/blob/master/docs/en/guides/Component-library-settings.md
	ComponentId int32 `protobuf:"varint,10,opt,name=componentId,proto3" json:"componentId,omitempty"`
	// The status of the span. False means the tracked execution ends in the
	// unexpected status. This affects the successful rate statistic in the
	// backend. Exception or error code happened in the tracked process doesn't
	// mean isError == true, the implementations of agent plugin and tracing SDK
	// make the final decision.
	IsError bool `protobuf:"varint,11,opt,name=isError,proto3" json:"isError,omitempty"`
	// String key, String value pair.
	// Tags provides more informance, includes parameters.
	//
	// In the OAP backend analysis, some special tag or tag combination could
	// provide other advanced features.
	// https://github.com/apache/skywalking/blob/master/docs/en/guides/Java-Plugin-Development-Guide.md#special-span-tags
	Tags []*v3.KeyStringValuePair `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	// String key, String value pair with an accurate timestamp.
	// Logging some events happening in the context of the span duration.
	Logs []*Log `protobuf:"bytes,13,rep,name=logs,proto3" json:"logs,omitempty"`
	// Force the backend don't do analysis, if the value is TRUE.
	// The backend has its own configurations to follow or override this.
	//
	// Use this mostly because the agent/SDK could know more context of the
	// service role.
	SkipAnalysis bool `protobuf:"varint,14,opt,name=skipAnalysis,proto3" json:"skipAnalysis,omitempty"`
	// contains filtered or unexported fields
}

Span represents a execution unit in the system, with duration and many other attributes. Span could be a method, a RPC, MQ message produce or consume. In the practice, the span should be added when it is really necessary, to avoid payload overhead. We recommend to creating spans in across process(client/server of RPC/MQ) and across thread cases only.

func (*SpanObject) Descriptor deprecated

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

Deprecated: Use SpanObject.ProtoReflect.Descriptor instead.

func (*SpanObject) GetComponentId

func (x *SpanObject) GetComponentId() int32

func (*SpanObject) GetEndTime

func (x *SpanObject) GetEndTime() int64

func (*SpanObject) GetIsError

func (x *SpanObject) GetIsError() bool

func (*SpanObject) GetLogs

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

func (*SpanObject) GetOperationName

func (x *SpanObject) GetOperationName() string

func (*SpanObject) GetParentSpanId

func (x *SpanObject) GetParentSpanId() int32

func (*SpanObject) GetPeer

func (x *SpanObject) GetPeer() string

func (*SpanObject) GetRefs

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

func (*SpanObject) GetSkipAnalysis

func (x *SpanObject) GetSkipAnalysis() bool

func (*SpanObject) GetSpanId

func (x *SpanObject) GetSpanId() int32

func (*SpanObject) GetSpanLayer

func (x *SpanObject) GetSpanLayer() SpanLayer

func (*SpanObject) GetSpanType

func (x *SpanObject) GetSpanType() SpanType

func (*SpanObject) GetStartTime

func (x *SpanObject) GetStartTime() int64

func (*SpanObject) GetTags

func (x *SpanObject) GetTags() []*v3.KeyStringValuePair

func (*SpanObject) ProtoMessage

func (*SpanObject) ProtoMessage()

func (*SpanObject) ProtoReflect

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

func (*SpanObject) Reset

func (x *SpanObject) Reset()

func (*SpanObject) String

func (x *SpanObject) String() string

type SpanType

type SpanType int32

Map to the type of span

const (
	// Server side of RPC. Consumer side of MQ.
	SpanType_Entry SpanType = 0
	// Client side of RPC. Producer side of MQ.
	SpanType_Exit SpanType = 1
	// A common local code execution.
	SpanType_Local SpanType = 2
)

func (SpanType) Descriptor

func (SpanType) Descriptor() protoreflect.EnumDescriptor

func (SpanType) Enum

func (x SpanType) Enum() *SpanType

func (SpanType) EnumDescriptor deprecated

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

Deprecated: Use SpanType.Descriptor instead.

func (SpanType) Number

func (x SpanType) Number() protoreflect.EnumNumber

func (SpanType) String

func (x SpanType) String() string

func (SpanType) Type

type Thread

type Thread struct {
	LiveCount                    int64 `protobuf:"varint,1,opt,name=liveCount,proto3" json:"liveCount,omitempty"`
	DaemonCount                  int64 `protobuf:"varint,2,opt,name=daemonCount,proto3" json:"daemonCount,omitempty"`
	PeakCount                    int64 `protobuf:"varint,3,opt,name=peakCount,proto3" json:"peakCount,omitempty"`
	RunnableStateThreadCount     int64 `protobuf:"varint,4,opt,name=runnableStateThreadCount,proto3" json:"runnableStateThreadCount,omitempty"`
	BlockedStateThreadCount      int64 `protobuf:"varint,5,opt,name=blockedStateThreadCount,proto3" json:"blockedStateThreadCount,omitempty"`
	WaitingStateThreadCount      int64 `protobuf:"varint,6,opt,name=waitingStateThreadCount,proto3" json:"waitingStateThreadCount,omitempty"`
	TimedWaitingStateThreadCount int64 `protobuf:"varint,7,opt,name=timedWaitingStateThreadCount,proto3" json:"timedWaitingStateThreadCount,omitempty"`
	// contains filtered or unexported fields
}

See: https://docs.oracle.com/javase/8/docs/api/java/lang/management/ThreadMXBean.html

func (*Thread) Descriptor deprecated

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

Deprecated: Use Thread.ProtoReflect.Descriptor instead.

func (*Thread) GetBlockedStateThreadCount

func (x *Thread) GetBlockedStateThreadCount() int64

func (*Thread) GetDaemonCount

func (x *Thread) GetDaemonCount() int64

func (*Thread) GetLiveCount

func (x *Thread) GetLiveCount() int64

func (*Thread) GetPeakCount

func (x *Thread) GetPeakCount() int64

func (*Thread) GetRunnableStateThreadCount

func (x *Thread) GetRunnableStateThreadCount() int64

func (*Thread) GetTimedWaitingStateThreadCount

func (x *Thread) GetTimedWaitingStateThreadCount() int64

func (*Thread) GetWaitingStateThreadCount

func (x *Thread) GetWaitingStateThreadCount() int64

func (*Thread) ProtoMessage

func (*Thread) ProtoMessage()

func (*Thread) ProtoReflect

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

func (*Thread) Reset

func (x *Thread) Reset()

func (*Thread) String

func (x *Thread) String() string

type TraceSegmentReportServiceClient

type TraceSegmentReportServiceClient interface {
	// Recommended trace segment report channel.
	// gRPC streaming provides better performance.
	// All language agents should choose this.
	Collect(ctx context.Context, opts ...grpc.CallOption) (TraceSegmentReportService_CollectClient, error)
	// An alternative for trace report by using gRPC unary
	// This is provided for some 3rd-party integration, if and only if they prefer
	// the unary mode somehow. The performance of SkyWalking OAP server would be
	// very similar with streaming report, the performance of the network and
	// client side are affected
	CollectInSync(ctx context.Context, in *SegmentCollection, opts ...grpc.CallOption) (*v3.Commands, error)
}

TraceSegmentReportServiceClient is the client API for TraceSegmentReportService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type TraceSegmentReportServiceServer

type TraceSegmentReportServiceServer interface {
	// Recommended trace segment report channel.
	// gRPC streaming provides better performance.
	// All language agents should choose this.
	Collect(TraceSegmentReportService_CollectServer) error
	// An alternative for trace report by using gRPC unary
	// This is provided for some 3rd-party integration, if and only if they prefer
	// the unary mode somehow. The performance of SkyWalking OAP server would be
	// very similar with streaming report, the performance of the network and
	// client side are affected
	CollectInSync(context.Context, *SegmentCollection) (*v3.Commands, error)
	// contains filtered or unexported methods
}

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

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 UnimplementedBrowserPerfServiceServer

type UnimplementedBrowserPerfServiceServer struct {
}

UnimplementedBrowserPerfServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBrowserPerfServiceServer) CollectErrorLogs

func (UnimplementedBrowserPerfServiceServer) CollectPerfData

type UnimplementedCLRMetricReportServiceServer

type UnimplementedCLRMetricReportServiceServer struct {
}

UnimplementedCLRMetricReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCLRMetricReportServiceServer) Collect

type UnimplementedJVMMetricReportServiceServer

type UnimplementedJVMMetricReportServiceServer struct {
}

UnimplementedJVMMetricReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJVMMetricReportServiceServer) Collect

type UnimplementedMeterReportServiceServer

type UnimplementedMeterReportServiceServer struct {
}

UnimplementedMeterReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMeterReportServiceServer) Collect

func (UnimplementedMeterReportServiceServer) CollectBatch

type UnimplementedSpanAttachedEventReportServiceServer

type UnimplementedSpanAttachedEventReportServiceServer struct {
}

UnimplementedSpanAttachedEventReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSpanAttachedEventReportServiceServer) Collect

type UnimplementedTraceSegmentReportServiceServer

type UnimplementedTraceSegmentReportServiceServer struct {
}

UnimplementedTraceSegmentReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceSegmentReportServiceServer) Collect

func (UnimplementedTraceSegmentReportServiceServer) CollectInSync

type UnsafeBrowserPerfServiceServer

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

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

type UnsafeCLRMetricReportServiceServer

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

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

type UnsafeJVMMetricReportServiceServer

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

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

type UnsafeMeterReportServiceServer

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

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

type UnsafeSpanAttachedEventReportServiceServer

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

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

type UnsafeTraceSegmentReportServiceServer

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL