mock

package
v0.0.0-...-7a0127b Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2024 License: PostgreSQL Imports: 10 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockEntityMgr 

type MockEntityMgr struct {
	// contains filtered or unexported fields
}

MockEntityMgr is a mock of EntityMgr interface.

func NewMockEntityMgr 

func NewMockEntityMgr(ctrl *gomock.Controller) *MockEntityMgr

NewMockEntityMgr creates a new mock instance.

func (*MockEntityMgr) AddDataShard 

func (m *MockEntityMgr) AddDataShard(ctx context.Context, shard *datashards.DataShard) error

AddDataShard mocks base method.

func (*MockEntityMgr) AddWorldShard 

func (m *MockEntityMgr) AddWorldShard(ctx context.Context, shard *datashards.DataShard) error

AddWorldShard mocks base method.

func (*MockEntityMgr) AlterDistributionAttach 

func (m *MockEntityMgr) AlterDistributionAttach(ctx context.Context, id string, rels []*distributions.DistributedRelation) error

AlterDistributionAttach mocks base method.

func (*MockEntityMgr) AlterDistributionDetach 

func (m *MockEntityMgr) AlterDistributionDetach(ctx context.Context, id, relName string) error

AlterDistributionDetach mocks base method.

func (*MockEntityMgr) BatchMoveKeyRange 

func (m *MockEntityMgr) BatchMoveKeyRange(ctx context.Context, req *kr.BatchMoveKeyRange) error

BatchMoveKeyRange mocks base method.

func (*MockEntityMgr) Cache 

func (m *MockEntityMgr) Cache() *cache.SchemaCache

Cache mocks base method.

func (*MockEntityMgr) CreateDistribution 

func (m *MockEntityMgr) CreateDistribution(ctx context.Context, ds *distributions.Distribution) error

CreateDistribution mocks base method.

func (*MockEntityMgr) CreateKeyRange 

func (m *MockEntityMgr) CreateKeyRange(ctx context.Context, kr *kr.KeyRange) error

CreateKeyRange mocks base method.

func (*MockEntityMgr) DropDistribution 

func (m *MockEntityMgr) DropDistribution(ctx context.Context, id string) error

DropDistribution mocks base method.

func (*MockEntityMgr) DropKeyRange 

func (m *MockEntityMgr) DropKeyRange(ctx context.Context, krid string) error

DropKeyRange mocks base method.

func (*MockEntityMgr) DropKeyRangeAll 

func (m *MockEntityMgr) DropKeyRangeAll(ctx context.Context) error

DropKeyRangeAll mocks base method.

func (*MockEntityMgr) DropShard 

func (m *MockEntityMgr) DropShard(ctx context.Context, id string) error

DropShard mocks base method.

func (*MockEntityMgr) EXPECT 

func (m *MockEntityMgr) EXPECT() *MockEntityMgrMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEntityMgr) GetBalancerTask 

func (m *MockEntityMgr) GetBalancerTask(ctx context.Context) (*tasks.BalancerTask, error)

GetBalancerTask mocks base method.

func (*MockEntityMgr) GetCoordinator 

func (m *MockEntityMgr) GetCoordinator(ctx context.Context) (string, error)

GetCoordinator mocks base method.

func (*MockEntityMgr) GetDistribution 

func (m *MockEntityMgr) GetDistribution(ctx context.Context, id string) (*distributions.Distribution, error)

GetDistribution mocks base method.

func (*MockEntityMgr) GetKeyRange 

func (m *MockEntityMgr) GetKeyRange(ctx context.Context, krId string) (*kr.KeyRange, error)

GetKeyRange mocks base method.

func (*MockEntityMgr) GetMoveTaskGroup 

func (m *MockEntityMgr) GetMoveTaskGroup(ctx context.Context) (*tasks.MoveTaskGroup, error)

GetMoveTaskGroup mocks base method.

func (*MockEntityMgr) GetRelationDistribution 

