csv

Documentation

Index

• type Config
• type Forwarder
  • func NewForwarder(config *Config) (*Forwarder, error)
  • func (f *Forwarder) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (f *Forwarder) AddEvents(ctx context.Context, events []*event.Event) error
  • func (f *Forwarder) AddSpans(ctx context.Context, spans []*trace.Span) error
  • func (f *Forwarder) Close() error
  • func (f *Forwarder) Datapoints() []*datapoint.Datapoint
  • func (f *Forwarder) DebugDatapoints() []*datapoint.Datapoint
  • func (f *Forwarder) DebugEndpoints() map[string]http.Handler
  • func (f *Forwarder) DefaultDatapoints() []*datapoint.Datapoint
  • func (f *Forwarder) Pipeline() int64
  • func (f *Forwarder) StartupFinished() error

Types

type Config

type Config struct {
	Filters     *filtering.FilterObj
	Filename    *string
	WriteString func(f *os.File, s string) (ret int, err error)
}

Config controls the optional configuration of the csv forwarder

type Forwarder

type Forwarder struct {
	filtering.FilteredForwarder
	// contains filtered or unexported fields
}

Forwarder prints datapoints to a file

func NewForwarder

func NewForwarder(config *Config) (*Forwarder, error)

NewForwarder creates a new filename forwarder

func (*Forwarder) AddDatapoints

func (f *Forwarder) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints writes the points to a file

func (*Forwarder) AddEvents

func (f *Forwarder) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents writes the events to a file

func (*Forwarder) AddSpans

func (f *Forwarder) AddSpans(ctx context.Context, spans []*trace.Span) error

AddSpans writes the spans to a file

func (*Forwarder) Close

func (f *Forwarder) Close() error

Close the file we write to

func (*Forwarder) Datapoints

func (f *Forwarder) Datapoints() []*datapoint.Datapoint

Datapoints implements the sfxclient.Collector interface and returns all datapoints

func (*Forwarder) DebugDatapoints

func (f *Forwarder) DebugDatapoints() []*datapoint.Datapoint

DebugDatapoints returns datapoints that are used for debugging

func (*Forwarder) DebugEndpoints

func (f *Forwarder) DebugEndpoints() map[string]http.Handler

DebugEndpoints returns no http handlers

func (*Forwarder) DefaultDatapoints

func (f *Forwarder) DefaultDatapoints() []*datapoint.Datapoint

DefaultDatapoints returns a set of default datapoints about the forwarder

func (*Forwarder) Pipeline

func (f *Forwarder) Pipeline() int64

Pipeline returns 0 because csvforwarder doesn't buffer

func (*Forwarder) StartupFinished

func (f *Forwarder) StartupFinished() error

StartupFinished can be called if you want to do something after startup is complete