fakevtctldclient

package
v0.15.10 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2024 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

	ApplySchemaResults map[string]struct {
		Response *vtctldatapb.ApplySchemaResponse
		Error    error
	}
	CancelSchemaMigrationResults map[string]struct {
		Response *vtctldatapb.CancelSchemaMigrationResponse
		Error    error
	}
	CleanupSchemaMigrationResults map[string]struct {
		Response *vtctldatapb.CleanupSchemaMigrationResponse
		Error    error
	}
	CompleteSchemaMigrationResults map[string]struct {
		Response *vtctldatapb.CompleteSchemaMigrationResponse
		Error    error
	}
	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
	}
	GetSchemaMigrationsResults map[string]struct {
		Response *vtctldatapb.GetSchemaMigrationsResponse
		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
	}
	LaunchSchemaMigrationResults map[string]struct {
		Response *vtctldatapb.LaunchSchemaMigrationResponse
		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
	}
	RetrySchemaMigrationResults map[string]struct {
		Response *vtctldatapb.RetrySchemaMigrationResponse
		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
	}
	WorkflowUpdateResults map[string]struct {
		Response *vtctldatapb.WorkflowUpdateResponse
		Error    error
	}
}

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

func (*VtctldClient) ApplySchema 

func (fake *VtctldClient) ApplySchema(ctx context.Context, req *vtctldatapb.ApplySchemaRequest, opts ...grpc.CallOption) (*vtctldatapb.ApplySchemaResponse, error)

ApplySchema is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CancelSchemaMigration 

func (fake *VtctldClient) CancelSchemaMigration(ctx context.Context, req *vtctldatapb.CancelSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldatapb.CancelSchemaMigrationResponse, error)

CancelSchemaMigration is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CleanupSchemaMigration 

func (fake *VtctldClient) CleanupSchemaMigration(ctx context.Context, req *vtctldatapb.CleanupSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldatapb.CleanupSchemaMigrationResponse, error)

CleanupSchemaMigration is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) Close 

func (fake *VtctldClient) Close() error

Close is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CompleteSchemaMigration 

func (fake *VtctldClient) CompleteSchemaMigration(ctx context.Context, req *vtctldatapb.CompleteSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldatapb.CompleteSchemaMigrationResponse, error)

CompleteSchemaMigration is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) CreateKeyspace 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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) GetSchemaMigrations 

func (fake *VtctldClient) GetSchemaMigrations(ctx context.Context, req *vtctldatapb.GetSchemaMigrationsRequest, opts ...grpc.CallOption) (*vtctldatapb.GetSchemaMigrationsResponse, error)

GetSchemaMigrations is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) GetSrvVSchema 

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 

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) LaunchSchemaMigration 

func (fake *VtctldClient) LaunchSchemaMigration(ctx context.Context, req *vtctldatapb.LaunchSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldatapb.LaunchSchemaMigrationResponse, error)

LaunchSchemaMigration is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) PingTablet 

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 

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 

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 

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 

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 

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 

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) RetrySchemaMigration 

func (fake *VtctldClient) RetrySchemaMigration(ctx context.Context, req *vtctldatapb.RetrySchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldatapb.RetrySchemaMigrationResponse, error)

RetrySchemaMigration is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) RunHealthCheck 

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 

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 

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 

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 

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 

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 

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 

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 

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

ValidateVersionKeyspace is part of the vtctldclient.VtctldClient interface.

func (*VtctldClient) WorkflowUpdate 

func (fake *VtctldClient) WorkflowUpdate(ctx context.Context, req *vtctldatapb.WorkflowUpdateRequest, opts ...grpc.CallOption) (*vtctldatapb.WorkflowUpdateResponse, error)

WorkflowUpdate 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.