block

type BadEncodingError ¶

type BadEncodingError struct{}

BadEncodingError contains all relevant information to generate a BadEncodingFraudProof.

type Block ¶

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

Block represents the entirety of a Block in the Celestia network. It contains the erasure coded block data as well as its ExtendedHeader.

func (b *Block) Commit() *core.Commit

func (b *Block) Data() *ExtendedBlockData

func (b *Block) DataSize() uint

func (b *Block) Header() *header.ExtendedHeader

type ExtendedBlockData ¶

type ExtendedBlockData = rsmt2d.ExtendedDataSquare

ExtendedBlockData is an alias to rsmt2d's ExtendedDataSquare type.

type Fetcher ¶

type Fetcher interface {
	GetBlock(ctx context.Context, height *int64) (*RawBlock, error)
	Commit(ctx context.Context, height *int64) (*core.Commit, error)
	ValidatorSet(ctx context.Context, height *int64) (*core.ValidatorSet, error)
	SubscribeNewBlockEvent(ctx context.Context) (<-chan *RawBlock, error)
	UnsubscribeNewBlockEvent(ctx context.Context) error
}

Fetcher encompasses the behavior necessary to fetch new "raw" blocks.

type RawBlock ¶

type RawBlock = core.Block

RawBlock is an alias to a "raw" Core block. It is "raw" because it is still awaiting erasure coding.

type Service ¶

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

Service represents the Block service that can be started / stopped on a `Full` node. Service contains 4 main functionalities:

1. Fetching "raw" blocks from either Celestia Core or other Celestia Full nodes.
2. Erasure coding the "raw" blocks and producing a DataAvailabilityHeader + verifying the Data root.
3. Storing erasure coded blocks.
4. Serving erasure coded blocks to other `Full` node peers.

TODO @renaynay: add docs about broadcaster

func NewBlockService(fetcher Fetcher, store ipld.DAGService, broadcaster header.Broadcaster) *Service

func (s *Service) GetBlockData(ctx context.Context, dah *da.DataAvailabilityHeader) (*ExtendedBlockData, error)

func (s *Service) Start(ctx context.Context) error

func (s *Service) Stop(ctx context.Context) error

func (s *Service) StoreBlockData(ctx context.Context, data *ExtendedBlockData) error