basicns

package

v0.0.0-...-575026b Latest Latest Go to latest Published: Sep 30, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Details

Package basicns provides a simple namespace implementation. All entries are stored in the root of the volume.

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Service blobcache.Service
	Schema  Schema
}

Client provides methods for interacting with a Namespace using a Service.

func (c *Client) CreateAt(ctx context.Context, nsh blobcache.Handle, name string, spec blobcache.VolumeSpec) (*blobcache.Handle, error)

CreateAt creates a new Volume using spec, and links it to volh.

func (c *Client) DeleteEntry(ctx context.Context, volh blobcache.Handle, name string) error

func (c *Client) GetEntry(ctx context.Context, volh blobcache.Handle, name string) (*Entry, error)

func (c *Client) ListEntries(ctx context.Context, volh blobcache.Handle) ([]Entry, error)

func (c *Client) ListNames(ctx context.Context, volh blobcache.Handle) ([]string, error)

func (c *Client) OpenAt(ctx context.Context, nsh blobcache.Handle, name string, mask blobcache.ActionSet) (*blobcache.Handle, error)

func (c *Client) PutEntry(ctx context.Context, volh blobcache.Handle, name string, target blobcache.Handle) error

type Entry struct {
	Name   string
	Target blobcache.OID
	Rights blobcache.ActionSet
}

func (ent *Entry) Link() schema.Link

type Schema struct{}

func (sch Schema) ListEntries(ctx context.Context, s cadata.Getter, root []byte) ([]Entry, error)

func (sch Schema) ReadLinks(ctx context.Context, s schema.RO, root []byte, dst map[blobcache.OID]blobcache.ActionSet) error

func (sch Schema) Validate(ctx context.Context, s schema.RO, _, next []byte) error

type Tx struct {
	Tx *blobcache.Tx
	// Root is the current root, set by calls to PutEntry and DeleteEntry
	Root   []byte
	Schema Schema
}

Tx wraps a Tx to provide a namespace view.

func (ns Tx) Commit(ctx context.Context) error

func (ns *Tx) DeleteEntry(ctx context.Context, name string) error

func (ns *Tx) GetEntry(ctx context.Context, name string) (*Entry, error)

func (ns Tx) ListEntries(ctx context.Context) ([]Entry, error)

func (ns Tx) ListNames(ctx context.Context) ([]string, error)

func (ns *Tx) PutEntry(ctx context.Context, name string, target blobcache.OID, rights blobcache.ActionSet) error