core

Documentation

Index

• type Exchange
  • func NewExchange(fetcher *core.BlockFetcher, dag format.DAGService, ...) *Exchange
  • func (ce *Exchange) RequestByHash(ctx context.Context, hash tmbytes.HexBytes) (*header.ExtendedHeader, error)
  • func (ce *Exchange) RequestHead(ctx context.Context) (*header.ExtendedHeader, error)
  • func (ce *Exchange) RequestHeader(ctx context.Context, height uint64) (*header.ExtendedHeader, error)
  • func (ce *Exchange) RequestHeaders(ctx context.Context, from, amount uint64) ([]*header.ExtendedHeader, error)
• type Listener
  • func NewListener(bcast header.Broadcaster, fetcher *core.BlockFetcher, dag format.DAGService, ...) *Listener
  • func (cl *Listener) Start(ctx context.Context) error
  • func (cl *Listener) Stop(ctx context.Context) error

Types

type Exchange

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

func NewExchange

func NewExchange(fetcher *core.BlockFetcher, dag format.DAGService, construct header.ConstructFn) *Exchange

func (*Exchange) RequestByHash

func (ce *Exchange) RequestByHash(ctx context.Context, hash tmbytes.HexBytes) (*header.ExtendedHeader, error)

func (*Exchange) RequestHead

func (ce *Exchange) RequestHead(ctx context.Context) (*header.ExtendedHeader, error)

func (*Exchange) RequestHeader

func (ce *Exchange) RequestHeader(ctx context.Context, height uint64) (*header.ExtendedHeader, error)

func (*Exchange) RequestHeaders

func (ce *Exchange) RequestHeaders(ctx context.Context, from, amount uint64) ([]*header.ExtendedHeader, error)

type Listener

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

Listener is responsible for listening to Core for new block events and converting new Core blocks into the main data structure used in the Celestia DA network: `ExtendedHeader`. After digesting the Core block, extending it, and generating the `ExtendedHeader`, the Listener broadcasts the new `ExtendedHeader` to the header-sub gossipsub network.

func NewListener

func NewListener(
	bcast header.Broadcaster,
	fetcher *core.BlockFetcher,
	dag format.DAGService,
	construct header.ConstructFn,
) *Listener

func (*Listener) Start

func (cl *Listener) Start(ctx context.Context) error

Start kicks off the Listener listener loop.

func (*Listener) Stop

func (cl *Listener) Stop(ctx context.Context) error

Stop stops the Listener listener loop.