data

Apr 4, 2021

Changes in this version

type RedisInfo

+ BlockPublishTopic string

+ EventPublishTopic string

+ TxPublishTopic string

Feb 18, 2021

Changes in this version

+ type ActiveSubscriptions struct

+ Count uint64

+ func (a *ActiveSubscriptions) Decrement(by uint64)

+ func (a *ActiveSubscriptions) Increment(by uint64)

+ type SendReceiveCounter struct

+ Receive uint64

+ Send uint64

+ func (s *SendReceiveCounter) IncrementReceive(by uint64)

+ func (s *SendReceiveCounter) IncrementSend(by uint64)

Feb 10, 2021

Changes in this version

type Block

+ ExtraData []byte

+ StateRootHash string

+ UncleHash string

+ func (b *Block) MarshalJSON() ([]byte, error)

Jan 31, 2021

Changes in this version

type RedisInfo

+ BlockRetryCountTable string

+ BlockRetryQueue string

+ UnfinalizedBlocksQueue string

Jan 27, 2021

Changes in this version

type StatusHolder

+ func (s *StatusHolder) MaxBlockNumberAtStartUp() uint64

type SyncState

+ MaxBlockNumberAtStartUp uint64

Jan 17, 2021

Changes in this version

type RedisInfo

+ BlockRetryQueueName string

+ UnfinalizedBlocksQueueName string

type StatusHolder

+ func (s *StatusHolder) GetLatestBlockNumber() uint64

+ func (s *StatusHolder) SetLatestBlockNumber(num uint64)

type SyncState

+ LatestBlockNumber uint64

Jan 8, 2021

Changes in this version

type Job

+ Redis *RedisInfo

+ Status *StatusHolder

+ type RedisInfo struct

+ Client *redis.Client

+ QueueName string

+ type StatusHolder struct

+ Mutex *sync.RWMutex

+ State *SyncState

+ func (s *StatusHolder) BlockCountInDB() uint64

+ func (s *StatusHolder) Done() uint64

+ func (s *StatusHolder) ElapsedTime() time.Duration

+ func (s *StatusHolder) IncrementBlocksInserted()

+ func (s *StatusHolder) IncrementBlocksProcessed()

+ func (s *StatusHolder) SetStartedAt()

Jan 3, 2021

Changes in this version

+ type ResultStatus struct

+ Failure uint64

+ Success uint64

+ func (r ResultStatus) Total() uint64

type SyncState

+ BlockCountAtStartUp uint64

+ NewBlocksInserted uint64

Dec 28, 2020

Changes in this version

+ type APIKey struct

+ APIKey common.Hash

+ type AuthPayload struct

+ Message AuthPayloadMessage

+ Signature string

+ func (a *AuthPayload) HasExpired(window int64) bool

+ func (a *AuthPayload) IsAdmin(signer []byte) bool

+ func (a *AuthPayload) RecoverSigner() []byte

+ func (a *AuthPayload) VerifySignature(signer []byte) bool

+ type AuthPayloadMessage struct

+ Address common.Address

+ TimeStamp uint64

+ func (a *AuthPayloadMessage) ToJSON() []byte

+ type Block struct

+ Difficulty string

+ GasLimit uint64

+ GasUsed uint64

+ Hash string

+ Miner string

+ Nonce uint64

+ Number uint64

+ ParentHash string

+ ReceiptRootHash string

+ Size float64

+ Time uint64

+ TransactionRootHash string

+ func (b *Block) MarshalBinary() ([]byte, error)

+ func (b *Block) ToJSON() []byte

+ type BlockChainNodeConnection struct

+ RPC *ethclient.Client

+ Websocket *ethclient.Client

+ type Blocks struct

+ Blocks []*Block

+ func (b *Blocks) ToJSON() []byte

+ type Event struct

+ BlockHash string

+ Data []byte

+ Index uint

+ Origin string

+ Topics pq.StringArray

+ TransactionHash string

+ func (e *Event) MarshalBinary() ([]byte, error)

+ func (e *Event) MarshalJSON() ([]byte, error)

+ func (e *Event) ToJSON() []byte

+ type Events struct

+ Events []*Event

+ func (e *Events) ToJSON() []byte

+ type Job struct

+ Block uint64

+ Client *ethclient.Client

+ DB *gorm.DB

+ Lock *sync.Mutex

+ RedisClient *redis.Client

+ RedisKey string

+ Synced *SyncState

+ type SyncState struct

+ BlockCountInDB uint64

+ Done uint64

+ StartedAt time.Time

+ type Transaction struct

+ BlockHash string

+ Contract string

+ Cost string

+ Data []byte

+ From string

+ Gas uint64

+ GasPrice string

+ Hash string

+ Nonce uint64

+ State uint64

+ To string

+ Value string

+ func (t *Transaction) MarshalBinary() ([]byte, error)

+ func (t *Transaction) MarshalJSON() ([]byte, error)

+ func (t *Transaction) ToJSON() []byte

+ type Transactions struct

+ Transactions []*Transaction

+ func (t *Transactions) ToJSON() []byte