ethereum_beacon_rpc_v1

package
v0.0.0-...-c85edb6 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2019 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthServices = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowServices   = fmt.Errorf("proto: integer overflow")
)
View Source
var ValidatorRole_name = map[int32]string{
	0: "UNKNOWN",
	1: "ATTESTER",
	2: "PROPOSER",
}
View Source
var ValidatorRole_value = map[string]int32{
	"UNKNOWN":  0,
	"ATTESTER": 1,
	"PROPOSER": 2,
}

Functions

func RegisterAttesterServiceServer

func RegisterAttesterServiceServer(s *grpc.Server, srv AttesterServiceServer)

func RegisterBeaconServiceServer

func RegisterBeaconServiceServer(s *grpc.Server, srv BeaconServiceServer)

func RegisterProposerServiceServer

func RegisterProposerServiceServer(s *grpc.Server, srv ProposerServiceServer)

func RegisterValidatorServiceServer

func RegisterValidatorServiceServer(s *grpc.Server, srv ValidatorServiceServer)

Types

type Assignment

type Assignment struct {
	PublicKey            []byte   `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Shard                uint64   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	AttesterSlot         uint64   `protobuf:"varint,3,opt,name=attester_slot,json=attesterSlot,proto3" json:"attester_slot,omitempty"`
	ProposerSlot         uint64   `protobuf:"varint,4,opt,name=proposer_slot,json=proposerSlot,proto3" json:"proposer_slot,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Assignment) Descriptor

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

func (*Assignment) GetAttesterSlot

func (m *Assignment) GetAttesterSlot() uint64

func (*Assignment) GetProposerSlot

func (m *Assignment) GetProposerSlot() uint64

func (*Assignment) GetPublicKey

func (m *Assignment) GetPublicKey() []byte

func (*Assignment) GetShard

func (m *Assignment) GetShard() uint64

func (*Assignment) Marshal

func (m *Assignment) Marshal() (dAtA []byte, err error)

func (*Assignment) MarshalTo

func (m *Assignment) MarshalTo(dAtA []byte) (int, error)

func (*Assignment) ProtoMessage

func (*Assignment) ProtoMessage()

func (*Assignment) Reset

func (m *Assignment) Reset()

func (*Assignment) Size

func (m *Assignment) Size() (n int)

func (*Assignment) String

func (m *Assignment) String() string

func (*Assignment) Unmarshal

func (m *Assignment) Unmarshal(dAtA []byte) error

func (*Assignment) XXX_DiscardUnknown

func (m *Assignment) XXX_DiscardUnknown()

func (*Assignment) XXX_Marshal

func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Assignment) XXX_Merge

func (dst *Assignment) XXX_Merge(src proto.Message)

func (*Assignment) XXX_Size

func (m *Assignment) XXX_Size() int

func (*Assignment) XXX_Unmarshal

func (m *Assignment) XXX_Unmarshal(b []byte) error

type AttestResponse

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 (*AttestResponse) Descriptor

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

func (*AttestResponse) GetAttestationHash

func (m *AttestResponse) GetAttestationHash() []byte

func (*AttestResponse) Marshal

func (m *AttestResponse) Marshal() (dAtA []byte, err error)

func (*AttestResponse) MarshalTo

func (m *AttestResponse) MarshalTo(dAtA []byte) (int, error)

func (*AttestResponse) ProtoMessage

func (*AttestResponse) ProtoMessage()

func (*AttestResponse) Reset

func (m *AttestResponse) Reset()

func (*AttestResponse) Size

func (m *AttestResponse) Size() (n int)

func (*AttestResponse) String

func (m *AttestResponse) String() string

func (*AttestResponse) Unmarshal

func (m *AttestResponse) Unmarshal(dAtA []byte) error

func (*AttestResponse) XXX_DiscardUnknown

func (m *AttestResponse) XXX_DiscardUnknown()

func (*AttestResponse) XXX_Marshal

func (m *AttestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttestResponse) XXX_Merge

func (dst *AttestResponse) XXX_Merge(src proto.Message)

func (*AttestResponse) XXX_Size

func (m *AttestResponse) XXX_Size() int

func (*AttestResponse) XXX_Unmarshal

func (m *AttestResponse) XXX_Unmarshal(b []byte) error

type AttestationInfoRequest

