services

Documentation

Index

• Variables
• type Client
  • func ClientFromString(client string) Client
• type MetadataService
  • func NewMetadataService(log logrus.FieldLogger, rpcClient *rpc.Client) MetadataService
  • func (m *MetadataService) ChainID() int32
  • func (m *MetadataService) Client(ctx context.Context) string
  • func (m *MetadataService) ClientVersion() string
  • func (m *MetadataService) GetChainID(ctx context.Context) (*int32, error)
  • func (m *MetadataService) IsSynced() bool
  • func (m *MetadataService) Name() Name
  • func (m *MetadataService) OnReady(ctx context.Context, cb func(context.Context) error)
  • func (m *MetadataService) Ready(ctx context.Context) error
  • func (m *MetadataService) RefreshAll(ctx context.Context) error
  • func (m *MetadataService) Start(ctx context.Context) error
  • func (m *MetadataService) Stop(ctx context.Context) error
• type Name
• type Service

Variables

var AllClients = []Client{
	ClientUnknown,
	ClientGeth,
	ClientNethermind,
	ClientBesu,
	ClientErigon,
	ClientReth,
	ClientEthereumJS,
}

Types

type Client

type Client string

const (
	ClientUnknown    Client = "unknown"
	ClientGeth       Client = "geth"
	ClientNethermind Client = "nethermind"
	ClientBesu       Client = "besu"
	ClientErigon     Client = "erigon"
	ClientReth       Client = "reth"
	ClientEthereumJS Client = "ethereumjs"
)

func ClientFromString

func ClientFromString(client string) Client

type MetadataService

type MetadataService struct {
	// contains filtered or unexported fields
}

func NewMetadataService

func NewMetadataService(log logrus.FieldLogger, rpcClient *rpc.Client) MetadataService

func (*MetadataService) ChainID

func (m *MetadataService) ChainID() int32

func (*MetadataService) Client

func (m *MetadataService) Client(ctx context.Context) string

func (*MetadataService) ClientVersion

func (m *MetadataService) ClientVersion() string

func (*MetadataService) GetChainID

func (m *MetadataService) GetChainID(ctx context.Context) (*int32, error)

func (*MetadataService) IsSynced

func (m *MetadataService) IsSynced() bool

func (*MetadataService) Name

func (m *MetadataService) Name() Name

func (*MetadataService) OnReady

func (m *MetadataService) OnReady(ctx context.Context, cb func(context.Context) error)

func (*MetadataService) Ready

func (m *MetadataService) Ready(ctx context.Context) error

func (*MetadataService) RefreshAll

func (m *MetadataService) RefreshAll(ctx context.Context) error

func (*MetadataService) Start

func (m *MetadataService) Start(ctx context.Context) error

func (*MetadataService) Stop

func (m *MetadataService) Stop(ctx context.Context) error

type Name

type Name string

type Service

type Service interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Ready(ctx context.Context) error
	OnReady(ctx context.Context, cb func(ctx context.Context) error)
	Name() Name
}