aptos

Documentation

Index

• type Watcher
  • func NewWatcher(chainID vaa.ChainID, networkID watchers.NetworkID, aptosRPC string, ...) (*Watcher, error)
  • func (e *Watcher) Run(ctx context.Context) error
• type WatcherConfig
  • func (wc *WatcherConfig) Create(msgC chan<- *common.MessagePublication, ...) (supervisor.Runnable, interfaces.Reobserver, error)
  • func (wc *WatcherConfig) GetChainID() vaa.ChainID
  • func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID

Types

type Watcher

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

Watcher is responsible for looking over Aptos blockchain and reporting new transactions to the wormhole contract

func NewWatcher

func NewWatcher(
	chainID vaa.ChainID,
	networkID watchers.NetworkID,
	aptosRPC string,
	aptosAccount string,
	aptosHandle string,
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
) (*Watcher, error)

NewWatcher creates a new Aptos appid watcher

func (*Watcher) Run

func (e *Watcher) Run(ctx context.Context) error

type WatcherConfig

type WatcherConfig struct {
	NetworkID watchers.NetworkID // human readable name
	ChainID   vaa.ChainID        // ChainID
	Rpc       string
	Account   string
	Handle    string
}

func (*WatcherConfig) Create

func (wc *WatcherConfig) Create(
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	_ <-chan *query.PerChainQueryInternal,
	_ chan<- *query.PerChainQueryResponseInternal,
	_ chan<- *common.GuardianSet,
	_ common.Environment,
) (supervisor.Runnable, interfaces.Reobserver, error)

func (*WatcherConfig) GetChainID

func (wc *WatcherConfig) GetChainID() vaa.ChainID

func (*WatcherConfig) GetNetworkID

func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID