storageclient

Documentation

Index

• type Client
  • func NewClient(host, certFile string, keyFile string, caFiles []string) *Client
  • func (c *Client) AddKeygroupTrigger(kg string, id string, host string) error
  • func (c *Client) Append(kg string, id string, val string, expiry int) error
  • func (c *Client) Close() error
  • func (c *Client) CreateKeygroup(kg string) error
  • func (c *Client) Delete(kg string, id string, vvector vclock.VClock) error
  • func (c *Client) DeleteKeygroup(kg string) error
  • func (c *Client) DeleteKeygroupTrigger(kg string, id string) error
  • func (c *Client) Destroy()
  • func (c *Client) Exists(kg string, id string) bool
  • func (c *Client) ExistsKeygroup(kg string) bool
  • func (c *Client) GetKeygroupTrigger(kg string) (map[string]string, error)
  • func (c *Client) IDs(kg string) ([]string, error)
  • func (c *Client) Read(kg, id string) ([]string, []vclock.VClock, bool, error)
  • func (c *Client) ReadAll(kg string) (map[string][]string, map[string][]vclock.VClock, error)
  • func (c *Client) ReadSome(kg, id string, count uint64) (map[string][]string, map[string][]vclock.VClock, error)
  • func (c *Client) Update(kg string, id string, val string, expiry int, vvector vclock.VClock) error

Types

type Client

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

Client to a grpc server

func NewClient

func NewClient(host, certFile string, keyFile string, caFiles []string) *Client

NewClient Client creates a new Client to communicate with a GRpc server

func (*Client) AddKeygroupTrigger

func (c *Client) AddKeygroupTrigger(kg string, id string, host string) error

AddKeygroupTrigger calls the same method on the remote server.

func (*Client) Append

func (c *Client) Append(kg string, id string, val string, expiry int) error

Append calls the same method on the remote server

func (*Client) Close

func (c *Client) Close() error

Close closes the connection to the storage service.

func (*Client) CreateKeygroup

func (c *Client) CreateKeygroup(kg string) error

CreateKeygroup calls the same method on the remote server

func (*Client) Delete

func (c *Client) Delete(kg string, id string, vvector vclock.VClock) error

Delete calls the same method on the remote server

func (*Client) DeleteKeygroup

func (c *Client) DeleteKeygroup(kg string) error

DeleteKeygroup calls the same method on the remote server

func (*Client) DeleteKeygroupTrigger

func (c *Client) DeleteKeygroupTrigger(kg string, id string) error

DeleteKeygroupTrigger calls the same method on the remote server.

func (*Client) Destroy

func (c *Client) Destroy()

Destroy destroys the connection

func (*Client) Exists

func (c *Client) Exists(kg string, id string) bool

Exists calls the same method on the remote server.

func (*Client) ExistsKeygroup

func (c *Client) ExistsKeygroup(kg string) bool

ExistsKeygroup calls the same method on the remote server.

func (*Client) GetKeygroupTrigger

func (c *Client) GetKeygroupTrigger(kg string) (map[string]string, error)

GetKeygroupTrigger calls the same method on the remote server.

func (*Client) IDs

func (c *Client) IDs(kg string) ([]string, error)

IDs calls the same method on the remote server

func (*Client) Read

func (c *Client) Read(kg, id string) ([]string, []vclock.VClock, bool, error)

Read calls the same method on the remote server

func (*Client) ReadAll

func (c *Client) ReadAll(kg string) (map[string][]string, map[string][]vclock.VClock, error)

ReadAll calls the same method on the remote server

func (*Client) ReadSome

func (c *Client) ReadSome(kg, id string, count uint64) (map[string][]string, map[string][]vclock.VClock, error)

ReadSome calls the same method on the remote server

func (*Client) Update

func (c *Client) Update(kg string, id string, val string, expiry int, vvector vclock.VClock) error