faketopo

Documentation

Overview

Package faketopo contains utitlities for tests that have to interact with a Vitess topology.

Index

• type FakeTopo
  • func (ft FakeTopo) Close()
  • func (ft FakeTopo) CreateKeyspace(ctx context.Context, keyspace string, value *topodatapb.Keyspace) error
  • func (ft FakeTopo) CreateShard(ctx context.Context, keyspace, shard string, value *topodatapb.Shard) error
  • func (ft FakeTopo) CreateTablet(ctx context.Context, tablet *topodatapb.Tablet) error
  • func (ft FakeTopo) DeleteKeyspace(ctx context.Context, keyspace string) error
  • func (ft FakeTopo) DeleteKeyspaceReplication(ctx context.Context, cell, keyspace string) error
  • func (ft FakeTopo) DeleteKeyspaceShards(ctx context.Context, keyspace string) error
  • func (ft FakeTopo) DeleteShard(ctx context.Context, keyspace, shard string) error
  • func (ft FakeTopo) DeleteShardReplication(ctx context.Context, cell, keyspace, shard string) error
  • func (ft FakeTopo) DeleteSrvKeyspace(ctx context.Context, cell, keyspace string) error
  • func (ft FakeTopo) DeleteTablet(ctx context.Context, alias *topodatapb.TabletAlias) error
  • func (ft FakeTopo) GetKeyspace(ctx context.Context, keyspace string) (*topodatapb.Keyspace, int64, error)
  • func (ft FakeTopo) GetKeyspaces(ctx context.Context) ([]string, error)
  • func (ft FakeTopo) GetKnownCells(ctx context.Context) ([]string, error)
  • func (ft FakeTopo) GetShard(ctx context.Context, keyspace, shard string) (*topodatapb.Shard, int64, error)
  • func (ft FakeTopo) GetShardNames(ctx context.Context, keyspace string) ([]string, error)
  • func (ft FakeTopo) GetShardReplication(ctx context.Context, cell, keyspace, shard string) (*topo.ShardReplicationInfo, error)
  • func (ft FakeTopo) GetSrvKeyspace(ctx context.Context, cell, keyspace string) (*topodatapb.SrvKeyspace, error)
  • func (ft FakeTopo) GetSrvKeyspaceNames(ctx context.Context, cell string) ([]string, error)
  • func (ft FakeTopo) GetSrvVSchema(ctx context.Context, cell string) (*vschemapb.SrvVSchema, error)
  • func (ft FakeTopo) GetTablet(ctx context.Context, alias *topodatapb.TabletAlias) (*topodatapb.Tablet, int64, error)
  • func (ft FakeTopo) GetTabletsByCell(ctx context.Context, cell string) ([]*topodatapb.TabletAlias, error)
  • func (ft FakeTopo) GetVSchema(ctx context.Context, keyspace string) (*vschemapb.Keyspace, error)
  • func (ft FakeTopo) LockKeyspaceForAction(ctx context.Context, keyspace, contents string) (string, error)
  • func (ft FakeTopo) LockShardForAction(ctx context.Context, keyspace, shard, contents string) (string, error)
  • func (ft FakeTopo) SaveVSchema(context.Context, string, *vschemapb.Keyspace) error
  • func (ft FakeTopo) UnlockKeyspaceForAction(ctx context.Context, keyspace, lockPath, results string) error
  • func (ft FakeTopo) UnlockShardForAction(ctx context.Context, keyspace, shard, lockPath, results string) error
  • func (ft FakeTopo) UpdateKeyspace(ctx context.Context, keyspace string, value *topodatapb.Keyspace, ...) (int64, error)
  • func (ft FakeTopo) UpdateShard(ctx context.Context, keyspace, shard string, value *topodatapb.Shard, ...) (int64, error)
  • func (ft FakeTopo) UpdateShardReplicationFields(ctx context.Context, cell, keyspace, shard string, ...) error
  • func (ft FakeTopo) UpdateSrvKeyspace(ctx context.Context, cell, keyspace string, ...) error
  • func (ft FakeTopo) UpdateSrvVSchema(ctx context.Context, cell string, srvVSchema *vschemapb.SrvVSchema) error
  • func (ft FakeTopo) UpdateTablet(ctx context.Context, tablet *topodatapb.Tablet, existingVersion int64) (newVersion int64, err error)
  • func (ft FakeTopo) ValidateShard(ctx context.Context, keyspace, shard string) error
  • func (ft FakeTopo) WatchSrvKeyspace(ctx context.Context, cell, keyspace string) (<-chan *topodatapb.SrvKeyspace, error)
  • func (ft FakeTopo) WatchSrvVSchema(ctx context.Context, cell string) (<-chan *vschemapb.SrvVSchema, error)

