transaction

Documentation

Index

• func NewProcessor(config *pr.Config) pr.Processor
• func Schema() string
• type Dropped
• type Event
  • func (ev *Event) DocType() string
  • func (t *Event) Mappings(pa *payload) (time.Time, []utility.DocMapping)
  • func (ev *Event) Transform() common.MapStr
• type Span
  • func (s *Span) DocType() string
  • func (s *Span) Mappings(config *pr.Config, pa *payload, tx Event) (time.Time, []utility.DocMapping)
  • func (s *Span) Transform(config *pr.Config, service m.Service) common.MapStr
• type SpanCount

Functions

func NewProcessor

func NewProcessor(config *pr.Config) pr.Processor

func Schema

func Schema() string

Types

type Dropped

type Dropped struct {
	Total *int
}

type Event

type Event struct {
	Id        string
	Name      string
	Type      string
	Result    *string
	Duration  float64
	Timestamp time.Time
	Context   common.MapStr
	Spans     []Span
	Marks     common.MapStr
	Sampled   *bool
	SpanCount SpanCount `mapstructure:"span_count"`
}

func (*Event) DocType

func (ev *Event) DocType() string

func (*Event) Mappings

func (t *Event) Mappings(pa *payload) (time.Time, []utility.DocMapping)

func (*Event) Transform

func (ev *Event) Transform() common.MapStr

type Span

type Span struct {
	Id         *int
	Name       string
	Type       string
	Start      float64
	Duration   float64
	Stacktrace m.Stacktrace `mapstructure:"stacktrace"`
	Context    common.MapStr
	Parent     *int
}

func (*Span) DocType

func (s *Span) DocType() string

func (*Span) Mappings

func (s *Span) Mappings(config *pr.Config, pa *payload, tx Event) (time.Time, []utility.DocMapping)

func (*Span) Transform

func (s *Span) Transform(config *pr.Config, service m.Service) common.MapStr

type SpanCount

type SpanCount struct {
	Dropped Dropped
}