chunkinfo

package
v1.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 21, 2022 License: BSD-3-Clause Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PullMax    = 200
	PullingMax = 10
	PullerMax  = 1000
)
View Source 
const (
	TimeOut = 30
	Time    = 5
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BitVector added in v1.3.0 

type BitVector struct {
	Len int    `json:"len"`
	B   []byte `json:"b"`
}

type BitVectorInfo added in v1.3.0 

type BitVectorInfo struct {
	RootCid   boson.Address
	Overlay   boson.Address
	Bitvector BitVector
}

type ChunkInfo 

type ChunkInfo struct {
	// contains filtered or unexported fields
}

func New 

func New(addr boson.Address, streamer p2p.Streamer, logger logging.Logger, traversal traversal.Traverser, storer storage.StateStorer, route routetab.RouteTab, oracleChain chain.Resolver) *ChunkInfo

func (*ChunkInfo) API added in v1.3.0 

func (ci *ChunkInfo) API() rpc.API

func (*ChunkInfo) CancelFindChunkInfo 

func (ci *ChunkInfo) CancelFindChunkInfo(rootCid boson.Address)

func (*ChunkInfo) DelChunkInfoSource added in v1.1.6 

func (ci *ChunkInfo) DelChunkInfoSource(rootCid boson.Address) bool

func (*ChunkInfo) DelDiscover added in v1.0.9 

func (ci *ChunkInfo) DelDiscover(rootCid boson.Address)

func (*ChunkInfo) DelFile 

func (ci *ChunkInfo) DelFile(rootCid boson.Address, del func()) bool

func (*ChunkInfo) FindChunkInfo 

func (ci *ChunkInfo) FindChunkInfo(ctx context.Context, authInfo []byte, rootCid boson.Address, overlays []boson.Address) bool

func (*ChunkInfo) GetChunkInfo 

func (ci *ChunkInfo) GetChunkInfo(rootCid boson.Address, cid boson.Address) []aco.Route

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 (ci *ChunkInfo) GetFileList(overlay boson.Address) (fileListInfo []map[string]interface{}, rootList []boson.Address)

func (*ChunkInfo) Init 

func (ci *ChunkInfo) Init(ctx context.Context, authInfo []byte, rootCid boson.Address) bool

func (*ChunkInfo) InitChunkInfo 

func (ci *ChunkInfo) InitChunkInfo() error

func (*ChunkInfo) IsDiscover 

func (ci *ChunkInfo) IsDiscover(rootCid boson.Address) bool

func (*ChunkInfo) Metrics 

func (ci *ChunkInfo) Metrics() []prometheus.Collector

func (*ChunkInfo) OnChunkRetrieved added in v1.1.7 

func (ci *ChunkInfo) OnChunkRetrieved(cid, rootCid, sourceOverlay boson.Address) error

func (*ChunkInfo) OnChunkTransferred 

func (ci *ChunkInfo) OnChunkTransferred(cid, rootCid boson.Address, overlay, target boson.Address) error

func (*ChunkInfo) Protocol 

func (ci *ChunkInfo) Protocol() p2p.ProtocolSpec

func (*ChunkInfo) Publish added in v1.3.0 

func (ci *ChunkInfo) Publish(key string, data interface{})

func (*ChunkInfo) Subscribe added in v1.3.0 

func (ci *ChunkInfo) Subscribe(key string, c chan interface{})

func (*ChunkInfo) SubscribeDownloadProgress added in v1.3.0 

func (ci *ChunkInfo) SubscribeDownloadProgress(rootCids []boson.Address) (c <-chan interface{}, unsubscribe func(), err error)

func (*ChunkInfo) SubscribeRetrievalProgress added in v1.3.0 

func (ci *ChunkInfo) SubscribeRetrievalProgress(rootCid boson.Address) (c <-chan interface{}, unsubscribe func(), err error)

func (*ChunkInfo) SubscribeRootCidStatus added in v1.3.0 

func (ci *ChunkInfo) SubscribeRootCidStatus() (c <-chan interface{}, unsubscribe func())

func (*ChunkInfo) UnSubscribe added in v1.3.0 

func (ci *ChunkInfo) UnSubscribe(key string, ch chan interface{})

func (*ChunkInfo) UpdateChunkInfoSource added in v1.1.6 

func (ci *ChunkInfo) UpdateChunkInfoSource(rootCid, sourceOverlay boson.Address, cid boson.Address) error

func (*ChunkInfo) UpdatePyramidSource added in v1.1.6 

func (ci *ChunkInfo) UpdatePyramidSource(rootCid, sourceOverlay boson.Address) error

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()) bool

	DelDiscover(rootCid boson.Address)

	OnChunkRetrieved(cid, rootCid, sourceOverlay boson.Address) error

	GetChunkInfoSource(rootCid boson.Address) aurora.ChunkInfoSourceApi
}

type Pull 

type Pull = uint32
const (
	UnPull Pull = iota
	Pulling
	Pulled
)

type PyramidCidNum 

type PyramidCidNum struct {
	Cid    boson.Address
	Number int
}

type Response 

type Response struct {
	StatusCode int             `json:"code"`
	Message    string          `json:"msg"`
	Body       RootCIDResponse `json:"data"`
}

type RootCIDResponse 

type RootCIDResponse struct {
	RootCID   string   `json:"rootcid"`
	Addresses []string `json:"addresses"`
}

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

View all Source files

Directories

Path Synopsis
Package pb holds only Protocol Buffer definitions and generated code.
 Package pb holds only Protocol Buffer definitions and generated code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.