type AttestationInfoRequest struct {
	Slot                 uint64   `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Shard                uint64   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AttestationInfoRequest) Descriptor

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

func (*AttestationInfoRequest) GetShard

func (m *AttestationInfoRequest) GetShard() uint64

func (*AttestationInfoRequest) GetSlot

func (m *AttestationInfoRequest) GetSlot() uint64

func (*AttestationInfoRequest) Marshal

func (m *AttestationInfoRequest) Marshal() (dAtA []byte, err error)

func (*AttestationInfoRequest) MarshalTo

func (m *AttestationInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*AttestationInfoRequest) ProtoMessage

func (*AttestationInfoRequest) ProtoMessage()

func (*AttestationInfoRequest) Reset

func (m *AttestationInfoRequest) Reset()

func (*AttestationInfoRequest) Size

func (m *AttestationInfoRequest) Size() (n int)

func (*AttestationInfoRequest) String

func (m *AttestationInfoRequest) String() string

func (*AttestationInfoRequest) Unmarshal

func (m *AttestationInfoRequest) Unmarshal(dAtA []byte) error

func (*AttestationInfoRequest) XXX_DiscardUnknown

func (m *AttestationInfoRequest) XXX_DiscardUnknown()

func (*AttestationInfoRequest) XXX_Marshal

func (m *AttestationInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttestationInfoRequest) XXX_Merge

func (dst *AttestationInfoRequest) XXX_Merge(src proto.Message)

func (*AttestationInfoRequest) XXX_Size

func (m *AttestationInfoRequest) XXX_Size() int

func (*AttestationInfoRequest) XXX_Unmarshal

func (m *AttestationInfoRequest) XXX_Unmarshal(b []byte) error

type AttestationInfoResponse

type AttestationInfoResponse struct {
	BeaconBlockRootHash32     []byte   `` /* 128-byte string literal not displayed */
	EpochBoundaryRootHash32   []byte   `` /* 134-byte string literal not displayed */
	JustifiedEpoch            uint64   `protobuf:"varint,3,opt,name=justified_epoch,json=justifiedEpoch,proto3" json:"justified_epoch,omitempty"`
	JustifiedBlockRootHash32  []byte   `` /* 137-byte string literal not displayed */
	LatestCrosslinkRootHash32 []byte   `` /* 140-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{} `json:"-"`
	XXX_unrecognized          []byte   `json:"-"`
	XXX_sizecache             int32    `json:"-"`
}

func (*AttestationInfoResponse) Descriptor

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

func (*AttestationInfoResponse) GetBeaconBlockRootHash32

func (m *AttestationInfoResponse) GetBeaconBlockRootHash32() []byte

func (*AttestationInfoResponse) GetEpochBoundaryRootHash32

func (m *AttestationInfoResponse) GetEpochBoundaryRootHash32() []byte

func (*AttestationInfoResponse) GetJustifiedBlockRootHash32

func (m *AttestationInfoResponse) GetJustifiedBlockRootHash32() []byte

func (*AttestationInfoResponse) GetJustifiedEpoch

func (m *AttestationInfoResponse) GetJustifiedEpoch() uint64

func (*AttestationInfoResponse) GetLatestCrosslinkRootHash32

func (m *AttestationInfoResponse) GetLatestCrosslinkRootHash32() []byte

func (*AttestationInfoResponse) Marshal

func (m *AttestationInfoResponse) Marshal() (dAtA []byte, err error)

func (*AttestationInfoResponse) MarshalTo

func (m *AttestationInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*AttestationInfoResponse) ProtoMessage

func (*AttestationInfoResponse) ProtoMessage()

func (*AttestationInfoResponse) Reset

func (m *AttestationInfoResponse) Reset()

func (*AttestationInfoResponse) Size

func (m *AttestationInfoResponse) Size() (n int)

func (*AttestationInfoResponse) String

func (m *AttestationInfoResponse) String() string

func (*AttestationInfoResponse) Unmarshal

func (m *AttestationInfoResponse) Unmarshal(dAtA []byte) error

func (*AttestationInfoResponse) XXX_DiscardUnknown

func (m *AttestationInfoResponse) XXX_DiscardUnknown()

func (*AttestationInfoResponse) XXX_Marshal

func (m *AttestationInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttestationInfoResponse) XXX_Merge

func (dst *AttestationInfoResponse) XXX_Merge(src proto.Message)

func (*AttestationInfoResponse) XXX_Size

func (m *AttestationInfoResponse) XXX_Size() int

func (*AttestationInfoResponse) XXX_Unmarshal

func (m *AttestationInfoResponse) XXX_Unmarshal(b []byte) error

type AttesterServiceClient

type AttesterServiceClient interface {
	AttestHead(ctx context.Context, in *v1.Attestation, opts ...grpc.CallOption) (*AttestResponse, error)
	CrosslinkCommitteesAtSlot(ctx context.Context, in *CrosslinkCommitteeRequest, opts ...grpc.CallOption) (*CrosslinkCommitteeResponse, error)
	AttestationInfoAtSlot(ctx context.Context, in *AttestationInfoRequest, opts ...grpc.CallOption) (*AttestationInfoResponse, error)
}

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.

func NewAttesterServiceClient

func NewAttesterServiceClient(cc *grpc.ClientConn) AttesterServiceClient

type AttesterServiceServer

type AttesterServiceServer interface {
	AttestHead(context.Context, *v1.Attestation) (*AttestResponse, error)
	CrosslinkCommitteesAtSlot(context.Context, *CrosslinkCommitteeRequest) (*CrosslinkCommitteeResponse, error)
	AttestationInfoAtSlot(context.Context, *AttestationInfoRequest) (*AttestationInfoResponse, error)
}

AttesterServiceServer is the server API for AttesterService service.

type BeaconServiceClient

type BeaconServiceClient interface {
	WaitForChainStart(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (BeaconService_WaitForChainStartClient, error)
	CanonicalHead(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*v1.BeaconBlock, error)
	LatestAttestation(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (BeaconService_LatestAttestationClient, error)
	PendingDeposits(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*PendingDepositsResponse, error)
	Eth1Data(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Eth1DataResponse, error)
}

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.

func NewBeaconServiceClient

func NewBeaconServiceClient(cc *grpc.ClientConn) BeaconServiceClient

type BeaconServiceServer

type BeaconServiceServer interface {
	WaitForChainStart(*types.Empty, BeaconService_WaitForChainStartServer) error
	CanonicalHead(context.Context, *types.Empty) (*v1.BeaconBlock, error)
	LatestAttestation(*types.Empty, BeaconService_LatestAttestationServer) error
	PendingDeposits(context.Context, *types.Empty) (*PendingDepositsResponse, error)
	Eth1Data(context.Context, *types.Empty) (*Eth1DataResponse, error)
}

BeaconServiceServer is the server API for BeaconService service.

type BeaconService_LatestAttestationClient

type BeaconService_LatestAttestationClient interface {
	Recv() (*v1.Attestation, error)
	grpc.ClientStream
}

type BeaconService_LatestAttestationServer

type BeaconService_LatestAttestationServer interface {
	Send(*v1.Attestation) error
	grpc.ServerStream
}

type BeaconService_WaitForChainStartClient

type BeaconService_WaitForChainStartClient interface {
	Recv() (*ChainStartResponse, error)
	grpc.ClientStream
}

type BeaconService_WaitForChainStartServer

type BeaconService_WaitForChainStartServer interface {
	Send(*ChainStartResponse) error
	grpc.ServerStream
}

type ChainStartResponse

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 (*ChainStartResponse) Descriptor

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

func (*ChainStartResponse) GetGenesisTime

func (m *ChainStartResponse) GetGenesisTime() uint64

func (*ChainStartResponse) GetStarted

func (m *ChainStartResponse) GetStarted() bool

func (*ChainStartResponse) Marshal

func (m *ChainStartResponse) Marshal() (dAtA []byte, err error)

func (*ChainStartResponse) MarshalTo

func (m *ChainStartResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChainStartResponse) ProtoMessage

func (*ChainStartResponse) ProtoMessage()

func (*ChainStartResponse) Reset

func (m *ChainStartResponse) Reset()

func (*ChainStartResponse) Size

func (m *ChainStartResponse) Size() (n int)

func (*ChainStartResponse) String

func (m *ChainStartResponse) String() string

func (*ChainStartResponse) Unmarshal

func (m *ChainStartResponse) Unmarshal(dAtA []byte) error

func (*ChainStartResponse) XXX_DiscardUnknown

func (m *ChainStartResponse) XXX_DiscardUnknown()

func (*ChainStartResponse) XXX_Marshal

func (m *ChainStartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChainStartResponse) XXX_Merge

func (dst *ChainStartResponse) XXX_Merge(src proto.Message)

func (*ChainStartResponse) XXX_Size

func (m *ChainStartResponse) XXX_Size() int

func (*ChainStartResponse) XXX_Unmarshal

func (m *ChainStartResponse) XXX_Unmarshal(b []byte) error

type CrosslinkCommitteeRequest

type CrosslinkCommitteeRequest struct {
	Slot                 uint64   `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrosslinkCommitteeRequest) Descriptor

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

