patrick

Documentation

Index

• func New(ctx context.Context, node peer.Node) (iface.Client, error)
• type Client
  • func (c *Client) Cancel(jid string, cid_log map[string]string) (interface{}, error)
  • func (c *Client) Close()
  • func (c *Client) DatabaseStats() (kvdbIface.Stats, error)
  • func (c *Client) Done(jid string, cid_log map[string]string, assetCid map[string]string) error
  • func (c *Client) Failed(jid string, cid_log map[string]string, assetCid map[string]string) error
  • func (c *Client) Get(jid string) (*iface.Job, error)
  • func (c *Client) IsLocked(jid string) (bool, error)
  • func (c *Client) List() ([]string, error)
  • func (c *Client) Lock(jid string, eta uint32) error
  • func (c *Client) Peers(pids ...peerCore.ID) iface.Client
  • func (c *Client) Timeout(jid string) error
  • func (c *Client) Unlock(jid string) error
• type Peer

Functions

func New

func New(ctx context.Context, node peer.Node) (iface.Client, error)

Types

type Client

type Client struct {
	*client.Client
	// contains filtered or unexported fields
}

func (*Client) Cancel

func (c *Client) Cancel(jid string, cid_log map[string]string) (interface{}, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) DatabaseStats

func (c *Client) DatabaseStats() (kvdbIface.Stats, error)

func (*Client) Done

func (c *Client) Done(jid string, cid_log map[string]string, assetCid map[string]string) error

func (*Client) Failed

func (c *Client) Failed(jid string, cid_log map[string]string, assetCid map[string]string) error

func (*Client) Get

func (c *Client) Get(jid string) (*iface.Job, error)

func (*Client) IsLocked

func (c *Client) IsLocked(jid string) (bool, error)

func (*Client) List

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

func (*Client) Lock

func (c *Client) Lock(jid string, eta uint32) error

func (*Client) Peers

func (c *Client) Peers(pids ...peerCore.ID) iface.Client

func (*Client) Timeout

func (c *Client) Timeout(jid string) error

func (*Client) Unlock

func (c *Client) Unlock(jid string) error

TODO: delete

type Peer

type Peer struct {
	Client
	Id string
}