Documentation
¶
Index ¶
- type CSVStreamInput
- func (i *CSVStreamInput) Configure() error
- func (i *CSVStreamInput) EntriesRead() int64
- func (i *CSVStreamInput) Errors() *chan error
- func (i *CSVStreamInput) InputExists() *bool
- func (i *CSVStreamInput) Loop(file io.Reader)
- func (i *CSVStreamInput) PushData(data interface{})
- func (i *CSVStreamInput) Run(file io.Reader)
- func (i *CSVStreamInput) SetTable(t tablestream.Table)
- func (i *CSVStreamInput) Table() tablestream.Table
- type Inputer
- type StreamInput
- func (i *StreamInput) Configure() error
- func (i *StreamInput) EntriesRead() int64
- func (i *StreamInput) Errors() *chan error
- func (i *StreamInput) InputExists() *bool
- func (i *StreamInput) Loop(file io.Reader)
- func (i *StreamInput) PushData(data interface{})
- func (i *StreamInput) Run(file io.Reader)
- func (i *StreamInput) SetTable(t tablestream.Table)
- func (i *StreamInput) Table() tablestream.Table
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CSVStreamInput ¶
type CSVStreamInput struct {
Inputer
// contains filtered or unexported fields
}
func (*CSVStreamInput) Configure ¶
func (i *CSVStreamInput) Configure() error
func (*CSVStreamInput) EntriesRead ¶
func (i *CSVStreamInput) EntriesRead() int64
func (*CSVStreamInput) Errors ¶
func (i *CSVStreamInput) Errors() *chan error
func (*CSVStreamInput) InputExists ¶
func (i *CSVStreamInput) InputExists() *bool
func (*CSVStreamInput) Loop ¶
func (i *CSVStreamInput) Loop(file io.Reader)
func (*CSVStreamInput) PushData ¶
func (i *CSVStreamInput) PushData(data interface{})
func (*CSVStreamInput) Run ¶
func (i *CSVStreamInput) Run(file io.Reader)
func (*CSVStreamInput) SetTable ¶
func (i *CSVStreamInput) SetTable(t tablestream.Table)
func (*CSVStreamInput) Table ¶
func (i *CSVStreamInput) Table() tablestream.Table
type Inputer ¶
type Inputer interface {
Configure() error
PushData(interface{})
Run(io.Reader)
InputExists() *bool
Table() tablestream.Table
SetTable(tablestream.Table)
Errors() *chan error
EntriesRead() int64
}
type StreamInput ¶
type StreamInput struct {
Inputer
// contains filtered or unexported fields
}
func (*StreamInput) Configure ¶
func (i *StreamInput) Configure() error
func (*StreamInput) EntriesRead ¶
func (i *StreamInput) EntriesRead() int64
func (*StreamInput) Errors ¶
func (i *StreamInput) Errors() *chan error
func (*StreamInput) InputExists ¶
func (i *StreamInput) InputExists() *bool
func (*StreamInput) Loop ¶
func (i *StreamInput) Loop(file io.Reader)
func (*StreamInput) PushData ¶
func (i *StreamInput) PushData(data interface{})
func (*StreamInput) Run ¶
func (i *StreamInput) Run(file io.Reader)
func (*StreamInput) SetTable ¶
func (i *StreamInput) SetTable(t tablestream.Table)
func (*StreamInput) Table ¶
func (i *StreamInput) Table() tablestream.Table
Source Files
Click to show internal directories.
Click to hide internal directories.