skywalkingv2

Nov 30, 2021

Changes in this version

+ type Application struct

+ type ApplicationInstance struct

+ type ApplicationRegisterHandle struct

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

+ type Endpoints struct

+ type Input struct

+ Address string

+ ComponentMapping map[int32]string

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

+ func (r *Input) Description() string

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

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

+ func (r *Input) Stop() error

+ type InstanceDiscoveryServiceHandle struct

+ 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 struct

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

+ type JVMMetricServiceHandle struct

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

+ type NetworkAddressRegisterHandle struct

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

+ type RegisterHandle struct

+ 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 interface

+ ServiceAndNetworkAddressMappingExist func(mappings []*agent.ServiceAndNetworkAddressMapping) (interface{}, interface{})

+ func NewRegistryInformationCache() RegistryInformationCache

+ type ServiceInstancePingHandle struct

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

+ type ServiceNameDiscoveryHandle struct

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

+ type TraceSegmentHandle struct

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

+ type TraceSegmentReportHandle struct

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