plasma

package

v0.0.0-...-e0f2aff Latest Latest Go to latest Published: Aug 24, 2021 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

This section is empty.

This section is empty.

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

Client is a client to Arrow's plasma store

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

Connect connects to plasma store

func (c *Client) Disconnect() error

Disconnect disconnects from plasma store

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

ReadTable reads a table from plasma store

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

Release releases (deletes) object from plasma store

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 [IDLength]byte

ObjectID is store ID for an object

func IDFromString(s string) (ObjectID, error)

IDFromString converts a string to ObjectID

func RandomID() (ObjectID, error)

RandomID return a new random plasma ID

func (oid ObjectID) String() string