publish

Documentation

Index

• type CsvPublisher
  • func (p *CsvPublisher) Close() error
  • func (p *CsvPublisher) Publish(tdp *tilt.TiltDataPoint)
  • func (p *CsvPublisher) PublishAll(tdps []*tilt.TiltDataPoint)
• type DatapointPublisher
  • func NewCsvPublisher(destDir string, fileName string) DatapointPublisher

Types

type CsvPublisher

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

func (*CsvPublisher) Close

func (p *CsvPublisher) Close() error

func (*CsvPublisher) Publish

func (p *CsvPublisher) Publish(tdp *tilt.TiltDataPoint)

func (*CsvPublisher) PublishAll

func (p *CsvPublisher) PublishAll(tdps []*tilt.TiltDataPoint)

type DatapointPublisher

type DatapointPublisher interface {
	io.Closer
	Publish(tdp *tilt.TiltDataPoint)
	PublishAll(tdp []*tilt.TiltDataPoint)
}

func NewCsvPublisher

func NewCsvPublisher(destDir string, fileName string) DatapointPublisher