Documentation ¶
Index ¶
- type RPCClient
- type RPCPool
- type TClient
- type TPool
- type Transport
- func (t *Transport) Check(ids []proto.ID) (res []proto.ID, err error)
- func (t *Transport) Close()
- func (t *Transport) Download(blobs lists.BlobMap) (err error)
- func (t *Transport) GetManifests(ids []proto.ID) (res []proto.Manifest, err error)
- func (t *Transport) GetSpec(id proto.ID) (res proto.Spec, err error)
- func (t *Transport) ServerInfo() (res proto.ServerInfo, err error)
- func (t *Transport) Upload(blobs lists.BlobMap) (err error)
- func (t *Transport) UploadSpec(spec proto.Spec) (err error)
- type Upload
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RPCClient ¶
type RPCClient struct {
// contains filtered or unexported fields
}
type RPCPool ¶
type RPCPool struct { *pools.ResourcePool // contains filtered or unexported fields }
func NewRPCPool ¶
type TPool ¶
type TPool struct { *pools.ResourcePool // contains filtered or unexported fields }
type Transport ¶
type Transport struct { *concurrency.BatchPool // contains filtered or unexported fields }
Common transport with pooled connections
func NewTransport ¶
New RPC pool with default endpoint
func (*Transport) GetManifests ¶
func (*Transport) ServerInfo ¶
func (t *Transport) ServerInfo() (res proto.ServerInfo, err error)
type Upload ¶
type Upload struct { *Transport *uuid.UUID // contains filtered or unexported fields }
func (*Upload) SendCreateUpload ¶
Click to show internal directories.
Click to hide internal directories.