csv

Documentation

Index

• type FilenameForwarder
  • func ForwarderLoader(forwardTo *config.ForwardTo) (*FilenameForwarder, error)
  • func NewForwarder(name string, filename string) (*FilenameForwarder, error)
  • func (connector *FilenameForwarder) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (connector *FilenameForwarder) AddEvents(ctx context.Context, events []*event.Event) error
  • func (connector *FilenameForwarder) Close() error
  • func (connector *FilenameForwarder) Stats() []*datapoint.Datapoint

Types

type FilenameForwarder

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

FilenameForwarder prints datapoints to a file

func ForwarderLoader

func ForwarderLoader(forwardTo *config.ForwardTo) (*FilenameForwarder, error)

ForwarderLoader loads a CSV forwarder forwarding points from proxy to a file

func NewForwarder

func NewForwarder(name string, filename string) (*FilenameForwarder, error)

NewForwarder creates a new filename forwarder

func (*FilenameForwarder) AddDatapoints

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

AddDatapoints writes the points to a file

func (*FilenameForwarder) AddEvents

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

AddEvents writes the events to a file

func (*FilenameForwarder) Close

func (connector *FilenameForwarder) Close() error

Close does nothing. We foolishly reopen the file on each AddDatapoints

func (*FilenameForwarder) Stats

func (connector *FilenameForwarder) Stats() []*datapoint.Datapoint

Stats returns an empty list