v1connect

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// EthServiceGetStatusProcedure is the fully-qualified name of the EthService's GetStatus RPC.
	EthServiceGetStatusProcedure = "/eth.v1.EthService/GetStatus"
	// EthServiceGetRegisteredEndpointsProcedure is the fully-qualified name of the EthService's
	// GetRegisteredEndpoints RPC.
	EthServiceGetRegisteredEndpointsProcedure = "/eth.v1.EthService/GetRegisteredEndpoints"
	// EthServiceGetRegisteredEndpointsForServiceProviderProcedure is the fully-qualified name of the
	// EthService's GetRegisteredEndpointsForServiceProvider RPC.
	EthServiceGetRegisteredEndpointsForServiceProviderProcedure = "/eth.v1.EthService/GetRegisteredEndpointsForServiceProvider"
	// EthServiceGetRegisteredEndpointInfoProcedure is the fully-qualified name of the EthService's
	// GetRegisteredEndpointInfo RPC.
	EthServiceGetRegisteredEndpointInfoProcedure = "/eth.v1.EthService/GetRegisteredEndpointInfo"
	// EthServiceGetServiceProviderProcedure is the fully-qualified name of the EthService's
	// GetServiceProvider RPC.
	EthServiceGetServiceProviderProcedure = "/eth.v1.EthService/GetServiceProvider"
	// EthServiceGetServiceProvidersProcedure is the fully-qualified name of the EthService's
	// GetServiceProviders RPC.
	EthServiceGetServiceProvidersProcedure = "/eth.v1.EthService/GetServiceProviders"
	// EthServiceGetStakingMetadataForServiceProviderProcedure is the fully-qualified name of the
	// EthService's GetStakingMetadataForServiceProvider RPC.
	EthServiceGetStakingMetadataForServiceProviderProcedure = "/eth.v1.EthService/GetStakingMetadataForServiceProvider"
	// EthServiceGetLatestFundingRoundProcedure is the fully-qualified name of the EthService's
	// GetLatestFundingRound RPC.
	EthServiceGetLatestFundingRoundProcedure = "/eth.v1.EthService/GetLatestFundingRound"
	// EthServiceIsDuplicateDelegateWalletProcedure is the fully-qualified name of the EthService's
	// IsDuplicateDelegateWallet RPC.
	EthServiceIsDuplicateDelegateWalletProcedure = "/eth.v1.EthService/IsDuplicateDelegateWallet"
	// EthServiceRegisterProcedure is the fully-qualified name of the EthService's Register RPC.
	EthServiceRegisterProcedure = "/eth.v1.EthService/Register"
	// EthServiceSubscribeProcedure is the fully-qualified name of the EthService's Subscribe RPC.
	EthServiceSubscribeProcedure = "/eth.v1.EthService/Subscribe"
	// EthServiceGetActiveSlashProposalForAddressProcedure is the fully-qualified name of the
	// EthService's GetActiveSlashProposalForAddress RPC.
	EthServiceGetActiveSlashProposalForAddressProcedure = "/eth.v1.EthService/GetActiveSlashProposalForAddress"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// EthServiceName is the fully-qualified name of the EthService service.
	EthServiceName = "eth.v1.EthService"
)

Variables

This section is empty.

Functions

func NewEthServiceHandler 

func NewEthServiceHandler(svc EthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewEthServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type EthServiceClient 

type EthServiceClient interface {
	GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)
	GetRegisteredEndpoints(context.Context, *connect.Request[v1.GetRegisteredEndpointsRequest]) (*connect.Response[v1.GetRegisteredEndpointsResponse], error)
	GetRegisteredEndpointsForServiceProvider(context.Context, *connect.Request[v1.GetRegisteredEndpointsForServiceProviderRequest]) (*connect.Response[v1.GetRegisteredEndpointsForServiceProviderResponse], error)
	GetRegisteredEndpointInfo(context.Context, *connect.Request[v1.GetRegisteredEndpointInfoRequest]) (*connect.Response[v1.GetRegisteredEndpointInfoResponse], error)
	GetServiceProvider(context.Context, *connect.Request[v1.GetServiceProviderRequest]) (*connect.Response[v1.GetServiceProviderResponse], error)
	GetServiceProviders(context.Context, *connect.Request[v1.GetServiceProvidersRequest]) (*connect.Response[v1.GetServiceProvidersResponse], error)
	GetStakingMetadataForServiceProvider(context.Context, *connect.Request[v1.GetStakingMetadataForServiceProviderRequest]) (*connect.Response[v1.GetStakingMetadataForServiceProviderResponse], error)
	GetLatestFundingRound(context.Context, *connect.Request[v1.GetLatestFundingRoundRequest]) (*connect.Response[v1.GetLatestFundingRoundResponse], error)
	IsDuplicateDelegateWallet(context.Context, *connect.Request[v1.IsDuplicateDelegateWalletRequest]) (*connect.Response[v1.IsDuplicateDelegateWalletResponse], error)
	Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)
	Subscribe(context.Context, *connect.Request[v1.SubscriptionRequest]) (*connect.ServerStreamForClient[v1.SubscriptionResponse], error)
	GetActiveSlashProposalForAddress(context.Context, *connect.Request[v1.GetActiveSlashProposalForAddressRequest]) (*connect.Response[v1.GetActiveSlashProposalForAddressResponse], error)
}

EthServiceClient is a client for the eth.v1.EthService service.

func NewEthServiceClient 

func NewEthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) EthServiceClient

NewEthServiceClient constructs a client for the eth.v1.EthService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type EthServiceHandler 

type EthServiceHandler interface {
	GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)
	GetRegisteredEndpoints(context.Context, *connect.Request[v1.GetRegisteredEndpointsRequest]) (*connect.Response[v1.GetRegisteredEndpointsResponse], error)
	GetRegisteredEndpointsForServiceProvider(context.Context, *connect.Request[v1.GetRegisteredEndpointsForServiceProviderRequest]) (*connect.Response[v1.GetRegisteredEndpointsForServiceProviderResponse], error)
	GetRegisteredEndpointInfo(context.Context, *connect.Request[v1.GetRegisteredEndpointInfoRequest]) (*connect.Response[v1.GetRegisteredEndpointInfoResponse], error)
	GetServiceProvider(context.Context, *connect.Request[v1.GetServiceProviderRequest]) (*connect.Response[v1.GetServiceProviderResponse], error)
	GetServiceProviders(context.Context, *connect.Request[v1.GetServiceProvidersRequest]) (*connect.Response[v1.GetServiceProvidersResponse], error)
	GetStakingMetadataForServiceProvider(context.Context, *connect.Request[v1.GetStakingMetadataForServiceProviderRequest]) (*connect.Response[v1.GetStakingMetadataForServiceProviderResponse], error)
	GetLatestFundingRound(context.Context, *connect.Request[v1.GetLatestFundingRoundRequest]) (*connect.Response[v1.GetLatestFundingRoundResponse], error)
	IsDuplicateDelegateWallet(context.Context, *connect.Request[v1.IsDuplicateDelegateWalletRequest]) (*connect.Response[v1.IsDuplicateDelegateWalletResponse], error)
	Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)
	Subscribe(context.Context, *connect.Request[v1.SubscriptionRequest], *connect.ServerStream[v1.SubscriptionResponse]) error
	GetActiveSlashProposalForAddress(context.Context, *connect.Request[v1.GetActiveSlashProposalForAddressRequest]) (*connect.Response[v1.GetActiveSlashProposalForAddressResponse], error)
}

EthServiceHandler is an implementation of the eth.v1.EthService service.

type UnimplementedEthServiceHandler 

type UnimplementedEthServiceHandler struct{}

UnimplementedEthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedEthServiceHandler) GetActiveSlashProposalForAddress 

func (UnimplementedEthServiceHandler) GetActiveSlashProposalForAddress(context.Context, *connect.Request[v1.GetActiveSlashProposalForAddressRequest]) (*connect.Response[v1.GetActiveSlashProposalForAddressResponse], error)

func (UnimplementedEthServiceHandler) GetLatestFundingRound 

func (UnimplementedEthServiceHandler) GetLatestFundingRound(context.Context, *connect.Request[v1.GetLatestFundingRoundRequest]) (*connect.Response[v1.GetLatestFundingRoundResponse], error)

func (UnimplementedEthServiceHandler) GetRegisteredEndpointInfo 

func (UnimplementedEthServiceHandler) GetRegisteredEndpointInfo(context.Context, *connect.Request[v1.GetRegisteredEndpointInfoRequest]) (*connect.Response[v1.GetRegisteredEndpointInfoResponse], error)

func (UnimplementedEthServiceHandler) GetRegisteredEndpoints 

func (UnimplementedEthServiceHandler) GetRegisteredEndpoints(context.Context, *connect.Request[v1.GetRegisteredEndpointsRequest]) (*connect.Response[v1.GetRegisteredEndpointsResponse], error)

func (UnimplementedEthServiceHandler) GetRegisteredEndpointsForServiceProvider 

func (UnimplementedEthServiceHandler) GetRegisteredEndpointsForServiceProvider(context.Context, *connect.Request[v1.GetRegisteredEndpointsForServiceProviderRequest]) (*connect.Response[v1.GetRegisteredEndpointsForServiceProviderResponse], error)

func (UnimplementedEthServiceHandler) GetServiceProvider 

func (UnimplementedEthServiceHandler) GetServiceProvider(context.Context, *connect.Request[v1.GetServiceProviderRequest]) (*connect.Response[v1.GetServiceProviderResponse], error)

func (UnimplementedEthServiceHandler) GetServiceProviders 

func (UnimplementedEthServiceHandler) GetServiceProviders(context.Context, *connect.Request[v1.GetServiceProvidersRequest]) (*connect.Response[v1.GetServiceProvidersResponse], error)

func (UnimplementedEthServiceHandler) GetStakingMetadataForServiceProvider 

func (UnimplementedEthServiceHandler) GetStakingMetadataForServiceProvider(context.Context, *connect.Request[v1.GetStakingMetadataForServiceProviderRequest]) (*connect.Response[v1.GetStakingMetadataForServiceProviderResponse], error)

func (UnimplementedEthServiceHandler) GetStatus 

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

func (UnimplementedEthServiceHandler) IsDuplicateDelegateWallet 

func (UnimplementedEthServiceHandler) IsDuplicateDelegateWallet(context.Context, *connect.Request[v1.IsDuplicateDelegateWalletRequest]) (*connect.Response[v1.IsDuplicateDelegateWalletResponse], error)

func (UnimplementedEthServiceHandler) Register 

func (UnimplementedEthServiceHandler) Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)

func (UnimplementedEthServiceHandler) Subscribe 

func (UnimplementedEthServiceHandler) Subscribe(context.Context, *connect.Request[v1.SubscriptionRequest], *connect.ServerStream[v1.SubscriptionResponse]) error

Source Files

View all Source files

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.