types

package

Go to main page

Versions in this module

v0

v0.9.6

Sep 26, 2025

v0.9.5

Sep 19, 2025

Changes in this version

+ type CCIPProviderArgs struct

+ ChainWriterConfig []byte

+ ContractReaderConfig []byte

+ ExternalJobID uuid.UUID

+ OffRampAddress string

+ PluginType uint32

v0.9.4

Sep 2, 2025

v0.9.3

Aug 21, 2025

v0.9.2

Aug 21, 2025

v0.9.1

Aug 20, 2025

v0.9.0

Aug 8, 2025

Changes in this version

+ type CCIPProvider interface

+ ChainAccessor func() ccipocr3.ChainAccessor

+ Codec func() ccipocr3.Codec

+ ContractTransmitter func() ocr3types.ContractTransmitter[[]byte]

type EVMService

+ GetFiltersNames func(ctx context.Context) ([]string, error)

type GethClient

+ HeaderByNumber func(ctx context.Context, request evm.HeaderByNumberRequest) (*evm.HeaderByNumberReply, error)

type Relayer

+ NewCCIPProvider func(ctx context.Context, rargs RelayArgs) (CCIPProvider, error)

type UnimplementedRelayer

+ func (u *UnimplementedRelayer) NewCCIPProvider(ctx context.Context, rargs RelayArgs) (CCIPProvider, error)

v0.8.0

Jul 14, 2025

Changes in this version

type OCR2PluginType

+ const SecureMint

type Relayer

+ TON func() (TONService, error)

+ type TONService interface

+ GetTxExecutionFees func(ctx context.Context, lt uint64) (*ton.TransactionFee, error)

+ GetTxStatus func(ctx context.Context, lt uint64) (TransactionStatus, ton.ExitCode, error)

+ HasFilter func(ctx context.Context, name string) bool

+ RegisterFilter func(ctx context.Context, filter ton.LPFilterQuery) error

+ SendTx func(ctx context.Context, msg ton.Message) error

+ UnregisterFilter func(ctx context.Context, name string) error

type UnimplementedRelayer

+ func (u *UnimplementedRelayer) TON() (TONService, error)

v0.7.2

Aug 1, 2025

v0.7.1

Jul 28, 2025

Changes in this version

+ type ChainInfo struct

+ ChainID string

+ FamilyName string

+ NetworkName string

+ NetworkNameFull string

type ChainService

+ GetChainInfo func(ctx context.Context) (ChainInfo, error)

type ContractWriter

+ GetEstimateFee func(ctx context.Context, contract, method string, args any, toAddress string, ...) (EstimateFee, error)

+ type EVMService interface

+ CalculateTransactionFee func(ctx context.Context, receiptGasInfo evm.ReceiptGasInfo) (*evm.TransactionFee, error)

+ GetForwarderForEOA func(ctx context.Context, eoa, ocr2AggregatorID evm.Address, pluginType string) (forwarder evm.Address, err error)

+ GetTransactionFee func(ctx context.Context, transactionID IdempotencyKey) (*evm.TransactionFee, error)

+ GetTransactionStatus func(ctx context.Context, transactionID IdempotencyKey) (TransactionStatus, error)

+ LatestAndFinalizedHead func(ctx context.Context) (latest evm.Head, finalized evm.Head, err error)

+ QueryTrackedLogs func(ctx context.Context, filterQuery []query.Expression, ...) ([]*evm.Log, error)

+ RegisterLogTracking func(ctx context.Context, filter evm.LPFilterQuery) error

+ SubmitTransaction func(ctx context.Context, txRequest evm.SubmitTransactionRequest) (*evm.TransactionResult, error)

+ UnregisterLogTracking func(ctx context.Context, filterName string) error

+ type EstimateFee struct

+ Decimals uint32

+ Fee *big.Int

+ type GethClient interface

+ BalanceAt func(ctx context.Context, account evm.Address, blockNumber *big.Int) (*big.Int, error)

+ CallContract func(ctx context.Context, msg *evm.CallMsg, blockNumber *big.Int) ([]byte, error)