func (m *MockEntityMgr) GetRelationDistribution(ctx context.Context, relation_name string) (*distributions.Distribution, error)

GetRelationDistribution mocks base method.

func (*MockEntityMgr) GetShard 

func (m *MockEntityMgr) GetShard(ctx context.Context, shardID string) (*datashards.DataShard, error)

GetShard mocks base method.

func (*MockEntityMgr) ListAllKeyRanges 

func (m *MockEntityMgr) ListAllKeyRanges(ctx context.Context) ([]*kr.KeyRange, error)

ListAllKeyRanges mocks base method.

func (*MockEntityMgr) ListDistributions 

func (m *MockEntityMgr) ListDistributions(ctx context.Context) ([]*distributions.Distribution, error)

ListDistributions mocks base method.

func (*MockEntityMgr) ListKeyRanges 

func (m *MockEntityMgr) ListKeyRanges(ctx context.Context, distribution string) ([]*kr.KeyRange, error)

ListKeyRanges mocks base method.

func (*MockEntityMgr) ListRouters 

func (m *MockEntityMgr) ListRouters(ctx context.Context) ([]*topology.Router, error)

ListRouters mocks base method.

func (*MockEntityMgr) ListShards 

func (m *MockEntityMgr) ListShards(ctx context.Context) ([]*datashards.DataShard, error)

ListShards mocks base method.

func (*MockEntityMgr) LockKeyRange 

func (m *MockEntityMgr) LockKeyRange(ctx context.Context, krid string) (*kr.KeyRange, error)

LockKeyRange mocks base method.

func (*MockEntityMgr) Move 

func (m *MockEntityMgr) Move(ctx context.Context, move *kr.MoveKeyRange) error

Move mocks base method.

func (*MockEntityMgr) QDB 

func (m *MockEntityMgr) QDB() qdb.QDB

QDB mocks base method.

func (*MockEntityMgr) RedistributeKeyRange 

func (m *MockEntityMgr) RedistributeKeyRange(ctx context.Context, req *kr.RedistributeKeyRange) error

RedistributeKeyRange mocks base method.

func (*MockEntityMgr) RegisterRouter 

func (m *MockEntityMgr) RegisterRouter(ctx context.Context, r *topology.Router) error

RegisterRouter mocks base method.

func (*MockEntityMgr) RemoveBalancerTask 

func (m *MockEntityMgr) RemoveBalancerTask(ctx context.Context) error

RemoveBalancerTask mocks base method.

func (*MockEntityMgr) RemoveMoveTaskGroup 

func (m *MockEntityMgr) RemoveMoveTaskGroup(ctx context.Context) error

RemoveMoveTaskGroup mocks base method.

func (*MockEntityMgr) RenameKeyRange 

func (m *MockEntityMgr) RenameKeyRange(ctx context.Context, krId, krIdNew string) error

RenameKeyRange mocks base method.

func (*MockEntityMgr) ShareKeyRange 

func (m *MockEntityMgr) ShareKeyRange(id string) error

ShareKeyRange mocks base method.

func (*MockEntityMgr) Split 

func (m *MockEntityMgr) Split(ctx context.Context, split *kr.SplitKeyRange) error

Split mocks base method.

func (*MockEntityMgr) SyncRouterCoordinatorAddress 

func (m *MockEntityMgr) SyncRouterCoordinatorAddress(ctx context.Context, router *topology.Router) error

SyncRouterCoordinatorAddress mocks base method.

func (*MockEntityMgr) SyncRouterMetadata 

func (m *MockEntityMgr) SyncRouterMetadata(ctx context.Context, router *topology.Router) error

SyncRouterMetadata mocks base method.

func (*MockEntityMgr) Unite 

func (m *MockEntityMgr) Unite(ctx context.Context, unite *kr.UniteKeyRange) error

Unite mocks base method.

func (*MockEntityMgr) UnlockKeyRange 

