v3

package
v1.8.8 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

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 (
	GCPhrase_name = map[int32]string{
		0: "NEW",
		1: "OLD",
	}
	GCPhrase_value = map[string]int32{
		"NEW": 0,
		"OLD": 1,
	}
)

Enum value maps for GCPhrase.

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",
	}
	SpanLayer_value = map[string]int32{
		"Unknown":      0,
		"Database":     1,
		"RPCFramework": 2,
		"Http":         3,
		"MQ":           4,
		"Cache":        5,
	}
)

Enum value maps for SpanLayer.

View Source
var BrowserPerfService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.BrowserPerfService",
	HandlerType: (*BrowserPerfServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collectPerfData",
			Handler:    _BrowserPerfService_CollectPerfData_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collectErrorLogs",
			Handler:       _BrowserPerfService_CollectErrorLogs_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "browser/BrowserPerf.proto",
}

BrowserPerfService_ServiceDesc is the grpc.ServiceDesc for BrowserPerfService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var CLRMetricReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.CLRMetricReportService",
	HandlerType: (*CLRMetricReportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collect",
			Handler:    _CLRMetricReportService_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/CLRMetric.proto",
}

CLRMetricReportService_ServiceDesc is the grpc.ServiceDesc for CLRMetricReportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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
View Source
var JVMMetricReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.JVMMetricReportService",
	HandlerType: (*JVMMetricReportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collect",
			Handler:    _JVMMetricReportService_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/JVMMetric.proto",
}

JVMMetricReportService_ServiceDesc is the grpc.ServiceDesc for JVMMetricReportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var MeterReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.MeterReportService",
	HandlerType: (*MeterReportServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collect",
			Handler:       _MeterReportService_Collect_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "language-agent/Meter.proto",
}

MeterReportService_ServiceDesc is the grpc.ServiceDesc for MeterReportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var TraceSegmentReportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.TraceSegmentReportService",
	HandlerType: (*TraceSegmentReportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collectInSync",
			Handler:    _TraceSegmentReportService_CollectInSync_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collect",
			Handler:       _TraceSegmentReportService_Collect_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "language-agent/Tracing.proto",
}

TraceSegmentReportService_ServiceDesc is the grpc.ServiceDesc for TraceSegmentReportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBrowserPerfServiceServer added in v1.1.2

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 RegisterTraceSegmentReportServiceServer

func RegisterTraceSegmentReportServiceServer(s grpc.ServiceRegistrar, srv TraceSegmentReportServiceServer)

Types

type BrowserErrorLog added in v1.1.2

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 added in v1.1.2

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

Deprecated: Use BrowserErrorLog.ProtoReflect.Descriptor instead.

func (*BrowserErrorLog) GetCategory added in v1.1.2

func (x *BrowserErrorLog) GetCategory() ErrorCategory

func (*BrowserErrorLog) GetCol added in v1.1.2

func (x *BrowserErrorLog) GetCol() int32

func (*BrowserErrorLog) GetErrorUrl added in v1.1.2

func (x *BrowserErrorLog) GetErrorUrl() string

func (*BrowserErrorLog) GetFirstReportedError added in v1.1.2

func (x *BrowserErrorLog) GetFirstReportedError() bool

func (*BrowserErrorLog) GetGrade added in v1.1.2

func (x *BrowserErrorLog) GetGrade() string

func (*BrowserErrorLog) GetLine added in v1.1.2

func (x *BrowserErrorLog) GetLine() int32

func (*BrowserErrorLog) GetMessage added in v1.1.2

func (x *BrowserErrorLog) GetMessage() string

func (*BrowserErrorLog) GetPagePath added in v1.1.2

func (x *BrowserErrorLog) GetPagePath() string

func (*BrowserErrorLog) GetService added in v1.1.2

func (x *BrowserErrorLog) GetService() string

func (*BrowserErrorLog) GetServiceVersion added in v1.1.2

func (x *BrowserErrorLog) GetServiceVersion() string

func (*BrowserErrorLog) GetStack added in v1.1.2

func (x *BrowserErrorLog) GetStack() string

func (*BrowserErrorLog) GetTime added in v1.1.2

func (x *BrowserErrorLog) GetTime() int64

func (*BrowserErrorLog) GetUniqueId added in v1.1.2

func (x *BrowserErrorLog) GetUniqueId() string

func (*BrowserErrorLog) ProtoMessage added in v1.1.2

func (*BrowserErrorLog) ProtoMessage()

func (*BrowserErrorLog) ProtoReflect added in v1.1.2

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

func (*BrowserErrorLog) Reset added in v1.1.2

func (x *BrowserErrorLog) Reset()

func (*BrowserErrorLog) String added in v1.1.2

func (x *BrowserErrorLog) String() string

type BrowserPerfData added in v1.1.2

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 added in v1.1.2

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

Deprecated: Use BrowserPerfData.ProtoReflect.Descriptor instead.

func (*BrowserPerfData) GetDnsTime added in v1.1.2

func (x *BrowserPerfData) GetDnsTime() int32

func (*BrowserPerfData) GetDomAnalysisTime added in v1.1.2

func (x *BrowserPerfData) GetDomAnalysisTime() int32

func (*BrowserPerfData) GetDomReadyTime added in v1.1.2

func (x *BrowserPerfData) GetDomReadyTime() int32

func (*BrowserPerfData) GetFirstPackTime added in v1.1.2

func (x *BrowserPerfData) GetFirstPackTime() int32

func (*BrowserPerfData) GetFmpTime added in v1.1.2

func (x *BrowserPerfData) GetFmpTime() int32

func (*BrowserPerfData) GetFptTime added in v1.1.2

func (x *BrowserPerfData) GetFptTime() int32

func (*BrowserPerfData) GetLoadPageTime added in v1.1.2

