async

Documentation

Index

• Constants
• func NewCHV2Marshaller(schema []abstract.ColSchema, cols columntypes.TypeMapping) db.ChangeItemMarshaller
• func NewPart(partID abstract.TablePartID, dbName string, cl ClusterClient, dao *dao.DDLDAO, ...) parts.Part
• func NewSink(transfer *dp_model.Transfer, dst *model.ChDestination, lgr log.Logger, ...) (abstract.AsyncSink, error)
• type BlockMarshallingError
  • func (e BlockMarshallingError) Code() coded.Code
  • func (e BlockMarshallingError) Error() string
  • func (e BlockMarshallingError) IsMarshallingError()
  • func (e BlockMarshallingError) Unwrap() error
• type ClusterClient
  • func NewClusterClient(conn conn.ConnParams, topology *topology2.Topology, ...) (ClusterClient, error)
• type DDLStreamingClient
  • func NewHostClient(opts *clickhouse.Options, lgr log.Logger) (DDLStreamingClient, error)
• type MiddlewareApplier
  • func NewMiddlewareApplier(mw abstract.Middleware) MiddlewareApplier
• type ShardClient
  • func NewShardClient(hosts []string, cp conn.ConnParams, topology *topology2.Topology, ...) (ShardClient, error)

Constants

const TMPPrefix = "dt_tmp_part"

Functions

func NewCHV2Marshaller

func NewCHV2Marshaller(schema []abstract.ColSchema, cols columntypes.TypeMapping) db.ChangeItemMarshaller

func NewPart

func NewPart(
	partID abstract.TablePartID, dbName string, cl ClusterClient, dao *dao.DDLDAO,
	sharder sharding.Sharder, lgr log.Logger, transferID string,
) parts.Part

func NewSink

func NewSink(
	transfer *dp_model.Transfer, dst *model.ChDestination, lgr log.Logger, mtrcs metrics.Registry, mw abstract.Middleware,
) (abstract.AsyncSink, error)

Types

type BlockMarshallingError

type BlockMarshallingError struct {
	// contains filtered or unexported fields
}

BlockMarshallingError is a wrapper for clickhouse-go/v2 *proto.BlockError *proto.BlockError occurs if the driver failed to build clickhouse native proto block. Usually it happens due to incorrect input types or values

func (BlockMarshallingError) Code

func (e BlockMarshallingError) Code() coded.Code

func (BlockMarshallingError) Error

func (e BlockMarshallingError) Error() string

func (BlockMarshallingError) IsMarshallingError

func (e BlockMarshallingError) IsMarshallingError()

func (BlockMarshallingError) Unwrap

func (e BlockMarshallingError) Unwrap() error

type ClusterClient

type ClusterClient interface {
	db_model.Client
	db_model.DDLExecutor
	sharding.Shards[ShardClient]
	io.Closer
}

func NewClusterClient

func NewClusterClient(conn conn.ConnParams, topology *topology2.Topology, shards sharding.ShardMap[[]string], lgr log.Logger) (ClusterClient, error)

type DDLStreamingClient

type DDLStreamingClient interface {
	db_model.Client
	db_model.DDLExecutor
	db_model.StreamInserter
	io.Closer
}

func NewHostClient

func NewHostClient(opts *clickhouse.Options, lgr log.Logger) (DDLStreamingClient, error)

type MiddlewareApplier

type MiddlewareApplier interface {
	io.Closer
	Apply([]abstract.ChangeItem) ([]abstract.ChangeItem, error)
}

func NewMiddlewareApplier

func NewMiddlewareApplier(mw abstract.Middleware) MiddlewareApplier

type ShardClient

type ShardClient interface {
	db_model.Client
	db_model.DDLExecutor
	AliveHost() (DDLStreamingClient, error)
	io.Closer
}

func NewShardClient

func NewShardClient(hosts []string, cp conn.ConnParams, topology *topology2.Topology, lgr log.Logger) (ShardClient, error)