services

package

v1.0.0 Latest Latest Go to latest Published: Oct 7, 2024 License: GPL-3.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ethpandaops/xatu

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Client
- func ClientFromString(client string) Client
type DutiesService
- func NewDutiesService(log logrus.FieldLogger, sbeacon beacon.Node, metadata *MetadataService) DutiesService
type MetadataService
- func NewMetadataService(log logrus.FieldLogger, sbeacon beacon.Node, overrideNetworkName string) MetadataService
type Name
type Service

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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) GetAttestationDuties ¶

func (m *DutiesService) GetAttestationDuties(epoch phase0.Epoch) ([]*v1.BeaconCommittee, error)

func (*DutiesService) GetLastCommitteeIndex ¶

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

func (*DutiesService) GetProposerDuties ¶ added in v0.0.156

func (m *DutiesService) GetProposerDuties(epoch phase0.Epoch) ([]*v1.ProposerDuty, 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) NiceToHaveEpochDuties ¶

func (m *DutiesService) NiceToHaveEpochDuties(ctx context.Context) []phase0.Epoch

func (*DutiesService) OnBeaconCommittee ¶

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

func (*DutiesService) OnProposerDuties ¶ added in v0.0.156

func (m *DutiesService) OnProposerDuties(fn func(phase0.Epoch, []*v1.ProposerDuty) 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) RequiredEpochDuties ¶

func (m *DutiesService) RequiredEpochDuties(ctx context.Context) []phase0.Epoch

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, overrideNetworkName string) MetadataService

func (*MetadataService) Client ¶

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

func (*MetadataService) DeriveNetwork ¶

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

func (*MetadataService) DeriveNodeIdentity ¶ added in v0.0.200

func (m *MetadataService) DeriveNodeIdentity(ctx context.Context) (*types.Identity, error)

func (*MetadataService) Name ¶

func (m *MetadataService) Name() Name

func (*MetadataService) NodeID ¶ added in v0.0.200

func (m *MetadataService) NodeID() (string, error)

func (*MetadataService) NodeIDHash ¶ added in v0.0.200

func (m *MetadataService) NodeIDHash() (string, error)

func (*MetadataService) NodeIdentity ¶ added in v0.0.200

func (m *MetadataService) NodeIdentity() (*types.Identity, error)

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) 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
}

Source Files ¶

View all Source files

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