Types

type FakeTopo

type FakeTopo struct{}

FakeTopo is a topo.Server implementation that always returns errNotImplemented errors.

func (FakeTopo) Close

func (ft FakeTopo) Close()

Close implements topo.Server.

func (FakeTopo) CreateKeyspace

func (ft FakeTopo) CreateKeyspace(ctx context.Context, keyspace string, value *topodatapb.Keyspace) error

CreateKeyspace implements topo.Server.

func (FakeTopo) CreateShard

func (ft FakeTopo) CreateShard(ctx context.Context, keyspace, shard string, value *topodatapb.Shard) error

CreateShard implements topo.Server.

func (FakeTopo) CreateTablet

func (ft FakeTopo) CreateTablet(ctx context.Context, tablet *topodatapb.Tablet) error

CreateTablet implements topo.Server.

func (FakeTopo) DeleteKeyspace

func (ft FakeTopo) DeleteKeyspace(ctx context.Context, keyspace string) error

DeleteKeyspace implements topo.Server.

func (FakeTopo) DeleteKeyspaceReplication

func (ft FakeTopo) DeleteKeyspaceReplication(ctx context.Context, cell, keyspace string) error

DeleteKeyspaceReplication implements topo.Server.

func (FakeTopo) DeleteKeyspaceShards

func (ft FakeTopo) DeleteKeyspaceShards(ctx context.Context, keyspace string) error

DeleteKeyspaceShards implements topo.Server.

func (FakeTopo) DeleteShard

func (ft FakeTopo) DeleteShard(ctx context.Context, keyspace, shard string) error

DeleteShard implements topo.Server.

func (FakeTopo) DeleteShardReplication

func (ft FakeTopo) DeleteShardReplication(ctx context.Context, cell, keyspace, shard string) error

DeleteShardReplication implements topo.Server.

func (FakeTopo) DeleteSrvKeyspace

func (ft FakeTopo) DeleteSrvKeyspace(ctx context.Context, cell, keyspace string) error

DeleteSrvKeyspace implements topo.Server.

func (FakeTopo) DeleteTablet

func (ft FakeTopo) DeleteTablet(ctx context.Context, alias *topodatapb.TabletAlias) error

DeleteTablet implements topo.Server.

func (FakeTopo) GetKeyspace

func (ft FakeTopo) GetKeyspace(ctx context.Context, keyspace string) (*topodatapb.Keyspace, int64, error)

GetKeyspace implements topo.Server.

func (FakeTopo) GetKeyspaces

func (ft FakeTopo) GetKeyspaces(ctx context.Context) ([]string, error)

GetKeyspaces implements topo.Server.

func (FakeTopo) GetKnownCells

func (ft FakeTopo) GetKnownCells(ctx context.Context) ([]string, error)

GetKnownCells implements topo.Server.

func (FakeTopo) GetShard

func (ft FakeTopo) GetShard(ctx context.Context, keyspace, shard string) (*topodatapb.Shard, int64, error)

GetShard implements topo.Server.

func (FakeTopo) GetShardNames

func (ft FakeTopo) GetShardNames(ctx context.Context, keyspace string) ([]string, error)

GetShardNames implements topo.Server.

func (FakeTopo) GetShardReplication

func (ft FakeTopo) GetShardReplication(ctx context.Context, cell, keyspace, shard string) (*topo.ShardReplicationInfo, error)

GetShardReplication implements topo.Server.

func (FakeTopo) GetSrvKeyspace

func (ft FakeTopo) GetSrvKeyspace(ctx context.Context, cell, keyspace string) (*topodatapb.SrvKeyspace, error)

GetSrvKeyspace implements topo.Server.

func (FakeTopo) GetSrvKeyspaceNames

func (ft FakeTopo) GetSrvKeyspaceNames(ctx context.Context, cell string) ([]string, error)

