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.

func NewBrowserPerfServiceClient 

func NewBrowserPerfServiceClient(cc grpc.ClientConnInterface) BrowserPerfServiceClient

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.

func NewCLRMetricReportServiceClient 

func NewCLRMetricReportServiceClient(cc grpc.ClientConnInterface) CLRMetricReportServiceClient

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) Descriptor() protoreflect.EnumDescriptor

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 (x ErrorCategory) Number() protoreflect.EnumNumber

func (ErrorCategory) String 

func (x ErrorCategory) String() string

func (ErrorCategory) Type 

func (ErrorCategory) Type() protoreflect.EnumType

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.

func NewJVMMetricReportServiceClient 

func NewJVMMetricReportServiceClient(cc grpc.ClientConnInterface) JVMMetricReportServiceClient

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.

func NewMeterReportServiceClient 

func NewMeterReportServiceClient(cc grpc.ClientConnInterface) MeterReportServiceClient

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 

func (PoolType) Type() protoreflect.EnumType

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.

func NewSpanAttachedEventReportServiceClient 

func NewSpanAttachedEventReportServiceClient(cc grpc.ClientConnInterface) SpanAttachedEventReportServiceClient

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 (x *SpanAttachedEvent_SpanReference) GetType() SpanAttachedEvent_SpanReferenceType

func (*SpanAttachedEvent_SpanReference) ProtoMessage 

func (*SpanAttachedEvent_SpanReference) ProtoMessage()

func (*SpanAttachedEvent_SpanReference) ProtoReflect 

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

func (*SpanAttachedEvent_SpanReference) Reset 

func (x *SpanAttachedEvent_SpanReference) Reset()

func (*SpanAttachedEvent_SpanReference) String 

func (x *SpanAttachedEvent_SpanReference) String() 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) Descriptor() protoreflect.EnumDescriptor

func (SpanAttachedEvent_SpanReferenceType) Enum 

func (x SpanAttachedEvent_SpanReferenceType) Enum() *SpanAttachedEvent_SpanReferenceType

func (SpanAttachedEvent_SpanReferenceType) EnumDescriptor deprecated 

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

Deprecated: Use SpanAttachedEvent_SpanReferenceType.Descriptor instead.

func (SpanAttachedEvent_SpanReferenceType) Number 

func (x SpanAttachedEvent_SpanReferenceType) Number() protoreflect.EnumNumber

func (SpanAttachedEvent_SpanReferenceType) String 

func (x SpanAttachedEvent_SpanReferenceType) String() string

func (SpanAttachedEvent_SpanReferenceType) Type 

func (SpanAttachedEvent_SpanReferenceType) Type() protoreflect.EnumType

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 

func (SpanLayer) Type() protoreflect.EnumType

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 

func (SpanType) Type() protoreflect.EnumType

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.

func NewTraceSegmentReportServiceClient 

func NewTraceSegmentReportServiceClient(cc grpc.ClientConnInterface) TraceSegmentReportServiceClient

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) CollectErrorLogs(BrowserPerfService_CollectErrorLogsServer) error

func (UnimplementedBrowserPerfServiceServer) CollectPerfData 

func (UnimplementedBrowserPerfServiceServer) CollectPerfData(context.Context, *BrowserPerfData) (*v3.Commands, error)

type UnimplementedCLRMetricReportServiceServer 

type UnimplementedCLRMetricReportServiceServer struct {
}

UnimplementedCLRMetricReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCLRMetricReportServiceServer) Collect 

func (UnimplementedCLRMetricReportServiceServer) Collect(context.Context, *CLRMetricCollection) (*v3.Commands, error)

type UnimplementedJVMMetricReportServiceServer 

type UnimplementedJVMMetricReportServiceServer struct {
}

UnimplementedJVMMetricReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJVMMetricReportServiceServer) Collect 

func (UnimplementedJVMMetricReportServiceServer) Collect(context.Context, *JVMMetricCollection) (*v3.Commands, error)

type UnimplementedMeterReportServiceServer 

type UnimplementedMeterReportServiceServer struct {
}

UnimplementedMeterReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMeterReportServiceServer) Collect 

func (UnimplementedMeterReportServiceServer) Collect(MeterReportService_CollectServer) error

func (UnimplementedMeterReportServiceServer) CollectBatch 

func (UnimplementedMeterReportServiceServer) CollectBatch(MeterReportService_CollectBatchServer) error

type UnimplementedSpanAttachedEventReportServiceServer 

type UnimplementedSpanAttachedEventReportServiceServer struct {
}

UnimplementedSpanAttachedEventReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSpanAttachedEventReportServiceServer) Collect 

func (UnimplementedSpanAttachedEventReportServiceServer) Collect(SpanAttachedEventReportService_CollectServer) error

type UnimplementedTraceSegmentReportServiceServer 

type UnimplementedTraceSegmentReportServiceServer struct {
}

UnimplementedTraceSegmentReportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceSegmentReportServiceServer) Collect 

func (UnimplementedTraceSegmentReportServiceServer) Collect(TraceSegmentReportService_CollectServer) error

func (UnimplementedTraceSegmentReportServiceServer) CollectInSync 

func (UnimplementedTraceSegmentReportServiceServer) CollectInSync(context.Context, *SegmentCollection) (*v3.Commands, error)

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.

Source Files

View all Source files

Directories

Path Synopsis

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.