Versions in this module Expand all Collapse all v0 v0.0.2 Dec 15, 2025 v0.0.1 Nov 25, 2025 Changes in this version + type Service struct + func Dial(privateKey ed25519.PrivateKey, ep blobcache.Endpoint) (*Service, error) + func New(privateKey ed25519.PrivateKey, pc net.PacketConn, ep blobcache.Endpoint) *Service + func (s *Service) Abort(ctx context.Context, tx blobcache.Handle) error + func (s *Service) AwaitReady(ctx context.Context) error + func (s *Service) BeginTx(ctx context.Context, volh blobcache.Handle, txp blobcache.TxParams) (*blobcache.Handle, error) + func (s *Service) CloneVolume(ctx context.Context, caller *blobcache.PeerID, volh blobcache.Handle) (*blobcache.Handle, error) + func (s *Service) Close() error + func (s *Service) Commit(ctx context.Context, tx blobcache.Handle) error + func (s *Service) Copy(ctx context.Context, tx blobcache.Handle, srcTxns []blobcache.Handle, ...) error + func (s *Service) CreateQueue(ctx context.Context, _ *blobcache.Endpoint, qspec blobcache.QueueSpec) (*blobcache.Handle, error) + func (s *Service) CreateVolume(ctx context.Context, host *blobcache.Endpoint, vspec blobcache.VolumeSpec) (*blobcache.Handle, error) + func (s *Service) Delete(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error + func (s *Service) Drop(ctx context.Context, h blobcache.Handle) error + func (s *Service) Endpoint(ctx context.Context) (blobcache.Endpoint, error) + func (s *Service) Exists(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, dst []bool) error + func (s *Service) Get(ctx context.Context, tx blobcache.Handle, cid blobcache.CID, buf []byte, ...) (int, error) + func (s *Service) Insert(ctx context.Context, from *blobcache.Endpoint, qh blobcache.Handle, ...) (*blobcache.InsertResp, error) + func (s *Service) InspectHandle(ctx context.Context, h blobcache.Handle) (*blobcache.HandleInfo, error) + func (s *Service) InspectTx(ctx context.Context, tx blobcache.Handle) (*blobcache.TxInfo, error) + func (s *Service) InspectVolume(ctx context.Context, h blobcache.Handle) (*blobcache.VolumeInfo, error) + func (s *Service) IsVisited(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, dst []bool) error + func (s *Service) KeepAlive(ctx context.Context, hs []blobcache.Handle) error + func (s *Service) Link(ctx context.Context, tx blobcache.Handle, subvol blobcache.Handle, ...) error + func (s *Service) Load(ctx context.Context, tx blobcache.Handle, dst *[]byte) error + func (s *Service) Next(ctx context.Context, qh blobcache.Handle, buf []blobcache.Message, ...) (int, error) + func (s *Service) OpenFiat(ctx context.Context, target blobcache.OID, mask blobcache.ActionSet) (*blobcache.Handle, error) + func (s *Service) OpenFrom(ctx context.Context, base blobcache.Handle, target blobcache.OID, ...) (*blobcache.Handle, error) + func (s *Service) Post(ctx context.Context, tx blobcache.Handle, data []byte, opts blobcache.PostOpts) (blobcache.CID, error) + func (s *Service) Save(ctx context.Context, tx blobcache.Handle, src []byte) error + func (s *Service) Share(ctx context.Context, h blobcache.Handle, to blobcache.PeerID, ...) (*blobcache.Handle, error) + func (s *Service) SubToVolume(ctx context.Context, qh blobcache.Handle, volh blobcache.Handle) error + func (s *Service) Unlink(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error + func (s *Service) Visit(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error + func (s *Service) VisitLinks(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error
Go to main page