Documentation
¶
Index ¶
- type Agent
- type Builder
- func (b *Builder) Bind(flags *flag.FlagSet)
- func (b *Builder) CreateAgent(mFactory metrics.Factory, logger *zap.Logger) (*Agent, error)
- func (b *Builder) GetProcessors(rep reporter.Reporter, mFactory metrics.Factory) ([]processors.Processor, error)
- func (b *Builder) WithChannel(c *tchannel.Channel) *Builder
- func (b *Builder) WithCollectorServiceName(s string) *Builder
- func (b *Builder) WithDiscoverer(d discovery.Discoverer) *Builder
- func (b *Builder) WithDiscoveryNotifier(n discovery.Notifier) *Builder
- func (b *Builder) WithReporter(r reporter.Reporter) *Builder
- type ProcessorConfiguration
- type SamplingServerConfiguration
- type ServerConfiguration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, samplingServer *http.Server, discoveryClient interface{}, logger *zap.Logger, ) *Agent
NewAgent creates the new Agent.
type Builder ¶
type Builder struct {
Processors []ProcessorConfiguration `yaml:"processors"`
SamplingServer SamplingServerConfiguration `yaml:"samplingServer"`
// CollectorHostPorts are host:ports of a static list of Jaeger Collectors.
CollectorHostPorts []string `yaml:"collectorHostPorts"`
// MinPeers is the min number of servers we want the agent to connect to.
// If zero, defaults to min(3, number of peers returned by service discovery)
DiscoveryMinPeers int `yaml:"minPeers"`
// CollectorServiceName is the name that Jaeger Collector's TChannel server
// responds to.
CollectorServiceName string `yaml:"collectorServiceName"`
// contains filtered or unexported fields
}
Builder Struct to hold configurations
func NewBuilder ¶
func NewBuilder() *Builder
NewBuilder creates a default builder with three processors.
func (*Builder) CreateAgent ¶
CreateAgent creates the Agent
func (*Builder) GetProcessors ¶
func (b *Builder) GetProcessors(rep reporter.Reporter, mFactory metrics.Factory) ([]processors.Processor, error)
GetProcessors creates Processors with attached Reporter
func (*Builder) WithChannel ¶
WithChannel sets tchannel channel
func (*Builder) WithCollectorServiceName ¶
WithCollectorServiceName sets collector service name
func (*Builder) WithDiscoverer ¶
func (b *Builder) WithDiscoverer(d discovery.Discoverer) *Builder
WithDiscoverer sets service discovery
func (*Builder) WithDiscoveryNotifier ¶
WithDiscoveryNotifier sets service discovery notifier
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, ) (processors.Processor, error)
GetThriftProcessor gets a TBufferedServer backed Processor using the collector configuration
type SamplingServerConfiguration ¶
type SamplingServerConfiguration struct {
HostPort string `yaml:"hostPort" validate:"nonzero"`
}
SamplingServerConfiguration holds config for a server providing sampling strategies to clients
func (SamplingServerConfiguration) GetSamplingServer ¶
func (c SamplingServerConfiguration) GetSamplingServer(svc string, channel *tchannel.Channel, mFactory metrics.Factory) *http.Server
GetSamplingServer creates an HTTP server that provides sampling strategies to client libraries.
type ServerConfiguration ¶
type ServerConfiguration struct {
QueueSize int `yaml:"queueSize"`
MaxPacketSize int `yaml:"maxPacketSize"`
HostPort string `yaml:"hostPort" validate:"nonzero"`
}
ServerConfiguration holds config for a server that receives spans from the network
Source Files
Directories