zk

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
  • func CreateConn(callback func(string, bool)) (*Storage, error)
  • func GetConn(callback func(string, bool)) (*Storage, error)

Functions

func CN2P

func CN2P(name string) string

ConfigNameToPath

func GetOneHost

func GetOneHost() string

func MonitorNodeRoot

func MonitorNodeRoot() string

func MyMonitorNode

func MyMonitorNode() (string, error)

func P2CN

func P2CN(path string) string

PathToConfigName

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

func (conn *Conn) Close()

func (*Conn) Create

func (conn *Conn) Create(path string, data []byte, lease clientv3.LeaseID) (string, error)

func (*Conn) CreateDriverResetChan

func (conn *Conn) CreateDriverResetChan()

func (*Conn) Exists

func (conn *Conn) Exists(path string) (bool, error)

func (*Conn) ExistsW

func (conn *Conn) ExistsW(path string) clientv3.WatchChan

func (*Conn) Get

func (conn *Conn) Get(path string) ([]byte, error)

func (*Conn) GetDriverResetChan

func (conn *Conn) GetDriverResetChan() <-chan bool

func (*Conn) Grant

func (conn *Conn) Grant(ttl int64) (clientv3.LeaseID, error)

func (*Conn) KeepAlive

func (conn *Conn) KeepAlive(ctx context.Context, lease clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)

func (*Conn) KeepAliveOnce

func (conn *Conn) KeepAliveOnce(ctx context.Context, lease clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error)

func (*Conn) Set

func (conn *Conn) Set(path string, data []byte, lease ...clientv3.LeaseID) (string, error)

type Storage

type Storage struct {
	Conn *Conn
}

func CreateConn

func CreateConn(callback func(string, bool)) (*Storage, error)

func GetConn

func GetConn(callback func(string, bool)) (*Storage, error)

获取一个连接单例