service

package
v2.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2021 License: GPL-3.0, Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_eth_service_beacon_chain_service_proto protoreflect.FileDescriptor
View Source 
var File_proto_eth_service_beacon_debug_service_proto protoreflect.FileDescriptor
View Source 
var File_proto_eth_service_events_service_proto protoreflect.FileDescriptor
View Source 
var File_proto_eth_service_node_service_proto protoreflect.FileDescriptor
View Source 
var File_proto_eth_service_validator_service_proto protoreflect.FileDescriptor

Functions

func RegisterBeaconChainHandler 

func RegisterBeaconChainHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBeaconChainHandler registers the http handlers for service BeaconChain to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBeaconChainHandlerClient 

func RegisterBeaconChainHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BeaconChainClient) error

RegisterBeaconChainHandlerClient registers the http handlers for service BeaconChain to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BeaconChainClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BeaconChainClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BeaconChainClient" to call the correct interceptors.

func RegisterBeaconChainHandlerFromEndpoint 

func RegisterBeaconChainHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBeaconChainHandlerFromEndpoint is same as RegisterBeaconChainHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBeaconChainHandlerServer 

func RegisterBeaconChainHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BeaconChainServer) error

RegisterBeaconChainHandlerServer registers the http handlers for service BeaconChain to "mux". UnaryRPC :call BeaconChainServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBeaconChainHandlerFromEndpoint instead.

func RegisterBeaconChainServer 

func RegisterBeaconChainServer(s *grpc.Server, srv BeaconChainServer)

func RegisterBeaconDebugHandler 

func RegisterBeaconDebugHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBeaconDebugHandler registers the http handlers for service BeaconDebug to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBeaconDebugHandlerClient 

func RegisterBeaconDebugHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BeaconDebugClient) error

RegisterBeaconDebugHandlerClient registers the http handlers for service BeaconDebug to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BeaconDebugClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BeaconDebugClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BeaconDebugClient" to call the correct interceptors.

func RegisterBeaconDebugHandlerFromEndpoint 

func RegisterBeaconDebugHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBeaconDebugHandlerFromEndpoint is same as RegisterBeaconDebugHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBeaconDebugHandlerServer 

func RegisterBeaconDebugHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BeaconDebugServer) error

RegisterBeaconDebugHandlerServer registers the http handlers for service BeaconDebug to "mux". UnaryRPC :call BeaconDebugServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBeaconDebugHandlerFromEndpoint instead.

func RegisterBeaconDebugServer 

func RegisterBeaconDebugServer(s *grpc.Server, srv BeaconDebugServer)

func RegisterBeaconNodeHandler 

func RegisterBeaconNodeHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBeaconNodeHandler registers the http handlers for service BeaconNode to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBeaconNodeHandlerClient 

func RegisterBeaconNodeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BeaconNodeClient) error

RegisterBeaconNodeHandlerClient registers the http handlers for service BeaconNode to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BeaconNodeClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BeaconNodeClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BeaconNodeClient" to call the correct interceptors.

func RegisterBeaconNodeHandlerFromEndpoint 

func RegisterBeaconNodeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBeaconNodeHandlerFromEndpoint is same as RegisterBeaconNodeHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBeaconNodeHandlerServer 

func RegisterBeaconNodeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BeaconNodeServer) error

RegisterBeaconNodeHandlerServer registers the http handlers for service BeaconNode to "mux". UnaryRPC :call BeaconNodeServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBeaconNodeHandlerFromEndpoint instead.

func RegisterBeaconNodeServer 

func RegisterBeaconNodeServer(s *grpc.Server, srv BeaconNodeServer)

func RegisterBeaconValidatorHandler 

func RegisterBeaconValidatorHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBeaconValidatorHandler registers the http handlers for service BeaconValidator to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBeaconValidatorHandlerClient 

func RegisterBeaconValidatorHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BeaconValidatorClient) error

RegisterBeaconValidatorHandlerClient registers the http handlers for service BeaconValidator to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BeaconValidatorClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BeaconValidatorClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BeaconValidatorClient" to call the correct interceptors.

func RegisterBeaconValidatorHandlerFromEndpoint 

func RegisterBeaconValidatorHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBeaconValidatorHandlerFromEndpoint is same as RegisterBeaconValidatorHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBeaconValidatorHandlerServer 

func RegisterBeaconValidatorHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BeaconValidatorServer) error

