services

Documentation

Index

• Variables
• type Client
  • func ClientFromString(client string) Client
• type DutiesService
  • func NewDutiesService(log logrus.FieldLogger, sbeacon beacon.Node, metadata *MetadataService) DutiesService
  • func (m *DutiesService) FetchBeaconCommittee(ctx context.Context, epoch phase0.Epoch) ([]*v1.BeaconCommittee, error)
  • func (m *DutiesService) GetLastCommitteeIndex(ctx context.Context, slot phase0.Slot) (*phase0.CommitteeIndex, error)
  • func (m *DutiesService) GetValidatorIndex(epoch phase0.Epoch, slot phase0.Slot, committeeIndex phase0.CommitteeIndex, ...) (phase0.ValidatorIndex, error)
  • func (m *DutiesService) Name() Name
  • func (m *DutiesService) OnBeaconCommittee(fn func(phase0.Epoch, []*v1.BeaconCommittee) error)
  • func (m *DutiesService) OnReady(ctx context.Context, fn func(context.Context) error)
  • func (m *DutiesService) Ready(ctx context.Context) error
  • func (m *DutiesService) Start(ctx context.Context) error
  • func (m *DutiesService) Stop(ctx context.Context) error
• type MetadataService
  • func NewMetadataService(log logrus.FieldLogger, sbeacon beacon.Node) MetadataService
  • func (m *MetadataService) Client(ctx context.Context) string
  • func (m *MetadataService) DeriveNetwork(_ context.Context) error
  • func (m *MetadataService) Name() Name
  • func (m *MetadataService) NodeVersion(_ context.Context) string
  • func (m *MetadataService) OnReady(ctx context.Context, cb func(context.Context) error)
  • func (m *MetadataService) OverrideNetworkName(name string)
  • 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
  • func (m *MetadataService) Wallclock() *ethwallclock.EthereumBeaconChain
• type Name
• type Service

Variables

var AllClients = []Client{
	ClientUnknown,
	ClientLighthouse,
	ClientNimbus,
	ClientTeku,
	ClientPrysm,
	ClientLodestar,
}

Types

type Client

type Client string

const (
	ClientUnknown    Client = "unknown"
	ClientLighthouse Client = "lighthouse"
	ClientNimbus     Client = "nimbus"
	ClientTeku       Client = "teku"
	ClientPrysm      Client = "prysm"
	ClientLodestar   Client = "lodestar"
)

func ClientFromString

func ClientFromString(client string) Client

type DutiesService

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

func NewDutiesService

func NewDutiesService(log logrus.FieldLogger, sbeacon beacon.Node, metadata *MetadataService) DutiesService

func (*DutiesService) FetchBeaconCommittee

func (m *DutiesService) FetchBeaconCommittee(ctx context.Context, epoch phase0.Epoch) ([]*v1.BeaconCommittee, error)

func (*DutiesService) GetLastCommitteeIndex

func (m *DutiesService) GetLastCommitteeIndex(ctx context.Context, slot phase0.Slot) (*phase0.CommitteeIndex, error)

func (*DutiesService) GetValidatorIndex

func (m *DutiesService) GetValidatorIndex(epoch phase0.Epoch, slot phase0.Slot, committeeIndex phase0.CommitteeIndex, position uint64) (phase0.ValidatorIndex, error)

func (*DutiesService) Name

func (m *DutiesService) Name() Name

func (*DutiesService) OnBeaconCommittee

func (m *DutiesService) OnBeaconCommittee(fn func(phase0.Epoch, []*v1.BeaconCommittee) error)

func (*DutiesService) OnReady

func (m *DutiesService) OnReady(ctx context.Context, fn func(context.Context) error)

func (*DutiesService) Ready

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

func (*DutiesService) Start

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

func (*DutiesService) Stop

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

type MetadataService

type MetadataService struct {
	Network *networks.Network

	Genesis *v1.Genesis
	Spec    *state.Spec
	// contains filtered or unexported fields
}

func NewMetadataService

func NewMetadataService(log logrus.FieldLogger, sbeacon beacon.Node) MetadataService

func (*MetadataService) Client

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

func (*MetadataService) DeriveNetwork

func (m *MetadataService) DeriveNetwork(_ context.Context) error

func (*MetadataService) Name

func (m *MetadataService) Name() Name

func (*MetadataService) NodeVersion

func (m *MetadataService) NodeVersion(_ context.Context) string

func (*MetadataService) OnReady

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

func (*MetadataService) OverrideNetworkName

func (m *MetadataService) OverrideNetworkName(name string)

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

func (*MetadataService) Wallclock

func (m *MetadataService) Wallclock() *ethwallclock.EthereumBeaconChain

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
}