func (m *MockEntityMgr) UnlockKeyRange(ctx context.Context, krid string) error

UnlockKeyRange mocks base method.

func (*MockEntityMgr) UnregisterRouter 

func (m *MockEntityMgr) UnregisterRouter(ctx context.Context, id string) error

UnregisterRouter mocks base method.

func (*MockEntityMgr) UpdateCoordinator 

func (m *MockEntityMgr) UpdateCoordinator(ctx context.Context, address string) error

UpdateCoordinator mocks base method.

func (*MockEntityMgr) WriteBalancerTask 

func (m *MockEntityMgr) WriteBalancerTask(ctx context.Context, task *tasks.BalancerTask) error

WriteBalancerTask mocks base method.

func (*MockEntityMgr) WriteMoveTaskGroup 

func (m *MockEntityMgr) WriteMoveTaskGroup(ctx context.Context, taskGroup *tasks.MoveTaskGroup) error

WriteMoveTaskGroup mocks base method.

type MockEntityMgrMockRecorder 

type MockEntityMgrMockRecorder struct {
	// contains filtered or unexported fields
}

MockEntityMgrMockRecorder is the mock recorder for MockEntityMgr.

func (*MockEntityMgrMockRecorder) AddDataShard 

func (mr *MockEntityMgrMockRecorder) AddDataShard(ctx, shard interface{}) *gomock.Call

AddDataShard indicates an expected call of AddDataShard.

func (*MockEntityMgrMockRecorder) AddWorldShard 

func (mr *MockEntityMgrMockRecorder) AddWorldShard(ctx, shard interface{}) *gomock.Call

AddWorldShard indicates an expected call of AddWorldShard.

func (*MockEntityMgrMockRecorder) AlterDistributionAttach 

func (mr *MockEntityMgrMockRecorder) AlterDistributionAttach(ctx, id, rels interface{}) *gomock.Call

AlterDistributionAttach indicates an expected call of AlterDistributionAttach.

func (*MockEntityMgrMockRecorder) AlterDistributionDetach 

func (mr *MockEntityMgrMockRecorder) AlterDistributionDetach(ctx, id, relName interface{}) *gomock.Call

AlterDistributionDetach indicates an expected call of AlterDistributionDetach.

func (*MockEntityMgrMockRecorder) BatchMoveKeyRange 

func (mr *MockEntityMgrMockRecorder) BatchMoveKeyRange(ctx, req interface{}) *gomock.Call

BatchMoveKeyRange indicates an expected call of BatchMoveKeyRange.

func (*MockEntityMgrMockRecorder) Cache 

func (mr *MockEntityMgrMockRecorder) Cache() *gomock.Call

Cache indicates an expected call of Cache.

func (*MockEntityMgrMockRecorder) CreateDistribution 

func (mr *MockEntityMgrMockRecorder) CreateDistribution(ctx, ds interface{}) *gomock.Call

CreateDistribution indicates an expected call of CreateDistribution.

func (*MockEntityMgrMockRecorder) CreateKeyRange 

func (mr *MockEntityMgrMockRecorder) CreateKeyRange(ctx, kr interface{}) *gomock.Call

CreateKeyRange indicates an expected call of CreateKeyRange.

func (*MockEntityMgrMockRecorder) DropDistribution 

func (mr *MockEntityMgrMockRecorder) DropDistribution(ctx, id interface{}) *gomock.Call

DropDistribution indicates an expected call of DropDistribution.

func (*MockEntityMgrMockRecorder) DropKeyRange 

func (mr *MockEntityMgrMockRecorder) DropKeyRange(ctx, krid interface{}) *gomock.Call

DropKeyRange indicates an expected call of DropKeyRange.

func (*MockEntityMgrMockRecorder) DropKeyRangeAll 

func (mr *MockEntityMgrMockRecorder) DropKeyRangeAll(ctx interface{}) *gomock.Call

