Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + var ErrBadResponse = errors.New("etcd request returned success, but response is missing required data") + func VersionFromInt(version int64) topo.Version + type EtcdVersion int64 + func (v EtcdVersion) String() string + type Factory struct + func (f Factory) Create(cell, serverAddr, root string) (topo.Conn, error) + func (f Factory) HasGlobalReadOnlyCell(serverAddr, root string) bool + type Server struct + func NewServer(serverAddr, root string) (*Server, error) + func NewServerWithOpts(serverAddr, root, certPath, keyPath, caPath 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