Documentation
¶
Index ¶
- Constants
- Variables
- func AppLogger(command string) zerolog.Logger
- func BaseLogger(application string) zerolog.Logger
- func EvmPusherLogger(chainRpcUrl string, contractAddress string) zerolog.Logger
- type AggregatedSignedPrice
- type AssetConfig
- type AssetEntry
- type AssetId
- type EncodedAssetId
- type EvmSignature
- type InternalEncodedAssetId
- type OraclePricesMessage
- type PublisherKey
- type PublisherSignedPrice
- type QuantizedPrice
- type StorkAggregatorWebsocketClient
- type StorkCalculationAlg
- type StorkContract
- type StorkContractCaller
- func (_StorkContract *StorkContractCaller) GetTemporalNumericValueV1(opts *bind.CallOpts, id [32]byte) (StorkStructsTemporalNumericValue, error)
- func (_StorkContract *StorkContractCaller) GetUpdateFeeV1(opts *bind.CallOpts, updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
- func (_StorkContract *StorkContractCaller) Owner(opts *bind.CallOpts) (common.Address, error)
- func (_StorkContract *StorkContractCaller) ProxiableUUID(opts *bind.CallOpts) ([32]byte, error)
- func (_StorkContract *StorkContractCaller) SingleUpdateFeeInWei(opts *bind.CallOpts) (*big.Int, error)
- func (_StorkContract *StorkContractCaller) StorkPublicKey(opts *bind.CallOpts) (common.Address, error)
- func (_StorkContract *StorkContractCaller) UPGRADEINTERFACEVERSION(opts *bind.CallOpts) (string, error)
- func (_StorkContract *StorkContractCaller) ValidTimePeriodSeconds(opts *bind.CallOpts) (*big.Int, error)
- func (_StorkContract *StorkContractCaller) VerifyMerkleRoot(opts *bind.CallOpts, leaves [][32]byte, root [32]byte) (bool, error)
- func (_StorkContract *StorkContractCaller) VerifyPublisherSignatureV1(opts *bind.CallOpts, oraclePubKey common.Address, assetPairId string, ...) (bool, error)
- func (_StorkContract *StorkContractCaller) VerifyPublisherSignaturesV1(opts *bind.CallOpts, signatures []StorkStructsPublisherSignature, ...) (bool, error)
- func (_StorkContract *StorkContractCaller) VerifyStorkSignatureV1(opts *bind.CallOpts, storkPubKey common.Address, id [32]byte, ...) (bool, error)
- func (_StorkContract *StorkContractCaller) Version(opts *bind.CallOpts) (string, error)
- type StorkContractCallerRaw
- type StorkContractCallerSession
- func (_StorkContract *StorkContractCallerSession) GetTemporalNumericValueV1(id [32]byte) (StorkStructsTemporalNumericValue, error)
- func (_StorkContract *StorkContractCallerSession) GetUpdateFeeV1(updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
- func (_StorkContract *StorkContractCallerSession) Owner() (common.Address, error)
- func (_StorkContract *StorkContractCallerSession) ProxiableUUID() ([32]byte, error)
- func (_StorkContract *StorkContractCallerSession) SingleUpdateFeeInWei() (*big.Int, error)
- func (_StorkContract *StorkContractCallerSession) StorkPublicKey() (common.Address, error)
- func (_StorkContract *StorkContractCallerSession) UPGRADEINTERFACEVERSION() (string, error)
- func (_StorkContract *StorkContractCallerSession) ValidTimePeriodSeconds() (*big.Int, error)
- func (_StorkContract *StorkContractCallerSession) VerifyMerkleRoot(leaves [][32]byte, root [32]byte) (bool, error)
- func (_StorkContract *StorkContractCallerSession) VerifyPublisherSignatureV1(oraclePubKey common.Address, assetPairId string, timestamp *big.Int, ...) (bool, error)
- func (_StorkContract *StorkContractCallerSession) VerifyPublisherSignaturesV1(signatures []StorkStructsPublisherSignature, merkleRoot [32]byte) (bool, error)
- func (_StorkContract *StorkContractCallerSession) VerifyStorkSignatureV1(storkPubKey common.Address, id [32]byte, recvTime *big.Int, ...) (bool, error)
- func (_StorkContract *StorkContractCallerSession) Version() (string, error)
- type StorkContractFilterer
- func (_StorkContract *StorkContractFilterer) FilterInitialized(opts *bind.FilterOpts) (*StorkContractInitializedIterator, error)
- func (_StorkContract *StorkContractFilterer) FilterOwnershipTransferred(opts *bind.FilterOpts, previousOwner []common.Address, ...) (*StorkContractOwnershipTransferredIterator, error)
- func (_StorkContract *StorkContractFilterer) FilterUpgraded(opts *bind.FilterOpts, implementation []common.Address) (*StorkContractUpgradedIterator, error)
- func (_StorkContract *StorkContractFilterer) FilterValueUpdate(opts *bind.FilterOpts, id [][32]byte) (*StorkContractValueUpdateIterator, error)
- func (_StorkContract *StorkContractFilterer) ParseInitialized(log types.Log) (*StorkContractInitialized, error)
- func (_StorkContract *StorkContractFilterer) ParseOwnershipTransferred(log types.Log) (*StorkContractOwnershipTransferred, error)
- func (_StorkContract *StorkContractFilterer) ParseUpgraded(log types.Log) (*StorkContractUpgraded, error)
- func (_StorkContract *StorkContractFilterer) ParseValueUpdate(log types.Log) (*StorkContractValueUpdate, error)
- func (_StorkContract *StorkContractFilterer) WatchInitialized(opts *bind.WatchOpts, sink chan<- *StorkContractInitialized) (event.Subscription, error)
- func (_StorkContract *StorkContractFilterer) WatchOwnershipTransferred(opts *bind.WatchOpts, sink chan<- *StorkContractOwnershipTransferred, ...) (event.Subscription, error)
- func (_StorkContract *StorkContractFilterer) WatchUpgraded(opts *bind.WatchOpts, sink chan<- *StorkContractUpgraded, ...) (event.Subscription, error)
- func (_StorkContract *StorkContractFilterer) WatchValueUpdate(opts *bind.WatchOpts, sink chan<- *StorkContractValueUpdate, id [][32]byte) (event.Subscription, error)
- type StorkContractInitialized
- type StorkContractInitializedIterator
- type StorkContractInterfacer
- func (sci *StorkContractInterfacer) BatchPushToContract(priceUpdates map[InternalEncodedAssetId]AggregatedSignedPrice) error
- func (sci *StorkContractInterfacer) ListenContractEvents(ch chan map[InternalEncodedAssetId]StorkStructsTemporalNumericValue)
- func (sci *StorkContractInterfacer) Poll(encodedAssetIds []InternalEncodedAssetId, ...)
- func (sci *StorkContractInterfacer) PullValues(encodedAssetIds []InternalEncodedAssetId) (map[InternalEncodedAssetId]StorkStructsTemporalNumericValue, error)
- type StorkContractOwnershipTransferred
- type StorkContractOwnershipTransferredIterator
- type StorkContractRaw
- func (_StorkContract *StorkContractRaw) Call(opts *bind.CallOpts, result *[]interface{}, method string, ...) error
- func (_StorkContract *StorkContractRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)
- func (_StorkContract *StorkContractRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)
- type StorkContractSession
- func (_StorkContract *StorkContractSession) GetTemporalNumericValueV1(id [32]byte) (StorkStructsTemporalNumericValue, error)
- func (_StorkContract *StorkContractSession) GetUpdateFeeV1(updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
- func (_StorkContract *StorkContractSession) Initialize(initialOwner common.Address, storkPublicKey common.Address, ...) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) Owner() (common.Address, error)
- func (_StorkContract *StorkContractSession) ProxiableUUID() ([32]byte, error)
- func (_StorkContract *StorkContractSession) RenounceOwnership() (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) SingleUpdateFeeInWei() (*big.Int, error)
- func (_StorkContract *StorkContractSession) StorkPublicKey() (common.Address, error)
- func (_StorkContract *StorkContractSession) TransferOwnership(newOwner common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) UPGRADEINTERFACEVERSION() (string, error)
- func (_StorkContract *StorkContractSession) UpdateSingleUpdateFeeInWei(maxStorkPerBlock *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) UpdateStorkPublicKey(storkPublicKey common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) UpdateTemporalNumericValuesV1(updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) UpdateValidTimePeriodSeconds(validTimePeriodSeconds *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) UpgradeToAndCall(newImplementation common.Address, data []byte) (*types.Transaction, error)
- func (_StorkContract *StorkContractSession) ValidTimePeriodSeconds() (*big.Int, error)
- func (_StorkContract *StorkContractSession) VerifyMerkleRoot(leaves [][32]byte, root [32]byte) (bool, error)
- func (_StorkContract *StorkContractSession) VerifyPublisherSignatureV1(oraclePubKey common.Address, assetPairId string, timestamp *big.Int, ...) (bool, error)
- func (_StorkContract *StorkContractSession) VerifyPublisherSignaturesV1(signatures []StorkStructsPublisherSignature, merkleRoot [32]byte) (bool, error)
- func (_StorkContract *StorkContractSession) VerifyStorkSignatureV1(storkPubKey common.Address, id [32]byte, recvTime *big.Int, ...) (bool, error)
- func (_StorkContract *StorkContractSession) Version() (string, error)
- type StorkContractTransactor
- func (_StorkContract *StorkContractTransactor) Initialize(opts *bind.TransactOpts, initialOwner common.Address, ...) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) RenounceOwnership(opts *bind.TransactOpts) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) TransferOwnership(opts *bind.TransactOpts, newOwner common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) UpdateSingleUpdateFeeInWei(opts *bind.TransactOpts, maxStorkPerBlock *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) UpdateStorkPublicKey(opts *bind.TransactOpts, storkPublicKey common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) UpdateTemporalNumericValuesV1(opts *bind.TransactOpts, updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) UpdateValidTimePeriodSeconds(opts *bind.TransactOpts, validTimePeriodSeconds *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactor) UpgradeToAndCall(opts *bind.TransactOpts, newImplementation common.Address, data []byte) (*types.Transaction, error)
- type StorkContractTransactorRaw
- type StorkContractTransactorSession
- func (_StorkContract *StorkContractTransactorSession) Initialize(initialOwner common.Address, storkPublicKey common.Address, ...) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) RenounceOwnership() (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) TransferOwnership(newOwner common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) UpdateSingleUpdateFeeInWei(maxStorkPerBlock *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) UpdateStorkPublicKey(storkPublicKey common.Address) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) UpdateTemporalNumericValuesV1(updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) UpdateValidTimePeriodSeconds(validTimePeriodSeconds *big.Int) (*types.Transaction, error)
- func (_StorkContract *StorkContractTransactorSession) UpgradeToAndCall(newImplementation common.Address, data []byte) (*types.Transaction, error)
- type StorkContractUpgraded
- type StorkContractUpgradedIterator
- type StorkContractValueUpdate
- type StorkContractValueUpdateIterator
- type StorkSignedPrice
- type StorkStructsPublisherSignature
- type StorkStructsTemporalNumericValue
- type StorkStructsTemporalNumericValueInput
- type SubscriberMessage
- type TimestampedSignature
- type VerifyPayload
Constants ¶
const ( ReconnectInterval = 1 * time.Second ReconnectionAttemptErrorThreshold = 5 )
const AssetConfigFileFlag = "asset-config-file"
const BatchingWindowFlag = "batching-window"
const ChainRpcUrlFlag = "chain-rpc-url"
const ContractAddressFlag = "contract-address"
const MnemonicFileFlag = "mnemonic-file"
const PollingFrequencyFlag = "polling-frequency"
const StorkAuthCredentialsFlag = "stork-auth-credentials"
const StorkWebsocketEndpointFlag = "stork-ws-endpoint"
required
const VerifyPublishersFlag = "verify-publishers"
optional
Variables ¶
var EvmpushCmd = &cobra.Command{
Use: "evm",
Short: "Push WebSocket prices to EVM contract",
Run: runEvmPush,
}
var StorkContractABI = StorkContractMetaData.ABI
StorkContractABI is the input ABI used to generate the binding from. Deprecated: Use StorkContractMetaData.ABI instead.
var StorkContractMetaData = &bind.MetaData{
ABI: "[{\"inputs\":[{\"internalType\":\"address\",\"name\":\"target\",\"type\":\"address\"}],\"name\":\"AddressEmptyCode\",\"type\":\"error\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"implementation\",\"type\":\"address\"}],\"name\":\"ERC1967InvalidImplementation\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"ERC1967NonPayable\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"FailedInnerCall\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"InsufficientFee\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"InvalidInitialization\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"InvalidSignature\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"NoFreshUpdate\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"NotFound\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"NotInitializing\",\"type\":\"error\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"owner\",\"type\":\"address\"}],\"name\":\"OwnableInvalidOwner\",\"type\":\"error\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"account\",\"type\":\"address\"}],\"name\":\"OwnableUnauthorizedAccount\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"StaleValue\",\"type\":\"error\"},{\"inputs\":[],\"name\":\"UUPSUnauthorizedCallContext\",\"type\":\"error\"},{\"inputs\":[{\"internalType\":\"bytes32\",\"name\":\"slot\",\"type\":\"bytes32\"}],\"name\":\"UUPSUnsupportedProxiableUUID\",\"type\":\"error\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":false,\"internalType\":\"uint64\",\"name\":\"version\",\"type\":\"uint64\"}],\"name\":\"Initialized\",\"type\":\"event\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":true,\"internalType\":\"address\",\"name\":\"previousOwner\",\"type\":\"address\"},{\"indexed\":true,\"internalType\":\"address\",\"name\":\"newOwner\",\"type\":\"address\"}],\"name\":\"OwnershipTransferred\",\"type\":\"event\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":true,\"internalType\":\"address\",\"name\":\"implementation\",\"type\":\"address\"}],\"name\":\"Upgraded\",\"type\":\"event\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":true,\"internalType\":\"bytes32\",\"name\":\"id\",\"type\":\"bytes32\"},{\"indexed\":false,\"internalType\":\"uint64\",\"name\":\"timestampNs\",\"type\":\"uint64\"},{\"indexed\":false,\"internalType\":\"int192\",\"name\":\"quantizedValue\",\"type\":\"int192\"}],\"name\":\"ValueUpdate\",\"type\":\"event\"},{\"inputs\":[],\"name\":\"UPGRADE_INTERFACE_VERSION\",\"outputs\":[{\"internalType\":\"string\",\"name\":\"\",\"type\":\"string\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"bytes32\",\"name\":\"id\",\"type\":\"bytes32\"}],\"name\":\"getTemporalNumericValueV1\",\"outputs\":[{\"components\":[{\"internalType\":\"uint64\",\"name\":\"timestampNs\",\"type\":\"uint64\"},{\"internalType\":\"int192\",\"name\":\"quantizedValue\",\"type\":\"int192\"}],\"internalType\":\"structStorkStructs.TemporalNumericValue\",\"name\":\"value\",\"type\":\"tuple\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"components\":[{\"components\":[{\"internalType\":\"uint64\",\"name\":\"timestampNs\",\"type\":\"uint64\"},{\"internalType\":\"int192\",\"name\":\"quantizedValue\",\"type\":\"int192\"}],\"internalType\":\"structStorkStructs.TemporalNumericValue\",\"name\":\"temporalNumericValue\",\"type\":\"tuple\"},{\"internalType\":\"bytes32\",\"name\":\"id\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"publisherMerkleRoot\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"valueComputeAlgHash\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"r\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"s\",\"type\":\"bytes32\"},{\"internalType\":\"uint8\",\"name\":\"v\",\"type\":\"uint8\"}],\"internalType\":\"structStorkStructs.TemporalNumericValueInput[]\",\"name\":\"updateData\",\"type\":\"tuple[]\"}],\"name\":\"getUpdateFeeV1\",\"outputs\":[{\"internalType\":\"uint256\",\"name\":\"feeAmount\",\"type\":\"uint256\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"initialOwner\",\"type\":\"address\"},{\"internalType\":\"address\",\"name\":\"storkPublicKey\",\"type\":\"address\"},{\"internalType\":\"uint256\",\"name\":\"validTimePeriodSeconds\",\"type\":\"uint256\"},{\"internalType\":\"uint256\",\"name\":\"singleUpdateFeeInWei\",\"type\":\"uint256\"}],\"name\":\"initialize\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"owner\",\"outputs\":[{\"internalType\":\"address\",\"name\":\"\",\"type\":\"address\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"proxiableUUID\",\"outputs\":[{\"internalType\":\"bytes32\",\"name\":\"\",\"type\":\"bytes32\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"renounceOwnership\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"singleUpdateFeeInWei\",\"outputs\":[{\"internalType\":\"uint256\",\"name\":\"\",\"type\":\"uint256\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"storkPublicKey\",\"outputs\":[{\"internalType\":\"address\",\"name\":\"\",\"type\":\"address\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"newOwner\",\"type\":\"address\"}],\"name\":\"transferOwnership\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"uint256\",\"name\":\"maxStorkPerBlock\",\"type\":\"uint256\"}],\"name\":\"updateSingleUpdateFeeInWei\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"storkPublicKey\",\"type\":\"address\"}],\"name\":\"updateStorkPublicKey\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[{\"components\":[{\"components\":[{\"internalType\":\"uint64\",\"name\":\"timestampNs\",\"type\":\"uint64\"},{\"internalType\":\"int192\",\"name\":\"quantizedValue\",\"type\":\"int192\"}],\"internalType\":\"structStorkStructs.TemporalNumericValue\",\"name\":\"temporalNumericValue\",\"type\":\"tuple\"},{\"internalType\":\"bytes32\",\"name\":\"id\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"publisherMerkleRoot\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"valueComputeAlgHash\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"r\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"s\",\"type\":\"bytes32\"},{\"internalType\":\"uint8\",\"name\":\"v\",\"type\":\"uint8\"}],\"internalType\":\"structStorkStructs.TemporalNumericValueInput[]\",\"name\":\"updateData\",\"type\":\"tuple[]\"}],\"name\":\"updateTemporalNumericValuesV1\",\"outputs\":[],\"stateMutability\":\"payable\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"uint256\",\"name\":\"validTimePeriodSeconds\",\"type\":\"uint256\"}],\"name\":\"updateValidTimePeriodSeconds\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"newImplementation\",\"type\":\"address\"},{\"internalType\":\"bytes\",\"name\":\"data\",\"type\":\"bytes\"}],\"name\":\"upgradeToAndCall\",\"outputs\":[],\"stateMutability\":\"payable\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"validTimePeriodSeconds\",\"outputs\":[{\"internalType\":\"uint256\",\"name\":\"\",\"type\":\"uint256\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"bytes32[]\",\"name\":\"leaves\",\"type\":\"bytes32[]\"},{\"internalType\":\"bytes32\",\"name\":\"root\",\"type\":\"bytes32\"}],\"name\":\"verifyMerkleRoot\",\"outputs\":[{\"internalType\":\"bool\",\"name\":\"\",\"type\":\"bool\"}],\"stateMutability\":\"pure\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"oraclePubKey\",\"type\":\"address\"},{\"internalType\":\"string\",\"name\":\"assetPairId\",\"type\":\"string\"},{\"internalType\":\"uint256\",\"name\":\"timestamp\",\"type\":\"uint256\"},{\"internalType\":\"uint256\",\"name\":\"value\",\"type\":\"uint256\"},{\"internalType\":\"bytes32\",\"name\":\"r\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"s\",\"type\":\"bytes32\"},{\"internalType\":\"uint8\",\"name\":\"v\",\"type\":\"uint8\"}],\"name\":\"verifyPublisherSignatureV1\",\"outputs\":[{\"internalType\":\"bool\",\"name\":\"\",\"type\":\"bool\"}],\"stateMutability\":\"pure\",\"type\":\"function\"},{\"inputs\":[{\"components\":[{\"internalType\":\"address\",\"name\":\"pubKey\",\"type\":\"address\"},{\"internalType\":\"string\",\"name\":\"assetPairId\",\"type\":\"string\"},{\"internalType\":\"uint64\",\"name\":\"timestamp\",\"type\":\"uint64\"},{\"internalType\":\"uint256\",\"name\":\"quantizedValue\",\"type\":\"uint256\"},{\"internalType\":\"bytes32\",\"name\":\"r\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"s\",\"type\":\"bytes32\"},{\"internalType\":\"uint8\",\"name\":\"v\",\"type\":\"uint8\"}],\"internalType\":\"structStorkStructs.PublisherSignature[]\",\"name\":\"signatures\",\"type\":\"tuple[]\"},{\"internalType\":\"bytes32\",\"name\":\"merkleRoot\",\"type\":\"bytes32\"}],\"name\":\"verifyPublisherSignaturesV1\",\"outputs\":[{\"internalType\":\"bool\",\"name\":\"\",\"type\":\"bool\"}],\"stateMutability\":\"pure\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"address\",\"name\":\"storkPubKey\",\"type\":\"address\"},{\"internalType\":\"bytes32\",\"name\":\"id\",\"type\":\"bytes32\"},{\"internalType\":\"uint256\",\"name\":\"recvTime\",\"type\":\"uint256\"},{\"internalType\":\"int256\",\"name\":\"quantizedValue\",\"type\":\"int256\"},{\"internalType\":\"bytes32\",\"name\":\"publisherMerkleRoot\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"valueComputeAlgHash\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"r\",\"type\":\"bytes32\"},{\"internalType\":\"bytes32\",\"name\":\"s\",\"type\":\"bytes32\"},{\"internalType\":\"uint8\",\"name\":\"v\",\"type\":\"uint8\"}],\"name\":\"verifyStorkSignatureV1\",\"outputs\":[{\"internalType\":\"bool\",\"name\":\"\",\"type\":\"bool\"}],\"stateMutability\":\"pure\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"version\",\"outputs\":[{\"internalType\":\"string\",\"name\":\"\",\"type\":\"string\"}],\"stateMutability\":\"pure\",\"type\":\"function\"}]",
}
StorkContractMetaData contains all meta data concerning the StorkContract contract.
Functions ¶
func BaseLogger ¶
Types ¶
type AggregatedSignedPrice ¶
type AggregatedSignedPrice struct { Timestamp int64 `json:"timestamp"` AssetId AssetId `json:"asset_id"` StorkSignedPrice *StorkSignedPrice `json:"stork_signed_price,omitempty"` SignedPrices []*PublisherSignedPrice `json:"signed_prices"` }
type AssetConfig ¶
type AssetConfig struct {
Assets map[AssetId]AssetEntry `yaml:"assets"`
}
Config
func LoadConfig ¶
func LoadConfig(filename string) (*AssetConfig, error)
type AssetEntry ¶
type AssetEntry struct { AssetId AssetId `yaml:"asset_id"` EncodedAssetId EncodedAssetId `yaml:"encoded_asset_id"` PercentChangeThreshold float64 `yaml:"percent_change_threshold"` FallbackPeriodSecs uint64 `yaml:"fallback_period_sec"` }
type EvmSignature ¶
type OraclePricesMessage ¶
type OraclePricesMessage struct { Type string `json:"type"` TraceID string `json:"trace_id"` Data map[string]AggregatedSignedPrice `json:"data"` }
type PublisherSignedPrice ¶
type PublisherSignedPrice struct { PublisherKey PublisherKey `json:"publisher_key"` ExternalAssetId string `json:"external_asset_id"` QuantizedPrice QuantizedPrice `json:"price"` TimestampedSignature TimestampedSignature `json:"timestamped_signature"` }
type StorkAggregatorWebsocketClient ¶
type StorkAggregatorWebsocketClient struct {
// contains filtered or unexported fields
}
func NewStorkAggregatorWebsocketClient ¶
func NewStorkAggregatorWebsocketClient(baseEndpoint, authToken string, assetIds []AssetId, logger zerolog.Logger) StorkAggregatorWebsocketClient
func (*StorkAggregatorWebsocketClient) Run ¶
func (p *StorkAggregatorWebsocketClient) Run(priceChan chan AggregatedSignedPrice)
type StorkCalculationAlg ¶
type StorkContract ¶
type StorkContract struct { StorkContractCaller // Read-only binding to the contract StorkContractTransactor // Write-only binding to the contract StorkContractFilterer // Log filterer for contract events }
StorkContract is an auto generated Go binding around an Ethereum contract.
func NewStorkContract ¶
func NewStorkContract(address common.Address, backend bind.ContractBackend) (*StorkContract, error)
NewStorkContract creates a new instance of StorkContract, bound to a specific deployed contract.
type StorkContractCaller ¶
type StorkContractCaller struct {
// contains filtered or unexported fields
}
StorkContractCaller is an auto generated read-only Go binding around an Ethereum contract.
func NewStorkContractCaller ¶
func NewStorkContractCaller(address common.Address, caller bind.ContractCaller) (*StorkContractCaller, error)
NewStorkContractCaller creates a new read-only instance of StorkContract, bound to a specific deployed contract.
func (*StorkContractCaller) GetTemporalNumericValueV1 ¶
func (_StorkContract *StorkContractCaller) GetTemporalNumericValueV1(opts *bind.CallOpts, id [32]byte) (StorkStructsTemporalNumericValue, error)
GetTemporalNumericValueV1 is a free data retrieval call binding the contract method 0x19af7a40.
Solidity: function getTemporalNumericValueV1(bytes32 id) view returns((uint64,int192) value)
func (*StorkContractCaller) GetUpdateFeeV1 ¶
func (_StorkContract *StorkContractCaller) GetUpdateFeeV1(opts *bind.CallOpts, updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
GetUpdateFeeV1 is a free data retrieval call binding the contract method 0xb2255ba3.
Solidity: function getUpdateFeeV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) view returns(uint256 feeAmount)
func (*StorkContractCaller) Owner ¶
Owner is a free data retrieval call binding the contract method 0x8da5cb5b.
Solidity: function owner() view returns(address)
func (*StorkContractCaller) ProxiableUUID ¶
func (_StorkContract *StorkContractCaller) ProxiableUUID(opts *bind.CallOpts) ([32]byte, error)
ProxiableUUID is a free data retrieval call binding the contract method 0x52d1902d.
Solidity: function proxiableUUID() view returns(bytes32)
func (*StorkContractCaller) SingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractCaller) SingleUpdateFeeInWei(opts *bind.CallOpts) (*big.Int, error)
SingleUpdateFeeInWei is a free data retrieval call binding the contract method 0x48b6404d.
Solidity: function singleUpdateFeeInWei() view returns(uint256)
func (*StorkContractCaller) StorkPublicKey ¶
func (_StorkContract *StorkContractCaller) StorkPublicKey(opts *bind.CallOpts) (common.Address, error)
StorkPublicKey is a free data retrieval call binding the contract method 0x8eeae4a7.
Solidity: function storkPublicKey() view returns(address)
func (*StorkContractCaller) UPGRADEINTERFACEVERSION ¶
func (_StorkContract *StorkContractCaller) UPGRADEINTERFACEVERSION(opts *bind.CallOpts) (string, error)
UPGRADEINTERFACEVERSION is a free data retrieval call binding the contract method 0xad3cb1cc.
Solidity: function UPGRADE_INTERFACE_VERSION() view returns(string)
func (*StorkContractCaller) ValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractCaller) ValidTimePeriodSeconds(opts *bind.CallOpts) (*big.Int, error)
ValidTimePeriodSeconds is a free data retrieval call binding the contract method 0xcb718a9b.
Solidity: function validTimePeriodSeconds() view returns(uint256)
func (*StorkContractCaller) VerifyMerkleRoot ¶
func (_StorkContract *StorkContractCaller) VerifyMerkleRoot(opts *bind.CallOpts, leaves [][32]byte, root [32]byte) (bool, error)
VerifyMerkleRoot is a free data retrieval call binding the contract method 0x44ecc82c.
Solidity: function verifyMerkleRoot(bytes32[] leaves, bytes32 root) pure returns(bool)
func (*StorkContractCaller) VerifyPublisherSignatureV1 ¶
func (_StorkContract *StorkContractCaller) VerifyPublisherSignatureV1(opts *bind.CallOpts, oraclePubKey common.Address, assetPairId string, timestamp *big.Int, value *big.Int, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyPublisherSignatureV1 is a free data retrieval call binding the contract method 0xd83cfe2c.
Solidity: function verifyPublisherSignatureV1(address oraclePubKey, string assetPairId, uint256 timestamp, uint256 value, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
func (*StorkContractCaller) VerifyPublisherSignaturesV1 ¶
func (_StorkContract *StorkContractCaller) VerifyPublisherSignaturesV1(opts *bind.CallOpts, signatures []StorkStructsPublisherSignature, merkleRoot [32]byte) (bool, error)
VerifyPublisherSignaturesV1 is a free data retrieval call binding the contract method 0x1519e36c.
Solidity: function verifyPublisherSignaturesV1((address,string,uint64,uint256,bytes32,bytes32,uint8)[] signatures, bytes32 merkleRoot) pure returns(bool)
func (*StorkContractCaller) VerifyStorkSignatureV1 ¶
func (_StorkContract *StorkContractCaller) VerifyStorkSignatureV1(opts *bind.CallOpts, storkPubKey common.Address, id [32]byte, recvTime *big.Int, quantizedValue *big.Int, publisherMerkleRoot [32]byte, valueComputeAlgHash [32]byte, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyStorkSignatureV1 is a free data retrieval call binding the contract method 0x2a6cd210.
Solidity: function verifyStorkSignatureV1(address storkPubKey, bytes32 id, uint256 recvTime, int256 quantizedValue, bytes32 publisherMerkleRoot, bytes32 valueComputeAlgHash, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
type StorkContractCallerRaw ¶
type StorkContractCallerRaw struct {
Contract *StorkContractCaller // Generic read-only contract binding to access the raw methods on
}
StorkContractCallerRaw is an auto generated low-level read-only Go binding around an Ethereum contract.
func (*StorkContractCallerRaw) Call ¶
func (_StorkContract *StorkContractCallerRaw) Call(opts *bind.CallOpts, result *[]interface{}, method string, params ...interface{}) error
Call invokes the (constant) contract method with params as input values and sets the output to result. The result type might be a single field for simple returns, a slice of interfaces for anonymous returns and a struct for named returns.
type StorkContractCallerSession ¶
type StorkContractCallerSession struct { Contract *StorkContractCaller // Generic contract caller binding to set the session for CallOpts bind.CallOpts // Call options to use throughout this session }
StorkContractCallerSession is an auto generated read-only Go binding around an Ethereum contract, with pre-set call options.
func (*StorkContractCallerSession) GetTemporalNumericValueV1 ¶
func (_StorkContract *StorkContractCallerSession) GetTemporalNumericValueV1(id [32]byte) (StorkStructsTemporalNumericValue, error)
GetTemporalNumericValueV1 is a free data retrieval call binding the contract method 0x19af7a40.
Solidity: function getTemporalNumericValueV1(bytes32 id) view returns((uint64,int192) value)
func (*StorkContractCallerSession) GetUpdateFeeV1 ¶
func (_StorkContract *StorkContractCallerSession) GetUpdateFeeV1(updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
GetUpdateFeeV1 is a free data retrieval call binding the contract method 0xb2255ba3.
Solidity: function getUpdateFeeV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) view returns(uint256 feeAmount)
func (*StorkContractCallerSession) Owner ¶
func (_StorkContract *StorkContractCallerSession) Owner() (common.Address, error)
Owner is a free data retrieval call binding the contract method 0x8da5cb5b.
Solidity: function owner() view returns(address)
func (*StorkContractCallerSession) ProxiableUUID ¶
func (_StorkContract *StorkContractCallerSession) ProxiableUUID() ([32]byte, error)
ProxiableUUID is a free data retrieval call binding the contract method 0x52d1902d.
Solidity: function proxiableUUID() view returns(bytes32)
func (*StorkContractCallerSession) SingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractCallerSession) SingleUpdateFeeInWei() (*big.Int, error)
SingleUpdateFeeInWei is a free data retrieval call binding the contract method 0x48b6404d.
Solidity: function singleUpdateFeeInWei() view returns(uint256)
func (*StorkContractCallerSession) StorkPublicKey ¶
func (_StorkContract *StorkContractCallerSession) StorkPublicKey() (common.Address, error)
StorkPublicKey is a free data retrieval call binding the contract method 0x8eeae4a7.
Solidity: function storkPublicKey() view returns(address)
func (*StorkContractCallerSession) UPGRADEINTERFACEVERSION ¶
func (_StorkContract *StorkContractCallerSession) UPGRADEINTERFACEVERSION() (string, error)
UPGRADEINTERFACEVERSION is a free data retrieval call binding the contract method 0xad3cb1cc.
Solidity: function UPGRADE_INTERFACE_VERSION() view returns(string)
func (*StorkContractCallerSession) ValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractCallerSession) ValidTimePeriodSeconds() (*big.Int, error)
ValidTimePeriodSeconds is a free data retrieval call binding the contract method 0xcb718a9b.
Solidity: function validTimePeriodSeconds() view returns(uint256)
func (*StorkContractCallerSession) VerifyMerkleRoot ¶
func (_StorkContract *StorkContractCallerSession) VerifyMerkleRoot(leaves [][32]byte, root [32]byte) (bool, error)
VerifyMerkleRoot is a free data retrieval call binding the contract method 0x44ecc82c.
Solidity: function verifyMerkleRoot(bytes32[] leaves, bytes32 root) pure returns(bool)
func (*StorkContractCallerSession) VerifyPublisherSignatureV1 ¶
func (_StorkContract *StorkContractCallerSession) VerifyPublisherSignatureV1(oraclePubKey common.Address, assetPairId string, timestamp *big.Int, value *big.Int, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyPublisherSignatureV1 is a free data retrieval call binding the contract method 0xd83cfe2c.
Solidity: function verifyPublisherSignatureV1(address oraclePubKey, string assetPairId, uint256 timestamp, uint256 value, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
func (*StorkContractCallerSession) VerifyPublisherSignaturesV1 ¶
func (_StorkContract *StorkContractCallerSession) VerifyPublisherSignaturesV1(signatures []StorkStructsPublisherSignature, merkleRoot [32]byte) (bool, error)
VerifyPublisherSignaturesV1 is a free data retrieval call binding the contract method 0x1519e36c.
Solidity: function verifyPublisherSignaturesV1((address,string,uint64,uint256,bytes32,bytes32,uint8)[] signatures, bytes32 merkleRoot) pure returns(bool)
func (*StorkContractCallerSession) VerifyStorkSignatureV1 ¶
func (_StorkContract *StorkContractCallerSession) VerifyStorkSignatureV1(storkPubKey common.Address, id [32]byte, recvTime *big.Int, quantizedValue *big.Int, publisherMerkleRoot [32]byte, valueComputeAlgHash [32]byte, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyStorkSignatureV1 is a free data retrieval call binding the contract method 0x2a6cd210.
Solidity: function verifyStorkSignatureV1(address storkPubKey, bytes32 id, uint256 recvTime, int256 quantizedValue, bytes32 publisherMerkleRoot, bytes32 valueComputeAlgHash, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
func (*StorkContractCallerSession) Version ¶
func (_StorkContract *StorkContractCallerSession) Version() (string, error)
Version is a free data retrieval call binding the contract method 0x54fd4d50.
Solidity: function version() pure returns(string)
type StorkContractFilterer ¶
type StorkContractFilterer struct {
// contains filtered or unexported fields
}
StorkContractFilterer is an auto generated log filtering Go binding around an Ethereum contract events.
func NewStorkContractFilterer ¶
func NewStorkContractFilterer(address common.Address, filterer bind.ContractFilterer) (*StorkContractFilterer, error)
NewStorkContractFilterer creates a new log filterer instance of StorkContract, bound to a specific deployed contract.
func (*StorkContractFilterer) FilterInitialized ¶
func (_StorkContract *StorkContractFilterer) FilterInitialized(opts *bind.FilterOpts) (*StorkContractInitializedIterator, error)
FilterInitialized is a free log retrieval operation binding the contract event 0xc7f505b2f371ae2175ee4913f4499e1f2633a7b5936321eed1cdaeb6115181d2.
Solidity: event Initialized(uint64 version)
func (*StorkContractFilterer) FilterOwnershipTransferred ¶
func (_StorkContract *StorkContractFilterer) FilterOwnershipTransferred(opts *bind.FilterOpts, previousOwner []common.Address, newOwner []common.Address) (*StorkContractOwnershipTransferredIterator, error)
FilterOwnershipTransferred is a free log retrieval operation binding the contract event 0x8be0079c531659141344cd1fd0a4f28419497f9722a3daafe3b4186f6b6457e0.
Solidity: event OwnershipTransferred(address indexed previousOwner, address indexed newOwner)
func (*StorkContractFilterer) FilterUpgraded ¶
func (_StorkContract *StorkContractFilterer) FilterUpgraded(opts *bind.FilterOpts, implementation []common.Address) (*StorkContractUpgradedIterator, error)
FilterUpgraded is a free log retrieval operation binding the contract event 0xbc7cd75a20ee27fd9adebab32041f755214dbc6bffa90cc0225b39da2e5c2d3b.
Solidity: event Upgraded(address indexed implementation)
func (*StorkContractFilterer) FilterValueUpdate ¶
func (_StorkContract *StorkContractFilterer) FilterValueUpdate(opts *bind.FilterOpts, id [][32]byte) (*StorkContractValueUpdateIterator, error)
FilterValueUpdate is a free log retrieval operation binding the contract event 0xe24720f45cb74f2d55f1deebb6098f50f10b511dab8a7d47c4819a08dcd0b895.
Solidity: event ValueUpdate(bytes32 indexed id, uint64 timestampNs, int192 quantizedValue)
func (*StorkContractFilterer) ParseInitialized ¶
func (_StorkContract *StorkContractFilterer) ParseInitialized(log types.Log) (*StorkContractInitialized, error)
ParseInitialized is a log parse operation binding the contract event 0xc7f505b2f371ae2175ee4913f4499e1f2633a7b5936321eed1cdaeb6115181d2.
Solidity: event Initialized(uint64 version)
func (*StorkContractFilterer) ParseOwnershipTransferred ¶
func (_StorkContract *StorkContractFilterer) ParseOwnershipTransferred(log types.Log) (*StorkContractOwnershipTransferred, error)
ParseOwnershipTransferred is a log parse operation binding the contract event 0x8be0079c531659141344cd1fd0a4f28419497f9722a3daafe3b4186f6b6457e0.
Solidity: event OwnershipTransferred(address indexed previousOwner, address indexed newOwner)
func (*StorkContractFilterer) ParseUpgraded ¶
func (_StorkContract *StorkContractFilterer) ParseUpgraded(log types.Log) (*StorkContractUpgraded, error)
ParseUpgraded is a log parse operation binding the contract event 0xbc7cd75a20ee27fd9adebab32041f755214dbc6bffa90cc0225b39da2e5c2d3b.
Solidity: event Upgraded(address indexed implementation)
func (*StorkContractFilterer) ParseValueUpdate ¶
func (_StorkContract *StorkContractFilterer) ParseValueUpdate(log types.Log) (*StorkContractValueUpdate, error)
ParseValueUpdate is a log parse operation binding the contract event 0xe24720f45cb74f2d55f1deebb6098f50f10b511dab8a7d47c4819a08dcd0b895.
Solidity: event ValueUpdate(bytes32 indexed id, uint64 timestampNs, int192 quantizedValue)
func (*StorkContractFilterer) WatchInitialized ¶
func (_StorkContract *StorkContractFilterer) WatchInitialized(opts *bind.WatchOpts, sink chan<- *StorkContractInitialized) (event.Subscription, error)
WatchInitialized is a free log subscription operation binding the contract event 0xc7f505b2f371ae2175ee4913f4499e1f2633a7b5936321eed1cdaeb6115181d2.
Solidity: event Initialized(uint64 version)
func (*StorkContractFilterer) WatchOwnershipTransferred ¶
func (_StorkContract *StorkContractFilterer) WatchOwnershipTransferred(opts *bind.WatchOpts, sink chan<- *StorkContractOwnershipTransferred, previousOwner []common.Address, newOwner []common.Address) (event.Subscription, error)
WatchOwnershipTransferred is a free log subscription operation binding the contract event 0x8be0079c531659141344cd1fd0a4f28419497f9722a3daafe3b4186f6b6457e0.
Solidity: event OwnershipTransferred(address indexed previousOwner, address indexed newOwner)
func (*StorkContractFilterer) WatchUpgraded ¶
func (_StorkContract *StorkContractFilterer) WatchUpgraded(opts *bind.WatchOpts, sink chan<- *StorkContractUpgraded, implementation []common.Address) (event.Subscription, error)
WatchUpgraded is a free log subscription operation binding the contract event 0xbc7cd75a20ee27fd9adebab32041f755214dbc6bffa90cc0225b39da2e5c2d3b.
Solidity: event Upgraded(address indexed implementation)
func (*StorkContractFilterer) WatchValueUpdate ¶
func (_StorkContract *StorkContractFilterer) WatchValueUpdate(opts *bind.WatchOpts, sink chan<- *StorkContractValueUpdate, id [][32]byte) (event.Subscription, error)
WatchValueUpdate is a free log subscription operation binding the contract event 0xe24720f45cb74f2d55f1deebb6098f50f10b511dab8a7d47c4819a08dcd0b895.
Solidity: event ValueUpdate(bytes32 indexed id, uint64 timestampNs, int192 quantizedValue)
type StorkContractInitialized ¶
type StorkContractInitialized struct { Version uint64 Raw types.Log // Blockchain specific contextual infos }
StorkContractInitialized represents a Initialized event raised by the StorkContract contract.
type StorkContractInitializedIterator ¶
type StorkContractInitializedIterator struct { Event *StorkContractInitialized // Event containing the contract specifics and raw log // contains filtered or unexported fields }
StorkContractInitializedIterator is returned from FilterInitialized and is used to iterate over the raw logs and unpacked data for Initialized events raised by the StorkContract contract.
func (*StorkContractInitializedIterator) Close ¶
func (it *StorkContractInitializedIterator) Close() error
Close terminates the iteration process, releasing any pending underlying resources.
func (*StorkContractInitializedIterator) Error ¶
func (it *StorkContractInitializedIterator) Error() error
Error returns any retrieval or parsing error occurred during filtering.
func (*StorkContractInitializedIterator) Next ¶
func (it *StorkContractInitializedIterator) Next() bool
Next advances the iterator to the subsequent event, returning whether there are any more events found. In case of a retrieval or parsing error, false is returned and Error() can be queried for the exact failure.
type StorkContractInterfacer ¶
type StorkContractInterfacer struct {
// contains filtered or unexported fields
}
func (*StorkContractInterfacer) BatchPushToContract ¶
func (sci *StorkContractInterfacer) BatchPushToContract(priceUpdates map[InternalEncodedAssetId]AggregatedSignedPrice) error
func (*StorkContractInterfacer) ListenContractEvents ¶
func (sci *StorkContractInterfacer) ListenContractEvents(ch chan map[InternalEncodedAssetId]StorkStructsTemporalNumericValue)
func (*StorkContractInterfacer) Poll ¶
func (sci *StorkContractInterfacer) Poll(encodedAssetIds []InternalEncodedAssetId, ch chan map[InternalEncodedAssetId]StorkStructsTemporalNumericValue)
func (*StorkContractInterfacer) PullValues ¶
func (sci *StorkContractInterfacer) PullValues(encodedAssetIds []InternalEncodedAssetId) (map[InternalEncodedAssetId]StorkStructsTemporalNumericValue, error)
type StorkContractOwnershipTransferred ¶
type StorkContractOwnershipTransferred struct { PreviousOwner common.Address NewOwner common.Address Raw types.Log // Blockchain specific contextual infos }
StorkContractOwnershipTransferred represents a OwnershipTransferred event raised by the StorkContract contract.
type StorkContractOwnershipTransferredIterator ¶
type StorkContractOwnershipTransferredIterator struct { Event *StorkContractOwnershipTransferred // Event containing the contract specifics and raw log // contains filtered or unexported fields }
StorkContractOwnershipTransferredIterator is returned from FilterOwnershipTransferred and is used to iterate over the raw logs and unpacked data for OwnershipTransferred events raised by the StorkContract contract.
func (*StorkContractOwnershipTransferredIterator) Close ¶
func (it *StorkContractOwnershipTransferredIterator) Close() error
Close terminates the iteration process, releasing any pending underlying resources.
func (*StorkContractOwnershipTransferredIterator) Error ¶
func (it *StorkContractOwnershipTransferredIterator) Error() error
Error returns any retrieval or parsing error occurred during filtering.
func (*StorkContractOwnershipTransferredIterator) Next ¶
func (it *StorkContractOwnershipTransferredIterator) Next() bool
Next advances the iterator to the subsequent event, returning whether there are any more events found. In case of a retrieval or parsing error, false is returned and Error() can be queried for the exact failure.
type StorkContractRaw ¶
type StorkContractRaw struct {
Contract *StorkContract // Generic contract binding to access the raw methods on
}
StorkContractRaw is an auto generated low-level Go binding around an Ethereum contract.
func (*StorkContractRaw) Call ¶
func (_StorkContract *StorkContractRaw) Call(opts *bind.CallOpts, result *[]interface{}, method string, params ...interface{}) error
Call invokes the (constant) contract method with params as input values and sets the output to result. The result type might be a single field for simple returns, a slice of interfaces for anonymous returns and a struct for named returns.
func (*StorkContractRaw) Transact ¶
func (_StorkContract *StorkContractRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)
Transact invokes the (paid) contract method with params as input values.
func (*StorkContractRaw) Transfer ¶
func (_StorkContract *StorkContractRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)
Transfer initiates a plain transaction to move funds to the contract, calling its default method if one is available.
type StorkContractSession ¶
type StorkContractSession struct { Contract *StorkContract // Generic contract binding to set the session for CallOpts bind.CallOpts // Call options to use throughout this session TransactOpts bind.TransactOpts // Transaction auth options to use throughout this session }
StorkContractSession is an auto generated Go binding around an Ethereum contract, with pre-set call and transact options.
func (*StorkContractSession) GetTemporalNumericValueV1 ¶
func (_StorkContract *StorkContractSession) GetTemporalNumericValueV1(id [32]byte) (StorkStructsTemporalNumericValue, error)
GetTemporalNumericValueV1 is a free data retrieval call binding the contract method 0x19af7a40.
Solidity: function getTemporalNumericValueV1(bytes32 id) view returns((uint64,int192) value)
func (*StorkContractSession) GetUpdateFeeV1 ¶
func (_StorkContract *StorkContractSession) GetUpdateFeeV1(updateData []StorkStructsTemporalNumericValueInput) (*big.Int, error)
GetUpdateFeeV1 is a free data retrieval call binding the contract method 0xb2255ba3.
Solidity: function getUpdateFeeV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) view returns(uint256 feeAmount)
func (*StorkContractSession) Initialize ¶
func (_StorkContract *StorkContractSession) Initialize(initialOwner common.Address, storkPublicKey common.Address, validTimePeriodSeconds *big.Int, singleUpdateFeeInWei *big.Int) (*types.Transaction, error)
Initialize is a paid mutator transaction binding the contract method 0xeb990c59.
Solidity: function initialize(address initialOwner, address storkPublicKey, uint256 validTimePeriodSeconds, uint256 singleUpdateFeeInWei) returns()
func (*StorkContractSession) Owner ¶
func (_StorkContract *StorkContractSession) Owner() (common.Address, error)
Owner is a free data retrieval call binding the contract method 0x8da5cb5b.
Solidity: function owner() view returns(address)
func (*StorkContractSession) ProxiableUUID ¶
func (_StorkContract *StorkContractSession) ProxiableUUID() ([32]byte, error)
ProxiableUUID is a free data retrieval call binding the contract method 0x52d1902d.
Solidity: function proxiableUUID() view returns(bytes32)
func (*StorkContractSession) RenounceOwnership ¶
func (_StorkContract *StorkContractSession) RenounceOwnership() (*types.Transaction, error)
RenounceOwnership is a paid mutator transaction binding the contract method 0x715018a6.
Solidity: function renounceOwnership() returns()
func (*StorkContractSession) SingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractSession) SingleUpdateFeeInWei() (*big.Int, error)
SingleUpdateFeeInWei is a free data retrieval call binding the contract method 0x48b6404d.
Solidity: function singleUpdateFeeInWei() view returns(uint256)
func (*StorkContractSession) StorkPublicKey ¶
func (_StorkContract *StorkContractSession) StorkPublicKey() (common.Address, error)
StorkPublicKey is a free data retrieval call binding the contract method 0x8eeae4a7.
Solidity: function storkPublicKey() view returns(address)
func (*StorkContractSession) TransferOwnership ¶
func (_StorkContract *StorkContractSession) TransferOwnership(newOwner common.Address) (*types.Transaction, error)
TransferOwnership is a paid mutator transaction binding the contract method 0xf2fde38b.
Solidity: function transferOwnership(address newOwner) returns()
func (*StorkContractSession) UPGRADEINTERFACEVERSION ¶
func (_StorkContract *StorkContractSession) UPGRADEINTERFACEVERSION() (string, error)
UPGRADEINTERFACEVERSION is a free data retrieval call binding the contract method 0xad3cb1cc.
Solidity: function UPGRADE_INTERFACE_VERSION() view returns(string)
func (*StorkContractSession) UpdateSingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractSession) UpdateSingleUpdateFeeInWei(maxStorkPerBlock *big.Int) (*types.Transaction, error)
UpdateSingleUpdateFeeInWei is a paid mutator transaction binding the contract method 0x4268340a.
Solidity: function updateSingleUpdateFeeInWei(uint256 maxStorkPerBlock) returns()
func (*StorkContractSession) UpdateStorkPublicKey ¶
func (_StorkContract *StorkContractSession) UpdateStorkPublicKey(storkPublicKey common.Address) (*types.Transaction, error)
UpdateStorkPublicKey is a paid mutator transaction binding the contract method 0x11992f3b.
Solidity: function updateStorkPublicKey(address storkPublicKey) returns()
func (*StorkContractSession) UpdateTemporalNumericValuesV1 ¶
func (_StorkContract *StorkContractSession) UpdateTemporalNumericValuesV1(updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
UpdateTemporalNumericValuesV1 is a paid mutator transaction binding the contract method 0x41bd64ba.
Solidity: function updateTemporalNumericValuesV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) payable returns()
func (*StorkContractSession) UpdateValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractSession) UpdateValidTimePeriodSeconds(validTimePeriodSeconds *big.Int) (*types.Transaction, error)
UpdateValidTimePeriodSeconds is a paid mutator transaction binding the contract method 0x785bdda0.
Solidity: function updateValidTimePeriodSeconds(uint256 validTimePeriodSeconds) returns()
func (*StorkContractSession) UpgradeToAndCall ¶
func (_StorkContract *StorkContractSession) UpgradeToAndCall(newImplementation common.Address, data []byte) (*types.Transaction, error)
UpgradeToAndCall is a paid mutator transaction binding the contract method 0x4f1ef286.
Solidity: function upgradeToAndCall(address newImplementation, bytes data) payable returns()
func (*StorkContractSession) ValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractSession) ValidTimePeriodSeconds() (*big.Int, error)
ValidTimePeriodSeconds is a free data retrieval call binding the contract method 0xcb718a9b.
Solidity: function validTimePeriodSeconds() view returns(uint256)
func (*StorkContractSession) VerifyMerkleRoot ¶
func (_StorkContract *StorkContractSession) VerifyMerkleRoot(leaves [][32]byte, root [32]byte) (bool, error)
VerifyMerkleRoot is a free data retrieval call binding the contract method 0x44ecc82c.
Solidity: function verifyMerkleRoot(bytes32[] leaves, bytes32 root) pure returns(bool)
func (*StorkContractSession) VerifyPublisherSignatureV1 ¶
func (_StorkContract *StorkContractSession) VerifyPublisherSignatureV1(oraclePubKey common.Address, assetPairId string, timestamp *big.Int, value *big.Int, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyPublisherSignatureV1 is a free data retrieval call binding the contract method 0xd83cfe2c.
Solidity: function verifyPublisherSignatureV1(address oraclePubKey, string assetPairId, uint256 timestamp, uint256 value, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
func (*StorkContractSession) VerifyPublisherSignaturesV1 ¶
func (_StorkContract *StorkContractSession) VerifyPublisherSignaturesV1(signatures []StorkStructsPublisherSignature, merkleRoot [32]byte) (bool, error)
VerifyPublisherSignaturesV1 is a free data retrieval call binding the contract method 0x1519e36c.
Solidity: function verifyPublisherSignaturesV1((address,string,uint64,uint256,bytes32,bytes32,uint8)[] signatures, bytes32 merkleRoot) pure returns(bool)
func (*StorkContractSession) VerifyStorkSignatureV1 ¶
func (_StorkContract *StorkContractSession) VerifyStorkSignatureV1(storkPubKey common.Address, id [32]byte, recvTime *big.Int, quantizedValue *big.Int, publisherMerkleRoot [32]byte, valueComputeAlgHash [32]byte, r [32]byte, s [32]byte, v uint8) (bool, error)
VerifyStorkSignatureV1 is a free data retrieval call binding the contract method 0x2a6cd210.
Solidity: function verifyStorkSignatureV1(address storkPubKey, bytes32 id, uint256 recvTime, int256 quantizedValue, bytes32 publisherMerkleRoot, bytes32 valueComputeAlgHash, bytes32 r, bytes32 s, uint8 v) pure returns(bool)
func (*StorkContractSession) Version ¶
func (_StorkContract *StorkContractSession) Version() (string, error)
Version is a free data retrieval call binding the contract method 0x54fd4d50.
Solidity: function version() pure returns(string)
type StorkContractTransactor ¶
type StorkContractTransactor struct {
// contains filtered or unexported fields
}
StorkContractTransactor is an auto generated write-only Go binding around an Ethereum contract.
func NewStorkContractTransactor ¶
func NewStorkContractTransactor(address common.Address, transactor bind.ContractTransactor) (*StorkContractTransactor, error)
NewStorkContractTransactor creates a new write-only instance of StorkContract, bound to a specific deployed contract.
func (*StorkContractTransactor) Initialize ¶
func (_StorkContract *StorkContractTransactor) Initialize(opts *bind.TransactOpts, initialOwner common.Address, storkPublicKey common.Address, validTimePeriodSeconds *big.Int, singleUpdateFeeInWei *big.Int) (*types.Transaction, error)
Initialize is a paid mutator transaction binding the contract method 0xeb990c59.
Solidity: function initialize(address initialOwner, address storkPublicKey, uint256 validTimePeriodSeconds, uint256 singleUpdateFeeInWei) returns()
func (*StorkContractTransactor) RenounceOwnership ¶
func (_StorkContract *StorkContractTransactor) RenounceOwnership(opts *bind.TransactOpts) (*types.Transaction, error)
RenounceOwnership is a paid mutator transaction binding the contract method 0x715018a6.
Solidity: function renounceOwnership() returns()
func (*StorkContractTransactor) TransferOwnership ¶
func (_StorkContract *StorkContractTransactor) TransferOwnership(opts *bind.TransactOpts, newOwner common.Address) (*types.Transaction, error)
TransferOwnership is a paid mutator transaction binding the contract method 0xf2fde38b.
Solidity: function transferOwnership(address newOwner) returns()
func (*StorkContractTransactor) UpdateSingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractTransactor) UpdateSingleUpdateFeeInWei(opts *bind.TransactOpts, maxStorkPerBlock *big.Int) (*types.Transaction, error)
UpdateSingleUpdateFeeInWei is a paid mutator transaction binding the contract method 0x4268340a.
Solidity: function updateSingleUpdateFeeInWei(uint256 maxStorkPerBlock) returns()
func (*StorkContractTransactor) UpdateStorkPublicKey ¶
func (_StorkContract *StorkContractTransactor) UpdateStorkPublicKey(opts *bind.TransactOpts, storkPublicKey common.Address) (*types.Transaction, error)
UpdateStorkPublicKey is a paid mutator transaction binding the contract method 0x11992f3b.
Solidity: function updateStorkPublicKey(address storkPublicKey) returns()
func (*StorkContractTransactor) UpdateTemporalNumericValuesV1 ¶
func (_StorkContract *StorkContractTransactor) UpdateTemporalNumericValuesV1(opts *bind.TransactOpts, updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
UpdateTemporalNumericValuesV1 is a paid mutator transaction binding the contract method 0x41bd64ba.
Solidity: function updateTemporalNumericValuesV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) payable returns()
func (*StorkContractTransactor) UpdateValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractTransactor) UpdateValidTimePeriodSeconds(opts *bind.TransactOpts, validTimePeriodSeconds *big.Int) (*types.Transaction, error)
UpdateValidTimePeriodSeconds is a paid mutator transaction binding the contract method 0x785bdda0.
Solidity: function updateValidTimePeriodSeconds(uint256 validTimePeriodSeconds) returns()
func (*StorkContractTransactor) UpgradeToAndCall ¶
func (_StorkContract *StorkContractTransactor) UpgradeToAndCall(opts *bind.TransactOpts, newImplementation common.Address, data []byte) (*types.Transaction, error)
UpgradeToAndCall is a paid mutator transaction binding the contract method 0x4f1ef286.
Solidity: function upgradeToAndCall(address newImplementation, bytes data) payable returns()
type StorkContractTransactorRaw ¶
type StorkContractTransactorRaw struct {
Contract *StorkContractTransactor // Generic write-only contract binding to access the raw methods on
}
StorkContractTransactorRaw is an auto generated low-level write-only Go binding around an Ethereum contract.
func (*StorkContractTransactorRaw) Transact ¶
func (_StorkContract *StorkContractTransactorRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)
Transact invokes the (paid) contract method with params as input values.
func (*StorkContractTransactorRaw) Transfer ¶
func (_StorkContract *StorkContractTransactorRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)
Transfer initiates a plain transaction to move funds to the contract, calling its default method if one is available.
type StorkContractTransactorSession ¶
type StorkContractTransactorSession struct { Contract *StorkContractTransactor // Generic contract transactor binding to set the session for TransactOpts bind.TransactOpts // Transaction auth options to use throughout this session }
StorkContractTransactorSession is an auto generated write-only Go binding around an Ethereum contract, with pre-set transact options.
func (*StorkContractTransactorSession) Initialize ¶
func (_StorkContract *StorkContractTransactorSession) Initialize(initialOwner common.Address, storkPublicKey common.Address, validTimePeriodSeconds *big.Int, singleUpdateFeeInWei *big.Int) (*types.Transaction, error)
Initialize is a paid mutator transaction binding the contract method 0xeb990c59.
Solidity: function initialize(address initialOwner, address storkPublicKey, uint256 validTimePeriodSeconds, uint256 singleUpdateFeeInWei) returns()
func (*StorkContractTransactorSession) RenounceOwnership ¶
func (_StorkContract *StorkContractTransactorSession) RenounceOwnership() (*types.Transaction, error)
RenounceOwnership is a paid mutator transaction binding the contract method 0x715018a6.
Solidity: function renounceOwnership() returns()
func (*StorkContractTransactorSession) TransferOwnership ¶
func (_StorkContract *StorkContractTransactorSession) TransferOwnership(newOwner common.Address) (*types.Transaction, error)
TransferOwnership is a paid mutator transaction binding the contract method 0xf2fde38b.
Solidity: function transferOwnership(address newOwner) returns()
func (*StorkContractTransactorSession) UpdateSingleUpdateFeeInWei ¶
func (_StorkContract *StorkContractTransactorSession) UpdateSingleUpdateFeeInWei(maxStorkPerBlock *big.Int) (*types.Transaction, error)
UpdateSingleUpdateFeeInWei is a paid mutator transaction binding the contract method 0x4268340a.
Solidity: function updateSingleUpdateFeeInWei(uint256 maxStorkPerBlock) returns()
func (*StorkContractTransactorSession) UpdateStorkPublicKey ¶
func (_StorkContract *StorkContractTransactorSession) UpdateStorkPublicKey(storkPublicKey common.Address) (*types.Transaction, error)
UpdateStorkPublicKey is a paid mutator transaction binding the contract method 0x11992f3b.
Solidity: function updateStorkPublicKey(address storkPublicKey) returns()
func (*StorkContractTransactorSession) UpdateTemporalNumericValuesV1 ¶
func (_StorkContract *StorkContractTransactorSession) UpdateTemporalNumericValuesV1(updateData []StorkStructsTemporalNumericValueInput) (*types.Transaction, error)
UpdateTemporalNumericValuesV1 is a paid mutator transaction binding the contract method 0x41bd64ba.
Solidity: function updateTemporalNumericValuesV1(((uint64,int192),bytes32,bytes32,bytes32,bytes32,bytes32,uint8)[] updateData) payable returns()
func (*StorkContractTransactorSession) UpdateValidTimePeriodSeconds ¶
func (_StorkContract *StorkContractTransactorSession) UpdateValidTimePeriodSeconds(validTimePeriodSeconds *big.Int) (*types.Transaction, error)
UpdateValidTimePeriodSeconds is a paid mutator transaction binding the contract method 0x785bdda0.
Solidity: function updateValidTimePeriodSeconds(uint256 validTimePeriodSeconds) returns()
func (*StorkContractTransactorSession) UpgradeToAndCall ¶
func (_StorkContract *StorkContractTransactorSession) UpgradeToAndCall(newImplementation common.Address, data []byte) (*types.Transaction, error)
UpgradeToAndCall is a paid mutator transaction binding the contract method 0x4f1ef286.
Solidity: function upgradeToAndCall(address newImplementation, bytes data) payable returns()
type StorkContractUpgraded ¶
type StorkContractUpgraded struct { Implementation common.Address Raw types.Log // Blockchain specific contextual infos }
StorkContractUpgraded represents a Upgraded event raised by the StorkContract contract.
type StorkContractUpgradedIterator ¶
type StorkContractUpgradedIterator struct { Event *StorkContractUpgraded // Event containing the contract specifics and raw log // contains filtered or unexported fields }
StorkContractUpgradedIterator is returned from FilterUpgraded and is used to iterate over the raw logs and unpacked data for Upgraded events raised by the StorkContract contract.
func (*StorkContractUpgradedIterator) Close ¶
func (it *StorkContractUpgradedIterator) Close() error
Close terminates the iteration process, releasing any pending underlying resources.
func (*StorkContractUpgradedIterator) Error ¶
func (it *StorkContractUpgradedIterator) Error() error
Error returns any retrieval or parsing error occurred during filtering.
func (*StorkContractUpgradedIterator) Next ¶
func (it *StorkContractUpgradedIterator) Next() bool
Next advances the iterator to the subsequent event, returning whether there are any more events found. In case of a retrieval or parsing error, false is returned and Error() can be queried for the exact failure.
type StorkContractValueUpdate ¶
type StorkContractValueUpdate struct { Id [32]byte TimestampNs uint64 QuantizedValue *big.Int Raw types.Log // Blockchain specific contextual infos }
StorkContractValueUpdate represents a ValueUpdate event raised by the StorkContract contract.
type StorkContractValueUpdateIterator ¶
type StorkContractValueUpdateIterator struct { Event *StorkContractValueUpdate // Event containing the contract specifics and raw log // contains filtered or unexported fields }
StorkContractValueUpdateIterator is returned from FilterValueUpdate and is used to iterate over the raw logs and unpacked data for ValueUpdate events raised by the StorkContract contract.
func (*StorkContractValueUpdateIterator) Close ¶
func (it *StorkContractValueUpdateIterator) Close() error
Close terminates the iteration process, releasing any pending underlying resources.
func (*StorkContractValueUpdateIterator) Error ¶
func (it *StorkContractValueUpdateIterator) Error() error
Error returns any retrieval or parsing error occurred during filtering.
func (*StorkContractValueUpdateIterator) Next ¶
func (it *StorkContractValueUpdateIterator) Next() bool
Next advances the iterator to the subsequent event, returning whether there are any more events found. In case of a retrieval or parsing error, false is returned and Error() can be queried for the exact failure.
type StorkSignedPrice ¶
type StorkSignedPrice struct { PublicKey string `json:"public_key"` EncodedAssetId EncodedAssetId `json:"encoded_asset_id"` QuantizedPrice QuantizedPrice `json:"price"` TimestampedSignature TimestampedSignature `json:"timestamped_signature"` PublisherMerkleRoot string `json:"publisher_merkle_root"` StorkCalculationAlg StorkCalculationAlg `json:"calculation_alg"` }
type StorkStructsPublisherSignature ¶
type StorkStructsPublisherSignature struct { PubKey common.Address AssetPairId string Timestamp uint64 QuantizedValue *big.Int R [32]byte S [32]byte V uint8 }
StorkStructsPublisherSignature is an auto generated low-level Go binding around an user-defined struct.
type StorkStructsTemporalNumericValue ¶
StorkStructsTemporalNumericValue is an auto generated low-level Go binding around an user-defined struct.
type StorkStructsTemporalNumericValueInput ¶
type StorkStructsTemporalNumericValueInput struct { TemporalNumericValue StorkStructsTemporalNumericValue Id [32]byte PublisherMerkleRoot [32]byte ValueComputeAlgHash [32]byte R [32]byte S [32]byte V uint8 }
StorkStructsTemporalNumericValueInput is an auto generated low-level Go binding around an user-defined struct.
type SubscriberMessage ¶
type TimestampedSignature ¶
type TimestampedSignature struct { Signature EvmSignature `json:"signature"` Timestamp int64 `json:"timestamp"` MsgHash string `json:"msg_hash"` }
type VerifyPayload ¶
type VerifyPayload struct {
// contains filtered or unexported fields
}