Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClickHouseIngester ¶
type ClickHouseIngester struct {
// contains filtered or unexported fields
}
func NewClickHouseIngester ¶
func NewClickHouseIngester(db *sql.DB, table string) (*ClickHouseIngester, error)
func (*ClickHouseIngester) Close ¶
func (ci *ClickHouseIngester) Close() error
func (*ClickHouseIngester) Get ¶
func (ci *ClickHouseIngester) Get() ([]map[string]interface{}, error)
func (*ClickHouseIngester) Ingest ¶
func (ci *ClickHouseIngester) Ingest(data map[string]interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.