rpc

Apr 19, 2024

Changes in this version

type Client

+ func (c *Client) WaitL2Header(ctx context.Context, blockID *big.Int) (*types.Header, error)

Apr 10, 2024

Changes in this version

+ type BlobData struct

+ Blob string

+ BlobHash string

+ KzgCommitment string

+ type BlobDataSeq struct

+ Data []*BlobData

+ type BlobDataSource struct

+ func NewBlobDataSource(ctx context.Context, client *Client, blobServerEndpoint *url.URL) *BlobDataSource

+ func (ds *BlobDataSource) GetBlobs(ctx context.Context, meta *bindings.TaikoDataBlockMetadata) ([]*blob.Sidecar, error)

type Client

+ func (c *Client) GetTransition(ctx context.Context, blockID *big.Int, transactionID uint32) (bindings.TaikoDataTransitionState, error)

type EngineClient

+ func (c *EngineClient) TxPoolContent(ctx context.Context, beneficiary common.Address, baseFee *big.Int, ...) ([]*miner.PreBuiltTxList, error)

Mar 28, 2024

Changes in this version

+ var BlockMaxTxListBytes uint64 = (params.BlobTxBytesPerFieldElement - 1) * params.BlobTxFieldElementsPerBlob

+ var ErrBlobInvalid = errors.New("invalid blob encoding")

type AccountPoolContent

+ func Content(ctx context.Context, client *EthClient) (AccountPoolContent, error)

+ type AccountPoolContentFrom map[string]map[string]*types.Transaction

+ type BeaconClient struct

+ func NewBeaconClient(endpoint string, timeout time.Duration) (*BeaconClient, error)

+ func (c *BeaconClient) GetBlobs(ctx context.Context, time uint64) ([]*blob.Sidecar, error)

type Client

+ func (c *Client) GetL2BlockInfo(ctx context.Context, blockID *big.Int) (struct{ ... }, error)

+ func (c *Client) GetTaikoDataSlotBByNumber(ctx context.Context, number uint64) (*bindings.TaikoDataSlotB, error)

+ type ConfigSpec struct

+ SecondsPerSlot string

type EthClient

+ func (c *EthClient) CreateBlobTx(opts *bind.TransactOpts, contract common.Address, input []byte, ...) (*types.BlobTx, error)

+ type GenesisResponse struct

+ Data struct{ ... }

+ type ReorgCheckResult struct

+ IsReorged bool

+ L1CurrentToReset *types.Header

+ LastHandledBlockIDToReset *big.Int

Feb 20, 2024

Changes in this version

+ var BlobBytes = params.BlobTxBytesPerFieldElement * params.BlobTxFieldElementsPerBlob

+ func DecodeBlob(blob []byte) ([]byte, error)

+ func DecodeBlobs(blobs []kzg4844.Blob) ([]byte, error)

+ func EncodeBlobs(origin []byte) []kzg4844.Blob

+ func MakeSidecar(data []byte) (*types.BlobTxSidecar, error)

type BlockProofStatus

+ ParentHeader *types.Header

type Client

+ L1Beacon *beacon.Client

+ func (c *Client) GetBlobs(ctx context.Context, slot *big.Int) ([]*blob.Sidecar, error)

+ func (c *Client) L2ParentByBlockID(ctx context.Context, blockID *big.Int) (*types.Header, error)

type ClientConfig

+ BackOffMaxRetries uint64

+ L1BeaconEndpoint string

type EngineClient

+ func NewJWTEngineClient(url, jwtSecret string) (*EngineClient, error)

type EthClient

+ func NewEthClient(ctx context.Context, url string, timeout time.Duration) (*EthClient, error)

+ func (c *EthClient) FillTransaction(ctx context.Context, args *TransactionArgs) (*types.Transaction, error)

+ func (c *EthClient) TransactBlobTx(opts *bind.TransactOpts, contract *common.Address, input []byte, ...) (*types.Transaction, error)

+ type SignTransactionResult struct

+ Raw hexutil.Bytes

+ Tx *types.Transaction

+ type TransactionArgs struct

+ AccessList *types.AccessList

+ BlobFeeCap *hexutil.Big

+ BlobHashes []common.Hash

+ ChainID *hexutil.Big

+ Data *hexutil.Bytes

+ From *common.Address

+ Gas *hexutil.Uint64

