mocks

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2019 License: Apache-2.0 Imports: 6 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. 

Copyright (c) 2017-2018 Uber Technologies, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0. DO NOT EDIT.

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) JobType added in v0.0.2 

func (_m *Job) JobType() common.JobType

JobType 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) AddTableShard added in v0.0.2 

func (_m *MemStore) AddTableShard(table string, shardID int, needPeerCopy bool)

AddTableShard provides a mock function with given fields: table, shardID, needPeerCopy

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) Bootstrap added in v0.0.2 

func (_m *MemStore) Bootstrap(peerSource client.PeerSource, origin string, topo topology.Topology, topoState *topology.StateSnapshot, options bootstrap.Options) error

Bootstrap provides a mock function with given fields: peerSource, origin, topo, topoState, options

func (*MemStore) FetchSchema 

func (_m *MemStore) FetchSchema() error

FetchSchema provides a mock function with given fields:

func (*MemStore) GetHostMemoryManager added in v0.0.2 

func (_m *MemStore) GetHostMemoryManager() common.HostMemoryManager

GetHostMemoryManager 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) (*common.TableSchema, error)

GetSchema provides a mock function with given fields: table

func (*MemStore) GetSchemas 

func (_m *MemStore) GetSchemas() map[string]*common.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 *common.UpsertBatch) error

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

func (*MemStore) InitShards 

func (_m *MemStore) InitShards(schedulerOff bool, shardOwner topology.ShardOwner)

InitShards provides a mock function with given fields: schedulerOff, shardOwner

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) RemoveTableShard added in v0.0.2 

func (_m *MemStore) RemoveTableShard(table string, shardID int)

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

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 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) EnableJobType added in v0.0.2 

func (_m *Scheduler) EnableJobType(jobType common.JobType, enable bool)

EnableJobType provides a mock function with given fields: jobType, enable

func (*Scheduler) GetJobDetails 

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

GetJobDetails provides a mock function with given fields: jobType

func (*Scheduler) IsJobTypeEnabled added in v0.0.2 

func (_m *Scheduler) IsJobTypeEnabled(jobType common.JobType) bool

IsJobTypeEnabled 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) (error, 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.