Documentation
¶
Index ¶
- type BatchHandler
- type Chunk
- type Client
- type PartitionType
- type TableChunkRepository
- func (repo *TableChunkRepository) CreateChunks(ctx context.Context, schema string, table string, structure *TableStructure, ...) ([]Chunk, error)
- func (repo *TableChunkRepository) CreateChunksForPartition(ctx context.Context, schema string, table string, partition TablePartition, ...) ([]Chunk, error)
- type TableColumn
- type TableDataFetcherRepository
- func (repo *TableDataFetcherRepository) FetchChunk(ctx context.Context, schema string, table string, structure *TableStructure, ...) error
- func (repo *TableDataFetcherRepository) FetchPartition(ctx context.Context, schema string, table string, partition TablePartition, ...) error
- func (repo *TableDataFetcherRepository) FetchPartitionChunk(ctx context.Context, schema string, table string, partition TablePartition, ...) error
- func (repo *TableDataFetcherRepository) FetchTable(ctx context.Context, schema string, table string, batchSize int, ...) error
- type TablePartition
- type TablePartitionRepository
- type TableStructure
- type TableStructureRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchHandler ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func Create ¶
func Create(config config.DatabaseConnectionConfig) *Client
type PartitionType ¶
type PartitionType = string
type TableChunkRepository ¶
type TableChunkRepository struct {
// contains filtered or unexported fields
}
func CreateTableChunkRepository ¶
func CreateTableChunkRepository(logger *zap.Logger, client *Client) *TableChunkRepository
func (*TableChunkRepository) CreateChunks ¶
func (repo *TableChunkRepository) CreateChunks(ctx context.Context, schema string, table string, structure *TableStructure, parallelism int) ([]Chunk, error)
func (*TableChunkRepository) CreateChunksForPartition ¶
func (repo *TableChunkRepository) CreateChunksForPartition(ctx context.Context, schema string, table string, partition TablePartition, structure *TableStructure, parallelism int) ([]Chunk, error)
type TableColumn ¶
type TableDataFetcherRepository ¶
type TableDataFetcherRepository struct {
// contains filtered or unexported fields
}
func CreateTableDataFetcherRepository ¶
func CreateTableDataFetcherRepository(logger *zap.Logger, client *Client) *TableDataFetcherRepository
func (*TableDataFetcherRepository) FetchChunk ¶
func (repo *TableDataFetcherRepository) FetchChunk(ctx context.Context, schema string, table string, structure *TableStructure, batchSize int, chunk Chunk, handler BatchHandler) error
func (*TableDataFetcherRepository) FetchPartition ¶
func (repo *TableDataFetcherRepository) FetchPartition(ctx context.Context, schema string, table string, partition TablePartition, batchSize int, handler BatchHandler) error
func (*TableDataFetcherRepository) FetchPartitionChunk ¶
func (repo *TableDataFetcherRepository) FetchPartitionChunk(ctx context.Context, schema string, table string, partition TablePartition, structure *TableStructure, batchSize int, chunk Chunk, handler BatchHandler) error
func (*TableDataFetcherRepository) FetchTable ¶
func (repo *TableDataFetcherRepository) FetchTable(ctx context.Context, schema string, table string, batchSize int, handler BatchHandler) error
type TablePartition ¶
type TablePartition struct {
ConstraintDefinition string
// contains filtered or unexported fields
}
func (TablePartition) String ¶
func (p TablePartition) String() string
type TablePartitionRepository ¶
type TablePartitionRepository struct {
// contains filtered or unexported fields
}
func CreateTablePartitionRepository ¶
func CreateTablePartitionRepository(logger *zap.Logger, client *Client) *TablePartitionRepository
func (*TablePartitionRepository) GetHypertablePartitions ¶
func (r *TablePartitionRepository) GetHypertablePartitions(ctx context.Context, schema string, table string) ([]TablePartition, error)
GetHypertablePartitions partitions == chunks
func (*TablePartitionRepository) GetTablePartitions ¶
func (r *TablePartitionRepository) GetTablePartitions(ctx context.Context, schema string, table string) ([]TablePartition, error)
type TableStructure ¶
type TableStructure struct {
Columns []TableColumn
PartitionColumn *TableColumn // optional
}
type TableStructureRepository ¶
type TableStructureRepository struct {
// contains filtered or unexported fields
}
func CreateTableStructureRepository ¶
func CreateTableStructureRepository(logger *zap.Logger, client *Client) *TableStructureRepository
func (*TableStructureRepository) ExtractTableStructure ¶
func (repo *TableStructureRepository) ExtractTableStructure(ctx context.Context, schema string, table string, partitionColumnName string) (*TableStructure, error)
Source Files
Click to show internal directories.
Click to hide internal directories.