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) Close() error
  • func (f *Forwarder) Datapoints() []*datapoint.Datapoint
  • func (f *Forwarder) Pipeline() int64

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) Close

func (f *Forwarder) Close() error

Close the file we write to

func (*Forwarder) Datapoints

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

Datapoints returns nothing and exists to satisfy the protocol.Forwarder interface

func (*Forwarder) Pipeline

func (f *Forwarder) Pipeline() int64

Pipeline returns 0 because csvforwarder doesn't buffer