Documentation
¶
Overview ¶
Package flow processes gotocol context information to collect and export request flows across the system
Index ¶
- func Add2Buffer(msg gotocol.Message)
- func AnnotateReceive(msg gotocol.Message, name string, received time.Time, tag_symbol string)
- func AnnotateSend(msg gotocol.Message, name string, tag_symbol string)
- func End(msg gotocol.Message, resphist, servhist, rthist *generic.Histogram)
- func Endless_clear()
- func Flush(t gotocol.TraceContextType, trace []*spannotype)
- func Instrument(msg gotocol.Message, name string, hist *generic.Histogram, tag_symbol string)
- func Interval_save()
- func Shutdown()
- func WriteZip(zip zipkinspan)
- type ByCtx
- type KafkaCollector
- type Values
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add2Buffer ¶
func AnnotateReceive ¶
AnnotateReceive service activity when receiving a message
func AnnotateSend ¶
AnnotateSend service sends on a flow
func Endless_clear ¶
func Endless_clear()
func Flush ¶
func Flush(t gotocol.TraceContextType, trace []*spannotype)
Flush the spans for a request in zipkin format
func Instrument ¶
Instrument common code for requests
func Interval_save ¶
func Interval_save()
kafka arch don't set,so we can't collect flow metrics during running 这种方法的bug,当出现Delete类型的错误时，无法抓到路径上经过Delete节点的所有trace
Types ¶
type KafkaCollector ¶
type KafkaCollector struct {
// contains filtered or unexported fields
}
KafkaCollector implements Collector by publishing spans to a Kafka broker.
func NewKafkaCollector ¶
func NewKafkaCollector(addrs []string) (*KafkaCollector, error)
NewKafkaCollector returns a new Kafka-backed Collector. addrs should be a slice of TCP endpoints of the form "host:port".
func (*KafkaCollector) Collect ¶
func (c *KafkaCollector) Collect(s []byte)
Collect implements Collector.
Source Files
Click to show internal directories.
Click to hide internal directories.