Documentation
¶
Index ¶
- type ColumnDef
- type DBCommand
- type DatabaseInfo
- type RecordDef
- type Writer
- func (writer *Writer) DeleteRecord(record *transmitter.Record) error
- func (writer *Writer) GetDefinition(record *transmitter.Record) *RecordDef
- func (writer *Writer) GetValue(value *transmitter.Value) interface{}
- func (writer *Writer) Init() error
- func (writer *Writer) InsertRecord(record *transmitter.Record) error
- func (writer *Writer) ProcessData(record *transmitter.Record) error
- func (writer *Writer) Truncate(table string) error
- func (writer *Writer) UpdateRecord(record *transmitter.Record) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabaseInfo ¶
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) DeleteRecord ¶
func (writer *Writer) DeleteRecord(record *transmitter.Record) error
func (*Writer) GetDefinition ¶
func (writer *Writer) GetDefinition(record *transmitter.Record) *RecordDef
func (*Writer) GetValue ¶
func (writer *Writer) GetValue(value *transmitter.Value) interface{}
func (*Writer) InsertRecord ¶
func (writer *Writer) InsertRecord(record *transmitter.Record) error
func (*Writer) ProcessData ¶
func (writer *Writer) ProcessData(record *transmitter.Record) error
func (*Writer) UpdateRecord ¶
func (writer *Writer) UpdateRecord(record *transmitter.Record) error
Click to show internal directories.
Click to hide internal directories.