blobcachetests

package

v0.8.0 Latest Latest Go to latest Published: Jun 24, 2026 License: GPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/blobcache/blobcache

Links

Open Source Insights

Documentation ¶

Overview ¶

package blobcachetests provides a test suite for blobcache.Service.

Index ¶

func Abort(t testing.TB, s blobcache.Service, txh blobcache.Handle)
func BeginTx(t testing.TB, s blobcache.Service, volh blobcache.Handle, ...) blobcache.Handle
func Commit(t testing.TB, s blobcache.Service, txh blobcache.Handle)
func CreateOnSameHost(t testing.TB, s blobcache.Service, base blobcache.Handle, ...) (blobcache.Handle, blobcache.FQOID)
func CreateVolume(t testing.TB, s blobcache.Service, host *blobcache.Endpoint, ...) blobcache.Handle
func Delete(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID)
func Endpoint(t testing.TB, s blobcache.Service) blobcache.Endpoint
func Exists(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID) bool
func Get(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID, ...) int
func GetBytes(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID, ...) []byte
func IsVisited(t testing.TB, s blobcache.Service, txh blobcache.Handle, cids []blobcache.CID) []bool
func Link(t testing.TB, s blobcache.Service, txh blobcache.Handle, volh blobcache.Handle, ...) blobcache.LinkToken
func Load(t testing.TB, s blobcache.Service, txh blobcache.Handle) []byte
func Modify(t testing.TB, s blobcache.Service, volh blobcache.Handle, ...)
func Post(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte, ...) blobcache.CID
func QueueAPI(t *testing.T, setup func(testing.TB) (blobcache.QueueAPI, blobcache.Handle))
func Save(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte)
func SaveCommit(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte)
func ServiceAPI(t *testing.T, mk func(t testing.TB) blobcache.Service)
func SetupScene(t testing.TB, scen Scene, nodes []blobcache.Service)
func TestManyBlobs(t *testing.T, singleTx bool, mk func(t testing.TB) blobcache.Service)
func TestMultiNode(t *testing.T, mk func(t testing.TB, n int) []blobcache.Service)
func TestVolumeSubscribe(t *testing.T, ...)
func TxAPI(t *testing.T, mk func(t testing.TB) (blobcache.Service, blobcache.Handle))
func Unlink(t testing.TB, s blobcache.Service, txh blobcache.Handle, ...)
func Visit(t testing.TB, s blobcache.Service, txh blobcache.Handle, cids []blobcache.CID)
type Contents
type Data
- func (d *Data) Fill(ctx context.Context, tx *bcsdk.Tx, vols []blobcache.Handle) error
type LocalVolume
- func (v *LocalVolume) VolumeSpec() blobcache.VolumeSpec
type Node
type PeerVolume
type Scene
type Volume

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Abort ¶

func Abort(t testing.TB, s blobcache.Service, txh blobcache.Handle)

func BeginTx ¶

func BeginTx(t testing.TB, s blobcache.Service, volh blobcache.Handle, params blobcache.TxParams) blobcache.Handle

func Commit ¶

func Commit(t testing.TB, s blobcache.Service, txh blobcache.Handle)

func CreateOnSameHost ¶

func CreateOnSameHost(t testing.TB, s blobcache.Service, base blobcache.Handle, spec blobcache.VolumeSpec) (blobcache.Handle, blobcache.FQOID)

CreateOnSameHost creates a new subvolume on the same host as the base volume.

func CreateVolume ¶

func CreateVolume(t testing.TB, s blobcache.Service, host *blobcache.Endpoint, spec blobcache.VolumeSpec) blobcache.Handle

func Delete ¶

func Delete(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID)

func Endpoint ¶

func Endpoint(t testing.TB, s blobcache.Service) blobcache.Endpoint

func Exists ¶

func Exists(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID) bool

func Get ¶

func Get(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID, buf []byte, opts blobcache.GetOpts) int

func GetBytes ¶

func GetBytes(t testing.TB, s blobcache.Service, txh blobcache.Handle, cid blobcache.CID, opts blobcache.GetOpts, maxSize int) []byte

