receiver

Documentation

Index

• type CSVRcv
  • func NewCSVRcv(filename string, headers []string) (*CSVRcv, error)
  • func (csvRcv *CSVRcv) Receive(p dataconverter.Params) error
  • func (csvRcv *CSVRcv) Stop() error
• type Receiver

Types

type CSVRcv

type CSVRcv struct {
	*csv.Writer
	// contains filtered or unexported fields
}

func NewCSVRcv

func NewCSVRcv(filename string, headers []string) (*CSVRcv, error)

func (*CSVRcv) Receive

func (csvRcv *CSVRcv) Receive(p dataconverter.Params) error

func (*CSVRcv) Stop

func (csvRcv *CSVRcv) Stop() error

type Receiver

type Receiver interface {
	Receive(dataconverter.Params) error
	Stop() error
}