Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + func NewServer(cells ...string) *topo.Server + func VersionFromInt(version int64) topo.Version + type Conn struct + func (c *Conn) Close() + func (c *Conn) Create(ctx context.Context, filePath string, contents []byte) (topo.Version, error) + func (c *Conn) Delete(ctx context.Context, filePath string, version topo.Version) error + func (c *Conn) Get(ctx context.Context, filePath string) ([]byte, topo.Version, error) + func (c *Conn) ListDir(ctx context.Context, dirPath string, full bool) ([]topo.DirEntry, error) + func (c *Conn) Lock(ctx context.Context, dirPath, contents string) (topo.LockDescriptor, error) + func (c *Conn) NewMasterParticipation(name, id string) (topo.MasterParticipation, error) + func (c *Conn) Update(ctx context.Context, filePath string, contents []byte, version topo.Version) (topo.Version, error) + func (c *Conn) Watch(ctx context.Context, filePath string) (*topo.WatchData, <-chan *topo.WatchData, topo.CancelFunc) + type Factory struct + func NewServerAndFactory(cells ...string) (*topo.Server, *Factory) + func (f *Factory) Create(cell, serverAddr, root string) (topo.Conn, error) + func (f *Factory) HasGlobalReadOnlyCell(serverAddr, root string) bool + func (f *Factory) Lock() + func (f *Factory) SetError(err error) + func (f *Factory) Unlock() + type NodeVersion uint64 + func (v NodeVersion) String() string
Go to main page