From d48e0925d003a796fe458d30817e0f295641de09 Mon Sep 17 00:00:00 2001 From: Nishant Das Date: Wed, 12 Jun 2019 23:11:04 +0800 Subject: [PATCH] Add gRPC Gateway Folder (#2793) * add gateway proto files * lint --- beacon-chain/internal/beacon_service_mock.go | 3 +- .../internal/validator_service_mock.go | 3 +- beacon-chain/main.go | 2 +- proto/beacon/p2p/v1/messages.pb.go | 5 +- proto/beacon/p2p/v1/types.pb.go | 5 +- proto/beacon/rpc/v1/services.pb.go | 5 +- proto/beacon/rpc/v1_gateway/BUILD.bazel | 1 + proto/beacon/rpc/v1_gateway/services.pb.go | 2554 +++++++++++++++++ proto/beacon/rpc/v1_gateway/services.pb.gw.go | 108 + proto/sharding/p2p/v1/messages.pb.go | 3 +- validator/internal/attester_service_mock.go | 3 +- validator/internal/beacon_service_mock.go | 3 +- validator/internal/proposer_service_mock.go | 3 +- validator/internal/validator_service_mock.go | 3 +- 14 files changed, 2687 insertions(+), 14 deletions(-) create mode 100644 proto/beacon/rpc/v1_gateway/BUILD.bazel create mode 100755 proto/beacon/rpc/v1_gateway/services.pb.go create mode 100755 proto/beacon/rpc/v1_gateway/services.pb.gw.go diff --git a/beacon-chain/internal/beacon_service_mock.go b/beacon-chain/internal/beacon_service_mock.go index e5f72ba0d3..71de260d67 100644 --- a/beacon-chain/internal/beacon_service_mock.go +++ b/beacon-chain/internal/beacon_service_mock.go @@ -6,12 +6,13 @@ package internal import ( context "context" + reflect "reflect" + types "github.com/gogo/protobuf/types" gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" v10 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" metadata "google.golang.org/grpc/metadata" - reflect "reflect" ) // MockBeaconServiceServer is a mock of BeaconServiceServer interface diff --git a/beacon-chain/internal/validator_service_mock.go b/beacon-chain/internal/validator_service_mock.go index a479bf598f..b14e1504ae 100644 --- a/beacon-chain/internal/validator_service_mock.go +++ b/beacon-chain/internal/validator_service_mock.go @@ -6,10 +6,11 @@ package internal import ( context "context" + reflect "reflect" + gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" metadata "google.golang.org/grpc/metadata" - reflect "reflect" ) // MockValidatorServiceServer is a mock of ValidatorServiceServer interface diff --git a/beacon-chain/main.go b/beacon-chain/main.go index 1080513c2e..82c316ef29 100644 --- a/beacon-chain/main.go +++ b/beacon-chain/main.go @@ -9,7 +9,7 @@ import ( joonix "github.com/joonix/log" "github.com/sirupsen/logrus" "github.com/urfave/cli" - "github.com/x-cray/logrus-prefixed-formatter" + prefixed "github.com/x-cray/logrus-prefixed-formatter" "github.com/prysmaticlabs/prysm/beacon-chain/node" "github.com/prysmaticlabs/prysm/beacon-chain/utils" diff --git a/proto/beacon/p2p/v1/messages.pb.go b/proto/beacon/p2p/v1/messages.pb.go index a4bd0865cf..4594ce2994 100755 --- a/proto/beacon/p2p/v1/messages.pb.go +++ b/proto/beacon/p2p/v1/messages.pb.go @@ -5,10 +5,11 @@ package ethereum_beacon_p2p_v1 import ( fmt "fmt" - proto "github.com/gogo/protobuf/proto" - types "github.com/gogo/protobuf/types" io "io" math "math" + + proto "github.com/gogo/protobuf/proto" + types "github.com/gogo/protobuf/types" ) // Reference imports to suppress errors if they are not otherwise used. diff --git a/proto/beacon/p2p/v1/types.pb.go b/proto/beacon/p2p/v1/types.pb.go index 516133f5c8..0995a83a49 100755 --- a/proto/beacon/p2p/v1/types.pb.go +++ b/proto/beacon/p2p/v1/types.pb.go @@ -5,10 +5,11 @@ package ethereum_beacon_p2p_v1 import ( fmt "fmt" - proto "github.com/gogo/protobuf/proto" - _ "github.com/prysmaticlabs/prysm/proto/common" io "io" math "math" + + proto "github.com/gogo/protobuf/proto" + _ "github.com/prysmaticlabs/prysm/proto/common" ) // Reference imports to suppress errors if they are not otherwise used. diff --git a/proto/beacon/rpc/v1/services.pb.go b/proto/beacon/rpc/v1/services.pb.go index bd62baff0a..9817099e19 100755 --- a/proto/beacon/rpc/v1/services.pb.go +++ b/proto/beacon/rpc/v1/services.pb.go @@ -7,14 +7,15 @@ import ( context "context" encoding_binary "encoding/binary" fmt "fmt" + io "io" + math "math" + proto "github.com/gogo/protobuf/proto" types "github.com/gogo/protobuf/types" _ "github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger/options" v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" _ "google.golang.org/genproto/googleapis/api/annotations" grpc "google.golang.org/grpc" - io "io" - math "math" ) // Reference imports to suppress errors if they are not otherwise used. diff --git a/proto/beacon/rpc/v1_gateway/BUILD.bazel b/proto/beacon/rpc/v1_gateway/BUILD.bazel new file mode 100644 index 0000000000..9968c4af55 --- /dev/null +++ b/proto/beacon/rpc/v1_gateway/BUILD.bazel @@ -0,0 +1 @@ +# gazelle:ignore diff --git a/proto/beacon/rpc/v1_gateway/services.pb.go b/proto/beacon/rpc/v1_gateway/services.pb.go new file mode 100755 index 0000000000..6d8479b0e6 --- /dev/null +++ b/proto/beacon/rpc/v1_gateway/services.pb.go @@ -0,0 +1,2554 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: proto/beacon/rpc/v1/services.proto + +package ethereum_beacon_rpc_v1 + +import ( + context "context" + fmt "fmt" + math "math" + + proto "github.com/golang/protobuf/proto" + empty "github.com/golang/protobuf/ptypes/empty" + timestamp "github.com/golang/protobuf/ptypes/timestamp" + _ "github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger/options" + v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" + _ "google.golang.org/genproto/googleapis/api/annotations" + grpc "google.golang.org/grpc" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +type ValidatorRole int32 + +const ( + ValidatorRole_UNKNOWN ValidatorRole = 0 + ValidatorRole_ATTESTER ValidatorRole = 1 + ValidatorRole_PROPOSER ValidatorRole = 2 +) + +var ValidatorRole_name = map[int32]string{ + 0: "UNKNOWN", + 1: "ATTESTER", + 2: "PROPOSER", +} + +var ValidatorRole_value = map[string]int32{ + "UNKNOWN": 0, + "ATTESTER": 1, + "PROPOSER": 2, +} + +func (x ValidatorRole) String() string { + return proto.EnumName(ValidatorRole_name, int32(x)) +} + +func (ValidatorRole) EnumDescriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{0} +} + +type ValidatorStatus int32 + +const ( + ValidatorStatus_UNKNOWN_STATUS ValidatorStatus = 0 + ValidatorStatus_PENDING_ACTIVE ValidatorStatus = 1 + ValidatorStatus_ACTIVE ValidatorStatus = 2 + ValidatorStatus_INITIATED_EXIT ValidatorStatus = 3 + ValidatorStatus_WITHDRAWABLE ValidatorStatus = 4 + ValidatorStatus_EXITED ValidatorStatus = 5 + ValidatorStatus_EXITED_SLASHED ValidatorStatus = 6 +) + +var ValidatorStatus_name = map[int32]string{ + 0: "UNKNOWN_STATUS", + 1: "PENDING_ACTIVE", + 2: "ACTIVE", + 3: "INITIATED_EXIT", + 4: "WITHDRAWABLE", + 5: "EXITED", + 6: "EXITED_SLASHED", +} + +var ValidatorStatus_value = map[string]int32{ + "UNKNOWN_STATUS": 0, + "PENDING_ACTIVE": 1, + "ACTIVE": 2, + "INITIATED_EXIT": 3, + "WITHDRAWABLE": 4, + "EXITED": 5, + "EXITED_SLASHED": 6, +} + +func (x ValidatorStatus) String() string { + return proto.EnumName(ValidatorStatus_name, int32(x)) +} + +func (ValidatorStatus) EnumDescriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{1} +} + +type ValidatorPerformanceRequest struct { + Slot uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"` + PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorPerformanceRequest) Reset() { *m = ValidatorPerformanceRequest{} } +func (m *ValidatorPerformanceRequest) String() string { return proto.CompactTextString(m) } +func (*ValidatorPerformanceRequest) ProtoMessage() {} +func (*ValidatorPerformanceRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{0} +} + +func (m *ValidatorPerformanceRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorPerformanceRequest.Unmarshal(m, b) +} +func (m *ValidatorPerformanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorPerformanceRequest.Marshal(b, m, deterministic) +} +func (m *ValidatorPerformanceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorPerformanceRequest.Merge(m, src) +} +func (m *ValidatorPerformanceRequest) XXX_Size() int { + return xxx_messageInfo_ValidatorPerformanceRequest.Size(m) +} +func (m *ValidatorPerformanceRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorPerformanceRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorPerformanceRequest proto.InternalMessageInfo + +func (m *ValidatorPerformanceRequest) GetSlot() uint64 { + if m != nil { + return m.Slot + } + return 0 +} + +func (m *ValidatorPerformanceRequest) GetPublicKey() []byte { + if m != nil { + return m.PublicKey + } + return nil +} + +type ValidatorPerformanceResponse struct { + Balance uint64 `protobuf:"varint,1,opt,name=balance,proto3" json:"balance,omitempty"` + TotalValidators uint64 `protobuf:"varint,2,opt,name=total_validators,json=totalValidators,proto3" json:"total_validators,omitempty"` + TotalActiveValidators uint64 `protobuf:"varint,3,opt,name=total_active_validators,json=totalActiveValidators,proto3" json:"total_active_validators,omitempty"` + AverageActiveValidatorBalance float32 `protobuf:"fixed32,4,opt,name=average_active_validator_balance,json=averageActiveValidatorBalance,proto3" json:"average_active_validator_balance,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorPerformanceResponse) Reset() { *m = ValidatorPerformanceResponse{} } +func (m *ValidatorPerformanceResponse) String() string { return proto.CompactTextString(m) } +func (*ValidatorPerformanceResponse) ProtoMessage() {} +func (*ValidatorPerformanceResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{1} +} + +func (m *ValidatorPerformanceResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorPerformanceResponse.Unmarshal(m, b) +} +func (m *ValidatorPerformanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorPerformanceResponse.Marshal(b, m, deterministic) +} +func (m *ValidatorPerformanceResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorPerformanceResponse.Merge(m, src) +} +func (m *ValidatorPerformanceResponse) XXX_Size() int { + return xxx_messageInfo_ValidatorPerformanceResponse.Size(m) +} +func (m *ValidatorPerformanceResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorPerformanceResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorPerformanceResponse proto.InternalMessageInfo + +func (m *ValidatorPerformanceResponse) GetBalance() uint64 { + if m != nil { + return m.Balance + } + return 0 +} + +func (m *ValidatorPerformanceResponse) GetTotalValidators() uint64 { + if m != nil { + return m.TotalValidators + } + return 0 +} + +func (m *ValidatorPerformanceResponse) GetTotalActiveValidators() uint64 { + if m != nil { + return m.TotalActiveValidators + } + return 0 +} + +func (m *ValidatorPerformanceResponse) GetAverageActiveValidatorBalance() float32 { + if m != nil { + return m.AverageActiveValidatorBalance + } + return 0 +} + +type ValidatorActivationRequest struct { + PublicKeys [][]byte `protobuf:"bytes,1,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorActivationRequest) Reset() { *m = ValidatorActivationRequest{} } +func (m *ValidatorActivationRequest) String() string { return proto.CompactTextString(m) } +func (*ValidatorActivationRequest) ProtoMessage() {} +func (*ValidatorActivationRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{2} +} + +func (m *ValidatorActivationRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorActivationRequest.Unmarshal(m, b) +} +func (m *ValidatorActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorActivationRequest.Marshal(b, m, deterministic) +} +func (m *ValidatorActivationRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorActivationRequest.Merge(m, src) +} +func (m *ValidatorActivationRequest) XXX_Size() int { + return xxx_messageInfo_ValidatorActivationRequest.Size(m) +} +func (m *ValidatorActivationRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorActivationRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorActivationRequest proto.InternalMessageInfo + +func (m *ValidatorActivationRequest) GetPublicKeys() [][]byte { + if m != nil { + return m.PublicKeys + } + return nil +} + +type ValidatorActivationResponse struct { + ActivatedPublicKeys [][]byte `protobuf:"bytes,1,rep,name=activated_public_keys,json=activatedPublicKeys,proto3" json:"activated_public_keys,omitempty"` // Deprecated: Do not use. + Statuses []*ValidatorActivationResponse_Status `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorActivationResponse) Reset() { *m = ValidatorActivationResponse{} } +func (m *ValidatorActivationResponse) String() string { return proto.CompactTextString(m) } +func (*ValidatorActivationResponse) ProtoMessage() {} +func (*ValidatorActivationResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{3} +} + +func (m *ValidatorActivationResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorActivationResponse.Unmarshal(m, b) +} +func (m *ValidatorActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorActivationResponse.Marshal(b, m, deterministic) +} +func (m *ValidatorActivationResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorActivationResponse.Merge(m, src) +} +func (m *ValidatorActivationResponse) XXX_Size() int { + return xxx_messageInfo_ValidatorActivationResponse.Size(m) +} +func (m *ValidatorActivationResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorActivationResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorActivationResponse proto.InternalMessageInfo + +// Deprecated: Do not use. +func (m *ValidatorActivationResponse) GetActivatedPublicKeys() [][]byte { + if m != nil { + return m.ActivatedPublicKeys + } + return nil +} + +func (m *ValidatorActivationResponse) GetStatuses() []*ValidatorActivationResponse_Status { + if m != nil { + return m.Statuses + } + return nil +} + +type ValidatorActivationResponse_Status struct { + PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` + Status *ValidatorStatusResponse `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorActivationResponse_Status) Reset() { *m = ValidatorActivationResponse_Status{} } +func (m *ValidatorActivationResponse_Status) String() string { return proto.CompactTextString(m) } +func (*ValidatorActivationResponse_Status) ProtoMessage() {} +func (*ValidatorActivationResponse_Status) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{3, 0} +} + +func (m *ValidatorActivationResponse_Status) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorActivationResponse_Status.Unmarshal(m, b) +} +func (m *ValidatorActivationResponse_Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorActivationResponse_Status.Marshal(b, m, deterministic) +} +func (m *ValidatorActivationResponse_Status) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorActivationResponse_Status.Merge(m, src) +} +func (m *ValidatorActivationResponse_Status) XXX_Size() int { + return xxx_messageInfo_ValidatorActivationResponse_Status.Size(m) +} +func (m *ValidatorActivationResponse_Status) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorActivationResponse_Status.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorActivationResponse_Status proto.InternalMessageInfo + +func (m *ValidatorActivationResponse_Status) GetPublicKey() []byte { + if m != nil { + return m.PublicKey + } + return nil +} + +func (m *ValidatorActivationResponse_Status) GetStatus() *ValidatorStatusResponse { + if m != nil { + return m.Status + } + return nil +} + +type ExitedValidatorsRequest struct { + PublicKeys [][]byte `protobuf:"bytes,1,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ExitedValidatorsRequest) Reset() { *m = ExitedValidatorsRequest{} } +func (m *ExitedValidatorsRequest) String() string { return proto.CompactTextString(m) } +func (*ExitedValidatorsRequest) ProtoMessage() {} +func (*ExitedValidatorsRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{4} +} + +func (m *ExitedValidatorsRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ExitedValidatorsRequest.Unmarshal(m, b) +} +func (m *ExitedValidatorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ExitedValidatorsRequest.Marshal(b, m, deterministic) +} +func (m *ExitedValidatorsRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ExitedValidatorsRequest.Merge(m, src) +} +func (m *ExitedValidatorsRequest) XXX_Size() int { + return xxx_messageInfo_ExitedValidatorsRequest.Size(m) +} +func (m *ExitedValidatorsRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ExitedValidatorsRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ExitedValidatorsRequest proto.InternalMessageInfo + +func (m *ExitedValidatorsRequest) GetPublicKeys() [][]byte { + if m != nil { + return m.PublicKeys + } + return nil +} + +type ExitedValidatorsResponse struct { + PublicKeys [][]byte `protobuf:"bytes,1,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ExitedValidatorsResponse) Reset() { *m = ExitedValidatorsResponse{} } +func (m *ExitedValidatorsResponse) String() string { return proto.CompactTextString(m) } +func (*ExitedValidatorsResponse) ProtoMessage() {} +func (*ExitedValidatorsResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{5} +} + +func (m *ExitedValidatorsResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ExitedValidatorsResponse.Unmarshal(m, b) +} +func (m *ExitedValidatorsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ExitedValidatorsResponse.Marshal(b, m, deterministic) +} +func (m *ExitedValidatorsResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ExitedValidatorsResponse.Merge(m, src) +} +func (m *ExitedValidatorsResponse) XXX_Size() int { + return xxx_messageInfo_ExitedValidatorsResponse.Size(m) +} +func (m *ExitedValidatorsResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ExitedValidatorsResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ExitedValidatorsResponse proto.InternalMessageInfo + +func (m *ExitedValidatorsResponse) GetPublicKeys() [][]byte { + if m != nil { + return m.PublicKeys + } + return nil +} + +type AttestationDataRequest struct { + Shard uint64 `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"` + Slot uint64 `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *AttestationDataRequest) Reset() { *m = AttestationDataRequest{} } +func (m *AttestationDataRequest) String() string { return proto.CompactTextString(m) } +func (*AttestationDataRequest) ProtoMessage() {} +func (*AttestationDataRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{6} +} + +func (m *AttestationDataRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_AttestationDataRequest.Unmarshal(m, b) +} +func (m *AttestationDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_AttestationDataRequest.Marshal(b, m, deterministic) +} +func (m *AttestationDataRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_AttestationDataRequest.Merge(m, src) +} +func (m *AttestationDataRequest) XXX_Size() int { + return xxx_messageInfo_AttestationDataRequest.Size(m) +} +func (m *AttestationDataRequest) XXX_DiscardUnknown() { + xxx_messageInfo_AttestationDataRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_AttestationDataRequest proto.InternalMessageInfo + +func (m *AttestationDataRequest) GetShard() uint64 { + if m != nil { + return m.Shard + } + return 0 +} + +func (m *AttestationDataRequest) GetSlot() uint64 { + if m != nil { + return m.Slot + } + return 0 +} + +type AttestationDataResponse struct { + BeaconBlockRootHash32 []byte `protobuf:"bytes,1,opt,name=beacon_block_root_hash32,json=beaconBlockRootHash32,proto3" json:"beacon_block_root_hash32,omitempty"` + EpochBoundaryRootHash32 []byte `protobuf:"bytes,2,opt,name=epoch_boundary_root_hash32,json=epochBoundaryRootHash32,proto3" json:"epoch_boundary_root_hash32,omitempty"` + JustifiedEpoch uint64 `protobuf:"varint,3,opt,name=justified_epoch,json=justifiedEpoch,proto3" json:"justified_epoch,omitempty"` + JustifiedBlockRootHash32 []byte `protobuf:"bytes,4,opt,name=justified_block_root_hash32,json=justifiedBlockRootHash32,proto3" json:"justified_block_root_hash32,omitempty"` + LatestCrosslink *v1.Crosslink `protobuf:"bytes,5,opt,name=latest_crosslink,json=latestCrosslink,proto3" json:"latest_crosslink,omitempty"` + HeadSlot uint64 `protobuf:"varint,6,opt,name=head_slot,json=headSlot,proto3" json:"head_slot,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *AttestationDataResponse) Reset() { *m = AttestationDataResponse{} } +func (m *AttestationDataResponse) String() string { return proto.CompactTextString(m) } +func (*AttestationDataResponse) ProtoMessage() {} +func (*AttestationDataResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{7} +} + +func (m *AttestationDataResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_AttestationDataResponse.Unmarshal(m, b) +} +func (m *AttestationDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_AttestationDataResponse.Marshal(b, m, deterministic) +} +func (m *AttestationDataResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_AttestationDataResponse.Merge(m, src) +} +func (m *AttestationDataResponse) XXX_Size() int { + return xxx_messageInfo_AttestationDataResponse.Size(m) +} +func (m *AttestationDataResponse) XXX_DiscardUnknown() { + xxx_messageInfo_AttestationDataResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_AttestationDataResponse proto.InternalMessageInfo + +func (m *AttestationDataResponse) GetBeaconBlockRootHash32() []byte { + if m != nil { + return m.BeaconBlockRootHash32 + } + return nil +} + +func (m *AttestationDataResponse) GetEpochBoundaryRootHash32() []byte { + if m != nil { + return m.EpochBoundaryRootHash32 + } + return nil +} + +func (m *AttestationDataResponse) GetJustifiedEpoch() uint64 { + if m != nil { + return m.JustifiedEpoch + } + return 0 +} + +func (m *AttestationDataResponse) GetJustifiedBlockRootHash32() []byte { + if m != nil { + return m.JustifiedBlockRootHash32 + } + return nil +} + +func (m *AttestationDataResponse) GetLatestCrosslink() *v1.Crosslink { + if m != nil { + return m.LatestCrosslink + } + return nil +} + +func (m *AttestationDataResponse) GetHeadSlot() uint64 { + if m != nil { + return m.HeadSlot + } + return 0 +} + +type PendingAttestationsRequest struct { + FilterReadyForInclusion bool `protobuf:"varint,1,opt,name=filter_ready_for_inclusion,json=filterReadyForInclusion,proto3" json:"filter_ready_for_inclusion,omitempty"` + ProposalBlockSlot uint64 `protobuf:"varint,2,opt,name=proposal_block_slot,json=proposalBlockSlot,proto3" json:"proposal_block_slot,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *PendingAttestationsRequest) Reset() { *m = PendingAttestationsRequest{} } +func (m *PendingAttestationsRequest) String() string { return proto.CompactTextString(m) } +func (*PendingAttestationsRequest) ProtoMessage() {} +func (*PendingAttestationsRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{8} +} + +func (m *PendingAttestationsRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_PendingAttestationsRequest.Unmarshal(m, b) +} +func (m *PendingAttestationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_PendingAttestationsRequest.Marshal(b, m, deterministic) +} +func (m *PendingAttestationsRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_PendingAttestationsRequest.Merge(m, src) +} +func (m *PendingAttestationsRequest) XXX_Size() int { + return xxx_messageInfo_PendingAttestationsRequest.Size(m) +} +func (m *PendingAttestationsRequest) XXX_DiscardUnknown() { + xxx_messageInfo_PendingAttestationsRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_PendingAttestationsRequest proto.InternalMessageInfo + +func (m *PendingAttestationsRequest) GetFilterReadyForInclusion() bool { + if m != nil { + return m.FilterReadyForInclusion + } + return false +} + +func (m *PendingAttestationsRequest) GetProposalBlockSlot() uint64 { + if m != nil { + return m.ProposalBlockSlot + } + return 0 +} + +type PendingAttestationsResponse struct { + PendingAttestations []*v1.Attestation `protobuf:"bytes,1,rep,name=pending_attestations,json=pendingAttestations,proto3" json:"pending_attestations,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *PendingAttestationsResponse) Reset() { *m = PendingAttestationsResponse{} } +func (m *PendingAttestationsResponse) String() string { return proto.CompactTextString(m) } +func (*PendingAttestationsResponse) ProtoMessage() {} +func (*PendingAttestationsResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{9} +} + +func (m *PendingAttestationsResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_PendingAttestationsResponse.Unmarshal(m, b) +} +func (m *PendingAttestationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_PendingAttestationsResponse.Marshal(b, m, deterministic) +} +func (m *PendingAttestationsResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_PendingAttestationsResponse.Merge(m, src) +} +func (m *PendingAttestationsResponse) XXX_Size() int { + return xxx_messageInfo_PendingAttestationsResponse.Size(m) +} +func (m *PendingAttestationsResponse) XXX_DiscardUnknown() { + xxx_messageInfo_PendingAttestationsResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_PendingAttestationsResponse proto.InternalMessageInfo + +func (m *PendingAttestationsResponse) GetPendingAttestations() []*v1.Attestation { + if m != nil { + return m.PendingAttestations + } + return nil +} + +type ChainStartResponse struct { + Started bool `protobuf:"varint,1,opt,name=started,proto3" json:"started,omitempty"` + GenesisTime uint64 `protobuf:"varint,2,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ChainStartResponse) Reset() { *m = ChainStartResponse{} } +func (m *ChainStartResponse) String() string { return proto.CompactTextString(m) } +func (*ChainStartResponse) ProtoMessage() {} +func (*ChainStartResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{10} +} + +func (m *ChainStartResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ChainStartResponse.Unmarshal(m, b) +} +func (m *ChainStartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ChainStartResponse.Marshal(b, m, deterministic) +} +func (m *ChainStartResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ChainStartResponse.Merge(m, src) +} +func (m *ChainStartResponse) XXX_Size() int { + return xxx_messageInfo_ChainStartResponse.Size(m) +} +func (m *ChainStartResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ChainStartResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ChainStartResponse proto.InternalMessageInfo + +func (m *ChainStartResponse) GetStarted() bool { + if m != nil { + return m.Started + } + return false +} + +func (m *ChainStartResponse) GetGenesisTime() uint64 { + if m != nil { + return m.GenesisTime + } + return 0 +} + +type ProposeRequest struct { + ParentHash []byte `protobuf:"bytes,1,opt,name=parent_hash,json=parentHash,proto3" json:"parent_hash,omitempty"` + SlotNumber uint64 `protobuf:"varint,2,opt,name=slot_number,json=slotNumber,proto3" json:"slot_number,omitempty"` + RandaoReveal []byte `protobuf:"bytes,3,opt,name=randao_reveal,json=randaoReveal,proto3" json:"randao_reveal,omitempty"` + AttestationBitmask []byte `protobuf:"bytes,4,opt,name=attestation_bitmask,json=attestationBitmask,proto3" json:"attestation_bitmask,omitempty"` + AttestationAggregateSig []uint64 `protobuf:"varint,5,rep,packed,name=attestation_aggregate_sig,json=attestationAggregateSig,proto3" json:"attestation_aggregate_sig,omitempty"` + Timestamp *timestamp.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ProposeRequest) Reset() { *m = ProposeRequest{} } +func (m *ProposeRequest) String() string { return proto.CompactTextString(m) } +func (*ProposeRequest) ProtoMessage() {} +func (*ProposeRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{11} +} + +func (m *ProposeRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ProposeRequest.Unmarshal(m, b) +} +func (m *ProposeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ProposeRequest.Marshal(b, m, deterministic) +} +func (m *ProposeRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ProposeRequest.Merge(m, src) +} +func (m *ProposeRequest) XXX_Size() int { + return xxx_messageInfo_ProposeRequest.Size(m) +} +func (m *ProposeRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ProposeRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ProposeRequest proto.InternalMessageInfo + +func (m *ProposeRequest) GetParentHash() []byte { + if m != nil { + return m.ParentHash + } + return nil +} + +func (m *ProposeRequest) GetSlotNumber() uint64 { + if m != nil { + return m.SlotNumber + } + return 0 +} + +func (m *ProposeRequest) GetRandaoReveal() []byte { + if m != nil { + return m.RandaoReveal + } + return nil +} + +func (m *ProposeRequest) GetAttestationBitmask() []byte { + if m != nil { + return m.AttestationBitmask + } + return nil +} + +func (m *ProposeRequest) GetAttestationAggregateSig() []uint64 { + if m != nil { + return m.AttestationAggregateSig + } + return nil +} + +func (m *ProposeRequest) GetTimestamp() *timestamp.Timestamp { + if m != nil { + return m.Timestamp + } + return nil +} + +type ProposeResponse struct { + BlockRootHash32 []byte `protobuf:"bytes,1,opt,name=block_root_hash32,json=blockRootHash32,proto3" json:"block_root_hash32,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ProposeResponse) Reset() { *m = ProposeResponse{} } +func (m *ProposeResponse) String() string { return proto.CompactTextString(m) } +func (*ProposeResponse) ProtoMessage() {} +func (*ProposeResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{12} +} + +func (m *ProposeResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ProposeResponse.Unmarshal(m, b) +} +func (m *ProposeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ProposeResponse.Marshal(b, m, deterministic) +} +func (m *ProposeResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ProposeResponse.Merge(m, src) +} +func (m *ProposeResponse) XXX_Size() int { + return xxx_messageInfo_ProposeResponse.Size(m) +} +func (m *ProposeResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ProposeResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ProposeResponse proto.InternalMessageInfo + +func (m *ProposeResponse) GetBlockRootHash32() []byte { + if m != nil { + return m.BlockRootHash32 + } + return nil +} + +type ProposerIndexRequest struct { + SlotNumber uint64 `protobuf:"varint,1,opt,name=slot_number,json=slotNumber,proto3" json:"slot_number,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ProposerIndexRequest) Reset() { *m = ProposerIndexRequest{} } +func (m *ProposerIndexRequest) String() string { return proto.CompactTextString(m) } +func (*ProposerIndexRequest) ProtoMessage() {} +func (*ProposerIndexRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{13} +} + +func (m *ProposerIndexRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ProposerIndexRequest.Unmarshal(m, b) +} +func (m *ProposerIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ProposerIndexRequest.Marshal(b, m, deterministic) +} +func (m *ProposerIndexRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ProposerIndexRequest.Merge(m, src) +} +func (m *ProposerIndexRequest) XXX_Size() int { + return xxx_messageInfo_ProposerIndexRequest.Size(m) +} +func (m *ProposerIndexRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ProposerIndexRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ProposerIndexRequest proto.InternalMessageInfo + +func (m *ProposerIndexRequest) GetSlotNumber() uint64 { + if m != nil { + return m.SlotNumber + } + return 0 +} + +type ProposerIndexResponse struct { + Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ProposerIndexResponse) Reset() { *m = ProposerIndexResponse{} } +func (m *ProposerIndexResponse) String() string { return proto.CompactTextString(m) } +func (*ProposerIndexResponse) ProtoMessage() {} +func (*ProposerIndexResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{14} +} + +func (m *ProposerIndexResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ProposerIndexResponse.Unmarshal(m, b) +} +func (m *ProposerIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ProposerIndexResponse.Marshal(b, m, deterministic) +} +func (m *ProposerIndexResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ProposerIndexResponse.Merge(m, src) +} +func (m *ProposerIndexResponse) XXX_Size() int { + return xxx_messageInfo_ProposerIndexResponse.Size(m) +} +func (m *ProposerIndexResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ProposerIndexResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ProposerIndexResponse proto.InternalMessageInfo + +func (m *ProposerIndexResponse) GetIndex() uint64 { + if m != nil { + return m.Index + } + return 0 +} + +type StateRootResponse struct { + StateRoot []byte `protobuf:"bytes,1,opt,name=state_root,json=stateRoot,proto3" json:"state_root,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *StateRootResponse) Reset() { *m = StateRootResponse{} } +func (m *StateRootResponse) String() string { return proto.CompactTextString(m) } +func (*StateRootResponse) ProtoMessage() {} +func (*StateRootResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{15} +} + +func (m *StateRootResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_StateRootResponse.Unmarshal(m, b) +} +func (m *StateRootResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_StateRootResponse.Marshal(b, m, deterministic) +} +func (m *StateRootResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_StateRootResponse.Merge(m, src) +} +func (m *StateRootResponse) XXX_Size() int { + return xxx_messageInfo_StateRootResponse.Size(m) +} +func (m *StateRootResponse) XXX_DiscardUnknown() { + xxx_messageInfo_StateRootResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_StateRootResponse proto.InternalMessageInfo + +func (m *StateRootResponse) GetStateRoot() []byte { + if m != nil { + return m.StateRoot + } + return nil +} + +type AttestResponse struct { + AttestationHash []byte `protobuf:"bytes,1,opt,name=attestation_hash,json=attestationHash,proto3" json:"attestation_hash,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *AttestResponse) Reset() { *m = AttestResponse{} } +func (m *AttestResponse) String() string { return proto.CompactTextString(m) } +func (*AttestResponse) ProtoMessage() {} +func (*AttestResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{16} +} + +func (m *AttestResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_AttestResponse.Unmarshal(m, b) +} +func (m *AttestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_AttestResponse.Marshal(b, m, deterministic) +} +func (m *AttestResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_AttestResponse.Merge(m, src) +} +func (m *AttestResponse) XXX_Size() int { + return xxx_messageInfo_AttestResponse.Size(m) +} +func (m *AttestResponse) XXX_DiscardUnknown() { + xxx_messageInfo_AttestResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_AttestResponse proto.InternalMessageInfo + +func (m *AttestResponse) GetAttestationHash() []byte { + if m != nil { + return m.AttestationHash + } + return nil +} + +type ValidatorIndexRequest struct { + PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorIndexRequest) Reset() { *m = ValidatorIndexRequest{} } +func (m *ValidatorIndexRequest) String() string { return proto.CompactTextString(m) } +func (*ValidatorIndexRequest) ProtoMessage() {} +func (*ValidatorIndexRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{17} +} + +func (m *ValidatorIndexRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorIndexRequest.Unmarshal(m, b) +} +func (m *ValidatorIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorIndexRequest.Marshal(b, m, deterministic) +} +func (m *ValidatorIndexRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorIndexRequest.Merge(m, src) +} +func (m *ValidatorIndexRequest) XXX_Size() int { + return xxx_messageInfo_ValidatorIndexRequest.Size(m) +} +func (m *ValidatorIndexRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorIndexRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorIndexRequest proto.InternalMessageInfo + +func (m *ValidatorIndexRequest) GetPublicKey() []byte { + if m != nil { + return m.PublicKey + } + return nil +} + +type ValidatorIndexResponse struct { + Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorIndexResponse) Reset() { *m = ValidatorIndexResponse{} } +func (m *ValidatorIndexResponse) String() string { return proto.CompactTextString(m) } +func (*ValidatorIndexResponse) ProtoMessage() {} +func (*ValidatorIndexResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{18} +} + +func (m *ValidatorIndexResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorIndexResponse.Unmarshal(m, b) +} +func (m *ValidatorIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorIndexResponse.Marshal(b, m, deterministic) +} +func (m *ValidatorIndexResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorIndexResponse.Merge(m, src) +} +func (m *ValidatorIndexResponse) XXX_Size() int { + return xxx_messageInfo_ValidatorIndexResponse.Size(m) +} +func (m *ValidatorIndexResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorIndexResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorIndexResponse proto.InternalMessageInfo + +func (m *ValidatorIndexResponse) GetIndex() uint64 { + if m != nil { + return m.Index + } + return 0 +} + +type CommitteeAssignmentsRequest struct { + EpochStart uint64 `protobuf:"varint,1,opt,name=epoch_start,json=epochStart,proto3" json:"epoch_start,omitempty"` + PublicKeys [][]byte `protobuf:"bytes,2,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *CommitteeAssignmentsRequest) Reset() { *m = CommitteeAssignmentsRequest{} } +func (m *CommitteeAssignmentsRequest) String() string { return proto.CompactTextString(m) } +func (*CommitteeAssignmentsRequest) ProtoMessage() {} +func (*CommitteeAssignmentsRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{19} +} + +func (m *CommitteeAssignmentsRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_CommitteeAssignmentsRequest.Unmarshal(m, b) +} +func (m *CommitteeAssignmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_CommitteeAssignmentsRequest.Marshal(b, m, deterministic) +} +func (m *CommitteeAssignmentsRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_CommitteeAssignmentsRequest.Merge(m, src) +} +func (m *CommitteeAssignmentsRequest) XXX_Size() int { + return xxx_messageInfo_CommitteeAssignmentsRequest.Size(m) +} +func (m *CommitteeAssignmentsRequest) XXX_DiscardUnknown() { + xxx_messageInfo_CommitteeAssignmentsRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_CommitteeAssignmentsRequest proto.InternalMessageInfo + +func (m *CommitteeAssignmentsRequest) GetEpochStart() uint64 { + if m != nil { + return m.EpochStart + } + return 0 +} + +func (m *CommitteeAssignmentsRequest) GetPublicKeys() [][]byte { + if m != nil { + return m.PublicKeys + } + return nil +} + +type PendingDepositsResponse struct { + PendingDeposits []*v1.Deposit `protobuf:"bytes,1,rep,name=pending_deposits,json=pendingDeposits,proto3" json:"pending_deposits,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *PendingDepositsResponse) Reset() { *m = PendingDepositsResponse{} } +func (m *PendingDepositsResponse) String() string { return proto.CompactTextString(m) } +func (*PendingDepositsResponse) ProtoMessage() {} +func (*PendingDepositsResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{20} +} + +func (m *PendingDepositsResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_PendingDepositsResponse.Unmarshal(m, b) +} +func (m *PendingDepositsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_PendingDepositsResponse.Marshal(b, m, deterministic) +} +func (m *PendingDepositsResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_PendingDepositsResponse.Merge(m, src) +} +func (m *PendingDepositsResponse) XXX_Size() int { + return xxx_messageInfo_PendingDepositsResponse.Size(m) +} +func (m *PendingDepositsResponse) XXX_DiscardUnknown() { + xxx_messageInfo_PendingDepositsResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_PendingDepositsResponse proto.InternalMessageInfo + +func (m *PendingDepositsResponse) GetPendingDeposits() []*v1.Deposit { + if m != nil { + return m.PendingDeposits + } + return nil +} + +type CommitteeAssignmentResponse struct { + Assignment []*CommitteeAssignmentResponse_CommitteeAssignment `protobuf:"bytes,1,rep,name=assignment,proto3" json:"assignment,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *CommitteeAssignmentResponse) Reset() { *m = CommitteeAssignmentResponse{} } +func (m *CommitteeAssignmentResponse) String() string { return proto.CompactTextString(m) } +func (*CommitteeAssignmentResponse) ProtoMessage() {} +func (*CommitteeAssignmentResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{21} +} + +func (m *CommitteeAssignmentResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_CommitteeAssignmentResponse.Unmarshal(m, b) +} +func (m *CommitteeAssignmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_CommitteeAssignmentResponse.Marshal(b, m, deterministic) +} +func (m *CommitteeAssignmentResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_CommitteeAssignmentResponse.Merge(m, src) +} +func (m *CommitteeAssignmentResponse) XXX_Size() int { + return xxx_messageInfo_CommitteeAssignmentResponse.Size(m) +} +func (m *CommitteeAssignmentResponse) XXX_DiscardUnknown() { + xxx_messageInfo_CommitteeAssignmentResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_CommitteeAssignmentResponse proto.InternalMessageInfo + +func (m *CommitteeAssignmentResponse) GetAssignment() []*CommitteeAssignmentResponse_CommitteeAssignment { + if m != nil { + return m.Assignment + } + return nil +} + +type CommitteeAssignmentResponse_CommitteeAssignment struct { + Committee []uint64 `protobuf:"varint,1,rep,packed,name=committee,proto3" json:"committee,omitempty"` + Shard uint64 `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"` + Slot uint64 `protobuf:"varint,3,opt,name=slot,proto3" json:"slot,omitempty"` + IsProposer bool `protobuf:"varint,4,opt,name=is_proposer,json=isProposer,proto3" json:"is_proposer,omitempty"` + PublicKey []byte `protobuf:"bytes,5,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` + Status ValidatorStatus `protobuf:"varint,6,opt,name=status,proto3,enum=ethereum.beacon.rpc.v1.ValidatorStatus" json:"status,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) Reset() { + *m = CommitteeAssignmentResponse_CommitteeAssignment{} +} +func (m *CommitteeAssignmentResponse_CommitteeAssignment) String() string { + return proto.CompactTextString(m) +} +func (*CommitteeAssignmentResponse_CommitteeAssignment) ProtoMessage() {} +func (*CommitteeAssignmentResponse_CommitteeAssignment) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{21, 0} +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment.Unmarshal(m, b) +} +func (m *CommitteeAssignmentResponse_CommitteeAssignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment.Marshal(b, m, deterministic) +} +func (m *CommitteeAssignmentResponse_CommitteeAssignment) XXX_Merge(src proto.Message) { + xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment.Merge(m, src) +} +func (m *CommitteeAssignmentResponse_CommitteeAssignment) XXX_Size() int { + return xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment.Size(m) +} +func (m *CommitteeAssignmentResponse_CommitteeAssignment) XXX_DiscardUnknown() { + xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment.DiscardUnknown(m) +} + +var xxx_messageInfo_CommitteeAssignmentResponse_CommitteeAssignment proto.InternalMessageInfo + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetCommittee() []uint64 { + if m != nil { + return m.Committee + } + return nil +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetShard() uint64 { + if m != nil { + return m.Shard + } + return 0 +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetSlot() uint64 { + if m != nil { + return m.Slot + } + return 0 +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetIsProposer() bool { + if m != nil { + return m.IsProposer + } + return false +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetPublicKey() []byte { + if m != nil { + return m.PublicKey + } + return nil +} + +func (m *CommitteeAssignmentResponse_CommitteeAssignment) GetStatus() ValidatorStatus { + if m != nil { + return m.Status + } + return ValidatorStatus_UNKNOWN_STATUS +} + +type ValidatorStatusResponse struct { + Status ValidatorStatus `protobuf:"varint,1,opt,name=status,proto3,enum=ethereum.beacon.rpc.v1.ValidatorStatus" json:"status,omitempty"` + Eth1DepositBlockNumber uint64 `protobuf:"varint,2,opt,name=eth1_deposit_block_number,json=eth1DepositBlockNumber,proto3" json:"eth1_deposit_block_number,omitempty"` + DepositInclusionSlot uint64 `protobuf:"varint,3,opt,name=deposit_inclusion_slot,json=depositInclusionSlot,proto3" json:"deposit_inclusion_slot,omitempty"` + ActivationEpoch uint64 `protobuf:"varint,4,opt,name=activation_epoch,json=activationEpoch,proto3" json:"activation_epoch,omitempty"` + PositionInActivationQueue uint64 `protobuf:"varint,5,opt,name=position_in_activation_queue,json=positionInActivationQueue,proto3" json:"position_in_activation_queue,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ValidatorStatusResponse) Reset() { *m = ValidatorStatusResponse{} } +func (m *ValidatorStatusResponse) String() string { return proto.CompactTextString(m) } +func (*ValidatorStatusResponse) ProtoMessage() {} +func (*ValidatorStatusResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{22} +} + +func (m *ValidatorStatusResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValidatorStatusResponse.Unmarshal(m, b) +} +func (m *ValidatorStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValidatorStatusResponse.Marshal(b, m, deterministic) +} +func (m *ValidatorStatusResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValidatorStatusResponse.Merge(m, src) +} +func (m *ValidatorStatusResponse) XXX_Size() int { + return xxx_messageInfo_ValidatorStatusResponse.Size(m) +} +func (m *ValidatorStatusResponse) XXX_DiscardUnknown() { + xxx_messageInfo_ValidatorStatusResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_ValidatorStatusResponse proto.InternalMessageInfo + +func (m *ValidatorStatusResponse) GetStatus() ValidatorStatus { + if m != nil { + return m.Status + } + return ValidatorStatus_UNKNOWN_STATUS +} + +func (m *ValidatorStatusResponse) GetEth1DepositBlockNumber() uint64 { + if m != nil { + return m.Eth1DepositBlockNumber + } + return 0 +} + +func (m *ValidatorStatusResponse) GetDepositInclusionSlot() uint64 { + if m != nil { + return m.DepositInclusionSlot + } + return 0 +} + +func (m *ValidatorStatusResponse) GetActivationEpoch() uint64 { + if m != nil { + return m.ActivationEpoch + } + return 0 +} + +func (m *ValidatorStatusResponse) GetPositionInActivationQueue() uint64 { + if m != nil { + return m.PositionInActivationQueue + } + return 0 +} + +type Eth1DataResponse struct { + Eth1Data *v1.Eth1Data `protobuf:"bytes,1,opt,name=eth1_data,json=eth1Data,proto3" json:"eth1_data,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *Eth1DataResponse) Reset() { *m = Eth1DataResponse{} } +func (m *Eth1DataResponse) String() string { return proto.CompactTextString(m) } +func (*Eth1DataResponse) ProtoMessage() {} +func (*Eth1DataResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{23} +} + +func (m *Eth1DataResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Eth1DataResponse.Unmarshal(m, b) +} +func (m *Eth1DataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Eth1DataResponse.Marshal(b, m, deterministic) +} +func (m *Eth1DataResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_Eth1DataResponse.Merge(m, src) +} +func (m *Eth1DataResponse) XXX_Size() int { + return xxx_messageInfo_Eth1DataResponse.Size(m) +} +func (m *Eth1DataResponse) XXX_DiscardUnknown() { + xxx_messageInfo_Eth1DataResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_Eth1DataResponse proto.InternalMessageInfo + +func (m *Eth1DataResponse) GetEth1Data() *v1.Eth1Data { + if m != nil { + return m.Eth1Data + } + return nil +} + +type BlockTreeResponse struct { + Tree []*BlockTreeResponse_TreeNode `protobuf:"bytes,1,rep,name=tree,proto3" json:"tree,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *BlockTreeResponse) Reset() { *m = BlockTreeResponse{} } +func (m *BlockTreeResponse) String() string { return proto.CompactTextString(m) } +func (*BlockTreeResponse) ProtoMessage() {} +func (*BlockTreeResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{24} +} + +func (m *BlockTreeResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_BlockTreeResponse.Unmarshal(m, b) +} +func (m *BlockTreeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_BlockTreeResponse.Marshal(b, m, deterministic) +} +func (m *BlockTreeResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_BlockTreeResponse.Merge(m, src) +} +func (m *BlockTreeResponse) XXX_Size() int { + return xxx_messageInfo_BlockTreeResponse.Size(m) +} +func (m *BlockTreeResponse) XXX_DiscardUnknown() { + xxx_messageInfo_BlockTreeResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_BlockTreeResponse proto.InternalMessageInfo + +func (m *BlockTreeResponse) GetTree() []*BlockTreeResponse_TreeNode { + if m != nil { + return m.Tree + } + return nil +} + +type BlockTreeResponse_TreeNode struct { + Block *v1.BeaconBlock `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"` + BlockRoot []byte `protobuf:"bytes,2,opt,name=block_root,json=blockRoot,proto3" json:"block_root,omitempty"` + ParticipatedVotes uint64 `protobuf:"varint,3,opt,name=participated_votes,json=participatedVotes,proto3" json:"participated_votes,omitempty"` + TotalVotes uint64 `protobuf:"varint,4,opt,name=total_votes,json=totalVotes,proto3" json:"total_votes,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *BlockTreeResponse_TreeNode) Reset() { *m = BlockTreeResponse_TreeNode{} } +func (m *BlockTreeResponse_TreeNode) String() string { return proto.CompactTextString(m) } +func (*BlockTreeResponse_TreeNode) ProtoMessage() {} +func (*BlockTreeResponse_TreeNode) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{24, 0} +} + +func (m *BlockTreeResponse_TreeNode) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_BlockTreeResponse_TreeNode.Unmarshal(m, b) +} +func (m *BlockTreeResponse_TreeNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_BlockTreeResponse_TreeNode.Marshal(b, m, deterministic) +} +func (m *BlockTreeResponse_TreeNode) XXX_Merge(src proto.Message) { + xxx_messageInfo_BlockTreeResponse_TreeNode.Merge(m, src) +} +func (m *BlockTreeResponse_TreeNode) XXX_Size() int { + return xxx_messageInfo_BlockTreeResponse_TreeNode.Size(m) +} +func (m *BlockTreeResponse_TreeNode) XXX_DiscardUnknown() { + xxx_messageInfo_BlockTreeResponse_TreeNode.DiscardUnknown(m) +} + +var xxx_messageInfo_BlockTreeResponse_TreeNode proto.InternalMessageInfo + +func (m *BlockTreeResponse_TreeNode) GetBlock() *v1.BeaconBlock { + if m != nil { + return m.Block + } + return nil +} + +func (m *BlockTreeResponse_TreeNode) GetBlockRoot() []byte { + if m != nil { + return m.BlockRoot + } + return nil +} + +func (m *BlockTreeResponse_TreeNode) GetParticipatedVotes() uint64 { + if m != nil { + return m.ParticipatedVotes + } + return 0 +} + +func (m *BlockTreeResponse_TreeNode) GetTotalVotes() uint64 { + if m != nil { + return m.TotalVotes + } + return 0 +} + +type TreeBlockSlotRequest struct { + SlotFrom uint64 `protobuf:"varint,1,opt,name=slot_from,json=slotFrom,proto3" json:"slot_from,omitempty"` + SlotTo uint64 `protobuf:"varint,2,opt,name=slot_to,json=slotTo,proto3" json:"slot_to,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *TreeBlockSlotRequest) Reset() { *m = TreeBlockSlotRequest{} } +func (m *TreeBlockSlotRequest) String() string { return proto.CompactTextString(m) } +func (*TreeBlockSlotRequest) ProtoMessage() {} +func (*TreeBlockSlotRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_9eb4e94b85965285, []int{25} +} + +func (m *TreeBlockSlotRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_TreeBlockSlotRequest.Unmarshal(m, b) +} +func (m *TreeBlockSlotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_TreeBlockSlotRequest.Marshal(b, m, deterministic) +} +func (m *TreeBlockSlotRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_TreeBlockSlotRequest.Merge(m, src) +} +func (m *TreeBlockSlotRequest) XXX_Size() int { + return xxx_messageInfo_TreeBlockSlotRequest.Size(m) +} +func (m *TreeBlockSlotRequest) XXX_DiscardUnknown() { + xxx_messageInfo_TreeBlockSlotRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_TreeBlockSlotRequest proto.InternalMessageInfo + +func (m *TreeBlockSlotRequest) GetSlotFrom() uint64 { + if m != nil { + return m.SlotFrom + } + return 0 +} + +func (m *TreeBlockSlotRequest) GetSlotTo() uint64 { + if m != nil { + return m.SlotTo + } + return 0 +} + +func init() { + proto.RegisterEnum("ethereum.beacon.rpc.v1.ValidatorRole", ValidatorRole_name, ValidatorRole_value) + proto.RegisterEnum("ethereum.beacon.rpc.v1.ValidatorStatus", ValidatorStatus_name, ValidatorStatus_value) + proto.RegisterType((*ValidatorPerformanceRequest)(nil), "ethereum.beacon.rpc.v1.ValidatorPerformanceRequest") + proto.RegisterType((*ValidatorPerformanceResponse)(nil), "ethereum.beacon.rpc.v1.ValidatorPerformanceResponse") + proto.RegisterType((*ValidatorActivationRequest)(nil), "ethereum.beacon.rpc.v1.ValidatorActivationRequest") + proto.RegisterType((*ValidatorActivationResponse)(nil), "ethereum.beacon.rpc.v1.ValidatorActivationResponse") + proto.RegisterType((*ValidatorActivationResponse_Status)(nil), "ethereum.beacon.rpc.v1.ValidatorActivationResponse.Status") + proto.RegisterType((*ExitedValidatorsRequest)(nil), "ethereum.beacon.rpc.v1.ExitedValidatorsRequest") + proto.RegisterType((*ExitedValidatorsResponse)(nil), "ethereum.beacon.rpc.v1.ExitedValidatorsResponse") + proto.RegisterType((*AttestationDataRequest)(nil), "ethereum.beacon.rpc.v1.AttestationDataRequest") + proto.RegisterType((*AttestationDataResponse)(nil), "ethereum.beacon.rpc.v1.AttestationDataResponse") + proto.RegisterType((*PendingAttestationsRequest)(nil), "ethereum.beacon.rpc.v1.PendingAttestationsRequest") + proto.RegisterType((*PendingAttestationsResponse)(nil), "ethereum.beacon.rpc.v1.PendingAttestationsResponse") + proto.RegisterType((*ChainStartResponse)(nil), "ethereum.beacon.rpc.v1.ChainStartResponse") + proto.RegisterType((*ProposeRequest)(nil), "ethereum.beacon.rpc.v1.ProposeRequest") + proto.RegisterType((*ProposeResponse)(nil), "ethereum.beacon.rpc.v1.ProposeResponse") + proto.RegisterType((*ProposerIndexRequest)(nil), "ethereum.beacon.rpc.v1.ProposerIndexRequest") + proto.RegisterType((*ProposerIndexResponse)(nil), "ethereum.beacon.rpc.v1.ProposerIndexResponse") + proto.RegisterType((*StateRootResponse)(nil), "ethereum.beacon.rpc.v1.StateRootResponse") + proto.RegisterType((*AttestResponse)(nil), "ethereum.beacon.rpc.v1.AttestResponse") + proto.RegisterType((*ValidatorIndexRequest)(nil), "ethereum.beacon.rpc.v1.ValidatorIndexRequest") + proto.RegisterType((*ValidatorIndexResponse)(nil), "ethereum.beacon.rpc.v1.ValidatorIndexResponse") + proto.RegisterType((*CommitteeAssignmentsRequest)(nil), "ethereum.beacon.rpc.v1.CommitteeAssignmentsRequest") + proto.RegisterType((*PendingDepositsResponse)(nil), "ethereum.beacon.rpc.v1.PendingDepositsResponse") + proto.RegisterType((*CommitteeAssignmentResponse)(nil), "ethereum.beacon.rpc.v1.CommitteeAssignmentResponse") + proto.RegisterType((*CommitteeAssignmentResponse_CommitteeAssignment)(nil), "ethereum.beacon.rpc.v1.CommitteeAssignmentResponse.CommitteeAssignment") + proto.RegisterType((*ValidatorStatusResponse)(nil), "ethereum.beacon.rpc.v1.ValidatorStatusResponse") + proto.RegisterType((*Eth1DataResponse)(nil), "ethereum.beacon.rpc.v1.Eth1DataResponse") + proto.RegisterType((*BlockTreeResponse)(nil), "ethereum.beacon.rpc.v1.BlockTreeResponse") + proto.RegisterType((*BlockTreeResponse_TreeNode)(nil), "ethereum.beacon.rpc.v1.BlockTreeResponse.TreeNode") + proto.RegisterType((*TreeBlockSlotRequest)(nil), "ethereum.beacon.rpc.v1.TreeBlockSlotRequest") +} + +func init() { proto.RegisterFile("proto/beacon/rpc/v1/services.proto", fileDescriptor_9eb4e94b85965285) } + +var fileDescriptor_9eb4e94b85965285 = []byte{ + // 2262 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x59, 0x4d, 0x6f, 0x1b, 0xc7, + 0xf9, 0xcf, 0x52, 0x2f, 0x96, 0x1e, 0xc9, 0x12, 0x35, 0x7a, 0x35, 0x65, 0xc3, 0x9b, 0xcd, 0x1f, + 0xb1, 0x2c, 0x44, 0x4b, 0x99, 0x0e, 0x9c, 0x44, 0x86, 0x91, 0x50, 0x12, 0x25, 0x2b, 0x11, 0x68, + 0x79, 0x49, 0xdb, 0xff, 0x16, 0x05, 0xb6, 0xc3, 0xe5, 0x88, 0xdc, 0x88, 0xdc, 0x59, 0xef, 0x0c, + 0x19, 0xb3, 0x87, 0x14, 0xed, 0xa5, 0x28, 0x7a, 0x73, 0xef, 0xcd, 0x97, 0x28, 0x50, 0xa0, 0x87, + 0x02, 0xfd, 0x0c, 0x3d, 0x16, 0xe8, 0xa1, 0x08, 0xda, 0x7b, 0x3f, 0x41, 0x31, 0xb3, 0xb3, 0xcb, + 0x15, 0xc9, 0x95, 0xa8, 0x9e, 0xc4, 0x7d, 0x5e, 0x67, 0x7e, 0xf3, 0xbc, 0xcd, 0x08, 0x0c, 0x3f, + 0xa0, 0x9c, 0xe6, 0x6b, 0x04, 0x3b, 0xd4, 0xcb, 0x07, 0xbe, 0x93, 0xef, 0x3e, 0xca, 0x33, 0x12, + 0x74, 0x5d, 0x87, 0x30, 0x53, 0x32, 0xd1, 0x1a, 0xe1, 0x4d, 0x12, 0x90, 0x4e, 0xdb, 0x0c, 0xc5, + 0xcc, 0xc0, 0x77, 0xcc, 0xee, 0xa3, 0xdc, 0x66, 0x83, 0xd2, 0x46, 0x8b, 0xe4, 0xa5, 0x54, 0xad, + 0x73, 0x9e, 0x27, 0x6d, 0x9f, 0xf7, 0x42, 0xa5, 0xdc, 0xfd, 0x41, 0x26, 0x77, 0xdb, 0x84, 0x71, + 0xdc, 0xf6, 0x23, 0x81, 0x4b, 0x9e, 0xfd, 0x82, 0x2f, 0x3c, 0xf3, 0x9e, 0x1f, 0xb9, 0xcd, 0xdd, + 0x55, 0x16, 0xb0, 0xef, 0xe6, 0xb1, 0xe7, 0x51, 0x8e, 0xb9, 0x4b, 0xbd, 0x88, 0xfb, 0x89, 0xfc, + 0xe3, 0xec, 0x34, 0x88, 0xb7, 0xc3, 0xbe, 0xc3, 0x8d, 0x06, 0x09, 0xf2, 0xd4, 0x97, 0x12, 0xc3, + 0xd2, 0xc6, 0x19, 0x6c, 0xbe, 0xc6, 0x2d, 0xb7, 0x8e, 0x39, 0x0d, 0xce, 0x48, 0x70, 0x4e, 0x83, + 0x36, 0xf6, 0x1c, 0x62, 0x91, 0xb7, 0x1d, 0xc2, 0x38, 0x42, 0x30, 0xc9, 0x5a, 0x94, 0x6f, 0x68, + 0xba, 0xb6, 0x35, 0x69, 0xc9, 0xdf, 0xe8, 0x1e, 0x80, 0xdf, 0xa9, 0xb5, 0x5c, 0xc7, 0xbe, 0x20, + 0xbd, 0x8d, 0x8c, 0xae, 0x6d, 0xcd, 0x5b, 0xb3, 0x21, 0xe5, 0x1b, 0xd2, 0x33, 0x7e, 0xd4, 0xe0, + 0xee, 0x68, 0x93, 0xcc, 0xa7, 0x1e, 0x23, 0x68, 0x03, 0x6e, 0xd5, 0x70, 0x4b, 0x90, 0x94, 0xd9, + 0xe8, 0x13, 0x3d, 0x84, 0x2c, 0xa7, 0x1c, 0xb7, 0xec, 0x6e, 0xa4, 0xcf, 0xa4, 0xfd, 0x49, 0x6b, + 0x51, 0xd2, 0x63, 0xb3, 0x0c, 0x3d, 0x81, 0xf5, 0x50, 0x14, 0x3b, 0xdc, 0xed, 0x92, 0xa4, 0xc6, + 0x84, 0xd4, 0x58, 0x95, 0xec, 0xa2, 0xe4, 0x26, 0xf4, 0x8e, 0x41, 0xc7, 0x5d, 0x12, 0xe0, 0x06, + 0x19, 0xd2, 0xb4, 0xa3, 0x55, 0x4d, 0xea, 0xda, 0x56, 0xc6, 0xba, 0xa7, 0xe4, 0x06, 0x4c, 0xec, + 0x87, 0x42, 0xc6, 0x33, 0xc8, 0xc5, 0x34, 0x29, 0x22, 0x61, 0x8d, 0x70, 0xbb, 0x0f, 0x73, 0x7d, + 0x8c, 0xd8, 0x86, 0xa6, 0x4f, 0x6c, 0xcd, 0x5b, 0x10, 0x83, 0xc4, 0x8c, 0x1f, 0x32, 0x09, 0xe0, + 0x93, 0xfa, 0x0a, 0xa4, 0x27, 0xb0, 0x8a, 0x43, 0x2a, 0xa9, 0xdb, 0x43, 0xa6, 0xf6, 0x33, 0x1b, + 0x9a, 0xb5, 0x1c, 0x0b, 0x9c, 0xc5, 0x76, 0xd1, 0x6b, 0x98, 0x61, 0x1c, 0xf3, 0x0e, 0x23, 0x02, + 0xba, 0x89, 0xad, 0xb9, 0xc2, 0x9e, 0x39, 0x3a, 0x4a, 0xcd, 0x2b, 0xdc, 0x9b, 0x15, 0x69, 0xc3, + 0x8a, 0x6d, 0xe5, 0x7c, 0x98, 0x0e, 0x69, 0x03, 0xc7, 0xaf, 0x0d, 0x1c, 0x3f, 0x3a, 0x86, 0xe9, + 0x50, 0x49, 0x9e, 0xdc, 0x5c, 0x21, 0x7f, 0xad, 0x7b, 0xe5, 0x4b, 0xb9, 0xb6, 0x94, 0xba, 0xb1, + 0x07, 0xeb, 0xa5, 0x77, 0x2e, 0x27, 0xf5, 0xfe, 0xe9, 0x8d, 0x8d, 0xee, 0x53, 0xd8, 0x18, 0xd6, + 0x55, 0xc8, 0x5e, 0xab, 0xbc, 0x0f, 0x6b, 0x45, 0xce, 0x45, 0x4a, 0x0a, 0x48, 0x0e, 0x31, 0xc7, + 0x91, 0xdf, 0x15, 0x98, 0x62, 0x4d, 0x1c, 0xd4, 0x55, 0xdc, 0x86, 0x1f, 0x71, 0x8e, 0x64, 0xfa, + 0x39, 0x62, 0xfc, 0x33, 0x03, 0xeb, 0x43, 0x46, 0xd4, 0x02, 0x3e, 0x83, 0x8d, 0x10, 0x09, 0xbb, + 0xd6, 0xa2, 0xce, 0x85, 0x1d, 0x50, 0xca, 0xed, 0x26, 0x66, 0xcd, 0xc7, 0x05, 0x05, 0xe7, 0x6a, + 0xc8, 0xdf, 0x17, 0x6c, 0x8b, 0x52, 0xfe, 0x5c, 0x32, 0xd1, 0x53, 0xc8, 0x11, 0x9f, 0x3a, 0x4d, + 0xbb, 0x46, 0x3b, 0x5e, 0x1d, 0x07, 0xbd, 0x4b, 0xaa, 0x61, 0x22, 0xae, 0x4b, 0x89, 0x7d, 0x25, + 0x90, 0x50, 0x7e, 0x00, 0x8b, 0xdf, 0x76, 0x18, 0x77, 0xcf, 0x5d, 0x52, 0xb7, 0xa5, 0x90, 0x4a, + 0x94, 0x85, 0x98, 0x5c, 0x12, 0x54, 0xf4, 0x0c, 0x36, 0xfb, 0x82, 0xc3, 0x2b, 0x9c, 0x94, 0x6e, + 0x36, 0x62, 0x91, 0xc1, 0x45, 0x9e, 0x42, 0xb6, 0x85, 0xc5, 0xc6, 0x6d, 0x27, 0xa0, 0x8c, 0xb5, + 0x5c, 0xef, 0x62, 0x63, 0x4a, 0x46, 0xc2, 0x87, 0x43, 0x91, 0xe0, 0x17, 0x7c, 0x11, 0x09, 0x07, + 0x91, 0xa0, 0xb5, 0x18, 0xaa, 0xc6, 0x04, 0xb4, 0x09, 0xb3, 0x4d, 0x82, 0xeb, 0xb6, 0x04, 0x78, + 0x5a, 0xae, 0x77, 0x46, 0x10, 0x2a, 0x02, 0xe4, 0xdf, 0x6a, 0x90, 0x3b, 0x23, 0x5e, 0xdd, 0xf5, + 0x1a, 0x09, 0xac, 0xe3, 0x28, 0x79, 0x0a, 0xb9, 0x73, 0xb7, 0xc5, 0x49, 0x60, 0x07, 0x04, 0xd7, + 0x7b, 0xf6, 0x39, 0x0d, 0x6c, 0xd7, 0x73, 0x5a, 0x1d, 0xe6, 0x52, 0x4f, 0x22, 0x3d, 0x63, 0xad, + 0x87, 0x12, 0x96, 0x10, 0x38, 0xa2, 0xc1, 0x49, 0xc4, 0x46, 0x26, 0x2c, 0xfb, 0x01, 0xf5, 0x29, + 0xc3, 0x2d, 0x05, 0x42, 0xe2, 0x8c, 0x97, 0x22, 0x96, 0xdc, 0xbc, 0x5c, 0x4b, 0x07, 0x36, 0x47, + 0x2e, 0x45, 0x9d, 0xf9, 0x6b, 0x58, 0xf1, 0x43, 0xb6, 0x8d, 0x13, 0x7c, 0x19, 0x7d, 0x73, 0x85, + 0x8f, 0xd2, 0x90, 0x49, 0xd8, 0xb2, 0x96, 0xfd, 0x61, 0xfb, 0xc6, 0x4b, 0x40, 0x07, 0x4d, 0xec, + 0x7a, 0x15, 0x8e, 0x03, 0x9e, 0xac, 0xb0, 0x4c, 0x10, 0x48, 0x5d, 0x6d, 0x33, 0xfa, 0x44, 0x1f, + 0xc2, 0x7c, 0x83, 0x78, 0x84, 0xb9, 0xcc, 0x16, 0x6d, 0x47, 0xed, 0x67, 0x4e, 0xd1, 0xaa, 0x6e, + 0x9b, 0x18, 0x7f, 0xc8, 0xc0, 0xc2, 0x99, 0xdc, 0x1f, 0x49, 0xe6, 0x1b, 0x0e, 0x88, 0x17, 0x06, + 0x81, 0x0a, 0x52, 0x08, 0x49, 0xe2, 0xd8, 0x85, 0x80, 0x80, 0xc7, 0xf6, 0x3a, 0xed, 0x1a, 0x09, + 0x94, 0x55, 0x10, 0xa4, 0xb2, 0xa4, 0xa0, 0x8f, 0xe0, 0x76, 0x80, 0xbd, 0x3a, 0xa6, 0x76, 0x40, + 0xba, 0x04, 0xb7, 0x64, 0xec, 0xcd, 0x5b, 0xf3, 0x21, 0xd1, 0x92, 0x34, 0x94, 0x87, 0xe5, 0x04, + 0x38, 0x76, 0xcd, 0xe5, 0x6d, 0xcc, 0x2e, 0x54, 0xc4, 0xa1, 0x04, 0x6b, 0x3f, 0xe4, 0xa0, 0x3d, + 0xb8, 0x93, 0x54, 0xc0, 0x8d, 0x46, 0x40, 0x1a, 0x98, 0x13, 0x9b, 0xb9, 0x8d, 0x8d, 0x29, 0x7d, + 0x62, 0x6b, 0xd2, 0x5a, 0x4f, 0x08, 0x14, 0x23, 0x7e, 0xc5, 0x6d, 0xa0, 0xcf, 0x61, 0x36, 0x6e, + 0xbc, 0x32, 0xb2, 0xe6, 0x0a, 0x39, 0x33, 0x6c, 0xac, 0x66, 0xd4, 0x9a, 0xcd, 0x6a, 0x24, 0x61, + 0xf5, 0x85, 0x8d, 0x67, 0xb0, 0x18, 0xe3, 0xa3, 0x00, 0xdf, 0x86, 0xa5, 0xb4, 0x5c, 0x5e, 0xac, + 0x5d, 0x4e, 0x10, 0xe3, 0x33, 0x58, 0x51, 0xea, 0xc1, 0x89, 0x57, 0x27, 0xef, 0x12, 0x20, 0x27, + 0x31, 0xd4, 0x06, 0x31, 0x34, 0x76, 0x60, 0x75, 0x40, 0x51, 0x79, 0x5f, 0x81, 0x29, 0x57, 0x10, + 0xa2, 0xb2, 0x24, 0x3f, 0x8c, 0x02, 0x2c, 0x89, 0xca, 0x4a, 0x84, 0xeb, 0x58, 0xf4, 0x1e, 0x80, + 0x00, 0x83, 0xc8, 0x85, 0x46, 0xc5, 0x9b, 0x45, 0x62, 0xc6, 0x53, 0x58, 0x08, 0xc3, 0x2b, 0x56, + 0x78, 0x08, 0xd9, 0x24, 0xc4, 0x89, 0xf3, 0x5f, 0x4c, 0xd0, 0xc5, 0xd6, 0x8c, 0x27, 0xb0, 0x1a, + 0x97, 0xdb, 0x4b, 0x3b, 0xbb, 0xba, 0x63, 0x18, 0x26, 0xac, 0x0d, 0xea, 0x5d, 0xb9, 0x31, 0x1b, + 0x36, 0x0f, 0x68, 0xbb, 0xed, 0x72, 0x4e, 0x48, 0x91, 0x31, 0xb7, 0xe1, 0xb5, 0x89, 0xc7, 0x93, + 0xcd, 0x21, 0xac, 0x92, 0x32, 0xe6, 0x23, 0x1c, 0x25, 0x49, 0x66, 0xc9, 0x60, 0x03, 0xc8, 0x0c, + 0x35, 0x00, 0x02, 0xeb, 0x2a, 0x97, 0x0f, 0x89, 0x4f, 0x99, 0xcb, 0xfb, 0x79, 0xfc, 0x35, 0x64, + 0xa3, 0x3c, 0xae, 0x2b, 0x9e, 0xca, 0xe1, 0xfb, 0x69, 0x39, 0xac, 0x6c, 0x58, 0x8b, 0xfe, 0x65, + 0x9b, 0xc6, 0xbf, 0x33, 0x23, 0x37, 0x12, 0xfb, 0x6a, 0x00, 0xe0, 0x98, 0xaa, 0xbc, 0x1c, 0xa7, + 0x75, 0xd3, 0x2b, 0x0c, 0x8d, 0xe4, 0x25, 0x4c, 0xe7, 0xfe, 0xa1, 0xc1, 0xf2, 0x08, 0x19, 0x74, + 0x17, 0x66, 0x9d, 0x88, 0x2c, 0xfd, 0x4f, 0x5a, 0x7d, 0x42, 0xbf, 0x19, 0x66, 0x46, 0x35, 0xc3, + 0x89, 0xc4, 0xc0, 0x78, 0x1f, 0xe6, 0x5c, 0x66, 0xfb, 0x2a, 0x76, 0x65, 0x3e, 0xcf, 0x58, 0xe0, + 0xb2, 0x28, 0x9a, 0x07, 0x02, 0x64, 0x6a, 0x70, 0xa4, 0xf8, 0x32, 0x1e, 0x29, 0x44, 0x9e, 0x2e, + 0x14, 0x1e, 0x8c, 0x3b, 0x52, 0x44, 0xa3, 0xc4, 0x9f, 0x32, 0xb0, 0x9e, 0x32, 0x6e, 0x24, 0x8c, + 0x6b, 0xff, 0x93, 0x71, 0xf4, 0x05, 0xdc, 0x21, 0xbc, 0xf9, 0x28, 0x8a, 0x07, 0xd5, 0x2d, 0x2e, + 0x55, 0x42, 0x71, 0x4f, 0x78, 0xa4, 0xce, 0x5d, 0xb6, 0x0c, 0x55, 0x15, 0x3f, 0x85, 0xb5, 0x48, + 0x2b, 0x6e, 0x4c, 0x76, 0x02, 0xbe, 0x15, 0xc5, 0x8d, 0xdb, 0x92, 0x68, 0x35, 0x32, 0x25, 0xe3, + 0x89, 0x4d, 0xb5, 0xf2, 0xc9, 0x70, 0x4a, 0xee, 0xd3, 0xc3, 0x5e, 0xfe, 0x25, 0xdc, 0x95, 0x06, + 0x84, 0xa0, 0xeb, 0xd9, 0x09, 0xb5, 0xb7, 0x1d, 0xd2, 0x21, 0x12, 0xea, 0x49, 0xeb, 0x4e, 0x24, + 0x73, 0xe2, 0xf5, 0x47, 0xc1, 0x97, 0x42, 0xc0, 0x78, 0x09, 0xd9, 0x92, 0x58, 0x7b, 0x72, 0x7e, + 0x79, 0x06, 0xb3, 0xe1, 0x86, 0x31, 0xc7, 0x12, 0xb4, 0xb9, 0x82, 0x9e, 0x16, 0xfc, 0xb1, 0xf2, + 0x0c, 0x51, 0xbf, 0x8c, 0xf7, 0x19, 0x58, 0x92, 0x20, 0x54, 0x03, 0xd2, 0xaf, 0xa0, 0x47, 0x30, + 0xc9, 0x03, 0x15, 0x66, 0x73, 0x85, 0x42, 0xda, 0x21, 0x0c, 0x29, 0x9a, 0xe2, 0xa3, 0x4c, 0xeb, + 0xc4, 0x92, 0xfa, 0xb9, 0x3f, 0x6a, 0x30, 0x13, 0x91, 0xd0, 0x17, 0x30, 0x25, 0x4f, 0x43, 0xad, + 0x32, 0xb5, 0xcd, 0xee, 0x27, 0xc6, 0xad, 0x50, 0x43, 0x84, 0x64, 0xbf, 0xa2, 0x47, 0x97, 0x9c, + 0xb8, 0x94, 0xa3, 0x1d, 0x40, 0x3e, 0x0e, 0xb8, 0xeb, 0xb8, 0xbe, 0x9c, 0xd0, 0xbb, 0x94, 0x93, + 0xe8, 0xe6, 0xb1, 0x94, 0xe4, 0xbc, 0x16, 0x0c, 0x91, 0x01, 0xea, 0x62, 0x23, 0xe5, 0xc2, 0xd3, + 0x82, 0xf0, 0x4e, 0x23, 0x28, 0xc6, 0x29, 0xac, 0x88, 0x55, 0xc7, 0xf3, 0x44, 0x54, 0xcc, 0x36, + 0x61, 0x56, 0x36, 0x85, 0xf3, 0x80, 0xb6, 0x55, 0x29, 0x9b, 0x11, 0x84, 0xa3, 0x80, 0xb6, 0xd1, + 0x3a, 0xdc, 0x92, 0x4c, 0x4e, 0x55, 0x9c, 0x4d, 0x8b, 0xcf, 0x2a, 0xdd, 0xfe, 0x1c, 0x6e, 0xc7, + 0xd1, 0x6a, 0xd1, 0x16, 0x41, 0x73, 0x70, 0xeb, 0x55, 0xf9, 0x9b, 0xf2, 0x8b, 0x37, 0xe5, 0xec, + 0x07, 0x68, 0x1e, 0x66, 0x8a, 0xd5, 0x6a, 0xa9, 0x52, 0x2d, 0x59, 0x59, 0x4d, 0x7c, 0x9d, 0x59, + 0x2f, 0xce, 0x5e, 0x54, 0x4a, 0x56, 0x36, 0xb3, 0xfd, 0x3b, 0x0d, 0x16, 0x07, 0x02, 0x1d, 0x21, + 0x58, 0x50, 0xca, 0x76, 0xa5, 0x5a, 0xac, 0xbe, 0xaa, 0x64, 0x3f, 0x10, 0xb4, 0xb3, 0x52, 0xf9, + 0xf0, 0xa4, 0x7c, 0x6c, 0x17, 0x0f, 0xaa, 0x27, 0xaf, 0x4b, 0x59, 0x0d, 0x01, 0x4c, 0xab, 0xdf, + 0x19, 0xc1, 0x3f, 0x29, 0x9f, 0x54, 0x4f, 0x8a, 0xd5, 0xd2, 0xa1, 0x5d, 0xfa, 0xff, 0x93, 0x6a, + 0x76, 0x02, 0x65, 0x61, 0xfe, 0xcd, 0x49, 0xf5, 0xf9, 0xa1, 0x55, 0x7c, 0x53, 0xdc, 0x3f, 0x2d, + 0x65, 0x27, 0x85, 0x86, 0xe0, 0x95, 0x0e, 0xb3, 0x53, 0x42, 0x23, 0xfc, 0x6d, 0x57, 0x4e, 0x8b, + 0x95, 0xe7, 0xa5, 0xc3, 0xec, 0x74, 0xe1, 0x37, 0xd3, 0x70, 0x3b, 0x3c, 0x9b, 0x4a, 0x78, 0xf1, + 0x46, 0x3f, 0x81, 0xa5, 0x37, 0xd8, 0xe5, 0x47, 0x34, 0xe8, 0x8f, 0x3d, 0x68, 0x6d, 0xa8, 0x6f, + 0x97, 0xc4, 0x7d, 0x3b, 0xb7, 0x9d, 0x5a, 0x2c, 0x87, 0x46, 0xa6, 0x5d, 0x0d, 0x9d, 0xc2, 0xed, + 0x03, 0xec, 0x51, 0xcf, 0x75, 0x70, 0xeb, 0x39, 0xc1, 0xf5, 0x54, 0xb3, 0xe3, 0x84, 0x11, 0xb2, + 0x60, 0xe9, 0x54, 0xce, 0xb2, 0x89, 0x71, 0xed, 0xe6, 0x16, 0x13, 0xca, 0xbb, 0x1a, 0xfa, 0x29, + 0x2c, 0x0e, 0xf4, 0xa5, 0x54, 0x8b, 0xa9, 0xb7, 0xae, 0xb4, 0xc6, 0x76, 0x0a, 0x33, 0x51, 0xae, + 0xa6, 0x1a, 0xdd, 0x4a, 0x33, 0x3a, 0x54, 0x22, 0xbe, 0x82, 0x99, 0x23, 0x1a, 0x5c, 0x5c, 0x69, + 0xed, 0x6e, 0xda, 0xa6, 0x85, 0x26, 0xfa, 0x41, 0x83, 0xd9, 0x38, 0xd9, 0x53, 0x6d, 0x3c, 0x1c, + 0xbb, 0x4e, 0x18, 0x2f, 0xde, 0x17, 0x77, 0x91, 0x79, 0x44, 0xb8, 0xd3, 0x24, 0x4c, 0x97, 0x99, + 0xac, 0x8b, 0x8a, 0xa1, 0x33, 0xd7, 0x73, 0x88, 0xde, 0xc2, 0x8c, 0xeb, 0xe7, 0xae, 0x87, 0x5b, + 0xee, 0x2f, 0x48, 0x3d, 0xe4, 0x9b, 0xbf, 0xfe, 0xdb, 0x8f, 0xbf, 0xcf, 0xac, 0xa1, 0x95, 0x7c, + 0xf7, 0x51, 0xf4, 0x1c, 0x23, 0x19, 0x42, 0x0f, 0x5d, 0x40, 0x36, 0xf6, 0xb2, 0xdf, 0x13, 0x49, + 0xcb, 0xd0, 0x27, 0x69, 0xeb, 0x19, 0x95, 0xdc, 0x37, 0x58, 0x7d, 0xe1, 0x5f, 0x1a, 0x2c, 0x86, + 0xc1, 0x40, 0x82, 0x7e, 0x2e, 0x40, 0x48, 0x92, 0xd1, 0x3a, 0x4e, 0x0c, 0xe5, 0x3e, 0x4e, 0xf3, + 0x38, 0x30, 0xf5, 0xbd, 0x83, 0xd5, 0x81, 0xdb, 0x6b, 0x91, 0xcb, 0xde, 0x63, 0x5e, 0x6d, 0x60, + 0xf0, 0xc6, 0x9c, 0x1e, 0x87, 0x29, 0x97, 0xe3, 0xc2, 0x5f, 0x27, 0xe2, 0xe9, 0x3a, 0xde, 0x68, + 0x0b, 0x6e, 0x5f, 0x1a, 0x7c, 0xd3, 0x61, 0x1e, 0x35, 0x58, 0xe7, 0x76, 0xc6, 0x94, 0x56, 0x7b, + 0xff, 0x1e, 0x96, 0x47, 0xdc, 0xe4, 0x50, 0xe1, 0x9a, 0x8c, 0x1a, 0x71, 0x03, 0xcd, 0x3d, 0xbe, + 0x91, 0x8e, 0xf2, 0xff, 0x33, 0x98, 0x57, 0x0b, 0x0b, 0x2b, 0xc9, 0x38, 0xe5, 0x26, 0xf7, 0xe0, + 0x9a, 0x3d, 0xc6, 0xd6, 0x6b, 0x90, 0x3d, 0xa0, 0x6d, 0xbf, 0xc3, 0x49, 0x7c, 0x39, 0x18, 0xcf, + 0x43, 0x6a, 0xb0, 0x0e, 0x5d, 0x32, 0x0a, 0xff, 0x99, 0x82, 0x6c, 0xbf, 0x89, 0xa8, 0x43, 0xfc, + 0x3e, 0xae, 0xdc, 0xfd, 0x19, 0x23, 0x1d, 0xd4, 0xf4, 0xa7, 0xb5, 0x74, 0x50, 0xaf, 0x78, 0xcf, + 0xda, 0xd5, 0x10, 0x85, 0x85, 0xcb, 0xb7, 0x0c, 0xb4, 0x73, 0xad, 0xa1, 0x4b, 0x61, 0x64, 0x8e, + 0x2b, 0xae, 0x90, 0xfe, 0xe5, 0xe8, 0xa1, 0xfa, 0xf1, 0x0d, 0x26, 0xf8, 0xeb, 0x03, 0xe9, 0xaa, + 0xfb, 0xc3, 0xdb, 0xe1, 0x56, 0x7e, 0xc3, 0x2d, 0xdf, 0xf4, 0xed, 0x0e, 0xfd, 0x4a, 0x83, 0x95, + 0x51, 0x6f, 0xbf, 0xe8, 0xfa, 0x43, 0x1b, 0x7e, 0x7c, 0xce, 0x7d, 0x7a, 0x33, 0x25, 0xb5, 0x86, + 0x0e, 0x64, 0x07, 0xdf, 0xfe, 0x50, 0xea, 0x46, 0x52, 0x5e, 0x18, 0x73, 0xbb, 0xe3, 0x2b, 0x84, + 0x6e, 0xf7, 0xff, 0x32, 0xf1, 0xbe, 0xf8, 0xe7, 0x09, 0xf4, 0x77, 0x0d, 0xa6, 0xce, 0x82, 0x1e, + 0x6b, 0xa3, 0xff, 0xfb, 0xba, 0xf2, 0xa2, 0xac, 0x5b, 0x67, 0x07, 0x7a, 0xf4, 0x5f, 0x03, 0xdd, + 0x0f, 0x68, 0xd7, 0xad, 0x8b, 0xf6, 0xd2, 0xd3, 0xa5, 0x90, 0x69, 0x1c, 0xc0, 0x82, 0xfc, 0x85, + 0xb9, 0xeb, 0xe8, 0xa7, 0xb8, 0xc6, 0xd0, 0x9d, 0x26, 0xe7, 0x3e, 0xdb, 0xcb, 0xe7, 0xfd, 0x88, + 0xde, 0xc2, 0x35, 0x66, 0x3a, 0xb4, 0x9d, 0x5b, 0xe3, 0x04, 0xb7, 0xbf, 0x1a, 0xa2, 0x6f, 0xff, + 0x1c, 0xee, 0x1f, 0x97, 0x5f, 0xe9, 0xc7, 0xc4, 0x23, 0x01, 0x6e, 0xe9, 0xe1, 0x73, 0xb0, 0x7e, + 0xea, 0x3a, 0xc4, 0x63, 0x44, 0xef, 0x3e, 0x36, 0x77, 0xd1, 0xb3, 0xc8, 0x6a, 0xc3, 0xe5, 0xcd, + 0x4e, 0x4d, 0xa8, 0x5d, 0x76, 0x10, 0x7e, 0x89, 0xfe, 0x56, 0xcb, 0xb7, 0xb1, 0xe8, 0x33, 0xf9, + 0xd3, 0x93, 0x83, 0x52, 0xb9, 0x52, 0x32, 0xdb, 0xf5, 0xc2, 0xd4, 0xae, 0xb9, 0x6b, 0xee, 0xe6, + 0x16, 0xb1, 0xef, 0x9a, 0x7e, 0xd0, 0x93, 0x9e, 0x3d, 0xc2, 0xb7, 0xb5, 0x4c, 0x21, 0x8b, 0x7d, + 0xbf, 0xe5, 0x3a, 0x32, 0xdf, 0xf2, 0xdf, 0x32, 0xea, 0x15, 0xee, 0x24, 0x29, 0x8d, 0xc0, 0x77, + 0x76, 0xbe, 0x23, 0xb5, 0x1d, 0x4e, 0xde, 0xf1, 0x14, 0xd6, 0x15, 0x5a, 0x82, 0xb5, 0x37, 0xe4, + 0x62, 0x2f, 0xdd, 0x45, 0xf0, 0x44, 0xd4, 0xcf, 0x1e, 0x6b, 0xeb, 0xc7, 0x72, 0xa7, 0xe8, 0xe3, + 0xf1, 0x76, 0x5e, 0x9b, 0x96, 0xb3, 0xc5, 0xe3, 0xff, 0x06, 0x00, 0x00, 0xff, 0xff, 0x93, 0x9e, + 0x49, 0xb6, 0xf9, 0x19, 0x00, 0x00, +} + +// Reference imports to suppress errors if they are not otherwise used. +var _ context.Context +var _ grpc.ClientConn + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +const _ = grpc.SupportPackageIsVersion4 + +// BeaconServiceClient is the client API for BeaconService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. +type BeaconServiceClient interface { + WaitForChainStart(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (BeaconService_WaitForChainStartClient, error) + CanonicalHead(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.BeaconBlock, error) + LatestAttestation(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (BeaconService_LatestAttestationClient, error) + PendingDeposits(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PendingDepositsResponse, error) + Eth1Data(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Eth1DataResponse, error) + ForkData(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.Fork, error) + BlockTree(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BlockTreeResponse, error) + BlockTreeBySlots(ctx context.Context, in *TreeBlockSlotRequest, opts ...grpc.CallOption) (*BlockTreeResponse, error) +} + +type beaconServiceClient struct { + cc *grpc.ClientConn +} + +func NewBeaconServiceClient(cc *grpc.ClientConn) BeaconServiceClient { + return &beaconServiceClient{cc} +} + +func (c *beaconServiceClient) WaitForChainStart(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (BeaconService_WaitForChainStartClient, error) { + stream, err := c.cc.NewStream(ctx, &_BeaconService_serviceDesc.Streams[0], "/ethereum.beacon.rpc.v1.BeaconService/WaitForChainStart", opts...) + if err != nil { + return nil, err + } + x := &beaconServiceWaitForChainStartClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type BeaconService_WaitForChainStartClient interface { + Recv() (*ChainStartResponse, error) + grpc.ClientStream +} + +type beaconServiceWaitForChainStartClient struct { + grpc.ClientStream +} + +func (x *beaconServiceWaitForChainStartClient) Recv() (*ChainStartResponse, error) { + m := new(ChainStartResponse) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +func (c *beaconServiceClient) CanonicalHead(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.BeaconBlock, error) { + out := new(v1.BeaconBlock) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/CanonicalHead", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *beaconServiceClient) LatestAttestation(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (BeaconService_LatestAttestationClient, error) { + stream, err := c.cc.NewStream(ctx, &_BeaconService_serviceDesc.Streams[1], "/ethereum.beacon.rpc.v1.BeaconService/LatestAttestation", opts...) + if err != nil { + return nil, err + } + x := &beaconServiceLatestAttestationClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type BeaconService_LatestAttestationClient interface { + Recv() (*v1.Attestation, error) + grpc.ClientStream +} + +type beaconServiceLatestAttestationClient struct { + grpc.ClientStream +} + +func (x *beaconServiceLatestAttestationClient) Recv() (*v1.Attestation, error) { + m := new(v1.Attestation) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +func (c *beaconServiceClient) PendingDeposits(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PendingDepositsResponse, error) { + out := new(PendingDepositsResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/PendingDeposits", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *beaconServiceClient) Eth1Data(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Eth1DataResponse, error) { + out := new(Eth1DataResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/Eth1Data", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *beaconServiceClient) ForkData(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1.Fork, error) { + out := new(v1.Fork) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/ForkData", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *beaconServiceClient) BlockTree(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BlockTreeResponse, error) { + out := new(BlockTreeResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/BlockTree", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *beaconServiceClient) BlockTreeBySlots(ctx context.Context, in *TreeBlockSlotRequest, opts ...grpc.CallOption) (*BlockTreeResponse, error) { + out := new(BlockTreeResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.BeaconService/BlockTreeBySlots", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// BeaconServiceServer is the server API for BeaconService service. +type BeaconServiceServer interface { + WaitForChainStart(*empty.Empty, BeaconService_WaitForChainStartServer) error + CanonicalHead(context.Context, *empty.Empty) (*v1.BeaconBlock, error) + LatestAttestation(*empty.Empty, BeaconService_LatestAttestationServer) error + PendingDeposits(context.Context, *empty.Empty) (*PendingDepositsResponse, error) + Eth1Data(context.Context, *empty.Empty) (*Eth1DataResponse, error) + ForkData(context.Context, *empty.Empty) (*v1.Fork, error) + BlockTree(context.Context, *empty.Empty) (*BlockTreeResponse, error) + BlockTreeBySlots(context.Context, *TreeBlockSlotRequest) (*BlockTreeResponse, error) +} + +func RegisterBeaconServiceServer(s *grpc.Server, srv BeaconServiceServer) { + s.RegisterService(&_BeaconService_serviceDesc, srv) +} + +func _BeaconService_WaitForChainStart_Handler(srv interface{}, stream grpc.ServerStream) error { + m := new(empty.Empty) + if err := stream.RecvMsg(m); err != nil { + return err + } + return srv.(BeaconServiceServer).WaitForChainStart(m, &beaconServiceWaitForChainStartServer{stream}) +} + +type BeaconService_WaitForChainStartServer interface { + Send(*ChainStartResponse) error + grpc.ServerStream +} + +type beaconServiceWaitForChainStartServer struct { + grpc.ServerStream +} + +func (x *beaconServiceWaitForChainStartServer) Send(m *ChainStartResponse) error { + return x.ServerStream.SendMsg(m) +} + +func _BeaconService_CanonicalHead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(empty.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).CanonicalHead(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/CanonicalHead", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).CanonicalHead(ctx, req.(*empty.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _BeaconService_LatestAttestation_Handler(srv interface{}, stream grpc.ServerStream) error { + m := new(empty.Empty) + if err := stream.RecvMsg(m); err != nil { + return err + } + return srv.(BeaconServiceServer).LatestAttestation(m, &beaconServiceLatestAttestationServer{stream}) +} + +type BeaconService_LatestAttestationServer interface { + Send(*v1.Attestation) error + grpc.ServerStream +} + +type beaconServiceLatestAttestationServer struct { + grpc.ServerStream +} + +func (x *beaconServiceLatestAttestationServer) Send(m *v1.Attestation) error { + return x.ServerStream.SendMsg(m) +} + +func _BeaconService_PendingDeposits_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(empty.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).PendingDeposits(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/PendingDeposits", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).PendingDeposits(ctx, req.(*empty.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _BeaconService_Eth1Data_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(empty.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).Eth1Data(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/Eth1Data", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).Eth1Data(ctx, req.(*empty.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _BeaconService_ForkData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(empty.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).ForkData(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/ForkData", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).ForkData(ctx, req.(*empty.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _BeaconService_BlockTree_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(empty.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).BlockTree(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/BlockTree", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).BlockTree(ctx, req.(*empty.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _BeaconService_BlockTreeBySlots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(TreeBlockSlotRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(BeaconServiceServer).BlockTreeBySlots(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.BeaconService/BlockTreeBySlots", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(BeaconServiceServer).BlockTreeBySlots(ctx, req.(*TreeBlockSlotRequest)) + } + return interceptor(ctx, in, info, handler) +} + +var _BeaconService_serviceDesc = grpc.ServiceDesc{ + ServiceName: "ethereum.beacon.rpc.v1.BeaconService", + HandlerType: (*BeaconServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "CanonicalHead", + Handler: _BeaconService_CanonicalHead_Handler, + }, + { + MethodName: "PendingDeposits", + Handler: _BeaconService_PendingDeposits_Handler, + }, + { + MethodName: "Eth1Data", + Handler: _BeaconService_Eth1Data_Handler, + }, + { + MethodName: "ForkData", + Handler: _BeaconService_ForkData_Handler, + }, + { + MethodName: "BlockTree", + Handler: _BeaconService_BlockTree_Handler, + }, + { + MethodName: "BlockTreeBySlots", + Handler: _BeaconService_BlockTreeBySlots_Handler, + }, + }, + Streams: []grpc.StreamDesc{ + { + StreamName: "WaitForChainStart", + Handler: _BeaconService_WaitForChainStart_Handler, + ServerStreams: true, + }, + { + StreamName: "LatestAttestation", + Handler: _BeaconService_LatestAttestation_Handler, + ServerStreams: true, + }, + }, + Metadata: "proto/beacon/rpc/v1/services.proto", +} + +// AttesterServiceClient is the client API for AttesterService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. +type AttesterServiceClient interface { + AttestHead(ctx context.Context, in *v1.Attestation, opts ...grpc.CallOption) (*AttestResponse, error) + AttestationDataAtSlot(ctx context.Context, in *AttestationDataRequest, opts ...grpc.CallOption) (*AttestationDataResponse, error) +} + +type attesterServiceClient struct { + cc *grpc.ClientConn +} + +func NewAttesterServiceClient(cc *grpc.ClientConn) AttesterServiceClient { + return &attesterServiceClient{cc} +} + +func (c *attesterServiceClient) AttestHead(ctx context.Context, in *v1.Attestation, opts ...grpc.CallOption) (*AttestResponse, error) { + out := new(AttestResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.AttesterService/AttestHead", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *attesterServiceClient) AttestationDataAtSlot(ctx context.Context, in *AttestationDataRequest, opts ...grpc.CallOption) (*AttestationDataResponse, error) { + out := new(AttestationDataResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.AttesterService/AttestationDataAtSlot", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// AttesterServiceServer is the server API for AttesterService service. +type AttesterServiceServer interface { + AttestHead(context.Context, *v1.Attestation) (*AttestResponse, error) + AttestationDataAtSlot(context.Context, *AttestationDataRequest) (*AttestationDataResponse, error) +} + +func RegisterAttesterServiceServer(s *grpc.Server, srv AttesterServiceServer) { + s.RegisterService(&_AttesterService_serviceDesc, srv) +} + +func _AttesterService_AttestHead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(v1.Attestation) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AttesterServiceServer).AttestHead(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.AttesterService/AttestHead", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AttesterServiceServer).AttestHead(ctx, req.(*v1.Attestation)) + } + return interceptor(ctx, in, info, handler) +} + +func _AttesterService_AttestationDataAtSlot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AttestationDataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AttesterServiceServer).AttestationDataAtSlot(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.AttesterService/AttestationDataAtSlot", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AttesterServiceServer).AttestationDataAtSlot(ctx, req.(*AttestationDataRequest)) + } + return interceptor(ctx, in, info, handler) +} + +var _AttesterService_serviceDesc = grpc.ServiceDesc{ + ServiceName: "ethereum.beacon.rpc.v1.AttesterService", + HandlerType: (*AttesterServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "AttestHead", + Handler: _AttesterService_AttestHead_Handler, + }, + { + MethodName: "AttestationDataAtSlot", + Handler: _AttesterService_AttestationDataAtSlot_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "proto/beacon/rpc/v1/services.proto", +} + +// ProposerServiceClient is the client API for ProposerService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. +type ProposerServiceClient interface { + ProposerIndex(ctx context.Context, in *ProposerIndexRequest, opts ...grpc.CallOption) (*ProposerIndexResponse, error) + PendingAttestations(ctx context.Context, in *PendingAttestationsRequest, opts ...grpc.CallOption) (*PendingAttestationsResponse, error) + ProposeBlock(ctx context.Context, in *v1.BeaconBlock, opts ...grpc.CallOption) (*ProposeResponse, error) + ComputeStateRoot(ctx context.Context, in *v1.BeaconBlock, opts ...grpc.CallOption) (*StateRootResponse, error) +} + +type proposerServiceClient struct { + cc *grpc.ClientConn +} + +func NewProposerServiceClient(cc *grpc.ClientConn) ProposerServiceClient { + return &proposerServiceClient{cc} +} + +func (c *proposerServiceClient) ProposerIndex(ctx context.Context, in *ProposerIndexRequest, opts ...grpc.CallOption) (*ProposerIndexResponse, error) { + out := new(ProposerIndexResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ProposerService/ProposerIndex", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *proposerServiceClient) PendingAttestations(ctx context.Context, in *PendingAttestationsRequest, opts ...grpc.CallOption) (*PendingAttestationsResponse, error) { + out := new(PendingAttestationsResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ProposerService/PendingAttestations", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *proposerServiceClient) ProposeBlock(ctx context.Context, in *v1.BeaconBlock, opts ...grpc.CallOption) (*ProposeResponse, error) { + out := new(ProposeResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ProposerService/ProposeBlock", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *proposerServiceClient) ComputeStateRoot(ctx context.Context, in *v1.BeaconBlock, opts ...grpc.CallOption) (*StateRootResponse, error) { + out := new(StateRootResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ProposerService/ComputeStateRoot", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// ProposerServiceServer is the server API for ProposerService service. +type ProposerServiceServer interface { + ProposerIndex(context.Context, *ProposerIndexRequest) (*ProposerIndexResponse, error) + PendingAttestations(context.Context, *PendingAttestationsRequest) (*PendingAttestationsResponse, error) + ProposeBlock(context.Context, *v1.BeaconBlock) (*ProposeResponse, error) + ComputeStateRoot(context.Context, *v1.BeaconBlock) (*StateRootResponse, error) +} + +func RegisterProposerServiceServer(s *grpc.Server, srv ProposerServiceServer) { + s.RegisterService(&_ProposerService_serviceDesc, srv) +} + +func _ProposerService_ProposerIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ProposerIndexRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ProposerServiceServer).ProposerIndex(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ProposerService/ProposerIndex", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ProposerServiceServer).ProposerIndex(ctx, req.(*ProposerIndexRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ProposerService_PendingAttestations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PendingAttestationsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ProposerServiceServer).PendingAttestations(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ProposerService/PendingAttestations", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ProposerServiceServer).PendingAttestations(ctx, req.(*PendingAttestationsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ProposerService_ProposeBlock_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(v1.BeaconBlock) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ProposerServiceServer).ProposeBlock(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ProposerService/ProposeBlock", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ProposerServiceServer).ProposeBlock(ctx, req.(*v1.BeaconBlock)) + } + return interceptor(ctx, in, info, handler) +} + +func _ProposerService_ComputeStateRoot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(v1.BeaconBlock) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ProposerServiceServer).ComputeStateRoot(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ProposerService/ComputeStateRoot", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ProposerServiceServer).ComputeStateRoot(ctx, req.(*v1.BeaconBlock)) + } + return interceptor(ctx, in, info, handler) +} + +var _ProposerService_serviceDesc = grpc.ServiceDesc{ + ServiceName: "ethereum.beacon.rpc.v1.ProposerService", + HandlerType: (*ProposerServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "ProposerIndex", + Handler: _ProposerService_ProposerIndex_Handler, + }, + { + MethodName: "PendingAttestations", + Handler: _ProposerService_PendingAttestations_Handler, + }, + { + MethodName: "ProposeBlock", + Handler: _ProposerService_ProposeBlock_Handler, + }, + { + MethodName: "ComputeStateRoot", + Handler: _ProposerService_ComputeStateRoot_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "proto/beacon/rpc/v1/services.proto", +} + +// ValidatorServiceClient is the client API for ValidatorService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. +type ValidatorServiceClient interface { + WaitForActivation(ctx context.Context, in *ValidatorActivationRequest, opts ...grpc.CallOption) (ValidatorService_WaitForActivationClient, error) + ValidatorIndex(ctx context.Context, in *ValidatorIndexRequest, opts ...grpc.CallOption) (*ValidatorIndexResponse, error) + CommitteeAssignment(ctx context.Context, in *CommitteeAssignmentsRequest, opts ...grpc.CallOption) (*CommitteeAssignmentResponse, error) + ValidatorStatus(ctx context.Context, in *ValidatorIndexRequest, opts ...grpc.CallOption) (*ValidatorStatusResponse, error) + ValidatorPerformance(ctx context.Context, in *ValidatorPerformanceRequest, opts ...grpc.CallOption) (*ValidatorPerformanceResponse, error) + ExitedValidators(ctx context.Context, in *ExitedValidatorsRequest, opts ...grpc.CallOption) (*ExitedValidatorsResponse, error) +} + +type validatorServiceClient struct { + cc *grpc.ClientConn +} + +func NewValidatorServiceClient(cc *grpc.ClientConn) ValidatorServiceClient { + return &validatorServiceClient{cc} +} + +func (c *validatorServiceClient) WaitForActivation(ctx context.Context, in *ValidatorActivationRequest, opts ...grpc.CallOption) (ValidatorService_WaitForActivationClient, error) { + stream, err := c.cc.NewStream(ctx, &_ValidatorService_serviceDesc.Streams[0], "/ethereum.beacon.rpc.v1.ValidatorService/WaitForActivation", opts...) + if err != nil { + return nil, err + } + x := &validatorServiceWaitForActivationClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type ValidatorService_WaitForActivationClient interface { + Recv() (*ValidatorActivationResponse, error) + grpc.ClientStream +} + +type validatorServiceWaitForActivationClient struct { + grpc.ClientStream +} + +func (x *validatorServiceWaitForActivationClient) Recv() (*ValidatorActivationResponse, error) { + m := new(ValidatorActivationResponse) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +func (c *validatorServiceClient) ValidatorIndex(ctx context.Context, in *ValidatorIndexRequest, opts ...grpc.CallOption) (*ValidatorIndexResponse, error) { + out := new(ValidatorIndexResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorIndex", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *validatorServiceClient) CommitteeAssignment(ctx context.Context, in *CommitteeAssignmentsRequest, opts ...grpc.CallOption) (*CommitteeAssignmentResponse, error) { + out := new(CommitteeAssignmentResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ValidatorService/CommitteeAssignment", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *validatorServiceClient) ValidatorStatus(ctx context.Context, in *ValidatorIndexRequest, opts ...grpc.CallOption) (*ValidatorStatusResponse, error) { + out := new(ValidatorStatusResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorStatus", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *validatorServiceClient) ValidatorPerformance(ctx context.Context, in *ValidatorPerformanceRequest, opts ...grpc.CallOption) (*ValidatorPerformanceResponse, error) { + out := new(ValidatorPerformanceResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorPerformance", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *validatorServiceClient) ExitedValidators(ctx context.Context, in *ExitedValidatorsRequest, opts ...grpc.CallOption) (*ExitedValidatorsResponse, error) { + out := new(ExitedValidatorsResponse) + err := c.cc.Invoke(ctx, "/ethereum.beacon.rpc.v1.ValidatorService/ExitedValidators", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// ValidatorServiceServer is the server API for ValidatorService service. +type ValidatorServiceServer interface { + WaitForActivation(*ValidatorActivationRequest, ValidatorService_WaitForActivationServer) error + ValidatorIndex(context.Context, *ValidatorIndexRequest) (*ValidatorIndexResponse, error) + CommitteeAssignment(context.Context, *CommitteeAssignmentsRequest) (*CommitteeAssignmentResponse, error) + ValidatorStatus(context.Context, *ValidatorIndexRequest) (*ValidatorStatusResponse, error) + ValidatorPerformance(context.Context, *ValidatorPerformanceRequest) (*ValidatorPerformanceResponse, error) + ExitedValidators(context.Context, *ExitedValidatorsRequest) (*ExitedValidatorsResponse, error) +} + +func RegisterValidatorServiceServer(s *grpc.Server, srv ValidatorServiceServer) { + s.RegisterService(&_ValidatorService_serviceDesc, srv) +} + +func _ValidatorService_WaitForActivation_Handler(srv interface{}, stream grpc.ServerStream) error { + m := new(ValidatorActivationRequest) + if err := stream.RecvMsg(m); err != nil { + return err + } + return srv.(ValidatorServiceServer).WaitForActivation(m, &validatorServiceWaitForActivationServer{stream}) +} + +type ValidatorService_WaitForActivationServer interface { + Send(*ValidatorActivationResponse) error + grpc.ServerStream +} + +type validatorServiceWaitForActivationServer struct { + grpc.ServerStream +} + +func (x *validatorServiceWaitForActivationServer) Send(m *ValidatorActivationResponse) error { + return x.ServerStream.SendMsg(m) +} + +func _ValidatorService_ValidatorIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ValidatorIndexRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ValidatorServiceServer).ValidatorIndex(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorIndex", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ValidatorServiceServer).ValidatorIndex(ctx, req.(*ValidatorIndexRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ValidatorService_CommitteeAssignment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(CommitteeAssignmentsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ValidatorServiceServer).CommitteeAssignment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ValidatorService/CommitteeAssignment", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ValidatorServiceServer).CommitteeAssignment(ctx, req.(*CommitteeAssignmentsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ValidatorService_ValidatorStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ValidatorIndexRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ValidatorServiceServer).ValidatorStatus(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorStatus", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ValidatorServiceServer).ValidatorStatus(ctx, req.(*ValidatorIndexRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ValidatorService_ValidatorPerformance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ValidatorPerformanceRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ValidatorServiceServer).ValidatorPerformance(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ValidatorService/ValidatorPerformance", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ValidatorServiceServer).ValidatorPerformance(ctx, req.(*ValidatorPerformanceRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _ValidatorService_ExitedValidators_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ExitedValidatorsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ValidatorServiceServer).ExitedValidators(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ethereum.beacon.rpc.v1.ValidatorService/ExitedValidators", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ValidatorServiceServer).ExitedValidators(ctx, req.(*ExitedValidatorsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +var _ValidatorService_serviceDesc = grpc.ServiceDesc{ + ServiceName: "ethereum.beacon.rpc.v1.ValidatorService", + HandlerType: (*ValidatorServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "ValidatorIndex", + Handler: _ValidatorService_ValidatorIndex_Handler, + }, + { + MethodName: "CommitteeAssignment", + Handler: _ValidatorService_CommitteeAssignment_Handler, + }, + { + MethodName: "ValidatorStatus", + Handler: _ValidatorService_ValidatorStatus_Handler, + }, + { + MethodName: "ValidatorPerformance", + Handler: _ValidatorService_ValidatorPerformance_Handler, + }, + { + MethodName: "ExitedValidators", + Handler: _ValidatorService_ExitedValidators_Handler, + }, + }, + Streams: []grpc.StreamDesc{ + { + StreamName: "WaitForActivation", + Handler: _ValidatorService_WaitForActivation_Handler, + ServerStreams: true, + }, + }, + Metadata: "proto/beacon/rpc/v1/services.proto", +} diff --git a/proto/beacon/rpc/v1_gateway/services.pb.gw.go b/proto/beacon/rpc/v1_gateway/services.pb.gw.go new file mode 100755 index 0000000000..1136b343b3 --- /dev/null +++ b/proto/beacon/rpc/v1_gateway/services.pb.gw.go @@ -0,0 +1,108 @@ +// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT. +// source: proto/beacon/rpc/v1/services.proto + +/* +Package ethereum_beacon_rpc_v1 is a reverse proxy. + +It translates gRPC into RESTful JSON APIs. +*/ +package ethereum_beacon_rpc_v1 + +import ( + "context" + "io" + "net/http" + + "github.com/golang/protobuf/proto" + "github.com/golang/protobuf/ptypes/empty" + "github.com/grpc-ecosystem/grpc-gateway/runtime" + "github.com/grpc-ecosystem/grpc-gateway/utilities" + "google.golang.org/grpc" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/grpclog" + "google.golang.org/grpc/status" +) + +var _ codes.Code +var _ io.Reader +var _ status.Status +var _ = runtime.String +var _ = utilities.NewDoubleArray + +func request_BeaconService_BlockTree_0(ctx context.Context, marshaler runtime.Marshaler, client BeaconServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { + var protoReq empty.Empty + var metadata runtime.ServerMetadata + + msg, err := client.BlockTree(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) + return msg, metadata, err + +} + +// RegisterBeaconServiceHandlerFromEndpoint is same as RegisterBeaconServiceHandler but +// automatically dials to "endpoint" and closes the connection when "ctx" gets done. +func RegisterBeaconServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) { + conn, err := grpc.Dial(endpoint, opts...) + if err != nil { + return err + } + defer func() { + if err != nil { + if cerr := conn.Close(); cerr != nil { + grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr) + } + return + } + go func() { + <-ctx.Done() + if cerr := conn.Close(); cerr != nil { + grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr) + } + }() + }() + + return RegisterBeaconServiceHandler(ctx, mux, conn) +} + +// RegisterBeaconServiceHandler registers the http handlers for service BeaconService to "mux". +// The handlers forward requests to the grpc endpoint over "conn". +func RegisterBeaconServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error { + return RegisterBeaconServiceHandlerClient(ctx, mux, NewBeaconServiceClient(conn)) +} + +// RegisterBeaconServiceHandlerClient registers the http handlers for service BeaconService +// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BeaconServiceClient". +// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BeaconServiceClient" +// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in +// "BeaconServiceClient" to call the correct interceptors. +func RegisterBeaconServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BeaconServiceClient) error { + + mux.Handle("GET", pattern_BeaconService_BlockTree_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { + ctx, cancel := context.WithCancel(req.Context()) + defer cancel() + inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) + rctx, err := runtime.AnnotateContext(ctx, mux, req) + if err != nil { + runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) + return + } + resp, md, err := request_BeaconService_BlockTree_0(rctx, inboundMarshaler, client, req, pathParams) + ctx = runtime.NewServerMetadataContext(ctx, md) + if err != nil { + runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) + return + } + + forward_BeaconService_BlockTree_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) + + }) + + return nil +} + +var ( + pattern_BeaconService_BlockTree_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v1", "beacon", "blocktree"}, "")) +) + +var ( + forward_BeaconService_BlockTree_0 = runtime.ForwardResponseMessage +) diff --git a/proto/sharding/p2p/v1/messages.pb.go b/proto/sharding/p2p/v1/messages.pb.go index ba268c5f4b..61228b93de 100644 --- a/proto/sharding/p2p/v1/messages.pb.go +++ b/proto/sharding/p2p/v1/messages.pb.go @@ -5,9 +5,10 @@ package ethereum_sharding_p2p_v1 import ( fmt "fmt" - proto "github.com/gogo/protobuf/proto" io "io" math "math" + + proto "github.com/gogo/protobuf/proto" ) // Reference imports to suppress errors if they are not otherwise used. diff --git a/validator/internal/attester_service_mock.go b/validator/internal/attester_service_mock.go index 2eeb0c72ec..dbfc69e693 100644 --- a/validator/internal/attester_service_mock.go +++ b/validator/internal/attester_service_mock.go @@ -6,11 +6,12 @@ package internal import ( context "context" + reflect "reflect" + gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" v10 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" grpc "google.golang.org/grpc" - reflect "reflect" ) // MockAttesterServiceClient is a mock of AttesterServiceClient interface diff --git a/validator/internal/beacon_service_mock.go b/validator/internal/beacon_service_mock.go index 9be213c105..4431c3b59f 100644 --- a/validator/internal/beacon_service_mock.go +++ b/validator/internal/beacon_service_mock.go @@ -6,13 +6,14 @@ package internal import ( context "context" + reflect "reflect" + types "github.com/gogo/protobuf/types" gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" v10 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" grpc "google.golang.org/grpc" metadata "google.golang.org/grpc/metadata" - reflect "reflect" ) // MockBeaconServiceClient is a mock of BeaconServiceClient interface diff --git a/validator/internal/proposer_service_mock.go b/validator/internal/proposer_service_mock.go index 7d197b2b4e..80b42740d9 100644 --- a/validator/internal/proposer_service_mock.go +++ b/validator/internal/proposer_service_mock.go @@ -6,11 +6,12 @@ package internal import ( context "context" + reflect "reflect" + gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1" v10 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" grpc "google.golang.org/grpc" - reflect "reflect" ) // MockProposerServiceClient is a mock of ProposerServiceClient interface diff --git a/validator/internal/validator_service_mock.go b/validator/internal/validator_service_mock.go index e408154265..936408a295 100644 --- a/validator/internal/validator_service_mock.go +++ b/validator/internal/validator_service_mock.go @@ -6,11 +6,12 @@ package internal import ( context "context" + reflect "reflect" + gomock "github.com/golang/mock/gomock" v1 "github.com/prysmaticlabs/prysm/proto/beacon/rpc/v1" grpc "google.golang.org/grpc" metadata "google.golang.org/grpc/metadata" - reflect "reflect" ) // MockValidatorServiceClient is a mock of ValidatorServiceClient interface