Versions in this module Expand all Collapse all v1 v1.10.2 Dec 15, 2024 Changes in this version + func Close() error + func Init(serverAddr []string) error + func PublishNewFilterLogEvent(shardID uint32, namespace, id string, crit ethereum.FilterQuery) error + func PublishShardUpdate(shardID uint32, blkNum uint64, logs []*types.Log) error + func PublishTxPoolUpdate(shardID uint32, tx types.PoolTransaction, local bool) error + func SubscribeNewFilterLogEvent(shardID uint32, namespace string, ...) + func SubscribeShardUpdate(shardID uint32, cb func(blkNum uint64, logs []*types.Log)) + func SubscribeTxPoolUpdate(shardID uint32, cb func(tx types.PoolTransaction, local bool)) + type BlockUpdate struct + BlkNum uint64 + Logs []*types.LogForStorage + type LockResult int + const LockResultFail + const LockResultRenewalSuccess + const LockResultSuccess + type NewFilterUpdated struct + FilterCriteria ethereum.FilterQuery + ID string + type RedisPreempt struct + func CreatePreempt(key string) *RedisPreempt + func (p *RedisPreempt) LastLockStatus() bool + func (p *RedisPreempt) TryLock(ttlSecond int) (result LockResult, err error) + func (p *RedisPreempt) Unlock() (bool, error) + type TxPoolUpdate struct + Local bool + Tx types.PoolTransaction + func (t *TxPoolUpdate) DecodeRLP(stream *rlp.Stream) error + func (t *TxPoolUpdate) EncodeRLP(w io.Writer) error
Go to main page