fakevtctldclient

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type VtctldClient 

type VtctldClient struct {
	vtctldclient.VtctldClient

	CreateKeyspaceShouldErr bool
	CreateShardShouldErr    bool
	DeleteKeyspaceShouldErr bool
	// Keyed by _sorted_ <ks/shard> list string joined by commas.
	DeleteShardsResults map[string]error
	// Keyed by _sorted_ TabletAlias list string joined by commas.
	DeleteTabletsResults          map[string]error
	EmergencyReparentShardResults map[string]struct {
		Response *vtctldatapb.EmergencyReparentShardResponse
		Error    error
	}
	FindAllShardsInKeyspaceResults map[string]struct {
		Response *vtctldatapb.FindAllShardsInKeyspaceResponse
		Error    error
	}
	GetBackupsResults map[string]struct {
		Response *vtctldatapb.GetBackupsResponse
		Error    error
	}
	GetCellInfoNamesResults *struct {
		Response *vtctldatapb.GetCellInfoNamesResponse
		Error    error
	}
	GetCellInfoResults map[string]struct {
		Response *vtctldatapb.GetCellInfoResponse
		Error    error
	}
	GetCellsAliasesResults *struct {
		Response *vtctldatapb.GetCellsAliasesResponse
		Error    error
	}
	GetKeyspaceResults map[string]struct {
		Response *vtctldatapb.GetKeyspaceResponse
		Error    error
	}
	GetKeyspacesResults *struct {
		Keyspaces []*vtctldatapb.Keyspace
		Error     error
	}
	GetSchemaResults map[string]struct {
		Response *vtctldatapb.GetSchemaResponse
		Error    error
	}
	GetSrvVSchemaResults map[string]struct {
		Response *vtctldatapb.GetSrvVSchemaResponse
		Error    error
	}
	GetVSchemaResults map[string]struct {
		Response *vtctldatapb.GetVSchemaResponse
		Error    error
	}
	GetWorkflowsResults map[string]struct {
		Response *vtctldatapb.GetWorkflowsResponse
		Error    error
	}
	PingTabletResults           map[string]error
	PlannedReparentShardResults map[string]struct {
		Response *vtctldatapb.PlannedReparentShardResponse
		Error    error
	}
	RefreshStateResults         map[string]error
	ReloadSchemaKeyspaceResults map[string]struct {
		Response *vtctldatapb.ReloadSchemaKeyspaceResponse
		Error    error
	}
	ReloadSchemaResults map[string]struct {
		Response *vtctldatapb.ReloadSchemaResponse
		Error    error
	}
	ReloadSchemaShardResults map[string]struct {
		Response *vtctldatapb.ReloadSchemaShardResponse
		Error    error
	}
	ReparentTabletResults map[string]struct {
		Response *vtctldatapb.ReparentTabletResponse
		Error    error
	}
	RunHealthCheckResults            map[string]error
	SetWritableResults               map[string]error
	ShardReplicationPositionsResults map[string]struct {
		Response *vtctldatapb.ShardReplicationPositionsResponse
		Error    error
	}
	StartReplicationResults           map[string]error
	StopReplicationResults            map[string]error
	TabletExternallyReparentedResults map[string]struct {
		Response *vtctldatapb.TabletExternallyReparentedResponse
		Error    error
	}
	ValidateKeyspaceResults map[string]struct {
		Response *vtctldatapb.ValidateKeyspaceResponse
		Error    error
	}
	ValidateSchemaKeyspaceResults map[string]struct {
		Response *vtctldatapb.ValidateSchemaKeyspaceResponse
		Error    error
	}
	ValidateVersionKeyspaceResults map[string]struct {
		Response *vtctldatapb.ValidateVersionKeyspaceResponse
		Error    error
	}
}

VtctldClient provides a partial mock implementation of the vtctldclient.VtctldClient interface for use in testing.

func (*VtctldClient) Close added in v0.14.0 

func (fake *VtctldClient) Close() error

Close is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CreateKeyspace added in v0.12.0 

func (fake *VtctldClient) CreateKeyspace(ctx context.Context, req *vtctldatapb.CreateKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.CreateKeyspaceResponse, error)

CreateKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CreateShard added in v0.14.0 

func (fake *VtctldClient) CreateShard(cxt context.Context, req *vtctldatapb.CreateShardRequest, opts ...grpc.CallOption) (*vtctldatapb.CreateShardResponse, error)

CreateShard is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) DeleteKeyspace added in v0.12.0 

