Documentation
¶
Index ¶
- type TimescaleDBDestination
- func (d *TimescaleDBDestination) Close() error
- func (d *TimescaleDBDestination) CreateSchema() ([]string, error)
- func (d *TimescaleDBDestination) Init(config map[string]interface{}, model *models.Model) error
- func (d *TimescaleDBDestination) InsertQuery() string
- func (d *TimescaleDBDestination) RunSchema() error
- func (d *TimescaleDBDestination) StoreData(data []map[string]interface{}) (int, int, error)
- func (d *TimescaleDBDestination) StoreDataBatch(data []map[string]interface{}) (int, int, error)
- func (d *TimescaleDBDestination) StoreDataSingle(data []map[string]interface{}) (int, int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TimescaleDBDestination ¶
type TimescaleDBDestination struct {
Model *models.Model
DB *sql.DB
Table string
Schema map[string]string // Column types
BatchSize int
}
func (*TimescaleDBDestination) Close ¶
func (d *TimescaleDBDestination) Close() error
func (*TimescaleDBDestination) CreateSchema ¶
func (d *TimescaleDBDestination) CreateSchema() ([]string, error)
func (*TimescaleDBDestination) Init ¶
func (d *TimescaleDBDestination) Init(config map[string]interface{}, model *models.Model) error
func (*TimescaleDBDestination) InsertQuery ¶
func (d *TimescaleDBDestination) InsertQuery() string
func (*TimescaleDBDestination) RunSchema ¶
func (d *TimescaleDBDestination) RunSchema() error
func (*TimescaleDBDestination) StoreData ¶
func (d *TimescaleDBDestination) StoreData(data []map[string]interface{}) (int, int, error)
func (*TimescaleDBDestination) StoreDataBatch ¶
func (d *TimescaleDBDestination) StoreDataBatch(data []map[string]interface{}) (int, int, error)
func (*TimescaleDBDestination) StoreDataSingle ¶
func (d *TimescaleDBDestination) StoreDataSingle(data []map[string]interface{}) (int, int, error)
Source Files
Click to show internal directories.
Click to hide internal directories.