Documentation
¶
Index ¶
- func CN2P(name string) string
- func GetOneHost() string
- func MonitorNodeRoot() string
- func MyMonitorNode() (string, error)
- func P2CN(path string) string
- type Conn
- func (conn *Conn) Close()
- func (conn *Conn) Create(path string, data []byte, lease clientv3.LeaseID) (string, error)
- func (conn *Conn) CreateDriverResetChan()
- func (conn *Conn) Exists(path string) (bool, error)
- func (conn *Conn) ExistsW(path string) clientv3.WatchChan
- func (conn *Conn) Get(path string) ([]byte, error)
- func (conn *Conn) GetDriverResetChan() <-chan bool
- func (conn *Conn) Grant(ttl int64) (clientv3.LeaseID, error)
- func (conn *Conn) KeepAlive(ctx context.Context, lease clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)
- func (conn *Conn) KeepAliveOnce(ctx context.Context, lease clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error)
- func (conn *Conn) Set(path string, data []byte, lease ...clientv3.LeaseID) (string, error)
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetOneHost ¶
func GetOneHost() string
func MonitorNodeRoot ¶
func MonitorNodeRoot() string
func MyMonitorNode ¶
Types ¶
type Conn ¶
type Conn struct {
// the underground connection to storage server has been re-created.
DriverReset chan bool
// contains filtered or unexported fields
}
func (*Conn) CreateDriverResetChan ¶
func (conn *Conn) CreateDriverResetChan()
func (*Conn) GetDriverResetChan ¶
func (*Conn) KeepAliveOnce ¶
Source Files
Click to show internal directories.
Click to hide internal directories.