agent

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 ApplicationRegisterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ApplicationRegisterService",
	HandlerType: (*ApplicationRegisterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "applicationCodeRegister",
			Handler:    _ApplicationRegisterService_ApplicationCodeRegister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/ApplicationRegisterService.proto",
}

ApplicationRegisterService_ServiceDesc is the grpc.ServiceDesc for ApplicationRegisterService 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_common_CLR_proto protoreflect.FileDescriptor
View Source 
var File_common_JVM_proto protoreflect.FileDescriptor
View Source 
var File_common_trace_common_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_ApplicationRegisterService_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_DiscoveryService_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_Downstream_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_JVMMetricsService_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_KeyWithIntegerValue_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_KeyWithStringValue_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_NetworkAddressRegisterService_proto protoreflect.FileDescriptor
View Source 
var File_language_agent_TraceSegmentService_proto protoreflect.FileDescriptor
View Source 
var File_register_InstancePing_proto protoreflect.FileDescriptor
View Source 
var File_register_Register_proto protoreflect.FileDescriptor
View Source 
var InstanceDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "InstanceDiscoveryService",
	HandlerType: (*InstanceDiscoveryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "registerInstance",
			Handler:    _InstanceDiscoveryService_RegisterInstance_Handler,
		},
		{
			MethodName: "heartbeat",
			Handler:    _InstanceDiscoveryService_Heartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/DiscoveryService.proto",
}

InstanceDiscoveryService_ServiceDesc is the grpc.ServiceDesc for InstanceDiscoveryService 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 JVMMetricsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "JVMMetricsService",
	HandlerType: (*JVMMetricsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collect",
			Handler:    _JVMMetricsService_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/JVMMetricsService.proto",
}

JVMMetricsService_ServiceDesc is the grpc.ServiceDesc for JVMMetricsService 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 NetworkAddressRegisterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "NetworkAddressRegisterService",
	HandlerType: (*NetworkAddressRegisterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "batchRegister",
			Handler:    _NetworkAddressRegisterService_BatchRegister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/NetworkAddressRegisterService.proto",
}

NetworkAddressRegisterService_ServiceDesc is the grpc.ServiceDesc for NetworkAddressRegisterService 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 Register_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Register",
	HandlerType: (*RegisterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "doServiceRegister",
			Handler:    _Register_DoServiceRegister_Handler,
		},
		{
			MethodName: "doServiceInstanceRegister",
			Handler:    _Register_DoServiceInstanceRegister_Handler,
		},
		{
			MethodName: "doEndpointRegister",
			Handler:    _Register_DoEndpointRegister_Handler,
		},
		{
			MethodName: "doNetworkAddressRegister",
			Handler:    _Register_DoNetworkAddressRegister_Handler,
		},
		{
			MethodName: "doServiceAndNetworkAddressMappingRegister",
			Handler:    _Register_DoServiceAndNetworkAddressMappingRegister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "register/Register.proto",
}

Register_ServiceDesc is the grpc.ServiceDesc for Register 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 ServiceInstancePing_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ServiceInstancePing",
	HandlerType: (*ServiceInstancePingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "doPing",
			Handler:    _ServiceInstancePing_DoPing_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "register/InstancePing.proto",
}

ServiceInstancePing_ServiceDesc is the grpc.ServiceDesc for ServiceInstancePing 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 ServiceNameDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ServiceNameDiscoveryService",
	HandlerType: (*ServiceNameDiscoveryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "discovery",
			Handler:    _ServiceNameDiscoveryService_Discovery_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/DiscoveryService.proto",
}

ServiceNameDiscoveryService_ServiceDesc is the grpc.ServiceDesc for ServiceNameDiscoveryService 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 TraceSegmentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TraceSegmentService",
	HandlerType: (*TraceSegmentServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collect",
			Handler:       _TraceSegmentService_Collect_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "language-agent/TraceSegmentService.proto",
}

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

Functions

func RegisterApplicationRegisterServiceServer 

func RegisterApplicationRegisterServiceServer(s grpc.ServiceRegistrar, srv ApplicationRegisterServiceServer)

func RegisterInstanceDiscoveryServiceServer 

func RegisterInstanceDiscoveryServiceServer(s grpc.ServiceRegistrar, srv InstanceDiscoveryServiceServer)

func RegisterJVMMetricsServiceServer 

func RegisterJVMMetricsServiceServer(s grpc.ServiceRegistrar, srv JVMMetricsServiceServer)

func RegisterNetworkAddressRegisterServiceServer 

func RegisterNetworkAddressRegisterServiceServer(s grpc.ServiceRegistrar, srv NetworkAddressRegisterServiceServer)

func RegisterRegisterServer 

func RegisterRegisterServer(s grpc.ServiceRegistrar, srv RegisterServer)

func RegisterServiceInstancePingServer 

func RegisterServiceInstancePingServer(s grpc.ServiceRegistrar, srv ServiceInstancePingServer)

func RegisterServiceNameDiscoveryServiceServer 

func RegisterServiceNameDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ServiceNameDiscoveryServiceServer)

func RegisterTraceSegmentServiceServer 

func RegisterTraceSegmentServiceServer(s grpc.ServiceRegistrar, srv TraceSegmentServiceServer)

Types

type Application 

type Application struct {
	ApplicationCode string `protobuf:"bytes,1,opt,name=applicationCode,proto3" json:"applicationCode,omitempty"`
	// contains filtered or unexported fields
}

func (*Application) Descriptor deprecated 

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

Deprecated: Use Application.ProtoReflect.Descriptor instead.

func (*Application) GetApplicationCode 

func (x *Application) GetApplicationCode() string

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) ProtoReflect 

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

func (*Application) Reset 

func (x *Application) Reset()

func (*Application) String 

func (x *Application) String() string

type ApplicationInstance 