func (*CrosslinkCommitteeRequest) GetSlot

func (m *CrosslinkCommitteeRequest) GetSlot() uint64

func (*CrosslinkCommitteeRequest) Marshal

func (m *CrosslinkCommitteeRequest) Marshal() (dAtA []byte, err error)

func (*CrosslinkCommitteeRequest) MarshalTo

func (m *CrosslinkCommitteeRequest) MarshalTo(dAtA []byte) (int, error)

func (*CrosslinkCommitteeRequest) ProtoMessage

func (*CrosslinkCommitteeRequest) ProtoMessage()

func (*CrosslinkCommitteeRequest) Reset

func (m *CrosslinkCommitteeRequest) Reset()

func (*CrosslinkCommitteeRequest) Size

func (m *CrosslinkCommitteeRequest) Size() (n int)

func (*CrosslinkCommitteeRequest) String

func (m *CrosslinkCommitteeRequest) String() string

func (*CrosslinkCommitteeRequest) Unmarshal

func (m *CrosslinkCommitteeRequest) Unmarshal(dAtA []byte) error

func (*CrosslinkCommitteeRequest) XXX_DiscardUnknown

func (m *CrosslinkCommitteeRequest) XXX_DiscardUnknown()

func (*CrosslinkCommitteeRequest) XXX_Marshal

