Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
Agent is a composition of all services / components
func NewAgent ¶
func NewAgent( processors []processors.Processor, httpServer *http.Server, logger *zap.Logger, ) *Agent
NewAgent creates the new Agent.
func (*Agent) GetHTTPRouter ¶
GetHTTPRouter returns Gorilla HTTP router used by the agent's HTTP server.
type Builder ¶
type Builder struct {
Processors []ProcessorConfiguration `yaml:"processors"`
HTTPServer HTTPServerConfiguration `yaml:"httpServer"`
// contains filtered or unexported fields
}
Builder Struct to hold configurations
func (*Builder) CreateAgent ¶
func (b *Builder) CreateAgent(primaryProxy CollectorProxy, logger *zap.Logger, mFactory metrics.Factory) (*Agent, error)
CreateAgent creates the Agent
func (*Builder) InitFromViper ¶
InitFromViper initializes Builder with properties retrieved from Viper.
type CollectorProxy ¶
type CollectorProxy interface {
GetReporter() reporter.Reporter
GetManager() configmanager.ClientConfigManager
io.Closer
}
CollectorProxy provides access to Reporter and ClientConfigManager
func CreateCollectorProxy ¶
func CreateCollectorProxy( opts ProxyBuilderOptions, builders map[reporter.Type]CollectorProxyBuilder, ) (CollectorProxy, error)
CreateCollectorProxy creates collector proxy
type CollectorProxyBuilder ¶
type CollectorProxyBuilder func(ProxyBuilderOptions) (CollectorProxy, error)
CollectorProxyBuilder is a func which builds CollectorProxy.
func GRPCCollectorProxyBuilder ¶
func GRPCCollectorProxyBuilder(builder *grpc.ConnBuilder) CollectorProxyBuilder
GRPCCollectorProxyBuilder creates CollectorProxyBuilder for GRPC reporter
type HTTPServerConfiguration ¶
type HTTPServerConfiguration struct {
HostPort string `yaml:"hostPort" validate:"nonzero"`
}
HTTPServerConfiguration holds config for a server providing sampling strategies and baggage restrictions to clients
type ProcessorConfiguration ¶
type ProcessorConfiguration struct {
Workers int `yaml:"workers"`
Model Model `yaml:"model"`
Protocol Protocol `yaml:"protocol"`
Server ServerConfiguration `yaml:"server"`
}
ProcessorConfiguration holds config for a processor that receives spans from Server
func (*ProcessorConfiguration) GetThriftProcessor ¶
func (c *ProcessorConfiguration) GetThriftProcessor( mFactory metrics.Factory, factory thrift.TProtocolFactory, handler processors.AgentProcessor, logger *zap.Logger, ) (processors.Processor, error)
GetThriftProcessor gets a TBufferedServer backed Processor using the collector configuration
type ProxyBuilderOptions ¶
ProxyBuilderOptions holds config for CollectorProxyBuilder
type ServerConfiguration ¶
type ServerConfiguration struct {
QueueSize int `yaml:"queueSize"`
MaxPacketSize int `yaml:"maxPacketSize"`
SocketBufferSize int `yaml:"socketBufferSize"`
HostPort string `yaml:"hostPort" validate:"nonzero"`
}
ServerConfiguration holds config for a server that receives spans from the network
Source Files
Directories