type ApplicationInstance struct {
	ApplicationId int32   `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	AgentUUID     string  `protobuf:"bytes,2,opt,name=agentUUID,proto3" json:"agentUUID,omitempty"`
	RegisterTime  int64   `protobuf:"varint,3,opt,name=registerTime,proto3" json:"registerTime,omitempty"`
	Osinfo        *OSInfo `protobuf:"bytes,4,opt,name=osinfo,proto3" json:"osinfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationInstance) Descriptor deprecated 

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

Deprecated: Use ApplicationInstance.ProtoReflect.Descriptor instead.

func (*ApplicationInstance) GetAgentUUID 

func (x *ApplicationInstance) GetAgentUUID() string

func (*ApplicationInstance) GetApplicationId 

func (x *ApplicationInstance) GetApplicationId() int32

func (*ApplicationInstance) GetOsinfo 

func (x *ApplicationInstance) GetOsinfo() *OSInfo

func (*ApplicationInstance) GetRegisterTime 

func (x *ApplicationInstance) GetRegisterTime() int64

func (*ApplicationInstance) ProtoMessage 

func (*ApplicationInstance) ProtoMessage()

func (*ApplicationInstance) ProtoReflect 

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

func (*ApplicationInstance) Reset 

func (x *ApplicationInstance) Reset()

func (*ApplicationInstance) String 

func (x *ApplicationInstance) String() string

type ApplicationInstanceHeartbeat 

type ApplicationInstanceHeartbeat struct {
	ApplicationInstanceId int32 `protobuf:"varint,1,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	HeartbeatTime         int64 `protobuf:"varint,2,opt,name=heartbeatTime,proto3" json:"heartbeatTime,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationInstanceHeartbeat) Descriptor deprecated 

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

Deprecated: Use ApplicationInstanceHeartbeat.ProtoReflect.Descriptor instead.

func (*ApplicationInstanceHeartbeat) GetApplicationInstanceId 

func (x *ApplicationInstanceHeartbeat) GetApplicationInstanceId() int32

func (*ApplicationInstanceHeartbeat) GetHeartbeatTime 

func (x *ApplicationInstanceHeartbeat) GetHeartbeatTime() int64

func (*ApplicationInstanceHeartbeat) ProtoMessage 

func (*ApplicationInstanceHeartbeat) ProtoMessage()

func (*ApplicationInstanceHeartbeat) ProtoReflect 

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

func (*ApplicationInstanceHeartbeat) Reset 

func (x *ApplicationInstanceHeartbeat) Reset()

func (*ApplicationInstanceHeartbeat) String 

func (x *ApplicationInstanceHeartbeat) String() string

type ApplicationInstanceMapping 

type ApplicationInstanceMapping struct {
	ApplicationId         int32 `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32 `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationInstanceMapping) Descriptor deprecated 

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

Deprecated: Use ApplicationInstanceMapping.ProtoReflect.Descriptor instead.

func (*ApplicationInstanceMapping) GetApplicationId 

func (x *ApplicationInstanceMapping) GetApplicationId() int32

func (*ApplicationInstanceMapping) GetApplicationInstanceId 

func (x *ApplicationInstanceMapping) GetApplicationInstanceId() int32

func (*ApplicationInstanceMapping) ProtoMessage 

func (*ApplicationInstanceMapping) ProtoMessage()

func (*ApplicationInstanceMapping) ProtoReflect 

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

func (*ApplicationInstanceMapping) Reset 

func (x *ApplicationInstanceMapping) Reset()

func (*ApplicationInstanceMapping) String 

func (x *ApplicationInstanceMapping) String() string

type ApplicationInstanceRecover 

type ApplicationInstanceRecover struct {
	ApplicationId         int32   `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32   `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	RegisterTime          int64   `protobuf:"varint,3,opt,name=registerTime,proto3" json:"registerTime,omitempty"`
	Osinfo                *OSInfo `protobuf:"bytes,4,opt,name=osinfo,proto3" json:"osinfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationInstanceRecover) Descriptor deprecated 

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

Deprecated: Use ApplicationInstanceRecover.ProtoReflect.Descriptor instead.

func (*ApplicationInstanceRecover) GetApplicationId 

func (x *ApplicationInstanceRecover) GetApplicationId() int32

func (*ApplicationInstanceRecover) GetApplicationInstanceId 

func (x *ApplicationInstanceRecover) GetApplicationInstanceId() int32

func (*ApplicationInstanceRecover) GetOsinfo 

func (x *ApplicationInstanceRecover) GetOsinfo() *OSInfo

func (*ApplicationInstanceRecover) GetRegisterTime 

func (x *ApplicationInstanceRecover) GetRegisterTime() int64

func (*ApplicationInstanceRecover) ProtoMessage 

func (*ApplicationInstanceRecover) ProtoMessage()

func (*ApplicationInstanceRecover) ProtoReflect 

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

func (*ApplicationInstanceRecover) Reset 

func (x *ApplicationInstanceRecover) Reset()

func (*ApplicationInstanceRecover) String 

func (x *ApplicationInstanceRecover) String() string

type ApplicationMapping 

type ApplicationMapping struct {
	Application *KeyWithIntegerValue `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationMapping) Descriptor deprecated 

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

Deprecated: Use ApplicationMapping.ProtoReflect.Descriptor instead.

func (*ApplicationMapping) GetApplication 

func (x *ApplicationMapping) GetApplication() *KeyWithIntegerValue

func (*ApplicationMapping) ProtoMessage 

func (*ApplicationMapping) ProtoMessage()

func (*ApplicationMapping) ProtoReflect 

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

func (*ApplicationMapping) Reset 

func (x *ApplicationMapping) Reset()

func (*ApplicationMapping) String 

func (x *ApplicationMapping) String() string

type ApplicationRegisterServiceClient 

type ApplicationRegisterServiceClient interface {
	ApplicationCodeRegister(ctx context.Context, in *Application, opts ...grpc.CallOption) (*ApplicationMapping, error)
}

ApplicationRegisterServiceClient is the client API for ApplicationRegisterService 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 NewApplicationRegisterServiceClient 

func NewApplicationRegisterServiceClient(cc grpc.ClientConnInterface) ApplicationRegisterServiceClient

type ApplicationRegisterServiceServer 

type ApplicationRegisterServiceServer interface {
	ApplicationCodeRegister(context.Context, *Application) (*ApplicationMapping, error)
}

ApplicationRegisterServiceServer is the server API for ApplicationRegisterService service. All implementations should embed UnimplementedApplicationRegisterServiceServer for forward compatibility

type CLRMetric 

type CLRMetric struct {
	Time   int64       `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu    *common.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() *common.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 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 Downstream 

type Downstream struct {
	// contains filtered or unexported fields
}

nothing down stream from collector yet.

func (*Downstream) Descriptor deprecated 

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

Deprecated: Use Downstream.ProtoReflect.Descriptor instead.

func (*Downstream) ProtoMessage 

func (*Downstream) ProtoMessage()

func (*Downstream) ProtoReflect 

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

func (*Downstream) Reset 

func (x *Downstream) Reset()

func (*Downstream) String 

func (x *Downstream) String() string

type Endpoint 

type Endpoint struct {
	ServiceId    int32                        `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName string                       `protobuf:"bytes,2,opt,name=endpointName,proto3" json:"endpointName,omitempty"`
	Tags         []*common.KeyStringValuePair `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties   []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// For endpoint
	// from DetectPoint is either `client` or `server`. No chance to be `proxy`.
	From common.DetectPoint `protobuf:"varint,5,opt,name=from,proto3,enum=DetectPoint" json:"from,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetEndpointName 

func (x *Endpoint) GetEndpointName() string

func (*Endpoint) GetFrom 

func (x *Endpoint) GetFrom() common.DetectPoint

func (*Endpoint) GetProperties 

func (x *Endpoint) GetProperties() []*common.KeyStringValuePair

func (*Endpoint) GetServiceId 

func (x *Endpoint) GetServiceId() int32

func (*Endpoint) GetTags 

func (x *Endpoint) GetTags() []*common.KeyStringValuePair

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

type EndpointMapping 

type EndpointMapping struct {
	Elements []*EndpointMappingElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointMapping) Descriptor deprecated 

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

Deprecated: Use EndpointMapping.ProtoReflect.Descriptor instead.

func (*EndpointMapping) GetElements 

func (x *EndpointMapping) GetElements() []*EndpointMappingElement

func (*EndpointMapping) ProtoMessage 

func (*EndpointMapping) ProtoMessage()

func (*EndpointMapping) ProtoReflect 

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

func (*EndpointMapping) Reset 

func (x *EndpointMapping) Reset()

func (*EndpointMapping) String 

func (x *EndpointMapping) String() string

type EndpointMappingElement 

type EndpointMappingElement struct {
	ServiceId    int32              `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName string             `protobuf:"bytes,2,opt,name=endpointName,proto3" json:"endpointName,omitempty"`
	EndpointId   int32              `protobuf:"varint,3,opt,name=endpointId,proto3" json:"endpointId,omitempty"`
	From         common.DetectPoint `protobuf:"varint,4,opt,name=from,proto3,enum=DetectPoint" json:"from,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointMappingElement) Descriptor deprecated 

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

Deprecated: Use EndpointMappingElement.ProtoReflect.Descriptor instead.

func (*EndpointMappingElement) GetEndpointId 

func (x *EndpointMappingElement) GetEndpointId() int32

func (*EndpointMappingElement) GetEndpointName 

func (x *EndpointMappingElement) GetEndpointName() string

func (*EndpointMappingElement) GetFrom 

func (x *EndpointMappingElement) GetFrom() common.DetectPoint

func (*EndpointMappingElement) GetServiceId 

func (x *EndpointMappingElement) GetServiceId() int32

func (*EndpointMappingElement) ProtoMessage 

func (*EndpointMappingElement) ProtoMessage()

func (*EndpointMappingElement) ProtoReflect 

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

func (*EndpointMappingElement) Reset 

func (x *EndpointMappingElement) Reset()

func (*EndpointMappingElement) String 

func (x *EndpointMappingElement) String() string

type Endpoints 

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

Endpoints register

func (*Endpoints) Descriptor deprecated 

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

Deprecated: Use Endpoints.ProtoReflect.Descriptor instead.

func (*Endpoints) GetEndpoints 

func (x *Endpoints) GetEndpoints() []*Endpoint

func (*Endpoints) ProtoMessage 

func (*Endpoints) ProtoMessage()

func (*Endpoints) ProtoReflect 

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

func (*Endpoints) Reset 

func (x *Endpoints) Reset()

func (*Endpoints) String 

func (x *Endpoints) String() string

type GC 

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

func (GCPhrase) Type() protoreflect.EnumType

type InstanceDiscoveryServiceClient 

type InstanceDiscoveryServiceClient interface {
	RegisterInstance(ctx context.Context, in *ApplicationInstance, opts ...grpc.CallOption) (*ApplicationInstanceMapping, error)
	Heartbeat(ctx context.Context, in *ApplicationInstanceHeartbeat, opts ...grpc.CallOption) (*Downstream, error)
}

InstanceDiscoveryServiceClient is the client API for InstanceDiscoveryService 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 NewInstanceDiscoveryServiceClient 

func NewInstanceDiscoveryServiceClient(cc grpc.ClientConnInterface) InstanceDiscoveryServiceClient

type InstanceDiscoveryServiceServer 

type InstanceDiscoveryServiceServer interface {
	RegisterInstance(context.Context, *ApplicationInstance) (*ApplicationInstanceMapping, error)
	Heartbeat(context.Context, *ApplicationInstanceHeartbeat) (*Downstream, error)
}

InstanceDiscoveryServiceServer is the server API for InstanceDiscoveryService service. All implementations should embed UnimplementedInstanceDiscoveryServiceServer for forward compatibility

type JVMMetric 

type JVMMetric struct {
	Time       int64         `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu        *common.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"`
	// 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() *common.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) 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 JVMMetrics 

type JVMMetrics struct {
	Metrics               []*JVMMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ApplicationInstanceId int32        `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*JVMMetrics) Descriptor deprecated 

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

Deprecated: Use JVMMetrics.ProtoReflect.Descriptor instead.

func (*JVMMetrics) GetApplicationInstanceId 

func (x *JVMMetrics) GetApplicationInstanceId() int32

func (*JVMMetrics) GetMetrics 

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

func (*JVMMetrics) ProtoMessage 

func (*JVMMetrics) ProtoMessage()

func (*JVMMetrics) ProtoReflect 

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

func (*JVMMetrics) Reset 

func (x *JVMMetrics) Reset()

func (*JVMMetrics) String 

func (x *JVMMetrics) String() string

type JVMMetricsServiceClient 

type JVMMetricsServiceClient interface {
	Collect(ctx context.Context, in *JVMMetrics, opts ...grpc.CallOption) (*Downstream, error)
}

JVMMetricsServiceClient is the client API for JVMMetricsService 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 NewJVMMetricsServiceClient 

func NewJVMMetricsServiceClient(cc grpc.ClientConnInterface) JVMMetricsServiceClient

type JVMMetricsServiceServer 

type JVMMetricsServiceServer interface {
	Collect(context.Context, *JVMMetrics) (*Downstream, error)
}

JVMMetricsServiceServer is the server API for JVMMetricsService service. All implementations should embed UnimplementedJVMMetricsServiceServer for forward compatibility

type KeyWithIntegerValue 

type KeyWithIntegerValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value int32  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyWithIntegerValue) Descriptor deprecated 

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

Deprecated: Use KeyWithIntegerValue.ProtoReflect.Descriptor instead.

func (*KeyWithIntegerValue) GetKey 

func (x *KeyWithIntegerValue) GetKey() string

func (*KeyWithIntegerValue) GetValue 

func (x *KeyWithIntegerValue) GetValue() int32

func (*KeyWithIntegerValue) ProtoMessage 

func (*KeyWithIntegerValue) ProtoMessage()

func (*KeyWithIntegerValue) ProtoReflect 

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

func (*KeyWithIntegerValue) Reset 

func (x *KeyWithIntegerValue) Reset()

func (*KeyWithIntegerValue) String 

func (x *KeyWithIntegerValue) String() string

type KeyWithStringValue 

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

func (*KeyWithStringValue) Descriptor deprecated 

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

Deprecated: Use KeyWithStringValue.ProtoReflect.Descriptor instead.

func (*KeyWithStringValue) GetKey 

func (x *KeyWithStringValue) GetKey() string

func (*KeyWithStringValue) GetValue 

func (x *KeyWithStringValue) GetValue() string

func (*KeyWithStringValue) ProtoMessage 

func (*KeyWithStringValue) ProtoMessage()

func (*KeyWithStringValue) ProtoReflect 

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

func (*KeyWithStringValue) Reset 

func (x *KeyWithStringValue) Reset()

func (*KeyWithStringValue) String 

func (x *KeyWithStringValue) String() string

type LogMessage 

type LogMessage struct {
	Time int64                 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Data []*KeyWithStringValue `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated 

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetData 

func (x *LogMessage) GetData() []*KeyWithStringValue

func (*LogMessage) GetTime 

func (x *LogMessage) GetTime() int64

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect 

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

func (*LogMessage) Reset 

func (x *LogMessage) Reset()

func (*LogMessage) String 

func (x *LogMessage) 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=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"`
	Commited int64    `protobuf:"varint,5,opt,name=commited,proto3" json:"commited,omitempty"`
	// contains filtered or unexported fields
}

func (*MemoryPool) Descriptor deprecated 

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

Deprecated: Use MemoryPool.ProtoReflect.Descriptor instead.

func (*MemoryPool) GetCommited 

func (x *MemoryPool) GetCommited() 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 NetAddressMapping 

type NetAddressMapping struct {
	AddressIds []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=addressIds,proto3" json:"addressIds,omitempty"`
	// contains filtered or unexported fields
}

func (*NetAddressMapping) Descriptor deprecated 

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

Deprecated: Use NetAddressMapping.ProtoReflect.Descriptor instead.

func (*NetAddressMapping) GetAddressIds 

func (x *NetAddressMapping) GetAddressIds() []*common.KeyIntValuePair

func (*NetAddressMapping) ProtoMessage 

func (*NetAddressMapping) ProtoMessage()

func (*NetAddressMapping) ProtoReflect 

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

func (*NetAddressMapping) Reset 

func (x *NetAddressMapping) Reset()

func (*NetAddressMapping) String 

func (x *NetAddressMapping) String() string

type NetAddresses 

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

Only known use case is the language agent. Network address represents the ip/hostname:port, which is usually used at client side of RPC.

func (*NetAddresses) Descriptor deprecated 

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

Deprecated: Use NetAddresses.ProtoReflect.Descriptor instead.

func (*NetAddresses) GetAddresses 

func (x *NetAddresses) GetAddresses() []string

func (*NetAddresses) ProtoMessage 

func (*NetAddresses) ProtoMessage()

func (*NetAddresses) ProtoReflect 

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

func (*NetAddresses) Reset 

func (x *NetAddresses) Reset()

func (*NetAddresses) String 

func (x *NetAddresses) String() string

type NetworkAddressMappings 

type NetworkAddressMappings struct {
	AddressIds []*KeyWithIntegerValue `protobuf:"bytes,1,rep,name=addressIds,proto3" json:"addressIds,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkAddressMappings) Descriptor deprecated 

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

Deprecated: Use NetworkAddressMappings.ProtoReflect.Descriptor instead.

func (*NetworkAddressMappings) GetAddressIds 

func (x *NetworkAddressMappings) GetAddressIds() []*KeyWithIntegerValue

func (*NetworkAddressMappings) ProtoMessage 

func (*NetworkAddressMappings) ProtoMessage()

func (*NetworkAddressMappings) ProtoReflect 

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

func (*NetworkAddressMappings) Reset 

func (x *NetworkAddressMappings) Reset()

func (*NetworkAddressMappings) String 

func (x *NetworkAddressMappings) String() string

type NetworkAddressRegisterServiceClient 

type NetworkAddressRegisterServiceClient interface {
	BatchRegister(ctx context.Context, in *NetworkAddresses, opts ...grpc.CallOption) (*NetworkAddressMappings, error)
}

NetworkAddressRegisterServiceClient is the client API for NetworkAddressRegisterService 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 NewNetworkAddressRegisterServiceClient 

func NewNetworkAddressRegisterServiceClient(cc grpc.ClientConnInterface) NetworkAddressRegisterServiceClient

type NetworkAddressRegisterServiceServer 

type NetworkAddressRegisterServiceServer interface {
	BatchRegister(context.Context, *NetworkAddresses) (*NetworkAddressMappings, error)
}

NetworkAddressRegisterServiceServer is the server API for NetworkAddressRegisterService service. All implementations should embed UnimplementedNetworkAddressRegisterServiceServer for forward compatibility

type NetworkAddresses 

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

func (*NetworkAddresses) Descriptor deprecated 

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

Deprecated: Use NetworkAddresses.ProtoReflect.Descriptor instead.

func (*NetworkAddresses) GetAddresses 

func (x *NetworkAddresses) GetAddresses() []string

func (*NetworkAddresses) ProtoMessage 

func (*NetworkAddresses) ProtoMessage()

func (*NetworkAddresses) ProtoReflect 

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

func (*NetworkAddresses) Reset 

func (x *NetworkAddresses) Reset()

func (*NetworkAddresses) String 

func (x *NetworkAddresses) String() string

type OSInfo 

type OSInfo struct {
	OsName    string   `protobuf:"bytes,1,opt,name=osName,proto3" json:"osName,omitempty"`
	Hostname  string   `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ProcessNo int32    `protobuf:"varint,3,opt,name=processNo,proto3" json:"processNo,omitempty"`
	Ipv4S     []string `protobuf:"bytes,4,rep,name=ipv4s,proto3" json:"ipv4s,omitempty"`
	// contains filtered or unexported fields
}

func (*OSInfo) Descriptor deprecated 

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

Deprecated: Use OSInfo.ProtoReflect.Descriptor instead.

func (*OSInfo) GetHostname 

func (x *OSInfo) GetHostname() string

func (*OSInfo) GetIpv4S 

func (x *OSInfo) GetIpv4S() []string

func (*OSInfo) GetOsName 

func (x *OSInfo) GetOsName() string

func (*OSInfo) GetProcessNo 

func (x *OSInfo) GetProcessNo() int32

func (*OSInfo) ProtoMessage 

func (*OSInfo) ProtoMessage()

func (*OSInfo) ProtoReflect 

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

func (*OSInfo) Reset 

func (x *OSInfo) Reset()

func (*OSInfo) String 

func (x *OSInfo) 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
const (
	RefType_CrossProcess RefType = 0
	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 RegisterClient 

type RegisterClient interface {
	DoServiceRegister(ctx context.Context, in *Services, opts ...grpc.CallOption) (*ServiceRegisterMapping, error)
	DoServiceInstanceRegister(ctx context.Context, in *ServiceInstances, opts ...grpc.CallOption) (*ServiceInstanceRegisterMapping, error)
	DoEndpointRegister(ctx context.Context, in *Endpoints, opts ...grpc.CallOption) (*EndpointMapping, error)
	DoNetworkAddressRegister(ctx context.Context, in *NetAddresses, opts ...grpc.CallOption) (*NetAddressMapping, error)
	DoServiceAndNetworkAddressMappingRegister(ctx context.Context, in *ServiceAndNetworkAddressMappings, opts ...grpc.CallOption) (*common.Commands, error)
}

RegisterClient is the client API for Register 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 NewRegisterClient 

func NewRegisterClient(cc grpc.ClientConnInterface) RegisterClient

type RegisterServer 

type RegisterServer interface {
	DoServiceRegister(context.Context, *Services) (*ServiceRegisterMapping, error)
	DoServiceInstanceRegister(context.Context, *ServiceInstances) (*ServiceInstanceRegisterMapping, error)
	DoEndpointRegister(context.Context, *Endpoints) (*EndpointMapping, error)
	DoNetworkAddressRegister(context.Context, *NetAddresses) (*NetAddressMapping, error)
	DoServiceAndNetworkAddressMappingRegister(context.Context, *ServiceAndNetworkAddressMappings) (*common.Commands, error)
}

RegisterServer is the server API for Register service. All implementations should embed UnimplementedRegisterServer for forward compatibility

type Service 

type Service struct {
	ServiceName string                       `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	Tags        []*common.KeyStringValuePair `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties  []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetProperties 

func (x *Service) GetProperties() []*common.KeyStringValuePair

func (*Service) GetServiceName 

func (x *Service) GetServiceName() string

func (*Service) GetTags 

func (x *Service) GetTags() []*common.KeyStringValuePair

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type ServiceAndNetworkAddressMapping 

type ServiceAndNetworkAddressMapping struct {
	ServiceId         int32  `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	ServiceInstanceId int32  `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	NetworkAddress    string `protobuf:"bytes,3,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
	NetworkAddressId  int32  `protobuf:"varint,4,opt,name=networkAddressId,proto3" json:"networkAddressId,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceAndNetworkAddressMapping) Descriptor deprecated 

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

Deprecated: Use ServiceAndNetworkAddressMapping.ProtoReflect.Descriptor instead.

func (*ServiceAndNetworkAddressMapping) GetNetworkAddress 

func (x *ServiceAndNetworkAddressMapping) GetNetworkAddress() string

func (*ServiceAndNetworkAddressMapping) GetNetworkAddressId 

func (x *ServiceAndNetworkAddressMapping) GetNetworkAddressId() int32

func (*ServiceAndNetworkAddressMapping) GetServiceId 

func (x *ServiceAndNetworkAddressMapping) GetServiceId() int32

func (*ServiceAndNetworkAddressMapping) GetServiceInstanceId 

func (x *ServiceAndNetworkAddressMapping) GetServiceInstanceId() int32

func (*ServiceAndNetworkAddressMapping) ProtoMessage 

func (*ServiceAndNetworkAddressMapping) ProtoMessage()

func (*ServiceAndNetworkAddressMapping) ProtoReflect 

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

func (*ServiceAndNetworkAddressMapping) Reset 

func (x *ServiceAndNetworkAddressMapping) Reset()

func (*ServiceAndNetworkAddressMapping) String 

func (x *ServiceAndNetworkAddressMapping) String() string

type ServiceAndNetworkAddressMappings 

type ServiceAndNetworkAddressMappings struct {
	Mappings []*ServiceAndNetworkAddressMapping `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceAndNetworkAddressMappings) Descriptor deprecated 

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

Deprecated: Use ServiceAndNetworkAddressMappings.ProtoReflect.Descriptor instead.

func (*ServiceAndNetworkAddressMappings) GetMappings 

func (x *ServiceAndNetworkAddressMappings) GetMappings() []*ServiceAndNetworkAddressMapping

func (*ServiceAndNetworkAddressMappings) ProtoMessage 

func (*ServiceAndNetworkAddressMappings) ProtoMessage()

func (*ServiceAndNetworkAddressMappings) ProtoReflect 

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

func (*ServiceAndNetworkAddressMappings) Reset 

func (x *ServiceAndNetworkAddressMappings) Reset()

func (*ServiceAndNetworkAddressMappings) String 

func (x *ServiceAndNetworkAddressMappings) String() string

type ServiceInstance 

type ServiceInstance struct {
	ServiceId    int32                        `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	InstanceUUID string                       `protobuf:"bytes,2,opt,name=instanceUUID,proto3" json:"instanceUUID,omitempty"`
	Time         int64                        `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Tags         []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties   []*common.KeyStringValuePair `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInstance) Descriptor deprecated 

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

Deprecated: Use ServiceInstance.ProtoReflect.Descriptor instead.

func (*ServiceInstance) GetInstanceUUID 

func (x *ServiceInstance) GetInstanceUUID() string

func (*ServiceInstance) GetProperties 

func (x *ServiceInstance) GetProperties() []*common.KeyStringValuePair

func (*ServiceInstance) GetServiceId 

func (x *ServiceInstance) GetServiceId() int32

func (*ServiceInstance) GetTags 

func (x *ServiceInstance) GetTags() []*common.KeyStringValuePair

func (*ServiceInstance) GetTime 

func (x *ServiceInstance) GetTime() int64

func (*ServiceInstance) ProtoMessage 

func (*ServiceInstance) ProtoMessage()

func (*ServiceInstance) ProtoReflect 

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

func (*ServiceInstance) Reset 

func (x *ServiceInstance) Reset()

func (*ServiceInstance) String 

func (x *ServiceInstance) String() string

type ServiceInstancePingClient 

type ServiceInstancePingClient interface {
	DoPing(ctx context.Context, in *ServiceInstancePingPkg, opts ...grpc.CallOption) (*common.Commands, error)
}

ServiceInstancePingClient is the client API for ServiceInstancePing 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 NewServiceInstancePingClient 

func NewServiceInstancePingClient(cc grpc.ClientConnInterface) ServiceInstancePingClient

type ServiceInstancePingPkg 

type ServiceInstancePingPkg struct {
	ServiceInstanceId   int32  `protobuf:"varint,1,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	Time                int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	ServiceInstanceUUID string `protobuf:"bytes,3,opt,name=serviceInstanceUUID,proto3" json:"serviceInstanceUUID,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInstancePingPkg) Descriptor deprecated 

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

Deprecated: Use ServiceInstancePingPkg.ProtoReflect.Descriptor instead.

func (*ServiceInstancePingPkg) GetServiceInstanceId 

func (x *ServiceInstancePingPkg) GetServiceInstanceId() int32

func (*ServiceInstancePingPkg) GetServiceInstanceUUID 

func (x *ServiceInstancePingPkg) GetServiceInstanceUUID() string

func (*ServiceInstancePingPkg) GetTime 

func (x *ServiceInstancePingPkg) GetTime() int64

func (*ServiceInstancePingPkg) ProtoMessage 

func (*ServiceInstancePingPkg) ProtoMessage()

func (*ServiceInstancePingPkg) ProtoReflect 

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

func (*ServiceInstancePingPkg) Reset 

func (x *ServiceInstancePingPkg) Reset()

func (*ServiceInstancePingPkg) String 

func (x *ServiceInstancePingPkg) String() string

type ServiceInstancePingServer 

type ServiceInstancePingServer interface {
	DoPing(context.Context, *ServiceInstancePingPkg) (*common.Commands, error)
}

ServiceInstancePingServer is the server API for ServiceInstancePing service. All implementations should embed UnimplementedServiceInstancePingServer for forward compatibility

type ServiceInstanceRegisterMapping 

type ServiceInstanceRegisterMapping struct {
	ServiceInstances []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=serviceInstances,proto3" json:"serviceInstances,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInstanceRegisterMapping) Descriptor deprecated 

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

Deprecated: Use ServiceInstanceRegisterMapping.ProtoReflect.Descriptor instead.

func (*ServiceInstanceRegisterMapping) GetServiceInstances 

func (x *ServiceInstanceRegisterMapping) GetServiceInstances() []*common.KeyIntValuePair

func (*ServiceInstanceRegisterMapping) ProtoMessage 

func (*ServiceInstanceRegisterMapping) ProtoMessage()

func (*ServiceInstanceRegisterMapping) ProtoReflect 

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

func (*ServiceInstanceRegisterMapping) Reset 

func (x *ServiceInstanceRegisterMapping) Reset()

func (*ServiceInstanceRegisterMapping) String 

func (x *ServiceInstanceRegisterMapping) String() string

type ServiceInstances 

type ServiceInstances struct {
	Instances []*ServiceInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

Service Instance register

func (*ServiceInstances) Descriptor deprecated 

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

Deprecated: Use ServiceInstances.ProtoReflect.Descriptor instead.

func (*ServiceInstances) GetInstances 

func (x *ServiceInstances) GetInstances() []*ServiceInstance

func (*ServiceInstances) ProtoMessage 

func (*ServiceInstances) ProtoMessage()

func (*ServiceInstances) ProtoReflect 

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

func (*ServiceInstances) Reset 

func (x *ServiceInstances) Reset()

func (*ServiceInstances) String 

func (x *ServiceInstances) String() string

type ServiceNameCollection 

type ServiceNameCollection struct {
	Elements []*ServiceNameElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceNameCollection) Descriptor deprecated 

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

Deprecated: Use ServiceNameCollection.ProtoReflect.Descriptor instead.

func (*ServiceNameCollection) GetElements 

func (x *ServiceNameCollection) GetElements() []*ServiceNameElement

func (*ServiceNameCollection) ProtoMessage 

func (*ServiceNameCollection) ProtoMessage()

func (*ServiceNameCollection) ProtoReflect 

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

func (*ServiceNameCollection) Reset 

func (x *ServiceNameCollection) Reset()

func (*ServiceNameCollection) String 

func (x *ServiceNameCollection) String() string

type ServiceNameDiscoveryServiceClient 

type ServiceNameDiscoveryServiceClient interface {
	Discovery(ctx context.Context, in *ServiceNameCollection, opts ...grpc.CallOption) (*ServiceNameMappingCollection, error)
}

ServiceNameDiscoveryServiceClient is the client API for ServiceNameDiscoveryService 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 NewServiceNameDiscoveryServiceClient 

func NewServiceNameDiscoveryServiceClient(cc grpc.ClientConnInterface) ServiceNameDiscoveryServiceClient

type ServiceNameDiscoveryServiceServer 

type ServiceNameDiscoveryServiceServer interface {
	Discovery(context.Context, *ServiceNameCollection) (*ServiceNameMappingCollection, error)
}

ServiceNameDiscoveryServiceServer is the server API for ServiceNameDiscoveryService service. All implementations should embed UnimplementedServiceNameDiscoveryServiceServer for forward compatibility

type ServiceNameElement 

type ServiceNameElement struct {
	ServiceName   string   `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	ApplicationId int32    `protobuf:"varint,2,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	SrcSpanType   SpanType `protobuf:"varint,3,opt,name=srcSpanType,proto3,enum=SpanType" json:"srcSpanType,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceNameElement) Descriptor deprecated 

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

Deprecated: Use ServiceNameElement.ProtoReflect.Descriptor instead.

func (*ServiceNameElement) GetApplicationId 

func (x *ServiceNameElement) GetApplicationId() int32

func (*ServiceNameElement) GetServiceName 

func (x *ServiceNameElement) GetServiceName() string

func (*ServiceNameElement) GetSrcSpanType 

func (x *ServiceNameElement) GetSrcSpanType() SpanType

func (*ServiceNameElement) ProtoMessage 

func (*ServiceNameElement) ProtoMessage()

func (*ServiceNameElement) ProtoReflect 

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

func (*ServiceNameElement) Reset 

func (x *ServiceNameElement) Reset()

func (*ServiceNameElement) String 

func (x *ServiceNameElement) String() string

type ServiceNameMappingCollection 

type ServiceNameMappingCollection struct {
	Elements []*ServiceNameMappingElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceNameMappingCollection) Descriptor deprecated 

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

Deprecated: Use ServiceNameMappingCollection.ProtoReflect.Descriptor instead.

func (*ServiceNameMappingCollection) GetElements 

func (x *ServiceNameMappingCollection) GetElements() []*ServiceNameMappingElement

func (*ServiceNameMappingCollection) ProtoMessage 

func (*ServiceNameMappingCollection) ProtoMessage()

func (*ServiceNameMappingCollection) ProtoReflect 

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

func (*ServiceNameMappingCollection) Reset 

func (x *ServiceNameMappingCollection) Reset()

func (*ServiceNameMappingCollection) String 

func (x *ServiceNameMappingCollection) String() string

type ServiceNameMappingElement 

type ServiceNameMappingElement struct {
	ServiceId int32               `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	Element   *ServiceNameElement `protobuf:"bytes,2,opt,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceNameMappingElement) Descriptor deprecated 

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

Deprecated: Use ServiceNameMappingElement.ProtoReflect.Descriptor instead.

func (*ServiceNameMappingElement) GetElement 

func (x *ServiceNameMappingElement) GetElement() *ServiceNameElement

func (*ServiceNameMappingElement) GetServiceId 

func (x *ServiceNameMappingElement) GetServiceId() int32

func (*ServiceNameMappingElement) ProtoMessage 

func (*ServiceNameMappingElement) ProtoMessage()

func (*ServiceNameMappingElement) ProtoReflect 

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

func (*ServiceNameMappingElement) Reset 

func (x *ServiceNameMappingElement) Reset()

func (*ServiceNameMappingElement) String 

func (x *ServiceNameMappingElement) String() string

type ServiceRegisterMapping 

type ServiceRegisterMapping struct {
	Services []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceRegisterMapping) Descriptor deprecated 

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

Deprecated: Use ServiceRegisterMapping.ProtoReflect.Descriptor instead.

func (*ServiceRegisterMapping) GetServices 

func (x *ServiceRegisterMapping) GetServices() []*common.KeyIntValuePair

func (*ServiceRegisterMapping) ProtoMessage 

func (*ServiceRegisterMapping) ProtoMessage()

func (*ServiceRegisterMapping) ProtoReflect 

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

func (*ServiceRegisterMapping) Reset 

func (x *ServiceRegisterMapping) Reset()

func (*ServiceRegisterMapping) String 

func (x *ServiceRegisterMapping) String() string

type Services 

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

Service register

func (*Services) Descriptor deprecated 

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

Deprecated: Use Services.ProtoReflect.Descriptor instead.

func (*Services) GetServices 

func (x *Services) GetServices() []*Service

func (*Services) ProtoMessage 

func (*Services) ProtoMessage()

func (*Services) ProtoReflect 

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

func (*Services) Reset 

func (x *Services) Reset()

func (*Services) String 

func (x *Services) String() string

type SpanLayer 

type SpanLayer int32
const (
	SpanLayer_Unknown      SpanLayer = 0
	SpanLayer_Database     SpanLayer = 1
	SpanLayer_RPCFramework SpanLayer = 2
	SpanLayer_Http         SpanLayer = 3
	SpanLayer_MQ           SpanLayer = 4
	SpanLayer_Cache        SpanLayer = 5
)

func (SpanLayer) 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 {
	SpanId          int32                    `protobuf:"varint,1,opt,name=spanId,proto3" json:"spanId,omitempty"`
	ParentSpanId    int32                    `protobuf:"varint,2,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	StartTime       int64                    `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime         int64                    `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Refs            []*TraceSegmentReference `protobuf:"bytes,5,rep,name=refs,proto3" json:"refs,omitempty"`
	OperationNameId int32                    `protobuf:"varint,6,opt,name=operationNameId,proto3" json:"operationNameId,omitempty"`
	OperationName   string                   `protobuf:"bytes,7,opt,name=operationName,proto3" json:"operationName,omitempty"`
	PeerId          int32                    `protobuf:"varint,8,opt,name=peerId,proto3" json:"peerId,omitempty"`
	Peer            string                   `protobuf:"bytes,9,opt,name=peer,proto3" json:"peer,omitempty"`
	SpanType        SpanType                 `protobuf:"varint,10,opt,name=spanType,proto3,enum=SpanType" json:"spanType,omitempty"`
	SpanLayer       SpanLayer                `protobuf:"varint,11,opt,name=spanLayer,proto3,enum=SpanLayer" json:"spanLayer,omitempty"`
	ComponentId     int32                    `protobuf:"varint,12,opt,name=componentId,proto3" json:"componentId,omitempty"`
	Component       string                   `protobuf:"bytes,13,opt,name=component,proto3" json:"component,omitempty"`
	IsError         bool                     `protobuf:"varint,14,opt,name=isError,proto3" json:"isError,omitempty"`
	Tags            []*KeyWithStringValue    `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs            []*LogMessage            `protobuf:"bytes,16,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanObject) Descriptor deprecated 

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

Deprecated: Use SpanObject.ProtoReflect.Descriptor instead.

func (*SpanObject) GetComponent 

func (x *SpanObject) GetComponent() string

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

func (*SpanObject) GetOperationName 

func (x *SpanObject) GetOperationName() string

func (*SpanObject) GetOperationNameId 

func (x *SpanObject) GetOperationNameId() int32

func (*SpanObject) GetParentSpanId 

func (x *SpanObject) GetParentSpanId() int32

func (*SpanObject) GetPeer 

func (x *SpanObject) GetPeer() string

func (*SpanObject) GetPeerId 

func (x *SpanObject) GetPeerId() int32

func (*SpanObject) GetRefs 

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

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

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
const (
	SpanType_Entry SpanType = 0
	SpanType_Exit  SpanType = 1
	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 TraceSegmentObject 

type TraceSegmentObject struct {
	TraceSegmentId        *UniqueId     `protobuf:"bytes,1,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	Spans                 []*SpanObject `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	ApplicationId         int32         `protobuf:"varint,3,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32         `protobuf:"varint,4,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	IsSizeLimited         bool          `protobuf:"varint,5,opt,name=isSizeLimited,proto3" json:"isSizeLimited,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceSegmentObject) Descriptor deprecated 

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

Deprecated: Use TraceSegmentObject.ProtoReflect.Descriptor instead.

func (*TraceSegmentObject) GetApplicationId 

func (x *TraceSegmentObject) GetApplicationId() int32

func (*TraceSegmentObject) GetApplicationInstanceId 

func (x *TraceSegmentObject) GetApplicationInstanceId() int32

func (*TraceSegmentObject) GetIsSizeLimited 

func (x *TraceSegmentObject) GetIsSizeLimited() bool

func (*TraceSegmentObject) GetSpans 

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

func (*TraceSegmentObject) GetTraceSegmentId 

func (x *TraceSegmentObject) GetTraceSegmentId() *UniqueId

func (*TraceSegmentObject) ProtoMessage 

func (*TraceSegmentObject) ProtoMessage()

func (*TraceSegmentObject) ProtoReflect 

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

func (*TraceSegmentObject) Reset 

func (x *TraceSegmentObject) Reset()

func (*TraceSegmentObject) String 

func (x *TraceSegmentObject) String() string

type TraceSegmentReference 

type TraceSegmentReference struct {
	RefType                     RefType   `protobuf:"varint,1,opt,name=refType,proto3,enum=RefType" json:"refType,omitempty"`
	ParentTraceSegmentId        *UniqueId `protobuf:"bytes,2,opt,name=parentTraceSegmentId,proto3" json:"parentTraceSegmentId,omitempty"`
	ParentSpanId                int32     `protobuf:"varint,3,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	ParentApplicationInstanceId int32     `protobuf:"varint,4,opt,name=parentApplicationInstanceId,proto3" json:"parentApplicationInstanceId,omitempty"`
	NetworkAddress              string    `protobuf:"bytes,5,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
	NetworkAddressId            int32     `protobuf:"varint,6,opt,name=networkAddressId,proto3" json:"networkAddressId,omitempty"`
	EntryApplicationInstanceId  int32     `protobuf:"varint,7,opt,name=entryApplicationInstanceId,proto3" json:"entryApplicationInstanceId,omitempty"`
	EntryServiceName            string    `protobuf:"bytes,8,opt,name=entryServiceName,proto3" json:"entryServiceName,omitempty"`
	EntryServiceId              int32     `protobuf:"varint,9,opt,name=entryServiceId,proto3" json:"entryServiceId,omitempty"`
	ParentServiceName           string    `protobuf:"bytes,10,opt,name=parentServiceName,proto3" json:"parentServiceName,omitempty"`
	ParentServiceId             int32     `protobuf:"varint,11,opt,name=parentServiceId,proto3" json:"parentServiceId,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceSegmentReference) Descriptor deprecated 

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

Deprecated: Use TraceSegmentReference.ProtoReflect.Descriptor instead.

func (*TraceSegmentReference) GetEntryApplicationInstanceId 

func (x *TraceSegmentReference) GetEntryApplicationInstanceId() int32

func (*TraceSegmentReference) GetEntryServiceId 

func (x *TraceSegmentReference) GetEntryServiceId() int32

func (*TraceSegmentReference) GetEntryServiceName 

func (x *TraceSegmentReference) GetEntryServiceName() string

func (*TraceSegmentReference) GetNetworkAddress 

func (x *TraceSegmentReference) GetNetworkAddress() string

func (*TraceSegmentReference) GetNetworkAddressId 

func (x *TraceSegmentReference) GetNetworkAddressId() int32

func (*TraceSegmentReference) GetParentApplicationInstanceId 

func (x *TraceSegmentReference) GetParentApplicationInstanceId() int32

func (*TraceSegmentReference) GetParentServiceId 

func (x *TraceSegmentReference) GetParentServiceId() int32

func (*TraceSegmentReference) GetParentServiceName 

func (x *TraceSegmentReference) GetParentServiceName() string

func (*TraceSegmentReference) GetParentSpanId 

func (x *TraceSegmentReference) GetParentSpanId() int32

func (*TraceSegmentReference) GetParentTraceSegmentId 

func (x *TraceSegmentReference) GetParentTraceSegmentId() *UniqueId

func (*TraceSegmentReference) GetRefType 

func (x *TraceSegmentReference) GetRefType() RefType

func (*TraceSegmentReference) ProtoMessage 

func (*TraceSegmentReference) ProtoMessage()

func (*TraceSegmentReference) ProtoReflect 

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

func (*TraceSegmentReference) Reset 

func (x *TraceSegmentReference) Reset()

func (*TraceSegmentReference) String 

func (x *TraceSegmentReference) String() string

type TraceSegmentServiceClient 

type TraceSegmentServiceClient interface {
	Collect(ctx context.Context, opts ...grpc.CallOption) (TraceSegmentService_CollectClient, error)
}

TraceSegmentServiceClient is the client API for TraceSegmentService 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 NewTraceSegmentServiceClient 

func NewTraceSegmentServiceClient(cc grpc.ClientConnInterface) TraceSegmentServiceClient

type TraceSegmentServiceServer 

type TraceSegmentServiceServer interface {
	Collect(TraceSegmentService_CollectServer) error
}

TraceSegmentServiceServer is the server API for TraceSegmentService service. All implementations should embed UnimplementedTraceSegmentServiceServer for forward compatibility

type TraceSegmentService_CollectClient 

type TraceSegmentService_CollectClient interface {
	Send(*UpstreamSegment) error
	CloseAndRecv() (*Downstream, error)
	grpc.ClientStream
}

type TraceSegmentService_CollectServer 

type TraceSegmentService_CollectServer interface {
	SendAndClose(*Downstream) error
	Recv() (*UpstreamSegment, error)
	grpc.ServerStream
}

type UnimplementedApplicationRegisterServiceServer 

type UnimplementedApplicationRegisterServiceServer struct {
}

UnimplementedApplicationRegisterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedApplicationRegisterServiceServer) ApplicationCodeRegister 

func (UnimplementedApplicationRegisterServiceServer) ApplicationCodeRegister(context.Context, *Application) (*ApplicationMapping, error)

type UnimplementedInstanceDiscoveryServiceServer 

type UnimplementedInstanceDiscoveryServiceServer struct {
}

UnimplementedInstanceDiscoveryServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInstanceDiscoveryServiceServer) Heartbeat 

func (UnimplementedInstanceDiscoveryServiceServer) Heartbeat(context.Context, *ApplicationInstanceHeartbeat) (*Downstream, error)

func (UnimplementedInstanceDiscoveryServiceServer) RegisterInstance 

func (UnimplementedInstanceDiscoveryServiceServer) RegisterInstance(context.Context, *ApplicationInstance) (*ApplicationInstanceMapping, error)

type UnimplementedJVMMetricsServiceServer 

type UnimplementedJVMMetricsServiceServer struct {
}

UnimplementedJVMMetricsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedJVMMetricsServiceServer) Collect 

func (UnimplementedJVMMetricsServiceServer) Collect(context.Context, *JVMMetrics) (*Downstream, error)

type UnimplementedNetworkAddressRegisterServiceServer 

type UnimplementedNetworkAddressRegisterServiceServer struct {
}

UnimplementedNetworkAddressRegisterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedNetworkAddressRegisterServiceServer) BatchRegister 

func (UnimplementedNetworkAddressRegisterServiceServer) BatchRegister(context.Context, *NetworkAddresses) (*NetworkAddressMappings, error)

type UnimplementedRegisterServer 

type UnimplementedRegisterServer struct {
}

UnimplementedRegisterServer should be embedded to have forward compatible implementations.

func (UnimplementedRegisterServer) DoEndpointRegister 

func (UnimplementedRegisterServer) DoEndpointRegister(context.Context, *Endpoints) (*EndpointMapping, error)

func (UnimplementedRegisterServer) DoNetworkAddressRegister 

func (UnimplementedRegisterServer) DoNetworkAddressRegister(context.Context, *NetAddresses) (*NetAddressMapping, error)

func (UnimplementedRegisterServer) DoServiceAndNetworkAddressMappingRegister 

func (UnimplementedRegisterServer) DoServiceAndNetworkAddressMappingRegister(context.Context, *ServiceAndNetworkAddressMappings) (*common.Commands, error)

func (UnimplementedRegisterServer) DoServiceInstanceRegister 

func (UnimplementedRegisterServer) DoServiceInstanceRegister(context.Context, *ServiceInstances) (*ServiceInstanceRegisterMapping, error)

func (UnimplementedRegisterServer) DoServiceRegister 

func (UnimplementedRegisterServer) DoServiceRegister(context.Context, *Services) (*ServiceRegisterMapping, error)

type UnimplementedServiceInstancePingServer 

type UnimplementedServiceInstancePingServer struct {
}

UnimplementedServiceInstancePingServer should be embedded to have forward compatible implementations.

func (UnimplementedServiceInstancePingServer) DoPing 

func (UnimplementedServiceInstancePingServer) DoPing(context.Context, *ServiceInstancePingPkg) (*common.Commands, error)

type UnimplementedServiceNameDiscoveryServiceServer 

type UnimplementedServiceNameDiscoveryServiceServer struct {
}

UnimplementedServiceNameDiscoveryServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedServiceNameDiscoveryServiceServer) Discovery 

func (UnimplementedServiceNameDiscoveryServiceServer) Discovery(context.Context, *ServiceNameCollection) (*ServiceNameMappingCollection, error)

type UnimplementedTraceSegmentServiceServer 

type UnimplementedTraceSegmentServiceServer struct {
}

UnimplementedTraceSegmentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTraceSegmentServiceServer) Collect 

func (UnimplementedTraceSegmentServiceServer) Collect(TraceSegmentService_CollectServer) error

type UniqueId 

type UniqueId struct {
	IdParts []int64 `protobuf:"varint,1,rep,packed,name=idParts,proto3" json:"idParts,omitempty"`
	// contains filtered or unexported fields
}

func (*UniqueId) Descriptor deprecated 

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

Deprecated: Use UniqueId.ProtoReflect.Descriptor instead.

func (*UniqueId) GetIdParts 

func (x *UniqueId) GetIdParts() []int64

func (*UniqueId) ProtoMessage 

func (*UniqueId) ProtoMessage()

func (*UniqueId) ProtoReflect 

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

func (*UniqueId) Reset 

func (x *UniqueId) Reset()

func (*UniqueId) String 

func (x *UniqueId) String() string

type UnsafeApplicationRegisterServiceServer 

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

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

type UnsafeInstanceDiscoveryServiceServer 

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

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

type UnsafeJVMMetricsServiceServer 

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

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

type UnsafeNetworkAddressRegisterServiceServer 

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

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

type UnsafeRegisterServer 

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

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

type UnsafeServiceInstancePingServer 

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

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

type UnsafeServiceNameDiscoveryServiceServer 

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

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

type UnsafeTraceSegmentServiceServer 

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

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

type UpstreamSegment 

type UpstreamSegment struct {
	GlobalTraceIds []*UniqueId `protobuf:"bytes,1,rep,name=globalTraceIds,proto3" json:"globalTraceIds,omitempty"`
	Segment        []byte      `protobuf:"bytes,2,opt,name=segment,proto3" json:"segment,omitempty"` // the byte array of TraceSegmentObject
	// contains filtered or unexported fields
}

func (*UpstreamSegment) Descriptor deprecated 

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

Deprecated: Use UpstreamSegment.ProtoReflect.Descriptor instead.

func (*UpstreamSegment) GetGlobalTraceIds 

func (x *UpstreamSegment) GetGlobalTraceIds() []*UniqueId

func (*UpstreamSegment) GetSegment 

func (x *UpstreamSegment) GetSegment() []byte

func (*UpstreamSegment) ProtoMessage 

func (*UpstreamSegment) ProtoMessage()

func (*UpstreamSegment) ProtoReflect 

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

func (*UpstreamSegment) Reset 

func (x *UpstreamSegment) Reset()

func (*UpstreamSegment) String 

func (x *UpstreamSegment) String() string

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.