executor

Documentation

Index

• Constants
• type Executor
  • 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() (uint64, error)
  • 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) QueryChallengeSlashCoolingOffPeriod() (uint64, error)
  • func (e *Executor) QueryInturnAttestationSubmitter() (*challengetypes.QueryInturnAttestationSubmitterResponse, error)
  • func (e *Executor) QueryLatestAttestedChallengeIds() ([]uint64, error)
  • func (e *Executor) QueryVotes(eventType votepool.EventType) ([]*votepool.Vote, error)
  • func (e *Executor) UpdateHeartbeatIntervalLoop()
• type GnfdCompositeClient
• type GnfdCompositeClients
  • func NewGnfdCompositClients(rpcAddrs []string, chainId string, account *types.Account) GnfdCompositeClients
  • func (gc *GnfdCompositeClients) GetClient() *GnfdCompositeClient
• type JsonRpcClient

Constants

const (
	UpdateCachedValidatorsInterval = 1 * time.Minute
	QueryHeartbeatIntervalInterval = 120 * time.Minute // blockchain challenge heartbeat interval only changed by governance

	VotePoolBroadcastMethodName   = "broadcast_vote"
	VotePoolBroadcastParameterKey = "vote"

	VotePoolQueryMethodName         = "query_vote"
	VotePoolQueryParameterEventType = "event_type"
	VotePoolQueryParameterEventHash = "event_hash"
)

Types

type Executor

type Executor struct {
	BlsPrivKey []byte
	BlsPubKey  []byte
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(cfg *config.Config) *Executor

func (*Executor) AttestChallenge

func (e *Executor) AttestChallenge(submitterAddress, challengerAddress, spOperatorAddress string, challengeId uint64, objectId sdkmath.Uint, voteResult challengetypes.VoteResult, voteValidatorSet []uint64, VoteAggSignature []byte, txOption sdktypes.TxOption) (bool, error)

func (*Executor) BroadcastVote

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

func (*Executor) CacheValidatorsLoop

func (e *Executor) CacheValidatorsLoop()

func (*Executor) GetAddr

func (e *Executor) GetAddr() string

func (*Executor) GetBlockAndBlockResultAtHeight

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

func (*Executor) GetCachedBlockHeight

func (e *Executor) GetCachedBlockHeight() (uint64, error)

func (*Executor) GetChallengeResultFromSp

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

func (*Executor) GetHeightLoop

func (e *Executor) GetHeightLoop()

func (*Executor) GetLatestBlockHeight

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

func (*Executor) GetNonce

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

func (*Executor) GetObjectInfoChecksums

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

func (*Executor) GetStorageProviderEndpoint

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

func (*Executor) GetValidatorsBlsPublicKey

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

func (*Executor) QueryCachedLatestValidators

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

func (*Executor) QueryChallengeHeartbeatInterval

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

func (*Executor) QueryChallengeSlashCoolingOffPeriod

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

func (*Executor) QueryInturnAttestationSubmitter

func (e *Executor) QueryInturnAttestationSubmitter() (*challengetypes.QueryInturnAttestationSubmitterResponse, error)

func (*Executor) QueryLatestAttestedChallengeIds

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

func (*Executor) QueryVotes

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

func (*Executor) UpdateHeartbeatIntervalLoop

func (e *Executor) UpdateHeartbeatIntervalLoop()

type GnfdCompositeClient

type GnfdCompositeClient struct {
	gnfdclient.IClient
	client.TendermintClient
	JsonRpcClient
	Height int64
}

type GnfdCompositeClients

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

func NewGnfdCompositClients

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

func (*GnfdCompositeClients) GetClient

func (gc *GnfdCompositeClients) GetClient() *GnfdCompositeClient

type JsonRpcClient

type JsonRpcClient = *jsonrpcclient.Client