README
¶
#add opentracing kafka transport
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaBasicAuthCredentials ¶
type KafkaBasicAuthCredentials struct {
// contains filtered or unexported fields
}
KafkaBasicAuthCredentials stores credentials for HTTP basic auth.
type KafkaOption ¶
type KafkaOption func(*KafkaTransport)
func KafkaBatchSize ¶
func KafkaBatchSize(n int) KafkaOption
HTTPBatchSize sets the maximum batch size, after which a collect will be triggered. The default batch size is 100 spans.
func KafkaClient ¶
func KafkaClient(topic string, group string, bootstrapservers string, saslEnabled bool, user string, password string) KafkaOption
HTTPTimeout sets maximum timeout for http request.
type KafkaTransport ¶
type KafkaTransport struct {
// contains filtered or unexported fields
}
use sarama.AsyncProducer
func NewKafkaTransport ¶
func NewKafkaTransport(encode string, options ...KafkaOption) (*KafkaTransport, error)
NewKafkaTransport returns a new Kafka-sarama-backend transport
http://hostname:9411/api/v1/spans
func (*KafkaTransport) Append ¶
func (c *KafkaTransport) Append(span *jaeger.Span) (int, error)
Append implements Transport.
func (*KafkaTransport) Flush ¶
func (c *KafkaTransport) Flush() (int, error)
Flush implements Transport.
Source Files
Click to show internal directories.
Click to hide internal directories.