func (fake *VtctldClient) DeleteKeyspace(ctx context.Context, req *vtctldatapb.DeleteKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.DeleteKeyspaceResponse, error)

DeleteKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) DeleteShards added in v0.14.0 

func (fake *VtctldClient) DeleteShards(ctx context.Context, req *vtctldatapb.DeleteShardsRequest, opts ...grpc.CallOption) (*vtctldatapb.DeleteShardsResponse, error)

DeleteShards is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) DeleteTablets added in v0.14.0 

func (fake *VtctldClient) DeleteTablets(ctx context.Context, req *vtctldatapb.DeleteTabletsRequest, opts ...grpc.CallOption) (*vtctldatapb.DeleteTabletsResponse, error)

DeleteTablets is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) EmergencyReparentShard added in v0.14.0 

func (fake *VtctldClient) EmergencyReparentShard(ctx context.Context, req *vtctldatapb.EmergencyReparentShardRequest, opts ...grpc.CallOption) (*vtctldatapb.EmergencyReparentShardResponse, error)

EmergencyReparentShard is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) FindAllShardsInKeyspace 

func (fake *VtctldClient) FindAllShardsInKeyspace(ctx context.Context, req *vtctldatapb.FindAllShardsInKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.FindAllShardsInKeyspaceResponse, error)

FindAllShardsInKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetBackups added in v0.14.0 

func (fake *VtctldClient) GetBackups(ctx context.Context, req *vtctldatapb.GetBackupsRequest, opts ...grpc.CallOption) (*vtctldatapb.GetBackupsResponse, error)

GetBackups is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetCellInfo added in v0.14.0 

func (fake *VtctldClient) GetCellInfo(ctx context.Context, req *vtctldatapb.GetCellInfoRequest, opts ...grpc.CallOption) (*vtctldatapb.GetCellInfoResponse, error)

GetCellInfo is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetCellInfoNames added in v0.14.0 

func (fake *VtctldClient) GetCellInfoNames(ctx context.Context, req *vtctldatapb.GetCellInfoNamesRequest, opts ...grpc.CallOption) (*vtctldatapb.GetCellInfoNamesResponse, error)

GetCellInfoNames is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetCellsAliases added in v0.14.0 

func (fake *VtctldClient) GetCellsAliases(ctx context.Context, req *vtctldatapb.GetCellsAliasesRequest, opts ...grpc.CallOption) (*vtctldatapb.GetCellsAliasesResponse, error)

GetCellsAliases is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetKeyspace 

func (fake *VtctldClient) GetKeyspace(ctx context.Context, req *vtctldatapb.GetKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.GetKeyspaceResponse, error)

GetKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetKeyspaces 

func (fake *VtctldClient) GetKeyspaces(ctx context.Context, req *vtctldatapb.GetKeyspacesRequest, opts ...grpc.CallOption) (*vtctldatapb.GetKeyspacesResponse, error)

GetKeyspaces is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetSchema 

func (fake *VtctldClient) GetSchema(ctx context.Context, req *vtctldatapb.GetSchemaRequest, opts ...grpc.CallOption) (*vtctldatapb.GetSchemaResponse, error)

GetSchema is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetSrvVSchema added in v0.14.0 

func (fake *VtctldClient) GetSrvVSchema(ctx context.Context, req *vtctldatapb.GetSrvVSchemaRequest, opts ...grpc.CallOption) (*vtctldatapb.GetSrvVSchemaResponse, error)

GetSrvVSchema is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetSrvVSchemas added in v0.14.0 

func (fake *VtctldClient) GetSrvVSchemas(ctx context.Context, req *vtctldatapb.GetSrvVSchemasRequest, opts ...grpc.CallOption) (resp *vtctldatapb.GetSrvVSchemasResponse, err error)

GetSrvVSchemas is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetVSchema 

func (fake *VtctldClient) GetVSchema(ctx context.Context, req *vtctldatapb.GetVSchemaRequest, opts ...grpc.CallOption) (*vtctldatapb.GetVSchemaResponse, error)

GetVSchema is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetWorkflows 

func (fake *VtctldClient) GetWorkflows(ctx context.Context, req *vtctldatapb.GetWorkflowsRequest, opts ...grpc.CallOption) (*vtctldatapb.GetWorkflowsResponse, error)

GetWorkflows is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) PingTablet added in v0.14.0 

func (fake *VtctldClient) PingTablet(ctx context.Context, req *vtctldatapb.PingTabletRequest, opts ...grpc.CallOption) (*vtctldatapb.PingTabletResponse, error)

PingTablet is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) PlannedReparentShard added in v0.14.0 

func (fake *VtctldClient) PlannedReparentShard(ctx context.Context, req *vtctldatapb.PlannedReparentShardRequest, opts ...grpc.CallOption) (*vtctldatapb.PlannedReparentShardResponse, error)

PlannedReparentShard is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) RefreshState added in v0.14.0 

func (fake *VtctldClient) RefreshState(ctx context.Context, req *vtctldatapb.RefreshStateRequest, opts ...grpc.CallOption) (*vtctldatapb.RefreshStateResponse, error)

RefreshState is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ReloadSchema added in v0.14.0 

func (fake *VtctldClient) ReloadSchema(ctx context.Context, req *vtctldatapb.ReloadSchemaRequest, opts ...grpc.CallOption) (*vtctldatapb.ReloadSchemaResponse, error)

ReloadSchema is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ReloadSchemaKeyspace added in v0.14.0 

func (fake *VtctldClient) ReloadSchemaKeyspace(ctx context.Context, req *vtctldatapb.ReloadSchemaKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.ReloadSchemaKeyspaceResponse, error)

ReloadSchemaKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ReloadSchemaShard added in v0.14.0 

func (fake *VtctldClient) ReloadSchemaShard(ctx context.Context, req *vtctldatapb.ReloadSchemaShardRequest, opts ...grpc.CallOption) (*vtctldatapb.ReloadSchemaShardResponse, error)

ReloadSchemaShard is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ReparentTablet added in v0.14.0 

func (fake *VtctldClient) ReparentTablet(ctx context.Context, req *vtctldatapb.ReparentTabletRequest, opts ...grpc.CallOption) (*vtctldatapb.ReparentTabletResponse, error)

ReparentTablet is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) RunHealthCheck added in v0.14.0 

func (fake *VtctldClient) RunHealthCheck(ctx context.Context, req *vtctldatapb.RunHealthCheckRequest, opts ...grpc.CallOption) (*vtctldatapb.RunHealthCheckResponse, error)

RunHealthCheck is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) SetWritable added in v0.14.0 

func (fake *VtctldClient) SetWritable(ctx context.Context, req *vtctldatapb.SetWritableRequest, opts ...grpc.CallOption) (*vtctldatapb.SetWritableResponse, error)

SetWritable is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ShardReplicationPositions added in v0.12.0 

func (fake *VtctldClient) ShardReplicationPositions(ctx context.Context, req *vtctldatapb.ShardReplicationPositionsRequest, opts ...grpc.CallOption) (*vtctldatapb.ShardReplicationPositionsResponse, error)

ShardReplicationPositions is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) StartReplication added in v0.14.0 

func (fake *VtctldClient) StartReplication(ctx context.Context, req *vtctldatapb.StartReplicationRequest, opts ...grpc.CallOption) (*vtctldatapb.StartReplicationResponse, error)

StartReplication is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) StopReplication added in v0.14.0 

func (fake *VtctldClient) StopReplication(ctx context.Context, req *vtctldatapb.StopReplicationRequest, opts ...grpc.CallOption) (*vtctldatapb.StopReplicationResponse, error)

StopReplication is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) TabletExternallyReparented added in v0.14.0 

func (fake *VtctldClient) TabletExternallyReparented(ctx context.Context, req *vtctldatapb.TabletExternallyReparentedRequest, opts ...grpc.CallOption) (*vtctldatapb.TabletExternallyReparentedResponse, error)

TabletExternallyReparented is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ValidateKeyspace added in v0.14.0 

func (fake *VtctldClient) ValidateKeyspace(ctx context.Context, req *vtctldatapb.ValidateKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.ValidateKeyspaceResponse, error)

ValidateKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ValidateSchemaKeyspace added in v0.14.0 

func (fake *VtctldClient) ValidateSchemaKeyspace(ctx context.Context, req *vtctldatapb.ValidateSchemaKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.ValidateSchemaKeyspaceResponse, error)

ValidateSchemaKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) ValidateVersionKeyspace added in v0.14.0 

func (fake *VtctldClient) ValidateVersionKeyspace(ctx context.Context, req *vtctldatapb.ValidateVersionKeyspaceRequest, opts ...grpc.CallOption) (*vtctldatapb.ValidateVersionKeyspaceResponse, error)

ValidateVersionKeyspace is part of the vtctldclient.VtctldClient interface.

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.