state

Documentation

Index

• type State
  • func New(ctx context.Context, rpc *rpc.Client) (*State, error)
  • func (s *State) Close()
  • func (s *State) GetHeadBlockID() *big.Int
  • func (s *State) GetL1Current() *types.Header
  • func (s *State) GetL1Head() *types.Header
  • func (s *State) GetL2Head() *types.Header
  • func (s *State) ResetL1Current(ctx context.Context, blockID *big.Int) error
  • func (s *State) SetL1Current(h *types.Header)
  • func (s *State) SubL1HeadsFeed(ch chan *types.Header) event.Subscription

Types

type State

type State struct {

	// Constants
	GenesisL1Height *big.Int
	// contains filtered or unexported fields
}

State contains all states which will be used by driver.

func New

func New(ctx context.Context, rpc *rpc.Client) (*State, error)

New creates a new driver state instance.

func (*State) Close

func (s *State) Close()

Close closes all inner subscriptions.

func (*State) GetHeadBlockID

func (s *State) GetHeadBlockID() *big.Int

GetHeadBlockID reads the last pending block ID concurrent safely.

func (*State) GetL1Current

func (s *State) GetL1Current() *types.Header

GetL1Current reads the L1 current cursor concurrent safely.

func (*State) GetL1Head

func (s *State) GetL1Head() *types.Header

GetL1Head reads the L1 head concurrent safely.

func (*State) GetL2Head

func (s *State) GetL2Head() *types.Header

GetL2Head reads the L2 head concurrent safely.

func (*State) ResetL1Current

func (s *State) ResetL1Current(ctx context.Context, blockID *big.Int) error

ResetL1Current resets the l1Current cursor to the L1 height which emitted a BlockProposed event with given blockID / blockHash.

func (*State) SetL1Current

func (s *State) SetL1Current(h *types.Header)

SetL1Current sets the L1 current cursor concurrent safely.

func (*State) SubL1HeadsFeed

func (s *State) SubL1HeadsFeed(ch chan *types.Header) event.Subscription

SubL1HeadsFeed registers a subscription of new L1 heads.