srvtopotest

package
v0.11.1 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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

WatchSrvVSchema implements srvtopo.Server

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL