eth

package
v1.2.12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DeregistrationTopic = "deregistration-subscriber"
)

Variables

This section is empty.

Functions

func DecodeSlashProposalArguments 

func DecodeSlashProposalArguments(callData string) (address ethcommon.Address, amount *big.Int, err error)

Types

type DeregistrationPubsub 

type DeregistrationPubsub = pubsub.Pubsub[*v1.ServiceEndpoint]

type EthService 

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

func NewEthService 

func NewEthService(dbURL, rpcURL, registryAddress string, logger *zap.Logger, environment string) *EthService

func (*EthService) GetActiveSlashProposalForAddress 

func (e *EthService) GetActiveSlashProposalForAddress(ctx context.Context, req *connect.Request[v1.GetActiveSlashProposalForAddressRequest]) (*connect.Response[v1.GetActiveSlashProposalForAddressResponse], error)

func (*EthService) GetAntiAbuseOracleAddresses added in v1.2.11 

func (eth *EthService) GetAntiAbuseOracleAddresses(ctx context.Context) ([]string, error)

GetAntiAbuseOracleAddresses returns the eth addresses of registered anti-abuse oracles, as last synced from the L1 EthRewardsManager contract. These are eligible to be reward-manager senders (alongside validators) and must therefore be allow-listed for add attestations and protected from delete attestations.

func (*EthService) GetLatestFundingRound 

func (e *EthService) GetLatestFundingRound(ctx context.Context, _ *connect.Request[v1.GetLatestFundingRoundRequest]) (*connect.Response[v1.GetLatestFundingRoundResponse], error)

func (*EthService) GetRegisteredEndpointInfo 

func (e *EthService) GetRegisteredEndpointInfo(ctx context.Context, req *connect.Request[v1.GetRegisteredEndpointInfoRequest]) (*connect.Response[v1.GetRegisteredEndpointInfoResponse], error)

func (*EthService) GetRegisteredEndpoints 

func (e *EthService) GetRegisteredEndpoints(ctx context.Context, _ *connect.Request[v1.GetRegisteredEndpointsRequest]) (*connect.Response[v1.GetRegisteredEndpointsResponse], error)

func (*EthService) GetRegisteredEndpointsForServiceProvider 

func (e *EthService) GetRegisteredEndpointsForServiceProvider(ctx context.Context, req *connect.Request[v1.GetRegisteredEndpointsForServiceProviderRequest]) (*connect.Response[v1.GetRegisteredEndpointsForServiceProviderResponse], error)

func (*EthService) GetServiceProvider 

func (e *EthService) GetServiceProvider(ctx context.Context, req *connect.Request[v1.GetServiceProviderRequest]) (*connect.Response[v1.GetServiceProviderResponse], error)

func (*EthService) GetServiceProviders 

func (e *EthService) GetServiceProviders(ctx context.Context, _ *connect.Request[v1.GetServiceProvidersRequest]) (*connect.Response[v1.GetServiceProvidersResponse], error)

func (*EthService) GetStakingMetadataForServiceProvider 

func (e *EthService) GetStakingMetadataForServiceProvider(ctx context.Context, req *connect.Request[v1.GetStakingMetadataForServiceProviderRequest]) (*connect.Response[v1.GetStakingMetadataForServiceProviderResponse], error)

func (*EthService) GetStatus 

func (e *EthService) GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)

func (*EthService) IsDuplicateDelegateWallet 

func (e *EthService) IsDuplicateDelegateWallet(ctx context.Context, req *connect.Request[v1.IsDuplicateDelegateWalletRequest]) (*connect.Response[v1.IsDuplicateDelegateWalletResponse], error)

func (*EthService) Register 

func (e *EthService) Register(ctx context.Context, req *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)

For development purposes only

func (*EthService) Run 

func (eth *EthService) Run(ctx context.Context) error

func (*EthService) Subscribe 

func (e *EthService) Subscribe(ctx context.Context, req *connect.Request[v1.SubscriptionRequest], stream *connect.ServerStream[v1.SubscriptionResponse]) error

func (*EthService) SubscribeToDeregistrationEvents 

func (eth *EthService) SubscribeToDeregistrationEvents() chan *v1.ServiceEndpoint

func (*EthService) UnsubscribeFromDeregistrationEvents 

func (eth *EthService) UnsubscribeFromDeregistrationEvents(ch chan *v1.ServiceEndpoint)

Source Files

View all Source files

Directories

Path Synopsis
gen

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.