Documentation ¶
Index ¶
- func DefaultPort() int16
- func DefaultProducer(brokerList []string) (*producer.KafkaProducer, error)
- func DefaultTopic() string
- func LocalNetworkIP() string
- func SerializeSpan(s *zipkincore.Span) ([]byte, error)
- type Collector
- type KafkaCollector
- type Span
- func (s *Span) Annotate(value string)
- func (s *Span) ClientReceive()
- func (s *Span) ClientReceiveAndCollect()
- func (s *Span) ClientSend()
- func (s *Span) ClientSendAndCollect()
- func (s *Span) Collect() error
- func (s *Span) GetAvroTraceInfo() *avro.GenericRecord
- func (s *Span) ID() int64
- func (s *Span) NewChild(name string) *Span
- func (s *Span) ParentID() *int64
- func (s *Span) Sampled() bool
- func (s *Span) ServerReceive()
- func (s *Span) ServerReceiveAndCollect()
- func (s *Span) ServerSend()
- func (s *Span) ServerSendAndCollect()
- func (s *Span) TraceID() int64
- type TraceInfo
- type Tracer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultPort ¶
func DefaultPort() int16
func DefaultProducer ¶
func DefaultTopic ¶
func DefaultTopic() string
func LocalNetworkIP ¶
func LocalNetworkIP() string
func SerializeSpan ¶
func SerializeSpan(s *zipkincore.Span) ([]byte, error)
Types ¶
type KafkaCollector ¶
type KafkaCollector struct {
// contains filtered or unexported fields
}
func (*KafkaCollector) Collect ¶
func (kc *KafkaCollector) Collect(bytes []byte)
type Span ¶
func (*Span) ClientReceive ¶
func (s *Span) ClientReceive()
func (*Span) ClientReceiveAndCollect ¶
func (s *Span) ClientReceiveAndCollect()
func (*Span) ClientSend ¶
func (s *Span) ClientSend()
func (*Span) ClientSendAndCollect ¶
func (s *Span) ClientSendAndCollect()
func (*Span) GetAvroTraceInfo ¶
func (s *Span) GetAvroTraceInfo() *avro.GenericRecord
func (*Span) ServerReceive ¶
func (s *Span) ServerReceive()
func (*Span) ServerReceiveAndCollect ¶
func (s *Span) ServerReceiveAndCollect()
func (*Span) ServerSend ¶
func (s *Span) ServerSend()
func (*Span) ServerSendAndCollect ¶
func (s *Span) ServerSendAndCollect()
type TraceInfo ¶
func NewTraceInfo ¶
func NewTraceInfo() *TraceInfo
Click to show internal directories.
Click to hide internal directories.