adminrpc

Documentation

Index

• func GovMsgToVaa(message *nodev1.GovernanceMessage, currentSetIndex uint32, timestamp time.Time) (*vaa.VAA, error)
• func NewPrivService(db *db.Database, injectC chan<- *common.MessagePublication, ...) *nodePrivilegedService

Functions

func GovMsgToVaa

func GovMsgToVaa(message *nodev1.GovernanceMessage, currentSetIndex uint32, timestamp time.Time) (*vaa.VAA, error)

func NewPrivService

func NewPrivService(
	db *db.Database,
	injectC chan<- *common.MessagePublication,
	obsvReqSendC chan<- *gossipv1.ObservationRequest,
	logger *zap.Logger,
	signedInC chan<- *gossipv1.SignedVAAWithQuorum,
	governor *governor.ChainGovernor,
	evmConnector connectors.Connector,
	guardianSigner guardiansigner.GuardianSigner,
	guardianAddress ethcommon.Address,
	rpcMap map[string]string,

) *nodePrivilegedService