Versions in this module Expand all Collapse all v0 v0.0.1 Nov 27, 2018 Changes in this version + type MetaStore struct + func (_m *MetaStore) AddArchiveBatchVersion(table string, shard int, batchID int, version uint32, seqNum uint32, ...) error + func (_m *MetaStore) AddColumn(table string, column common.Column, appendToArchivingSortOrder bool) error + func (_m *MetaStore) CreateTable(table *common.Table) error + func (_m *MetaStore) DeleteColumn(table string, column string) error + func (_m *MetaStore) DeleteTable(name string) error + func (_m *MetaStore) ExtendEnumDict(table string, column string, enumCases []string) ([]int, error) + func (_m *MetaStore) GetArchiveBatchVersion(table string, shard int, batchID int, cutoff uint32) (uint32, uint32, int, error) + func (_m *MetaStore) GetArchivingCutoff(table string, shard int) (uint32, error) + func (_m *MetaStore) GetBackfillProgressInfo(table string, shard int) (int64, uint32, error) + func (_m *MetaStore) GetEnumDict(table string, column string) ([]string, error) + func (_m *MetaStore) GetOwnedShards(table string) ([]int, error) + func (_m *MetaStore) GetSnapshotProgress(table string, shard int) (int64, uint32, int32, uint32, error) + func (_m *MetaStore) GetTable(name string) (*common.Table, error) + func (_m *MetaStore) ListTables() ([]string, error) + func (_m *MetaStore) PurgeArchiveBatches(table string, shard int, batchIDStart int, batchIDEnd int) error + func (_m *MetaStore) UpdateArchivingCutoff(table string, shard int, cutoff uint32) error + func (_m *MetaStore) UpdateBackfillProgress(table string, shard int, redoLogFile int64, offset uint32) error + func (_m *MetaStore) UpdateColumn(table string, column string, config common.ColumnConfig) error + func (_m *MetaStore) UpdateSnapshotProgress(table string, shard int, redoLogFile int64, upsertBatchOffset uint32, ...) error + func (_m *MetaStore) UpdateTable(table common.Table) error + func (_m *MetaStore) UpdateTableConfig(table string, config common.TableConfig) error + func (_m *MetaStore) WatchEnumDictEvents(table string, column string, startCase int) (<-chan string, chan<- struct{}, error) + func (_m *MetaStore) WatchShardOwnershipEvents() (<-chan common.ShardOwnership, chan<- struct{}, error) + func (_m *MetaStore) WatchTableListEvents() (<-chan []string, chan<- struct{}, error) + func (_m *MetaStore) WatchTableSchemaEvents() (<-chan *common.Table, chan<- struct{}, error) + type TableSchemaMutator struct + func (_m *TableSchemaMutator) AddColumn(table string, column common.Column, appendToArchivingSortOrder bool) error + func (_m *TableSchemaMutator) CreateTable(table *common.Table) error + func (_m *TableSchemaMutator) DeleteColumn(table string, column string) error + func (_m *TableSchemaMutator) DeleteTable(name string) error + func (_m *TableSchemaMutator) GetTable(name string) (*common.Table, error) + func (_m *TableSchemaMutator) ListTables() ([]string, error) + func (_m *TableSchemaMutator) UpdateColumn(table string, column string, config common.ColumnConfig) error + func (_m *TableSchemaMutator) UpdateTable(table common.Table) error + func (_m *TableSchemaMutator) UpdateTableConfig(table string, config common.TableConfig) error + type TableSchemaReader struct + func (_m *TableSchemaReader) GetTable(name string) (*common.Table, error) + func (_m *TableSchemaReader) ListTables() ([]string, error) + type TableSchemaValidator struct + func (_m *TableSchemaValidator) SetNewTable(table common.Table) + func (_m *TableSchemaValidator) SetOldTable(table common.Table) + func (_m *TableSchemaValidator) Validate() error + type TableSchemaWatchable struct + func (_m *TableSchemaWatchable) WatchTableListEvents() (<-chan []string, chan<- struct{}, error) + func (_m *TableSchemaWatchable) WatchTableSchemaEvents() (<-chan *common.Table, chan<- struct{}, error)