dealtracker

Documentation

Index

• func DealStateStreamFromHTTPRequest(request *http.Request, depth int, decompress bool) (chan *jstream.MetaValue, io.Closer, error)
• type Cid
• type CloserFunc
  • func (c CloserFunc) Close() error
• type Deal
  • func (d Deal) GetState() model.DealState
  • func (d Deal) Key() string
• type DealProposal
• type DealState
• type DealTracker
  • func NewDealTracker(db *gorm.DB, interval time.Duration, dealZstURL string, lotusURL string, ...) DealTracker
  • func (d *DealTracker) Run(ctx context.Context) error

Functions

func DealStateStreamFromHTTPRequest

func DealStateStreamFromHTTPRequest(request *http.Request, depth int, decompress bool) (chan *jstream.MetaValue, io.Closer, error)

Types

type Cid

type Cid struct {
	Root string `json:"/" mapstructure:"/"`
}

type CloserFunc

type CloserFunc func() error

func (CloserFunc) Close

func (c CloserFunc) Close() error

type Deal

type Deal struct {
	Proposal DealProposal
	State    DealState
}

func (Deal) GetState

func (d Deal) GetState() model.DealState

func (Deal) Key

func (d Deal) Key() string

type DealProposal

type DealProposal struct {
	PieceCID             Cid
	PieceSize            int64
	VerifiedDeal         bool
	Client               string
	Provider             string
	Label                string
	StartEpoch           int32
	EndEpoch             int32
	StoragePricePerEpoch string
}

type DealState

type DealState struct {
	SectorStartEpoch int32
	LastUpdatedEpoch int32
	SlashEpoch       int32
}

type DealTracker

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

func NewDealTracker

func NewDealTracker(
	db *gorm.DB,
	interval time.Duration,
	dealZstURL string,
	lotusURL string,
	lotusToken string) DealTracker

func (*DealTracker) Run

func (d *DealTracker) Run(ctx context.Context) error