types

package
v1.0.0-rc58 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// InternalBlobstreamABIJSON is the json encoded abi for private functions in the
	// Blobstream contract. This is needed to encode data that is signed over in a way
	// that the contracts can easily verify.
	InternalBlobstreamABIJSON = `` /* 1660-byte string literal not displayed */

	// Domain separator constants copied directly from the contracts.
	ValidatorSetDomainSeparator   = "0x636865636b706f696e7400000000000000000000000000000000000000000000"
	DataCommitmentDomainSeparator = "0x7472616e73616374696f6e426174636800000000000000000000000000000000"
)
View Source 
const (
	EventTypeAttestationRequest = "AttestationRequest"
	AttributeKeyNonce           = "nonce"
)
View Source 
const (
	DefaultParamspace = ModuleName

	// MinimumDataCommitmentWindow is a constant that defines the minimum
	// allowable window for the Blobstream data commitments.
	MinimumDataCommitmentWindow = 100
)

DefaultParamspace defines the default blobstream module parameter subspace

View Source 
const (
	// ModuleName is the name of the module.
	ModuleName = "qgb"

	// StoreKey to be used when creating the KVStore.
	StoreKey = ModuleName

	// RouterKey is the module name router key.
	RouterKey = ModuleName

	// QuerierRoute to be used for querier msgs.
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key.
	MemStoreKey = "mem_qgb"
)
View Source 
const (
	// AttestationRequestKey indexes attestation requests by nonce
	AttestationRequestKey = "AttestationRequestKey"

	// LatestUnBondingBlockHeight indexes the latest validator unbonding block
	// height
	LatestUnBondingBlockHeight = "LatestUnBondingBlockHeight"

	// LatestAttestationNonce indexes the latest attestation request nonce
	LatestAttestationNonce = "LatestAttestationNonce"

	// EarliestAvailableAttestationNonce indexes the earliest available
	// attestation nonce
	EarliestAvailableAttestationNonce = "EarliestAvailableAttestationNonce"

	// EVMAddress indexes evm addresses by validator address
	EVMAddress = "EVMAddress"
)
View Source 
const URLMsgRegisterEVMAddress = "/celestia.blob.v1.MsgRegisterEVMAddress"

Variables

View Source 
var (
	ExternalBlobstreamABI abi.ABI
	InternalBlobstreamABI abi.ABI
	BridgeValidatorAbi    abi.Arguments

	VsDomainSeparator ethcmn.Hash
	DcDomainSeparator ethcmn.Hash
)
View Source 
var (
	ErrDuplicate                                 = errors.Register(ModuleName, 2, "duplicate")
	ErrEmpty                                     = errors.Register(ModuleName, 6, "empty")
	ErrNoValidators                              = errors.Register(ModuleName, 12, "no bonded validators in active set")
	ErrInvalidValAddress                         = errors.Register(ModuleName, 13, "invalid validator address in current valset %v")
	ErrInvalidEVMAddress                         = errors.Register(ModuleName, 14, "discovered invalid EVM address stored for validator %v")
	ErrInvalidValset                             = errors.Register(ModuleName, 15, "generated invalid valset")
	ErrAttestationNotValsetRequest               = errors.Register(ModuleName, 16, "attestation is not a valset request")
	ErrAttestationNotFound                       = errors.Register(ModuleName, 18, "attestation not found")
	ErrNilAttestation                            = errors.Register(ModuleName, 22, "nil attestation")
	ErrUnmarshalllAttestation                    = errors.Register(ModuleName, 26, "couldn't unmarshall attestation from store")
	ErrNonceHigherThanLatestAttestationNonce     = errors.Register(ModuleName, 27, "the provided nonce is higher than the latest attestation nonce")
	ErrNoValsetBeforeNonceOne                    = errors.Register(ModuleName, 28, "there is no valset before attestation nonce 1")
	ErrDataCommitmentNotGenerated                = errors.Register(ModuleName, 29, "no data commitment has been generated for the provided height")
	ErrDataCommitmentNotFound                    = errors.Register(ModuleName, 30, "data commitment not found")
	ErrLatestAttestationNonceStillNotInitialized = errors.Register(ModuleName, 31, "the latest attestation nonce has still not been defined in store")
	ErrInvalidDataCommitmentWindow               = errors.Register(ModuleName, 32, "invalid data commitment window")
	ErrEarliestAvailableNonceStillNotInitialized = errors.Register(ModuleName, 33, "the earliest available nonce after pruning has still not been defined in store")
	ErrRequestedNonceWasPruned                   = errors.Register(ModuleName, 34, "the requested nonce has been pruned")
	ErrUnknownAttestationType                    = errors.Register(ModuleName, 35, "unknown attestation type")
	ErrEVMAddressNotHex                          = errors.Register(ModuleName, 36, "the provided evm address is not a valid hex address")
	ErrEVMAddressAlreadyExists                   = errors.Register(ModuleName, 37, "the provided evm address already exists")
	ErrEVMAddressNotFound                        = errors.Register(ModuleName, 38, "EVM address not found")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ParamsStoreKeyDataCommitmentWindow = []byte("DataCommitmentWindow")

ParamsStoreKeyDataCommitmentWindow is the key used for the DataCommitmentWindow param.

Functions

func ConvertByteArrToString 

func ConvertByteArrToString(value []byte) string

func DefaultEVMAddress 

func DefaultEVMAddress(addr sdk.ValAddress) gethcommon.Address

func EVMAddrLessThan 

func EVMAddrLessThan(e common.Address, o common.Address) bool

EVMAddrLessThan migrates the EVM address less than function.

func GetAttestationKey 

func GetAttestationKey(nonce uint64) string

GetAttestationKey returns the following key format prefix nonce [0x0][0 0 0 0 0 0 0 1]

func GetEVMKey 

func GetEVMKey(valAddress sdk.ValAddress) []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for blobstream module

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func UInt64Bytes 

func UInt64Bytes(n uint64) []byte

UInt64Bytes uses the SDK byte marshaling to encode a uint64.

Types

type AttestationRequestI 

type AttestationRequestI interface {
	proto.Message
	codec.ProtoMarshaler
	GetNonce() uint64
	BlockTime() time.Time
}

AttestationRequestI is either a DataCommitment or a Valset. This was decided as part of the universal nonce approach under: https://github.com/celestiaorg/celestia-app/issues/468#issuecomment-1156887715

type BridgeValidator 

type BridgeValidator struct {
	// Voting power of the validator.
	Power uint64 `protobuf:"varint,1,opt,name=power,proto3" json:"power,omitempty"`
	// EVM address that will be used by the validator to sign messages.
	EvmAddress string `protobuf:"bytes,2,opt,name=evm_address,json=evmAddress,proto3" json:"evm_address,omitempty"`
}

BridgeValidator represents a validator's ETH address and its power

func (*BridgeValidator) Descriptor 

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

func (*BridgeValidator) GetEvmAddress 

func (m *BridgeValidator) GetEvmAddress() string

func (*BridgeValidator) GetPower 

func (m *BridgeValidator) GetPower() uint64

func (*BridgeValidator) Marshal 

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

func (*BridgeValidator) MarshalTo 

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

func (*BridgeValidator) MarshalToSizedBuffer 

func (m *BridgeValidator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BridgeValidator) ProtoMessage 

func (*BridgeValidator) ProtoMessage()

func (*BridgeValidator) Reset 

func (m *BridgeValidator) Reset()

func (*BridgeValidator) Size 

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

func (*BridgeValidator) String 

func (m *BridgeValidator) String() string

func (BridgeValidator) ToInternal 

func (b BridgeValidator) ToInternal() (*InternalBridgeValidator, error)

ToInternal transforms a BridgeValidator into its fully validated internal type.

func (*BridgeValidator) Unmarshal 

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

func (*BridgeValidator) XXX_DiscardUnknown 

func (m *BridgeValidator) XXX_DiscardUnknown()

func (*BridgeValidator) XXX_Marshal 

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

func (*BridgeValidator) XXX_Merge 

func (m *BridgeValidator) XXX_Merge(src proto.Message)

func (*BridgeValidator) XXX_Size 

func (m *BridgeValidator) XXX_Size() int

func (*BridgeValidator) XXX_Unmarshal 

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

type BridgeValidators 

type BridgeValidators []BridgeValidator

BridgeValidators is the sorted set of validators EVM address and their corresponding power.

func (BridgeValidators) ToInternal 

func (b BridgeValidators) ToInternal() (*InternalBridgeValidators, error)

type DataCommitment 

type DataCommitment struct {
	// Universal nonce defined under:
	// https://github.com/celestiaorg/celestia-app/pull/464
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// First block defining the ordered set of blocks used to create the
	// commitment.
	BeginBlock uint64 `protobuf:"varint,2,opt,name=begin_block,json=beginBlock,proto3" json:"begin_block,omitempty"`
	// End exclusive last block defining the ordered set of blocks used to create
	// the commitment.
	EndBlock uint64 `protobuf:"varint,3,opt,name=end_block,json=endBlock,proto3" json:"end_block,omitempty"`
	// Block time where this data commitment was created
	Time time.Time `protobuf:"bytes,4,opt,name=time,proto3,stdtime" json:"time"`
}

DataCommitment is the data commitment request message that will be signed using orchestrators. It does not contain a `commitment` field as this message will be created inside the state machine and it doesn't make sense to ask tendermint for the commitment there. The range defined by begin_block and end_block is end exclusive.

func NewDataCommitment 

func NewDataCommitment(
	nonce uint64,
	beginBlock uint64,
	endBlock uint64,
	blockTime time.Time,
) *DataCommitment

NewDataCommitment creates a new DataCommitment.

func (*DataCommitment) BlockTime 

func (m *DataCommitment) BlockTime() time.Time

func (*DataCommitment) Descriptor 

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

func (*DataCommitment) GetBeginBlock 

func (m *DataCommitment) GetBeginBlock() uint64

func (*DataCommitment) GetEndBlock 

func (m *DataCommitment) GetEndBlock() uint64

func (*DataCommitment) GetNonce 

func (m *DataCommitment) GetNonce() uint64

func (*DataCommitment) GetTime 

func (m *DataCommitment) GetTime() time.Time

func (*DataCommitment) Marshal 

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

func (*DataCommitment) MarshalTo 

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

func (*DataCommitment) MarshalToSizedBuffer 

func (m *DataCommitment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataCommitment) ProtoMessage 

func (*DataCommitment) ProtoMessage()

func (*DataCommitment) Reset 

func (m *DataCommitment) Reset()

func (*DataCommitment) Size 

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

func (*DataCommitment) String 

func (m *DataCommitment) String() string

func (*DataCommitment) Unmarshal 

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

func (*DataCommitment) XXX_DiscardUnknown 

func (m *DataCommitment) XXX_DiscardUnknown()

func (*DataCommitment) XXX_Marshal 

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

func (*DataCommitment) XXX_Merge 

func (m *DataCommitment) XXX_Merge(src proto.Message)

func (*DataCommitment) XXX_Size 

func (m *DataCommitment) XXX_Size() int

func (*DataCommitment) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}

