algorand

Documentation

Index

• Constants
• type Watcher
  • func NewWatcher(indexerRPC string, indexerToken string, algodRPC string, algodToken string, ...) *Watcher
  • func (e *Watcher) Run(ctx context.Context) error
• type WatcherConfig
  • func (wc *WatcherConfig) Create(msgC chan<- *common.MessagePublication, ...) (interfaces.L1Finalizer, supervisor.Runnable, error)
  • func (wc *WatcherConfig) GetChainID() vaa.ChainID
  • func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID
  • func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID
  • func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)

Constants

const MAX_DEPTH = 8

Algorand allows max depth of 8 inner transactions

Types

type Watcher

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

Watcher is responsible for looking over Algorand blockchain and reporting new transactions to the appid

func NewWatcher

func NewWatcher(
	indexerRPC string,
	indexerToken string,
	algodRPC string,
	algodToken string,
	appid uint64,
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
) *Watcher

NewWatcher creates a new Algorand 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
	IndexerRPC   string
	IndexerToken string
	AlgodRPC     string
	AlgodToken   string
	AppID        uint64
}

func (*WatcherConfig) Create

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

func (*WatcherConfig) GetChainID

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

func (*WatcherConfig) GetNetworkID

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

func (*WatcherConfig) RequiredL1Finalizer

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

func (*WatcherConfig) SetL1Finalizer

func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)