l1

Documentation

Index

• type Client
  • func NewClient(l1 Subscriber, chain *blockchain.Blockchain, log utils.SimpleLogger) *Client
  • func (c *Client) Run(ctx context.Context) error
• type EthSubscriber
  • func NewEthSubscriber(ethClientAddress string, coreContractAddress common.Address) (*EthSubscriber, error)
  • func (s *EthSubscriber) ChainID(ctx context.Context) (*big.Int, error)
  • func (s *EthSubscriber) Close()
  • func (s *EthSubscriber) FinalisedHeight(ctx context.Context) (uint64, error)
  • func (s *EthSubscriber) WatchHeader(ctx context.Context, sink chan<- *types.Header) (event.Subscription, error)
  • func (s *EthSubscriber) WatchLogStateUpdate(ctx context.Context, sink chan<- *contract.StarknetLogStateUpdate) (event.Subscription, error)
• type Subscriber

Types

type Client

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

func NewClient

func NewClient(l1 Subscriber, chain *blockchain.Blockchain, log utils.SimpleLogger) *Client

func (*Client) Run

func (c *Client) Run(ctx context.Context) error

type EthSubscriber

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

func NewEthSubscriber

func NewEthSubscriber(ethClientAddress string, coreContractAddress common.Address) (*EthSubscriber, error)

func (*EthSubscriber) ChainID

func (s *EthSubscriber) ChainID(ctx context.Context) (*big.Int, error)

func (*EthSubscriber) Close

func (s *EthSubscriber) Close()

func (*EthSubscriber) FinalisedHeight

func (s *EthSubscriber) FinalisedHeight(ctx context.Context) (uint64, error)

func (*EthSubscriber) WatchHeader

func (s *EthSubscriber) WatchHeader(ctx context.Context, sink chan<- *types.Header) (event.Subscription, error)

func (*EthSubscriber) WatchLogStateUpdate

func (s *EthSubscriber) WatchLogStateUpdate(ctx context.Context, sink chan<- *contract.StarknetLogStateUpdate) (event.Subscription, error)

type Subscriber

type Subscriber interface {
	FinalisedHeight(ctx context.Context) (uint64, error)
	WatchHeader(ctx context.Context, sink chan<- *types.Header) (event.Subscription, error)
	WatchLogStateUpdate(ctx context.Context, sink chan<- *contract.StarknetLogStateUpdate) (event.Subscription, error)
	ChainID(ctx context.Context) (*big.Int, error)

	Close()
}