services

package

Go to main page

Versions in this module

v0

v0.5.1

Jul 2, 2024

v0.5.0

Jun 18, 2024

v0.4.0

Jun 4, 2024

Changes in this version

type BeaconClientManager

+ func NewBeaconClientManagerWithFallback(primaryBc beacon.IBeaconClient, fallbackBc beacon.IBeaconClient, chainID uint, ...) *BeaconClientManager

type ExecutionClientManager

+ func NewExecutionClientManagerWithFallback(primaryEc eth.IExecutionClient, fallbackEc eth.IExecutionClient, chainID uint, ...) *ExecutionClientManager

+ func (m *ExecutionClientManager) ChainID(ctx context.Context) (*big.Int, error)

type ServiceProvider

+ func NewServiceProviderWithCustomServices(cfg config.IConfig, resources *config.NetworkResources, ...) (*ServiceProvider, error)

v0.3.1

May 17, 2024

Changes in this version

type BeaconClientManager

+ func (m *BeaconClientManager) SetFallbackReady(ready bool)

+ func (m *BeaconClientManager) SetPrimaryReady(ready bool)

type ExecutionClientManager

+ func (m *ExecutionClientManager) SetFallbackReady(ready bool)

+ func (m *ExecutionClientManager) SetPrimaryReady(ready bool)

v0.3.0

Apr 29, 2024

v0.2.0

Mar 30, 2024

Changes in this version

type BeaconClientManager

+ func (m *BeaconClientManager) GetBeaconBlockHeader(ctx context.Context, blockId string) (beacon.BeaconBlockHeader, bool, error)

+ func (m *BeaconClientManager) GetClientTypeName() string

+ func (m *BeaconClientManager) GetCommitteesForEpoch(ctx context.Context, epoch *uint64) (beacon.Committees, error)

+ func (m *BeaconClientManager) GetFallbackClient() beacon.IBeaconClient

+ func (m *BeaconClientManager) GetPrimaryClient() beacon.IBeaconClient

+ func (m *BeaconClientManager) IsFallbackEnabled() bool

type ExecutionClientManager

+ func (m *ExecutionClientManager) GetClientTypeName() string

+ func (m *ExecutionClientManager) GetFallbackClient() eth.IExecutionClient

+ func (m *ExecutionClientManager) GetPrimaryClient() eth.IExecutionClient

+ func (m *ExecutionClientManager) IsFallbackEnabled() bool

+ type IClientManager interface

+ GetClientTypeName func() string

+ GetFallbackClient func() ClientType

+ GetPrimaryClient func() ClientType

+ IsFallbackEnabled func() bool

+ IsFallbackReady func() bool

+ IsPrimaryReady func() bool

type ServiceProvider

+ func (p *ServiceProvider) CancelContextOnShutdown()

+ func (p *ServiceProvider) Close()

+ func (p *ServiceProvider) GetBaseContext() context.Context

+ func (p *ServiceProvider) GetTasksLogger() *log.Logger

v0.1.0

Mar 8, 2024

Changes in this version

+ const DockerApiVersion

+ func GetEthClientLatestBlockTimestamp(ec eth.IExecutionClient) (uint64, error)

+ func IsSyncWithinThreshold(ec eth.IExecutionClient) (bool, time.Time, error)

+ type BeaconClientManager struct

+ func NewBeaconClientManager(primaryProvider string, fallbackProvider string, clientTimeout time.Duration) (*BeaconClientManager, error)

+ func (m *BeaconClientManager) ChangeWithdrawalCredentials(ctx context.Context, validatorIndex string, ...) error

+ func (m *BeaconClientManager) CheckStatus(ctx context.Context) *types.ClientManagerStatus

+ func (m *BeaconClientManager) Close(ctx context.Context) error

+ func (m *BeaconClientManager) ExitValidator(ctx context.Context, validatorIndex string, epoch uint64, ...) error

+ func (m *BeaconClientManager) GetAttestations(ctx context.Context, blockId string) ([]beacon.AttestationInfo, bool, error)

+ func (m *BeaconClientManager) GetBeaconBlock(ctx context.Context, blockId string) (beacon.BeaconBlock, bool, error)

+ func (m *BeaconClientManager) GetBeaconHead(ctx context.Context) (beacon.BeaconHead, error)

+ func (m *BeaconClientManager) GetDomainData(ctx context.Context, domainType []byte, epoch uint64, useGenesisFork bool) ([]byte, error)

+ func (m *BeaconClientManager) GetEth1DataForEth2Block(ctx context.Context, blockId string) (beacon.Eth1Data, bool, error)

+ func (m *BeaconClientManager) GetEth2Config(ctx context.Context) (beacon.Eth2Config, error)

+ func (m *BeaconClientManager) GetEth2DepositContract(ctx context.Context) (beacon.Eth2DepositContract, error)

+ func (m *BeaconClientManager) GetSyncStatus(ctx context.Context) (beacon.SyncStatus, error)

+ func (m *BeaconClientManager) GetValidatorIndex(ctx context.Context, pubkey beacon.ValidatorPubkey) (string, error)

+ func (m *BeaconClientManager) GetValidatorProposerDuties(ctx context.Context, indices []string, epoch uint64) (map[string]uint64, error)

+ func (m *BeaconClientManager) GetValidatorStatus(ctx context.Context, pubkey beacon.ValidatorPubkey, ...) (beacon.ValidatorStatus, error)

+ func (m *BeaconClientManager) GetValidatorStatusByIndex(ctx context.Context, index string, opts *beacon.ValidatorStatusOptions) (beacon.ValidatorStatus, error)

+ func (m *BeaconClientManager) GetValidatorStatuses(ctx context.Context, pubkeys []beacon.ValidatorPubkey, ...) (map[beacon.ValidatorPubkey]beacon.ValidatorStatus, error)

+ func (m *BeaconClientManager) GetValidatorSyncDuties(ctx context.Context, indices []string, epoch uint64) (map[string]bool, error)

+ func (m *BeaconClientManager) IsFallbackReady() bool

+ func (m *BeaconClientManager) IsPrimaryReady() bool

+ type ExecutionClientManager struct

+ func NewExecutionClientManager(primaryEcUrl string, fallbackEcUrl string, chainID uint, ...) (*ExecutionClientManager, error)

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

+ func (m *ExecutionClientManager) BlockNumber(ctx context.Context) (uint64, error)

+ func (m *ExecutionClientManager) CallContract(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

+ func (m *ExecutionClientManager) CheckStatus(ctx context.Context) *apitypes.ClientManagerStatus

+ func (m *ExecutionClientManager) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)

+ func (m *ExecutionClientManager) EstimateGas(ctx context.Context, call ethereum.CallMsg) (gas uint64, err error)

+ func (m *ExecutionClientManager) FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)

+ func (m *ExecutionClientManager) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

+ func (m *ExecutionClientManager) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

+ func (m *ExecutionClientManager) IsFallbackReady() bool

+ func (m *ExecutionClientManager) IsPrimaryReady() bool

+ func (m *ExecutionClientManager) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ func (m *ExecutionClientManager) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

+ func (m *ExecutionClientManager) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

+ func (m *ExecutionClientManager) SendTransaction(ctx context.Context, tx *types.Transaction) error

+ func (m *ExecutionClientManager) SubscribeFilterLogs(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)

+ func (m *ExecutionClientManager) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (m *ExecutionClientManager) SuggestGasTipCap(ctx context.Context) (*big.Int, error)

+ func (m *ExecutionClientManager) SyncProgress(ctx context.Context) (*ethereum.SyncProgress, error)

+ func (m *ExecutionClientManager) TransactionByHash(ctx context.Context, hash common.Hash) (tx *types.Transaction, isPending bool, err error)

+ func (m *ExecutionClientManager) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

+ func (m ExecutionClientManager) GetFallbackExecutionClient() eth.IExecutionClient

+ func (m ExecutionClientManager) GetPrimaryExecutionClient() eth.IExecutionClient

+ type ServiceProvider struct

+ func NewServiceProvider(cfg config.IConfig, clientTimeout time.Duration, debugMode bool) (*ServiceProvider, error)

+ func (p *ServiceProvider) GetApiLogger() *log.ColorLogger

+ func (p *ServiceProvider) GetBeaconClient() *BeaconClientManager

+ func (p *ServiceProvider) GetConfig() config.IConfig

+ func (p *ServiceProvider) GetDocker() *client.Client

+ func (p *ServiceProvider) GetEthClient() *ExecutionClientManager

+ func (p *ServiceProvider) GetNetworkResources() *config.NetworkResources

+ func (p *ServiceProvider) GetQueryManager() *eth.QueryManager

+ func (p *ServiceProvider) GetTransactionManager() *eth.TransactionManager

+ func (p *ServiceProvider) GetWallet() *wallet.Wallet

+ func (p *ServiceProvider) IsDebugMode() bool

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