bcremote

func (*Service) Abort ¶

func (s *Service) Abort(ctx context.Context, tx blobcache.Handle) error

Abort aborts a transaction.

func (*Service) AwaitReady ¶

func (s *Service) AwaitReady(ctx context.Context) error

AwaitReady pings the server in a loop and awaits a response. Any error returned will be from ctx.Err()

func (*Service) BeginTx ¶

func (s *Service) BeginTx(ctx context.Context, volh blobcache.Handle, txp blobcache.TxParams) (*blobcache.Handle, error)

func (*Service) CloneVolume ¶

func (s *Service) CloneVolume(ctx context.Context, caller *blobcache.PeerID, volh blobcache.Handle) (*blobcache.Handle, error)

func (*Service) Close ¶

func (s *Service) Close() error

Close closes the Service.

func (*Service) Commit ¶

func (s *Service) Commit(ctx context.Context, tx blobcache.Handle) error

Commit commits a transaction.

func (*Service) Copy ¶

func (s *Service) Copy(ctx context.Context, tx blobcache.Handle, srcTxns []blobcache.Handle, cids []blobcache.CID, success []bool) error

func (*Service) CreateQueue ¶

func (s *Service) CreateQueue(ctx context.Context, _ *blobcache.Endpoint, qspec blobcache.QueueSpec) (*blobcache.Handle, error)

func (*Service) CreateVolume ¶

func (s *Service) CreateVolume(ctx context.Context, host *blobcache.Endpoint, vspec blobcache.VolumeSpec) (*blobcache.Handle, error)

CreateVolume creates a new volume.

func (*Service) Delete ¶

func (s *Service) Delete(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error

Delete deletes a CID from the volume

func (*Service) Drop ¶

func (s *Service) Drop(ctx context.Context, h blobcache.Handle) error

func (*Service) Endpoint ¶

func (s *Service) Endpoint(ctx context.Context) (blobcache.Endpoint, error)

Endpoint returns the endpoint of the remote service.

func (*Service) Exists ¶

func (s *Service) Exists(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, dst []bool) error

Exists checks if a CID exists in the volume

func (*Service) Get ¶

func (s *Service) Get(ctx context.Context, tx blobcache.Handle, cid blobcache.CID, buf []byte, opts blobcache.GetOpts) (int, error)

Get returns the data for a CID.

func (*Service) Insert ¶

func (s *Service) Insert(ctx context.Context, from *blobcache.Endpoint, qh blobcache.Handle, msgs []blobcache.Message) (*blobcache.InsertResp, error)

func (*Service) InspectHandle ¶

func (s *Service) InspectHandle(ctx context.Context, h blobcache.Handle) (*blobcache.HandleInfo, error)

func (*Service) InspectTx ¶

func (s *Service) InspectTx(ctx context.Context, tx blobcache.Handle) (*blobcache.TxInfo, error)

InspectTx returns info about a transaction.

func (*Service) InspectVolume ¶

func (s *Service) InspectVolume(ctx context.Context, h blobcache.Handle) (*blobcache.VolumeInfo, error)

InspectVolume returns info about a Volume.

func (*Service) IsVisited ¶

func (s *Service) IsVisited(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, dst []bool) error

func (*Service) KeepAlive ¶

func (s *Service) KeepAlive(ctx context.Context, hs []blobcache.Handle) error

func (*Service) Link ¶

func (s *Service) Link(ctx context.Context, tx blobcache.Handle, subvol blobcache.Handle, mask blobcache.ActionSet) error

Link allows the Volume to reference another volume.

func (*Service) Load ¶

func (s *Service) Load(ctx context.Context, tx blobcache.Handle, dst *[]byte) error

Load loads the volume root into dst

func (*Service) Next ¶

func (s *Service) Next(ctx context.Context, qh blobcache.Handle, buf []blobcache.Message, opts blobcache.NextOpts) (int, error)

func (*Service) OpenFiat ¶

func (s *Service) OpenFiat(ctx context.Context, target blobcache.OID, mask blobcache.ActionSet) (*blobcache.Handle, error)

func (*Service) OpenFrom ¶

func (s *Service) OpenFrom(ctx context.Context, base blobcache.Handle, target blobcache.OID, mask blobcache.ActionSet) (*blobcache.Handle, error)

func (*Service) Post ¶

func (s *Service) Post(ctx context.Context, tx blobcache.Handle, data []byte, opts blobcache.PostOpts) (blobcache.CID, error)

Post posts data to the volume

func (*Service) Save ¶

func (s *Service) Save(ctx context.Context, tx blobcache.Handle, src []byte) error

Save writes to the volume root.

func (*Service) Share ¶

func (s *Service) Share(ctx context.Context, h blobcache.Handle, to blobcache.PeerID, mask blobcache.ActionSet) (*blobcache.Handle, error)

func (*Service) SubToVolume ¶

func (s *Service) SubToVolume(ctx context.Context, qh blobcache.Handle, volh blobcache.Handle) error

func (*Service) Unlink ¶

func (s *Service) Unlink(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error

func (*Service) Visit ¶

func (s *Service) Visit(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error

func (*Service) VisitLinks ¶

func (s *Service) VisitLinks(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error