skywalkingv2

Documentation

Index

• type Application
• type ApplicationInstance
• type ApplicationRegisterHandle
  • func (h *ApplicationRegisterHandle) ApplicationCodeRegister(context context.Context, application *agent.Application) (*agent.ApplicationMapping, error)
• type Endpoints
• type Input
  • func (r *Input) Collect(pipeline.Collector) error
  • func (r *Input) Description() string
  • func (r *Input) Init(ctx pipeline.Context) (int, error)
  • func (r *Input) Start(collector pipeline.Collector) error
  • func (r *Input) Stop() error
• type InstanceDiscoveryServiceHandle
  • func (i InstanceDiscoveryServiceHandle) Heartbeat(ctx context.Context, heartbeat *agent.ApplicationInstanceHeartbeat) (*agent.Downstream, error)
  • func (i InstanceDiscoveryServiceHandle) RegisterInstance(ctx context.Context, instance *agent.ApplicationInstance) (*agent.ApplicationInstanceMapping, error)
• type JVMMetricReportHandle
  • func (j *JVMMetricReportHandle) Collect(ctx context.Context, metrics *v2.JVMMetricCollection) (*common.Commands, error)
• type JVMMetricServiceHandle
  • func (j *JVMMetricServiceHandle) Collect(ctx context.Context, metrics *agent.JVMMetrics) (*agent.Downstream, error)
• type NetworkAddressRegisterHandle
  • func (n *NetworkAddressRegisterHandle) BatchRegister(ctx context.Context, addresses *agent.NetworkAddresses) (*agent.NetworkAddressMappings, error)
• type RegisterHandle
  • func (r RegisterHandle) DoEndpointRegister(ctx context.Context, endpoints *agent.Endpoints) (*agent.EndpointMapping, error)
  • func (r RegisterHandle) DoNetworkAddressRegister(ctx context.Context, addresses *agent.NetAddresses) (*agent.NetAddressMapping, error)
  • func (r RegisterHandle) DoServiceAndNetworkAddressMappingRegister(ctx context.Context, mappings *agent.ServiceAndNetworkAddressMappings) (*common.Commands, error)
  • func (r RegisterHandle) DoServiceInstanceRegister(ctx context.Context, instances *agent.ServiceInstances) (*agent.ServiceInstanceRegisterMapping, error)
  • func (r RegisterHandle) DoServiceRegister(ctx context.Context, services *agent.Services) (*agent.ServiceRegisterMapping, error)
• type RegistryInformationCache
  • func NewRegistryInformationCache() RegistryInformationCache
• type ServiceInstancePingHandle
  • func (s ServiceInstancePingHandle) DoPing(ctx context.Context, pkg *agent.ServiceInstancePingPkg) (*common.Commands, error)
• type ServiceNameDiscoveryHandle
  • func (s ServiceNameDiscoveryHandle) Discovery(ctx context.Context, collection *agent.ServiceNameCollection) (*agent.ServiceNameMappingCollection, error)
• type TraceSegmentHandle
  • func (t *TraceSegmentHandle) Collect(server agent.TraceSegmentService_CollectServer) error
• type TraceSegmentReportHandle
  • func (t *TraceSegmentReportHandle) Collect(server v2.TraceSegmentReportService_CollectServer) error

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(pipeline.Collector) error

func (*Input) Description

func (r *Input) Description() string

func (*Input) Init

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

func (*Input) Start

func (r *Input) Start(collector pipeline.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