ipc

Documentation

Index

• type Ipc
  • func NewClient(ctx context.Context, ipcPath string) (*Ipc, error)
  • func (c *Ipc) Close() error
  • func (c *Ipc) GetChainID() (*big.Int, error)
  • func (c *Ipc) GetCheckToAddress(tx *types.Transaction) string
  • func (c *Ipc) GetPendingTxdetailsByHash(txLog types.Log) (rtypes.TransactionInPool, error)
  • func (c *Ipc) MonitorPendingTransactions()
  • func (c *Ipc) ProcessAndPrepareBlock(header *types.Header) (rHeader *types.Header, rBlock *rtypes.Block, err error)
  • func (c *Ipc) ProcessAndPrepareTransactions(block *types.Block)

Types

type Ipc

type Ipc struct {
	TxMessagesCh   chan rtypes.PendingTransactionInPool
	TxMessagesDup  *lru.Cache[common.Hash, bool]
	TxMessageBlock chan rtypes.Transaction
	TxTraceCalls   chan rtypes.TraceCallTransactionResponse
	IpcErrorCh     chan error
	IpcPath        string
	EthClient      *ethclient.Client
	RpcClient      *rpc.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, ipcPath string) (*Ipc, error)

func (*Ipc) Close

func (c *Ipc) Close() error

func (*Ipc) GetChainID

func (c *Ipc) GetChainID() (*big.Int, error)

func (*Ipc) GetCheckToAddress

func (c *Ipc) GetCheckToAddress(tx *types.Transaction) string

func (*Ipc) GetPendingTxdetailsByHash

func (c *Ipc) GetPendingTxdetailsByHash(txLog types.Log) (rtypes.TransactionInPool, error)

func (*Ipc) MonitorPendingTransactions

func (c *Ipc) MonitorPendingTransactions()

func (*Ipc) ProcessAndPrepareBlock

func (c *Ipc) ProcessAndPrepareBlock(header *types.Header) (rHeader *types.Header, rBlock *rtypes.Block, err error)

func (*Ipc) ProcessAndPrepareTransactions

func (c *Ipc) ProcessAndPrepareTransactions(block *types.Block)