sealing

Documentation

Index

• Constants
• type ErrApi
• type ErrBadCommD
• type ErrExpiredDeals
• type ErrExpiredTicket
• type ErrInvalidDeals
• type Log
  • func (t *Log) MarshalCBOR(w io.Writer) error
  • func (t *Log) UnmarshalCBOR(r io.Reader) error
• type Piece
  • func (t *Piece) MarshalCBOR(w io.Writer) error
  • func (t *Piece) UnmarshalCBOR(r io.Reader) error
• type SealSeed
  • func (t *SealSeed) Equals(o *SealSeed) bool
  • func (t *SealSeed) MarshalCBOR(w io.Writer) error
  • func (t *SealSeed) SB() sectorbuilder.SealSeed
  • func (t *SealSeed) UnmarshalCBOR(r io.Reader) error
• type SealTicket
  • func (t *SealTicket) MarshalCBOR(w io.Writer) error
  • func (t *SealTicket) SB() sectorbuilder.SealTicket
  • func (t *SealTicket) UnmarshalCBOR(r io.Reader) error
• type Sealing
  • func New(api sealingApi, events *events.Events, maddr address.Address, ...) *Sealing
  • func (m *Sealing) AllocatePiece(size uint64) (sectorID uint64, offset uint64, err error)
  • func (m *Sealing) ForceSectorState(ctx context.Context, id uint64, state api.SectorState) error
  • func (m *Sealing) GetSectorInfo(sid uint64) (SectorInfo, error)
  • func (m *Sealing) ListSectors() ([]SectorInfo, error)
  • func (m *Sealing) Plan(events []statemachine.Event, user interface{}) (interface{}, error)
  • func (m *Sealing) PledgeSector() error
  • func (m *Sealing) Run(ctx context.Context) error
  • func (m *Sealing) SealPiece(ctx context.Context, size uint64, r io.Reader, sectorID uint64, dealID uint64) error
  • func (m *Sealing) Stop(ctx context.Context) error
• type SectorCommitFailed
• type SectorCommitted
• type SectorComputeProofFailed
• type SectorFatalError
• type SectorFaultReported
• type SectorFaultedFinal
• type SectorFaulty
• type SectorForceState
• type SectorInfo
  • func (t *SectorInfo) MarshalCBOR(w io.Writer) error
  • func (t *SectorInfo) UnmarshalCBOR(r io.Reader) error
• type SectorPacked
• type SectorPackingFailed
• type SectorPreCommitFailed
• type SectorPreCommitted
• type SectorProving
• type SectorRestart
• type SectorRetryPreCommit
• type SectorRetrySeal
• type SectorRetryWaitSeed
• type SectorSealFailed
• type SectorSealed
• type SectorSeedReady
• type SectorStart
• type TicketFn

Constants

const SectorStorePrefix = "/sectors"

Types

type ErrApi

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

TODO: For now we handle this by halting state execution, when we get jsonrpc reconnecting

We should implement some wait-for-api logic

type ErrBadCommD

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

type ErrExpiredDeals

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

type ErrExpiredTicket

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

type ErrInvalidDeals

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

type Log

type Log struct {
	Timestamp uint64
	Trace     string // for errors

	Message string

	// additional data (Event info)
	Kind string
}

func (*Log) MarshalCBOR

func (t *Log) MarshalCBOR(w io.Writer) error

func (*Log) UnmarshalCBOR

func (t *Log) UnmarshalCBOR(r io.Reader) error

type Piece

type Piece struct {
	DealID uint64

	Size  uint64
	CommP []byte
}

func (*Piece) MarshalCBOR

func (t *Piece) MarshalCBOR(w io.Writer) error

func (*Piece) UnmarshalCBOR

func (t *Piece) UnmarshalCBOR(r io.Reader) error

type SealSeed

type SealSeed struct {
	BlockHeight uint64
	TicketBytes []byte
}