func (m *CrosslinkCommitteeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrosslinkCommitteeRequest) XXX_Merge

func (dst *CrosslinkCommitteeRequest) XXX_Merge(src proto.Message)

func (*CrosslinkCommitteeRequest) XXX_Size

func (m *CrosslinkCommitteeRequest) XXX_Size() int

func (*CrosslinkCommitteeRequest) XXX_Unmarshal

func (m *CrosslinkCommitteeRequest) XXX_Unmarshal(b []byte) error

type CrosslinkCommitteeResponse

type CrosslinkCommitteeResponse 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrosslinkCommitteeResponse) Descriptor

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

func (*CrosslinkCommitteeResponse) GetCommittee

func (m *CrosslinkCommitteeResponse) GetCommittee() []uint64

func (*CrosslinkCommitteeResponse) GetShard

func (m *CrosslinkCommitteeResponse) GetShard() uint64

func (*CrosslinkCommitteeResponse) Marshal

func (m *CrosslinkCommitteeResponse) Marshal() (dAtA []byte, err error)

func (*CrosslinkCommitteeResponse) MarshalTo

func (m *CrosslinkCommitteeResponse) MarshalTo(dAtA []byte) (int, error)

func (*CrosslinkCommitteeResponse) ProtoMessage

func (*CrosslinkCommitteeResponse) ProtoMessage()

func (*CrosslinkCommitteeResponse) Reset

func (m *CrosslinkCommitteeResponse) Reset()

func (*CrosslinkCommitteeResponse) Size

func (m *CrosslinkCommitteeResponse) Size() (n int)

func (*CrosslinkCommitteeResponse) String

func (m *CrosslinkCommitteeResponse) String() string

func (*CrosslinkCommitteeResponse) Unmarshal

func (m *CrosslinkCommitteeResponse) Unmarshal(dAtA []byte) error

func (*CrosslinkCommitteeResponse) XXX_DiscardUnknown

func (m *CrosslinkCommitteeResponse) XXX_DiscardUnknown()

func (*CrosslinkCommitteeResponse) XXX_Marshal

func (m *CrosslinkCommitteeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrosslinkCommitteeResponse) XXX_Merge

func (dst *CrosslinkCommitteeResponse) XXX_Merge(src proto.Message)

func (*CrosslinkCommitteeResponse) XXX_Size

func (m *CrosslinkCommitteeResponse) XXX_Size() int

func (*CrosslinkCommitteeResponse) XXX_Unmarshal

func (m *CrosslinkCommitteeResponse) XXX_Unmarshal(b []byte) error

type Eth1DataResponse

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 (*Eth1DataResponse) Descriptor

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

func (*Eth1DataResponse) GetEth1Data

func (m *Eth1DataResponse) GetEth1Data() *v1.Eth1Data

func (*Eth1DataResponse) Marshal

func (m *Eth1DataResponse) Marshal() (dAtA []byte, err error)

func (*Eth1DataResponse) MarshalTo

func (m *Eth1DataResponse) MarshalTo(dAtA []byte) (int, error)

func (*Eth1DataResponse) ProtoMessage

func (*Eth1DataResponse) ProtoMessage()

func (*Eth1DataResponse) Reset

func (m *Eth1DataResponse) Reset()

func (*Eth1DataResponse) Size

func (m *Eth1DataResponse) Size() (n int)

func (*Eth1DataResponse) String

func (m *Eth1DataResponse) String() string

func (*Eth1DataResponse) Unmarshal

func (m *Eth1DataResponse) Unmarshal(dAtA []byte) error

func (*Eth1DataResponse) XXX_DiscardUnknown

func (m *Eth1DataResponse) XXX_DiscardUnknown()

func (*Eth1DataResponse) XXX_Marshal

func (m *Eth1DataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Eth1DataResponse) XXX_Merge

func (dst *Eth1DataResponse) XXX_Merge(src proto.Message)

func (*Eth1DataResponse) XXX_Size

func (m *Eth1DataResponse) XXX_Size() int

func (*Eth1DataResponse) XXX_Unmarshal

func (m *Eth1DataResponse) XXX_Unmarshal(b []byte) error

type PendingDepositsResponse

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 (*PendingDepositsResponse) Descriptor

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

func (*PendingDepositsResponse) GetPendingDeposits

func (m *PendingDepositsResponse) GetPendingDeposits() []*v1.Deposit

func (*PendingDepositsResponse) Marshal

func (m *PendingDepositsResponse) Marshal() (dAtA []byte, err error)

func (*PendingDepositsResponse) MarshalTo

func (m *PendingDepositsResponse) MarshalTo(dAtA []byte) (int, error)

