fakevtctldclient

Documentation

Index

• type VtctldClient
  • func (fake *VtctldClient) CreateKeyspace(ctx context.Context, req *vtctldatapb.CreateKeyspaceRequest, ...) (*vtctldatapb.CreateKeyspaceResponse, error)
  • func (fake *VtctldClient) DeleteKeyspace(ctx context.Context, req *vtctldatapb.DeleteKeyspaceRequest, ...) (*vtctldatapb.DeleteKeyspaceResponse, error)
  • func (fake *VtctldClient) FindAllShardsInKeyspace(ctx context.Context, req *vtctldatapb.FindAllShardsInKeyspaceRequest, ...) (*vtctldatapb.FindAllShardsInKeyspaceResponse, error)
  • func (fake *VtctldClient) GetKeyspace(ctx context.Context, req *vtctldatapb.GetKeyspaceRequest, ...) (*vtctldatapb.GetKeyspaceResponse, error)
  • func (fake *VtctldClient) GetKeyspaces(ctx context.Context, req *vtctldatapb.GetKeyspacesRequest, ...) (*vtctldatapb.GetKeyspacesResponse, error)
  • func (fake *VtctldClient) GetSchema(ctx context.Context, req *vtctldatapb.GetSchemaRequest, ...) (*vtctldatapb.GetSchemaResponse, error)
  • func (fake *VtctldClient) GetVSchema(ctx context.Context, req *vtctldatapb.GetVSchemaRequest, ...) (*vtctldatapb.GetVSchemaResponse, error)
  • func (fake *VtctldClient) GetWorkflows(ctx context.Context, req *vtctldatapb.GetWorkflowsRequest, ...) (*vtctldatapb.GetWorkflowsResponse, error)
  • func (fake *VtctldClient) ShardReplicationPositions(ctx context.Context, req *vtctldatapb.ShardReplicationPositionsRequest, ...) (*vtctldatapb.ShardReplicationPositionsResponse, error)

Types

type VtctldClient

type VtctldClient struct {
	vtctldclient.VtctldClient

	CreateKeyspaceShouldErr        bool
	DeleteKeyspaceShouldErr        bool
	FindAllShardsInKeyspaceResults map[string]struct {
		Response *vtctldatapb.FindAllShardsInKeyspaceResponse
		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
	}
	GetVSchemaResults map[string]struct {
		Response *vtctldatapb.GetVSchemaResponse
		Error    error
	}
	GetWorkflowsResults map[string]struct {
		Response *vtctldatapb.GetWorkflowsResponse
		Error    error
	}
	ShardReplicationPositionsResults map[string]struct {
		Response *vtctldatapb.ShardReplicationPositionsResponse
		Error    error
	}
}

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

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