builder

Documentation

Index

• func AddFlags(flags *flag.FlagSet)
• type CollectorOptions
  • func (cOpts *CollectorOptions) InitFromViper(v *viper.Viper) *CollectorOptions
• type SpanHandlerBuilder
  • func NewSpanHandlerBuilder(cOpts *CollectorOptions, sFlags *flags.SharedFlags, opts ...basicB.Option) (*SpanHandlerBuilder, error)
  • func (spanHb *SpanHandlerBuilder) BuildHandlers() (app.ZipkinSpansHandler, app.JaegerBatchesHandler)

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

AddFlags adds flags for CollectorOptions

Types

type CollectorOptions

type CollectorOptions struct {
	// QueueSize is the size of collector's queue
	QueueSize int
	// NumWorkers is the number of internal workers in a collector
	NumWorkers int
	// WriteCacheTTL denotes how often to check and re-write a service or operation name
	WriteCacheTTL time.Duration
	// CollectorPort is the port that the collector service listens in on for tchannel requests
	CollectorPort int
	// CollectorHTTPPort is the port that the collector service listens in on for http requests
	CollectorHTTPPort int
	// CollectorZipkinHTTPPort is the port that the Zipkin collector service listens in on for http requests
	CollectorZipkinHTTPPort int
	// CollectorHealthCheckHTTPPort is the port that the health check service listens in on for http requests
	CollectorHealthCheckHTTPPort int
}

CollectorOptions holds configuration for collector

func (*CollectorOptions) InitFromViper

func (cOpts *CollectorOptions) InitFromViper(v *viper.Viper) *CollectorOptions

InitFromViper initializes CollectorOptions with properties from viper

type SpanHandlerBuilder

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

SpanHandlerBuilder holds configuration required for handlers

func NewSpanHandlerBuilder

func NewSpanHandlerBuilder(cOpts *CollectorOptions, sFlags *flags.SharedFlags, opts ...basicB.Option) (*SpanHandlerBuilder, error)

NewSpanHandlerBuilder returns new SpanHandlerBuilder with configured span storage.

func (*SpanHandlerBuilder) BuildHandlers

func (spanHb *SpanHandlerBuilder) BuildHandlers() (app.ZipkinSpansHandler, app.JaegerBatchesHandler)

BuildHandlers builds span handlers (Zipkin, Jaeger)