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) CreateEndPoints(ctx context.Context, cell, keyspace, shard string, ...) error
  • 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) DeleteEndPoints(ctx context.Context, cell, keyspace, shard string, ...) 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) DeleteSrvShard(ctx context.Context, cell, keyspace, shard string) error
  • func (ft FakeTopo) DeleteTablet(ctx context.Context, alias *topodatapb.TabletAlias) error
  • func (ft FakeTopo) GetEndPoints(ctx context.Context, cell, keyspace, shard string, ...) (*topodatapb.EndPoints, int64, 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) GetSrvShard(ctx context.Context, cell, keyspace, shard string) (*topodatapb.SrvShard, error)
  • func (ft FakeTopo) GetSrvTabletTypesPerShard(ctx context.Context, cell, keyspace, shard string) ([]topodatapb.TabletType, 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) (string, 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) LockSrvShardForAction(ctx context.Context, cell, keyspace, shard, contents string) (string, error)
  • func (ft FakeTopo) SaveVSchema(context.Context, string, string) 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) UnlockSrvShardForAction(ctx context.Context, cell, keyspace, shard, lockPath, results string) error
  • func (ft FakeTopo) UpdateEndPoints(ctx context.Context, cell, keyspace, shard 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) UpdateSrvShard(ctx context.Context, cell, keyspace, shard string, ...) 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) WatchVSchema(ctx context.Context, keyspace string) (<-chan string, 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) CreateEndPoints

func (ft FakeTopo) CreateEndPoints(ctx context.Context, cell, keyspace, shard string, tabletType topodatapb.TabletType, addrs *topodatapb.EndPoints) error

CreateEndPoints 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) DeleteEndPoints

func (ft FakeTopo) DeleteEndPoints(ctx context.Context, cell, keyspace, shard string, tabletType topodatapb.TabletType, existingVersion int64) error

DeleteEndPoints 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) DeleteSrvShard

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

DeleteSrvShard implements topo.Server.

func (FakeTopo) DeleteTablet

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

DeleteTablet implements topo.Server.

func (FakeTopo) GetEndPoints

func (ft FakeTopo) GetEndPoints(ctx context.Context, cell, keyspace, shard string, tabletType topodatapb.TabletType) (*topodatapb.EndPoints, int64, error)

GetEndPoints 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) GetSrvShard

func (ft FakeTopo) GetSrvShard(ctx context.Context, cell, keyspace, shard string) (*topodatapb.SrvShard, error)

GetSrvShard implements topo.Server.

func (FakeTopo) GetSrvTabletTypesPerShard

func (ft FakeTopo) GetSrvTabletTypesPerShard(ctx context.Context, cell, keyspace, shard string) ([]topodatapb.TabletType, error)

GetSrvTabletTypesPerShard 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) (string, 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) LockSrvShardForAction

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

LockSrvShardForAction implements topo.Server.

func (FakeTopo) SaveVSchema

func (ft FakeTopo) SaveVSchema(context.Context, string, string) 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) UnlockSrvShardForAction

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

UnlockSrvShardForAction implements topo.Server.

func (FakeTopo) UpdateEndPoints

func (ft FakeTopo) UpdateEndPoints(ctx context.Context, cell, keyspace, shard string, tabletType topodatapb.TabletType, addrs *topodatapb.EndPoints, existingVersion int64) error

UpdateEndPoints 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) UpdateSrvShard

func (ft FakeTopo) UpdateSrvShard(ctx context.Context, cell, keyspace, shard string, srvShard *topodatapb.SrvShard) error

UpdateSrvShard 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) WatchVSchema

func (ft FakeTopo) WatchVSchema(ctx context.Context, keyspace string) (<-chan string, error)

WatchVSchema implements topo.Server.WatchSrvKeyspace