RegisterBeaconValidatorHandlerServer registers the http handlers for service BeaconValidator to "mux". UnaryRPC :call BeaconValidatorServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBeaconValidatorHandlerFromEndpoint instead.

func RegisterBeaconValidatorServer 

func RegisterBeaconValidatorServer(s *grpc.Server, srv BeaconValidatorServer)

func RegisterEventsHandler 

func RegisterEventsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventsHandler registers the http handlers for service Events to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventsHandlerClient 

func RegisterEventsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventsClient) error

RegisterEventsHandlerClient registers the http handlers for service Events to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventsClient" to call the correct interceptors.

func RegisterEventsHandlerFromEndpoint 

func RegisterEventsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventsHandlerFromEndpoint is same as RegisterEventsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventsHandlerServer 

func RegisterEventsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventsServer) error

RegisterEventsHandlerServer registers the http handlers for service Events to "mux". UnaryRPC :call EventsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEventsHandlerFromEndpoint instead.

func RegisterEventsServer 

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

Types

type BeaconChainClient 

type BeaconChainClient interface {
	GetGenesis(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.GenesisResponse, error)
	GetStateRoot(ctx context.Context, in *v1.StateRequest, opts ...grpc.CallOption) (*v1.StateRootResponse, error)
	GetStateFork(ctx context.Context, in *v1.StateRequest, opts ...grpc.CallOption) (*v1.StateForkResponse, error)
	GetFinalityCheckpoints(ctx context.Context, in *v1.StateRequest, opts ...grpc.CallOption) (*v1.StateFinalityCheckpointResponse, error)
	ListValidators(ctx context.Context, in *v1.StateValidatorsRequest, opts ...grpc.CallOption) (*v1.StateValidatorsResponse, error)
	GetValidator(ctx context.Context, in *v1.StateValidatorRequest, opts ...grpc.CallOption) (*v1.StateValidatorResponse, error)
	ListValidatorBalances(ctx context.Context, in *v1.ValidatorBalancesRequest, opts ...grpc.CallOption) (*v1.ValidatorBalancesResponse, error)
	ListCommittees(ctx context.Context, in *v1.StateCommitteesRequest, opts ...grpc.CallOption) (*v1.StateCommitteesResponse, error)
	ListSyncCommittees(ctx context.Context, in *v2.StateSyncCommitteesRequest, opts ...grpc.CallOption) (*v2.StateSyncCommitteesResponse, error)
	ListBlockHeaders(ctx context.Context, in *v1.BlockHeadersRequest, opts ...grpc.CallOption) (*v1.BlockHeadersResponse, error)
	GetBlockHeader(ctx context.Context, in *v1.BlockRequest, opts ...grpc.CallOption) (*v1.BlockHeaderResponse, error)
	SubmitBlock(ctx context.Context, in *v2.SignedBeaconBlockContainerV2, opts ...grpc.CallOption) (*empty.Empty, error)
	GetBlockRoot(ctx context.Context, in *v1.BlockRequest, opts ...grpc.CallOption) (*v1.BlockRootResponse, error)
	GetBlock(ctx context.Context, in *v1.BlockRequest, opts ...grpc.CallOption) (*v1.BlockResponse, error)
	GetBlockSSZ(ctx context.Context, in *v1.BlockRequest, opts ...grpc.CallOption) (*v1.BlockSSZResponse, error)
	GetBlockV2(ctx context.Context, in *v2.BlockRequestV2, opts ...grpc.CallOption) (*v2.BlockResponseV2, error)
	GetBlockSSZV2(ctx context.Context, in *v2.BlockRequestV2, opts ...grpc.CallOption) (*v2.BlockSSZResponseV2, error)
	ListBlockAttestations(ctx context.Context, in *v1.BlockRequest, opts ...grpc.CallOption) (*v1.BlockAttestationsResponse, error)
	ListPoolAttestations(ctx context.Context, in *v1.AttestationsPoolRequest, opts ...grpc.CallOption) (*v1.AttestationsPoolResponse, error)
	SubmitAttestations(ctx context.Context, in *v1.SubmitAttestationsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ListPoolAttesterSlashings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.AttesterSlashingsPoolResponse, error)
	SubmitAttesterSlashing(ctx context.Context, in *v1.AttesterSlashing, opts ...grpc.CallOption) (*empty.Empty, error)
	ListPoolProposerSlashings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.ProposerSlashingPoolResponse, error)
	SubmitProposerSlashing(ctx context.Context, in *v1.ProposerSlashing, opts ...grpc.CallOption) (*empty.Empty, error)
	ListPoolVoluntaryExits(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.VoluntaryExitsPoolResponse, error)
	SubmitVoluntaryExit(ctx context.Context, in *v1.SignedVoluntaryExit, opts ...grpc.CallOption) (*empty.Empty, error)
	SubmitPoolSyncCommitteeSignatures(ctx context.Context, in *v2.SubmitPoolSyncCommitteeSignatures, opts ...grpc.CallOption) (*empty.Empty, error)
	GetForkSchedule(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.ForkScheduleResponse, error)
	GetSpec(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.SpecResponse, error)
	GetDepositContract(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.DepositContractResponse, error)
}

