Versions in this module Expand all Collapse all v1 v1.1.4 Jun 19, 2020 Changes in this version + const ETH + const SubscribeCommitrevealLogCommit + const SubscribeCommitrevealLogRandom + const SubscribeCommitrevealLogReveal + const SubscribeCommitrevealLogStartCommitreveal + const SubscribeDosproxyUpdateBootstrapGroups + const SubscribeDosproxyUpdateGroupSize + const SubscribeLogGroupDissolve + const SubscribeLogGrouping + const SubscribeLogGroupingInitiated + const SubscribeLogInsufficientPendingNode + const SubscribeLogInsufficientWorkingGroup + const SubscribeLogNoWorkingGroup + const SubscribeLogPublicKeyAccepted + const SubscribeLogPublicKeySuggested + const SubscribeLogRequestUserRandom + const SubscribeLogUpdateRandom + const SubscribeLogUrl + const SubscribeLogValidationResult + const TrafficSystemRandom + const TrafficUserQuery + const TrafficUserRandom + func CheckSync(ctx context.Context, cs chan *ethclient.Client) chan *ethclient.Client + func CheckTransaction(client *ethclient.Client, tx *types.Transaction) (err error) + func DialToEth(ctx context.Context, urlPool []string) (out chan DialResult) + func GenEthkey(credentialPath, passPhrase string) (err error) + func GetBalance(client *ethclient.Client, key *keystore.Key) (balance *big.Float, err error) + func GetCurrentBlock(client *ethclient.Client) (blknum uint64, err error) + func NewEthAdaptor(key *keystore.Key, config *configuration.Config, l logger) (adaptor *ethAdaptor, err error) + func NumOfAccounts(credentialPath string) (n int) + func ReadEthKey(credentialPath, passphrase string) (key *keystore.Key, err error) + type DialResult struct + Client *ethclient.Client + Err error + Url string + type LogCommit struct + Cid *big.Int + Commitment [32]byte + From common.Address + type LogCommon struct + BlockN uint64 + Raw types.Log + Removed bool + Tx string + type LogGroupDissolve struct + GroupId *big.Int + type LogGrouping struct + GroupId *big.Int + NodeId [][]byte + type LogGroupingInitiated struct + GroupSize *big.Int + NumPendingNodes *big.Int + type LogInsufficientPendingNode struct + NumPendingNodes *big.Int + type LogInsufficientWorkingGroup struct + NumWorkingGroups *big.Int + type LogPublicKeyAccepted struct + GroupId *big.Int + WorkingGroupSize *big.Int + type LogPublicKeySuggested struct + Count *big.Int + GroupId *big.Int + GroupSize *big.Int + type LogRandom struct + Cid *big.Int + Random *big.Int + type LogRequestUserRandom struct + DispatchedGroupId *big.Int + LastSystemRandomness *big.Int + RequestId *big.Int + UserSeed *big.Int + type LogReveal struct + Cid *big.Int + From common.Address + Secret *big.Int + type LogStartCommitReveal struct + Cid *big.Int + CommitDuration *big.Int + RevealDuration *big.Int + RevealThreshold *big.Int + StartBlock *big.Int + type LogUpdateGroupSize struct + NewSize *big.Int + OldSize *big.Int + type LogUpdateGroupToPick struct + NewNum *big.Int + OldNum *big.Int + type LogUpdateRandom struct + DispatchedGroupId *big.Int + LastRandomness *big.Int + type LogUrl struct + DataSource string + DispatchedGroupId *big.Int + QueryId *big.Int + Randomness *big.Int + Selector string + Timeout *big.Int + type LogValidationResult struct + Message []byte + Pass bool + PubKey [4]*big.Int + Signature [2]*big.Int + TrafficId *big.Int + TrafficType uint8 + Version uint8 + type OnchainError struct + Idx int + func (e *OnchainError) Error() string + func (e *OnchainError) Format(f fmt.State, c rune) + func (e *OnchainError) FormatError(p errors.Printer) error + func (e *OnchainError) Unwrap() error + type ProxyAdapter interface + Address func() (addr common.Address) + Balance func() (balance *big.Float, err error) + BootStrapUrl func() string + BootstrapEndBlk func() (result uint64, err error) + BootstrapRound func() (result uint64, err error) + BootstrapStartThreshold func() (result uint64, err error) + Commit func(cid *big.Int, commitment [32]byte) (err error) + Connect func(urls []string, deadline time.Time) (err error) + CurrentBlock func() (r uint64, err error) + DataReturn func(signatures *vss.Signature) (err error) + Disconnect func(idx int) + DisconnectAll func() + GetExpiredWorkingGroupSize func() (r uint64, err error) + GetWorkingGroupSize func() (r uint64, err error) + GroupPubKey func(idx int) (groupPubKeys [4]*big.Int, err error) + GroupSize func() (r uint64, err error) + GroupToPick func() (result uint64, err error) + IsPendingNode func(id []byte) (bool, error) + LastGroupFormationRequestId func() (r uint64, err error) + LastUpdatedBlock func() (r uint64, err error) + NumPendingGroups func() (r uint64, err error) + NumPendingNodes func() (r uint64, err error) + PendingNonce func() (result uint64, err error) + RefreshSystemRandomHardLimit func() (limit uint64, err error) + RegisterGroupPubKey func(IdWithPubKeys [5]*big.Int) (err error) + RegisterNewNode func() (err error) + Reveal func(cid *big.Int, secret *big.Int) (err error) + SetGroupSize func(g uint64) (err error) + SignalBootstrap func(cid *big.Int) (err error) + SignalGroupDissolve func() (err error) + SignalGroupFormation func() (err error) + SignalRandom func() (err error) + SignalUnregister func(addr common.Address) (err error) + StartCommitReveal func(startBlock int64, commitDuration int64, revealDuration int64, ...) (err error) + SubscribeEvent func(subscribeTypes []int) (chan interface{}, chan error) + UnRegisterNode func() (err error) + UpdateRandomness func(signatures *vss.Signature) (err error) + func NewProxyAdapter(key *keystore.Key, config *configuration.Config) (ProxyAdapter, error) v1.0.4-m Jun 4, 2021 v1.0.2-m Dec 17, 2020 v1.0.1-m Jul 24, 2020 v1.0.0-m Jul 2, 2020