csv

Documentation

Index

• func NewFile(path, name, ext string, append bool) (*file, error)
• type Writer
  • func (this *Writer) Define(cfg gopi.Config) error
  • func (this *Writer) Dispose() error
  • func (this *Writer) New(cfg gopi.Config) error
  • func (this *Writer) Ping() (time.Duration, error)
  • func (this *Writer) Run(ctx context.Context) error
  • func (this *Writer) String() string
  • func (this *Writer) Write(metrics ...gopi.Measurement) error

Functions

func NewFile

func NewFile(path, name, ext string, append bool) (*file, error)

Types

type Writer

type Writer struct {
	sync.Mutex
	gopi.Unit
	gopi.Logger
	gopi.Publisher
	// contains filtered or unexported fields
}

func (*Writer) Define

func (this *Writer) Define(cfg gopi.Config) error

func (*Writer) Dispose

func (this *Writer) Dispose() error

func (*Writer) New

func (this *Writer) New(cfg gopi.Config) error

func (*Writer) Ping

func (this *Writer) Ping() (time.Duration, error)

func (*Writer) Run

func (this *Writer) Run(ctx context.Context) error

func (*Writer) String

func (this *Writer) String() string

func (*Writer) Write

func (this *Writer) Write(metrics ...gopi.Measurement) error

Write measurements to the endpoint