Documentation ¶
Index ¶
- Constants
- Variables
- type BitVector
- type BitVectorInfo
- type ChunkInfo
- func (ci *ChunkInfo) API() rpc.API
- func (ci *ChunkInfo) CancelFindChunkInfo(rootCid boson.Address)
- func (ci *ChunkInfo) DelChunkInfoSource(rootCid boson.Address) bool
- func (ci *ChunkInfo) DelDiscover(rootCid boson.Address)
- func (ci *ChunkInfo) DelFile(rootCid boson.Address, del func() error) error
- func (ci *ChunkInfo) DelManifest(key string)
- func (ci *ChunkInfo) FindChunkInfo(ctx context.Context, authInfo []byte, rootCid boson.Address, ...) bool
- func (ci *ChunkInfo) GetChunkInfo(rootCid boson.Address, cid boson.Address) []aco.Route
- func (ci *ChunkInfo) GetChunkInfoDiscoverOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay
- func (ci *ChunkInfo) GetChunkInfoServerOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay
- func (ci *ChunkInfo) GetChunkInfoSource(rootCid boson.Address) aurora.ChunkInfoSourceApi
- func (ci *ChunkInfo) GetChunkPyramid(rootCid boson.Address) []*PyramidCidNum
- func (ci *ChunkInfo) GetFileList(overlay boson.Address) (fileListInfo []map[string]interface{}, rootList []boson.Address)
- func (ci *ChunkInfo) GetManifest(rootCid, pathVar string, depth int) (maniFest *ManifestNode)
- func (ci *ChunkInfo) Init(ctx context.Context, authInfo []byte, rootCid boson.Address) bool
- func (ci *ChunkInfo) InitChunkInfo() error
- func (ci *ChunkInfo) InitManifest()
- func (ci *ChunkInfo) IsDiscover(rootCid boson.Address) bool
- func (ci *ChunkInfo) ManifestView(ctx context.Context, nameOrHex, pathVar string, depth int) (*ManifestNode, error)
- func (ci *ChunkInfo) Metrics() []prometheus.Collector
- func (ci *ChunkInfo) OnChunkRetrieved(cid, rootCid, sourceOverlay boson.Address) error
- func (ci *ChunkInfo) OnChunkTransferred(cid, rootCid boson.Address, overlay, target boson.Address) error
- func (ci *ChunkInfo) Protocol() p2p.ProtocolSpec
- func (ci *ChunkInfo) PublishDownloadProgress(rootCid boson.Address, bitV BitVectorInfo)
- func (ci *ChunkInfo) PublishRetrievalProgress(rootCid boson.Address, bitV BitVectorInfo)
- func (ci *ChunkInfo) PublishRootCidStatus(statusEvent RootCidStatusEven)
- func (ci *ChunkInfo) SubscribeDownloadProgress(notifier *rpc.Notifier, sub *rpc.Subscription, rootCids []boson.Address)
- func (ci *ChunkInfo) SubscribeRetrievalProgress(notifier *rpc.Notifier, sub *rpc.Subscription, rootCid boson.Address)
- func (ci *ChunkInfo) SubscribeRootCidStatus(notifier *rpc.Notifier, sub *rpc.Subscription)
- func (ci *ChunkInfo) UpdateChunkInfoSource(rootCid, sourceOverlay boson.Address, cid boson.Address) error
- func (ci *ChunkInfo) UpdatePyramidSource(rootCid, sourceOverlay boson.Address) error
- type Interface
- type ManifestNode
- type Pull
- type PyramidCidNum
- type Response
- type RootCIDResponse
- type RootCidStatus
- type RootCidStatusEven
Constants ¶
View Source
const ( PullMax = 200 PullingMax = 10 PullerMax = 1000 )
View Source
const ( TimeOut = 30 Time = 5 )
Variables ¶
Functions ¶
This section is empty.
Types ¶
type BitVectorInfo ¶ added in v1.3.0
type ChunkInfo ¶
type ChunkInfo struct {
// contains filtered or unexported fields
}
func (*ChunkInfo) CancelFindChunkInfo ¶
func (*ChunkInfo) DelChunkInfoSource ¶ added in v1.1.6
func (*ChunkInfo) DelDiscover ¶ added in v1.0.9
func (*ChunkInfo) DelManifest ¶ added in v1.3.5
func (*ChunkInfo) FindChunkInfo ¶
func (*ChunkInfo) GetChunkInfo ¶
func (*ChunkInfo) GetChunkInfoDiscoverOverlays ¶
func (ci *ChunkInfo) GetChunkInfoDiscoverOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay
func (*ChunkInfo) GetChunkInfoServerOverlays ¶
func (ci *ChunkInfo) GetChunkInfoServerOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay
func (*ChunkInfo) GetChunkInfoSource ¶ added in v1.1.6
func (ci *ChunkInfo) GetChunkInfoSource(rootCid boson.Address) aurora.ChunkInfoSourceApi
func (*ChunkInfo) GetChunkPyramid ¶
func (ci *ChunkInfo) GetChunkPyramid(rootCid boson.Address) []*PyramidCidNum
func (*ChunkInfo) GetFileList ¶
func (*ChunkInfo) GetManifest ¶ added in v1.3.5
func (ci *ChunkInfo) GetManifest(rootCid, pathVar string, depth int) (maniFest *ManifestNode)
func (*ChunkInfo) InitChunkInfo ¶
func (*ChunkInfo) InitManifest ¶ added in v1.3.5
func (ci *ChunkInfo) InitManifest()
func (*ChunkInfo) ManifestView ¶ added in v1.3.5
func (*ChunkInfo) Metrics ¶
func (ci *ChunkInfo) Metrics() []prometheus.Collector
func (*ChunkInfo) OnChunkRetrieved ¶ added in v1.1.7
func (*ChunkInfo) OnChunkTransferred ¶
func (*ChunkInfo) Protocol ¶
func (ci *ChunkInfo) Protocol() p2p.ProtocolSpec
func (*ChunkInfo) PublishDownloadProgress ¶ added in v1.3.5
func (ci *ChunkInfo) PublishDownloadProgress(rootCid boson.Address, bitV BitVectorInfo)
func (*ChunkInfo) PublishRetrievalProgress ¶ added in v1.3.5
func (ci *ChunkInfo) PublishRetrievalProgress(rootCid boson.Address, bitV BitVectorInfo)
func (*ChunkInfo) PublishRootCidStatus ¶ added in v1.3.5
func (ci *ChunkInfo) PublishRootCidStatus(statusEvent RootCidStatusEven)
func (*ChunkInfo) SubscribeDownloadProgress ¶ added in v1.3.0
func (*ChunkInfo) SubscribeRetrievalProgress ¶ added in v1.3.0
func (*ChunkInfo) SubscribeRootCidStatus ¶ added in v1.3.0
func (ci *ChunkInfo) SubscribeRootCidStatus(notifier *rpc.Notifier, sub *rpc.Subscription)
func (*ChunkInfo) UpdateChunkInfoSource ¶ added in v1.1.6
type Interface ¶
type Interface interface { FindChunkInfo(ctx context.Context, authInfo []byte, rootCid boson.Address, overlays []boson.Address) bool GetChunkInfo(rootCid boson.Address, cid boson.Address) []aco.Route GetChunkInfoDiscoverOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay GetChunkInfoServerOverlays(rootCid boson.Address) []aurora.ChunkInfoOverlay CancelFindChunkInfo(rootCid boson.Address) OnChunkTransferred(cid boson.Address, rootCid boson.Address, overlays, target boson.Address) error Init(ctx context.Context, authInfo []byte, rootCid boson.Address) bool GetChunkPyramid(rootCid boson.Address) []*PyramidCidNum IsDiscover(rootCid boson.Address) bool GetFileList(overlay boson.Address) (fileListInfo []map[string]interface{}, rootList []boson.Address) DelFile(rootCid boson.Address, del func() error) error DelDiscover(rootCid boson.Address) OnChunkRetrieved(cid, rootCid, sourceOverlay boson.Address) error GetChunkInfoSource(rootCid boson.Address) aurora.ChunkInfoSourceApi ManifestView(ctx context.Context, nameOrHex, pathVar string, depth int) (*ManifestNode, error) GetManifest(rootCid, pathVar string, depth int) (maniFest *ManifestNode) }
type ManifestNode ¶ added in v1.3.5
type PyramidCidNum ¶
type Response ¶
type Response struct { StatusCode int `json:"code"` Message string `json:"msg"` Body RootCIDResponse `json:"data"` }
type RootCIDResponse ¶
type RootCidStatus ¶ added in v1.3.0
type RootCidStatus = int
const ( RootCid_DEL RootCidStatus = iota RootCid_ADD )
type RootCidStatusEven ¶ added in v1.3.0
type RootCidStatusEven struct { RootCid boson.Address Status RootCidStatus }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.