Versions in this module Expand all Collapse all v0 v0.1.1 Sep 17, 2024 Changes in this version + const DestinationConfigAuthBasicPassword + const DestinationConfigAuthBasicUsername + const DestinationConfigAuthMechanism + const DestinationConfigKeyspace + const DestinationConfigNodes + const DestinationConfigTable v0.1.0 Jun 14, 2024 Changes in this version + const AuthMechanismBasic + const AuthMechanismNone + var Connector = sdk.Connector + func NewDestination() sdk.Destination + func Specification() sdk.Specification + type Destination struct + func (d *Destination) Configure(ctx context.Context, cfg map[string]string) error + func (d *Destination) Open(ctx context.Context) error + func (d *Destination) Parameters() map[string]sdk.Parameter + func (d *Destination) Teardown(context.Context) error + func (d *Destination) Write(ctx context.Context, records []sdk.Record) (int, error) + type DestinationConfig struct + AuthMechanism string + AuthPassword string + AuthUsername string + Keyspace string + Nodes []string + Table string + func (DestinationConfig) Parameters() map[string]sdk.Parameter + type QueryBuilder struct + func (q *QueryBuilder) BuildDeleteQuery(rec sdk.Record, table string) (string, []interface{}) + func (q *QueryBuilder) BuildInsertQuery(rec sdk.Record, table string) (string, []interface{}) + func (q *QueryBuilder) BuildUpdateQuery(rec sdk.Record, table string) (string, []interface{})
Go to main page