func IsVisited ¶

func IsVisited(t testing.TB, s blobcache.Service, txh blobcache.Handle, cids []blobcache.CID) []bool

func Link ¶

func Link(t testing.TB, s blobcache.Service, txh blobcache.Handle, volh blobcache.Handle, mask blobcache.ActionSet) blobcache.LinkToken

func Load ¶

func Load(t testing.TB, s blobcache.Service, txh blobcache.Handle) []byte

func Modify ¶

func Modify(t testing.TB, s blobcache.Service, volh blobcache.Handle, f func(tx *bcsdk.Tx) ([]byte, error))

func Post ¶

func Post(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte, opts blobcache.PostOpts) blobcache.CID

func QueueAPI ¶ added in v0.4.0

func QueueAPI(t *testing.T, setup func(testing.TB) (blobcache.QueueAPI, blobcache.Handle))

func Save ¶

func Save(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte)

func SaveCommit ¶

func SaveCommit(t testing.TB, s blobcache.Service, txh blobcache.Handle, data []byte)

SaveCommit is a convenience function that saves the given data and then commits the transaction.

func ServiceAPI ¶

func ServiceAPI(t *testing.T, mk func(t testing.TB) blobcache.Service)

ServiceAPI tests an implementation of blobcache.Service.

func SetupScene ¶ added in v0.8.0

func SetupScene(t testing.TB, scen Scene, nodes []blobcache.Service)

func TestManyBlobs ¶

func TestManyBlobs(t *testing.T, singleTx bool, mk func(t testing.TB) blobcache.Service)

func TestMultiNode ¶

func TestMultiNode(t *testing.T, mk func(t testing.TB, n int) []blobcache.Service)

func TestVolumeSubscribe ¶ added in v0.4.0

func TestVolumeSubscribe(t *testing.T, setup func(testing.TB) (svc blobcache.Service, volh, qh blobcache.Handle))

func TxAPI ¶

func TxAPI(t *testing.T, mk func(t testing.TB) (blobcache.Service, blobcache.Handle))

TxAPI runs a test suite for transactions on a given volume. The function mk should return a service and a volume handle. The volume handle will be used to open multiple transactions, sometimes concurrently.

func Unlink ¶

func Unlink(t testing.TB, s blobcache.Service, txh blobcache.Handle, ltok blobcache.LinkToken)

func Visit ¶

func Visit(t testing.TB, s blobcache.Service, txh blobcache.Handle, cids []blobcache.CID)

Types ¶

type Contents ¶ added in v0.8.0

type Contents interface {
	// Fill fills a Volume.
	// tx is a transaction on the Volume being filled.
	// vols are handles to all of the volumes on the same Node as the Volume being filled.
	Fill(ctx context.Context, tx *bcsdk.Tx, vols []blobcache.Handle) error
}

Contents are Volume contents

type Data ¶ added in v0.8.0

type Data struct {
	Cell []byte
}

func (*Data) Fill ¶ added in v0.8.0

func (d *Data) Fill(ctx context.Context, tx *bcsdk.Tx, vols []blobcache.Handle) error

type LocalVolume ¶ added in v0.8.0

type LocalVolume struct {
	Schema   blobcache.SchemaSpec
	Contents Contents
}

LocalVolume describes a Volume in a Scenario

func (*LocalVolume) VolumeSpec ¶ added in v0.8.0

func (v *LocalVolume) VolumeSpec() blobcache.VolumeSpec

type Node ¶ added in v0.8.0

type Node struct {
	Root    LocalVolume
	Volumes []Volume
}

type PeerVolume ¶ added in v0.8.0

type PeerVolume struct {
	Node   int
	Volume int
}

type Scene ¶ added in v0.8.0

type Scene struct {
	Nodes []Node
}

Scene describes an initial configuration of Nodes and Volumes

type Volume ¶ added in v0.8.0

type Volume interface {
	// contains filtered or unexported methods
}

Volume describes how a Volume should be setup in a Scene

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL