types

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 28, 2024

v0.4.1

Nov 21, 2024

v0.4.0

Sep 2, 2024

v0.3.1

Nov 21, 2024

v0.3.0

Aug 22, 2024

v0.2.1

Nov 21, 2024

v0.2.0

Jul 16, 2024

Changes in this version

+ const ErrChainReaderConfigMissing

type BoundContract

+ func (bc BoundContract) Key() string

+ type ChainReader interface

+ 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 Head

+ Identifier string

type PluginProvider

+ ChainReader func() ChainReader

v0.1.1

Nov 12, 2024

Changes in this version

type ContractReader

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

+ type LLOConfigProvider interface

+ ContractConfigTrackers func() []ocrtypes.ContractConfigTracker

+ OffchainConfigDigester func() ocrtypes.OffchainConfigDigester

type LLOProvider

+ ShouldRetireCache func() llo.ShouldRetireCache

type RelayArgs

+ OracleSpecID int32

type UnimplementedContractReader

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

v0.0.1

Nov 21, 2024

Changes in this version

+ const ErrContractReaderConfigMissing

+ const ErrFieldNotFound

+ const ErrInternal

+ const ErrInvalidConfig

+ const ErrInvalidEncoding

+ const ErrInvalidType

+ const ErrNotASlice

+ const ErrNotFound

+ const ErrSettingTransactionGasLimitNotSupported

+ 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[BoundContract]ContractBatch

+ type BatchGetLatestValuesResult map[BoundContract]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) ReadIdentifier(readName string) string

+ func (bc BoundContract) String() 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

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

+ 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, srcProvider 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 ChainService interface

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

+ LatestHead func(ctx context.Context) (Head, 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 interface

+ 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 ContractTypeProvider interface

+ CreateContractType func(readName 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

+ Height 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

+ ReportCodecV4 func() v4.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)

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

+ type PluginProvider interface

+ Codec func() Codec

+ ContractReader func() ContractReader

+ 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(ctx context.Context, rargs RelayArgs, pargs PluginArgs) (AutomationProvider, error)

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

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

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

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

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

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

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

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

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

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

+ NewPluginProvider func(ctx context.Context, 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 Pending

+ const Unconfirmed

+ const Unknown

+ type TxMeta struct

+ GasLimit *big.Int

+ WorkflowExecutionID *string

+ type TypeProvider interface

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

+ 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

+ type UnimplementedError string

+ func (e UnimplementedError) Error() string

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

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

v0.0.1-beta

Nov 26, 2024

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