db_proto

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

type Sinker struct {
	*sink.Sinker
	// contains filtered or unexported fields
}

type SinkerFactoryClickhouse struct {
	SinkInfoFolder  string
	CursorFilePath  string
	QueryRetryCount int
	QueryRetrySleep time.Duration
}

type SinkerFactoryFunc func(ctx context.Context, dsnString, schemaName string, logger *zap.Logger, tracer logging.Tracer) (*Sinker, error)

type SinkerFactoryOptions struct {
	UseProtoOption bool
	// Constraints says which constraints the schema gets and when; the zero value means
	// all of them, created once the backfill is done.
	Constraints     protosql.ConstraintPolicy
	UseTransactions bool
	// WriteMode says how a sealed spool segment reaches the database. The zero value
	// resolves per driver and schema.
	WriteMode protosql.WriteMode
	// DecodeWorkers bounds how many blocks are unmarshalled and walked concurrently at
	// flush time. Zero picks one per core, less one, capped at 8.
	DecodeWorkers int
	// DecodeBatchSize is how many blocks are held in memory and decoded together. Zero
	// picks four per decode worker. It sizes the CPU stage, not the database write.
	DecodeBatchSize int
	Encoding        bytes.Encoding
	// Spool, when set, holds rows on disk and applies them from a background goroutine.
	Spool      *spool.Options
	Clickhouse SinkerFactoryClickhouse
}