mocks

Documentation

Index

• type RedologManager
  • func (_m *RedologManager) AppendToRedoLog(upsertBatch *common.UpsertBatch) (int64, uint32)
  • func (_m *RedologManager) CheckpointRedolog(cutoff uint32, redoFileCheckpointed int64, batchOffset uint32) error
  • func (_m *RedologManager) Close()
  • func (_m *RedologManager) GetBatchReceived() int
  • func (_m *RedologManager) GetBatchRecovered() int
  • func (_m *RedologManager) GetNumFiles() int
  • func (_m *RedologManager) GetTotalSize() int
  • func (_m *RedologManager) IsAppendEnabled() bool
  • func (_m *RedologManager) Iterator() (redolog.NextUpsertFunc, error)
  • func (_m *RedologManager) UpdateMaxEventTime(eventTime uint32, redoFile int64)
  • func (_m *RedologManager) WaitForRecoveryDone()

Types

type RedologManager

type RedologManager struct {
	mock.Mock
}

RedologManager is an autogenerated mock type for the RedologManager type

func (*RedologManager) AppendToRedoLog

func (_m *RedologManager) AppendToRedoLog(upsertBatch *common.UpsertBatch) (int64, uint32)

AppendToRedoLog provides a mock function with given fields: upsertBatch

func (*RedologManager) CheckpointRedolog

func (_m *RedologManager) CheckpointRedolog(cutoff uint32, redoFileCheckpointed int64, batchOffset uint32) error

CheckpointRedolog provides a mock function with given fields: cutoff, redoFileCheckpointed, batchOffset

func (*RedologManager) Close

func (_m *RedologManager) Close()

Close provides a mock function with given fields:

func (*RedologManager) GetBatchReceived

func (_m *RedologManager) GetBatchReceived() int

GetBatchReceived provides a mock function with given fields:

func (*RedologManager) GetBatchRecovered

func (_m *RedologManager) GetBatchRecovered() int

GetBatchRecovered provides a mock function with given fields:

func (*RedologManager) GetNumFiles

func (_m *RedologManager) GetNumFiles() int

GetNumFiles provides a mock function with given fields:

func (*RedologManager) GetTotalSize

func (_m *RedologManager) GetTotalSize() int

GetTotalSize provides a mock function with given fields:

func (*RedologManager) IsAppendEnabled

func (_m *RedologManager) IsAppendEnabled() bool

IsAppendEnabled provides a mock function with given fields:

func (*RedologManager) Iterator

func (_m *RedologManager) Iterator() (redolog.NextUpsertFunc, error)

Iterator provides a mock function with given fields:

func (*RedologManager) UpdateMaxEventTime

func (_m *RedologManager) UpdateMaxEventTime(eventTime uint32, redoFile int64)

UpdateMaxEventTime provides a mock function with given fields: eventTime, redoFile

func (*RedologManager) WaitForRecoveryDone

func (_m *RedologManager) WaitForRecoveryDone()

WaitForRecoveryDone provides a mock function with given fields: