Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + var DefaultTableConfig = common.TableConfig type SchemaFetchJob + func (j *SchemaFetchJob) FetchEnum() + func (j *SchemaFetchJob) FetchSchema() v0.0.1 Nov 27, 2018 Changes in this version + const DefaultArchivingDelayMinutes + const DefaultArchivingIntervalMinutes + const DefaultBackfillIntervalMinutes + const DefaultBackfillMaxBufferSize + const DefaultBackfillStoreBatchSize + const DefaultBackfillThresholdInBytes + const DefaultBatchSize + const DefaultMaxRedoLogSize + const DefaultRecordRetentionInDays + const DefaultRedologRotationInterval + const DefaultSnapshotIntervalMinutes + const DefaultSnapshotThreshold + var ErrAllColumnsInvalid = errors.New("All columns are invalid") + var ErrChangePrimaryKeyColumn = errors.New("Primary key column cannot be changed") + var ErrColumnAlreadyDeleted = errors.New("Column already deleted") + var ErrColumnAlreadyExist = errors.New("Column already exists") + var ErrColumnDeleted = errors.New("Column already deleted") + var ErrColumnDoesNotExist = errors.New("Column does not exist") + var ErrColumnNonExist = errors.New("Column does not exist") + var ErrDeletePrimaryKeyColumn = errors.New("Primary key column cannot be deleted") + var ErrDeleteTimeColumn = errors.New("Time column cannot be deleted") + var ErrDisallowMissingEventTime = errors.New("Can not disallow missing event time") + var ErrDuplicatedColumn = errors.New("Illegal deplicated use of column") + var ErrDuplicatedColumnName = errors.New("Duplicated column name found") + var ErrIllegalChangeSortColumn = errors.New("Illegal changes on sort columns") + var ErrIllegalSchemaVersion = errors.New("New schema version not greater than old") + var ErrInsufficientColumnCount = errors.New("Insufficient column count") + var ErrInvalidDataType = errors.New("Invalid data type") + var ErrMissingPrimaryKey = errors.New("Primary key columns not specified") + var ErrNewColumnWithDeletion = errors.New("Can not add column with deleted flag on") + var ErrNotDimensionTable = errors.New("Table is not dimension table") + var ErrNotEnumColumn = errors.New("Column is not enum type") + var ErrNotFactTable = errors.New("Table is not fact table") + var ErrReusingColumnIDNotAllowed = errors.New("Reusing column id not allowed") + var ErrSchemaUpdateNotAllowed = errors.New("Illegal schame update on immutable field") + var ErrShardDoesNotExist = errors.New("Shard does not exist") + var ErrTableAlreadyExist = errors.New("Table already exists") + var ErrTableDoesNotExist = errors.New("Table does not exist") + var ErrTimeColumnDoesNotAllowDefault = errors.New("Time column does not allow default value") + var ErrWatcherAlreadyExist = errors.New("Watcher already registered") + func ValidateDefaultValue(valueStr, dataTypeStr string) (err error) + type MetaStore interface + AddArchiveBatchVersion func(table string, shard, batchID int, version uint32, seqNum uint32, batchSize int) error + ExtendEnumDict func(table, column string, enumCases []string) ([]int, error) + GetArchiveBatchVersion func(table string, shard, batchID int, cutoff uint32) (uint32, uint32, int, error) + GetArchivingCutoff func(table string, shard int) (uint32, error) + GetBackfillProgressInfo func(table string, shard int) (int64, uint32, error) + GetEnumDict func(table, column string) ([]string, error) + GetOwnedShards func(table string) ([]int, error) + GetSnapshotProgress func(table string, shard int) (int64, uint32, int32, uint32, error) + PurgeArchiveBatches func(table string, shard, batchIDStart, batchIDEnd int) error + UpdateArchivingCutoff func(table string, shard int, cutoff uint32) error + UpdateBackfillProgress func(table string, shard int, redoLogFile int64, offset uint32) error + UpdateSnapshotProgress func(table string, shard int, redoLogFile int64, upsertBatchOffset uint32, ...) error + WatchEnumDictEvents func(table, column string, startCase int) (events <-chan string, done chan<- struct{}, err error) + WatchShardOwnershipEvents func() (events <-chan common.ShardOwnership, done chan<- struct{}, err error) + func NewDiskMetaStore(basePath string) (MetaStore, error) + type SchemaFetchJob struct + func NewSchemaFetchJob(intervalInSeconds int, schemaMutator TableSchemaMutator, ...) *SchemaFetchJob + func (j *SchemaFetchJob) Run() + func (j *SchemaFetchJob) Stop() + type TableSchemaMutator interface + AddColumn func(table string, column common.Column, appendToArchivingSortOrder bool) error + CreateTable func(table *common.Table) error + DeleteColumn func(table string, column string) error + DeleteTable func(name string) error + UpdateColumn func(table string, column string, config common.ColumnConfig) error + UpdateTable func(table common.Table) error + UpdateTableConfig func(table string, config common.TableConfig) error + type TableSchemaReader interface + GetTable func(name string) (*common.Table, error) + ListTables func() ([]string, error) + type TableSchemaValidator interface + SetNewTable func(table common.Table) + SetOldTable func(table common.Table) + Validate func() error + func NewTableSchameValidator() TableSchemaValidator + type TableSchemaWatchable interface + WatchTableListEvents func() (events <-chan []string, done chan<- struct{}, err error) + WatchTableSchemaEvents func() (events <-chan *common.Table, done chan<- struct{}, err error)