GenesisState struct, containing all persistent data required by Blobstream module

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() *Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type InternalBridgeValidator 

type InternalBridgeValidator struct {
	Power      uint64
	EVMAddress common.Address
}

InternalBridgeValidator bridges Validator but with validated EVMAddress.

func NewInternalBridgeValidator 

func NewInternalBridgeValidator(bridgeValidator BridgeValidator) (*InternalBridgeValidator, error)

func (InternalBridgeValidator) ToExternal 

func (i InternalBridgeValidator) ToExternal() BridgeValidator

func (InternalBridgeValidator) ValidateBasic 

func (i InternalBridgeValidator) ValidateBasic() error

type InternalBridgeValidators 

type InternalBridgeValidators []*InternalBridgeValidator

InternalBridgeValidators is the sorted set of validator data for EVM bridge MultiSig set.

func (InternalBridgeValidators) GetPowers 

func (ibv InternalBridgeValidators) GetPowers() []uint64

GetPowers returns only the power values for all members.

func (InternalBridgeValidators) HasDuplicates 

func (ibv InternalBridgeValidators) HasDuplicates() bool

HasDuplicates returns true if there are duplicates in the set.

func (InternalBridgeValidators) PowerDiff 

func (ibv InternalBridgeValidators) PowerDiff(c InternalBridgeValidators) sdk.Dec

PowerDiff returns the difference in power between two bridge validator sets. Note this is Blobstream bridge power *not* Cosmos voting power. Cosmos voting power is based on the absolute number of tokens in the staking pool at any given time. Blobstream bridge power is normalized using the equation.

validators cosmos voting power / total cosmos voting power in this block = Blobstream bridge power / u32_max

As an example if someone has 52% of the Cosmos voting power when a validator set is created their Blobstream bridge voting power is u32_max * .52

Normalized voting power dramatically reduces how often we have to produce new validator set updates. For example if the total on chain voting power increases by 1% due to inflation, we shouldn't have to generate a new validator set, after all the validators retained their relative percentages during inflation and normalized Blobstream power shows no difference.

func (InternalBridgeValidators) Sort 

func (ibv InternalBridgeValidators) Sort()

Sort sorts the validators by power.

func (InternalBridgeValidators) ToExternal 

func (ibv InternalBridgeValidators) ToExternal() BridgeValidators

func (InternalBridgeValidators) TotalPower 

func (ibv InternalBridgeValidators) TotalPower() (out uint64)

TotalPower returns the total power in the bridge validator set.

func (InternalBridgeValidators) ValidateBasic 

func (ibv InternalBridgeValidators) ValidateBasic() error

ValidateBasic performs stateless checks.

type MsgClient 

type MsgClient interface {
	// RegisterEVMAddress records an evm address for the validator which is used
	// by the relayer to aggregate signatures. A validator can only register a
	// single EVM address. The EVM address can be overridden by a later message.
	// There are no validity checks of the EVM addresses existence on the Ethereum
	// state machine.
	RegisterEVMAddress(ctx context.Context, in *MsgRegisterEVMAddress, opts ...grpc.CallOption) (*MsgRegisterEVMAddressResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgRegisterEVMAddress 

type MsgRegisterEVMAddress struct {
	// The operating address of the validator.
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	// The matching HEX encoded EVM address.
	EvmAddress string `protobuf:"bytes,2,opt,name=evm_address,json=evmAddress,proto3" json:"evm_address,omitempty"`
}

MsgRegisterEVMAddress registers an evm address to a validator.

func NewMsgRegisterEVMAddress 

func NewMsgRegisterEVMAddress(valAddress sdk.ValAddress, evmAddress common.Address) *MsgRegisterEVMAddress

func (*MsgRegisterEVMAddress) Descriptor 

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

func (*MsgRegisterEVMAddress) GetEvmAddress 

func (m *MsgRegisterEVMAddress) GetEvmAddress() string

func (MsgRegisterEVMAddress) GetSigners 

func (msg MsgRegisterEVMAddress) GetSigners() []sdk.AccAddress

GetSigner fulfills the sdk.Msg interface. The signer must be the validator address

func (*MsgRegisterEVMAddress) GetValidatorAddress 

func (m *MsgRegisterEVMAddress) GetValidatorAddress() string

func (*MsgRegisterEVMAddress) Marshal 

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

func (*MsgRegisterEVMAddress) MarshalTo 

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

func (*MsgRegisterEVMAddress) MarshalToSizedBuffer 

func (m *MsgRegisterEVMAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRegisterEVMAddress) ProtoMessage 

func (*MsgRegisterEVMAddress) ProtoMessage()

func (*MsgRegisterEVMAddress) Reset 

func (m *MsgRegisterEVMAddress) Reset()

func (*MsgRegisterEVMAddress) Size 

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

func (*MsgRegisterEVMAddress) String 

func (m *MsgRegisterEVMAddress) String() string

func (*MsgRegisterEVMAddress) Unmarshal 

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

func (MsgRegisterEVMAddress) ValidateBasic 

func (msg MsgRegisterEVMAddress) ValidateBasic() error

ValidateBasic verifies that the EVM address and val address are of a valid type

func (*MsgRegisterEVMAddress) XXX_DiscardUnknown 

func (m *MsgRegisterEVMAddress) XXX_DiscardUnknown()

func (*MsgRegisterEVMAddress) XXX_Marshal 

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

func (*MsgRegisterEVMAddress) XXX_Merge 

func (m *MsgRegisterEVMAddress) XXX_Merge(src proto.Message)

func (*MsgRegisterEVMAddress) XXX_Size 

func (m *MsgRegisterEVMAddress) XXX_Size() int

func (*MsgRegisterEVMAddress) XXX_Unmarshal 

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

type MsgRegisterEVMAddressResponse 

type MsgRegisterEVMAddressResponse struct {
}

MsgRegisterEVMAddressResponse is the response to registering an EVM address.

func (*MsgRegisterEVMAddressResponse) Descriptor 

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

func (*MsgRegisterEVMAddressResponse) Marshal 

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

func (*MsgRegisterEVMAddressResponse) MarshalTo 

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

func (*MsgRegisterEVMAddressResponse) MarshalToSizedBuffer 

func (m *MsgRegisterEVMAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRegisterEVMAddressResponse) ProtoMessage 

func (*MsgRegisterEVMAddressResponse) ProtoMessage()

func (*MsgRegisterEVMAddressResponse) Reset 

func (m *MsgRegisterEVMAddressResponse) Reset()

func (*MsgRegisterEVMAddressResponse) Size 

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

func (*MsgRegisterEVMAddressResponse) String 

func (m *MsgRegisterEVMAddressResponse) String() string

func (*MsgRegisterEVMAddressResponse) Unmarshal 

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

func (*MsgRegisterEVMAddressResponse) XXX_DiscardUnknown 

func (m *MsgRegisterEVMAddressResponse) XXX_DiscardUnknown()

func (*MsgRegisterEVMAddressResponse) XXX_Marshal 

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

func (*MsgRegisterEVMAddressResponse) XXX_Merge 

func (m *MsgRegisterEVMAddressResponse) XXX_Merge(src proto.Message)

func (*MsgRegisterEVMAddressResponse) XXX_Size 

func (m *MsgRegisterEVMAddressResponse) XXX_Size() int

func (*MsgRegisterEVMAddressResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RegisterEVMAddress records an evm address for the validator which is used
	// by the relayer to aggregate signatures. A validator can only register a
	// single EVM address. The EVM address can be overridden by a later message.
	// There are no validity checks of the EVM addresses existence on the Ethereum
	// state machine.
	RegisterEVMAddress(context.Context, *MsgRegisterEVMAddress) (*MsgRegisterEVMAddressResponse, error)
}

MsgServer is the server API for Msg service.

type Params 

type Params struct {
	DataCommitmentWindow uint64 `protobuf:"varint,1,opt,name=data_commitment_window,json=dataCommitmentWindow,proto3" json:"data_commitment_window,omitempty"`
}

Params represent Blobstream genesis and store parameters.

func (*Params) Descriptor 

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

func (*Params) GetDataCommitmentWindow 

func (m *Params) GetDataCommitmentWindow() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements the ParamSet interface and returns all the key/value pairs of auth module's parameters.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) ValidateBasic 

func (p Params) ValidateBasic() error

ValidateBasic checks that the parameters have valid values.

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryAttestationRequestByNonceRequest 

type QueryAttestationRequestByNonceRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

QueryAttestationRequestByNonceRequest

func (*QueryAttestationRequestByNonceRequest) Descriptor 

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

func (*QueryAttestationRequestByNonceRequest) GetNonce 

func (m *QueryAttestationRequestByNonceRequest) GetNonce() uint64

func (*QueryAttestationRequestByNonceRequest) Marshal 

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

func (*QueryAttestationRequestByNonceRequest) MarshalTo 

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

func (*QueryAttestationRequestByNonceRequest) MarshalToSizedBuffer 

func (m *QueryAttestationRequestByNonceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAttestationRequestByNonceRequest) ProtoMessage 

func (*QueryAttestationRequestByNonceRequest) ProtoMessage()

func (*QueryAttestationRequestByNonceRequest) Reset 

func (m *QueryAttestationRequestByNonceRequest) Reset()

func (*QueryAttestationRequestByNonceRequest) Size 

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

func (*QueryAttestationRequestByNonceRequest) String 

func (m *QueryAttestationRequestByNonceRequest) String() string

func (*QueryAttestationRequestByNonceRequest) Unmarshal 

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

func (*QueryAttestationRequestByNonceRequest) XXX_DiscardUnknown 

func (m *QueryAttestationRequestByNonceRequest) XXX_DiscardUnknown()

func (*QueryAttestationRequestByNonceRequest) XXX_Marshal 

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

func (*QueryAttestationRequestByNonceRequest) XXX_Merge 

func (m *QueryAttestationRequestByNonceRequest) XXX_Merge(src proto.Message)

func (*QueryAttestationRequestByNonceRequest) XXX_Size 

func (m *QueryAttestationRequestByNonceRequest) XXX_Size() int

func (*QueryAttestationRequestByNonceRequest) XXX_Unmarshal 

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

type QueryAttestationRequestByNonceResponse 

type QueryAttestationRequestByNonceResponse struct {
	// AttestationRequestI is either a Data Commitment or a Valset.
	// This was decided as part of the universal nonce approach under:
	// https://github.com/celestiaorg/celestia-app/issues/468#issuecomment-1156887715
	Attestation *types.Any `protobuf:"bytes,1,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

QueryAttestationRequestByNonceResponse

func (*QueryAttestationRequestByNonceResponse) Descriptor 

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

func (*QueryAttestationRequestByNonceResponse) GetAttestation 

func (m *QueryAttestationRequestByNonceResponse) GetAttestation() *types.Any

func (*QueryAttestationRequestByNonceResponse) Marshal 

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

func (*QueryAttestationRequestByNonceResponse) MarshalTo 

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

func (*QueryAttestationRequestByNonceResponse) MarshalToSizedBuffer 

func (m *QueryAttestationRequestByNonceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAttestationRequestByNonceResponse) ProtoMessage 

func (*QueryAttestationRequestByNonceResponse) ProtoMessage()

func (*QueryAttestationRequestByNonceResponse) Reset 

func (m *QueryAttestationRequestByNonceResponse) Reset()

func (*QueryAttestationRequestByNonceResponse) Size 

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

func (*QueryAttestationRequestByNonceResponse) String 

func (m *QueryAttestationRequestByNonceResponse) String() string

func (*QueryAttestationRequestByNonceResponse) Unmarshal 

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

func (*QueryAttestationRequestByNonceResponse) XXX_DiscardUnknown 

func (m *QueryAttestationRequestByNonceResponse) XXX_DiscardUnknown()

func (*QueryAttestationRequestByNonceResponse) XXX_Marshal 

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

func (*QueryAttestationRequestByNonceResponse) XXX_Merge 

func (m *QueryAttestationRequestByNonceResponse) XXX_Merge(src proto.Message)

func (*QueryAttestationRequestByNonceResponse) XXX_Size 

func (m *QueryAttestationRequestByNonceResponse) XXX_Size() int

func (*QueryAttestationRequestByNonceResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the current parameters for the blobstream module
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// AttestationRequestByNonce queries attestation request by nonce.
	// Returns nil if not found.
	AttestationRequestByNonce(ctx context.Context, in *QueryAttestationRequestByNonceRequest, opts ...grpc.CallOption) (*QueryAttestationRequestByNonceResponse, error)
	// LatestAttestationNonce queries latest attestation nonce.
	LatestAttestationNonce(ctx context.Context, in *QueryLatestAttestationNonceRequest, opts ...grpc.CallOption) (*QueryLatestAttestationNonceResponse, error)
	// EarliestAttestationNonce queries the earliest attestation nonce.
	EarliestAttestationNonce(ctx context.Context, in *QueryEarliestAttestationNonceRequest, opts ...grpc.CallOption) (*QueryEarliestAttestationNonceResponse, error)
	// LatestValsetRequestBeforeNonce Queries latest Valset request before nonce.
	// And, even if the current nonce is a valset, it will return the previous
	// one.
	// If the provided nonce is 1, it will return an error, because, there is
	// no valset before nonce 1.
	LatestValsetRequestBeforeNonce(ctx context.Context, in *QueryLatestValsetRequestBeforeNonceRequest, opts ...grpc.CallOption) (*QueryLatestValsetRequestBeforeNonceResponse, error)
	// LatestUnbondingHeight returns the latest unbonding height
	LatestUnbondingHeight(ctx context.Context, in *QueryLatestUnbondingHeightRequest, opts ...grpc.CallOption) (*QueryLatestUnbondingHeightResponse, error)
	// DataCommitmentRangeForHeight returns the data commitment window
	// that includes the provided height
	DataCommitmentRangeForHeight(ctx context.Context, in *QueryDataCommitmentRangeForHeightRequest, opts ...grpc.CallOption) (*QueryDataCommitmentRangeForHeightResponse, error)
	// LatestDataCommitment returns the latest data commitment in store
	LatestDataCommitment(ctx context.Context, in *QueryLatestDataCommitmentRequest, opts ...grpc.CallOption) (*QueryLatestDataCommitmentResponse, error)
	// EVMAddress returns the evm address associated with a supplied
	// validator address
	EVMAddress(ctx context.Context, in *QueryEVMAddressRequest, opts ...grpc.CallOption) (*QueryEVMAddressResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryDataCommitmentRangeForHeightRequest 

type QueryDataCommitmentRangeForHeightRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

QueryDataCommitmentRangeForHeightRequest

func (*QueryDataCommitmentRangeForHeightRequest) Descriptor 

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

func (*QueryDataCommitmentRangeForHeightRequest) GetHeight 

func (m *QueryDataCommitmentRangeForHeightRequest) GetHeight() uint64

func (*QueryDataCommitmentRangeForHeightRequest) Marshal 

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

func (*QueryDataCommitmentRangeForHeightRequest) MarshalTo 

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

func (*QueryDataCommitmentRangeForHeightRequest) MarshalToSizedBuffer 

func (m *QueryDataCommitmentRangeForHeightRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDataCommitmentRangeForHeightRequest) ProtoMessage 

func (*QueryDataCommitmentRangeForHeightRequest) ProtoMessage()

func (*QueryDataCommitmentRangeForHeightRequest) Reset 

func (m *QueryDataCommitmentRangeForHeightRequest) Reset()

func (*QueryDataCommitmentRangeForHeightRequest) Size 

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

func (*QueryDataCommitmentRangeForHeightRequest) String 

func (m *QueryDataCommitmentRangeForHeightRequest) String() string

func (*QueryDataCommitmentRangeForHeightRequest) Unmarshal 

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

func (*QueryDataCommitmentRangeForHeightRequest) XXX_DiscardUnknown 

func (m *QueryDataCommitmentRangeForHeightRequest) XXX_DiscardUnknown()

func (*QueryDataCommitmentRangeForHeightRequest) XXX_Marshal 

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

func (*QueryDataCommitmentRangeForHeightRequest) XXX_Merge 

func (m *QueryDataCommitmentRangeForHeightRequest) XXX_Merge(src proto.Message)

func (*QueryDataCommitmentRangeForHeightRequest) XXX_Size 

func (m *QueryDataCommitmentRangeForHeightRequest) XXX_Size() int

func (*QueryDataCommitmentRangeForHeightRequest) XXX_Unmarshal 

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

type QueryDataCommitmentRangeForHeightResponse 

type QueryDataCommitmentRangeForHeightResponse struct {
	DataCommitment *DataCommitment `protobuf:"bytes,1,opt,name=data_commitment,json=dataCommitment,proto3" json:"data_commitment,omitempty"`
}

QueryDataCommitmentRangeForHeightResponse

func (*QueryDataCommitmentRangeForHeightResponse) Descriptor 

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

func (*QueryDataCommitmentRangeForHeightResponse) GetDataCommitment 

func (m *QueryDataCommitmentRangeForHeightResponse) GetDataCommitment() *DataCommitment

func (*QueryDataCommitmentRangeForHeightResponse) Marshal 

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

func (*QueryDataCommitmentRangeForHeightResponse) MarshalTo 

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

func (*QueryDataCommitmentRangeForHeightResponse) MarshalToSizedBuffer 

func (m *QueryDataCommitmentRangeForHeightResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDataCommitmentRangeForHeightResponse) ProtoMessage 

func (*QueryDataCommitmentRangeForHeightResponse) ProtoMessage()

func (*QueryDataCommitmentRangeForHeightResponse) Reset 

func (m *QueryDataCommitmentRangeForHeightResponse) Reset()

func (*QueryDataCommitmentRangeForHeightResponse) Size 

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

func (*QueryDataCommitmentRangeForHeightResponse) String 

func (m *QueryDataCommitmentRangeForHeightResponse) String() string

func (*QueryDataCommitmentRangeForHeightResponse) Unmarshal 

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

func (*QueryDataCommitmentRangeForHeightResponse) XXX_DiscardUnknown 

func (m *QueryDataCommitmentRangeForHeightResponse) XXX_DiscardUnknown()

func (*QueryDataCommitmentRangeForHeightResponse) XXX_Marshal 

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

func (*QueryDataCommitmentRangeForHeightResponse) XXX_Merge 

func (m *QueryDataCommitmentRangeForHeightResponse) XXX_Merge(src proto.Message)

func (*QueryDataCommitmentRangeForHeightResponse) XXX_Size 

func (m *QueryDataCommitmentRangeForHeightResponse) XXX_Size() int

func (*QueryDataCommitmentRangeForHeightResponse) XXX_Unmarshal 

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

type QueryEVMAddressRequest 

type QueryEVMAddressRequest struct {
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}

QueryEVMAddressRequest

func (*QueryEVMAddressRequest) Descriptor 

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

func (*QueryEVMAddressRequest) GetValidatorAddress 

func (m *QueryEVMAddressRequest) GetValidatorAddress() string

func (*QueryEVMAddressRequest) Marshal 

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

func (*QueryEVMAddressRequest) MarshalTo 

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

func (*QueryEVMAddressRequest) MarshalToSizedBuffer 

func (m *QueryEVMAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEVMAddressRequest) ProtoMessage 

func (*QueryEVMAddressRequest) ProtoMessage()

func (*QueryEVMAddressRequest) Reset 

func (m *QueryEVMAddressRequest) Reset()

func (*QueryEVMAddressRequest) Size 

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

func (*QueryEVMAddressRequest) String 

func (m *QueryEVMAddressRequest) String() string

func (*QueryEVMAddressRequest) Unmarshal 

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

func (*QueryEVMAddressRequest) XXX_DiscardUnknown 

func (m *QueryEVMAddressRequest) XXX_DiscardUnknown()

func (*QueryEVMAddressRequest) XXX_Marshal 

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

func (*QueryEVMAddressRequest) XXX_Merge 

func (m *QueryEVMAddressRequest) XXX_Merge(src proto.Message)

func (*QueryEVMAddressRequest) XXX_Size 

func (m *QueryEVMAddressRequest) XXX_Size() int

func (*QueryEVMAddressRequest) XXX_Unmarshal 

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

type QueryEVMAddressResponse 

type QueryEVMAddressResponse struct {
	EvmAddress string `protobuf:"bytes,1,opt,name=evm_address,json=evmAddress,proto3" json:"evm_address,omitempty"`
}

QueryEVMAddressResponse

func (*QueryEVMAddressResponse) Descriptor 

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

func (*QueryEVMAddressResponse) GetEvmAddress 

func (m *QueryEVMAddressResponse) GetEvmAddress() string

func (*QueryEVMAddressResponse) Marshal 

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

func (*QueryEVMAddressResponse) MarshalTo 

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

func (*QueryEVMAddressResponse) MarshalToSizedBuffer 

func (m *QueryEVMAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEVMAddressResponse) ProtoMessage 

func (*QueryEVMAddressResponse) ProtoMessage()

func (*QueryEVMAddressResponse) Reset 

func (m *QueryEVMAddressResponse) Reset()

func (*QueryEVMAddressResponse) Size 

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

func (*QueryEVMAddressResponse) String 

func (m *QueryEVMAddressResponse) String() string

func (*QueryEVMAddressResponse) Unmarshal 

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

func (*QueryEVMAddressResponse) XXX_DiscardUnknown 

func (m *QueryEVMAddressResponse) XXX_DiscardUnknown()

func (*QueryEVMAddressResponse) XXX_Marshal 

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

func (*QueryEVMAddressResponse) XXX_Merge 

func (m *QueryEVMAddressResponse) XXX_Merge(src proto.Message)

func (*QueryEVMAddressResponse) XXX_Size 

func (m *QueryEVMAddressResponse) XXX_Size() int

func (*QueryEVMAddressResponse) XXX_Unmarshal 

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

type QueryEarliestAttestationNonceRequest 

type QueryEarliestAttestationNonceRequest struct {
}

QueryEarliestAttestationNonceRequest earliest attestation nonce request

func (*QueryEarliestAttestationNonceRequest) Descriptor 

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

func (*QueryEarliestAttestationNonceRequest) Marshal 

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

func (*QueryEarliestAttestationNonceRequest) MarshalTo 

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

func (*QueryEarliestAttestationNonceRequest) MarshalToSizedBuffer 

func (m *QueryEarliestAttestationNonceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEarliestAttestationNonceRequest) ProtoMessage 

func (*QueryEarliestAttestationNonceRequest) ProtoMessage()

func (*QueryEarliestAttestationNonceRequest) Reset 

func (m *QueryEarliestAttestationNonceRequest) Reset()

func (*QueryEarliestAttestationNonceRequest) Size 

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

func (*QueryEarliestAttestationNonceRequest) String 

func (m *QueryEarliestAttestationNonceRequest) String() string

func (*QueryEarliestAttestationNonceRequest) Unmarshal 

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

func (*QueryEarliestAttestationNonceRequest) XXX_DiscardUnknown 

func (m *QueryEarliestAttestationNonceRequest) XXX_DiscardUnknown()

func (*QueryEarliestAttestationNonceRequest) XXX_Marshal 

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

func (*QueryEarliestAttestationNonceRequest) XXX_Merge 

func (m *QueryEarliestAttestationNonceRequest) XXX_Merge(src proto.Message)

func (*QueryEarliestAttestationNonceRequest) XXX_Size 

func (m *QueryEarliestAttestationNonceRequest) XXX_Size() int

func (*QueryEarliestAttestationNonceRequest) XXX_Unmarshal 

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

type QueryEarliestAttestationNonceResponse 

type QueryEarliestAttestationNonceResponse struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

QueryEarliestAttestationNonceResponse earliest attestation nonce response

func (*QueryEarliestAttestationNonceResponse) Descriptor 

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

func (*QueryEarliestAttestationNonceResponse) GetNonce 

func (m *QueryEarliestAttestationNonceResponse) GetNonce() uint64

func (*QueryEarliestAttestationNonceResponse) Marshal 

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

func (*QueryEarliestAttestationNonceResponse) MarshalTo 

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

func (*QueryEarliestAttestationNonceResponse) MarshalToSizedBuffer 

func (m *QueryEarliestAttestationNonceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEarliestAttestationNonceResponse) ProtoMessage 

func (*QueryEarliestAttestationNonceResponse) ProtoMessage()

func (*QueryEarliestAttestationNonceResponse) Reset 

func (m *QueryEarliestAttestationNonceResponse) Reset()

func (*QueryEarliestAttestationNonceResponse) Size 

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

func (*QueryEarliestAttestationNonceResponse) String 

func (m *QueryEarliestAttestationNonceResponse) String() string

func (*QueryEarliestAttestationNonceResponse) Unmarshal 

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

func (*QueryEarliestAttestationNonceResponse) XXX_DiscardUnknown 

func (m *QueryEarliestAttestationNonceResponse) XXX_DiscardUnknown()

func (*QueryEarliestAttestationNonceResponse) XXX_Marshal 

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

func (*QueryEarliestAttestationNonceResponse) XXX_Merge 

func (m *QueryEarliestAttestationNonceResponse) XXX_Merge(src proto.Message)

func (*QueryEarliestAttestationNonceResponse) XXX_Size 

func (m *QueryEarliestAttestationNonceResponse) XXX_Size() int

func (*QueryEarliestAttestationNonceResponse) XXX_Unmarshal 

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

type QueryLatestAttestationNonceRequest 

type QueryLatestAttestationNonceRequest struct {
}

QueryLatestAttestationNonceRequest latest attestation nonce request

func (*QueryLatestAttestationNonceRequest) Descriptor 

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

func (*QueryLatestAttestationNonceRequest) Marshal 

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

func (*QueryLatestAttestationNonceRequest) MarshalTo 

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

func (*QueryLatestAttestationNonceRequest) MarshalToSizedBuffer 

func (m *QueryLatestAttestationNonceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestAttestationNonceRequest) ProtoMessage 

func (*QueryLatestAttestationNonceRequest) ProtoMessage()

func (*QueryLatestAttestationNonceRequest) Reset 

func (m *QueryLatestAttestationNonceRequest) Reset()

func (*QueryLatestAttestationNonceRequest) Size 

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

func (*QueryLatestAttestationNonceRequest) String 

func (m *QueryLatestAttestationNonceRequest) String() string

func (*QueryLatestAttestationNonceRequest) Unmarshal 

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

func (*QueryLatestAttestationNonceRequest) XXX_DiscardUnknown 

func (m *QueryLatestAttestationNonceRequest) XXX_DiscardUnknown()

func (*QueryLatestAttestationNonceRequest) XXX_Marshal 

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

func (*QueryLatestAttestationNonceRequest) XXX_Merge 

func (m *QueryLatestAttestationNonceRequest) XXX_Merge(src proto.Message)

func (*QueryLatestAttestationNonceRequest) XXX_Size 

func (m *QueryLatestAttestationNonceRequest) XXX_Size() int

func (*QueryLatestAttestationNonceRequest) XXX_Unmarshal 

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

type QueryLatestAttestationNonceResponse 

type QueryLatestAttestationNonceResponse struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

QueryLatestAttestationNonceResponse latest attestation nonce response

func (*QueryLatestAttestationNonceResponse) Descriptor 

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

func (*QueryLatestAttestationNonceResponse) GetNonce 

func (m *QueryLatestAttestationNonceResponse) GetNonce() uint64

func (*QueryLatestAttestationNonceResponse) Marshal 

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

func (*QueryLatestAttestationNonceResponse) MarshalTo 

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

func (*QueryLatestAttestationNonceResponse) MarshalToSizedBuffer 

func (m *QueryLatestAttestationNonceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestAttestationNonceResponse) ProtoMessage 

func (*QueryLatestAttestationNonceResponse) ProtoMessage()

func (*QueryLatestAttestationNonceResponse) Reset 

func (m *QueryLatestAttestationNonceResponse) Reset()

func (*QueryLatestAttestationNonceResponse) Size 

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

func (*QueryLatestAttestationNonceResponse) String 

func (m *QueryLatestAttestationNonceResponse) String() string

func (*QueryLatestAttestationNonceResponse) Unmarshal 

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

func (*QueryLatestAttestationNonceResponse) XXX_DiscardUnknown 

func (m *QueryLatestAttestationNonceResponse) XXX_DiscardUnknown()

func (*QueryLatestAttestationNonceResponse) XXX_Marshal 

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

func (*QueryLatestAttestationNonceResponse) XXX_Merge 

func (m *QueryLatestAttestationNonceResponse) XXX_Merge(src proto.Message)

func (*QueryLatestAttestationNonceResponse) XXX_Size 

func (m *QueryLatestAttestationNonceResponse) XXX_Size() int

func (*QueryLatestAttestationNonceResponse) XXX_Unmarshal 

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

type QueryLatestDataCommitmentRequest 

type QueryLatestDataCommitmentRequest struct {
}

QueryLatestDataCommitmentRequest

func (*QueryLatestDataCommitmentRequest) Descriptor 

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

func (*QueryLatestDataCommitmentRequest) Marshal 

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

func (*QueryLatestDataCommitmentRequest) MarshalTo 

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

func (*QueryLatestDataCommitmentRequest) MarshalToSizedBuffer 

func (m *QueryLatestDataCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestDataCommitmentRequest) ProtoMessage 

func (*QueryLatestDataCommitmentRequest) ProtoMessage()

func (*QueryLatestDataCommitmentRequest) Reset 

func (m *QueryLatestDataCommitmentRequest) Reset()

func (*QueryLatestDataCommitmentRequest) Size 

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

func (*QueryLatestDataCommitmentRequest) String 

func (m *QueryLatestDataCommitmentRequest) String() string

func (*QueryLatestDataCommitmentRequest) Unmarshal 

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

func (*QueryLatestDataCommitmentRequest) XXX_DiscardUnknown 

func (m *QueryLatestDataCommitmentRequest) XXX_DiscardUnknown()

func (*QueryLatestDataCommitmentRequest) XXX_Marshal 

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

func (*QueryLatestDataCommitmentRequest) XXX_Merge 

func (m *QueryLatestDataCommitmentRequest) XXX_Merge(src proto.Message)

func (*QueryLatestDataCommitmentRequest) XXX_Size 

func (m *QueryLatestDataCommitmentRequest) XXX_Size() int

func (*QueryLatestDataCommitmentRequest) XXX_Unmarshal 

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

type QueryLatestDataCommitmentResponse 

type QueryLatestDataCommitmentResponse struct {
	DataCommitment *DataCommitment `protobuf:"bytes,1,opt,name=data_commitment,json=dataCommitment,proto3" json:"data_commitment,omitempty"`
}

QueryLatestDataCommitmentResponse

func (*QueryLatestDataCommitmentResponse) Descriptor 

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

func (*QueryLatestDataCommitmentResponse) GetDataCommitment 

func (m *QueryLatestDataCommitmentResponse) GetDataCommitment() *DataCommitment

func (*QueryLatestDataCommitmentResponse) Marshal 

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

func (*QueryLatestDataCommitmentResponse) MarshalTo 

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

func (*QueryLatestDataCommitmentResponse) MarshalToSizedBuffer 

func (m *QueryLatestDataCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestDataCommitmentResponse) ProtoMessage 

func (*QueryLatestDataCommitmentResponse) ProtoMessage()

func (*QueryLatestDataCommitmentResponse) Reset 

func (m *QueryLatestDataCommitmentResponse) Reset()

func (*QueryLatestDataCommitmentResponse) Size 

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

func (*QueryLatestDataCommitmentResponse) String 

func (m *QueryLatestDataCommitmentResponse) String() string

func (*QueryLatestDataCommitmentResponse) Unmarshal 

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

func (*QueryLatestDataCommitmentResponse) XXX_DiscardUnknown 

func (m *QueryLatestDataCommitmentResponse) XXX_DiscardUnknown()

func (*QueryLatestDataCommitmentResponse) XXX_Marshal 

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

func (*QueryLatestDataCommitmentResponse) XXX_Merge 

func (m *QueryLatestDataCommitmentResponse) XXX_Merge(src proto.Message)

func (*QueryLatestDataCommitmentResponse) XXX_Size 

func (m *QueryLatestDataCommitmentResponse) XXX_Size() int

func (*QueryLatestDataCommitmentResponse) XXX_Unmarshal 

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

type QueryLatestUnbondingHeightRequest 

type QueryLatestUnbondingHeightRequest struct {
}

QueryLatestUnbondingHeightRequest

func (*QueryLatestUnbondingHeightRequest) Descriptor 

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

func (*QueryLatestUnbondingHeightRequest) Marshal 

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

func (*QueryLatestUnbondingHeightRequest) MarshalTo 

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

func (*QueryLatestUnbondingHeightRequest) MarshalToSizedBuffer 

func (m *QueryLatestUnbondingHeightRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestUnbondingHeightRequest) ProtoMessage 

func (*QueryLatestUnbondingHeightRequest) ProtoMessage()

func (*QueryLatestUnbondingHeightRequest) Reset 

func (m *QueryLatestUnbondingHeightRequest) Reset()

func (*QueryLatestUnbondingHeightRequest) Size 

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

func (*QueryLatestUnbondingHeightRequest) String 

func (m *QueryLatestUnbondingHeightRequest) String() string

func (*QueryLatestUnbondingHeightRequest) Unmarshal 

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

func (*QueryLatestUnbondingHeightRequest) XXX_DiscardUnknown 

func (m *QueryLatestUnbondingHeightRequest) XXX_DiscardUnknown()

func (*QueryLatestUnbondingHeightRequest) XXX_Marshal 

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

func (*QueryLatestUnbondingHeightRequest) XXX_Merge 

func (m *QueryLatestUnbondingHeightRequest) XXX_Merge(src proto.Message)

func (*QueryLatestUnbondingHeightRequest) XXX_Size 

func (m *QueryLatestUnbondingHeightRequest) XXX_Size() int

func (*QueryLatestUnbondingHeightRequest) XXX_Unmarshal 

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

type QueryLatestUnbondingHeightResponse 

type QueryLatestUnbondingHeightResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

QueryLatestUnbondingHeightResponse

func (*QueryLatestUnbondingHeightResponse) Descriptor 

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

func (*QueryLatestUnbondingHeightResponse) GetHeight 

func (m *QueryLatestUnbondingHeightResponse) GetHeight() uint64

func (*QueryLatestUnbondingHeightResponse) Marshal 

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

func (*QueryLatestUnbondingHeightResponse) MarshalTo 

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

func (*QueryLatestUnbondingHeightResponse) MarshalToSizedBuffer 

func (m *QueryLatestUnbondingHeightResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestUnbondingHeightResponse) ProtoMessage 

func (*QueryLatestUnbondingHeightResponse) ProtoMessage()

func (*QueryLatestUnbondingHeightResponse) Reset 

func (m *QueryLatestUnbondingHeightResponse) Reset()

func (*QueryLatestUnbondingHeightResponse) Size 

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

func (*QueryLatestUnbondingHeightResponse) String 

func (m *QueryLatestUnbondingHeightResponse) String() string

func (*QueryLatestUnbondingHeightResponse) Unmarshal 

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

func (*QueryLatestUnbondingHeightResponse) XXX_DiscardUnknown 

func (m *QueryLatestUnbondingHeightResponse) XXX_DiscardUnknown()

func (*QueryLatestUnbondingHeightResponse) XXX_Marshal 

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

func (*QueryLatestUnbondingHeightResponse) XXX_Merge 

func (m *QueryLatestUnbondingHeightResponse) XXX_Merge(src proto.Message)

func (*QueryLatestUnbondingHeightResponse) XXX_Size 

func (m *QueryLatestUnbondingHeightResponse) XXX_Size() int

func (*QueryLatestUnbondingHeightResponse) XXX_Unmarshal 

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

type QueryLatestValsetRequestBeforeNonceRequest 

type QueryLatestValsetRequestBeforeNonceRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

QueryLatestValsetRequestBeforeNonceRequest latest Valset request before universal nonce request

func (*QueryLatestValsetRequestBeforeNonceRequest) Descriptor 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) GetNonce 

func (m *QueryLatestValsetRequestBeforeNonceRequest) GetNonce() uint64

func (*QueryLatestValsetRequestBeforeNonceRequest) Marshal 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) MarshalTo 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) MarshalToSizedBuffer 

func (m *QueryLatestValsetRequestBeforeNonceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestValsetRequestBeforeNonceRequest) ProtoMessage 

func (*QueryLatestValsetRequestBeforeNonceRequest) ProtoMessage()

func (*QueryLatestValsetRequestBeforeNonceRequest) Reset 

func (m *QueryLatestValsetRequestBeforeNonceRequest) Reset()

func (*QueryLatestValsetRequestBeforeNonceRequest) Size 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) String 

func (m *QueryLatestValsetRequestBeforeNonceRequest) String() string

func (*QueryLatestValsetRequestBeforeNonceRequest) Unmarshal 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) XXX_DiscardUnknown 

func (m *QueryLatestValsetRequestBeforeNonceRequest) XXX_DiscardUnknown()

func (*QueryLatestValsetRequestBeforeNonceRequest) XXX_Marshal 

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

func (*QueryLatestValsetRequestBeforeNonceRequest) XXX_Merge 

func (m *QueryLatestValsetRequestBeforeNonceRequest) XXX_Merge(src proto.Message)

func (*QueryLatestValsetRequestBeforeNonceRequest) XXX_Size 

func (m *QueryLatestValsetRequestBeforeNonceRequest) XXX_Size() int

func (*QueryLatestValsetRequestBeforeNonceRequest) XXX_Unmarshal 

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

type QueryLatestValsetRequestBeforeNonceResponse 

type QueryLatestValsetRequestBeforeNonceResponse struct {
	Valset *Valset `protobuf:"bytes,1,opt,name=valset,proto3" json:"valset,omitempty"`
}

QueryLatestValsetRequestBeforeNonceResponse latest Valset request before height response

func (*QueryLatestValsetRequestBeforeNonceResponse) Descriptor 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) GetValset 

func (m *QueryLatestValsetRequestBeforeNonceResponse) GetValset() *Valset

func (*QueryLatestValsetRequestBeforeNonceResponse) Marshal 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) MarshalTo 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) MarshalToSizedBuffer 

func (m *QueryLatestValsetRequestBeforeNonceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryLatestValsetRequestBeforeNonceResponse) ProtoMessage 

func (*QueryLatestValsetRequestBeforeNonceResponse) ProtoMessage()

func (*QueryLatestValsetRequestBeforeNonceResponse) Reset 

func (m *QueryLatestValsetRequestBeforeNonceResponse) Reset()

func (*QueryLatestValsetRequestBeforeNonceResponse) Size 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) String 

func (m *QueryLatestValsetRequestBeforeNonceResponse) String() string

func (*QueryLatestValsetRequestBeforeNonceResponse) Unmarshal 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) XXX_DiscardUnknown 

func (m *QueryLatestValsetRequestBeforeNonceResponse) XXX_DiscardUnknown()

func (*QueryLatestValsetRequestBeforeNonceResponse) XXX_Marshal 

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

func (*QueryLatestValsetRequestBeforeNonceResponse) XXX_Merge 

func (m *QueryLatestValsetRequestBeforeNonceResponse) XXX_Merge(src proto.Message)

func (*QueryLatestValsetRequestBeforeNonceResponse) XXX_Size 

func (m *QueryLatestValsetRequestBeforeNonceResponse) XXX_Size() int

func (*QueryLatestValsetRequestBeforeNonceResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

func (m *QueryParamsRequest) XXX_Merge(src proto.Message)

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

func (m *QueryParamsResponse) XXX_Merge(src proto.Message)

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the current parameters for the blobstream module
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// AttestationRequestByNonce queries attestation request by nonce.
	// Returns nil if not found.
	AttestationRequestByNonce(context.Context, *QueryAttestationRequestByNonceRequest) (*QueryAttestationRequestByNonceResponse, error)
	// LatestAttestationNonce queries latest attestation nonce.
	LatestAttestationNonce(context.Context, *QueryLatestAttestationNonceRequest) (*QueryLatestAttestationNonceResponse, error)
	// EarliestAttestationNonce queries the earliest attestation nonce.
	EarliestAttestationNonce(context.Context, *QueryEarliestAttestationNonceRequest) (*QueryEarliestAttestationNonceResponse, error)
	// LatestValsetRequestBeforeNonce Queries latest Valset request before nonce.
	// And, even if the current nonce is a valset, it will return the previous
	// one.
	// If the provided nonce is 1, it will return an error, because, there is
	// no valset before nonce 1.
	LatestValsetRequestBeforeNonce(context.Context, *QueryLatestValsetRequestBeforeNonceRequest) (*QueryLatestValsetRequestBeforeNonceResponse, error)
	// LatestUnbondingHeight returns the latest unbonding height
	LatestUnbondingHeight(context.Context, *QueryLatestUnbondingHeightRequest) (*QueryLatestUnbondingHeightResponse, error)
	// DataCommitmentRangeForHeight returns the data commitment window
	// that includes the provided height
	DataCommitmentRangeForHeight(context.Context, *QueryDataCommitmentRangeForHeightRequest) (*QueryDataCommitmentRangeForHeightResponse, error)
	// LatestDataCommitment returns the latest data commitment in store
	LatestDataCommitment(context.Context, *QueryLatestDataCommitmentRequest) (*QueryLatestDataCommitmentResponse, error)
	// EVMAddress returns the evm address associated with a supplied
	// validator address
	EVMAddress(context.Context, *QueryEVMAddressRequest) (*QueryEVMAddressResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) RegisterEVMAddress 

func (*UnimplementedMsgServer) RegisterEVMAddress(ctx context.Context, req *MsgRegisterEVMAddress) (*MsgRegisterEVMAddressResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AttestationRequestByNonce 

func (*UnimplementedQueryServer) AttestationRequestByNonce(ctx context.Context, req *QueryAttestationRequestByNonceRequest) (*QueryAttestationRequestByNonceResponse, error)

func (*UnimplementedQueryServer) DataCommitmentRangeForHeight 

func (*UnimplementedQueryServer) DataCommitmentRangeForHeight(ctx context.Context, req *QueryDataCommitmentRangeForHeightRequest) (*QueryDataCommitmentRangeForHeightResponse, error)

func (*UnimplementedQueryServer) EVMAddress 

func (*UnimplementedQueryServer) EVMAddress(ctx context.Context, req *QueryEVMAddressRequest) (*QueryEVMAddressResponse, error)

func (*UnimplementedQueryServer) EarliestAttestationNonce 

func (*UnimplementedQueryServer) EarliestAttestationNonce(ctx context.Context, req *QueryEarliestAttestationNonceRequest) (*QueryEarliestAttestationNonceResponse, error)

func (*UnimplementedQueryServer) LatestAttestationNonce 

func (*UnimplementedQueryServer) LatestAttestationNonce(ctx context.Context, req *QueryLatestAttestationNonceRequest) (*QueryLatestAttestationNonceResponse, error)

func (*UnimplementedQueryServer) LatestDataCommitment 

func (*UnimplementedQueryServer) LatestDataCommitment(ctx context.Context, req *QueryLatestDataCommitmentRequest) (*QueryLatestDataCommitmentResponse, error)

func (*UnimplementedQueryServer) LatestUnbondingHeight 

func (*UnimplementedQueryServer) LatestUnbondingHeight(ctx context.Context, req *QueryLatestUnbondingHeightRequest) (*QueryLatestUnbondingHeightResponse, error)

func (*UnimplementedQueryServer) LatestValsetRequestBeforeNonce 

func (*UnimplementedQueryServer) LatestValsetRequestBeforeNonce(ctx context.Context, req *QueryLatestValsetRequestBeforeNonceRequest) (*QueryLatestValsetRequestBeforeNonceResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

type Valset 

type Valset struct {
	// Universal nonce defined under:
	// https://github.com/celestiaorg/celestia-app/pull/464
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// List of BridgeValidator containing the current validator set.
	Members []BridgeValidator `protobuf:"bytes,2,rep,name=members,proto3" json:"members"`
	// Current chain height
	Height uint64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	// Block time where this valset was created
	Time time.Time `protobuf:"bytes,4,opt,name=time,proto3,stdtime" json:"time"`
}

Valset is the EVM Bridge Multsig Set, each Blobstream validator also maintains an ETH key to sign messages, these are used to check signatures on ETH because of the significant gas savings

func NewValset 

func NewValset(nonce, height uint64, members InternalBridgeValidators, blockTime time.Time) (*Valset, error)

NewValset returns a new valset.

func (*Valset) BlockTime 

func (v *Valset) BlockTime() time.Time

func (*Valset) Descriptor 

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

func (*Valset) GetHeight 

func (m *Valset) GetHeight() uint64

func (*Valset) GetMembers 

func (m *Valset) GetMembers() []BridgeValidator

func (*Valset) GetNonce 

func (m *Valset) GetNonce() uint64

func (*Valset) GetTime 

func (m *Valset) GetTime() time.Time

func (*Valset) Hash 

func (v *Valset) Hash() (ethcmn.Hash, error)

Hash mimics the 'computeValsetHash' function used by the Blobstream contracts by using a Valset to compute the hash of the abi encoded validator set.

func (*Valset) Marshal 

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

func (*Valset) MarshalTo 

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

func (*Valset) MarshalToSizedBuffer 

func (m *Valset) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Valset) ProtoMessage 

func (*Valset) ProtoMessage()

func (*Valset) Reset 

func (m *Valset) Reset()

func (*Valset) SignBytes 

func (v *Valset) SignBytes() (ethcmn.Hash, error)

SignBytes produces the bytes that celestia validators are required to sign over when the validator set changes.

func (*Valset) Size 

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

func (*Valset) String 

func (m *Valset) String() string

func (*Valset) TwoThirdsThreshold 

func (v *Valset) TwoThirdsThreshold() uint64

func (*Valset) Unmarshal 

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

func (*Valset) XXX_DiscardUnknown 

func (m *Valset) XXX_DiscardUnknown()

func (*Valset) XXX_Marshal 

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

func (*Valset) XXX_Merge 

func (m *Valset) XXX_Merge(src proto.Message)

func (*Valset) XXX_Size 

func (m *Valset) XXX_Size() int

func (*Valset) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.