sharder

Documentation

Index

• Constants
• type Config
• type SharderTransformer
  • func (f *SharderTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult
  • func (f *SharderTransformer) Description() string
  • func (f *SharderTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)
  • func (f *SharderTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool
  • func (f *SharderTransformer) Type() abstract.TransformerType

Constants

const Type = abstract.TransformerType("sharder_transformer")

Types

type Config

type Config struct {
	Columns     filter.Columns `json:"columns"`
	Tables      filter.Tables  `json:"tables"`
	ShardsCount string         `json:"shardsCount"`
}

type SharderTransformer

type SharderTransformer struct {
	Columns   filter.Filter
	Tables    filter.Filter
	ShardsNum int64
	Logger    log.Logger
}

func (*SharderTransformer) Apply

func (f *SharderTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult

func (*SharderTransformer) Description

func (f *SharderTransformer) Description() string

func (*SharderTransformer) ResultSchema

func (f *SharderTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)

func (*SharderTransformer) Suitable

func (f *SharderTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool

func (*SharderTransformer) Type

func (f *SharderTransformer) Type() abstract.TransformerType