Documentation
¶
Overview ¶
Package bchttp implements a Blobcache service over HTTP.
Index ¶
- type AbortReq
- type AbortResp
- type AddFromReq
- type AddFromResp
- type BeginTxReq
- type BeginTxResp
- type Client
- func (c *Client) Abort(ctx context.Context, tx blobcache.Handle) error
- func (c *Client) BeginTx(ctx context.Context, vol blobcache.Handle, txp blobcache.TxParams) (*blobcache.Handle, error)
- func (c *Client) CloneVolume(ctx context.Context, caller *blobcache.PeerID, vol blobcache.Handle) (*blobcache.Handle, error)
- func (c *Client) Commit(ctx context.Context, tx blobcache.Handle) error
- func (c *Client) Copy(ctx context.Context, tx blobcache.Handle, srcs []blobcache.Handle, ...) error
- func (c *Client) CreateQueue(ctx context.Context, host *blobcache.Endpoint, qspec blobcache.QueueSpec) (*blobcache.Handle, error)
- func (c *Client) CreateVolume(ctx context.Context, host *blobcache.Endpoint, vspec blobcache.VolumeSpec) (*blobcache.Handle, error)
- func (c *Client) Delete(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error
- func (c *Client) Drop(ctx context.Context, h blobcache.Handle) error
- func (c *Client) Endpoint(ctx context.Context) (blobcache.Endpoint, error)
- func (c *Client) Exists(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, dst []bool) error
- func (c *Client) Get(ctx context.Context, tx blobcache.Handle, cid blobcache.CID, buf []byte, ...) (int, error)
- func (c *Client) Insert(ctx context.Context, from *blobcache.Endpoint, q blobcache.Handle, ...) (*blobcache.InsertResp, error)
- func (c *Client) InspectHandle(ctx context.Context, h blobcache.Handle) (*blobcache.HandleInfo, error)
- func (c *Client) InspectTx(ctx context.Context, tx blobcache.Handle) (*blobcache.TxInfo, error)
- func (c *Client) InspectVolume(ctx context.Context, h blobcache.Handle) (*blobcache.VolumeInfo, error)
- func (c *Client) IsVisited(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID, out []bool) error
- func (c *Client) KeepAlive(ctx context.Context, hs []blobcache.Handle) error
- func (c *Client) Link(ctx context.Context, tx blobcache.Handle, subvol blobcache.Handle, ...) error
- func (c *Client) Load(ctx context.Context, tx blobcache.Handle, dst *[]byte) error
- func (c *Client) Next(ctx context.Context, q blobcache.Handle, buf []blobcache.Message, ...) (int, error)
- func (c *Client) OpenFiat(ctx context.Context, target blobcache.OID, mask blobcache.ActionSet) (*blobcache.Handle, error)
- func (c *Client) OpenFrom(ctx context.Context, base blobcache.Handle, target blobcache.OID, ...) (*blobcache.Handle, error)
- func (c *Client) Post(ctx context.Context, tx blobcache.Handle, data []byte, opts blobcache.PostOpts) (blobcache.CID, error)
- func (c *Client) Save(ctx context.Context, tx blobcache.Handle, root []byte) error
- func (c *Client) Share(ctx context.Context, h blobcache.Handle, to blobcache.PeerID, ...) (*blobcache.Handle, error)
- func (c *Client) SubToVolume(ctx context.Context, q blobcache.Handle, vol blobcache.Handle) error
- func (c *Client) Unlink(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error
- func (c *Client) Visit(ctx context.Context, tx blobcache.Handle, cids []blobcache.CID) error
- func (c *Client) VisitLinks(ctx context.Context, tx blobcache.Handle, targets []blobcache.OID) error
- type CloneVolumeReq
- type CloneVolumeResp
- type CommitReq
- type CommitResp
- type CreateQueueReq
- type CreateQueueResp
- type CreateVolumeReq
- type CreateVolumeResp
- type DeleteReq
- type DeleteResp
- type DropReq
- type DropResp
- type EndpointReq
- type EndpointResp
- type ExistsReq
- type ExistsResp
- type GetReq
- type InsertReq
- type InspectHandleReq
- type InspectHandleResp
- type InspectTxReq
- type InspectTxResp
- type InspectVolumeReq
- type IsVisitedReq
- type IsVisitedResp
- type KeepAliveReq
- type KeepAliveResp
- type LinkReq
- type LinkResp
- type LoadReq
- type LoadResp
- type NextReq
- type NextResp
- type OpenFiatReq
- type OpenFiatResp
- type OpenFromReq
- type OpenFromResp
- type SaveReq
- type SaveResp
- type Server
- type ShareReq
- type ShareResp
- type SubToVolumeReq
- type SubToVolumeResp
- type UnlinkReq
- type UnlinkResp
- type VisitLinksReq
- type VisitLinksResp
- type VisitReq
- type VisitResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddFromReq ¶
type AddFromResp ¶
type AddFromResp struct {
Added []bool `json:"added"`
}
type BeginTxReq ¶
type BeginTxResp ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CloneVolume ¶
func (*Client) CreateQueue ¶
func (*Client) CreateVolume ¶
func (*Client) InspectHandle ¶
func (*Client) InspectVolume ¶
func (*Client) SubToVolume ¶
type CloneVolumeReq ¶
type CloneVolumeResp ¶
type CommitResp ¶
type CommitResp struct{}
type CreateQueueReq ¶
type CreateQueueResp ¶
type CreateVolumeReq ¶
type CreateVolumeReq struct {
Host *blobcache.Endpoint `json:"host,omitempty"`
Spec blobcache.VolumeSpec `json:"spec"`
}
type CreateVolumeResp ¶
type DeleteResp ¶
type DeleteResp struct{}
type EndpointReq ¶
type EndpointReq struct{}
type EndpointResp ¶
type ExistsResp ¶
type ExistsResp struct {
Exists []bool `json:"exists"`
}
type InspectHandleReq ¶
Handle messages.
type InspectHandleResp ¶
type InspectHandleResp struct {
Info blobcache.HandleInfo `json:"info"`
}
type InspectTxReq ¶
type InspectTxResp ¶
type InspectVolumeReq ¶
type IsVisitedReq ¶
type IsVisitedResp ¶
type IsVisitedResp struct {
Visited []bool `json:"visited"`
}
type KeepAliveReq ¶
type KeepAliveResp ¶
type KeepAliveResp struct{}
type OpenFiatReq ¶
type OpenFiatResp ¶
type OpenFiatResp struct {
Handle blobcache.Handle `json:"handle"`
Info blobcache.VolumeInfo `json:"info"`
}
type OpenFromReq ¶
type OpenFromResp ¶
type OpenFromResp struct {
Handle blobcache.Handle `json:"handle"`
Info blobcache.VolumeInfo `json:"info"`
}
type SubToVolumeReq ¶
type SubToVolumeResp ¶
type SubToVolumeResp struct{}
type UnlinkResp ¶
type UnlinkResp struct{}
type VisitLinksReq ¶
type VisitLinksResp ¶
type VisitLinksResp struct{}
Click to show internal directories.
Click to hide internal directories.