Documentation ¶
Index ¶
- Constants
- Variables
- type Snowflake
- func (s *Snowflake) Close() error
- func (s *Snowflake) CreateStream(ctx context.Context, stream, table string) error
- func (s *Snowflake) CreateTrackingTable(ctx context.Context, trackingTable, table string) error
- func (s *Snowflake) GetData(ctx context.Context, table, key string, fields []string, offset, limit int) ([]map[string]interface{}, error)
- func (s *Snowflake) GetTrackingData(ctx context.Context, stream, trackingTable string, fields []string, ...) ([]map[string]interface{}, error)
Constants ¶
View Source
const ( MetadataColumnAction = "METADATA$ACTION" MetadataColumnUpdate = "METADATA$ISUPDATE" MetadataColumnRow = "METADATA$ROW_ID" MetadataColumnTime = "METADATA$TS" )
Variables ¶
View Source
var MetadataFields = []string{MetadataColumnAction, MetadataColumnUpdate, MetadataColumnTime}
Functions ¶
This section is empty.
Types ¶
type Snowflake ¶
type Snowflake struct {
// contains filtered or unexported fields
}
Snowflake repository.
func (*Snowflake) CreateStream ¶
CreateStream create stream.
func (*Snowflake) CreateTrackingTable ¶
CreateTrackingTable create stream.
Click to show internal directories.
Click to hide internal directories.