DropKeyRangeAll indicates an expected call of DropKeyRangeAll.

func (*MockEntityMgrMockRecorder) DropShard 

func (mr *MockEntityMgrMockRecorder) DropShard(ctx, id interface{}) *gomock.Call

DropShard indicates an expected call of DropShard.

func (*MockEntityMgrMockRecorder) GetBalancerTask 

func (mr *MockEntityMgrMockRecorder) GetBalancerTask(ctx interface{}) *gomock.Call

GetBalancerTask indicates an expected call of GetBalancerTask.

func (*MockEntityMgrMockRecorder) GetCoordinator 

func (mr *MockEntityMgrMockRecorder) GetCoordinator(ctx interface{}) *gomock.Call

GetCoordinator indicates an expected call of GetCoordinator.

func (*MockEntityMgrMockRecorder) GetDistribution 

func (mr *MockEntityMgrMockRecorder) GetDistribution(ctx, id interface{}) *gomock.Call

GetDistribution indicates an expected call of GetDistribution.

func (*MockEntityMgrMockRecorder) GetKeyRange 

func (mr *MockEntityMgrMockRecorder) GetKeyRange(ctx, krId interface{}) *gomock.Call

GetKeyRange indicates an expected call of GetKeyRange.

func (*MockEntityMgrMockRecorder) GetMoveTaskGroup 

func (mr *MockEntityMgrMockRecorder) GetMoveTaskGroup(ctx interface{}) *gomock.Call

GetMoveTaskGroup indicates an expected call of GetMoveTaskGroup.

func (*MockEntityMgrMockRecorder) GetRelationDistribution 

func (mr *MockEntityMgrMockRecorder) GetRelationDistribution(ctx, relation_name interface{}) *gomock.Call

GetRelationDistribution indicates an expected call of GetRelationDistribution.

func (*MockEntityMgrMockRecorder) GetShard 

func (mr *MockEntityMgrMockRecorder) GetShard(ctx, shardID interface{}) *gomock.Call

GetShard indicates an expected call of GetShard.

func (*MockEntityMgrMockRecorder) ListAllKeyRanges 

func (mr *MockEntityMgrMockRecorder) ListAllKeyRanges(ctx interface{}) *gomock.Call

ListAllKeyRanges indicates an expected call of ListAllKeyRanges.

func (*MockEntityMgrMockRecorder) ListDistributions 

func (mr *MockEntityMgrMockRecorder) ListDistributions(ctx interface{}) *gomock.Call

ListDistributions indicates an expected call of ListDistributions.

func (*MockEntityMgrMockRecorder) ListKeyRanges 

func (mr *MockEntityMgrMockRecorder) ListKeyRanges(ctx, distribution interface{}) *gomock.Call

ListKeyRanges indicates an expected call of ListKeyRanges.

func (*MockEntityMgrMockRecorder) ListRouters 

func (mr *MockEntityMgrMockRecorder) ListRouters(ctx interface{}) *gomock.Call

ListRouters indicates an expected call of ListRouters.

func (*MockEntityMgrMockRecorder) ListShards 

func (mr *MockEntityMgrMockRecorder) ListShards(ctx interface{}) *gomock.Call

ListShards indicates an expected call of ListShards.

func (*MockEntityMgrMockRecorder) LockKeyRange 

func (mr *MockEntityMgrMockRecorder) LockKeyRange(ctx, krid interface{}) *gomock.Call

LockKeyRange indicates an expected call of LockKeyRange.

func (*MockEntityMgrMockRecorder) Move 

func (mr *MockEntityMgrMockRecorder) Move(ctx, move interface{}) *gomock.Call

Move indicates an expected call of Move.

func (*MockEntityMgrMockRecorder) QDB 

func (mr *MockEntityMgrMockRecorder) QDB() *gomock.Call

QDB indicates an expected call of QDB.

func (*MockEntityMgrMockRecorder) RedistributeKeyRange 

