appspy

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Aug 5, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewExporter

func NewExporter(cfg *Config) exporter.Exporter

Types

type AppSpy

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

func NewAppSpy

func NewAppSpy(cfg *Config) (*AppSpy, error)

func (*AppSpy) GetReceiver

func (a *AppSpy) GetReceiver() receiver.Receiver

func (*AppSpy) Init

func (a *AppSpy) Init(cfg any) error

func (*AppSpy) Start

func (a *AppSpy) Start() error

func (*AppSpy) Stop

func (a *AppSpy) Stop() error

type ComponentsFactory

type ComponentsFactory struct {
	// receiver used to receive ebpf data from cilium etc.
	Receivers map[string]ReceiverFactory
	// detector used to handle receiver data
	Detectors map[string]DetectorFactory
	// processor used to handle detector data as aggregator
	Processors map[string]ProcessorFactory
	// exporter used to handler processor data and send trace metric to
	// server like prometheus etc.
	Exporters map[string]ExporterFactory
}

data folw of pipline: receiver --> detector --> processor --> exporter

func NewConpnentsFactory

func NewConpnentsFactory() *ComponentsFactory

func (*ComponentsFactory) RegisterDetector

func (c *ComponentsFactory) RegisterDetector(name string, cb NewDetectorCb, config any)

func (*ComponentsFactory) RegisterExporter

func (c *ComponentsFactory) RegisterExporter(name string, cb NewExporterCb, config any)

func (*ComponentsFactory) RegisterProcessor

func (c *ComponentsFactory) RegisterProcessor(name string, cb NewProcessorCb, config any)

func (*ComponentsFactory) RegisterReceiver

func (c *ComponentsFactory) RegisterReceiver(name string, cb NewReceiverCb, config any)

type Config

type Config struct {
	Exporter string
	Server   string
	Port     string
}

type DetectorFactory

type DetectorFactory struct {
	NewComponentMember NewDetectorCb
	Config             any
}

type ExporterFactory

type ExporterFactory struct {
	NewComponentMember NewExporterCb
	Config             any
}

type NewDetectorCb

type NewDetectorCb func(cfg any, consumers []consumer.Consumer) detector.Detector

type NewExporterCb

type NewExporterCb func(cfg any, consumers consumer.Consumer) exporter.Exporter

type NewProcessorCb

type NewProcessorCb func(cfg any, consumers consumer.Consumer) processor.Processor

type NewReceiverCb

type NewReceiverCb func(cfg any, managers *detector.DetectorManager) receiver.Receiver

type ProcessorFactory

type ProcessorFactory struct {
	NewComponentMember NewProcessorCb
	Config             any
}

type ReceiverFactory

type ReceiverFactory struct {
	NewComponentMember NewReceiverCb
	Config             any
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL