mocks

Documentation

Overview

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Index

• type MetaStore
  • 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
  • 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
  • func (_m *TableSchemaReader) GetTable(name string) (*common.Table, error)
  • func (_m *TableSchemaReader) ListTables() ([]string, error)
• type TableSchemaValidator
  • func (_m *TableSchemaValidator) SetNewTable(table common.Table)
  • func (_m *TableSchemaValidator) SetOldTable(table common.Table)
  • func (_m *TableSchemaValidator) Validate() error
• type TableSchemaWatchable
  • func (_m *TableSchemaWatchable) WatchTableListEvents() (<-chan []string, chan<- struct{}, error)
  • func (_m *TableSchemaWatchable) WatchTableSchemaEvents() (<-chan *common.Table, chan<- struct{}, error)

Types

type MetaStore

type MetaStore struct {
	mock.Mock
}

MetaStore is an autogenerated mock type for the MetaStore type

func (*MetaStore) AddArchiveBatchVersion

func (_m *MetaStore) AddArchiveBatchVersion(table string, shard int, batchID int, version uint32, seqNum uint32, batchSize int) error

AddArchiveBatchVersion provides a mock function with given fields: table, shard, batchID, version, seqNum, batchSize

func (*MetaStore) AddColumn

func (_m *MetaStore) AddColumn(table string, column common.Column, appendToArchivingSortOrder bool) error

AddColumn provides a mock function with given fields: table, column, appendToArchivingSortOrder

func (*MetaStore) CreateTable

func (_m *MetaStore) CreateTable(table *common.Table) error

CreateTable provides a mock function with given fields: table

func (*MetaStore) DeleteColumn

func (_m *MetaStore) DeleteColumn(table string, column string) error

DeleteColumn provides a mock function with given fields: table, column

func (*MetaStore) DeleteTable

func (_m *MetaStore) DeleteTable(name string) error

DeleteTable provides a mock function with given fields: name

func (*MetaStore) ExtendEnumDict

func (_m *MetaStore) ExtendEnumDict(table string, column string, enumCases []string) ([]int, error)

ExtendEnumDict provides a mock function with given fields: table, column, enumCases

func (*MetaStore) GetArchiveBatchVersion

func (_m *MetaStore) GetArchiveBatchVersion(table string, shard int, batchID int, cutoff uint32) (uint32, uint32, int, error)

GetArchiveBatchVersion provides a mock function with given fields: table, shard, batchID, cutoff

func (*MetaStore) GetArchivingCutoff

func (_m *MetaStore) GetArchivingCutoff(table string, shard int) (uint32, error)

GetArchivingCutoff provides a mock function with given fields: table, shard

func (*MetaStore) GetBackfillProgressInfo

func (_m *MetaStore) GetBackfillProgressInfo(table string, shard int) (int64, uint32, error)

GetBackfillProgressInfo provides a mock function with given fields: table, shard

func (*MetaStore) GetEnumDict

func (_m *MetaStore) GetEnumDict(table string, column string) ([]string, error)

GetEnumDict provides a mock function with given fields: table, column

func (*MetaStore) GetOwnedShards

func (_m *MetaStore) GetOwnedShards(table string) ([]int, error)

GetOwnedShards provides a mock function with given fields: table

func (*MetaStore) GetSnapshotProgress

func (_m *MetaStore) GetSnapshotProgress(table string, shard int) (int64, uint32, int32, uint32, error)

GetSnapshotProgress provides a mock function with given fields: table, shard

func (*MetaStore) GetTable

func (_m *MetaStore) GetTable(name string) (*common.Table, error)

GetTable provides a mock function with given fields: name

func (*MetaStore) ListTables

func (_m *MetaStore) ListTables() ([]string, error)

ListTables provides a mock function with given fields:

func (*MetaStore) PurgeArchiveBatches

func (_m *MetaStore) PurgeArchiveBatches(table string, shard int, batchIDStart int, batchIDEnd int) error

PurgeArchiveBatches provides a mock function with given fields: table, shard, batchIDStart, batchIDEnd

func (*MetaStore) UpdateArchivingCutoff

func (_m *MetaStore) UpdateArchivingCutoff(table string, shard int, cutoff uint32) error

UpdateArchivingCutoff provides a mock function with given fields: table, shard, cutoff

func (*MetaStore) UpdateBackfillProgress

func (_m *MetaStore) UpdateBackfillProgress(table string, shard int, redoLogFile int64, offset uint32) error

UpdateBackfillProgress provides a mock function with given fields: table, shard, redoLogFile, offset

func (*MetaStore) UpdateColumn

func (_m *MetaStore) UpdateColumn(table string, column string, config common.ColumnConfig) error

UpdateColumn provides a mock function with given fields: table, column, config

func (*MetaStore) UpdateSnapshotProgress

func (_m *MetaStore) UpdateSnapshotProgress(table string, shard int, redoLogFile int64, upsertBatchOffset uint32, lastReadBatchID int32, lastReadBatchOffset uint32) error

UpdateSnapshotProgress provides a mock function with given fields: table, shard, redoLogFile, upsertBatchOffset, lastReadBatchID, lastReadBatchOffset

func (*MetaStore) UpdateTable

func (_m *MetaStore) UpdateTable(table common.Table) error

UpdateTable provides a mock function with given fields: table

func (*MetaStore) UpdateTableConfig

func (_m *MetaStore) UpdateTableConfig(table string, config common.TableConfig) error

UpdateTableConfig provides a mock function with given fields: table, config

func (*MetaStore) WatchEnumDictEvents

func (_m *MetaStore) WatchEnumDictEvents(table string, column string, startCase int) (<-chan string, chan<- struct{}, error)

WatchEnumDictEvents provides a mock function with given fields: table, column, startCase

func (*MetaStore) WatchShardOwnershipEvents

func (_m *MetaStore) WatchShardOwnershipEvents() (<-chan common.ShardOwnership, chan<- struct{}, error)

WatchShardOwnershipEvents provides a mock function with given fields:

func (*MetaStore) WatchTableListEvents

func (_m *MetaStore) WatchTableListEvents() (<-chan []string, chan<- struct{}, error)

WatchTableListEvents provides a mock function with given fields:

func (*MetaStore) WatchTableSchemaEvents

func (_m *MetaStore) WatchTableSchemaEvents() (<-chan *common.Table, chan<- struct{}, error)

WatchTableSchemaEvents provides a mock function with given fields:

type TableSchemaMutator

type TableSchemaMutator struct {
	mock.Mock
}

TableSchemaMutator is an autogenerated mock type for the TableSchemaMutator type

func (*TableSchemaMutator) AddColumn

func (_m *TableSchemaMutator) AddColumn(table string, column common.Column, appendToArchivingSortOrder bool) error

AddColumn provides a mock function with given fields: table, column, appendToArchivingSortOrder

func (*TableSchemaMutator) CreateTable

func (_m *TableSchemaMutator) CreateTable(table *common.Table) error

CreateTable provides a mock function with given fields: table

func (*TableSchemaMutator) DeleteColumn

func (_m *TableSchemaMutator) DeleteColumn(table string, column string) error

DeleteColumn provides a mock function with given fields: table, column

func (*TableSchemaMutator) DeleteTable

func (_m *TableSchemaMutator) DeleteTable(name string) error

DeleteTable provides a mock function with given fields: name

func (*TableSchemaMutator) GetTable

func (_m *TableSchemaMutator) GetTable(name string) (*common.Table, error)

GetTable provides a mock function with given fields: name

func (*TableSchemaMutator) ListTables

func (_m *TableSchemaMutator) ListTables() ([]string, error)

ListTables provides a mock function with given fields:

func (*TableSchemaMutator) UpdateColumn

func (_m *TableSchemaMutator) UpdateColumn(table string, column string, config common.ColumnConfig) error

UpdateColumn provides a mock function with given fields: table, column, config

func (*TableSchemaMutator) UpdateTable

func (_m *TableSchemaMutator) UpdateTable(table common.Table) error

UpdateTable provides a mock function with given fields: table

func (*TableSchemaMutator) UpdateTableConfig

func (_m *TableSchemaMutator) UpdateTableConfig(table string, config common.TableConfig) error

UpdateTableConfig provides a mock function with given fields: table, config

type TableSchemaReader

type TableSchemaReader struct {
	mock.Mock
}

TableSchemaReader is an autogenerated mock type for the TableSchemaReader type

func (*TableSchemaReader) GetTable

func (_m *TableSchemaReader) GetTable(name string) (*common.Table, error)

GetTable provides a mock function with given fields: name

func (*TableSchemaReader) ListTables

func (_m *TableSchemaReader) ListTables() ([]string, error)

ListTables provides a mock function with given fields:

type TableSchemaValidator

type TableSchemaValidator struct {
	mock.Mock
}

TableSchemaValidator is an autogenerated mock type for the TableSchemaValidator type

func (*TableSchemaValidator) SetNewTable

func (_m *TableSchemaValidator) SetNewTable(table common.Table)

SetNewTable provides a mock function with given fields: table

func (*TableSchemaValidator) SetOldTable

func (_m *TableSchemaValidator) SetOldTable(table common.Table)

SetOldTable provides a mock function with given fields: table

func (*TableSchemaValidator) Validate

func (_m *TableSchemaValidator) Validate() error

Validate provides a mock function with given fields:

type TableSchemaWatchable

type TableSchemaWatchable struct {
	mock.Mock
}

TableSchemaWatchable is an autogenerated mock type for the TableSchemaWatchable type

func (*TableSchemaWatchable) WatchTableListEvents

func (_m *TableSchemaWatchable) WatchTableListEvents() (<-chan []string, chan<- struct{}, error)

WatchTableListEvents provides a mock function with given fields:

func (*TableSchemaWatchable) WatchTableSchemaEvents

func (_m *TableSchemaWatchable) WatchTableSchemaEvents() (<-chan *common.Table, chan<- struct{}, error)

WatchTableSchemaEvents provides a mock function with given fields: