Versions in this module Expand all Collapse all v1 v1.6.0 Jul 10, 2018 Changes in this version + type Factory struct + func NewFactory() *Factory + func (f *Factory) AddFlags(flagSet *flag.FlagSet) + func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error) + func (f *Factory) CreateSpanReader() (spanstore.Reader, error) + func (f *Factory) CreateSpanWriter() (spanstore.Writer, error) + func (f *Factory) InitFromViper(v *viper.Viper) + func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error + type Marshaller interface + Marshal func(*model.Span) ([]byte, error) + type Options struct + func (opt *Options) AddFlags(flagSet *flag.FlagSet) + func (opt *Options) InitFromViper(v *viper.Viper) + type SpanWriter struct + func NewSpanWriter(producer sarama.AsyncProducer, marshaller Marshaller, topic string, ...) *SpanWriter + func (w *SpanWriter) Close() error + func (w *SpanWriter) WriteSpan(span *model.Span) error