client

Documentation

Index

• func Path(dir string, name string) string
• type Client
  • func New(addrArray []string) *Client
  • func (c *Client) Add(path string, num int) *Response
  • func (c *Client) Close()
  • func (c *Client) CreateInt(path string, value int) *Response
  • func (c *Client) Del(path string) *Response
  • func (c *Client) Get(path string) *Response
  • func (c *Client) GetAndWatch(path string, immediately bool, notify WatchNotify)
  • func (c *Client) GetList(path string) *Response
  • func (c *Client) Inc(path string) *Response
  • func (c *Client) Lock(path string)
  • func (c *Client) MkDir(path string, value string) *Response
  • func (c *Client) MkFile(path string, value string) *Response
  • func (c *Client) MkFileTmp(path string, value string) *Response
  • func (c *Client) MkFileWithVerb(path string, value string, v Verb) *Response
  • func (c *Client) Name() string
  • func (c *Client) RemoveWatch(path string) *Response
  • func (c *Client) Set(path string, value string) *Response
  • func (c *Client) Start()
  • func (c *Client) ULock(path string)
  • func (c *Client) Watch(path string, immediately bool, notify WatchNotify) *Response
• type MsgSendType
• type WatchNotify

Functions

func Path

func Path(dir string, name string) string

Types

type Client

type Client struct {
	Tag int
	// contains filtered or unexported fields
}

func New

func New(addrArray []string) *Client

Creates a new server.

func (*Client) Add

func (c *Client) Add(path string, num int) *Response

func (*Client) Close

func (c *Client) Close()

func (*Client) CreateInt

func (c *Client) CreateInt(path string, value int) *Response

func (*Client) Del

func (c *Client) Del(path string) *Response

func (*Client) Get

func (c *Client) Get(path string) *Response

func (*Client) GetAndWatch

func (c *Client) GetAndWatch(path string, immediately bool, notify WatchNotify)

func (*Client) GetList

func (c *Client) GetList(path string) *Response

func (*Client) Inc

func (c *Client) Inc(path string) *Response

func (*Client) Lock

func (c *Client) Lock(path string)

func (*Client) MkDir

func (c *Client) MkDir(path string, value string) *Response

func (*Client) MkFile

func (c *Client) MkFile(path string, value string) *Response

func (*Client) MkFileTmp

func (c *Client) MkFileTmp(path string, value string) *Response

func (*Client) MkFileWithVerb

func (c *Client) MkFileWithVerb(path string, value string, v Verb) *Response

func (*Client) Name

func (c *Client) Name() string

func (*Client) RemoveWatch

func (c *Client) RemoveWatch(path string) *Response

func (*Client) Set

func (c *Client) Set(path string, value string) *Response

func (*Client) Start

func (c *Client) Start()

Get the server list.

func (*Client) ULock

func (c *Client) ULock(path string)

func (*Client) Watch

func (c *Client) Watch(path string, immediately bool, notify WatchNotify) *Response

type MsgSendType

type MsgSendType int

type WatchNotify

type WatchNotify func(path string, value string, verb Verb, stopWatch *bool)

watch verb is Verb_Create | Verb_Set | Verb_Del