core

Documentation

Index

• type Exchange
  • func NewExchange(fetcher *core.BlockFetcher, bServ blockservice.BlockService, ...) *Exchange
  • func (ce *Exchange) Get(ctx context.Context, hash tmbytes.HexBytes) (*header.ExtendedHeader, error)
  • func (ce *Exchange) GetByHeight(ctx context.Context, height uint64) (*header.ExtendedHeader, error)
  • func (ce *Exchange) GetRangeByHeight(ctx context.Context, from, amount uint64) ([]*header.ExtendedHeader, error)
  • func (ce *Exchange) Head(ctx context.Context) (*header.ExtendedHeader, error)
• type Listener
  • func NewListener(bcast header.Broadcaster, fetcher *core.BlockFetcher, ...) *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, bServ blockservice.BlockService, construct header.ConstructFn) *Exchange

func (*Exchange) Get

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

func (*Exchange) GetByHeight

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

func (*Exchange) GetRangeByHeight

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

func (*Exchange) Head

func (ce *Exchange) Head(ctx context.Context) (*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,
	bServ blockservice.BlockService,
	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.