operation

package
v0.2.4 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2022 License: Apache-2.0, MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func UnSerializePeers

func UnSerializePeers(prs []AddrInfoString) []*peer.AddrInfo

Types

type AddrInfoString

type AddrInfoString struct {
	ID    string
	Addrs []string
}

func SerializePeers

func SerializePeers(peers []*peer.AddrInfo) []AddrInfoString

type PinningOperation

type PinningOperation struct {
	Obj   cid.Cid
	Name  string
	Peers []AddrInfoString
	Meta  string

	Status types.PinningStatus

	UserId  uint
	ContId  uint
	Replace uint

	LastUpdate time.Time

	Started     time.Time
	NumFetched  int
	SizeFetched int64
	FetchErr    error
	EndTime     time.Time

	Location string

	SkipLimiter bool

	MakeDeal bool
	// contains filtered or unexported fields
}

TODO: some of these fields are overkill for the generalized pin manager thing, but are still in use by the primary estuary node. Should probably find a way to decouple this better

func (*PinningOperation) Complete

func (po *PinningOperation) Complete()

func (*PinningOperation) Fail

func (po *PinningOperation) Fail(err error)

func (*PinningOperation) SetStatus

func (po *PinningOperation) SetStatus(st types.PinningStatus)

func (*PinningOperation) UpdateProgress

func (po *PinningOperation) UpdateProgress(size int64)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL