chunkinfo

package
v1.1.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Oct 27, 2021 License: BSD-3-Clause Imports: 22 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 ChunkInfo

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

ChunkInfo

func New

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

New

func (*ChunkInfo) CancelFindChunkInfo

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

CancelFindChunkInfo

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

func (*ChunkInfo) DelPyramid

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

func (*ChunkInfo) FindChunkInfo

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

FindChunkInfo

func (*ChunkInfo) GetChunkInfo

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

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) GetChunkPyramid

func (ci *ChunkInfo) GetChunkPyramid(rootCid boson.Address) []*PyramidCidNum

func (*ChunkInfo) GetFileList

func (ci *ChunkInfo) GetFileList(overlay boson.Address) (fileListInfo map[string]*aurora.FileInfo, 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) OnChunkTransferred

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

OnChunkTransferred

func (*ChunkInfo) Protocol

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

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]*aurora.FileInfo, rootList []boson.Address)

	DelFile(rootCid boson.Address) bool

	DelDiscover(rootCid boson.Address)

	DelPyramid(rootCid boson.Address) bool
}

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"`
}

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