func (mr *MockEntityMgrMockRecorder) RedistributeKeyRange(ctx, req interface{}) *gomock.Call

RedistributeKeyRange indicates an expected call of RedistributeKeyRange.

func (*MockEntityMgrMockRecorder) RegisterRouter 

func (mr *MockEntityMgrMockRecorder) RegisterRouter(ctx, r interface{}) *gomock.Call

RegisterRouter indicates an expected call of RegisterRouter.

func (*MockEntityMgrMockRecorder) RemoveBalancerTask 

func (mr *MockEntityMgrMockRecorder) RemoveBalancerTask(ctx interface{}) *gomock.Call

RemoveBalancerTask indicates an expected call of RemoveBalancerTask.

func (*MockEntityMgrMockRecorder) RemoveMoveTaskGroup 

func (mr *MockEntityMgrMockRecorder) RemoveMoveTaskGroup(ctx interface{}) *gomock.Call

RemoveMoveTaskGroup indicates an expected call of RemoveMoveTaskGroup.

func (*MockEntityMgrMockRecorder) RenameKeyRange 

func (mr *MockEntityMgrMockRecorder) RenameKeyRange(ctx, krId, krIdNew interface{}) *gomock.Call

RenameKeyRange indicates an expected call of RenameKeyRange.

func (*MockEntityMgrMockRecorder) ShareKeyRange 

func (mr *MockEntityMgrMockRecorder) ShareKeyRange(id interface{}) *gomock.Call

ShareKeyRange indicates an expected call of ShareKeyRange.

func (*MockEntityMgrMockRecorder) Split 

func (mr *MockEntityMgrMockRecorder) Split(ctx, split interface{}) *gomock.Call

Split indicates an expected call of Split.

func (*MockEntityMgrMockRecorder) SyncRouterCoordinatorAddress 

func (mr *MockEntityMgrMockRecorder) SyncRouterCoordinatorAddress(ctx, router interface{}) *gomock.Call

SyncRouterCoordinatorAddress indicates an expected call of SyncRouterCoordinatorAddress.

func (*MockEntityMgrMockRecorder) SyncRouterMetadata 

func (mr *MockEntityMgrMockRecorder) SyncRouterMetadata(ctx, router interface{}) *gomock.Call

SyncRouterMetadata indicates an expected call of SyncRouterMetadata.

func (*MockEntityMgrMockRecorder) Unite 

func (mr *MockEntityMgrMockRecorder) Unite(ctx, unite interface{}) *gomock.Call

Unite indicates an expected call of Unite.

func (*MockEntityMgrMockRecorder) UnlockKeyRange 

func (mr *MockEntityMgrMockRecorder) UnlockKeyRange(ctx, krid interface{}) *gomock.Call

UnlockKeyRange indicates an expected call of UnlockKeyRange.

func (*MockEntityMgrMockRecorder) UnregisterRouter 

func (mr *MockEntityMgrMockRecorder) UnregisterRouter(ctx, id interface{}) *gomock.Call

UnregisterRouter indicates an expected call of UnregisterRouter.

func (*MockEntityMgrMockRecorder) UpdateCoordinator 

func (mr *MockEntityMgrMockRecorder) UpdateCoordinator(ctx, address interface{}) *gomock.Call

UpdateCoordinator indicates an expected call of UpdateCoordinator.

func (*MockEntityMgrMockRecorder) WriteBalancerTask 

func (mr *MockEntityMgrMockRecorder) WriteBalancerTask(ctx, task interface{}) *gomock.Call

WriteBalancerTask indicates an expected call of WriteBalancerTask.

func (*MockEntityMgrMockRecorder) WriteMoveTaskGroup 

func (mr *MockEntityMgrMockRecorder) WriteMoveTaskGroup(ctx, taskGroup interface{}) *gomock.Call

WriteMoveTaskGroup indicates an expected call of WriteMoveTaskGroup.

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.