executor

Aug 11, 2023

Changes in this version

type Executor

+ func (e *Executor) QueryChallengeSlashCoolingOffPeriod() (uint64, error)

May 23, 2023

Changes in this version

+ const QueryAttestedChallengeInterval

+ const QueryHeartbeatIntervalInterval

+ const UpdateCachedValidatorsInterval

+ const VotePoolBroadcastMethodName

+ const VotePoolBroadcastParameterKey

+ const VotePoolQueryMethodName

+ const VotePoolQueryParameterEventHash

+ const VotePoolQueryParameterEventType

+ func NewTendermintJsonRPCClient(provider string) (*tmjsonrpcclient.Client, error)

+ func NewTendermintRPCClient(provider string) *tm.TendermintClient

+ type Executor struct

+ BlsPrivKey []byte

+ BlsPubKey []byte

+ func NewExecutor(cfg *config.Config) *Executor

+ func (e *Executor) AttestChallenge(submitterAddress, challengerAddress, spOperatorAddress string, ...) (bool, error)

+ func (e *Executor) BroadcastVote(v *votepool.Vote) error

+ func (e *Executor) CacheValidatorsLoop()

+ func (e *Executor) GetAddr() string

+ func (e *Executor) GetBlockAndBlockResultAtHeight(height int64) (*tmtypes.Block, *ctypes.ResultBlockResults, error)

+ func (e *Executor) GetCachedBlockHeight() (latestHeight uint64)

+ func (e *Executor) GetChallengeResultFromSp(objectId, endpoint string, segmentIndex, redundancyIndex int) (*types.ChallengeResult, error)

+ func (e *Executor) GetHeightLoop()

+ func (e *Executor) GetLatestBlockHeight() (uint64, error)

+ func (e *Executor) GetNonce() (uint64, error)

+ func (e *Executor) GetObjectInfoChecksums(objectId string) ([][]byte, error)

+ func (e *Executor) GetStorageProviderEndpoint(address string) (string, error)

+ func (e *Executor) GetValidatorsBlsPublicKey() ([]string, error)

+ func (e *Executor) QueryCachedLatestValidators() ([]*tmtypes.Validator, error)

+ func (e *Executor) QueryChallengeHeartbeatInterval() (uint64, error)

+ func (e *Executor) QueryInturnAttestationSubmitter() (*challangetypes.QueryInturnAttestationSubmitterResponse, error)

+ func (e *Executor) QueryLatestAttestedChallengeIds() ([]uint64, error)

+ func (e *Executor) QueryVotes(eventType votepool.EventType) ([]*votepool.Vote, error)

+ func (e *Executor) UpdateHeartbeatIntervalLoop()

+ type GnfdCompositeClient struct

+ Height int64

+ type GnfdCompositeClients struct

+ func NewGnfdCompositClients(rpcAddrs []string, chainId string, account *types.Account) GnfdCompositeClients

+ func (gc *GnfdCompositeClients) GetClient() *GnfdCompositeClient

+ type JsonRpcClient = *jsonrpcclient.Client