Documentation
¶
Index ¶
- type 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
- type Options
- type SpanWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory implements storage.Factory and creates write-only storage components backed by kafka.
func (*Factory) CreateDependencyReader ¶
func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error)
CreateDependencyReader implements storage.Factory
func (*Factory) CreateSpanReader ¶
CreateSpanReader implements storage.Factory
func (*Factory) CreateSpanWriter ¶
CreateSpanWriter implements storage.Factory
func (*Factory) InitFromViper ¶
InitFromViper implements plugin.Configurable
type Marshaller ¶
Marshaller encodes a span into a byte array to be sent to Kafka
type Options ¶
type Options struct {
// contains filtered or unexported fields
}
Options stores the configuration options for Kafka
func (*Options) InitFromViper ¶
InitFromViper initializes Options with properties from viper
type SpanWriter ¶
type SpanWriter struct {
// contains filtered or unexported fields
}
SpanWriter writes spans to kafka. Implements spanstore.Writer
func NewSpanWriter ¶
func NewSpanWriter(producer sarama.AsyncProducer, marshaller Marshaller, topic string, factory metrics.Factory) *SpanWriter
NewSpanWriter initiates and returns a new kafka spanwriter
func (*SpanWriter) Close ¶
func (w *SpanWriter) Close() error
Close closes SpanWriter by closing producer
Source Files
Click to show internal directories.
Click to hide internal directories.