skywalkingv2

package
v1.0.33 Latest Latest
Warning

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

 Go to latest Published: May 11, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Application 

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

type ApplicationInstance 

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

type ApplicationRegisterHandle 

type ApplicationRegisterHandle struct {
	RegistryInformationCache
}

func (*ApplicationRegisterHandle) ApplicationCodeRegister 

func (h *ApplicationRegisterHandle) ApplicationCodeRegister(context context.Context, application *agent.Application) (*agent.ApplicationMapping, error)

type Endpoints 

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

type Input 

type Input struct {
	Address          string
	ComponentMapping map[int32]string
	// contains filtered or unexported fields
}

func (*Input) Collect 

func (r *Input) Collect(ilogtail.Collector) error

func (*Input) Description 

func (r *Input) Description() string

func (*Input) Init 

func (r *Input) Init(ctx ilogtail.Context) (int, error)

func (*Input) Start 

func (r *Input) Start(collector ilogtail.Collector) error

func (*Input) Stop 

func (r *Input) Stop() error

type InstanceDiscoveryServiceHandle 

type InstanceDiscoveryServiceHandle struct {
	RegistryInformationCache
}

func (InstanceDiscoveryServiceHandle) Heartbeat 

func (i InstanceDiscoveryServiceHandle) Heartbeat(ctx context.Context, heartbeat *agent.ApplicationInstanceHeartbeat) (*agent.Downstream, error)

func (InstanceDiscoveryServiceHandle) RegisterInstance 

func (i InstanceDiscoveryServiceHandle) RegisterInstance(ctx context.Context, instance *agent.ApplicationInstance) (*agent.ApplicationInstanceMapping, error)

type JVMMetricReportHandle 

type JVMMetricReportHandle struct {
	RegistryInformationCache
	// contains filtered or unexported fields
}

func (*JVMMetricReportHandle) Collect 

func (j *JVMMetricReportHandle) Collect(ctx context.Context, metrics *v2.JVMMetricCollection) (*common.Commands, error)

type JVMMetricServiceHandle 

type JVMMetricServiceHandle struct {
	RegistryInformationCache
	// contains filtered or unexported fields
}

func (*JVMMetricServiceHandle) Collect 

func (j *JVMMetricServiceHandle) Collect(ctx context.Context, metrics *agent.JVMMetrics) (*agent.Downstream, error)

type NetworkAddressRegisterHandle 

type NetworkAddressRegisterHandle struct {
	RegistryInformationCache
}

func (*NetworkAddressRegisterHandle) BatchRegister 

func (n *NetworkAddressRegisterHandle) BatchRegister(ctx context.Context, addresses *agent.NetworkAddresses) (*agent.NetworkAddressMappings, error)

type RegisterHandle 

type RegisterHandle struct {
	RegistryInformationCache
}

func (RegisterHandle) DoEndpointRegister 

func (r RegisterHandle) DoEndpointRegister(ctx context.Context, endpoints *agent.Endpoints) (*agent.EndpointMapping, error)

func (RegisterHandle) DoNetworkAddressRegister 

func (r RegisterHandle) DoNetworkAddressRegister(ctx context.Context, addresses *agent.NetAddresses) (*agent.NetAddressMapping, error)

func (RegisterHandle) DoServiceAndNetworkAddressMappingRegister 

func (r RegisterHandle) DoServiceAndNetworkAddressMappingRegister(ctx context.Context, mappings *agent.ServiceAndNetworkAddressMappings) (*common.Commands, error)

func (RegisterHandle) DoServiceInstanceRegister 

func (r RegisterHandle) DoServiceInstanceRegister(ctx context.Context, instances *agent.ServiceInstances) (*agent.ServiceInstanceRegisterMapping, error)

func (RegisterHandle) DoServiceRegister 

func (r RegisterHandle) DoServiceRegister(ctx context.Context, services *agent.Services) (*agent.ServiceRegisterMapping, error)

type RegistryInformationCache 

type RegistryInformationCache interface {
	ServiceAndNetworkAddressMappingExist(mappings []*agent.ServiceAndNetworkAddressMapping) (interface{}, interface{})
	// contains filtered or unexported methods
}

func NewRegistryInformationCache 

func NewRegistryInformationCache() RegistryInformationCache

type ServiceInstancePingHandle 

type ServiceInstancePingHandle struct {
	RegistryInformationCache
}

func (ServiceInstancePingHandle) DoPing 

func (s ServiceInstancePingHandle) DoPing(ctx context.Context, pkg *agent.ServiceInstancePingPkg) (*common.Commands, error)

type ServiceNameDiscoveryHandle 

type ServiceNameDiscoveryHandle struct {
	RegistryInformationCache
}

func (ServiceNameDiscoveryHandle) Discovery 

func (s ServiceNameDiscoveryHandle) Discovery(ctx context.Context, collection *agent.ServiceNameCollection) (*agent.ServiceNameMappingCollection, error)

type TraceSegmentHandle 

type TraceSegmentHandle struct {
	RegistryInformationCache
	// contains filtered or unexported fields
}

func (*TraceSegmentHandle) Collect 

func (t *TraceSegmentHandle) Collect(server agent.TraceSegmentService_CollectServer) error

type TraceSegmentReportHandle 

type TraceSegmentReportHandle struct {
	RegistryInformationCache
	// contains filtered or unexported fields
}

func (*TraceSegmentReportHandle) Collect 

func (t *TraceSegmentReportHandle) Collect(server v2.TraceSegmentReportService_CollectServer) error

Source Files

View all Source files

Directories

Path Synopsis
skywalking
apm/network/common
apm/network/language/agent
apm/network/language/agent/v2

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.