chunkinfo

Documentation

Index

• Constants
• type ChunkInfo
  • func New(addr boson.Address, streamer p2p.Streamer, logger logging.Logger, ...) *ChunkInfo
  • 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()) bool
  • 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]*aurora.FileInfo, rootList []boson.Address)
  • func (ci *ChunkInfo) Init(ctx context.Context, authInfo []byte, rootCid boson.Address) bool
  • func (ci *ChunkInfo) InitChunkInfo() error
  • func (ci *ChunkInfo) IsDiscover(rootCid boson.Address) bool
  • 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) UpdateChunkInfoSource(rootCid, sourceOverlay boson.Address, cid boson.Address) error
  • func (ci *ChunkInfo) UpdatePyramidSource(rootCid, sourceOverlay boson.Address) error
• type Interface
• type Pull
• type PyramidCidNum
• type Response
• type RootCIDResponse

Constants

const (
	PullMax    = 200
	PullingMax = 10
	PullerMax  = 1000
)

const (
	TimeOut = 30
	Time    = 5
)

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 chain.Resolver) *ChunkInfo

New

func (*ChunkInfo) CancelFindChunkInfo

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

CancelFindChunkInfo

func (*ChunkInfo) DelChunkInfoSource

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

func (*ChunkInfo) DelDiscover

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

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

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]*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) OnChunkRetrieved

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

Record every chunk source.

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

func (*ChunkInfo) UpdateChunkInfoSource

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

func (*ChunkInfo) UpdatePyramidSource

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]*aurora.FileInfo, 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"`
}