plugin

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChainConfig

type ChainConfig struct {
	BroadcastChanSize   *uint64
	ConfirmPollPeriod   *config.Duration
	OCR2CachePollPeriod *time.Duration
	OCR2CacheTTL        *time.Duration
	BalancePollPeriod   *time.Duration
}

func (*ChainConfig) SetDefaults

func (c *ChainConfig) SetDefaults()

type NodeConfig

type NodeConfig struct {
	Name        *string
	URL         *config.URL
	SolidityURL *config.URL
}

func (*NodeConfig) ValidateConfig

func (n *NodeConfig) ValidateConfig() error

type NodeConfigs

type NodeConfigs []*NodeConfig

func (NodeConfigs) SelectRandom

func (ns NodeConfigs) SelectRandom() (*NodeConfig, error)

func (*NodeConfigs) SetFrom

func (ns *NodeConfigs) SetFrom(fs *NodeConfigs)

type TOMLConfig

type TOMLConfig struct {
	ChainID *string
	// Do not access directly, use [IsEnabled]
	Enabled *bool
	ChainConfig
	Nodes NodeConfigs
}

func NewDefault

func NewDefault() *TOMLConfig

func (*TOMLConfig) BalancePollPeriod

func (c *TOMLConfig) BalancePollPeriod() time.Duration

func (*TOMLConfig) BroadcastChanSize

func (c *TOMLConfig) BroadcastChanSize() uint64

func (*TOMLConfig) ConfirmPollPeriod

func (c *TOMLConfig) ConfirmPollPeriod() time.Duration

func (*TOMLConfig) IsEnabled

func (c *TOMLConfig) IsEnabled() bool

func (*TOMLConfig) ListNodes

func (c *TOMLConfig) ListNodes() NodeConfigs

func (*TOMLConfig) OCR2CachePollPeriod

func (c *TOMLConfig) OCR2CachePollPeriod() time.Duration

func (*TOMLConfig) OCR2CacheTTL

func (c *TOMLConfig) OCR2CacheTTL() time.Duration

func (*TOMLConfig) SetFrom

func (c *TOMLConfig) SetFrom(f *TOMLConfig)

func (*TOMLConfig) TOMLString

func (c *TOMLConfig) TOMLString() (string, error)

func (*TOMLConfig) ValidateConfig

func (c *TOMLConfig) ValidateConfig() error

type TOMLConfigs

type TOMLConfigs []*TOMLConfig

func (*TOMLConfigs) SetFrom

func (cs *TOMLConfigs) SetFrom(fs *TOMLConfigs) error

func (TOMLConfigs) ValidateConfig

func (cs TOMLConfigs) ValidateConfig() error

type TronRelayer

type TronRelayer struct {
	services.StateMachine
	// contains filtered or unexported fields
}

func NewRelayer

func NewRelayer(cfg *TOMLConfig, lggr logger.Logger, keystore core.Keystore) (*TronRelayer, error)

func (*TronRelayer) Close

func (t *TronRelayer) Close() error

func (*TronRelayer) GetChainStatus

func (t *TronRelayer) GetChainStatus(ctx context.Context) (types.ChainStatus, error)

ChainService interface

func (*TronRelayer) HealthReport

func (t *TronRelayer) HealthReport() map[string]error

func (*TronRelayer) LatestHead

func (t *TronRelayer) LatestHead(ctx context.Context) (types.Head, error)

func (*TronRelayer) ListNodeStatuses

func (t *TronRelayer) ListNodeStatuses(ctx context.Context, pageSize int32, pageToken string) ([]types.NodeStatus, string, int, error)

func (*TronRelayer) Name

func (t *TronRelayer) Name() string

Service interface

func (*TronRelayer) NewConfigProvider

func (t *TronRelayer) NewConfigProvider(ctx context.Context, args types.RelayArgs) (types.ConfigProvider, error)

func (*TronRelayer) NewContractReader

func (t *TronRelayer) NewContractReader(ctx context.Context, contractReaderConfig []byte) (types.ContractReader, error)

func (*TronRelayer) NewContractWriter

func (t *TronRelayer) NewContractWriter(_ context.Context, _ []byte) (types.ContractWriter, error)

Relayer interface

func (*TronRelayer) NewEVMChain added in v0.0.9

func (t *TronRelayer) NewEVMChain(ctx context.Context) (types.EVMChain, error)

func (*TronRelayer) NewLLOProvider

func (*TronRelayer) NewMedianProvider

func (t *TronRelayer) NewMedianProvider(ctx context.Context, relayargs types.RelayArgs, pluginargs types.PluginArgs) (types.MedianProvider, error)

implement MedianProvider type from github.com/smartcontractkit/chainlink-common/pkg/loop/internal/types

if the loop.Relayer returned by NewRelayer supports the internal loop type MedianProvider, it's called here: see https://github.com/smartcontractkit/chainlink-common/blob/7c11e2c2ce3677f57239c40585b04fd1c9ce1713/pkg/loop/internal/relayer/relayer.go#L493

func (*TronRelayer) NewPluginProvider

func (t *TronRelayer) NewPluginProvider(ctx context.Context, relayargs types.RelayArgs, pluginargs types.PluginArgs) (types.PluginProvider, error)

func (*TronRelayer) Ready

func (t *TronRelayer) Ready() error

func (*TronRelayer) Replay

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

func (*TronRelayer) Start

func (t *TronRelayer) Start(ctx context.Context) error

func (*TronRelayer) Transact

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

Jump to

Keyboard shortcuts

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