skywalkingreceiver

Documentation

Index

• func NewFactory() receiver.Factory
• type Config
  • func (cfg *Config) Unmarshal(componentParser *confmap.Conf) error
  • func (cfg *Config) Validate() error
• type Protocols
• type SwManagementServiceServer
  • func (s *SwManagementServiceServer) KeepAlive(ctx context.Context, ping *management.InstancePingPkg) (*v3.Commands, error)
  • func (s *SwManagementServiceServer) ReportInstanceProperties(ctx context.Context, properties *management.InstanceProperties) (*v3.Commands, error)

Functions

func NewFactory

func NewFactory() receiver.Factory

NewFactory creates a new Skywalking receiver factory.

Types

type Config

type Config struct {
	Protocols   `mapstructure:"protocols"`
	ExtensionID *component.ID `mapstructure:"fillproc_extension"`
}

Config defines configuration for skywalking receiver.

func (*Config) Unmarshal

func (cfg *Config) Unmarshal(componentParser *confmap.Conf) error

Unmarshal a config.Parser into the config struct.

func (*Config) Validate

func (cfg *Config) Validate() error

Validate checks the receiver configuration is valid

type Protocols

type Protocols struct {
	GRPC *configgrpc.ServerConfig `mapstructure:"grpc"`
	HTTP *confighttp.ServerConfig `mapstructure:"http"`
}

Protocols is the configuration for the supported protocols.

type SwManagementServiceServer

type SwManagementServiceServer struct {
	management.UnimplementedManagementServiceServer
	TraceReceiver *trace.Receiver
}

func (*SwManagementServiceServer) KeepAlive

func (s *SwManagementServiceServer) KeepAlive(ctx context.Context, ping *management.InstancePingPkg) (*v3.Commands, error)

func (*SwManagementServiceServer) ReportInstanceProperties

func (s *SwManagementServiceServer) ReportInstanceProperties(ctx context.Context, properties *management.InstanceProperties) (*v3.Commands, error)