Versions in this module Expand all Collapse all v1 v1.0.3 Mar 25, 2020 v1.0.1 Mar 25, 2020 Changes in this version + func VersionFromInt(version int64) topo.Version + type Factory struct + func (f Factory) Create(cell, serverAddr, root string) (topo.Conn, error) + func (f Factory) HasGlobalReadOnlyCell(serverAddr, root string) bool + type KubernetesVersion string + func (v KubernetesVersion) String() string + type NodeReference struct + func (n *NodeReference) ToData() vtv1beta1.VitessTopoNodeData + type Server struct + func NewServer(_, root string) (*Server, error) + func (s *Server) Close() + func (s *Server) Create(ctx context.Context, filePath string, contents []byte) (topo.Version, error) + func (s *Server) Delete(ctx context.Context, filePath string, version topo.Version) error + func (s *Server) Get(ctx context.Context, filePath string) ([]byte, topo.Version, error) + func (s *Server) ListDir(ctx context.Context, dirPath string, full bool) ([]topo.DirEntry, error) + func (s *Server) Lock(ctx context.Context, dirPath, contents string) (topo.LockDescriptor, error) + func (s *Server) NewMasterParticipation(name, id string) (topo.MasterParticipation, error) + func (s *Server) Update(ctx context.Context, filePath string, contents []byte, version topo.Version) (topo.Version, error) + func (s *Server) Watch(ctx context.Context, filePath string) (*topo.WatchData, <-chan *topo.WatchData, topo.CancelFunc)
Go to main page