collector

Documentation

Index

• type Collector
  • func New(cfg *conf.Config) (*Collector, error)
  • func (c *Collector) Close() error
  • func (c *Collector) ListenAndStart() error
  • func (c *Collector) Process(ctx context.Context, protoSpan *model.ProtoSpan) error
• type OperationNameProcess
  • func (o *OperationNameProcess) Process(span *model.Span) error
• type ProcessFunc
  • func (p ProcessFunc) Process(span *model.Span) error
• type Processer
  • func NewOperationNameProcess() Processer
  • func NewPeerServiceDetectProcesser(data map[string]map[string]struct{}) Processer
  • func NewServiceBreakerProcess(n int) Processer

Types

type Collector

type Collector struct {
	// contains filtered or unexported fields
}

Collector dapper collector receving trace data from tcp and write to hbase and influxdb

func New

func New(cfg *conf.Config) (*Collector, error)

New new dapper collector

func (*Collector) Close

func (c *Collector) Close() error

Close collector

func (*Collector) ListenAndStart

func (c *Collector) ListenAndStart() error

ListenAndStart listen and start collector server

func (*Collector) Process

func (c *Collector) Process(ctx context.Context, protoSpan *model.ProtoSpan) error

Process dispatch protoSpan

type OperationNameProcess

type OperationNameProcess struct{}

OperationNameProcess fix operation name so sad!

func (*OperationNameProcess) Process

func (o *OperationNameProcess) Process(span *model.Span) error

Process implement operation name

type ProcessFunc

type ProcessFunc func(*model.Span) error

ProcessFunc implement Processer

func (ProcessFunc) Process

func (p ProcessFunc) Process(span *model.Span) error

Process implement Processer

type Processer

type Processer interface {
	Process(span *model.Span) error
}

Processer span processer

func NewOperationNameProcess

func NewOperationNameProcess() Processer

NewOperationNameProcess .

func NewPeerServiceDetectProcesser

func NewPeerServiceDetectProcesser(data map[string]map[string]struct{}) Processer

NewPeerServiceDetectProcesser .

func NewServiceBreakerProcess

func NewServiceBreakerProcess(n int) Processer

NewServiceBreakerProcess .