+ GasPrice *hexutil.Big

+ Input *hexutil.Bytes

+ MaxFeePerGas *hexutil.Big

+ MaxPriorityFeePerGas *hexutil.Big

+ Nonce *hexutil.Uint64

+ To *common.Address

+ Value *hexutil.Big

Dec 5, 2023

Changes in this version

+ type BlockProofStatus struct

+ CurrentTransitionState *bindings.TaikoDataTransitionState

+ Invalid bool

+ IsSubmitted bool

+ ParentBlock *types.Header

+ func GetBlockProofStatus(ctx context.Context, cli *Client, id *big.Int, proverAddress common.Address) (*BlockProofStatus, error)

type Client

+ GuardianProver *bindings.GuardianProver

type ClientConfig

+ GuardianProverAddress common.Address

Oct 18, 2023

Changes in this version

+ func SubscribeTransitionContested(taikoL1 *bindings.TaikoL1Client, ...) event.Subscription

+ func SubscribeTransitionProved(taikoL1 *bindings.TaikoL1Client, ...) event.Subscription

type Client

+ func (c *Client) GetTiers(ctx context.Context) ([]*TierProviderTierWithID, error)

+ type TierProviderTierWithID struct

+ ID uint16

Oct 3, 2023

Changes in this version

+ var ZeroAddress = common.HexToAddress("0x0000000000000000000000000000000000000000")

+ func CheckProverBalance(ctx context.Context, rpc *Client, prover common.Address, ...) (bool, error)

+ func IncreaseGasTipCap(ctx context.Context, cli *Client, opts *bind.TransactOpts, ...) (*bind.TransactOpts, error)

Sep 5, 2023

Changes in this version

type Client

+ TaikoToken *bindings.TaikoToken

type ClientConfig

+ BackOffMaxRetrys *big.Int

+ TaikoTokenAddress common.Address

Aug 10, 2023

Changes in this version

+ func IsArchiveNode(ctx context.Context, client *EthClient, l2GenesisHeight uint64) (bool, error)

type ClientConfig

+ Timeout *time.Duration

+ type EthClient struct

+ func NewEthClientWithDefaultTimeout(ethclient *ethclient.Client) *EthClient

+ func NewEthClientWithTimeout(ethclient *ethclient.Client, timeout time.Duration) *EthClient

