cache

Documentation

Index

• Variables
• func MustInitFromViper()
• type CfxCache
  • func NewCfx() *CfxCache
  • func (cache *CfxCache) GetClientVersion(cfx sdk.ClientOperator) (string, error)
  • func (cache *CfxCache) GetGasPrice(cfx sdk.ClientOperator) (*hexutil.Big, error)
• type EthCache
  • func (cache *EthCache) Call(client *node.Web3goClient, callRequest types.CallRequest, ...) ([]byte, error)
  • func (cache *EthCache) GetBlockNumber(client *node.Web3goClient) (*hexutil.Big, error)
  • func (cache *EthCache) GetChainId(client *web3go.Client) (*hexutil.Uint64, error)
  • func (cache *EthCache) GetClientVersion(client *web3go.Client) (string, error)
  • func (cache *EthCache) GetGasPrice(client *web3go.Client) (*hexutil.Big, error)
  • func (cache *EthCache) GetNetVersion(client *web3go.Client) (string, error)
• type EthCacheConfig
• type StatusCache
  • func NewStatusCache() *StatusCache
  • func (c *StatusCache) GetBestBlockHash(cfx sdk.ClientOperator) (types.Hash, error)
  • func (c *StatusCache) GetEpochNumber(cfx sdk.ClientOperator, epoch *types.Epoch) (*hexutil.Big, error)
  • func (c *StatusCache) GetStatus(cfx sdk.ClientOperator) (types.Status, error)

Variables

var CfxDefault = NewCfx()

Functions

func MustInitFromViper

func MustInitFromViper()

Types

type CfxCache

type CfxCache struct {
	*StatusCache
	// contains filtered or unexported fields
}

CfxCache memory cache for some core space RPC methods

func NewCfx

func NewCfx() *CfxCache

func (*CfxCache) GetClientVersion

func (cache *CfxCache) GetClientVersion(cfx sdk.ClientOperator) (string, error)

func (*CfxCache) GetGasPrice

func (cache *CfxCache) GetGasPrice(cfx sdk.ClientOperator) (*hexutil.Big, error)

type EthCache

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

EthCache memory cache for some evm space RPC methods

var (
	EthDefault *EthCache = newEthCache(newEthCacheConfig())
)

func (*EthCache) Call

func (cache *EthCache) Call(client *node.Web3goClient, callRequest types.CallRequest, blockNum *types.BlockNumberOrHash) ([]byte, error)

func (*EthCache) GetBlockNumber

func (cache *EthCache) GetBlockNumber(client *node.Web3goClient) (*hexutil.Big, error)

func (*EthCache) GetChainId

func (cache *EthCache) GetChainId(client *web3go.Client) (*hexutil.Uint64, error)

func (*EthCache) GetClientVersion

func (cache *EthCache) GetClientVersion(client *web3go.Client) (string, error)

func (*EthCache) GetGasPrice

func (cache *EthCache) GetGasPrice(client *web3go.Client) (*hexutil.Big, error)

func (*EthCache) GetNetVersion

func (cache *EthCache) GetNetVersion(client *web3go.Client) (string, error)

type EthCacheConfig

type EthCacheConfig struct {
	NetVersionExpiration    time.Duration `default:"1m"`
	ClientVersionExpiration time.Duration `default:"1m"`
	ChainIdExpiration       time.Duration `default:"8760h"`
	BlockNumberExpiration   time.Duration `default:"1s"`
	PriceExpiration         time.Duration `default:"3s"`
	CallCacheExpiration     time.Duration `default:"1s"`
	CallCacheSize           int           `default:"128"`
}

type StatusCache

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

StatusCache memory cache for core space status related RPC method suites.

func NewStatusCache

func NewStatusCache() *StatusCache

func (*StatusCache) GetBestBlockHash

func (c *StatusCache) GetBestBlockHash(cfx sdk.ClientOperator) (types.Hash, error)

func (*StatusCache) GetEpochNumber

func (c *StatusCache) GetEpochNumber(cfx sdk.ClientOperator, epoch *types.Epoch) (*hexutil.Big, error)

func (*StatusCache) GetStatus

func (c *StatusCache) GetStatus(cfx sdk.ClientOperator) (types.Status, error)