service

package
v0.0.0-...-321975c Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2025 License: Apache-2.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.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ImportedKeystoreStatus_Status_name = map[int32]string{
		0: "IMPORTED",
		1: "DUPLICATE",
		2: "ERROR",
	}
	ImportedKeystoreStatus_Status_value = map[string]int32{
		"IMPORTED":  0,
		"DUPLICATE": 1,
		"ERROR":     2,
	}
)

Enum value maps for ImportedKeystoreStatus_Status.

View Source 
var (
	DeletedKeystoreStatus_Status_name = map[int32]string{
		0: "DELETED",
		1: "NOT_FOUND",
		2: "NOT_ACTIVE",
		3: "ERROR",
	}
	DeletedKeystoreStatus_Status_value = map[string]int32{
		"DELETED":    0,
		"NOT_FOUND":  1,
		"NOT_ACTIVE": 2,
		"ERROR":      3,
	}
)

Enum value maps for DeletedKeystoreStatus_Status.

View Source 
var File_eth_service_beacon_chain_service_proto protoreflect.FileDescriptor
View Source 
var File_eth_service_beacon_debug_service_proto protoreflect.FileDescriptor
View Source 
var File_eth_service_events_service_proto protoreflect.FileDescriptor
View Source 
var File_eth_service_key_management_proto protoreflect.FileDescriptor
View Source 
var File_eth_service_node_service_proto protoreflect.FileDescriptor
View Source 
var File_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)

func RegisterKeyManagementHandler 

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

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

func RegisterKeyManagementHandlerClient 

func RegisterKeyManagementHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KeyManagementClient) error

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

func RegisterKeyManagementHandlerFromEndpoint 

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

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

func RegisterKeyManagementHandlerServer 

func RegisterKeyManagementHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KeyManagementServer) error

RegisterKeyManagementHandlerServer registers the http handlers for service KeyManagement to "mux". UnaryRPC :call KeyManagementServer 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 RegisterKeyManagementHandlerFromEndpoint instead.

func RegisterKeyManagementServer 

func RegisterKeyManagementServer(s *grpc.Server, srv KeyManagementServer)

Types

type BeaconChainClient 

type BeaconChainClient interface {
	// Deprecated: Do not use.
	GetWeakSubjectivity(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v1.WeakSubjectivityResponse, 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 {
	// Deprecated: Do not use.
	GetWeakSubjectivity(context.Context, *emptypb.Empty) (*v1.WeakSubjectivityResponse, error)
}

BeaconChainServer is the server API for BeaconChain service.

type BeaconDebugClient 

type BeaconDebugClient interface {
	ListForkChoiceHeadsV2(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v2.ForkChoiceHeadsResponse, error)
	GetForkChoice(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v1.ForkChoiceDump, 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 {
	ListForkChoiceHeadsV2(context.Context, *emptypb.Empty) (*v2.ForkChoiceHeadsResponse, error)
	GetForkChoice(context.Context, *emptypb.Empty) (*v1.ForkChoiceDump, error)
}

BeaconDebugServer is the server API for BeaconDebug service.

type BeaconNodeClient 

type BeaconNodeClient interface {
	GetIdentity(ctx context.Context, in *emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*v1.PeerCountResponse, error)
	GetVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v1.VersionResponse, error)
	GetHealth(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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, *emptypb.Empty) (*v1.IdentityResponse, error)
	ListPeers(context.Context, *v1.PeersRequest) (*v1.PeersResponse, error)
	GetPeer(context.Context, *v1.PeerRequest) (*v1.PeerResponse, error)
	PeerCount(context.Context, *emptypb.Empty) (*v1.PeerCountResponse, error)
	GetVersion(context.Context, *emptypb.Empty) (*v1.VersionResponse, error)
	GetHealth(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
}

BeaconNodeServer is the server API for BeaconNode service.

type BeaconValidatorClient 

type BeaconValidatorClient interface {
	ProduceBlockV2(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v2.ProduceBlockResponseV2, error)
	ProduceBlockV2SSZ(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v2.SSZContainer, error)
	ProduceBlindedBlock(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v2.ProduceBlindedBlockResponse, error)
	ProduceBlindedBlockSSZ(ctx context.Context, in *v1.ProduceBlockRequest, opts ...grpc.CallOption) (*v2.SSZContainer, 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 {
	ProduceBlockV2(context.Context, *v1.ProduceBlockRequest) (*v2.ProduceBlockResponseV2, error)
	ProduceBlockV2SSZ(context.Context, *v1.ProduceBlockRequest) (*v2.SSZContainer, error)
	ProduceBlindedBlock(context.Context, *v1.ProduceBlockRequest) (*v2.ProduceBlindedBlockResponse, error)
	ProduceBlindedBlockSSZ(context.Context, *v1.ProduceBlockRequest) (*v2.SSZContainer, error)
}

BeaconValidatorServer is the server API for BeaconValidator service.

type DeleteKeystoresRequest 

type DeleteKeystoresRequest struct {
	Pubkeys [][]byte `protobuf:"bytes,1,rep,name=pubkeys,proto3" json:"pubkeys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeystoresRequest) Descriptor deprecated 

func (*DeleteKeystoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteKeystoresRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeystoresRequest) GetPubkeys 

func (x *DeleteKeystoresRequest) GetPubkeys() [][]byte

func (*DeleteKeystoresRequest) ProtoMessage 

func (*DeleteKeystoresRequest) ProtoMessage()

func (*DeleteKeystoresRequest) ProtoReflect 

func (x *DeleteKeystoresRequest) ProtoReflect() protoreflect.Message

func (*DeleteKeystoresRequest) Reset 

func (x *DeleteKeystoresRequest) Reset()

func (*DeleteKeystoresRequest) String 

func (x *DeleteKeystoresRequest) String() string

type DeleteKeystoresResponse 

type DeleteKeystoresResponse struct {
	Data               []*DeletedKeystoreStatus `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	SlashingProtection string                   `protobuf:"bytes,2,opt,name=slashing_protection,json=slashingProtection,proto3" json:"slashing_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeystoresResponse) Descriptor deprecated 

func (*DeleteKeystoresResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteKeystoresResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeystoresResponse) GetData 

func (x *DeleteKeystoresResponse) GetData() []*DeletedKeystoreStatus

func (*DeleteKeystoresResponse) GetSlashingProtection 

func (x *DeleteKeystoresResponse) GetSlashingProtection() string

func (*DeleteKeystoresResponse) ProtoMessage 

func (*DeleteKeystoresResponse) ProtoMessage()

func (*DeleteKeystoresResponse) ProtoReflect 

func (x *DeleteKeystoresResponse) ProtoReflect() protoreflect.Message

func (*DeleteKeystoresResponse) Reset 

func (x *DeleteKeystoresResponse) Reset()

func (*DeleteKeystoresResponse) String 

func (x *DeleteKeystoresResponse) String() string

type DeletedKeystoreStatus 

type DeletedKeystoreStatus struct {
	Status  DeletedKeystoreStatus_Status `protobuf:"varint,1,opt,name=status,proto3,enum=ethereum.eth.service.DeletedKeystoreStatus_Status" json:"status,omitempty"`
	Message string                       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletedKeystoreStatus) Descriptor deprecated 

func (*DeletedKeystoreStatus) Descriptor() ([]byte, []int)

Deprecated: Use DeletedKeystoreStatus.ProtoReflect.Descriptor instead.

func (*DeletedKeystoreStatus) GetMessage 

func (x *DeletedKeystoreStatus) GetMessage() string

func (*DeletedKeystoreStatus) GetStatus 

func (x *DeletedKeystoreStatus) GetStatus() DeletedKeystoreStatus_Status

func (*DeletedKeystoreStatus) ProtoMessage 

func (*DeletedKeystoreStatus) ProtoMessage()

func (*DeletedKeystoreStatus) ProtoReflect 

func (x *DeletedKeystoreStatus) ProtoReflect() protoreflect.Message

func (*DeletedKeystoreStatus) Reset 

func (x *DeletedKeystoreStatus) Reset()

func (*DeletedKeystoreStatus) String 

func (x *DeletedKeystoreStatus) String() string

type DeletedKeystoreStatus_Status 

type DeletedKeystoreStatus_Status int32
const (
	DeletedKeystoreStatus_DELETED    DeletedKeystoreStatus_Status = 0
	DeletedKeystoreStatus_NOT_FOUND  DeletedKeystoreStatus_Status = 1
	DeletedKeystoreStatus_NOT_ACTIVE DeletedKeystoreStatus_Status = 2
	DeletedKeystoreStatus_ERROR      DeletedKeystoreStatus_Status = 3
)

func (DeletedKeystoreStatus_Status) Descriptor 

func (DeletedKeystoreStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (DeletedKeystoreStatus_Status) Enum 

func (x DeletedKeystoreStatus_Status) Enum() *DeletedKeystoreStatus_Status

func (DeletedKeystoreStatus_Status) EnumDescriptor deprecated 

func (DeletedKeystoreStatus_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeletedKeystoreStatus_Status.Descriptor instead.

func (DeletedKeystoreStatus_Status) Number 

func (x DeletedKeystoreStatus_Status) Number() protoreflect.EnumNumber

func (DeletedKeystoreStatus_Status) String 

func (x DeletedKeystoreStatus_Status) String() string

func (DeletedKeystoreStatus_Status) Type 

func (DeletedKeystoreStatus_Status) Type() protoreflect.EnumType

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 ImportKeystoresRequest 

type ImportKeystoresRequest struct {
	Keystores          []string `protobuf:"bytes,1,rep,name=keystores,proto3" json:"keystores,omitempty"`
	Passwords          []string `protobuf:"bytes,2,rep,name=passwords,proto3" json:"passwords,omitempty"`
	SlashingProtection string   `protobuf:"bytes,3,opt,name=slashing_protection,json=slashingProtection,proto3" json:"slashing_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportKeystoresRequest) Descriptor deprecated 

func (*ImportKeystoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use ImportKeystoresRequest.ProtoReflect.Descriptor instead.

func (*ImportKeystoresRequest) GetKeystores 

func (x *ImportKeystoresRequest) GetKeystores() []string

func (*ImportKeystoresRequest) GetPasswords 

func (x *ImportKeystoresRequest) GetPasswords() []string

func (*ImportKeystoresRequest) GetSlashingProtection 

func (x *ImportKeystoresRequest) GetSlashingProtection() string

func (*ImportKeystoresRequest) ProtoMessage 

func (*ImportKeystoresRequest) ProtoMessage()

func (*ImportKeystoresRequest) ProtoReflect 

func (x *ImportKeystoresRequest) ProtoReflect() protoreflect.Message

func (*ImportKeystoresRequest) Reset 

func (x *ImportKeystoresRequest) Reset()

func (*ImportKeystoresRequest) String 

func (x *ImportKeystoresRequest) String() string

type ImportKeystoresResponse 

type ImportKeystoresResponse struct {
	Data []*ImportedKeystoreStatus `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportKeystoresResponse) Descriptor deprecated 

func (*ImportKeystoresResponse) Descriptor() ([]byte, []int)

Deprecated: Use ImportKeystoresResponse.ProtoReflect.Descriptor instead.

func (*ImportKeystoresResponse) GetData 

func (x *ImportKeystoresResponse) GetData() []*ImportedKeystoreStatus

func (*ImportKeystoresResponse) ProtoMessage 

func (*ImportKeystoresResponse) ProtoMessage()

func (*ImportKeystoresResponse) ProtoReflect 

func (x *ImportKeystoresResponse) ProtoReflect() protoreflect.Message

func (*ImportKeystoresResponse) Reset 

func (x *ImportKeystoresResponse) Reset()

func (*ImportKeystoresResponse) String 

func (x *ImportKeystoresResponse) String() string

type ImportedKeystoreStatus 

type ImportedKeystoreStatus struct {
	Status  ImportedKeystoreStatus_Status `protobuf:"varint,1,opt,name=status,proto3,enum=ethereum.eth.service.ImportedKeystoreStatus_Status" json:"status,omitempty"`
	Message string                        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportedKeystoreStatus) Descriptor deprecated 

func (*ImportedKeystoreStatus) Descriptor() ([]byte, []int)

Deprecated: Use ImportedKeystoreStatus.ProtoReflect.Descriptor instead.

func (*ImportedKeystoreStatus) GetMessage 

func (x *ImportedKeystoreStatus) GetMessage() string

func (*ImportedKeystoreStatus) GetStatus 

func (x *ImportedKeystoreStatus) GetStatus() ImportedKeystoreStatus_Status

func (*ImportedKeystoreStatus) ProtoMessage 

func (*ImportedKeystoreStatus) ProtoMessage()

func (*ImportedKeystoreStatus) ProtoReflect 

func (x *ImportedKeystoreStatus) ProtoReflect() protoreflect.Message

func (*ImportedKeystoreStatus) Reset 

func (x *ImportedKeystoreStatus) Reset()

func (*ImportedKeystoreStatus) String 

func (x *ImportedKeystoreStatus) String() string

type ImportedKeystoreStatus_Status 

type ImportedKeystoreStatus_Status int32
const (
	ImportedKeystoreStatus_IMPORTED  ImportedKeystoreStatus_Status = 0
	ImportedKeystoreStatus_DUPLICATE ImportedKeystoreStatus_Status = 1
	ImportedKeystoreStatus_ERROR     ImportedKeystoreStatus_Status = 2
)

func (ImportedKeystoreStatus_Status) Descriptor 

func (ImportedKeystoreStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (ImportedKeystoreStatus_Status) Enum 

func (x ImportedKeystoreStatus_Status) Enum() *ImportedKeystoreStatus_Status

func (ImportedKeystoreStatus_Status) EnumDescriptor deprecated 

func (ImportedKeystoreStatus_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ImportedKeystoreStatus_Status.Descriptor instead.

func (ImportedKeystoreStatus_Status) Number 

func (x ImportedKeystoreStatus_Status) Number() protoreflect.EnumNumber

func (ImportedKeystoreStatus_Status) String 

func (x ImportedKeystoreStatus_Status) String() string

func (ImportedKeystoreStatus_Status) Type 

func (ImportedKeystoreStatus_Status) Type() protoreflect.EnumType

type KeyManagementClient 

type KeyManagementClient interface {
	ListKeystores(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListKeystoresResponse, error)
	ImportKeystores(ctx context.Context, in *ImportKeystoresRequest, opts ...grpc.CallOption) (*ImportKeystoresResponse, error)
	DeleteKeystores(ctx context.Context, in *DeleteKeystoresRequest, opts ...grpc.CallOption) (*DeleteKeystoresResponse, error)
}

KeyManagementClient is the client API for KeyManagement service.

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

func NewKeyManagementClient 

func NewKeyManagementClient(cc grpc.ClientConnInterface) KeyManagementClient

type KeyManagementServer 

type KeyManagementServer interface {
	ListKeystores(context.Context, *emptypb.Empty) (*ListKeystoresResponse, error)
	ImportKeystores(context.Context, *ImportKeystoresRequest) (*ImportKeystoresResponse, error)
	DeleteKeystores(context.Context, *DeleteKeystoresRequest) (*DeleteKeystoresResponse, error)
}

KeyManagementServer is the server API for KeyManagement service.

type ListKeystoresResponse 

type ListKeystoresResponse struct {
	Data []*ListKeystoresResponse_Keystore `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeystoresResponse) Descriptor deprecated 

func (*ListKeystoresResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListKeystoresResponse.ProtoReflect.Descriptor instead.

func (*ListKeystoresResponse) GetData 

func (x *ListKeystoresResponse) GetData() []*ListKeystoresResponse_Keystore

func (*ListKeystoresResponse) ProtoMessage 

func (*ListKeystoresResponse) ProtoMessage()

func (*ListKeystoresResponse) ProtoReflect 

func (x *ListKeystoresResponse) ProtoReflect() protoreflect.Message

func (*ListKeystoresResponse) Reset 

func (x *ListKeystoresResponse) Reset()

func (*ListKeystoresResponse) String 

func (x *ListKeystoresResponse) String() string

type ListKeystoresResponse_Keystore 

type ListKeystoresResponse_Keystore struct {
	ValidatingPubkey []byte `protobuf:"bytes,1,opt,name=validating_pubkey,json=validatingPubkey,proto3" json:"validating_pubkey,omitempty"`
	DerivationPath   string `protobuf:"bytes,2,opt,name=derivation_path,json=derivationPath,proto3" json:"derivation_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeystoresResponse_Keystore) Descriptor deprecated 

func (*ListKeystoresResponse_Keystore) Descriptor() ([]byte, []int)

Deprecated: Use ListKeystoresResponse_Keystore.ProtoReflect.Descriptor instead.

func (*ListKeystoresResponse_Keystore) GetDerivationPath 

func (x *ListKeystoresResponse_Keystore) GetDerivationPath() string

func (*ListKeystoresResponse_Keystore) GetValidatingPubkey 

func (x *ListKeystoresResponse_Keystore) GetValidatingPubkey() []byte

func (*ListKeystoresResponse_Keystore) ProtoMessage 

func (*ListKeystoresResponse_Keystore) ProtoMessage()

func (*ListKeystoresResponse_Keystore) ProtoReflect 

func (x *ListKeystoresResponse_Keystore) ProtoReflect() protoreflect.Message

func (*ListKeystoresResponse_Keystore) Reset 

func (x *ListKeystoresResponse_Keystore) Reset()

func (*ListKeystoresResponse_Keystore) String 

func (x *ListKeystoresResponse_Keystore) String() string

type PubkeyRequest 

type PubkeyRequest struct {
	Pubkey []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// contains filtered or unexported fields
}

func (*PubkeyRequest) Descriptor deprecated 

func (*PubkeyRequest) Descriptor() ([]byte, []int)

Deprecated: Use PubkeyRequest.ProtoReflect.Descriptor instead.

func (*PubkeyRequest) GetPubkey 

func (x *PubkeyRequest) GetPubkey() []byte

func (*PubkeyRequest) ProtoMessage 

func (*PubkeyRequest) ProtoMessage()

func (*PubkeyRequest) ProtoReflect 

func (x *PubkeyRequest) ProtoReflect() protoreflect.Message

func (*PubkeyRequest) Reset 

func (x *PubkeyRequest) Reset()

func (*PubkeyRequest) String 

func (x *PubkeyRequest) String() string

type UnimplementedBeaconChainServer 

type UnimplementedBeaconChainServer struct {
}

UnimplementedBeaconChainServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconChainServer) GetWeakSubjectivity 

func (*UnimplementedBeaconChainServer) GetWeakSubjectivity(context.Context, *emptypb.Empty) (*v1.WeakSubjectivityResponse, error)

type UnimplementedBeaconDebugServer 

type UnimplementedBeaconDebugServer struct {
}

UnimplementedBeaconDebugServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconDebugServer) GetForkChoice 

func (*UnimplementedBeaconDebugServer) GetForkChoice(context.Context, *emptypb.Empty) (*v1.ForkChoiceDump, error)

func (*UnimplementedBeaconDebugServer) ListForkChoiceHeadsV2 

func (*UnimplementedBeaconDebugServer) ListForkChoiceHeadsV2(context.Context, *emptypb.Empty) (*v2.ForkChoiceHeadsResponse, error)

type UnimplementedBeaconNodeServer 

type UnimplementedBeaconNodeServer struct {
}

UnimplementedBeaconNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconNodeServer) GetHealth 

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

func (*UnimplementedBeaconNodeServer) GetIdentity 

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

func (*UnimplementedBeaconNodeServer) GetPeer 

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

func (*UnimplementedBeaconNodeServer) GetVersion 

func (*UnimplementedBeaconNodeServer) GetVersion(context.Context, *emptypb.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, *emptypb.Empty) (*v1.PeerCountResponse, error)

type UnimplementedBeaconValidatorServer 

type UnimplementedBeaconValidatorServer struct {
}

UnimplementedBeaconValidatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedBeaconValidatorServer) ProduceBlindedBlock 

func (*UnimplementedBeaconValidatorServer) ProduceBlindedBlock(context.Context, *v1.ProduceBlockRequest) (*v2.ProduceBlindedBlockResponse, error)

func (*UnimplementedBeaconValidatorServer) ProduceBlindedBlockSSZ 

func (*UnimplementedBeaconValidatorServer) ProduceBlindedBlockSSZ(context.Context, *v1.ProduceBlockRequest) (*v2.SSZContainer, error)

func (*UnimplementedBeaconValidatorServer) ProduceBlockV2 

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

func (*UnimplementedBeaconValidatorServer) ProduceBlockV2SSZ 

func (*UnimplementedBeaconValidatorServer) ProduceBlockV2SSZ(context.Context, *v1.ProduceBlockRequest) (*v2.SSZContainer, 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

type UnimplementedKeyManagementServer 

type UnimplementedKeyManagementServer struct {
}

UnimplementedKeyManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyManagementServer) DeleteKeystores 

func (*UnimplementedKeyManagementServer) DeleteKeystores(context.Context, *DeleteKeystoresRequest) (*DeleteKeystoresResponse, error)

func (*UnimplementedKeyManagementServer) ImportKeystores 

func (*UnimplementedKeyManagementServer) ImportKeystores(context.Context, *ImportKeystoresRequest) (*ImportKeystoresResponse, error)

func (*UnimplementedKeyManagementServer) ListKeystores 

func (*UnimplementedKeyManagementServer) ListKeystores(context.Context, *emptypb.Empty) (*ListKeystoresResponse, 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.