fsclient

Documentation

Index

• Variables
• type Client
  • func New(dir string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Create(path string, data []byte) error
  • func (c *Client) CreateEphemeral(path string, data []byte) (<-chan struct{}, error)
  • func (c *Client) CreateEphemeralInOrder(path string, data []byte) (<-chan struct{}, string, error)
  • func (c *Client) Delete(path string) error
  • func (c *Client) List(path string, must bool) ([]string, error)
  • func (c *Client) Read(path string, must bool) ([]byte, error)
  • func (c *Client) Update(path string, data []byte) error
  • func (c *Client) WatchInOrder(path string) (<-chan struct{}, []string, error)

Variables

var ErrClosedClient = errors.New("use of closed fs client")

var ErrNotSupported = errors.New("not supported")

Types

type Client

type Client struct {
	sync.Mutex

	RootDir  string
	DataDir  string
	TempDir  string
	LockFile string
	// contains filtered or unexported fields
}

func New

func New(dir string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Create

func (c *Client) Create(path string, data []byte) error

func (*Client) CreateEphemeral

func (c *Client) CreateEphemeral(path string, data []byte) (<-chan struct{}, error)

func (*Client) CreateEphemeralInOrder

func (c *Client) CreateEphemeralInOrder(path string, data []byte) (<-chan struct{}, string, error)

func (*Client) Delete

func (c *Client) Delete(path string) error

func (*Client) List

func (c *Client) List(path string, must bool) ([]string, error)

func (*Client) Read

func (c *Client) Read(path string, must bool) ([]byte, error)

func (*Client) Update

func (c *Client) Update(path string, data []byte) error

func (*Client) WatchInOrder

func (c *Client) WatchInOrder(path string) (<-chan struct{}, []string, error)