events

package

v0.0.11 Latest Latest Go to latest Published: Dec 8, 2022 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alicenet/alicenet

Links

Open Source Insights

Documentation ¶

Index ¶

func GetALCBEvents() map[string]abi.Event
func GetDisputeGPKjTasks(dkgState *state.DkgState, phaseStart, phaseEnd uint64) []*dkgtasks.DisputeGPKjTask
func GetDisputeShareDistributionTasks(dkgState *state.DkgState, phaseStart, phaseEnd uint64) []*dkgtasks.DisputeShareDistributionTask
func GetDynamicsEvents() map[string]abi.Event
func GetETHDKGEvents() map[string]abi.Event
func GetGovernanceEvents() map[string]abi.Event
func GetPublicStakingEvents() map[string]abi.Event
func GetSnapshotEvents() map[string]abi.Event
func GetValidatorPoolEvents() map[string]abi.Event
func ProcessAddressRegistered(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessDepositReceived(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessDynamicValueChanged(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessGPKJSubmissionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessKeyShareSubmissionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessKeyShareSubmitted(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessMPKSet(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessNewAliceNetNodeVersionAvailable(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessNewCanonicalAliceNetNodeVersion(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessRegistrationComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessRegistrationOpened(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessShareDistribution(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessShareDistributionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessSnapshotTaken(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, ...) error
func ProcessSnapshotTakenOld(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorJoined(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorLeft(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorMajorSlashed(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorMemberAdded(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorMinorSlashed(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func ProcessValidatorSetCompleted(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, ...) error
func RegisterETHDKGEvents(em *objects.EventMap, monDB *db.Database, ...)
func SetupEventMap(em *objects.EventMap, cdb, monDB *db.Database, ...) error
func UpdateStateOnGPKJSubmissionComplete(dkgState *state.DkgState, disputeGPKjStartBlock uint64) ([]*dkgtasks.DisputeGPKjTask, *dkgtasks.CompletionTask)
func UpdateStateOnKeyShareSubmissionComplete(dkgState *state.DkgState, mpkSubmissionStartBlock uint64) *dkgtasks.MPKSubmissionTask
func UpdateStateOnMPKSet(dkgState *state.DkgState, gpkjSubmissionStartBlock uint64, ...) (*dkgtasks.GPKjSubmissionTask, *dkgtasks.DisputeMissingGPKjTask, ...)
func UpdateStateOnRegistrationComplete(dkgState *state.DkgState, shareDistributionStartBlockNumber uint64) (*dkgtasks.ShareDistributionTask, *dkgtasks.DisputeMissingShareDistributionTask, ...)
func UpdateStateOnRegistrationOpened(account accounts.Account, ...) (*state.DkgState, *dkgtasks.RegisterTask, ...)
func UpdateStateOnShareDistributionComplete(dkgState *state.DkgState, disputeShareDistributionStartBlock uint64) ([]*dkgtasks.DisputeShareDistributionTask, *dkgtasks.KeyShareSubmissionTask, ...)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetALCBEvents ¶ added in v0.0.8

func GetALCBEvents() map[string]abi.Event

func GetDisputeGPKjTasks ¶

func GetDisputeGPKjTasks(dkgState *state.DkgState, phaseStart, phaseEnd uint64) []*dkgtasks.DisputeGPKjTask

func GetDisputeShareDistributionTasks ¶

func GetDisputeShareDistributionTasks(dkgState *state.DkgState, phaseStart, phaseEnd uint64) []*dkgtasks.DisputeShareDistributionTask

func GetDynamicsEvents ¶ added in v0.0.5

func GetDynamicsEvents() map[string]abi.Event

func GetETHDKGEvents ¶

func GetETHDKGEvents() map[string]abi.Event

func GetGovernanceEvents ¶

func GetGovernanceEvents() map[string]abi.Event

func GetPublicStakingEvents ¶

func GetPublicStakingEvents() map[string]abi.Event

func GetSnapshotEvents ¶

func GetSnapshotEvents() map[string]abi.Event

func GetValidatorPoolEvents ¶

func GetValidatorPoolEvents() map[string]abi.Event

func ProcessAddressRegistered ¶

func ProcessAddressRegistered(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database) error

func ProcessDepositReceived ¶

func ProcessDepositReceived(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, cdb, monDB *db.Database, depositHandler interfaces.DepositHandler, chainID uint32) error

func ProcessDynamicValueChanged ¶ added in v0.0.5

func ProcessDynamicValueChanged(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, adminHandler monInterfaces.AdminHandler) error

ProcessDynamicValueChanged handles a dynamic value updating coming from our smart contract.

func ProcessGPKJSubmissionComplete ¶

func ProcessGPKJSubmissionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessKeyShareSubmissionComplete ¶

func ProcessKeyShareSubmissionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessKeyShareSubmitted ¶

func ProcessKeyShareSubmitted(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database) error

func ProcessMPKSet ¶

func ProcessMPKSet(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, adminHandler monitorInterfaces.AdminHandler, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessNewAliceNetNodeVersionAvailable ¶ added in v0.0.5

func ProcessNewAliceNetNodeVersionAvailable(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monState *objects.MonitorState, taskHandler executor.TaskHandler) error

func ProcessNewCanonicalAliceNetNodeVersion ¶ added in v0.0.5

func ProcessNewCanonicalAliceNetNodeVersion(
	contracts layer1.AllSmartContracts,
	logger *logrus.Entry,
	log types.Log,
	exitFunc func(),
) error

func ProcessRegistrationComplete ¶

func ProcessRegistrationComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessRegistrationOpened ¶

func ProcessRegistrationOpened(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monState *objects.MonitorState, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessShareDistribution ¶

func ProcessShareDistribution(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database) error

func ProcessShareDistributionComplete ¶

func ProcessShareDistributionComplete(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, monDB *db.Database, taskHandler executor.TaskHandler) error

func ProcessSnapshotTaken ¶

func ProcessSnapshotTaken(contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, adminHandler monInterfaces.AdminHandler, taskHandler executor.TaskHandler) error

ProcessSnapshotTaken handles receiving snapshots

func ProcessSnapshotTakenOld ¶ added in v0.0.5

func ProcessSnapshotTakenOld(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, log types.Log, adminHandler monInterfaces.AdminHandler, taskHandler executor.TaskHandler) error

ProcessSnapshotTakenOld handles receiving snapshots.

func ProcessValidatorJoined ¶

func ProcessValidatorJoined(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, state *objects.MonitorState, log types.Log) error

ProcessValidatorJoined handles the Minor Slash event.

func ProcessValidatorLeft ¶

func ProcessValidatorLeft(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, state *objects.MonitorState, log types.Log) error

ProcessValidatorLeft handles the Minor Slash event.

func ProcessValidatorMajorSlashed ¶

func ProcessValidatorMajorSlashed(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, state *objects.MonitorState, log types.Log) error

ProcessValidatorMajorSlashed handles the Major Slash event.

func ProcessValidatorMemberAdded ¶

func ProcessValidatorMemberAdded(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, monitorState *objects.MonitorState, log types.Log, monDB *db.Database) error

ProcessValidatorMemberAdded handles receiving keys for a specific validator.

func ProcessValidatorMinorSlashed ¶

func ProcessValidatorMinorSlashed(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, state *objects.MonitorState, log types.Log) error

ProcessValidatorMinorSlashed handles the Minor Slash event.

func ProcessValidatorSetCompleted ¶

func ProcessValidatorSetCompleted(eth layer1.Client, contracts layer1.AllSmartContracts, logger *logrus.Entry, monitorState *objects.MonitorState, log types.Log, monDB *db.Database,
	adminHandler monInterfaces.AdminHandler,
) error

ProcessValidatorSetCompleted handles receiving validatorSet changes.

func RegisterETHDKGEvents ¶

func RegisterETHDKGEvents(em *objects.EventMap, monDB *db.Database, adminHandler monInterfaces.AdminHandler, taskHandler executor.TaskHandler)

func SetupEventMap ¶

func SetupEventMap(em *objects.EventMap, cdb, monDB *db.Database, adminHandler monInterfaces.AdminHandler, depositHandler monInterfaces.DepositHandler, taskHandler executor.TaskHandler, exitFunc func(), chainID uint32) error

func UpdateStateOnGPKJSubmissionComplete ¶

func UpdateStateOnGPKJSubmissionComplete(dkgState *state.DkgState, disputeGPKjStartBlock uint64) ([]*dkgtasks.DisputeGPKjTask, *dkgtasks.CompletionTask)

func UpdateStateOnKeyShareSubmissionComplete ¶

func UpdateStateOnKeyShareSubmissionComplete(dkgState *state.DkgState, mpkSubmissionStartBlock uint64) *dkgtasks.MPKSubmissionTask

func UpdateStateOnMPKSet ¶

func UpdateStateOnMPKSet(dkgState *state.DkgState, gpkjSubmissionStartBlock uint64, adminHandler monitorInterfaces.AdminHandler) (*dkgtasks.GPKjSubmissionTask, *dkgtasks.DisputeMissingGPKjTask, []*dkgtasks.DisputeGPKjTask)

func UpdateStateOnRegistrationComplete ¶

func UpdateStateOnRegistrationComplete(dkgState *state.DkgState, shareDistributionStartBlockNumber uint64) (*dkgtasks.ShareDistributionTask, *dkgtasks.DisputeMissingShareDistributionTask, []*dkgtasks.DisputeShareDistributionTask)

func UpdateStateOnRegistrationOpened ¶

func UpdateStateOnRegistrationOpened(account accounts.Account, startBlock, phaseLength, confirmationLength, nonce uint64, amIValidator bool, validatorAddresses []common.Address) (*state.DkgState, *dkgtasks.RegisterTask, *dkgtasks.DisputeMissingRegistrationTask)

func UpdateStateOnShareDistributionComplete ¶

func UpdateStateOnShareDistributionComplete(dkgState *state.DkgState, disputeShareDistributionStartBlock uint64) ([]*dkgtasks.DisputeShareDistributionTask, *dkgtasks.KeyShareSubmissionTask, *dkgtasks.DisputeMissingKeySharesTask)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL