mconfig

Documentation

Index

• Constants
• type KeySets
• type KeyValue
• type Param
  • func NewParams() *Param
  • func (s *Param) CheckHostAndTable() error
  • func (s *Param) CheckShardIndex() error
  • func (s *Param) CheckShardKey() error
  • func (s *Param) GetColumnFilter() (k []*KeySets, err error)
  • func (s *Param) GetKeyVal(key string) string
  • func (s *Param) Load(log *logrus.Logger) error

Constants

const (
	SOURCEDB              = "source.db"
	SOURCETABLE           = "source.table"
	TARGETDB              = "target.db"
	TARGETTABLE           = "target.table"
	PARALLEL              = "dml.parallel"
	CURSOR                = "dml.cursor.number"
	BATCH                 = "dml.insert.batch"
	TABLECOLUMNFILTER     = "table.column.filter"
	TABLEFINDWHERE        = "table.data.find"
	TABLEAGGREGATE        = "table.data.aggregate"
	TABLECOLUSTERSHARDING = "table.cluster.sharding"
	TABLESHARDKEY         = "table.shard.key"
	TABLESHARDINDEX       = "table.shard.index"
)

Types

type KeySets

type KeySets struct {
	Kes   string
	Value string
}

type KeyValue

type KeyValue struct {
	Value   string
	Default string
}

type Param

type Param struct {
	Keys map[string]*KeyValue
	// contains filtered or unexported fields
}

func NewParams

func NewParams() *Param

func (*Param) CheckHostAndTable

func (s *Param) CheckHostAndTable() error

func (*Param) CheckShardIndex

func (s *Param) CheckShardIndex() error

func (*Param) CheckShardKey

func (s *Param) CheckShardKey() error

func (*Param) GetColumnFilter

func (s *Param) GetColumnFilter() (k []*KeySets, err error)

func (*Param) GetKeyVal

func (s *Param) GetKeyVal(key string) string

func (*Param) Load

func (s *Param) Load(log *logrus.Logger) error