database

Documentation

Index

• func BuildParams(config *data.StreamConfig) []interface{}
• type Batch
• type Column
  • func MapToMvrColumns(columns []*sql.ColumnType) []Column
• type DataStream
• type MSDataReader
  • func NewMSDataReader(connUrl *url.URL) (*MSDataReader, error)
  • func (reader *MSDataReader) Close() error
  • func (reader *MSDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (*DataStream, error)
  • func (reader *MSDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error
• type PGDataReader
  • func NewPGDataReader(connUrl *url.URL) (*PGDataReader, error)
  • func (pool *PGDataReader) Close() error
  • func (pool *PGDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)
  • func (pool *PGDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error
• type SnowflakeDataReader
  • func NewSnowflakeDataReader(connUrl *url.URL) (*SnowflakeDataReader, error)
  • func (sf *SnowflakeDataReader) Close() error
  • func (sf *SnowflakeDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)
  • func (sf *SnowflakeDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error

Functions

func BuildParams

func BuildParams(config *data.StreamConfig) []interface{}

Types

type Batch

type Batch = data.Batch

type Column

type Column = data.Column

func MapToMvrColumns

func MapToMvrColumns(columns []*sql.ColumnType) []Column

type DataStream

type DataStream = data.DataStream

type MSDataReader

type MSDataReader struct {
	Conn             *sql.DB
	KeepOriginalUUID bool
}

func NewMSDataReader

func NewMSDataReader(connUrl *url.URL) (*MSDataReader, error)

func (*MSDataReader) Close

func (reader *MSDataReader) Close() error

func (*MSDataReader) CreateDataStream

func (reader *MSDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (*DataStream, error)

func (*MSDataReader) ExecuteDataStream

func (reader *MSDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error

type PGDataReader

type PGDataReader struct {
	Pool *pgxpool.Pool
}

func NewPGDataReader

func NewPGDataReader(connUrl *url.URL) (*PGDataReader, error)

func (*PGDataReader) Close

func (pool *PGDataReader) Close() error

func (*PGDataReader) CreateDataStream

func (pool *PGDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)

func (*PGDataReader) ExecuteDataStream

func (pool *PGDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error

type SnowflakeDataReader

type SnowflakeDataReader struct {
	Snowflake *sql.DB
}

func NewSnowflakeDataReader

func NewSnowflakeDataReader(connUrl *url.URL) (*SnowflakeDataReader, error)

func (*SnowflakeDataReader) Close

func (sf *SnowflakeDataReader) Close() error

func (*SnowflakeDataReader) CreateDataStream

func (sf *SnowflakeDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)

func (*SnowflakeDataReader) ExecuteDataStream

func (sf *SnowflakeDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error