+ EstimateGas func(ctx context.Context, call *evm.CallMsg) (uint64, error)

+ FilterLogs func(ctx context.Context, filterQuery evm.FilterQuery) ([]*evm.Log, error)

+ GetTransactionByHash func(ctx context.Context, hash evm.Hash) (*evm.Transaction, error)

+ GetTransactionReceipt func(ctx context.Context, txHash evm.Hash) (*evm.Receipt, error)

+ type IdempotencyKey = string

type OCR2PluginType

+ const DonTimePlugin

+ const VaultPlugin

type Relayer

+ EVM func() (EVMService, error)

type Sequence

+ TxHash []byte

+ type UnimplementedRelayer struct

+ func (u *UnimplementedRelayer) Close() error

+ func (u *UnimplementedRelayer) EVM() (EVMService, error)

+ func (u *UnimplementedRelayer) GetChainInfo(ctx context.Context) (ChainInfo, error)

+ func (u *UnimplementedRelayer) GetChainStatus(ctx context.Context) (ChainStatus, error)

+ func (u *UnimplementedRelayer) HealthReport() map[string]error

+ func (u *UnimplementedRelayer) LatestHead(ctx context.Context) (Head, error)

+ func (u *UnimplementedRelayer) ListNodeStatuses(ctx context.Context, pageSize int32, pageToken string) (stats []NodeStatus, nextPageToken string, total int, err error)

+ func (u *UnimplementedRelayer) Name() string

+ func (u *UnimplementedRelayer) NewAutomationProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (AutomationProvider, error)

+ func (u *UnimplementedRelayer) NewCCIPCommitProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (CCIPCommitProvider, error)

+ func (u *UnimplementedRelayer) NewCCIPExecProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (CCIPExecProvider, error)

+ func (u *UnimplementedRelayer) NewConfigProvider(ctx context.Context, rargs RelayArgs) (ConfigProvider, error)

+ func (u *UnimplementedRelayer) NewContractReader(ctx context.Context, contractReaderConfig []byte) (ContractReader, error)

+ func (u *UnimplementedRelayer) NewContractWriter(ctx context.Context, config []byte) (ContractWriter, error)

+ func (u *UnimplementedRelayer) NewFunctionsProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (FunctionsProvider, error)

+ func (u *UnimplementedRelayer) NewLLOProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (LLOProvider, error)

+ func (u *UnimplementedRelayer) NewMedianProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (MedianProvider, error)

+ func (u *UnimplementedRelayer) NewMercuryProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (MercuryProvider, error)

+ func (u *UnimplementedRelayer) NewOCR3CapabilityProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (OCR3CapabilityProvider, error)

+ func (u *UnimplementedRelayer) NewPluginProvider(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (PluginProvider, error)

+ func (u *UnimplementedRelayer) Ready() error

+ func (u *UnimplementedRelayer) Replay(ctx context.Context, fromBlock string, args map[string]any) error

+ func (u *UnimplementedRelayer) Start(ctx context.Context) error

+ func (u *UnimplementedRelayer) Transact(ctx context.Context, from, to string, amount *big.Int, balanceCheck bool) error

v0.7.1-ccip

Aug 7, 2025

v0.7.0

Apr 14, 2025

v0.6.0

Mar 27, 2025

Changes in this version

type ChainService

+ Replay func(ctx context.Context, fromBlock string, args map[string]any) error

v0.5.0

Mar 12, 2025

v0.4.1

Jan 16, 2025

v0.4.0

Dec 14, 2024

Changes in this version

+ const ErrFinalityViolated

+ type ContractKeyFilter struct

+ Contract BoundContract

+ SequenceDataType any

type ContractReader

+ GetLatestValueWithHeadData func(ctx context.Context, readIdentifier string, ...) (*Head, error)

+ HealthReport func() map[string]error

+ QueryKeys func(ctx context.Context, filters []ContractKeyFilter, ...) (iter.Seq2[string, Sequence], error)

+ type ContractWriter interface

+ GetFeeComponents func(ctx context.Context) (*ChainFeeComponents, error)

+ GetTransactionStatus func(ctx context.Context, transactionID string) (TransactionStatus, error)

+ SubmitTransaction func(ctx context.Context, contractName, method string, args any, ...) error

+ type LLOConfigProvider interface

+ ContractConfigTrackers func() []ocrtypes.ContractConfigTracker

+ OffchainConfigDigester func() ocrtypes.OffchainConfigDigester

type LLOProvider

+ ShouldRetireCache func() llo.ShouldRetireCache

type RelayArgs

+ OracleSpecID int32

type Relayer

+ NewContractWriter func(ctx context.Context, config []byte) (ContractWriter, error)

type UnimplementedContractReader

+ func (UnimplementedContractReader) GetLatestValueWithHeadData(ctx context.Context, readIdentifier string, ...) (*Head, error)

+ func (UnimplementedContractReader) QueryKeys(ctx context.Context, keyQueries []ContractKeyFilter, ...) (iter.Seq2[string, Sequence], error)

v0.3.1-beholder

Nov 21, 2024

v0.3.0

Oct 9, 2024

v0.2.2

Sep 17, 2024

Changes in this version

+ const ErrContractReaderConfigMissing

+ const ErrSettingTransactionGasLimitNotSupported

type BoundContract

+ func (bc BoundContract) ReadIdentifier(readName string) string

+ func (bc BoundContract) String() string

type ChainService

+ LatestHead func(ctx context.Context) (Head, error)

type ContractReader

+ BatchGetLatestValues func(ctx context.Context, request BatchGetLatestValuesRequest) (BatchGetLatestValuesResult, error)

+ Bind func(ctx context.Context, bindings []BoundContract) error

+ GetLatestValue func(ctx context.Context, readIdentifier string, ...) error

+ QueryKey func(ctx context.Context, contract BoundContract, filter query.KeyFilter, ...) ([]Sequence, error)

+ Unbind func(ctx context.Context, bindings []BoundContract) error

type Head

+ Height string

type MercuryProvider

+ ReportCodecV4 func() v4.ReportCodec

type PluginMercury

+ NewMercuryV4Factory func(ctx context.Context, provider MercuryProvider, dataSource v4.DataSource) (MercuryPluginFactory, error)

type PluginProvider

+ ContractReader func() ContractReader

type TransactionStatus

+ const Pending

type TxMeta

+ GasLimit *big.Int

+ type UnimplementedContractReader struct

+ func (UnimplementedContractReader) BatchGetLatestValues(ctx context.Context, request BatchGetLatestValuesRequest) (BatchGetLatestValuesResult, error)

+ func (UnimplementedContractReader) Bind(ctx context.Context, bindings []BoundContract) error

+ func (UnimplementedContractReader) Close() error

+ func (UnimplementedContractReader) GetLatestValue(ctx context.Context, readIdentifier string, ...) error

+ func (UnimplementedContractReader) HealthReport() map[string]error

+ func (UnimplementedContractReader) Name() string

+ func (UnimplementedContractReader) QueryKey(ctx context.Context, boundContract BoundContract, filter query.KeyFilter, ...) ([]Sequence, error)

+ func (UnimplementedContractReader) Ready() error

+ func (UnimplementedContractReader) Start(context.Context) error

+ func (UnimplementedContractReader) Unbind(ctx context.Context, bindings []BoundContract) error

v0.2.1

Jul 18, 2024

Changes in this version

type CCIPExecProvider

+ GetTransactionStatus func(ctx context.Context, transactionID string) (TransactionStatus, error)

v0.2.0

Jul 15, 2024

Changes in this version

+ const ErrChainReaderConfigMissing

+ const ErrFieldNotFound

+ const ErrInternal

+ const ErrInvalidConfig

+ const ErrInvalidEncoding

+ const ErrInvalidType

+ const ErrNotASlice

+ const ErrNotFound

+ const ErrSliceWrongLen

+ type AutomationProvider interface

+ BlockSubscriber func() automation.BlockSubscriber

+ Encoder func() automation.Encoder

+ LogEventProvider func() automation.LogEventProvider

+ LogRecoverer func() automation.LogRecoverer

+ PayloadBuilder func() automation.PayloadBuilder

+ Registry func() automation.Registry

+ TransmitEventProvider func() automation.EventProvider

+ UpkeepProvider func() automation.ConditionalUpkeepProvider

+ UpkeepStateStore func() automation.UpkeepStateStore

+ type BatchGetLatestValuesRequest map[string]ContractBatch

+ type BatchGetLatestValuesResult map[string]ContractBatchResults

+ type BatchRead struct

+ Params any

+ ReadName string

+ ReturnVal any

+ type BatchReadResult struct

+ ReadName string

+ func (brr *BatchReadResult) GetResult() (any, error)

+ func (brr *BatchReadResult) SetResult(returnValue any, err error)

+ type BoundContract struct

+ Address string

+ Name string

+ func (bc BoundContract) Key() string

+ type CCIPCommitFactoryGenerator interface

+ NewCommitFactory func(ctx context.Context, provider CCIPCommitProvider) (ReportingPluginFactory, error)

+ type CCIPCommitProvider interface

+ NewCommitStoreReader func(ctx context.Context, addr ccip.Address) (ccip.CommitStoreReader, error)

+ NewOffRampReader func(ctx context.Context, addr ccip.Address) (ccip.OffRampReader, error)

+ NewOnRampReader func(ctx context.Context, addr ccip.Address, sourceSelector uint64, ...) (ccip.OnRampReader, error)

+ NewPriceGetter func(ctx context.Context) (ccip.PriceGetter, error)

+ NewPriceRegistryReader func(ctx context.Context, addr ccip.Address) (ccip.PriceRegistryReader, error)

+ SourceNativeToken func(ctx context.Context, addr ccip.Address) (ccip.Address, error)

+ type CCIPExecProvider interface

+ NewCommitStoreReader func(ctx context.Context, addr ccip.Address) (ccip.CommitStoreReader, error)

+ NewOffRampReader func(ctx context.Context, addr ccip.Address) (ccip.OffRampReader, error)

+ NewOnRampReader func(ctx context.Context, addr ccip.Address, sourceSelector uint64, ...) (ccip.OnRampReader, error)

+ NewPriceRegistryReader func(ctx context.Context, addr ccip.Address) (ccip.PriceRegistryReader, error)

+ NewTokenDataReader func(ctx context.Context, tokenAddress ccip.Address) (ccip.TokenDataReader, error)

+ NewTokenPoolBatchedReader func(ctx context.Context, offRampAddress ccip.Address, sourceSelector uint64) (ccip.TokenPoolBatchedReader, error)

+ SourceNativeToken func(ctx context.Context, addr ccip.Address) (ccip.Address, error)

+ type CCIPExecutionFactoryGenerator interface

+ NewExecutionFactory func(ctx context.Context, provider CCIPExecProvider) (ReportingPluginFactory, error)

+ type CCIPFactoryGenerator interface

+ type CCIPOCR3CommitProvider interface

+ MsgHasher func(ctx context.Context) (ccipocr3.MessageHasher, error)

+ ReportCodec func(ctx context.Context) (ccipocr3.CommitPluginCodec, error)

+ type CCIPOCR3ExecuteProvider interface

+ MsgHasher func(ctx context.Context) (ccipocr3.MessageHasher, error)

+ ReportCodec func(ctx context.Context) (ccipocr3.ExecutePluginCodec, error)

+ type ChainFeeComponents struct

+ DataAvailabilityFee *big.Int

+ ExecutionFee *big.Int

+ type ChainReader interface

+ BatchGetLatestValues func(ctx context.Context, request BatchGetLatestValuesRequest) (BatchGetLatestValuesResult, error)

+ Bind func(ctx context.Context, bindings []BoundContract) error

+ GetLatestValue func(ctx context.Context, contractName, method string, ...) error

+ QueryKey func(ctx context.Context, contractName string, filter query.KeyFilter, ...) ([]Sequence, error)

+ type ChainService interface

+ GetChainStatus func(ctx context.Context) (ChainStatus, error)

+ ListNodeStatuses func(ctx context.Context, pageSize int32, pageToken string) (stats []NodeStatus, nextPageToken string, total int, err error)

+ Transact func(ctx context.Context, from, to string, amount *big.Int, balanceCheck bool) error

+ type ChainStatus struct

+ Config string

+ Enabled bool

+ ID string

+ type ChainWriter interface

+ GetFeeComponents func(ctx context.Context) (*ChainFeeComponents, error)

+ GetTransactionStatus func(ctx context.Context, transactionID string) (TransactionStatus, error)

+ SubmitTransaction func(ctx context.Context, contractName, method string, args any, ...) error

+ type Codec interface

+ type ConfigProvider interface

+ ContractConfigTracker func() ocrtypes.ContractConfigTracker

+ OffchainConfigDigester func() ocrtypes.OffchainConfigDigester

+ type ContractBatch []BatchRead

+ type ContractBatchResults []BatchReadResult

+ type ContractReader = ChainReader

+ type ContractTypeProvider interface

+ CreateContractType func(contractName, itemType string, forEncoding bool) (any, error)

+ type Decoder interface

+ Decode func(ctx context.Context, raw []byte, into any, itemType string) error

+ GetMaxDecodingSize func(ctx context.Context, n int, itemType string) (int, error)

+ type Encoder interface

+ Encode func(ctx context.Context, item any, itemType string) ([]byte, error)

+ GetMaxEncodingSize func(ctx context.Context, n int, itemType string) (int, error)

+ type FunctionsEvents interface

+ LatestEvents func() ([]OracleRequest, []OracleResponse, error)

+ type FunctionsProvider interface

+ FunctionsEvents func() FunctionsEvents

+ type Head struct

+ Hash []byte

+ Identifier string

+ Timestamp uint64

+ type InternalError string

+ func (e InternalError) Error() string

+ func (e InternalError) GRPCStatus() *status.Status

+ func (e InternalError) Is(target error) bool

+ type InvalidArgumentError string

+ func (e InvalidArgumentError) Error() string

+ func (e InvalidArgumentError) GRPCStatus() *status.Status

+ func (e InvalidArgumentError) Is(target error) bool

+ type LLOProvider interface

+ ChannelDefinitionCache func() llo.ChannelDefinitionCache

+ ContractTransmitter func() llo.Transmitter

+ type MedianProvider interface

+ MedianContract func() median.MedianContract

+ OnchainConfigCodec func() median.OnchainConfigCodec

+ ReportCodec func() median.ReportCodec

+ type MercuryCredentials struct

+ LegacyURL string

+ Password string

+ URL string

+ Username string

+ type MercuryPluginFactory interface

+ type MercuryProvider interface

+ MercuryChainReader func() mercury.ChainReader

+ MercuryServerFetcher func() mercury.ServerFetcher

+ OnchainConfigCodec func() mercury.OnchainConfigCodec

+ ReportCodecV1 func() v1.ReportCodec

+ ReportCodecV2 func() v2.ReportCodec

+ ReportCodecV3 func() v3.ReportCodec

+ type NodeStatus struct

+ ChainID string

+ Config string

+ Name string

+ State string

+ type NotFoundError string

+ func (e NotFoundError) Error() string

+ func (e NotFoundError) GRPCStatus() *status.Status

+ func (e NotFoundError) Is(target error) bool

+ type OCR2PluginType string

+ const CCIPCommit

+ const CCIPExecution

+ const DKG

+ const Functions

+ const GenericPlugin

+ const LLO

+ const Median

+ const Mercury

+ const OCR2Keeper

+ const OCR2VRF

+ const OCR3Capability

+ type OCR3CapabilityProvider interface

+ type OCR3ContractTransmitter interface

+ OCR3ContractTransmitter func() ocr3types.ContractTransmitter[[]byte]

+ type OracleRequest struct

+ CallbackGasLimit uint64

+ CoordinatorContract ocrtypes.Account

+ Data []byte

+ DataVersion uint16

+ Flags [32]byte

+ OnchainMetadata []byte

+ RequestID [32]byte

+ RequestInitiator ocrtypes.Account

+ RequestingContract ocrtypes.Account

+ SubscriptionId uint64

+ SubscriptionOwner ocrtypes.Account

+ TxHash []byte

+ type OracleResponse struct

+ RequestID [32]byte

+ type Plugin = PluginProvider

+ type PluginArgs struct

+ PluginConfig []byte

+ TransmitterID string

+ type PluginMercury interface

+ NewMercuryV1Factory func(ctx context.Context, provider MercuryProvider, dataSource v1.DataSource) (MercuryPluginFactory, error)

+ NewMercuryV2Factory func(ctx context.Context, provider MercuryProvider, dataSource v2.DataSource) (MercuryPluginFactory, error)

+ NewMercuryV3Factory func(ctx context.Context, provider MercuryProvider, dataSource v3.DataSource) (MercuryPluginFactory, error)

+ type PluginProvider interface

+ ChainReader func() ChainReader

+ Codec func() Codec

+ ContractTransmitter func() ocrtypes.ContractTransmitter

+ type RelayArgs struct

+ ContractID string

+ ExternalJobID uuid.UUID

+ JobID int32

+ MercuryCredentials *MercuryCredentials

+ New bool

+ ProviderType string

+ RelayConfig []byte

+ type RelayID struct

+ ChainID string

+ Network string

+ func NewRelayID(n string, c string) RelayID

+ func (i *RelayID) Name() string

+ func (i *RelayID) String() string

+ func (i *RelayID) UnmarshalString(s string) error

+ type Relayer interface

+ NewAutomationProvider func(rargs RelayArgs, pargs PluginArgs) (AutomationProvider, error)

+ NewCCIPCommitProvider func(rargs RelayArgs, pargs PluginArgs) (CCIPCommitProvider, error)

+ NewCCIPExecProvider func(rargs RelayArgs, pargs PluginArgs) (CCIPExecProvider, error)

+ NewChainWriter func(ctx context.Context, config []byte) (ChainWriter, error)

+ NewConfigProvider func(rargs RelayArgs) (ConfigProvider, error)

+ NewContractReader func(contractReaderConfig []byte) (ContractReader, error)

+ NewFunctionsProvider func(rargs RelayArgs, pargs PluginArgs) (FunctionsProvider, error)

+ NewLLOProvider func(rargs RelayArgs, pargs PluginArgs) (LLOProvider, error)

+ NewMedianProvider func(rargs RelayArgs, pargs PluginArgs) (MedianProvider, error)

+ NewMercuryProvider func(rargs RelayArgs, pargs PluginArgs) (MercuryProvider, error)

+ NewOCR3CapabilityProvider func(rargs RelayArgs, pargs PluginArgs) (OCR3CapabilityProvider, error)

+ NewPluginProvider func(rargs RelayArgs, pargs PluginArgs) (PluginProvider, error)

+ type RemoteCodec interface

+ type ReportingPluginFactory interface

+ type Sequence struct

+ Cursor string

+ Data any

+ type Service interface

+ Close func() error

+ HealthReport func() map[string]error

+ Name func() string

+ Ready func() error

+ Start func(context.Context) error

+ type TransactionStatus int

+ const Failed

+ const Fatal

+ const Finalized

+ const Unconfirmed

+ const Unknown

+ type TxMeta struct

+ WorkflowExecutionID *string

+ type TypeProvider interface

+ CreateType func(itemType string, forEncoding bool) (any, error)

+ type UnimplementedError string

+ func (e UnimplementedError) Error() string

+ func (e UnimplementedError) GRPCStatus() *status.Status

+ func (e UnimplementedError) Is(target error) bool

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