beaconspotproto

package
v0.0.0-...-e0aa601 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_begmaroman_beaconspot_proto_beaconspot_beaconspot_proto protoreflect.FileDescriptor

Functions

func RegisterBeaconSpotServiceServer 

func RegisterBeaconSpotServiceServer(s grpc.ServiceRegistrar, srv BeaconSpotServiceServer)

Types

type BeaconSpotServiceClient 

type BeaconSpotServiceClient interface {
	Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*health.HealthResponse, error)
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DomainData returns domain data by the given request
	DomainData(ctx context.Context, in *DomainDataRequest, opts ...grpc.CallOption) (*DomainDataResponse, error)
	// GetAttestation returns attestation data by the given request parameters.
	GetAttestation(ctx context.Context, in *GetAttestationRequest, opts ...grpc.CallOption) (*GetAttestationResponse, error)
	// ProposeAttestation submits the given signed attestation to the beacon nodes.
	// This endpoint submits attestation to all nodes and waits for response from all of them.
	ProposeAttestation(ctx context.Context, in *ProposeAttestationRequest, opts ...grpc.CallOption) (*ProposeAttestationResponse, error)
	// GetAggregateSelectionProof returns aggregation data by the given params.
	GetAggregateSelectionProof(ctx context.Context, in *GetAggregateSelectionProofRequest, opts ...grpc.CallOption) (*GetAggregateSelectionProofResponse, error)
	// SubmitSignedAggregateSelectionProof submits signed aggregation data to the beacon nodes.
	// This endpoint submits aggregation to all nodes and waits for response from all of them.
	SubmitSignedAggregateSelectionProof(ctx context.Context, in *SubmitSignedAggregateSelectionProofRequest, opts ...grpc.CallOption) (*SubmitSignedAggregateSelectionProofResponse, error)
	// GetBlock returns a block by the given request.
	GetBlock(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (*GetBlockResponse, error)
	// ProposeBlock proposes the given signed block to beacon nodes.
	// This endpoint submits signed block to all nodes and waits for response from all of them.
	ProposeBlock(ctx context.Context, in *ProposeBlockRequest, opts ...grpc.CallOption) (*ProposeBlockResponse, error)
	// SubnetsSubscribe sends a request to nodes to subscribe on the given subnets.
	SubnetsSubscribe(ctx context.Context, in *SubnetsSubscribeRequest, opts ...grpc.CallOption) (*SubnetsSubscribeResponse, error)
	// StreamDuties opens duties streaming from the beacon nodes.
	StreamDuties(ctx context.Context, in *StreamDutiesRequest, opts ...grpc.CallOption) (BeaconSpotService_StreamDutiesClient, error)
}

BeaconSpotServiceClient is the client API for BeaconSpotService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBeaconSpotServiceClient 

func NewBeaconSpotServiceClient(cc grpc.ClientConnInterface) BeaconSpotServiceClient

type BeaconSpotServiceServer 

type BeaconSpotServiceServer interface {
	Health(context.Context, *emptypb.Empty) (*health.HealthResponse, error)
	Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// DomainData returns domain data by the given request
	DomainData(context.Context, *DomainDataRequest) (*DomainDataResponse, error)
	// GetAttestation returns attestation data by the given request parameters.
	GetAttestation(context.Context, *GetAttestationRequest) (*GetAttestationResponse, error)
	// ProposeAttestation submits the given signed attestation to the beacon nodes.
	// This endpoint submits attestation to all nodes and waits for response from all of them.
	ProposeAttestation(context.Context, *ProposeAttestationRequest) (*ProposeAttestationResponse, error)
	// GetAggregateSelectionProof returns aggregation data by the given params.
	GetAggregateSelectionProof(context.Context, *GetAggregateSelectionProofRequest) (*GetAggregateSelectionProofResponse, error)
	// SubmitSignedAggregateSelectionProof submits signed aggregation data to the beacon nodes.
	// This endpoint submits aggregation to all nodes and waits for response from all of them.
	SubmitSignedAggregateSelectionProof(context.Context, *SubmitSignedAggregateSelectionProofRequest) (*SubmitSignedAggregateSelectionProofResponse, error)
	// GetBlock returns a block by the given request.
	GetBlock(context.Context, *GetBlockRequest) (*GetBlockResponse, error)
	// ProposeBlock proposes the given signed block to beacon nodes.
	// This endpoint submits signed block to all nodes and waits for response from all of them.
	ProposeBlock(context.Context, *ProposeBlockRequest) (*ProposeBlockResponse, error)
	// SubnetsSubscribe sends a request to nodes to subscribe on the given subnets.
	SubnetsSubscribe(context.Context, *SubnetsSubscribeRequest) (*SubnetsSubscribeResponse, error)
	// StreamDuties opens duties streaming from the beacon nodes.
	StreamDuties(*StreamDutiesRequest, BeaconSpotService_StreamDutiesServer) error
	// contains filtered or unexported methods
}

