cosmwasm

package

v0.0.0-...-43fc98a Latest Latest Go to latest Published: Feb 24, 2024 License: Apache-2.0 Imports: 24 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/sunoj/wormhole

Documentation ¶

Index ¶

Constants
func EventsToMessagePublications(contract string, txHash string, events []gjson.Result, logger *zap.Logger, ...) []*common.MessagePublication
func StringToAddress(value string) (vaa.Address, error)
func StringToHash(value string) (eth_common.Hash, error)
type Watcher
- func NewWatcher(urlWS string, urlLCD string, contract string, ...) *Watcher
- func (e *Watcher) Run(ctx context.Context) error
type WatcherConfig

Constants ¶

View Source

const ReadLimitSize = 524288

ReadLimitSize can be used to increase the read limit size on the listening connection. The default read limit size is not large enough, causing "failed to read: read limited at 32769 bytes" errors during testing. Increasing this limit effects an internal buffer that is used to as part of the zero alloc/copy design.

Variables ¶

This section is empty.

Functions ¶

func EventsToMessagePublications ¶

func EventsToMessagePublications(contract string, txHash string, events []gjson.Result, logger *zap.Logger, chainID vaa.ChainID, contractAddressKey string, b64Encoded bool) []*common.MessagePublication

func StringToAddress ¶

func StringToAddress(value string) (vaa.Address, error)

StringToAddress convert string into address

func StringToHash ¶

func StringToHash(value string) (eth_common.Hash, error)

StringToHash convert string into transaction hash

Types ¶

type Watcher ¶

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

Watcher is responsible for looking over a cosmwasm blockchain and reporting new transactions to the contract

func NewWatcher ¶

func NewWatcher(
	urlWS string,
	urlLCD string,
	contract string,
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	chainID vaa.ChainID,
	env common.Environment,
) *Watcher

NewWatcher creates a new cosmwasm contract 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
	Websocket string             // Websocket URL
	Lcd       string             // LCD
	Contract  string             // hex representation of the contract address
}

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)

Source Files ¶

View all Source files

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