BeaconChainClient is the client API for BeaconChain service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBeaconChainClient 

func NewBeaconChainClient(cc grpc.ClientConnInterface) BeaconChainClient

type BeaconChainServer 

type BeaconChainServer interface {
	GetGenesis(context.Context, *empty.Empty) (*v1.GenesisResponse, error)
	GetStateRoot(context.Context, *v1.StateRequest) (*v1.StateRootResponse, error)
	GetStateFork(context.Context, *v1.StateRequest) (*v1.StateForkResponse, error)
	GetFinalityCheckpoints(context.Context, *v1.StateRequest) (*v1.StateFinalityCheckpointResponse, error)
	ListValidators(context.Context, *v1.StateValidatorsRequest) (*v1.StateValidatorsResponse, error)
	GetValidator(context.Context, *v1.StateValidatorRequest) (*v1.StateValidatorResponse, error)
	ListValidatorBalances(context.Context, *v1.ValidatorBalancesRequest) (*v1.ValidatorBalancesResponse, error)
	ListCommittees(context.Context, *v1.StateCommitteesRequest) (*v1.StateCommitteesResponse, error)
	ListSyncCommittees(context.Context, *v2.StateSyncCommitteesRequest) (*v2.StateSyncCommitteesResponse, error)
	ListBlockHeaders(context.Context, *v1.BlockHeadersRequest) (*v1.BlockHeadersResponse, error)
	GetBlockHeader(context.Context, *v1.BlockRequest) (*v1.BlockHeaderResponse, error)
	SubmitBlock(context.Context, *v2.SignedBeaconBlockContainerV2) (*empty.Empty, error)
	GetBlockRoot(context.Context, *v1.BlockRequest) (*v1.BlockRootResponse, error)
	GetBlock(context.Context, *v1.BlockRequest) (*v1.BlockResponse, error)
	GetBlockSSZ(context.Context, *v1.BlockRequest) (*v1.BlockSSZResponse, error)
	GetBlockV2(context.Context, *v2.BlockRequestV2) (*v2.BlockResponseV2, error)
	GetBlockSSZV2(context.Context, *v2.BlockRequestV2) (*v2.BlockSSZResponseV2, error)
	ListBlockAttestations(context.Context, *v1.BlockRequest) (*v1.BlockAttestationsResponse, error)
	ListPoolAttestations(context.Context, *v1.AttestationsPoolRequest) (*v1.AttestationsPoolResponse, error)
	SubmitAttestations(context.Context, *v1.SubmitAttestationsRequest) (*empty.Empty, error)
	ListPoolAttesterSlashings(context.Context, *empty.Empty) (*v1.AttesterSlashingsPoolResponse, error)
	SubmitAttesterSlashing(context.Context, *v1.AttesterSlashing) (*empty.Empty, error)
	ListPoolProposerSlashings(context.Context, *empty.Empty) (*v1.ProposerSlashingPoolResponse, error)
	SubmitProposerSlashing(context.Context, *v1.ProposerSlashing) (*empty.Empty, error)
	ListPoolVoluntaryExits(context.Context, *empty.Empty) (*v1.VoluntaryExitsPoolResponse, error)
	SubmitVoluntaryExit(context.Context, *v1.SignedVoluntaryExit) (*empty.Empty, error)
	SubmitPoolSyncCommitteeSignatures(context.Context, *v2.SubmitPoolSyncCommitteeSignatures) (*empty.Empty, error)
	GetForkSchedule(context.Context, *empty.Empty) (*v1.ForkScheduleResponse, error)
	GetSpec(context.Context, *empty.Empty) (*v1.SpecResponse, error)
	GetDepositContract(context.Context, *empty.Empty) (*v1.DepositContractResponse, error)
}

BeaconChainServer is the server API for BeaconChain service.

type BeaconDebugClient 

type BeaconDebugClient interface {
	GetBeaconState(ctx context.Context, in *v1.StateRequest, opts ...grpc.CallOption) (*v1.BeaconStateResponse, error)
	GetBeaconStateSSZ(ctx context.Context, in *v1.StateRequest, opts ...grpc.CallOption) (*v1.BeaconStateSSZResponse, error)
	GetBeaconStateV2(ctx context.Context, in *v2.StateRequestV2, opts ...grpc.CallOption) (*v2.BeaconStateResponseV2, error)
	GetBeaconStateSSZV2(ctx context.Context, in *v2.StateRequestV2, opts ...grpc.CallOption) (*v2.BeaconStateSSZResponseV2, error)
	ListForkChoiceHeads(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.ForkChoiceHeadsResponse, error)
}

BeaconDebugClient is the client API for BeaconDebug service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBeaconDebugClient 

func NewBeaconDebugClient(cc grpc.ClientConnInterface) BeaconDebugClient

type BeaconDebugServer 

type BeaconDebugServer interface {
	GetBeaconState(context.Context, *v1.StateRequest) (*v1.BeaconStateResponse, error)
	GetBeaconStateSSZ(context.Context, *v1.StateRequest) (*v1.BeaconStateSSZResponse, error)
	GetBeaconStateV2(context.Context, *v2.StateRequestV2) (*v2.BeaconStateResponseV2, error)
	GetBeaconStateSSZV2(context.Context, *v2.StateRequestV2) (*v2.BeaconStateSSZResponseV2, error)
	ListForkChoiceHeads(context.Context, *empty.Empty) (*v1.ForkChoiceHeadsResponse, error)
}

BeaconDebugServer is the server API for BeaconDebug service.

type BeaconNodeClient 

type BeaconNodeClient interface {
	GetIdentity(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.IdentityResponse, error)
	ListPeers(ctx context.Context, in *v1.PeersRequest, opts ...grpc.CallOption) (*v1.PeersResponse, error)
	GetPeer(ctx context.Context, in *v1.PeerRequest, opts ...grpc.CallOption) (*v1.PeerResponse, error)
	PeerCount(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.PeerCountResponse, error)
	GetSyncStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.SyncingResponse, error)
	GetVersion(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.VersionResponse, error)
	GetHealth(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

BeaconNodeClient is the client API for BeaconNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBeaconNodeClient 

func NewBeaconNodeClient(cc grpc.ClientConnInterface) BeaconNodeClient

type BeaconNodeServer 

type BeaconNodeServer interface {
	GetIdentity(context.Context, *empty.Empty) (*v1.IdentityResponse, error)
	ListPeers(context.Context, *v1.PeersRequest) (*v1.PeersResponse, error)
	GetPeer(context.Context, *v1.PeerRequest) (*v1.PeerResponse, error)
	PeerCount(context.Context, *empty.Empty) (*v1.PeerCountResponse, error)
	GetSyncStatus(context.Context, *empty.Empty) (*v1.SyncingResponse, error)
	GetVersion(context.Context, *empty.Empty) (*v1.VersionResponse, error)
	GetHealth(context.Context, *empty.Empty) (*empty.Empty, error)
}

BeaconNodeServer is the server API for BeaconNode service.

type BeaconValidatorClient 

type BeaconValidatorClient interface {
	GetAttesterDuties(ctx context.Context, in *v1.AttesterDutiesRequest, opts ...grpc.CallOption) (*v1.AttesterDutiesResponse, error)
	GetProposerDuties(ctx context.Context, in *v1.ProposerDutiesRequest, opts ...grpc.CallOption) (*v1.ProposerDutiesResponse, error)
	GetSyncCommitteeDuties(ctx context.Context, in *v2.SyncCommitteeDutiesRequest, opts ...grpc.CallOption) (*v2.SyncCommitteeDutiesResponse, error)
	ProduceBlock(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v1.ProduceBlockResponse, error)
	ProduceBlockV2(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v2.ProduceBlockResponseV2, error)
	ProduceAttestationData(ctx context.Context, in *v1.ProduceAttestationDataRequest, opts ...grpc.CallOption) (*v1.ProduceAttestationDataResponse, error)
	GetAggregateAttestation(ctx context.Context, in *v1.AggregateAttestationRequest, opts ...grpc.CallOption) (*v1.AggregateAttestationResponse, error)
	SubmitAggregateAndProofs(ctx context.Context, in *v1.SubmitAggregateAndProofsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SubmitBeaconCommitteeSubscription(ctx context.Context, in *v1.SubmitBeaconCommitteeSubscriptionsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SubmitSyncCommitteeSubscription(ctx context.Context, in *v2.SubmitSyncCommitteeSubscriptionsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ProduceSyncCommitteeContribution(ctx context.Context, in *v2.ProduceSyncCommitteeContributionRequest, opts ...grpc.CallOption) (*v2.ProduceSyncCommitteeContributionResponse, error)
	SubmitContributionAndProofs(ctx context.Context, in *v2.SubmitContributionAndProofsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

BeaconValidatorClient is the client API for BeaconValidator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBeaconValidatorClient 

func NewBeaconValidatorClient(cc grpc.ClientConnInterface) BeaconValidatorClient

type BeaconValidatorServer 

type BeaconValidatorServer interface {
	GetAttesterDuties(context.Context, *v1.AttesterDutiesRequest) (*v1.AttesterDutiesResponse, error)
	GetProposerDuties(context.Context, *v1.ProposerDutiesRequest) (*v1.ProposerDutiesResponse, error)
	GetSyncCommitteeDuties(context.Context, *v2.SyncCommitteeDutiesRequest) (*v2.SyncCommitteeDutiesResponse, error)
	ProduceBlock(context.Context, *v1.ProduceBlockRequest) (*v1.ProduceBlockResponse, error)
	ProduceBlockV2(context.Context, *v1.ProduceBlockRequest) (*v2.ProduceBlockResponseV2, error)
	ProduceAttestationData(context.Context, *v1.ProduceAttestationDataRequest) (*v1.ProduceAttestationDataResponse, error)
	GetAggregateAttestation(context.Context, *v1.AggregateAttestationRequest) (*v1.AggregateAttestationResponse, error)
	SubmitAggregateAndProofs(context.Context, *v1.SubmitAggregateAndProofsRequest) (*empty.Empty, error)
	SubmitBeaconCommitteeSubscription(context.Context, *v1.SubmitBeaconCommitteeSubscriptionsRequest) (*empty.Empty, error)
	SubmitSyncCommitteeSubscription(context.Context, *v2.SubmitSyncCommitteeSubscriptionsRequest) (*empty.Empty, error)
	ProduceSyncCommitteeContribution(context.Context, *v2.ProduceSyncCommitteeContributionRequest) (*v2.ProduceSyncCommitteeContributionResponse, error)
	SubmitContributionAndProofs(context.Context, *v2.SubmitContributionAndProofsRequest) (*empty.Empty, error)
}

BeaconValidatorServer is the server API for BeaconValidator service.

type EventsClient 

type EventsClient interface {
	StreamEvents(ctx context.Context, in *v1.StreamEventsRequest, opts ...grpc.CallOption) (Events_StreamEventsClient, error)
}

EventsClient is the client API for Events service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventsClient 

func NewEventsClient(cc grpc.ClientConnInterface) EventsClient

type EventsServer 

type EventsServer interface {
	StreamEvents(*v1.StreamEventsRequest, Events_StreamEventsServer) error
}

EventsServer is the server API for Events service.

type Events_StreamEventsClient 

type Events_StreamEventsClient interface {
	Recv() (*gateway.EventSource, error)
	grpc.ClientStream
}

type Events_StreamEventsServer 

type Events_StreamEventsServer interface {
	Send(*gateway.EventSource) error
	grpc.ServerStream
}

type UnimplementedBeaconChainServer 

type UnimplementedBeaconChainServer struct {
}

UnimplementedBeaconChainServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconChainServer) GetBlock 

func (*UnimplementedBeaconChainServer) GetBlock(context.Context, *v1.BlockRequest) (*v1.BlockResponse, error)

func (*UnimplementedBeaconChainServer) GetBlockHeader 

func (*UnimplementedBeaconChainServer) GetBlockHeader(context.Context, *v1.BlockRequest) (*v1.BlockHeaderResponse, error)

func (*UnimplementedBeaconChainServer) GetBlockRoot 

func (*UnimplementedBeaconChainServer) GetBlockRoot(context.Context, *v1.BlockRequest) (*v1.BlockRootResponse, error)

func (*UnimplementedBeaconChainServer) GetBlockSSZ 

func (*UnimplementedBeaconChainServer) GetBlockSSZ(context.Context, *v1.BlockRequest) (*v1.BlockSSZResponse, error)

func (*UnimplementedBeaconChainServer) GetBlockSSZV2 

func (*UnimplementedBeaconChainServer) GetBlockSSZV2(context.Context, *v2.BlockRequestV2) (*v2.BlockSSZResponseV2, error)

func (*UnimplementedBeaconChainServer) GetBlockV2 

func (*UnimplementedBeaconChainServer) GetBlockV2(context.Context, *v2.BlockRequestV2) (*v2.BlockResponseV2, error)

func (*UnimplementedBeaconChainServer) GetDepositContract 

func (*UnimplementedBeaconChainServer) GetDepositContract(context.Context, *empty.Empty) (*v1.DepositContractResponse, error)

func (*UnimplementedBeaconChainServer) GetFinalityCheckpoints 

func (*UnimplementedBeaconChainServer) GetFinalityCheckpoints(context.Context, *v1.StateRequest) (*v1.StateFinalityCheckpointResponse, error)

func (*UnimplementedBeaconChainServer) GetForkSchedule 

func (*UnimplementedBeaconChainServer) GetForkSchedule(context.Context, *empty.Empty) (*v1.ForkScheduleResponse, error)

func (*UnimplementedBeaconChainServer) GetGenesis 

func (*UnimplementedBeaconChainServer) GetGenesis(context.Context, *empty.Empty) (*v1.GenesisResponse, error)

func (*UnimplementedBeaconChainServer) GetSpec 

func (*UnimplementedBeaconChainServer) GetSpec(context.Context, *empty.Empty) (*v1.SpecResponse, error)

func (*UnimplementedBeaconChainServer) GetStateFork 

func (*UnimplementedBeaconChainServer) GetStateFork(context.Context, *v1.StateRequest) (*v1.StateForkResponse, error)

func (*UnimplementedBeaconChainServer) GetStateRoot 

func (*UnimplementedBeaconChainServer) GetStateRoot(context.Context, *v1.StateRequest) (*v1.StateRootResponse, error)

func (*UnimplementedBeaconChainServer) GetValidator 

func (*UnimplementedBeaconChainServer) GetValidator(context.Context, *v1.StateValidatorRequest) (*v1.StateValidatorResponse, error)

func (*UnimplementedBeaconChainServer) ListBlockAttestations 

func (*UnimplementedBeaconChainServer) ListBlockAttestations(context.Context, *v1.BlockRequest) (*v1.BlockAttestationsResponse, error)

func (*UnimplementedBeaconChainServer) ListBlockHeaders 

func (*UnimplementedBeaconChainServer) ListBlockHeaders(context.Context, *v1.BlockHeadersRequest) (*v1.BlockHeadersResponse, error)

func (*UnimplementedBeaconChainServer) ListCommittees 

func (*UnimplementedBeaconChainServer) ListCommittees(context.Context, *v1.StateCommitteesRequest) (*v1.StateCommitteesResponse, error)

func (*UnimplementedBeaconChainServer) ListPoolAttestations 

func (*UnimplementedBeaconChainServer) ListPoolAttestations(context.Context, *v1.AttestationsPoolRequest) (*v1.AttestationsPoolResponse, error)

func (*UnimplementedBeaconChainServer) ListPoolAttesterSlashings 

func (*UnimplementedBeaconChainServer) ListPoolAttesterSlashings(context.Context, *empty.Empty) (*v1.AttesterSlashingsPoolResponse, error)

func (*UnimplementedBeaconChainServer) ListPoolProposerSlashings 

func (*UnimplementedBeaconChainServer) ListPoolProposerSlashings(context.Context, *empty.Empty) (*v1.ProposerSlashingPoolResponse, error)

func (*UnimplementedBeaconChainServer) ListPoolVoluntaryExits 

func (*UnimplementedBeaconChainServer) ListPoolVoluntaryExits(context.Context, *empty.Empty) (*v1.VoluntaryExitsPoolResponse, error)

func (*UnimplementedBeaconChainServer) ListSyncCommittees 

func (*UnimplementedBeaconChainServer) ListSyncCommittees(context.Context, *v2.StateSyncCommitteesRequest) (*v2.StateSyncCommitteesResponse, error)

func (*UnimplementedBeaconChainServer) ListValidatorBalances 

func (*UnimplementedBeaconChainServer) ListValidatorBalances(context.Context, *v1.ValidatorBalancesRequest) (*v1.ValidatorBalancesResponse, error)

func (*UnimplementedBeaconChainServer) ListValidators 

func (*UnimplementedBeaconChainServer) ListValidators(context.Context, *v1.StateValidatorsRequest) (*v1.StateValidatorsResponse, error)

func (*UnimplementedBeaconChainServer) SubmitAttestations 

func (*UnimplementedBeaconChainServer) SubmitAttestations(context.Context, *v1.SubmitAttestationsRequest) (*empty.Empty, error)

func (*UnimplementedBeaconChainServer) SubmitAttesterSlashing 

func (*UnimplementedBeaconChainServer) SubmitAttesterSlashing(context.Context, *v1.AttesterSlashing) (*empty.Empty, error)

func (*UnimplementedBeaconChainServer) SubmitBlock 

func (*UnimplementedBeaconChainServer) SubmitBlock(context.Context, *v2.SignedBeaconBlockContainerV2) (*empty.Empty, error)

func (*UnimplementedBeaconChainServer) SubmitPoolSyncCommitteeSignatures 

func (*UnimplementedBeaconChainServer) SubmitPoolSyncCommitteeSignatures(context.Context, *v2.SubmitPoolSyncCommitteeSignatures) (*empty.Empty, error)

func (*UnimplementedBeaconChainServer) SubmitProposerSlashing 

func (*UnimplementedBeaconChainServer) SubmitProposerSlashing(context.Context, *v1.ProposerSlashing) (*empty.Empty, error)

func (*UnimplementedBeaconChainServer) SubmitVoluntaryExit 

func (*UnimplementedBeaconChainServer) SubmitVoluntaryExit(context.Context, *v1.SignedVoluntaryExit) (*empty.Empty, error)

type UnimplementedBeaconDebugServer 

type UnimplementedBeaconDebugServer struct {
}

UnimplementedBeaconDebugServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconDebugServer) GetBeaconState 

func (*UnimplementedBeaconDebugServer) GetBeaconState(context.Context, *v1.StateRequest) (*v1.BeaconStateResponse, error)

func (*UnimplementedBeaconDebugServer) GetBeaconStateSSZ 

func (*UnimplementedBeaconDebugServer) GetBeaconStateSSZ(context.Context, *v1.StateRequest) (*v1.BeaconStateSSZResponse, error)

func (*UnimplementedBeaconDebugServer) GetBeaconStateSSZV2 

func (*UnimplementedBeaconDebugServer) GetBeaconStateSSZV2(context.Context, *v2.StateRequestV2) (*v2.BeaconStateSSZResponseV2, error)

func (*UnimplementedBeaconDebugServer) GetBeaconStateV2 

func (*UnimplementedBeaconDebugServer) GetBeaconStateV2(context.Context, *v2.StateRequestV2) (*v2.BeaconStateResponseV2, error)

func (*UnimplementedBeaconDebugServer) ListForkChoiceHeads 

func (*UnimplementedBeaconDebugServer) ListForkChoiceHeads(context.Context, *empty.Empty) (*v1.ForkChoiceHeadsResponse, error)

type UnimplementedBeaconNodeServer 

type UnimplementedBeaconNodeServer struct {
}

UnimplementedBeaconNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconNodeServer) GetHealth 

func (*UnimplementedBeaconNodeServer) GetHealth(context.Context, *empty.Empty) (*empty.Empty, error)

func (*UnimplementedBeaconNodeServer) GetIdentity 

func (*UnimplementedBeaconNodeServer) GetIdentity(context.Context, *empty.Empty) (*v1.IdentityResponse, error)

func (*UnimplementedBeaconNodeServer) GetPeer 

func (*UnimplementedBeaconNodeServer) GetPeer(context.Context, *v1.PeerRequest) (*v1.PeerResponse, error)

func (*UnimplementedBeaconNodeServer) GetSyncStatus 

func (*UnimplementedBeaconNodeServer) GetSyncStatus(context.Context, *empty.Empty) (*v1.SyncingResponse, error)

func (*UnimplementedBeaconNodeServer) GetVersion 

func (*UnimplementedBeaconNodeServer) GetVersion(context.Context, *empty.Empty) (*v1.VersionResponse, error)

func (*UnimplementedBeaconNodeServer) ListPeers 

func (*UnimplementedBeaconNodeServer) ListPeers(context.Context, *v1.PeersRequest) (*v1.PeersResponse, error)

func (*UnimplementedBeaconNodeServer) PeerCount 

func (*UnimplementedBeaconNodeServer) PeerCount(context.Context, *empty.Empty) (*v1.PeerCountResponse, error)

type UnimplementedBeaconValidatorServer 

type UnimplementedBeaconValidatorServer struct {
}

UnimplementedBeaconValidatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconValidatorServer) GetAggregateAttestation 

func (*UnimplementedBeaconValidatorServer) GetAggregateAttestation(context.Context, *v1.AggregateAttestationRequest) (*v1.AggregateAttestationResponse, error)

func (*UnimplementedBeaconValidatorServer) GetAttesterDuties 

func (*UnimplementedBeaconValidatorServer) GetAttesterDuties(context.Context, *v1.AttesterDutiesRequest) (*v1.AttesterDutiesResponse, error)

func (*UnimplementedBeaconValidatorServer) GetProposerDuties 

func (*UnimplementedBeaconValidatorServer) GetProposerDuties(context.Context, *v1.ProposerDutiesRequest) (*v1.ProposerDutiesResponse, error)

func (*UnimplementedBeaconValidatorServer) GetSyncCommitteeDuties 

func (*UnimplementedBeaconValidatorServer) GetSyncCommitteeDuties(context.Context, *v2.SyncCommitteeDutiesRequest) (*v2.SyncCommitteeDutiesResponse, error)

func (*UnimplementedBeaconValidatorServer) ProduceAttestationData 

func (*UnimplementedBeaconValidatorServer) ProduceAttestationData(context.Context, *v1.ProduceAttestationDataRequest) (*v1.ProduceAttestationDataResponse, error)

func (*UnimplementedBeaconValidatorServer) ProduceBlock 

func (*UnimplementedBeaconValidatorServer) ProduceBlock(context.Context, *v1.ProduceBlockRequest) (*v1.ProduceBlockResponse, error)

func (*UnimplementedBeaconValidatorServer) ProduceBlockV2 

func (*UnimplementedBeaconValidatorServer) ProduceBlockV2(context.Context, *v1.ProduceBlockRequest) (*v2.ProduceBlockResponseV2, error)

func (*UnimplementedBeaconValidatorServer) ProduceSyncCommitteeContribution 

func (*UnimplementedBeaconValidatorServer) ProduceSyncCommitteeContribution(context.Context, *v2.ProduceSyncCommitteeContributionRequest) (*v2.ProduceSyncCommitteeContributionResponse, error)

func (*UnimplementedBeaconValidatorServer) SubmitAggregateAndProofs 

func (*UnimplementedBeaconValidatorServer) SubmitAggregateAndProofs(context.Context, *v1.SubmitAggregateAndProofsRequest) (*empty.Empty, error)

func (*UnimplementedBeaconValidatorServer) SubmitBeaconCommitteeSubscription 

func (*UnimplementedBeaconValidatorServer) SubmitBeaconCommitteeSubscription(context.Context, *v1.SubmitBeaconCommitteeSubscriptionsRequest) (*empty.Empty, error)

func (*UnimplementedBeaconValidatorServer) SubmitContributionAndProofs 

func (*UnimplementedBeaconValidatorServer) SubmitContributionAndProofs(context.Context, *v2.SubmitContributionAndProofsRequest) (*empty.Empty, error)

func (*UnimplementedBeaconValidatorServer) SubmitSyncCommitteeSubscription 

func (*UnimplementedBeaconValidatorServer) SubmitSyncCommitteeSubscription(context.Context, *v2.SubmitSyncCommitteeSubscriptionsRequest) (*empty.Empty, error)

type UnimplementedEventsServer 

type UnimplementedEventsServer struct {
}

UnimplementedEventsServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventsServer) StreamEvents 

func (*UnimplementedEventsServer) StreamEvents(*v1.StreamEventsRequest, Events_StreamEventsServer) 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.