plasma

Documentation

Index

• Constants
• type Client
  • func Connect(path string) (*Client, error)
  • func (c *Client) Disconnect() error
  • func (c *Client) ReadTable(id ObjectID, timeout time.Duration) (*carrow.Table, error)
  • func (c *Client) Release(id ObjectID) error
  • func (c *Client) WriteTable(t *carrow.Table, id ObjectID) error
• type ObjectID
  • func IDFromString(s string) (ObjectID, error)
  • func RandomID() (ObjectID, error)
  • func (oid ObjectID) String() string

Constants

const (
	// IDLength is length of ObjectID in bytes
	IDLength = 20
)

Types

type Client

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

Client is a client to Arrow's plasma store

func Connect

func Connect(path string) (*Client, error)

Connect connects to plasma store

func (*Client) Disconnect

func (c *Client) Disconnect() error

Disconnect disconnects from plasma store

func (*Client) ReadTable

func (c *Client) ReadTable(id ObjectID, timeout time.Duration) (*carrow.Table, error)

ReadTable reads a table from plasma store

func (*Client) Release

func (c *Client) Release(id ObjectID) error

Release releases (deletes) object from plasma store

func (*Client) WriteTable

func (c *Client) WriteTable(t *carrow.Table, id ObjectID) error

WriteTable write a table to plasma store If id is empty, a new random id will be generated

type ObjectID

type ObjectID [IDLength]byte

ObjectID is store ID for an object

func IDFromString

func IDFromString(s string) (ObjectID, error)

IDFromString converts a string to ObjectID

func RandomID

func RandomID() (ObjectID, error)

RandomID return a new random plasma ID

func (ObjectID) String

func (oid ObjectID) String() string