BeaconSpotServiceServer is the server API for BeaconSpotService service. All implementations must embed UnimplementedBeaconSpotServiceServer for forward compatibility

type BeaconSpotService_StreamDutiesClient 

type BeaconSpotService_StreamDutiesClient interface {
	Recv() (*StreamDutiesResponse, error)
	grpc.ClientStream
}

type BeaconSpotService_StreamDutiesServer 

type BeaconSpotService_StreamDutiesServer interface {
	Send(*StreamDutiesResponse) error
	grpc.ServerStream
}

type DomainDataRequest 

type DomainDataRequest struct {
	Epoch  uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Domain []byte `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

DomainData operation

func (*DomainDataRequest) Descriptor deprecated 

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

Deprecated: Use DomainDataRequest.ProtoReflect.Descriptor instead.

func (*DomainDataRequest) GetDomain 

func (x *DomainDataRequest) GetDomain() []byte

func (*DomainDataRequest) GetEpoch 

func (x *DomainDataRequest) GetEpoch() uint64

func (*DomainDataRequest) ProtoMessage 

func (*DomainDataRequest) ProtoMessage()

func (*DomainDataRequest) ProtoReflect 

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

func (*DomainDataRequest) Reset 

func (x *DomainDataRequest) Reset()

func (*DomainDataRequest) String 

func (x *DomainDataRequest) String() string

type DomainDataResponse 

type DomainDataResponse struct {

	// Types that are assignable to Result:
	//	*DomainDataResponse_Error
	//	*DomainDataResponse_DomainData
	Result isDomainDataResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*DomainDataResponse) Descriptor deprecated 

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

Deprecated: Use DomainDataResponse.ProtoReflect.Descriptor instead.

func (*DomainDataResponse) GetDomainData 

func (x *DomainDataResponse) GetDomainData() []byte

func (*DomainDataResponse) GetError 

func (x *DomainDataResponse) GetError() *status.Status

func (*DomainDataResponse) GetResult 

func (m *DomainDataResponse) GetResult() isDomainDataResponse_Result

func (*DomainDataResponse) ProtoMessage 

func (*DomainDataResponse) ProtoMessage()

func (*DomainDataResponse) ProtoReflect 

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

func (*DomainDataResponse) Reset 

func (x *DomainDataResponse) Reset()

func (*DomainDataResponse) String 

func (x *DomainDataResponse) String() string

type DomainDataResponse_DomainData 

type DomainDataResponse_DomainData struct {
	DomainData []byte `protobuf:"bytes,2,opt,name=domain_data,json=domainData,proto3,oneof"`
}

type DomainDataResponse_Error 

type DomainDataResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type GetAggregateSelectionProofRequest 

type GetAggregateSelectionProofRequest struct {
	Slot           uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	CommitteeIndex uint64 `protobuf:"varint,2,opt,name=committee_index,json=committeeIndex,proto3" json:"committee_index,omitempty"`
	PublicKey      []byte `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Signature      []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

GetAggregateSelectionProof operation

func (*GetAggregateSelectionProofRequest) Descriptor deprecated 

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

Deprecated: Use GetAggregateSelectionProofRequest.ProtoReflect.Descriptor instead.

func (*GetAggregateSelectionProofRequest) GetCommitteeIndex 

func (x *GetAggregateSelectionProofRequest) GetCommitteeIndex() uint64

func (*GetAggregateSelectionProofRequest) GetPublicKey 

func (x *GetAggregateSelectionProofRequest) GetPublicKey() []byte

func (*GetAggregateSelectionProofRequest) GetSignature 

func (x *GetAggregateSelectionProofRequest) GetSignature() []byte

func (*GetAggregateSelectionProofRequest) GetSlot 

func (x *GetAggregateSelectionProofRequest) GetSlot() uint64

func (*GetAggregateSelectionProofRequest) ProtoMessage 

func (*GetAggregateSelectionProofRequest) ProtoMessage()

func (*GetAggregateSelectionProofRequest) ProtoReflect 

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

func (*GetAggregateSelectionProofRequest) Reset 

func (x *GetAggregateSelectionProofRequest) Reset()

func (*GetAggregateSelectionProofRequest) String 

func (x *GetAggregateSelectionProofRequest) String() string

type GetAggregateSelectionProofResponse 

type GetAggregateSelectionProofResponse struct {

	// Types that are assignable to Result:
	//	*GetAggregateSelectionProofResponse_Error
	//	*GetAggregateSelectionProofResponse_Data
	Result isGetAggregateSelectionProofResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*GetAggregateSelectionProofResponse) Descriptor deprecated 

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

Deprecated: Use GetAggregateSelectionProofResponse.ProtoReflect.Descriptor instead.

func (*GetAggregateSelectionProofResponse) GetData 

func (x *GetAggregateSelectionProofResponse) GetData() *v1alpha1.AggregateAttestationAndProof

func (*GetAggregateSelectionProofResponse) GetError 

func (x *GetAggregateSelectionProofResponse) GetError() *status.Status

func (*GetAggregateSelectionProofResponse) GetResult 

func (m *GetAggregateSelectionProofResponse) GetResult() isGetAggregateSelectionProofResponse_Result

func (*GetAggregateSelectionProofResponse) ProtoMessage 

func (*GetAggregateSelectionProofResponse) ProtoMessage()

func (*GetAggregateSelectionProofResponse) ProtoReflect 

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

func (*GetAggregateSelectionProofResponse) Reset 

func (x *GetAggregateSelectionProofResponse) Reset()

func (*GetAggregateSelectionProofResponse) String 

func (x *GetAggregateSelectionProofResponse) String() string

type GetAggregateSelectionProofResponse_Data 

type GetAggregateSelectionProofResponse_Data struct {
	Data *v1alpha1.AggregateAttestationAndProof `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type GetAggregateSelectionProofResponse_Error 

type GetAggregateSelectionProofResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type GetAttestationRequest 

type GetAttestationRequest struct {
	Slot           uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	CommitteeIndex uint64 `protobuf:"varint,2,opt,name=committee_index,json=committeeIndex,proto3" json:"committee_index,omitempty"`
	// contains filtered or unexported fields
}

GetAttestation operation

func (*GetAttestationRequest) Descriptor deprecated 

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

Deprecated: Use GetAttestationRequest.ProtoReflect.Descriptor instead.

func (*GetAttestationRequest) GetCommitteeIndex 

func (x *GetAttestationRequest) GetCommitteeIndex() uint64

func (*GetAttestationRequest) GetSlot 

func (x *GetAttestationRequest) GetSlot() uint64

func (*GetAttestationRequest) ProtoMessage 

func (*GetAttestationRequest) ProtoMessage()

func (*GetAttestationRequest) ProtoReflect 

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

func (*GetAttestationRequest) Reset 

func (x *GetAttestationRequest) Reset()

func (*GetAttestationRequest) String 

func (x *GetAttestationRequest) String() string

type GetAttestationResponse 

type GetAttestationResponse struct {

	// Types that are assignable to Result:
	//	*GetAttestationResponse_Error
	//	*GetAttestationResponse_AttestationData
	Result isGetAttestationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*GetAttestationResponse) Descriptor deprecated 

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

Deprecated: Use GetAttestationResponse.ProtoReflect.Descriptor instead.

func (*GetAttestationResponse) GetAttestationData 

func (x *GetAttestationResponse) GetAttestationData() *v1alpha1.AttestationData

func (*GetAttestationResponse) GetError 

func (x *GetAttestationResponse) GetError() *status.Status

func (*GetAttestationResponse) GetResult 

func (m *GetAttestationResponse) GetResult() isGetAttestationResponse_Result

func (*GetAttestationResponse) ProtoMessage 

func (*GetAttestationResponse) ProtoMessage()

func (*GetAttestationResponse) ProtoReflect 

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

func (*GetAttestationResponse) Reset 

func (x *GetAttestationResponse) Reset()

func (*GetAttestationResponse) String 

func (x *GetAttestationResponse) String() string

type GetAttestationResponse_AttestationData 

type GetAttestationResponse_AttestationData struct {
	AttestationData *v1alpha1.AttestationData `protobuf:"bytes,2,opt,name=attestation_data,json=attestationData,proto3,oneof"`
}

type GetAttestationResponse_Error 

type GetAttestationResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type GetBlockRequest 

type GetBlockRequest struct {
	Slot         uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	RandaoReveal []byte `protobuf:"bytes,2,opt,name=randao_reveal,json=randaoReveal,proto3" json:"randao_reveal,omitempty"`
	Graffiti     []byte `protobuf:"bytes,3,opt,name=graffiti,proto3" json:"graffiti,omitempty"`
	// contains filtered or unexported fields
}

GetBlock operation

func (*GetBlockRequest) Descriptor deprecated 

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

Deprecated: Use GetBlockRequest.ProtoReflect.Descriptor instead.

func (*GetBlockRequest) GetGraffiti 

func (x *GetBlockRequest) GetGraffiti() []byte

func (*GetBlockRequest) GetRandaoReveal 

func (x *GetBlockRequest) GetRandaoReveal() []byte

func (*GetBlockRequest) GetSlot 

func (x *GetBlockRequest) GetSlot() uint64

func (*GetBlockRequest) ProtoMessage 

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) ProtoReflect 

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

func (*GetBlockRequest) Reset 

func (x *GetBlockRequest) Reset()

func (*GetBlockRequest) String 

func (x *GetBlockRequest) String() string

type GetBlockResponse 

type GetBlockResponse struct {

	// Types that are assignable to Result:
	//	*GetBlockResponse_Error
	//	*GetBlockResponse_BeaconBlock
	Result isGetBlockResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*GetBlockResponse) Descriptor deprecated 

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

Deprecated: Use GetBlockResponse.ProtoReflect.Descriptor instead.

func (*GetBlockResponse) GetBeaconBlock 

func (x *GetBlockResponse) GetBeaconBlock() *v1alpha1.BeaconBlock

func (*GetBlockResponse) GetError 

func (x *GetBlockResponse) GetError() *status.Status

func (*GetBlockResponse) GetResult 

func (m *GetBlockResponse) GetResult() isGetBlockResponse_Result

func (*GetBlockResponse) ProtoMessage 

func (*GetBlockResponse) ProtoMessage()

func (*GetBlockResponse) ProtoReflect 

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

func (*GetBlockResponse) Reset 

func (x *GetBlockResponse) Reset()

func (*GetBlockResponse) String 

func (x *GetBlockResponse) String() string

type GetBlockResponse_BeaconBlock 

type GetBlockResponse_BeaconBlock struct {
	BeaconBlock *v1alpha1.BeaconBlock `protobuf:"bytes,2,opt,name=beacon_block,json=beaconBlock,proto3,oneof"`
}

type GetBlockResponse_Error 

type GetBlockResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type ProposeAttestationRequest 

type ProposeAttestationRequest struct {
	AttestationData *v1alpha1.AttestationData `protobuf:"bytes,1,opt,name=attestation_data,json=attestationData,proto3" json:"attestation_data,omitempty"`
	AggregationBits []byte                    `protobuf:"bytes,2,opt,name=aggregation_bits,json=aggregationBits,proto3" json:"aggregation_bits,omitempty"`
	Signature       []byte                    `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

ProposeAttestation operation

func (*ProposeAttestationRequest) Descriptor deprecated 

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

Deprecated: Use ProposeAttestationRequest.ProtoReflect.Descriptor instead.

func (*ProposeAttestationRequest) GetAggregationBits 

func (x *ProposeAttestationRequest) GetAggregationBits() []byte

func (*ProposeAttestationRequest) GetAttestationData 

func (x *ProposeAttestationRequest) GetAttestationData() *v1alpha1.AttestationData

func (*ProposeAttestationRequest) GetSignature 

func (x *ProposeAttestationRequest) GetSignature() []byte

func (*ProposeAttestationRequest) ProtoMessage 

func (*ProposeAttestationRequest) ProtoMessage()

func (*ProposeAttestationRequest) ProtoReflect 

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

func (*ProposeAttestationRequest) Reset 

func (x *ProposeAttestationRequest) Reset()

func (*ProposeAttestationRequest) String 

func (x *ProposeAttestationRequest) String() string

type ProposeAttestationResponse 

type ProposeAttestationResponse struct {

	// Types that are assignable to Result:
	//	*ProposeAttestationResponse_Error
	//	*ProposeAttestationResponse_Empty
	Result isProposeAttestationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*ProposeAttestationResponse) Descriptor deprecated 

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

Deprecated: Use ProposeAttestationResponse.ProtoReflect.Descriptor instead.

func (*ProposeAttestationResponse) GetEmpty 

func (x *ProposeAttestationResponse) GetEmpty() *emptypb.Empty

func (*ProposeAttestationResponse) GetError 

func (x *ProposeAttestationResponse) GetError() *status.Status

func (*ProposeAttestationResponse) GetResult 

func (m *ProposeAttestationResponse) GetResult() isProposeAttestationResponse_Result

func (*ProposeAttestationResponse) ProtoMessage 

func (*ProposeAttestationResponse) ProtoMessage()

func (*ProposeAttestationResponse) ProtoReflect 

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

func (*ProposeAttestationResponse) Reset 

func (x *ProposeAttestationResponse) Reset()

func (*ProposeAttestationResponse) String 

func (x *ProposeAttestationResponse) String() string

type ProposeAttestationResponse_Empty 

type ProposeAttestationResponse_Empty struct {
	Empty *emptypb.Empty `protobuf:"bytes,2,opt,name=empty,proto3,oneof"`
}

type ProposeAttestationResponse_Error 

type ProposeAttestationResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type ProposeBlockRequest 

type ProposeBlockRequest struct {
	Signature   []byte                `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	BeaconBlock *v1alpha1.BeaconBlock `protobuf:"bytes,2,opt,name=beacon_block,json=beaconBlock,proto3" json:"beacon_block,omitempty"`
	// contains filtered or unexported fields
}

ProposeBlock operation

func (*ProposeBlockRequest) Descriptor deprecated 

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

Deprecated: Use ProposeBlockRequest.ProtoReflect.Descriptor instead.

func (*ProposeBlockRequest) GetBeaconBlock 

func (x *ProposeBlockRequest) GetBeaconBlock() *v1alpha1.BeaconBlock

func (*ProposeBlockRequest) GetSignature 

func (x *ProposeBlockRequest) GetSignature() []byte

func (*ProposeBlockRequest) ProtoMessage 

func (*ProposeBlockRequest) ProtoMessage()

func (*ProposeBlockRequest) ProtoReflect 

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

func (*ProposeBlockRequest) Reset 

func (x *ProposeBlockRequest) Reset()

func (*ProposeBlockRequest) String 

func (x *ProposeBlockRequest) String() string

type ProposeBlockResponse 

type ProposeBlockResponse struct {

	// Types that are assignable to Result:
	//	*ProposeBlockResponse_Error
	//	*ProposeBlockResponse_Empty
	Result isProposeBlockResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*ProposeBlockResponse) Descriptor deprecated 

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

Deprecated: Use ProposeBlockResponse.ProtoReflect.Descriptor instead.

func (*ProposeBlockResponse) GetEmpty 

func (x *ProposeBlockResponse) GetEmpty() *emptypb.Empty

func (*ProposeBlockResponse) GetError 

func (x *ProposeBlockResponse) GetError() *status.Status

func (*ProposeBlockResponse) GetResult 

func (m *ProposeBlockResponse) GetResult() isProposeBlockResponse_Result

func (*ProposeBlockResponse) ProtoMessage 

func (*ProposeBlockResponse) ProtoMessage()

func (*ProposeBlockResponse) ProtoReflect 

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

func (*ProposeBlockResponse) Reset 

func (x *ProposeBlockResponse) Reset()

func (*ProposeBlockResponse) String 

func (x *ProposeBlockResponse) String() string

type ProposeBlockResponse_Empty 

type ProposeBlockResponse_Empty struct {
	Empty *emptypb.Empty `protobuf:"bytes,2,opt,name=empty,proto3,oneof"`
}

type ProposeBlockResponse_Error 

type ProposeBlockResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type StreamDutiesRequest 

type StreamDutiesRequest struct {
	PublicKeys [][]byte `protobuf:"bytes,1,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"`
	// contains filtered or unexported fields
}

StreamDuties operation

func (*StreamDutiesRequest) Descriptor deprecated 

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

Deprecated: Use StreamDutiesRequest.ProtoReflect.Descriptor instead.

func (*StreamDutiesRequest) GetPublicKeys 

func (x *StreamDutiesRequest) GetPublicKeys() [][]byte

func (*StreamDutiesRequest) ProtoMessage 

func (*StreamDutiesRequest) ProtoMessage()

func (*StreamDutiesRequest) ProtoReflect 

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

func (*StreamDutiesRequest) Reset 

func (x *StreamDutiesRequest) Reset()

func (*StreamDutiesRequest) String 

func (x *StreamDutiesRequest) String() string

type StreamDutiesResponse 

type StreamDutiesResponse struct {

	// Types that are assignable to Result:
	//	*StreamDutiesResponse_Error
	//	*StreamDutiesResponse_Duties
	Result isStreamDutiesResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*StreamDutiesResponse) Descriptor deprecated 

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

Deprecated: Use StreamDutiesResponse.ProtoReflect.Descriptor instead.

func (*StreamDutiesResponse) GetDuties 

func (x *StreamDutiesResponse) GetDuties() *v1alpha1.DutiesResponse

func (*StreamDutiesResponse) GetError 

func (x *StreamDutiesResponse) GetError() *status.Status

func (*StreamDutiesResponse) GetResult 

func (m *StreamDutiesResponse) GetResult() isStreamDutiesResponse_Result

func (*StreamDutiesResponse) ProtoMessage 

func (*StreamDutiesResponse) ProtoMessage()

func (*StreamDutiesResponse) ProtoReflect 

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

func (*StreamDutiesResponse) Reset 

func (x *StreamDutiesResponse) Reset()

func (*StreamDutiesResponse) String 

func (x *StreamDutiesResponse) String() string

type StreamDutiesResponse_Duties 

type StreamDutiesResponse_Duties struct {
	Duties *v1alpha1.DutiesResponse `protobuf:"bytes,2,opt,name=duties,proto3,oneof"`
}

type StreamDutiesResponse_Error 

type StreamDutiesResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type SubmitSignedAggregateSelectionProofRequest 

type SubmitSignedAggregateSelectionProofRequest struct {
	Signature []byte                                 `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Data      *v1alpha1.AggregateAttestationAndProof `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

GetAggregateSelectionProof operation

func (*SubmitSignedAggregateSelectionProofRequest) Descriptor deprecated 

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

Deprecated: Use SubmitSignedAggregateSelectionProofRequest.ProtoReflect.Descriptor instead.

func (*SubmitSignedAggregateSelectionProofRequest) GetData 

func (x *SubmitSignedAggregateSelectionProofRequest) GetData() *v1alpha1.AggregateAttestationAndProof

func (*SubmitSignedAggregateSelectionProofRequest) GetSignature 

func (x *SubmitSignedAggregateSelectionProofRequest) GetSignature() []byte

func (*SubmitSignedAggregateSelectionProofRequest) ProtoMessage 

func (*SubmitSignedAggregateSelectionProofRequest) ProtoMessage()

func (*SubmitSignedAggregateSelectionProofRequest) ProtoReflect 

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

func (*SubmitSignedAggregateSelectionProofRequest) Reset 

func (x *SubmitSignedAggregateSelectionProofRequest) Reset()

func (*SubmitSignedAggregateSelectionProofRequest) String 

func (x *SubmitSignedAggregateSelectionProofRequest) String() string

type SubmitSignedAggregateSelectionProofResponse 

type SubmitSignedAggregateSelectionProofResponse struct {

	// Types that are assignable to Result:
	//	*SubmitSignedAggregateSelectionProofResponse_Error
	//	*SubmitSignedAggregateSelectionProofResponse_Empty
	Result isSubmitSignedAggregateSelectionProofResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*SubmitSignedAggregateSelectionProofResponse) Descriptor deprecated 

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

Deprecated: Use SubmitSignedAggregateSelectionProofResponse.ProtoReflect.Descriptor instead.

func (*SubmitSignedAggregateSelectionProofResponse) GetEmpty 

func (x *SubmitSignedAggregateSelectionProofResponse) GetEmpty() *emptypb.Empty

func (*SubmitSignedAggregateSelectionProofResponse) GetError 

func (x *SubmitSignedAggregateSelectionProofResponse) GetError() *status.Status

func (*SubmitSignedAggregateSelectionProofResponse) GetResult 

func (m *SubmitSignedAggregateSelectionProofResponse) GetResult() isSubmitSignedAggregateSelectionProofResponse_Result

func (*SubmitSignedAggregateSelectionProofResponse) ProtoMessage 

func (*SubmitSignedAggregateSelectionProofResponse) ProtoMessage()

func (*SubmitSignedAggregateSelectionProofResponse) ProtoReflect 

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

func (*SubmitSignedAggregateSelectionProofResponse) Reset 

func (x *SubmitSignedAggregateSelectionProofResponse) Reset()

func (*SubmitSignedAggregateSelectionProofResponse) String 

func (x *SubmitSignedAggregateSelectionProofResponse) String() string

type SubmitSignedAggregateSelectionProofResponse_Empty 

type SubmitSignedAggregateSelectionProofResponse_Empty struct {
	Empty *emptypb.Empty `protobuf:"bytes,2,opt,name=empty,proto3,oneof"`
}

type SubmitSignedAggregateSelectionProofResponse_Error 

type SubmitSignedAggregateSelectionProofResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type SubnetSubscription 

type SubnetSubscription struct {
	ValidatorIndex   uint64 `protobuf:"varint,1,opt,name=validator_index,json=validatorIndex,proto3" json:"validator_index,omitempty"`
	CommitteeIndex   uint64 `protobuf:"varint,2,opt,name=committee_index,json=committeeIndex,proto3" json:"committee_index,omitempty"`
	CommitteesAtSlot uint64 `protobuf:"varint,3,opt,name=committees_at_slot,json=committeesAtSlot,proto3" json:"committees_at_slot,omitempty"`
	Slot             uint64 `protobuf:"varint,4,opt,name=slot,proto3" json:"slot,omitempty"`
	IsAggregator     bool   `protobuf:"varint,5,opt,name=is_aggregator,json=isAggregator,proto3" json:"is_aggregator,omitempty"`
	// contains filtered or unexported fields
}

func (*SubnetSubscription) Descriptor deprecated 

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

Deprecated: Use SubnetSubscription.ProtoReflect.Descriptor instead.

func (*SubnetSubscription) GetCommitteeIndex 

func (x *SubnetSubscription) GetCommitteeIndex() uint64

func (*SubnetSubscription) GetCommitteesAtSlot 

func (x *SubnetSubscription) GetCommitteesAtSlot() uint64

func (*SubnetSubscription) GetIsAggregator 

func (x *SubnetSubscription) GetIsAggregator() bool

func (*SubnetSubscription) GetSlot 

func (x *SubnetSubscription) GetSlot() uint64

func (*SubnetSubscription) GetValidatorIndex 

func (x *SubnetSubscription) GetValidatorIndex() uint64

func (*SubnetSubscription) ProtoMessage 

func (*SubnetSubscription) ProtoMessage()

func (*SubnetSubscription) ProtoReflect 

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

func (*SubnetSubscription) Reset 

func (x *SubnetSubscription) Reset()

func (*SubnetSubscription) String 

func (x *SubnetSubscription) String() string

type SubnetsSubscribeRequest 

type SubnetsSubscribeRequest struct {
	Subscriptions []*SubnetSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

SubnetsSubscribe operation

func (*SubnetsSubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubnetsSubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubnetsSubscribeRequest) GetSubscriptions 

func (x *SubnetsSubscribeRequest) GetSubscriptions() []*SubnetSubscription

func (*SubnetsSubscribeRequest) ProtoMessage 

func (*SubnetsSubscribeRequest) ProtoMessage()

func (*SubnetsSubscribeRequest) ProtoReflect 

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

func (*SubnetsSubscribeRequest) Reset 

func (x *SubnetsSubscribeRequest) Reset()

func (*SubnetsSubscribeRequest) String 

func (x *SubnetsSubscribeRequest) String() string

type SubnetsSubscribeResponse 

type SubnetsSubscribeResponse struct {

	// Types that are assignable to Result:
	//	*SubnetsSubscribeResponse_Error
	//	*SubnetsSubscribeResponse_Empty
	Result isSubnetsSubscribeResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*SubnetsSubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubnetsSubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubnetsSubscribeResponse) GetEmpty 

func (x *SubnetsSubscribeResponse) GetEmpty() *emptypb.Empty

func (*SubnetsSubscribeResponse) GetError 

func (x *SubnetsSubscribeResponse) GetError() *status.Status

func (*SubnetsSubscribeResponse) GetResult 

func (m *SubnetsSubscribeResponse) GetResult() isSubnetsSubscribeResponse_Result

func (*SubnetsSubscribeResponse) ProtoMessage 

func (*SubnetsSubscribeResponse) ProtoMessage()

func (*SubnetsSubscribeResponse) ProtoReflect 

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

func (*SubnetsSubscribeResponse) Reset 

func (x *SubnetsSubscribeResponse) Reset()

func (*SubnetsSubscribeResponse) String 

func (x *SubnetsSubscribeResponse) String() string

type SubnetsSubscribeResponse_Empty 

type SubnetsSubscribeResponse_Empty struct {
	Empty *emptypb.Empty `protobuf:"bytes,2,opt,name=empty,proto3,oneof"`
}

type SubnetsSubscribeResponse_Error 

type SubnetsSubscribeResponse_Error struct {
	Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type UnimplementedBeaconSpotServiceServer 

type UnimplementedBeaconSpotServiceServer struct {
}

UnimplementedBeaconSpotServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBeaconSpotServiceServer) DomainData 

func (UnimplementedBeaconSpotServiceServer) DomainData(context.Context, *DomainDataRequest) (*DomainDataResponse, error)

func (UnimplementedBeaconSpotServiceServer) GetAggregateSelectionProof 

func (UnimplementedBeaconSpotServiceServer) GetAggregateSelectionProof(context.Context, *GetAggregateSelectionProofRequest) (*GetAggregateSelectionProofResponse, error)

func (UnimplementedBeaconSpotServiceServer) GetAttestation 

func (UnimplementedBeaconSpotServiceServer) GetAttestation(context.Context, *GetAttestationRequest) (*GetAttestationResponse, error)

func (UnimplementedBeaconSpotServiceServer) GetBlock 

func (UnimplementedBeaconSpotServiceServer) GetBlock(context.Context, *GetBlockRequest) (*GetBlockResponse, error)

func (UnimplementedBeaconSpotServiceServer) Health 

func (UnimplementedBeaconSpotServiceServer) Health(context.Context, *emptypb.Empty) (*health.HealthResponse, error)

func (UnimplementedBeaconSpotServiceServer) Ping 

func (UnimplementedBeaconSpotServiceServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedBeaconSpotServiceServer) ProposeAttestation 

func (UnimplementedBeaconSpotServiceServer) ProposeAttestation(context.Context, *ProposeAttestationRequest) (*ProposeAttestationResponse, error)

func (UnimplementedBeaconSpotServiceServer) ProposeBlock 

func (UnimplementedBeaconSpotServiceServer) ProposeBlock(context.Context, *ProposeBlockRequest) (*ProposeBlockResponse, error)

func (UnimplementedBeaconSpotServiceServer) StreamDuties 

func (UnimplementedBeaconSpotServiceServer) StreamDuties(*StreamDutiesRequest, BeaconSpotService_StreamDutiesServer) error

func (UnimplementedBeaconSpotServiceServer) SubmitSignedAggregateSelectionProof 

func (UnimplementedBeaconSpotServiceServer) SubmitSignedAggregateSelectionProof(context.Context, *SubmitSignedAggregateSelectionProofRequest) (*SubmitSignedAggregateSelectionProofResponse, error)

func (UnimplementedBeaconSpotServiceServer) SubnetsSubscribe 

func (UnimplementedBeaconSpotServiceServer) SubnetsSubscribe(context.Context, *SubnetsSubscribeRequest) (*SubnetsSubscribeResponse, error)

type UnsafeBeaconSpotServiceServer 

type UnsafeBeaconSpotServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBeaconSpotServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BeaconSpotServiceServer will result in compilation errors.

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.