GetSrvKeyspaceNames implements topo.Server.

func (FakeTopo) GetSrvVSchema

func (ft FakeTopo) GetSrvVSchema(ctx context.Context, cell string) (*vschemapb.SrvVSchema, error)

GetSrvVSchema implements topo.Server.

func (FakeTopo) GetTablet

func (ft FakeTopo) GetTablet(ctx context.Context, alias *topodatapb.TabletAlias) (*topodatapb.Tablet, int64, error)

GetTablet implements topo.Server.

func (FakeTopo) GetTabletsByCell

func (ft FakeTopo) GetTabletsByCell(ctx context.Context, cell string) ([]*topodatapb.TabletAlias, error)

GetTabletsByCell implements topo.Server.

func (FakeTopo) GetVSchema

func (ft FakeTopo) GetVSchema(ctx context.Context, keyspace string) (*vschemapb.Keyspace, error)

GetVSchema implements topo.Server.

func (FakeTopo) LockKeyspaceForAction

func (ft FakeTopo) LockKeyspaceForAction(ctx context.Context, keyspace, contents string) (string, error)

LockKeyspaceForAction implements topo.Server.

func (FakeTopo) LockShardForAction

func (ft FakeTopo) LockShardForAction(ctx context.Context, keyspace, shard, contents string) (string, error)

LockShardForAction implements topo.Server.

func (FakeTopo) SaveVSchema

func (ft FakeTopo) SaveVSchema(context.Context, string, *vschemapb.Keyspace) error

SaveVSchema implements topo.Server.

func (FakeTopo) UnlockKeyspaceForAction

func (ft FakeTopo) UnlockKeyspaceForAction(ctx context.Context, keyspace, lockPath, results string) error

UnlockKeyspaceForAction implements topo.Server.

func (FakeTopo) UnlockShardForAction

func (ft FakeTopo) UnlockShardForAction(ctx context.Context, keyspace, shard, lockPath, results string) error

UnlockShardForAction implements topo.Server.

func (FakeTopo) UpdateKeyspace

func (ft FakeTopo) UpdateKeyspace(ctx context.Context, keyspace string, value *topodatapb.Keyspace, existingVersion int64) (int64, error)

UpdateKeyspace implements topo.Server.

func (FakeTopo) UpdateShard

func (ft FakeTopo) UpdateShard(ctx context.Context, keyspace, shard string, value *topodatapb.Shard, existingVersion int64) (int64, error)

UpdateShard implements topo.Server.

func (FakeTopo) UpdateShardReplicationFields

func (ft FakeTopo) UpdateShardReplicationFields(ctx context.Context, cell, keyspace, shard string, update func(*topodatapb.ShardReplication) error) error

UpdateShardReplicationFields implements topo.Server.

func (FakeTopo) UpdateSrvKeyspace

func (ft FakeTopo) UpdateSrvKeyspace(ctx context.Context, cell, keyspace string, srvKeyspace *topodatapb.SrvKeyspace) error

UpdateSrvKeyspace implements topo.Server.

func (FakeTopo) UpdateSrvVSchema

func (ft FakeTopo) UpdateSrvVSchema(ctx context.Context, cell string, srvVSchema *vschemapb.SrvVSchema) error

UpdateSrvVSchema implements topo.Server.

func (FakeTopo) UpdateTablet

func (ft FakeTopo) UpdateTablet(ctx context.Context, tablet *topodatapb.Tablet, existingVersion int64) (newVersion int64, err error)

UpdateTablet implements topo.Server.

func (FakeTopo) ValidateShard

func (ft FakeTopo) ValidateShard(ctx context.Context, keyspace, shard string) error

ValidateShard implements topo.Server.

func (FakeTopo) WatchSrvKeyspace

func (ft FakeTopo) WatchSrvKeyspace(ctx context.Context, cell, keyspace string) (<-chan *topodatapb.SrvKeyspace, error)

WatchSrvKeyspace implements topo.Server.WatchSrvKeyspace

func (FakeTopo) WatchSrvVSchema

func (ft FakeTopo) WatchSrvVSchema(ctx context.Context, cell string) (<-chan *vschemapb.SrvVSchema, error)

WatchSrvVSchema implements topo.Server.WatchSrvVSchema