mocks

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 27, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchReader 

type BatchReader struct {
	mock.Mock
}

BatchReader is an autogenerated mock type for the BatchReader type

func (*BatchReader) GetDataValue 

func (_m *BatchReader) GetDataValue(row int, columnID int) common.DataValue

GetDataValue provides a mock function with given fields: row, columnID

func (*BatchReader) GetDataValueWithDefault 

func (_m *BatchReader) GetDataValueWithDefault(row int, columnID int, defaultValue common.DataValue) common.DataValue

GetDataValueWithDefault provides a mock function with given fields: row, columnID, defaultValue

type Job 

type Job struct {
	mock.Mock
}

Job is an autogenerated mock type for the Job type

func (*Job) GetIdentifier 

func (_m *Job) GetIdentifier() string

GetIdentifier provides a mock function with given fields:

func (*Job) Run 

func (_m *Job) Run() error

Run provides a mock function with given fields:

func (*Job) String 

func (_m *Job) String() string

String provides a mock function with given fields:

type MemStore 

type MemStore struct {
	mock.Mock
}

MemStore is an autogenerated mock type for the MemStore type

func (*MemStore) Archive 

func (_m *MemStore) Archive(table string, shardID int, cutoff uint32, reporter memstore.ArchiveJobDetailReporter) error

Archive provides a mock function with given fields: table, shardID, cutoff, reporter

func (*MemStore) Backfill 

func (_m *MemStore) Backfill(table string, shardID int, reporter memstore.BackfillJobDetailReporter) error

Backfill provides a mock function with given fields: table, shardID, reporter

func (*MemStore) FetchSchema 

func (_m *MemStore) FetchSchema() error

FetchSchema provides a mock function with given fields:

func (*MemStore) GetMemoryUsageDetails 

func (_m *MemStore) GetMemoryUsageDetails() (map[string]memstore.TableShardMemoryUsage, error)

GetMemoryUsageDetails provides a mock function with given fields:

func (*MemStore) GetScheduler 

func (_m *MemStore) GetScheduler() memstore.Scheduler

GetScheduler provides a mock function with given fields:

func (*MemStore) GetSchema 

func (_m *MemStore) GetSchema(table string) (*memstore.TableSchema, error)

GetSchema provides a mock function with given fields: table

func (*MemStore) GetSchemas 

func (_m *MemStore) GetSchemas() map[string]*memstore.TableSchema

GetSchemas provides a mock function with given fields:

func (*MemStore) GetTableShard 

func (_m *MemStore) GetTableShard(table string, shardID int) (*memstore.TableShard, error)

GetTableShard provides a mock function with given fields: table, shardID

func (*MemStore) HandleIngestion 

func (_m *MemStore) HandleIngestion(table string, shardID int, upsertBatch *memstore.UpsertBatch) error

HandleIngestion provides a mock function with given fields: table, shardID, upsertBatch

func (*MemStore) InitShards 

func (_m *MemStore) InitShards(schedulerOff bool)

InitShards provides a mock function with given fields: schedulerOff

func (*MemStore) Lock 

func (_m *MemStore) Lock()

Lock provides a mock function with given fields:

func (*MemStore) Purge 

func (_m *MemStore) Purge(table string, shardID int, batchIDStart int, batchIDEnd int, reporter memstore.PurgeJobDetailReporter) error

Purge provides a mock function with given fields: table, shardID, batchIDStart, batchIDEnd, reporter

func (*MemStore) RLock 

func (_m *MemStore) RLock()

RLock provides a mock function with given fields:

func (*MemStore) RUnlock 

func (_m *MemStore) RUnlock()

RUnlock provides a mock function with given fields:

func (*MemStore) Snapshot 

func (_m *MemStore) Snapshot(table string, shardID int, reporter memstore.SnapshotJobDetailReporter) error

Snapshot provides a mock function with given fields: table, shardID, reporter

func (*MemStore) Unlock 

func (_m *MemStore) Unlock()

Unlock provides a mock function with given fields:

type PrimaryKey 

type PrimaryKey struct {
	mock.Mock
}

PrimaryKey is an autogenerated mock type for the PrimaryKey type

func (*PrimaryKey) AllocatedBytes 

func (_m *PrimaryKey) AllocatedBytes() uint

AllocatedBytes provides a mock function with given fields:

func (*PrimaryKey) Capacity 

func (_m *PrimaryKey) Capacity() uint

Capacity provides a mock function with given fields:

func (*PrimaryKey) Delete 

func (_m *PrimaryKey) Delete(key memstore.Key)

Delete provides a mock function with given fields: key

func (*PrimaryKey) Destruct 

func (_m *PrimaryKey) Destruct()

Destruct provides a mock function with given fields:

func (*PrimaryKey) Find 

func (_m *PrimaryKey) Find(key memstore.Key) (memstore.RecordID, bool)

Find provides a mock function with given fields: key

func (*PrimaryKey) FindOrInsert 

func (_m *PrimaryKey) FindOrInsert(key memstore.Key, value memstore.RecordID, eventTime uint32) (bool, memstore.RecordID, error)

FindOrInsert provides a mock function with given fields: key, value, eventTime

func (*PrimaryKey) GetEventTimeCutoff 

func (_m *PrimaryKey) GetEventTimeCutoff() uint32

GetEventTimeCutoff provides a mock function with given fields:

func (*PrimaryKey) LockForTransfer 

func (_m *PrimaryKey) LockForTransfer() memstore.PrimaryKeyData

LockForTransfer provides a mock function with given fields:

func (*PrimaryKey) Size 

func (_m *PrimaryKey) Size() uint

Size provides a mock function with given fields:

func (*PrimaryKey) UnlockAfterTransfer 

func (_m *PrimaryKey) UnlockAfterTransfer()

UnlockAfterTransfer provides a mock function with given fields:

func (*PrimaryKey) Update 

func (_m *PrimaryKey) Update(key memstore.Key, value memstore.RecordID) bool

Update provides a mock function with given fields: key, value

func (*PrimaryKey) UpdateEventTimeCutoff 

func (_m *PrimaryKey) UpdateEventTimeCutoff(eventTimeCutoff uint32)

UpdateEventTimeCutoff provides a mock function with given fields: eventTimeCutoff

type RedoLogBrowser 

type RedoLogBrowser struct {
	mock.Mock
}

RedoLogBrowser is an autogenerated mock type for the RedoLogBrowser type

func (*RedoLogBrowser) ListLogFiles 

func (_m *RedoLogBrowser) ListLogFiles() ([]int64, error)

ListLogFiles provides a mock function with given fields:

func (*RedoLogBrowser) ListUpsertBatch 

func (_m *RedoLogBrowser) ListUpsertBatch(creationTime int64) ([]int64, error)

ListUpsertBatch provides a mock function with given fields: creationTime

func (*RedoLogBrowser) ReadData 

func (_m *RedoLogBrowser) ReadData(creationTime int64, upsertBatchOffset int64, start int, length int) ([][]interface{}, []string, int, error)

ReadData provides a mock function with given fields: creationTime, upsertBatchOffset, start, length

type Scheduler 

type Scheduler struct {
	mock.Mock
}

Scheduler is an autogenerated mock type for the Scheduler type

func (*Scheduler) DeleteTable 

func (_m *Scheduler) DeleteTable(table string, isFactTable bool)

DeleteTable provides a mock function with given fields: table, isFactTable

func (*Scheduler) GetJobDetails 

func (_m *Scheduler) GetJobDetails(jobType common.JobType) interface{}

GetJobDetails provides a mock function with given fields: jobType

func (*Scheduler) Lock 

func (_m *Scheduler) Lock()

Lock provides a mock function with given fields:

func (*Scheduler) NewArchivingJob 

func (_m *Scheduler) NewArchivingJob(tableName string, shardID int, cutoff uint32) memstore.Job

NewArchivingJob provides a mock function with given fields: tableName, shardID, cutoff

func (*Scheduler) NewBackfillJob 

func (_m *Scheduler) NewBackfillJob(tableName string, shardID int) memstore.Job

NewBackfillJob provides a mock function with given fields: tableName, shardID

func (*Scheduler) NewPurgeJob 

func (_m *Scheduler) NewPurgeJob(tableName string, shardID int, batchIDStart int, batchIDEnd int) memstore.Job

NewPurgeJob provides a mock function with given fields: tableName, shardID, batchIDStart, batchIDEnd

func (*Scheduler) NewSnapshotJob 

func (_m *Scheduler) NewSnapshotJob(tableName string, shardID int) memstore.Job

NewSnapshotJob provides a mock function with given fields: tableName, shardID

func (*Scheduler) RLock 

func (_m *Scheduler) RLock()

RLock provides a mock function with given fields:

func (*Scheduler) RUnlock 

func (_m *Scheduler) RUnlock()

RUnlock provides a mock function with given fields:

func (*Scheduler) Start 

func (_m *Scheduler) Start()

Start provides a mock function with given fields:

func (*Scheduler) Stop 

func (_m *Scheduler) Stop()

Stop provides a mock function with given fields:

func (*Scheduler) SubmitJob 

func (_m *Scheduler) SubmitJob(job memstore.Job) chan error

SubmitJob provides a mock function with given fields: job

func (*Scheduler) Unlock 

func (_m *Scheduler) Unlock()

Unlock provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.