node

Documentation

Index

• func Read(ctx context.Context, log zerolog.Logger, client client.Client, ...) error
• func Sync(ctx context.Context, log zerolog.Logger, client client.Client, ...) error
• type FeeMonitor
  • func NewFeeMonitor(ctx context.Context, conn *grpc.ClientConn) (*FeeMonitor, error)
  • func (fm *FeeMonitor) EstimateGas(ctx context.Context, txBytes []byte) (uint64, error)
  • func (fm *FeeMonitor) GasPrice() float64
• type Releaser
  • func NewReleaser(client client.Client, delay time.Duration, trigger TriggerFn) *Releaser
  • func (r *Releaser) Start(ctx context.Context) error
• type TriggerFn

Functions

func Read

func Read(
	ctx context.Context,
	log zerolog.Logger,
	client client.Client,
	store *account.Store,
	pool *tx.Pool,
) error

Reader listens to committed blocks to the Celestia blockchain and updates the balances of accounts in its store

func Sync

func Sync(
	ctx context.Context,
	log zerolog.Logger,
	client client.Client,
	store *account.Store,
	pool *tx.Pool,
	signer string,
	fromHeight, toHeight uint64,
) error

Types

type FeeMonitor

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

func NewFeeMonitor

func NewFeeMonitor(ctx context.Context, conn *grpc.ClientConn) (*FeeMonitor, error)

func (*FeeMonitor) EstimateGas

func (fm *FeeMonitor) EstimateGas(ctx context.Context, txBytes []byte) (uint64, error)

func (*FeeMonitor) GasPrice

func (fm *FeeMonitor) GasPrice() float64

type Releaser

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

func NewReleaser

func NewReleaser(client client.Client, delay time.Duration, trigger TriggerFn) *Releaser

func (*Releaser) Start

func (r *Releaser) Start(ctx context.Context) error

type TriggerFn

type TriggerFn func() error

TriggerFn is the function that is invoked by the releaser. An error here will cause the releaser to stop and error out.