func (*PendingDepositsResponse) ProtoMessage

func (*PendingDepositsResponse) ProtoMessage()

func (*PendingDepositsResponse) Reset

func (m *PendingDepositsResponse) Reset()

func (*PendingDepositsResponse) Size

func (m *PendingDepositsResponse) Size() (n int)

func (*PendingDepositsResponse) String

func (m *PendingDepositsResponse) String() string

func (*PendingDepositsResponse) Unmarshal

func (m *PendingDepositsResponse) Unmarshal(dAtA []byte) error

func (*PendingDepositsResponse) XXX_DiscardUnknown

func (m *PendingDepositsResponse) XXX_DiscardUnknown()

func (*PendingDepositsResponse) XXX_Marshal

func (m *PendingDepositsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PendingDepositsResponse) XXX_Merge

func (dst *PendingDepositsResponse) XXX_Merge(src proto.Message)

func (*PendingDepositsResponse) XXX_Size

func (m *PendingDepositsResponse) XXX_Size() int

func (*PendingDepositsResponse) XXX_Unmarshal

func (m *PendingDepositsResponse) XXX_Unmarshal(b []byte) error

type ProposeRequest

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"`
	RandaoRevealHash32      []byte           `protobuf:"bytes,3,opt,name=randao_reveal_hash32,json=randaoRevealHash32,proto3" json:"randao_reveal_hash32,omitempty"`
	AttestationBitmask      []byte           `protobuf:"bytes,4,opt,name=attestation_bitmask,json=attestationBitmask,proto3" json:"attestation_bitmask,omitempty"`
	AttestationAggregateSig []uint64         `` /* 140-byte string literal not displayed */
	Timestamp               *types.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}         `json:"-"`
	XXX_unrecognized        []byte           `json:"-"`
	XXX_sizecache           int32            `json:"-"`
}

func (*ProposeRequest) Descriptor

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

func (*ProposeRequest) GetAttestationAggregateSig

func (m *ProposeRequest) GetAttestationAggregateSig() []uint64

func (*ProposeRequest) GetAttestationBitmask

func (m *ProposeRequest) GetAttestationBitmask() []byte

func (*ProposeRequest) GetParentHash

func (m *ProposeRequest) GetParentHash() []byte

func (*ProposeRequest) GetRandaoRevealHash32

func (m *ProposeRequest) GetRandaoRevealHash32() []byte

func (*ProposeRequest) GetSlotNumber

func (m *ProposeRequest) GetSlotNumber() uint64

func (*ProposeRequest) GetTimestamp

func (m *ProposeRequest) GetTimestamp() *types.Timestamp

func (*ProposeRequest) Marshal

func (m *ProposeRequest) Marshal() (dAtA []byte, err error)

func (*ProposeRequest) MarshalTo

func (m *ProposeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ProposeRequest) ProtoMessage

func (*ProposeRequest) ProtoMessage()

func (*ProposeRequest) Reset

func (m *ProposeRequest) Reset()

func (*ProposeRequest) Size

func (m *ProposeRequest) Size() (n int)

func (*ProposeRequest) String

func (m *ProposeRequest) String() string

func (*ProposeRequest) Unmarshal

func (m *ProposeRequest) Unmarshal(dAtA []byte) error

func (*ProposeRequest) XXX_DiscardUnknown

func (m *ProposeRequest) XXX_DiscardUnknown()

func (*ProposeRequest) XXX_Marshal

func (m *ProposeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposeRequest) XXX_Merge

func (dst *ProposeRequest) XXX_Merge(src proto.Message)

func (*ProposeRequest) XXX_Size

func (m *ProposeRequest) XXX_Size() int

func (*ProposeRequest) XXX_Unmarshal

func (m *ProposeRequest) XXX_Unmarshal(b []byte) error

type ProposeResponse