func (x *BrowserPerfData) GetLoadPageTime() int32

func (*BrowserPerfData) GetPagePath added in v1.1.2

func (x *BrowserPerfData) GetPagePath() string

func (*BrowserPerfData) GetRedirectTime added in v1.1.2

func (x *BrowserPerfData) GetRedirectTime() int32

func (*BrowserPerfData) GetResTime added in v1.1.2

func (x *BrowserPerfData) GetResTime() int32

func (*BrowserPerfData) GetService added in v1.1.2

func (x *BrowserPerfData) GetService() string

func (*BrowserPerfData) GetServiceVersion added in v1.1.2

func (x *BrowserPerfData) GetServiceVersion() string

func (*BrowserPerfData) GetSslTime added in v1.1.2

func (x *BrowserPerfData) GetSslTime() int32

func (*BrowserPerfData) GetTcpTime added in v1.1.2

func (x *BrowserPerfData) GetTcpTime() int32

func (*BrowserPerfData) GetTime added in v1.1.2

func (x *BrowserPerfData) GetTime() int64

func (*BrowserPerfData) GetTransTime added in v1.1.2

func (x *BrowserPerfData) GetTransTime() int32

func (*BrowserPerfData) GetTtfbTime added in v1.1.2

func (x *BrowserPerfData) GetTtfbTime() int32

func (*BrowserPerfData) GetTtlTime added in v1.1.2

func (x *BrowserPerfData) GetTtlTime() int32

func (*BrowserPerfData) ProtoMessage added in v1.1.2

func (*BrowserPerfData) ProtoMessage()

func (*BrowserPerfData) ProtoReflect added in v1.1.2

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

func (*BrowserPerfData) Reset added in v1.1.2

func (x *BrowserPerfData) Reset()

func (*BrowserPerfData) String added in v1.1.2

func (x *BrowserPerfData) String() string

type BrowserPerfServiceClient added in v1.1.2

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 added in v1.1.2

func NewBrowserPerfServiceClient(cc grpc.ClientConnInterface) BrowserPerfServiceClient

type BrowserPerfServiceServer added in v1.1.2

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
}

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

type BrowserPerfService_CollectErrorLogsClient added in v1.1.2

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

type BrowserPerfService_CollectErrorLogsServer added in v1.1.2

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

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

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 added in v1.1.2

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 added in v1.1.2

func (ErrorCategory) Enum added in v1.1.2

func (x ErrorCategory) Enum() *ErrorCategory

func (ErrorCategory) EnumDescriptor deprecated added in v1.1.2

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

Deprecated: Use ErrorCategory.Descriptor instead.

func (ErrorCategory) Number added in v1.1.2

func (ErrorCategory) String added in v1.1.2

func (x ErrorCategory) String() string

func (ErrorCategory) Type added in v1.1.2

type GC

type GC struct {
	Phrase GCPhrase `protobuf:"varint,1,opt,name=phrase,proto3,enum=skywalking.v3.GCPhrase" json:"phrase,omitempty"`
	Count  int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Time   int64    `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// 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) GetPhrase

func (x *GC) GetPhrase() GCPhrase

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 GCPhrase

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

func (GCPhrase) Descriptor

func (GCPhrase) Descriptor() protoreflect.EnumDescriptor

func (GCPhrase) Enum

func (x GCPhrase) Enum() *GCPhrase

func (GCPhrase) EnumDescriptor deprecated

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

Deprecated: Use GCPhrase.Descriptor instead.

func (GCPhrase) Number

func (x GCPhrase) Number() protoreflect.EnumNumber

func (GCPhrase) String

func (x GCPhrase) String() string

func (GCPhrase) Type

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

func (*JVMMetric) Descriptor deprecated

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

Deprecated: Use JVMMetric.ProtoReflect.Descriptor instead.

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

JVMMetricReportServiceServer is the server API for JVMMetricReportService service. All implementations should 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.
	// Also, could use Int32.MIN_VALUE to represent negative 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"`
	// 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) 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.
	Collect(ctx context.Context, opts ...grpc.CallOption) (MeterReportService_CollectClient, 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.
	Collect(MeterReportService_CollectServer) error
}

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

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, such as, 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 concept like golang, it could represent all tracked operations of one request context.

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

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

func (*Thread) Descriptor deprecated

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

Deprecated: Use Thread.ProtoReflect.Descriptor instead.

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

TraceSegmentReportServiceServer is the server API for TraceSegmentReportService service. All implementations should 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 added in v1.1.2

type UnimplementedBrowserPerfServiceServer struct {
}

UnimplementedBrowserPerfServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBrowserPerfServiceServer) CollectErrorLogs added in v1.1.2

func (UnimplementedBrowserPerfServiceServer) CollectPerfData added in v1.1.2

type UnimplementedCLRMetricReportServiceServer

type UnimplementedCLRMetricReportServiceServer struct {
}

UnimplementedCLRMetricReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCLRMetricReportServiceServer) Collect

type UnimplementedJVMMetricReportServiceServer

type UnimplementedJVMMetricReportServiceServer struct {
}

UnimplementedJVMMetricReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedJVMMetricReportServiceServer) Collect

type UnimplementedMeterReportServiceServer

type UnimplementedMeterReportServiceServer struct {
}

UnimplementedMeterReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedMeterReportServiceServer) Collect

type UnimplementedTraceSegmentReportServiceServer

type UnimplementedTraceSegmentReportServiceServer struct {
}

UnimplementedTraceSegmentReportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTraceSegmentReportServiceServer) Collect

func (UnimplementedTraceSegmentReportServiceServer) CollectInSync

type UnsafeBrowserPerfServiceServer added in v1.1.2

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 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.

Jump to

Keyboard shortcuts

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