api

Documentation

Index

• type Gatherer
• type GathererConfig

Types

type Gatherer

type Gatherer interface {
	api.Module
	// DataChannel is a blocking channel to transfer the apm data to the upstream processor module.
	OutputDataChannel() <-chan *queue.SequenceEvent
	// Ack the sent offset.
	Ack(lastOffset event.Offset)
	// Inject the Processor module.
	SetProcessor(processor api.Module) error
}

Gatherer is the APM data collection module in Satellite.

type GathererConfig

type GathererConfig struct {
	// common config
	*config.CommonFields
	QueueConfig plugin.Config `mapstructure:"queue"` // queue plugin config

	// ReceiverGatherer
	ReceiverConfig plugin.Config `mapstructure:"receiver"`    // collector plugin config
	ServerName     string        `mapstructure:"server_name"` // depends on which server

	// FetcherGatherer
	FetcherConfig plugin.Config `mapstructure:"fetcher"` // fetcher plugin config
}

GathererConfig contains all implementation fields.