func (*SealSeed) Equals

func (t *SealSeed) Equals(o *SealSeed) bool

func (*SealSeed) MarshalCBOR

func (t *SealSeed) MarshalCBOR(w io.Writer) error

func (*SealSeed) SB

func (t *SealSeed) SB() sectorbuilder.SealSeed

func (*SealSeed) UnmarshalCBOR

func (t *SealSeed) UnmarshalCBOR(r io.Reader) error

type SealTicket

type SealTicket struct {
	BlockHeight uint64
	TicketBytes []byte
}

func (*SealTicket) MarshalCBOR

func (t *SealTicket) MarshalCBOR(w io.Writer) error

func (*SealTicket) SB

func (t *SealTicket) SB() sectorbuilder.SealTicket

func (*SealTicket) UnmarshalCBOR

func (t *SealTicket) UnmarshalCBOR(r io.Reader) error

type Sealing

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

func New

func New(api sealingApi, events *events.Events, maddr address.Address, worker address.Address, ds datastore.Batching, sb sectorbuilder.Interface, tktFn TicketFn) *Sealing

func (*Sealing) AllocatePiece

func (m *Sealing) AllocatePiece(size uint64) (sectorID uint64, offset uint64, err error)

func (*Sealing) ForceSectorState

func (m *Sealing) ForceSectorState(ctx context.Context, id uint64, state api.SectorState) error

func (*Sealing) GetSectorInfo

func (m *Sealing) GetSectorInfo(sid uint64) (SectorInfo, error)

func (*Sealing) ListSectors

func (m *Sealing) ListSectors() ([]SectorInfo, error)

func (*Sealing) Plan

func (m *Sealing) Plan(events []statemachine.Event, user interface{}) (interface{}, error)

func (*Sealing) PledgeSector

func (m *Sealing) PledgeSector() error

func (*Sealing) Run

func (m *Sealing) Run(ctx context.Context) error

func (*Sealing) SealPiece

func (m *Sealing) SealPiece(ctx context.Context, size uint64, r io.Reader, sectorID uint64, dealID uint64) error

func (*Sealing) Stop

func (m *Sealing) Stop(ctx context.Context) error

type SectorCommitFailed

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

type SectorCommitted

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

type SectorComputeProofFailed

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

type SectorFatalError

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

type SectorFaultReported

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

type SectorFaultedFinal

type SectorFaultedFinal struct{}

type SectorFaulty

type SectorFaulty struct{}

type SectorForceState

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

type SectorInfo

type SectorInfo struct {
	State    api.SectorState
	SectorID uint64
	Nonce    uint64 // TODO: remove

	Pieces []Piece

	// PreCommit
	CommD  []byte
	CommR  []byte
	Proof  []byte
	Ticket SealTicket

	PreCommitMessage *cid.Cid

	// WaitSeed
	Seed SealSeed

	// Committing
	CommitMessage *cid.Cid

	// Faults
	FaultReportMsg *cid.Cid

	// Debug
	LastErr string

	Log []Log
}

func (*SectorInfo) MarshalCBOR

func (t *SectorInfo) MarshalCBOR(w io.Writer) error

func (*SectorInfo) UnmarshalCBOR

func (t *SectorInfo) UnmarshalCBOR(r io.Reader) error

type SectorPacked

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

type SectorPackingFailed

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

type SectorPreCommitFailed

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

type SectorPreCommitted

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

type SectorProving

type SectorProving struct{}

type SectorRestart

type SectorRestart struct{}

type SectorRetryPreCommit

type SectorRetryPreCommit struct{}

type SectorRetrySeal

type SectorRetrySeal struct{}

type SectorRetryWaitSeed

type SectorRetryWaitSeed struct{}

type SectorSealFailed

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

type SectorSealed

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

type SectorSeedReady

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

type SectorStart

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

type TicketFn

type TicketFn func(context.Context) (*sectorbuilder.SealTicket, error)