Versions in this module Expand all Collapse all v1 v1.0.0 Dec 5, 2022 Changes in this version + var KafkazipkinHostfail = errors.New("trace: Parse kafkazipkin url fail Host is nil") + var KafkazipkinTopicfail = errors.New("trace: Parse kafkazipkin url fail Topic is nil") + func NewSaramaReporter(address string, asyncFlag bool, logger *logrus.Entry) (r reporter.Reporter, err error) + type KafkaGoReporter struct + Stoped bool + func NewGoReporter(endpoint string) (*KafkaGoReporter, error) + func (r *KafkaGoReporter) Close() error + func (r *KafkaGoReporter) Send(s model.SpanModel, flag bool) + type Producer struct
Go to main page