splitter

Documentation

Index

• type SplittedTableMetadata
• type Splitter
  • func BuildSplitter(ctx context.Context, storage postgresStorage, desiredTableSize uint64, ...) Splitter
• type TableFull
  • func NewTableFull(storage postgresStorage, desiredTableSize uint64, ...) *TableFull
  • func (t *TableFull) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)
• type TableIncrement
  • func NewTableIncrement(storage postgresStorage, desiredTableSize uint64, ...) *TableIncrement
  • func (t *TableIncrement) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)
• type View
  • func NewView(storage postgresStorage, snapshotDegreeOfParallelism int) *View
  • func (t *View) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)

Types

type SplittedTableMetadata

type SplittedTableMetadata struct {
	DataSizeInBytes uint64
	DataSizeInRows  uint64
	PartsCount      uint64
}

type Splitter

type Splitter interface {
	Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)
}

func BuildSplitter

func BuildSplitter(ctx context.Context, storage postgresStorage, desiredTableSize uint64, snapshotDegreeOfParallelism int, isView, hasDataFiltration bool) Splitter

type TableFull

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

func NewTableFull

func NewTableFull(storage postgresStorage, desiredTableSize uint64, snapshotDegreeOfParallelism int) *TableFull

func (*TableFull) Split

func (t *TableFull) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)

type TableIncrement

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

func NewTableIncrement

func NewTableIncrement(storage postgresStorage, desiredTableSize uint64, snapshotDegreeOfParallelism int) *TableIncrement

func (*TableIncrement) Split

func (t *TableIncrement) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)

type View

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

func NewView

func NewView(storage postgresStorage, snapshotDegreeOfParallelism int) *View

func (*View) Split

func (t *View) Split(ctx context.Context, table abstract.TableDescription) (*SplittedTableMetadata, error)