srvtopotest

Documentation

Index

• type PassthroughSrvTopoServer
  • func NewPassthroughSrvTopoServer() *PassthroughSrvTopoServer
  • func (srv *PassthroughSrvTopoServer) GetSrvKeyspace(ctx context.Context, cell, keyspace string) (*topodatapb.SrvKeyspace, error)
  • func (srv *PassthroughSrvTopoServer) GetSrvKeyspaceNames(ctx context.Context, cell string, staleOK bool) ([]string, error)
  • func (srv *PassthroughSrvTopoServer) GetTopoServer() (*topo.Server, error)
  • func (srv *PassthroughSrvTopoServer) WatchSrvKeyspace(ctx context.Context, cell, keyspace string, ...)
  • func (srv *PassthroughSrvTopoServer) WatchSrvVSchema(ctx context.Context, cell string, ...)

Types

type PassthroughSrvTopoServer

type PassthroughSrvTopoServer struct {
	TopoServer      *topo.Server
	TopoServerError error

	SrvKeyspaceNames      []string
	SrvKeyspaceNamesError error

	SrvKeyspace      *topodatapb.SrvKeyspace
	SrvKeyspaceError error

	WatchedSrvVSchema      *vschemapb.SrvVSchema
	WatchedSrvVSchemaError error
}

PassthroughSrvTopoServer is a bare implementation of srvtopo.Server for use in tests

func NewPassthroughSrvTopoServer

func NewPassthroughSrvTopoServer() *PassthroughSrvTopoServer

NewPassthroughSrvTopoServer returns a new, unconfigured test PassthroughSrvTopoServer

func (*PassthroughSrvTopoServer) GetSrvKeyspace

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

GetSrvKeyspace implements srvtopo.Server

func (*PassthroughSrvTopoServer) GetSrvKeyspaceNames

func (srv *PassthroughSrvTopoServer) GetSrvKeyspaceNames(ctx context.Context, cell string, staleOK bool) ([]string, error)

GetSrvKeyspaceNames implements srvtopo.Server

func (*PassthroughSrvTopoServer) GetTopoServer

func (srv *PassthroughSrvTopoServer) GetTopoServer() (*topo.Server, error)

GetTopoServer implements srvtopo.Server

func (*PassthroughSrvTopoServer) WatchSrvKeyspace

func (srv *PassthroughSrvTopoServer) WatchSrvKeyspace(ctx context.Context, cell, keyspace string, callback func(*topodatapb.SrvKeyspace, error) bool)

func (*PassthroughSrvTopoServer) WatchSrvVSchema

func (srv *PassthroughSrvTopoServer) WatchSrvVSchema(ctx context.Context, cell string, callback func(*vschemapb.SrvVSchema, error) bool)

WatchSrvVSchema implements srvtopo.Server