Go library providing an abstraction to multiple Ethereum 2 beacon nodes. Its external API follows the official Ethereum beacon APIs specification.
This library is under development; expect APIs and data structures to change until it reaches version 1.0. In addition, clients' implementations of both their own and the standard API are themselves under development so implementation of the the full API can be incomplete.
Between versions 0.18.0 and 0.19.0 the API has undergone a number of changes. Please see the detailed documentation regarding these changes.
go-eth2-client is a standard Go module which can be installed with:
go get github.com/attestantio/go-eth2-clientgo-eth2-client supports beacon nodes that comply with the standard beacon node API. To date it has been tested against the following beacon nodes:
- Lighthouse minimum version 2.0.0
- Nimbus minimum version 1.7.0
- Prysm minimum version ?
- Teku minimum version 21.9.2
Please read the Go documentation for this library for interface information.
Below is a complete annotated example to access a beacon node.
package main
import (
"context"
"fmt"
eth2client "github.com/attestantio/go-eth2-client"
"github.com/attestantio/go-eth2-client/api"
"github.com/attestantio/go-eth2-client/http"
"github.com/rs/zerolog"
)
func main() {
// Provide a cancellable context to the creation function.
ctx, cancel := context.WithCancel(context.Background())
client, err := http.New(ctx,
// WithAddress supplies the address of the beacon node, as a URL.
http.WithAddress("http://localhost:5052/"),
// LogLevel supplies the level of logging to carry out.
http.WithLogLevel(zerolog.WarnLevel),
)
if err != nil {
panic(err)
}
fmt.Printf("Connected to %s\n", client.Name())
// Client functions have their own interfaces. Not all functions are
// supported by all clients, so checks should be made for each function when
// casting the service to the relevant interface.
if provider, isProvider := client.(eth2client.GenesisProvider); isProvider {
genesisResponse, err := provider.Genesis(ctx, &api.GenesisOpts{})
if err != nil {
// Errors may be API errors, in which case they will have more detail
// about the failure.
var apiErr *api.Error
if errors.As(err, &apiErr) {
switch apiErr.StatusCode {
case 404:
panic("genesis not found")
case 503:
panic("node is syncing")
}
}
panic(err)
}
fmt.Printf("Genesis time is %v\n", genesisResponse.Data.GenesisTime)
}
// You can also access the struct directly if required.
httpClient := client.(*http.Service)
genesisResponse, err := httpClient.Genesis(ctx, &api.GenesisOpts{})
if err != nil {
panic(err)
}
fmt.Printf("Genesis validators root is %s\n", genesisResponse.Data.GenesisValidatorsRoot)
// Cancelling the context passed to New() frees up resources held by the
// client, closes connections, clears handlers, etc.
cancel()
}Jim McDonald: @mcdee.
Contributions welcome. Please check out the issues.
Apache-2.0 © 2020, 2021 Attestant Limited