processor

Documentation

Index

• Constants
• Variables
• func AddFlags(flags *flag.FlagSet)
• type Flags
  • func (f *Flags) InitFromViper(v *viper.Viper) *Flags
• type Option
• type ProcessSpan
  • func ChainedProcessSpan(sps ...ProcessSpan) ProcessSpan
• type ProcessSpans
• type SpanProcessor
  • func NewSpanProcessor(logger *zap.Logger, opts ...Option) SpanProcessor

Constants

const (
	DefaultNumWorkers       = 4
	DefaultConfigServerAddr = "config-server"
	DefaultConfigServerPort = ports.ConfigServerGrpcListenPort
)

const (
	ParentTagNameService   = "p-svc"
	ParentTagNameOperation = "p-op"

	QueueCapacity = 1048576 // 2 ^ 20
)

Variables

var Options options

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

Types

type Flags

type Flags struct {
	NumWorkers       int
	ConfigServerAddr string
	ConfigServerPort int
}

func (*Flags) InitFromViper

func (f *Flags) InitFromViper(v *viper.Viper) *Flags

type Option

type Option func(opt *options)

type ProcessSpan

type ProcessSpan func(span *model.Span)

func ChainedProcessSpan

func ChainedProcessSpan(sps ...ProcessSpan) ProcessSpan

type ProcessSpans

type ProcessSpans func(spans []*model.Span)

type SpanProcessor

type SpanProcessor interface {
	io.Closer
	ProcessSpans(spans []*model.Span) error
}

func NewSpanProcessor

func NewSpanProcessor(logger *zap.Logger, opts ...Option) SpanProcessor