redshift

Documentation

Index

• Constants
• type DB
  • func Open(option *types.RedshiftOpt) (*DB, error)
  • func (db *DB) CreateTable(ctx context.Context, opt offline.CreateTableOpt) error
  • func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (*types.ExportResult, error)
  • func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, error)
  • func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (*types.JoinResult, error)
  • func (db *DB) Ping(ctx context.Context) error
  • func (db *DB) Push(ctx context.Context, opt offline.PushOpt) error
  • func (db *DB) Snapshot(ctx context.Context, opt offline.SnapshotOpt) error
  • func (db *DB) TableSchema(ctx context.Context, opt offline.TableSchemaOpt) (*types.DataTableSchema, error)

Constants

const (
	Backend           = types.BackendRedshift
	RedshiftBatchSize = 20
)

Types

type DB

type DB struct {
	*sqlx.DB
}

func Open

func Open(option *types.RedshiftOpt) (*DB, error)

func (*DB) CreateTable

func (db *DB) CreateTable(ctx context.Context, opt offline.CreateTableOpt) error

func (*DB) Export

func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (*types.ExportResult, error)

func (*DB) Import

func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, error)

func (*DB) Join

func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (*types.JoinResult, error)

func (*DB) Ping

func (db *DB) Ping(ctx context.Context) error

func (*DB) Push

func (db *DB) Push(ctx context.Context, opt offline.PushOpt) error

func (*DB) Snapshot

func (db *DB) Snapshot(ctx context.Context, opt offline.SnapshotOpt) error

func (*DB) TableSchema

func (db *DB) TableSchema(ctx context.Context, opt offline.TableSchemaOpt) (*types.DataTableSchema, error)