+ func (c *EthClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ func (c *EthClient) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

+ func (c *EthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

+ func (c *EthClient) BlockNumber(ctx context.Context) (uint64, error)

+ func (c *EthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

+ func (c *EthClient) CallContractAtHash(ctx context.Context, msg ethereum.CallMsg, blockHash common.Hash) ([]byte, error)

+ func (c *EthClient) ChainID(ctx context.Context) (*big.Int, error)

+ func (c *EthClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

+ func (c *EthClient) EstimateGas(ctx context.Context, msg ethereum.CallMsg) (uint64, error)

+ func (c *EthClient) FeeHistory(ctx context.Context, blockCount uint64, lastBlock *big.Int, ...) (*ethereum.FeeHistory, error)

+ func (c *EthClient) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

+ func (c *EthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

+ func (c *EthClient) NetworkID(ctx context.Context) (*big.Int, error)

+ func (c *EthClient) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ func (c *EthClient) PeerCount(ctx context.Context) (uint64, error)

+ func (c *EthClient) PendingBalanceAt(ctx context.Context, account common.Address) (*big.Int, error)

+ func (c *EthClient) PendingCallContract(ctx context.Context, msg ethereum.CallMsg) ([]byte, error)

+ func (c *EthClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

+ func (c *EthClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

+ func (c *EthClient) PendingStorageAt(ctx context.Context, account common.Address, key common.Hash) ([]byte, error)

+ func (c *EthClient) PendingTransactionCount(ctx context.Context) (uint, error)

+ func (c *EthClient) SendTransaction(ctx context.Context, tx *types.Transaction) error

+ func (c *EthClient) StorageAt(ctx context.Context, account common.Address, key common.Hash, ...) ([]byte, error)

+ func (c *EthClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (c *EthClient) SuggestGasTipCap(ctx context.Context) (*big.Int, error)

+ func (c *EthClient) SyncProgress(ctx context.Context) (*ethereum.SyncProgress, error)

+ func (c *EthClient) TransactionByHash(ctx context.Context, hash common.Hash) (tx *types.Transaction, isPending bool, err error)

+ func (c *EthClient) TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)

+ func (c *EthClient) TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)

+ func (c *EthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

Jul 24, 2023

Changes in this version

+ func GetPendingTxByNonce(ctx context.Context, cli *Client, address common.Address, nonce uint64) (*types.Transaction, error)

+ type AccountPoolContent map[string]map[string]*types.Transaction

+ func ContentFrom(ctx context.Context, rawRPC *rpc.Client, address common.Address) (AccountPoolContent, error)

type Client

+ func (c *Client) CheckL1ReorgFromL1Cursor(ctx context.Context, l1Current *types.Header, genesisHeightL1 uint64) (bool, *types.Header, error)

+ func (c *Client) CheckL1ReorgFromL2EE(ctx context.Context, blockID *big.Int) (bool, *types.Header, *big.Int, error)

+ func (c *Client) IsJustSyncedByP2P(ctx context.Context) (bool, error)

Jul 10, 2023

Changes in this version

+ func SubscribeSlashed(taikoProverPool *bindings.TaikoL1ProverPool, ...) event.Subscription

type Client

+ TaikoProverPoolL1 *bindings.TaikoL1ProverPool

type ClientConfig

+ TaikoProverPoolL1Address common.Address

Jun 26, 2023

Changes in this version

type ClientConfig

+ RetryInterval time.Duration

type EngineClient

+ func (c *EngineClient) ExchangeTransitionConfiguration(ctx context.Context, cfg *engine.TransitionConfigurationV1) (*engine.TransitionConfigurationV1, error)

Jun 8, 2023

Changes in this version

+ func NeedNewSystemProof(ctx context.Context, cli *Client, id *big.Int, realProofSkipSize *big.Int) (bool, error)

type Client

+ func (c *Client) WaitTillL2ExecutionEngineSynced(ctx context.Context) error

Jun 4, 2023

Changes in this version

+ func NeedNewProof(ctx context.Context, cli *Client, id *big.Int, proverAddress common.Address, ...) (bool, error)

+ func StringToBytes32(str string) [32]byte

type Client

+ func (c *Client) CheckL1Reorg(ctx context.Context, blockID *big.Int) (bool, *types.Header, *big.Int, error)

Apr 30, 2023

Changes in this version

+ func SubscribeXchainSynced(taikoL1 *bindings.TaikoL1Client, ch chan *bindings.TaikoL1ClientXchainSynced) event.Subscription

type Client

+ L1GethClient *gethclient.Client

+ L2CheckPoint *ethclient.Client

+ L2GethClient *gethclient.Client

+ func (c *Client) GetStorageRoot(ctx context.Context, contract common.Address, height *big.Int) (common.Hash, error)

type ClientConfig

+ L2CheckPoint string

Mar 15, 2023

Changes in this version

type Client

+ func (c *Client) GetPoolContent(ctx context.Context, maxTransactionsPerBlock *big.Int, ...) ([]types.Transactions, error)

+ func (c *Client) WaitTillL2Synced(ctx context.Context) error

Feb 8, 2023

Changes in this version

type Client

+ func (c *Client) L2ExecutionEngineSyncProgress(ctx context.Context) (*L2SyncProgress, error)

+ type L2SyncProgress struct

+ CurrentBlockID *big.Int

+ HighestBlockID *big.Int

Jan 12, 2023

Changes in this version

+ func SubscribeBlockProposed(taikoL1 *bindings.TaikoL1Client, ch chan *bindings.TaikoL1ClientBlockProposed) event.Subscription

+ func SubscribeBlockProven(taikoL1 *bindings.TaikoL1Client, ch chan *bindings.TaikoL1ClientBlockProven) event.Subscription

+ func SubscribeBlockVerified(taikoL1 *bindings.TaikoL1Client, ch chan *bindings.TaikoL1ClientBlockVerified) event.Subscription

+ func SubscribeChainHead(client *ethclient.Client, ch chan *types.Header) event.Subscription

+ func SubscribeEvent(eventName string, ...) event.Subscription

+ func SubscribeHeaderSynced(taikoL1 *bindings.TaikoL1Client, ch chan *bindings.TaikoL1ClientHeaderSynced) event.Subscription

type PoolContent

+ func (pc PoolContent) Len() int

+ func (pc PoolContent) ToTxsByPriceAndNonce(chainID *big.Int) *types.TransactionsByPriceAndNonce

Dec 11, 2022

Changes in this version

+ func GetProtocolConstants(taikoL1Client *bindings.TaikoL1Client, opts *bind.CallOpts) (*bindings.ProtocolConstants, error)

+ func GetProtocolStateVariables(taikoL1Client *bindings.TaikoL1Client, opts *bind.CallOpts) (*bindings.ProtocolStateVariables, error)

type Client

+ func (c *Client) GetProtocolStateVariables(opts *bind.CallOpts) (*bindings.ProtocolStateVariables, error)

Dec 10, 2022

Changes in this version

type Client

+ func (c *Client) IsProposerWhitelisted(proposer common.Address) (bool, error)

+ func (c *Client) IsProverWhitelisted(prover common.Address) (bool, error)

Dec 4, 2022

Changes in this version

type Client

+ func (c *Client) GetProtocolConstants(opts *bind.CallOpts) (*bindings.ProtocolConstants, error)

Nov 22, 2022

Changes in this version

+ var FallbackGasTipCap = big.NewInt(1500000000)

+ func DialClientWithBackoff(ctx context.Context, url string) (*ethclient.Client, error)

+ func DialEngineClient(ctx context.Context, endpointUrl string, jwtSecret string) (*rpc.Client, error)

+ func GetReceiptsByBlock(ctx context.Context, cli *ethclient.Client, block *types.Block) (types.Receipts, error)

+ func IsMaxPriorityFeePerGasNotFoundError(err error) bool

+ func SetHead(ctx context.Context, rpc *rpc.Client, headNum *big.Int) error

+ func WaitConfirmations(ctx context.Context, client *ethclient.Client, confirmations uint64, ...) error

+ func WaitReceipt(ctx context.Context, client *ethclient.Client, tx *types.Transaction) (*types.Receipt, error)

+ type Client struct

+ L1 *ethclient.Client

+ L1ChainID *big.Int

+ L1RawRPC *rpc.Client

+ L2 *ethclient.Client

+ L2ChainID *big.Int

+ L2Engine *EngineClient

+ L2RawRPC *rpc.Client

+ TaikoL1 *bindings.TaikoL1Client

+ TaikoL2 *bindings.V1TaikoL2Client

+ func NewClient(ctx context.Context, cfg *ClientConfig) (*Client, error)

+ func (c *Client) GetBlockMetadataByID(blockID *big.Int) (*bindings.LibDataBlockMetadata, error)

+ func (c *Client) GetGenesisL1Header(ctx context.Context) (*types.Header, error)

+ func (c *Client) L2AccountNonce(ctx context.Context, account common.Address, height *big.Int) (uint64, error)

+ func (c *Client) L2ParentByBlockId(ctx context.Context, blockID *big.Int) (*types.Header, error)

+ func (c *Client) L2PoolContent(ctx context.Context) (pending PoolContent, queued PoolContent, err error)

+ func (c *Client) LatestL2KnownL1Header(ctx context.Context) (*types.Header, error)

+ func (c *Client) WaitL1Origin(ctx context.Context, blockID *big.Int) (*rawdb.L1Origin, error)

+ type ClientConfig struct

+ JwtSecret string

+ L1Endpoint string

+ L2Endpoint string

+ L2EngineEndpoint string

+ TaikoL1Address common.Address

+ TaikoL2Address common.Address

+ type EngineClient struct

+ func DialEngineClientWithBackoff(ctx context.Context, url string, jwtSecret string) (*EngineClient, error)

+ func (c *EngineClient) ForkchoiceUpdate(ctx context.Context, fc *beacon.ForkchoiceStateV1, ...) (*beacon.ForkChoiceResponse, error)

+ func (c *EngineClient) GetPayload(ctx context.Context, payloadID *beacon.PayloadID) (*beacon.ExecutableDataV1, error)

+ func (c *EngineClient) NewPayload(ctx context.Context, payload *beacon.ExecutableDataV1) (*beacon.PayloadStatusV1, error)

+ type PoolContent map[common.Address]map[string]*types.Transaction

+ func (pc PoolContent) ToTxLists() TxLists

+ type TxLists []types.Transactions

+ func (t TxLists) Len() int