type ProposeResponse struct {
	BlockHash            []byte   `protobuf:"bytes,1,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProposeResponse) Descriptor

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

func (*ProposeResponse) GetBlockHash

func (m *ProposeResponse) GetBlockHash() []byte

func (*ProposeResponse) Marshal

func (m *ProposeResponse) Marshal() (dAtA []byte, err error)

func (*ProposeResponse) MarshalTo

func (m *ProposeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ProposeResponse) ProtoMessage

func (*ProposeResponse) ProtoMessage()

func (*ProposeResponse) Reset

func (m *ProposeResponse) Reset()

func (*ProposeResponse) Size

func (m *ProposeResponse) Size() (n int)

func (*ProposeResponse) String

func (m *ProposeResponse) String() string

func (*ProposeResponse) Unmarshal

func (m *ProposeResponse) Unmarshal(dAtA []byte) error

func (*ProposeResponse) XXX_DiscardUnknown

func (m *ProposeResponse) XXX_DiscardUnknown()

func (*ProposeResponse) XXX_Marshal

func (m *ProposeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposeResponse) XXX_Merge

func (dst *ProposeResponse) XXX_Merge(src proto.Message)

func (*ProposeResponse) XXX_Size

func (m *ProposeResponse) XXX_Size() int

func (*ProposeResponse) XXX_Unmarshal

func (m *ProposeResponse) XXX_Unmarshal(b []byte) error

type ProposerIndexRequest

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 (*ProposerIndexRequest) Descriptor

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

func (*ProposerIndexRequest) GetSlotNumber

func (m *ProposerIndexRequest) GetSlotNumber() uint64

func (*ProposerIndexRequest) Marshal

func (m *ProposerIndexRequest) Marshal() (dAtA []byte, err error)

func (*ProposerIndexRequest) MarshalTo

func (m *ProposerIndexRequest) MarshalTo(dAtA []byte) (int, error)

func (*ProposerIndexRequest) ProtoMessage

func (*ProposerIndexRequest) ProtoMessage()

func (*ProposerIndexRequest) Reset

func (m *ProposerIndexRequest) Reset()

func (*ProposerIndexRequest) Size

func (m *ProposerIndexRequest) Size() (n int)

func (*ProposerIndexRequest) String

func (m *ProposerIndexRequest) String() string

func (*ProposerIndexRequest) Unmarshal

func (m *ProposerIndexRequest) Unmarshal(dAtA []byte) error

func (*ProposerIndexRequest) XXX_DiscardUnknown

func (m *ProposerIndexRequest) XXX_DiscardUnknown()

func (*ProposerIndexRequest) XXX_Marshal

func (m *ProposerIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposerIndexRequest) XXX_Merge

func (dst *ProposerIndexRequest) XXX_Merge(src proto.Message)

func (*ProposerIndexRequest) XXX_Size

func (m *ProposerIndexRequest) XXX_Size() int

func (*ProposerIndexRequest) XXX_Unmarshal

func (m *ProposerIndexRequest) XXX_Unmarshal(b []byte) error

type ProposerIndexResponse

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 (*ProposerIndexResponse) Descriptor

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

func (*ProposerIndexResponse) GetIndex

func (m *ProposerIndexResponse) GetIndex() uint64

func (*ProposerIndexResponse) Marshal

func (m *ProposerIndexResponse) Marshal() (dAtA []byte, err error)

func (*ProposerIndexResponse) MarshalTo

func (m *ProposerIndexResponse) MarshalTo(dAtA []byte) (int, error)

func (*ProposerIndexResponse) ProtoMessage

func (*ProposerIndexResponse) ProtoMessage()

func (*ProposerIndexResponse) Reset

func (m *ProposerIndexResponse) Reset()

func (*ProposerIndexResponse) Size

func (m *ProposerIndexResponse) Size() (n int)

func (*ProposerIndexResponse) String

func (m *ProposerIndexResponse) String() string

func (*ProposerIndexResponse) Unmarshal

func (m *ProposerIndexResponse) Unmarshal(dAtA []byte) error

func (*ProposerIndexResponse) XXX_DiscardUnknown

func (m *ProposerIndexResponse) XXX_DiscardUnknown()

func (*ProposerIndexResponse) XXX_Marshal

func (m *ProposerIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposerIndexResponse) XXX_Merge

func (dst *ProposerIndexResponse) XXX_Merge(src proto.Message)

func (*ProposerIndexResponse) XXX_Size

func (m *ProposerIndexResponse) XXX_Size() int

func (*ProposerIndexResponse) XXX_Unmarshal

func (m *ProposerIndexResponse) XXX_Unmarshal(b []byte) error

type ProposerServiceClient

type ProposerServiceClient interface {
	ProposerIndex(ctx context.Context, in *ProposerIndexRequest, opts ...grpc.CallOption) (*ProposerIndexResponse, 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)
}

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.

func NewProposerServiceClient

func NewProposerServiceClient(cc *grpc.ClientConn) ProposerServiceClient

type ProposerServiceServer

type ProposerServiceServer interface {
	ProposerIndex(context.Context, *ProposerIndexRequest) (*ProposerIndexResponse, error)
	ProposeBlock(context.Context, *v1.BeaconBlock) (*ProposeResponse, error)
	ComputeStateRoot(context.Context, *v1.BeaconBlock) (*StateRootResponse, error)
}

ProposerServiceServer is the server API for ProposerService service.

type StateRootResponse

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 (*StateRootResponse) Descriptor

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

func (*StateRootResponse) GetStateRoot

func (m *StateRootResponse) GetStateRoot() []byte

func (*StateRootResponse) Marshal

func (m *StateRootResponse) Marshal() (dAtA []byte, err error)

func (*StateRootResponse) MarshalTo

func (m *StateRootResponse) MarshalTo(dAtA []byte) (int, error)

func (*StateRootResponse) ProtoMessage

func (*StateRootResponse) ProtoMessage()

func (*StateRootResponse) Reset

func (m *StateRootResponse) Reset()

func (*StateRootResponse) Size

func (m *StateRootResponse) Size() (n int)

func (*StateRootResponse) String

func (m *StateRootResponse) String() string

func (*StateRootResponse) Unmarshal

func (m *StateRootResponse) Unmarshal(dAtA []byte) error

func (*StateRootResponse) XXX_DiscardUnknown

func (m *StateRootResponse) XXX_DiscardUnknown()

func (*StateRootResponse) XXX_Marshal

func (m *StateRootResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateRootResponse) XXX_Merge

func (dst *StateRootResponse) XXX_Merge(src proto.Message)

func (*StateRootResponse) XXX_Size

func (m *StateRootResponse) XXX_Size() int

func (*StateRootResponse) XXX_Unmarshal

func (m *StateRootResponse) XXX_Unmarshal(b []byte) error

type ValidatorEpochAssignmentsRequest

type ValidatorEpochAssignmentsRequest struct {
	EpochStart           uint64   `protobuf:"varint,1,opt,name=epoch_start,json=epochStart,proto3" json:"epoch_start,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 (*ValidatorEpochAssignmentsRequest) Descriptor

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

func (*ValidatorEpochAssignmentsRequest) GetEpochStart

func (m *ValidatorEpochAssignmentsRequest) GetEpochStart() uint64

func (*ValidatorEpochAssignmentsRequest) GetPublicKey

func (m *ValidatorEpochAssignmentsRequest) GetPublicKey() []byte

func (*ValidatorEpochAssignmentsRequest) Marshal

func (m *ValidatorEpochAssignmentsRequest) Marshal() (dAtA []byte, err error)

func (*ValidatorEpochAssignmentsRequest) MarshalTo

func (m *ValidatorEpochAssignmentsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorEpochAssignmentsRequest) ProtoMessage

func (*ValidatorEpochAssignmentsRequest) ProtoMessage()

func (*ValidatorEpochAssignmentsRequest) Reset

func (*ValidatorEpochAssignmentsRequest) Size

func (m *ValidatorEpochAssignmentsRequest) Size() (n int)

func (*ValidatorEpochAssignmentsRequest) String

func (*ValidatorEpochAssignmentsRequest) Unmarshal

func (m *ValidatorEpochAssignmentsRequest) Unmarshal(dAtA []byte) error

func (*ValidatorEpochAssignmentsRequest) XXX_DiscardUnknown

func (m *ValidatorEpochAssignmentsRequest) XXX_DiscardUnknown()

func (*ValidatorEpochAssignmentsRequest) XXX_Marshal

func (m *ValidatorEpochAssignmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorEpochAssignmentsRequest) XXX_Merge

func (dst *ValidatorEpochAssignmentsRequest) XXX_Merge(src proto.Message)

func (*ValidatorEpochAssignmentsRequest) XXX_Size

func (m *ValidatorEpochAssignmentsRequest) XXX_Size() int

func (*ValidatorEpochAssignmentsRequest) XXX_Unmarshal

func (m *ValidatorEpochAssignmentsRequest) XXX_Unmarshal(b []byte) error

type ValidatorEpochAssignmentsResponse

type ValidatorEpochAssignmentsResponse struct {
	Assignment           *Assignment `protobuf:"bytes,2,opt,name=assignment,proto3" json:"assignment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ValidatorEpochAssignmentsResponse) Descriptor

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

func (*ValidatorEpochAssignmentsResponse) GetAssignment

func (m *ValidatorEpochAssignmentsResponse) GetAssignment() *Assignment

func (*ValidatorEpochAssignmentsResponse) Marshal

func (m *ValidatorEpochAssignmentsResponse) Marshal() (dAtA []byte, err error)

func (*ValidatorEpochAssignmentsResponse) MarshalTo

func (m *ValidatorEpochAssignmentsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorEpochAssignmentsResponse) ProtoMessage

func (*ValidatorEpochAssignmentsResponse) ProtoMessage()

func (*ValidatorEpochAssignmentsResponse) Reset

func (*ValidatorEpochAssignmentsResponse) Size

func (m *ValidatorEpochAssignmentsResponse) Size() (n int)

func (*ValidatorEpochAssignmentsResponse) String

func (*ValidatorEpochAssignmentsResponse) Unmarshal

func (m *ValidatorEpochAssignmentsResponse) Unmarshal(dAtA []byte) error

func (*ValidatorEpochAssignmentsResponse) XXX_DiscardUnknown

func (m *ValidatorEpochAssignmentsResponse) XXX_DiscardUnknown()

func (*ValidatorEpochAssignmentsResponse) XXX_Marshal

func (m *ValidatorEpochAssignmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorEpochAssignmentsResponse) XXX_Merge

func (dst *ValidatorEpochAssignmentsResponse) XXX_Merge(src proto.Message)

func (*ValidatorEpochAssignmentsResponse) XXX_Size

func (m *ValidatorEpochAssignmentsResponse) XXX_Size() int

func (*ValidatorEpochAssignmentsResponse) XXX_Unmarshal

func (m *ValidatorEpochAssignmentsResponse) XXX_Unmarshal(b []byte) error

type ValidatorIndexRequest

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 (*ValidatorIndexRequest) Descriptor

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

func (*ValidatorIndexRequest) GetPublicKey

func (m *ValidatorIndexRequest) GetPublicKey() []byte

func (*ValidatorIndexRequest) Marshal

func (m *ValidatorIndexRequest) Marshal() (dAtA []byte, err error)

func (*ValidatorIndexRequest) MarshalTo

func (m *ValidatorIndexRequest) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorIndexRequest) ProtoMessage

func (*ValidatorIndexRequest) ProtoMessage()

func (*ValidatorIndexRequest) Reset

func (m *ValidatorIndexRequest) Reset()

func (*ValidatorIndexRequest) Size

func (m *ValidatorIndexRequest) Size() (n int)

func (*ValidatorIndexRequest) String

func (m *ValidatorIndexRequest) String() string

func (*ValidatorIndexRequest) Unmarshal

func (m *ValidatorIndexRequest) Unmarshal(dAtA []byte) error

func (*ValidatorIndexRequest) XXX_DiscardUnknown

func (m *ValidatorIndexRequest) XXX_DiscardUnknown()

func (*ValidatorIndexRequest) XXX_Marshal

func (m *ValidatorIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorIndexRequest) XXX_Merge

func (dst *ValidatorIndexRequest) XXX_Merge(src proto.Message)

func (*ValidatorIndexRequest) XXX_Size

func (m *ValidatorIndexRequest) XXX_Size() int

func (*ValidatorIndexRequest) XXX_Unmarshal

func (m *ValidatorIndexRequest) XXX_Unmarshal(b []byte) error

type ValidatorIndexResponse

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 (*ValidatorIndexResponse) Descriptor

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

func (*ValidatorIndexResponse) GetIndex

func (m *ValidatorIndexResponse) GetIndex() uint64

func (*ValidatorIndexResponse) Marshal

func (m *ValidatorIndexResponse) Marshal() (dAtA []byte, err error)

func (*ValidatorIndexResponse) MarshalTo

func (m *ValidatorIndexResponse) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorIndexResponse) ProtoMessage

func (*ValidatorIndexResponse) ProtoMessage()

func (*ValidatorIndexResponse) Reset

func (m *ValidatorIndexResponse) Reset()

func (*ValidatorIndexResponse) Size

func (m *ValidatorIndexResponse) Size() (n int)

func (*ValidatorIndexResponse) String

func (m *ValidatorIndexResponse) String() string

func (*ValidatorIndexResponse) Unmarshal

func (m *ValidatorIndexResponse) Unmarshal(dAtA []byte) error

func (*ValidatorIndexResponse) XXX_DiscardUnknown

func (m *ValidatorIndexResponse) XXX_DiscardUnknown()

func (*ValidatorIndexResponse) XXX_Marshal

func (m *ValidatorIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorIndexResponse) XXX_Merge

func (dst *ValidatorIndexResponse) XXX_Merge(src proto.Message)

func (*ValidatorIndexResponse) XXX_Size

func (m *ValidatorIndexResponse) XXX_Size() int

func (*ValidatorIndexResponse) XXX_Unmarshal

func (m *ValidatorIndexResponse) XXX_Unmarshal(b []byte) error

type ValidatorRole

type ValidatorRole int32
const (
	ValidatorRole_UNKNOWN  ValidatorRole = 0
	ValidatorRole_ATTESTER ValidatorRole = 1
	ValidatorRole_PROPOSER ValidatorRole = 2
)

func (ValidatorRole) EnumDescriptor

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

func (ValidatorRole) String

func (x ValidatorRole) String() string

type ValidatorServiceClient

type ValidatorServiceClient interface {
	ValidatorIndex(ctx context.Context, in *ValidatorIndexRequest, opts ...grpc.CallOption) (*ValidatorIndexResponse, error)
	ValidatorEpochAssignments(ctx context.Context, in *ValidatorEpochAssignmentsRequest, opts ...grpc.CallOption) (*ValidatorEpochAssignmentsResponse, error)
}

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.

func NewValidatorServiceClient

func NewValidatorServiceClient(cc *grpc.ClientConn) ValidatorServiceClient

type ValidatorServiceServer

type ValidatorServiceServer interface {
	ValidatorIndex(context.Context, *ValidatorIndexRequest) (*ValidatorIndexResponse, error)
	ValidatorEpochAssignments(context.Context, *ValidatorEpochAssignmentsRequest) (*ValidatorEpochAssignmentsResponse, error)
}

ValidatorServiceServer is the server API for ValidatorService service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL