common

Documentation

Index

• Constants
• type ServiceProvider
  • func NewServiceProvider(userDir string) (*ServiceProvider, error)
  • func NewServiceProviderFromConfig(cfg *hdconfig.HyperdriveConfig) (*ServiceProvider, error)
  • func NewServiceProviderFromCustomServices(cfg *hdconfig.HyperdriveConfig, resources *config.NetworkResources, ...) (*ServiceProvider, error)
  • func (p *ServiceProvider) GetConfig() *hdconfig.HyperdriveConfig
  • func (p *ServiceProvider) GetUserDir() string
  • func (sp *ServiceProvider) RequireBeaconClientSynced(ctx context.Context) error
  • func (sp *ServiceProvider) RequireEthClientSynced(ctx context.Context) error
  • func (sp *ServiceProvider) RequireNodeAddress() error
  • func (sp *ServiceProvider) RequireWalletReady() error
  • func (sp *ServiceProvider) WaitBeaconClientSynced(ctx context.Context, verbose bool) error
  • func (sp *ServiceProvider) WaitEthClientSynced(ctx context.Context, verbose bool) error
  • func (sp *ServiceProvider) WaitForWallet(ctx context.Context) error

Constants

const (
	// Log keys
	PrimarySyncProgressKey  string = "primarySyncProgress"
	FallbackSyncProgressKey string = "fallbackSyncProgress"
	SyncProgressKey         string = "syncProgress"
	PrimaryErrorKey         string = "primaryError"
	FallbackErrorKey        string = "fallbackError"
)

Settings

Types

type ServiceProvider

type ServiceProvider struct {
	*services.ServiceProvider
	// contains filtered or unexported fields
}

A container for all of the various services used by Hyperdrive

func NewServiceProvider

func NewServiceProvider(userDir string) (*ServiceProvider, error)

Creates a new ServiceProvider instance by loading the Hyperdrive config in the provided directory

func NewServiceProviderFromConfig

func NewServiceProviderFromConfig(cfg *hdconfig.HyperdriveConfig) (*ServiceProvider, error)

Creates a new ServiceProvider instance directly from a Hyperdrive config instead of loading it from the filesystem

func NewServiceProviderFromCustomServices

func NewServiceProviderFromCustomServices(cfg *hdconfig.HyperdriveConfig, resources *config.NetworkResources, ecManager *services.ExecutionClientManager, bnManager *services.BeaconClientManager, docker client.APIClient) (*ServiceProvider, error)

Creates a new ServiceProvider instance from custom services and artifacts

func (*ServiceProvider) GetConfig

func (p *ServiceProvider) GetConfig() *hdconfig.HyperdriveConfig

func (*ServiceProvider) GetUserDir

func (p *ServiceProvider) GetUserDir() string

func (*ServiceProvider) RequireBeaconClientSynced

func (sp *ServiceProvider) RequireBeaconClientSynced(ctx context.Context) error

func (*ServiceProvider) RequireEthClientSynced

func (sp *ServiceProvider) RequireEthClientSynced(ctx context.Context) error

func (*ServiceProvider) RequireNodeAddress

func (sp *ServiceProvider) RequireNodeAddress() error

func (*ServiceProvider) RequireWalletReady

func (sp *ServiceProvider) RequireWalletReady() error

func (*ServiceProvider) WaitBeaconClientSynced

func (sp *ServiceProvider) WaitBeaconClientSynced(ctx context.Context, verbose bool) error

Wait for the Beacon client to sync; timeout of 0 indicates no timeout

func (*ServiceProvider) WaitEthClientSynced

func (sp *ServiceProvider) WaitEthClientSynced(ctx context.Context, verbose bool) error

Wait for the Executon client to sync; timeout of 0 indicates no timeout

func (*ServiceProvider) WaitForWallet

func (sp *ServiceProvider) WaitForWallet(ctx context.Context) error

Wait for the wallet to be ready