README
¶
Celestia Blob Cosmos SDK Module
This module enables posting block data to celestia via the proposing validator.
1. Introduction
1.1 Background
Using a Cosmos chain with a light client tracking Celestia with a proof-of-blob mechanism to confirm that data has been written to the DA within the trusting period allows a familiar architecture to be used with minor modifications, creating a viable path for not only green-field applications but also existing Cosmos chains that wish to take advantage of DA layer guarantees.
1.2 Purpose
This document aims to delineate the architecture required to modify a standard Cosmos chain in order to incorporate Celestia into the trust model, leveraging it for Data Availability with it’s decentralized validator set.
1.3 Scope
The scope encompasses the existing well-known Cosmos SDK app-chain components, the additional Celestia light client created at Genesis, the DA blob publish mechanism, light client update mechanism via Vote Extensions (VE), and proof-of-blob (PoB) mechanism.
2. Architecture
2.1 Design Overview
The proposed architecture provides an option for Rollup applications to use a standard Cosmos SDK app-chain on top of Celestia. This design entails:
- Tendermint mempool for transaction ingest and gossip
- Tendermint validator block proposals for transaction sequencing
- A light client on the Rollup tracking Celestia, created in the Rollup chain state during Genesis
- Standard 07-tendermint light client
- Optionally, DA light client expiration halts the chain. Alternatively for exploration: chain goes into a “recovery mode” where blocks continue to be produced but the only valid transactions are those that can recover the light client e.g. client substitution.
- trusting period of the light client is no more than the data retention window on the DA (period during which ShareCommitment blob-inclusion proofs can be generated)
- An RPC connection from the Rollup validators to the Celestia chain for:
- Relaying ICA blob publish packets or broadcasting blob publish txs directly (covered in 4.2)
- Block header queries to update the light client on the Rollup via Vote Extensions
- ShareCommitment blob-inclusion proof queries for Proof of Blob verification
- Rollchain SDK module:
- final-height - non-skipped incremental height that has blob inclusion proven against the Celestia light client. Blocks at or below this height are considered final.
- validator celestia account mapping - used to feegrant validators on Celestia for paying blob publish tx fees
2.2 Benefits
- It’s, “just a Cosmos chain”. A whole ecosystem of developers are already trained and ready to build with this architecture. Existing chains have a straightforward path to utilizing Celestia for DA.
- Secured by Celestia - the smaller validator set of the rollup has data security guarantees provided by the $500M of staked assets on the Celestia mainnet. The history of rollup chain block data is forever secured by the Celestia validator set.
- Rollchains will be IBC compatible out of the box with all other Cosmos SDK chains, as the 07-tendermint light client can be used both for both tracking counterparties on the rollup, and tracking the rollup on the counterparties.
- Provides a scaling path for existing Cosmos chains to reduce the size of their validator set, enabling faster block times and a slimmer security budget.
- Fullnodes can sync directly from Celestia or from rollchain p2p network.
3. Technical Breakdown
3.1 Light Client Updates via Proposer Injection
Validators have a background go-routine running that is constantly querying the Celestia RPC for new block headers and ShareCommitment proofs, always proof height+1 so that validators can pre-cache proofs instead of having to fetch proofs at pre-vote time. A trusted height is kept in the chain state of the rollup within a new x/tiablob module. During the proposal, the proposing validator packages and signs a client update message in addition to ShareCommitment proofs for heights since the last trusted height that can be verified against the apphash for the new client state height. During block commit, assuming there is consensus on the new state and the proofs are valid, the client state is updated on the rollup and the trust height is incremented within the tiablob module state. The final/trusted height will never skip heights to ensure that all data has been published to DA.
3.2 Validator blob publish fees
MsgPayForBlobs is required as part of the blob publish transaction on Celestia to pay for the inclusion of the data on Celestia. Additionally, the transaction execution fees must be paid.
An ICA on Celestia controlled by the rollchain protocol feegrants all of the validator's Celestia addresses. The proposing validator publishes any outstanding block data above the last proven height to Celestia. This is paid for by the ICA account via feegrant. The proposer also relays any unrelayed ShareCommitment proofs back to the rollchain.
Validators need to generate a Celestia account key within their keyring. ICA feegrant authorization to the validator accounts can be performed automatically in protocol using the validators Celestia accounts registered within the state of the tiablob module. This then only requires a single Celestia account (the ICA) to stay funded, which can be monitored by all of the validators of the rollup. Similarly, If it is an HA PoA deployment, there is only one wallet to monitor.
Appendix 1
1.1 - Rollchain ↔ Celestia Security Model
flowchart LR
subgraph Celestia
rlc[Rollchain Light Client]
subgraph cv [Validator Set]
cVal1[Val1]
cVal2[Val2]
cVal3[...]
cVal4[Val100]
end
end
cv--"2. Proof of Blob via Proposal Injection"-->clc
subgraph Rollchain
clc[Celestia Light Client]
subgraph rv [Validator Set]
rVal1[Val1]
rVal2[Val2]
rVal3[Val3]
rVal4[Val4]
end
end
rv--"1. Proposer Post Blob with ICA Feegrant"-->rlc
1.2 - Rollchain ↔ Celestia Data Flow
flowchart
subgraph Celestia
cv(Validator Set)
subgraph cb [Blocks]
cby(Block y)
end
cs(Blob State)
end
subgraph Rollchain
subgraph Blocks
rbx[Block x]
rbx2[Block x+1]
end
rv(Validator Set)
end
rbx --"1. Post Blob Tx"--> cv
cv --"2. Commit Blob to state"-->cby
cs --"3. Proof of Blob"--> rv
rv -- "4. Verify PoB" --> rv
rv --> rbx2
rbx2 -.-> cv
Documentation
¶
Overview ¶
Package tiablob is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterInterfaces(registry types.InterfaceRegistry)
- func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type BlockWithExpiration
- func (*BlockWithExpiration) Descriptor() ([]byte, []int)
- func (m *BlockWithExpiration) GetExpiration() time.Time
- func (m *BlockWithExpiration) GetHeight() int64
- func (m *BlockWithExpiration) Marshal() (dAtA []byte, err error)
- func (m *BlockWithExpiration) MarshalTo(dAtA []byte) (int, error)
- func (m *BlockWithExpiration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BlockWithExpiration) ProtoMessage()
- func (m *BlockWithExpiration) Reset()
- func (m *BlockWithExpiration) Size() (n int)
- func (m *BlockWithExpiration) String() string
- func (m *BlockWithExpiration) Unmarshal(dAtA []byte) error
- func (m *BlockWithExpiration) XXX_DiscardUnknown()
- func (m *BlockWithExpiration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlockWithExpiration) XXX_Merge(src proto.Message)
- func (m *BlockWithExpiration) XXX_Size() int
- func (m *BlockWithExpiration) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetCelestiaGenesisState() *celestia_da_light_client.GenesisState
- func (m *GenesisState) GetPendingBlocks() []*BlockWithExpiration
- func (m *GenesisState) GetProvenHeight() int64
- func (m *GenesisState) GetValidators() []Validator
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs *GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type InjectedData
- func (*InjectedData) Descriptor() ([]byte, []int)
- func (m *InjectedData) GetCreateClient() *celestia_da_light_client.CreateClient
- func (m *InjectedData) GetHeaders() []*celestia_da_light_client.Header
- func (m *InjectedData) GetPendingBlocks() PendingBlocks
- func (m *InjectedData) GetProofs() []*celestia_da_light_client.BlobProof
- func (d InjectedData) IsEmpty() bool
- func (m *InjectedData) Marshal() (dAtA []byte, err error)
- func (m *InjectedData) MarshalTo(dAtA []byte) (int, error)
- func (m *InjectedData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InjectedData) ProtoMessage()
- func (m *InjectedData) Reset()
- func (m *InjectedData) Size() (n int)
- func (m *InjectedData) String() string
- func (m *InjectedData) Unmarshal(dAtA []byte) error
- func (m *InjectedData) XXX_DiscardUnknown()
- func (m *InjectedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InjectedData) XXX_Merge(src proto.Message)
- func (m *InjectedData) XXX_Size() int
- func (m *InjectedData) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgServer
- type MsgSetCelestiaAddress
- func (*MsgSetCelestiaAddress) Descriptor() ([]byte, []int)
- func (m *MsgSetCelestiaAddress) Marshal() (dAtA []byte, err error)
- func (m *MsgSetCelestiaAddress) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetCelestiaAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetCelestiaAddress) ProtoMessage()
- func (m *MsgSetCelestiaAddress) Reset()
- func (m *MsgSetCelestiaAddress) Size() (n int)
- func (m *MsgSetCelestiaAddress) String() string
- func (m *MsgSetCelestiaAddress) Unmarshal(dAtA []byte) error
- func (msg *MsgSetCelestiaAddress) Validate(ac address.Codec) ([]byte, error)
- func (m *MsgSetCelestiaAddress) XXX_DiscardUnknown()
- func (m *MsgSetCelestiaAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetCelestiaAddress) XXX_Merge(src proto.Message)
- func (m *MsgSetCelestiaAddress) XXX_Size() int
- func (m *MsgSetCelestiaAddress) XXX_Unmarshal(b []byte) error
- type MsgSetCelestiaAddressResponse
- func (*MsgSetCelestiaAddressResponse) Descriptor() ([]byte, []int)
- func (m *MsgSetCelestiaAddressResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgSetCelestiaAddressResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetCelestiaAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetCelestiaAddressResponse) ProtoMessage()
- func (m *MsgSetCelestiaAddressResponse) Reset()
- func (m *MsgSetCelestiaAddressResponse) Size() (n int)
- func (m *MsgSetCelestiaAddressResponse) String() string
- func (m *MsgSetCelestiaAddressResponse) Unmarshal(dAtA []byte) error
- func (m *MsgSetCelestiaAddressResponse) XXX_DiscardUnknown()
- func (m *MsgSetCelestiaAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetCelestiaAddressResponse) XXX_Merge(src proto.Message)
- func (m *MsgSetCelestiaAddressResponse) XXX_Size() int
- func (m *MsgSetCelestiaAddressResponse) XXX_Unmarshal(b []byte) error
- type PendingBlocks
- func (*PendingBlocks) Descriptor() ([]byte, []int)
- func (m *PendingBlocks) GetBlockHeights() []int64
- func (m *PendingBlocks) Marshal() (dAtA []byte, err error)
- func (m *PendingBlocks) MarshalTo(dAtA []byte) (int, error)
- func (m *PendingBlocks) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PendingBlocks) ProtoMessage()
- func (m *PendingBlocks) Reset()
- func (m *PendingBlocks) Size() (n int)
- func (m *PendingBlocks) String() string
- func (m *PendingBlocks) Unmarshal(dAtA []byte) error
- func (m *PendingBlocks) XXX_DiscardUnknown()
- func (m *PendingBlocks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PendingBlocks) XXX_Merge(src proto.Message)
- func (m *PendingBlocks) XXX_Size() int
- func (m *PendingBlocks) XXX_Unmarshal(b []byte) error
- type QueryCelestiaAddressRequest
- func (*QueryCelestiaAddressRequest) Descriptor() ([]byte, []int)
- func (m *QueryCelestiaAddressRequest) GetValidatorAddress() string
- func (m *QueryCelestiaAddressRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryCelestiaAddressRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCelestiaAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCelestiaAddressRequest) ProtoMessage()
- func (m *QueryCelestiaAddressRequest) Reset()
- func (m *QueryCelestiaAddressRequest) Size() (n int)
- func (m *QueryCelestiaAddressRequest) String() string
- func (m *QueryCelestiaAddressRequest) Unmarshal(dAtA []byte) error
- func (m *QueryCelestiaAddressRequest) XXX_DiscardUnknown()
- func (m *QueryCelestiaAddressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCelestiaAddressRequest) XXX_Merge(src proto.Message)
- func (m *QueryCelestiaAddressRequest) XXX_Size() int
- func (m *QueryCelestiaAddressRequest) XXX_Unmarshal(b []byte) error
- type QueryCelestiaAddressResponse
- func (*QueryCelestiaAddressResponse) Descriptor() ([]byte, []int)
- func (m *QueryCelestiaAddressResponse) GetCelestiaAddress() string
- func (m *QueryCelestiaAddressResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryCelestiaAddressResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCelestiaAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCelestiaAddressResponse) ProtoMessage()
- func (m *QueryCelestiaAddressResponse) Reset()
- func (m *QueryCelestiaAddressResponse) Size() (n int)
- func (m *QueryCelestiaAddressResponse) String() string
- func (m *QueryCelestiaAddressResponse) Unmarshal(dAtA []byte) error
- func (m *QueryCelestiaAddressResponse) XXX_DiscardUnknown()
- func (m *QueryCelestiaAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCelestiaAddressResponse) XXX_Merge(src proto.Message)
- func (m *QueryCelestiaAddressResponse) XXX_Size() int
- func (m *QueryCelestiaAddressResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryExpiredBlocksRequest
- func (*QueryExpiredBlocksRequest) Descriptor() ([]byte, []int)
- func (m *QueryExpiredBlocksRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryExpiredBlocksRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExpiredBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExpiredBlocksRequest) ProtoMessage()
- func (m *QueryExpiredBlocksRequest) Reset()
- func (m *QueryExpiredBlocksRequest) Size() (n int)
- func (m *QueryExpiredBlocksRequest) String() string
- func (m *QueryExpiredBlocksRequest) Unmarshal(dAtA []byte) error
- func (m *QueryExpiredBlocksRequest) XXX_DiscardUnknown()
- func (m *QueryExpiredBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExpiredBlocksRequest) XXX_Merge(src proto.Message)
- func (m *QueryExpiredBlocksRequest) XXX_Size() int
- func (m *QueryExpiredBlocksRequest) XXX_Unmarshal(b []byte) error
- type QueryExpiredBlocksResponse
- func (*QueryExpiredBlocksResponse) Descriptor() ([]byte, []int)
- func (m *QueryExpiredBlocksResponse) GetCurrentTime() time.Time
- func (m *QueryExpiredBlocksResponse) GetExpiredBlocks() []*BlockWithExpiration
- func (m *QueryExpiredBlocksResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryExpiredBlocksResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExpiredBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExpiredBlocksResponse) ProtoMessage()
- func (m *QueryExpiredBlocksResponse) Reset()
- func (m *QueryExpiredBlocksResponse) Size() (n int)
- func (m *QueryExpiredBlocksResponse) String() string
- func (m *QueryExpiredBlocksResponse) Unmarshal(dAtA []byte) error
- func (m *QueryExpiredBlocksResponse) XXX_DiscardUnknown()
- func (m *QueryExpiredBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExpiredBlocksResponse) XXX_Merge(src proto.Message)
- func (m *QueryExpiredBlocksResponse) XXX_Size() int
- func (m *QueryExpiredBlocksResponse) XXX_Unmarshal(b []byte) error
- type QueryPendingBlocksRequest
- func (*QueryPendingBlocksRequest) Descriptor() ([]byte, []int)
- func (m *QueryPendingBlocksRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPendingBlocksRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPendingBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPendingBlocksRequest) ProtoMessage()
- func (m *QueryPendingBlocksRequest) Reset()
- func (m *QueryPendingBlocksRequest) Size() (n int)
- func (m *QueryPendingBlocksRequest) String() string
- func (m *QueryPendingBlocksRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPendingBlocksRequest) XXX_DiscardUnknown()
- func (m *QueryPendingBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPendingBlocksRequest) XXX_Merge(src proto.Message)
- func (m *QueryPendingBlocksRequest) XXX_Size() int
- func (m *QueryPendingBlocksRequest) XXX_Unmarshal(b []byte) error
- type QueryPendingBlocksResponse
- func (*QueryPendingBlocksResponse) Descriptor() ([]byte, []int)
- func (m *QueryPendingBlocksResponse) GetPendingBlocks() []*BlockWithExpiration
- func (m *QueryPendingBlocksResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPendingBlocksResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPendingBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPendingBlocksResponse) ProtoMessage()
- func (m *QueryPendingBlocksResponse) Reset()
- func (m *QueryPendingBlocksResponse) Size() (n int)
- func (m *QueryPendingBlocksResponse) String() string
- func (m *QueryPendingBlocksResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPendingBlocksResponse) XXX_DiscardUnknown()
- func (m *QueryPendingBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPendingBlocksResponse) XXX_Merge(src proto.Message)
- func (m *QueryPendingBlocksResponse) XXX_Size() int
- func (m *QueryPendingBlocksResponse) XXX_Unmarshal(b []byte) error
- type QueryProvenHeightRequest
- func (*QueryProvenHeightRequest) Descriptor() ([]byte, []int)
- func (m *QueryProvenHeightRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryProvenHeightRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryProvenHeightRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryProvenHeightRequest) ProtoMessage()
- func (m *QueryProvenHeightRequest) Reset()
- func (m *QueryProvenHeightRequest) Size() (n int)
- func (m *QueryProvenHeightRequest) String() string
- func (m *QueryProvenHeightRequest) Unmarshal(dAtA []byte) error
- func (m *QueryProvenHeightRequest) XXX_DiscardUnknown()
- func (m *QueryProvenHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryProvenHeightRequest) XXX_Merge(src proto.Message)
- func (m *QueryProvenHeightRequest) XXX_Size() int
- func (m *QueryProvenHeightRequest) XXX_Unmarshal(b []byte) error
- type QueryProvenHeightResponse
- func (*QueryProvenHeightResponse) Descriptor() ([]byte, []int)
- func (m *QueryProvenHeightResponse) GetProvenHeight() int64
- func (m *QueryProvenHeightResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryProvenHeightResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryProvenHeightResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryProvenHeightResponse) ProtoMessage()
- func (m *QueryProvenHeightResponse) Reset()
- func (m *QueryProvenHeightResponse) Size() (n int)
- func (m *QueryProvenHeightResponse) String() string
- func (m *QueryProvenHeightResponse) Unmarshal(dAtA []byte) error
- func (m *QueryProvenHeightResponse) XXX_DiscardUnknown()
- func (m *QueryProvenHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryProvenHeightResponse) XXX_Merge(src proto.Message)
- func (m *QueryProvenHeightResponse) XXX_Size() int
- func (m *QueryProvenHeightResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QueryValidatorsRequest
- func (*QueryValidatorsRequest) Descriptor() ([]byte, []int)
- func (m *QueryValidatorsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryValidatorsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryValidatorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryValidatorsRequest) ProtoMessage()
- func (m *QueryValidatorsRequest) Reset()
- func (m *QueryValidatorsRequest) Size() (n int)
- func (m *QueryValidatorsRequest) String() string
- func (m *QueryValidatorsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryValidatorsRequest) XXX_DiscardUnknown()
- func (m *QueryValidatorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryValidatorsRequest) XXX_Merge(src proto.Message)
- func (m *QueryValidatorsRequest) XXX_Size() int
- func (m *QueryValidatorsRequest) XXX_Unmarshal(b []byte) error
- type QueryValidatorsResponse
- func (*QueryValidatorsResponse) Descriptor() ([]byte, []int)
- func (m *QueryValidatorsResponse) GetValidators() []Validator
- func (m *QueryValidatorsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryValidatorsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryValidatorsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryValidatorsResponse) ProtoMessage()
- func (m *QueryValidatorsResponse) Reset()
- func (m *QueryValidatorsResponse) Size() (n int)
- func (m *QueryValidatorsResponse) String() string
- func (m *QueryValidatorsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryValidatorsResponse) XXX_DiscardUnknown()
- func (m *QueryValidatorsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryValidatorsResponse) XXX_Merge(src proto.Message)
- func (m *QueryValidatorsResponse) XXX_Size() int
- func (m *QueryValidatorsResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) CelestiaAddress(ctx context.Context, req *QueryCelestiaAddressRequest) (*QueryCelestiaAddressResponse, error)
- func (*UnimplementedQueryServer) ExpiredBlocks(ctx context.Context, req *QueryExpiredBlocksRequest) (*QueryExpiredBlocksResponse, error)
- func (*UnimplementedQueryServer) PendingBlocks(ctx context.Context, req *QueryPendingBlocksRequest) (*QueryPendingBlocksResponse, error)
- func (*UnimplementedQueryServer) ProvenHeight(ctx context.Context, req *QueryProvenHeightRequest) (*QueryProvenHeightResponse, error)
- func (*UnimplementedQueryServer) Validators(ctx context.Context, req *QueryValidatorsRequest) (*QueryValidatorsResponse, error)
- type UnprovenBlock
- func (*UnprovenBlock) Descriptor() ([]byte, []int)
- func (m *UnprovenBlock) GetBlock() []byte
- func (m *UnprovenBlock) GetHeight() int64
- func (m *UnprovenBlock) Marshal() (dAtA []byte, err error)
- func (m *UnprovenBlock) MarshalTo(dAtA []byte) (int, error)
- func (m *UnprovenBlock) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnprovenBlock) ProtoMessage()
- func (m *UnprovenBlock) Reset()
- func (m *UnprovenBlock) Size() (n int)
- func (m *UnprovenBlock) String() string
- func (m *UnprovenBlock) Unmarshal(dAtA []byte) error
- func (m *UnprovenBlock) XXX_DiscardUnknown()
- func (m *UnprovenBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnprovenBlock) XXX_Merge(src proto.Message)
- func (m *UnprovenBlock) XXX_Size() int
- func (m *UnprovenBlock) XXX_Unmarshal(b []byte) error
- type Validator
- func (*Validator) Descriptor() ([]byte, []int)
- func (m *Validator) GetCelestiaAddress() string
- func (m *Validator) GetValidatorAddress() string
- func (m *Validator) Marshal() (dAtA []byte, err error)
- func (m *Validator) MarshalTo(dAtA []byte) (int, error)
- func (m *Validator) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Validator) ProtoMessage()
- func (m *Validator) Reset()
- func (m *Validator) Size() (n int)
- func (m *Validator) String() string
- func (m *Validator) Unmarshal(dAtA []byte) error
- func (m *Validator) XXX_DiscardUnknown()
- func (m *Validator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Validator) XXX_Merge(src proto.Message)
- func (m *Validator) XXX_Size() int
- func (m *Validator) XXX_Unmarshal(b []byte) error
- type Validators
- func (*Validators) Descriptor() ([]byte, []int)
- func (m *Validators) GetValidators() []Validator
- func (m *Validators) Marshal() (dAtA []byte, err error)
- func (m *Validators) MarshalTo(dAtA []byte) (int, error)
- func (m *Validators) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Validators) ProtoMessage()
- func (m *Validators) Reset()
- func (m *Validators) Size() (n int)
- func (m *Validators) String() string
- func (m *Validators) Unmarshal(dAtA []byte) error
- func (m *Validators) XXX_DiscardUnknown()
- func (m *Validators) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Validators) XXX_Merge(src proto.Message)
- func (m *Validators) XXX_Size() int
- func (m *Validators) XXX_Unmarshal(b []byte) error
Constants ¶
const ( // ModuleName is the name of the module ModuleName = "tiablob" // StoreKey to be used when creating the KVStore StoreKey = ModuleName // RouterKey to be used for routing msgs RouterKey = ModuleName // QuerierRoute to be used for querier msgs QuerierRoute = ModuleName // TransientStoreKey defines the transient store key TransientStoreKey = "transient_" + ModuleName Bech32Celestia = "celestia" AddrLen = 20 )
Variables ¶
var ( ErrInvalidLengthAbci = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAbci = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAbci = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( // ValidatorsKey saves the current validators. ValidatorsKey = collections.NewPrefix(0) // ClientIDKey saves the current clientID. ClientIDKey = collections.NewPrefix(1) // ProvenHeightKey saves the current proven height. ProvenHeightKey = collections.NewPrefix(2) // PendingBlocksToTimeouts maps pending blocks to their timeout PendingBlocksToTimeouts = collections.NewPrefix(3) // TimeoutsToPendingBlocks maps timeouts to a set of pending blocks TimeoutsToPendingBlocks = collections.NewPrefix(4) // light client store key ClientStoreKey = []byte("client_store/") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
Functions ¶
func RegisterInterfaces ¶
func RegisterInterfaces(registry types.InterfaceRegistry)
RegisterInterfaces registers the interfaces types with the interface registry.
func RegisterLegacyAminoCodec ¶
func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
RegisterLegacyAminoCodec registers the necessary interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
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)
Types ¶
type BlockWithExpiration ¶
type BlockWithExpiration struct { Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"` Expiration time.Time `protobuf:"bytes,2,opt,name=expiration,proto3,stdtime" json:"expiration"` }
func (*BlockWithExpiration) Descriptor ¶
func (*BlockWithExpiration) Descriptor() ([]byte, []int)
func (*BlockWithExpiration) GetExpiration ¶
func (m *BlockWithExpiration) GetExpiration() time.Time
func (*BlockWithExpiration) GetHeight ¶
func (m *BlockWithExpiration) GetHeight() int64
func (*BlockWithExpiration) Marshal ¶
func (m *BlockWithExpiration) Marshal() (dAtA []byte, err error)
func (*BlockWithExpiration) MarshalTo ¶
func (m *BlockWithExpiration) MarshalTo(dAtA []byte) (int, error)
func (*BlockWithExpiration) MarshalToSizedBuffer ¶
func (m *BlockWithExpiration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BlockWithExpiration) ProtoMessage ¶
func (*BlockWithExpiration) ProtoMessage()
func (*BlockWithExpiration) Reset ¶
func (m *BlockWithExpiration) Reset()
func (*BlockWithExpiration) Size ¶
func (m *BlockWithExpiration) Size() (n int)
func (*BlockWithExpiration) String ¶
func (m *BlockWithExpiration) String() string
func (*BlockWithExpiration) Unmarshal ¶
func (m *BlockWithExpiration) Unmarshal(dAtA []byte) error
func (*BlockWithExpiration) XXX_DiscardUnknown ¶
func (m *BlockWithExpiration) XXX_DiscardUnknown()
func (*BlockWithExpiration) XXX_Marshal ¶
func (m *BlockWithExpiration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlockWithExpiration) XXX_Merge ¶
func (m *BlockWithExpiration) XXX_Merge(src proto.Message)
func (*BlockWithExpiration) XXX_Size ¶
func (m *BlockWithExpiration) XXX_Size() int
func (*BlockWithExpiration) XXX_Unmarshal ¶
func (m *BlockWithExpiration) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"` // the height of the last block that was proven to be posted to Celestia. // increment only, never skipping heights. ProvenHeight int64 `protobuf:"varint,2,opt,name=proven_height,json=provenHeight,proto3" json:"proven_height,omitempty"` CelestiaGenesisState *celestia_da_light_client.GenesisState `protobuf:"bytes,3,opt,name=celestia_genesis_state,json=celestiaGenesisState,proto3" json:"celestia_genesis_state,omitempty"` PendingBlocks []*BlockWithExpiration `protobuf:"bytes,4,rep,name=pending_blocks,json=pendingBlocks,proto3" json:"pending_blocks,omitempty"` }
GenesisState defines the rollchain module's genesis state.
func NewGenesisState ¶
func NewGenesisState() *GenesisState
NewGenesisState creates a new genesis state with default values.
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetCelestiaGenesisState ¶
func (m *GenesisState) GetCelestiaGenesisState() *celestia_da_light_client.GenesisState
func (*GenesisState) GetPendingBlocks ¶
func (m *GenesisState) GetPendingBlocks() []*BlockWithExpiration
func (*GenesisState) GetProvenHeight ¶
func (m *GenesisState) GetProvenHeight() int64
func (*GenesisState) GetValidators ¶
func (m *GenesisState) GetValidators() []Validator
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err 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
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 InjectedData ¶
type InjectedData struct { CreateClient *celestia_da_light_client.CreateClient `protobuf:"bytes,1,opt,name=create_client,json=createClient,proto3" json:"create_client,omitempty"` Headers []*celestia_da_light_client.Header `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"` Proofs []*celestia_da_light_client.BlobProof `protobuf:"bytes,3,rep,name=proofs,proto3" json:"proofs,omitempty"` PendingBlocks PendingBlocks `protobuf:"bytes,4,opt,name=pending_blocks,json=pendingBlocks,proto3" json:"pending_blocks"` }
func (*InjectedData) Descriptor ¶
func (*InjectedData) Descriptor() ([]byte, []int)
func (*InjectedData) GetCreateClient ¶
func (m *InjectedData) GetCreateClient() *celestia_da_light_client.CreateClient
func (*InjectedData) GetHeaders ¶
func (m *InjectedData) GetHeaders() []*celestia_da_light_client.Header
func (*InjectedData) GetPendingBlocks ¶
func (m *InjectedData) GetPendingBlocks() PendingBlocks
func (*InjectedData) GetProofs ¶
func (m *InjectedData) GetProofs() []*celestia_da_light_client.BlobProof
func (InjectedData) IsEmpty ¶
func (d InjectedData) IsEmpty() bool
func (*InjectedData) Marshal ¶
func (m *InjectedData) Marshal() (dAtA []byte, err error)
func (*InjectedData) MarshalToSizedBuffer ¶
func (m *InjectedData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InjectedData) ProtoMessage ¶
func (*InjectedData) ProtoMessage()
func (*InjectedData) Reset ¶
func (m *InjectedData) Reset()
func (*InjectedData) Size ¶
func (m *InjectedData) Size() (n int)
func (*InjectedData) String ¶
func (m *InjectedData) String() string
func (*InjectedData) Unmarshal ¶
func (m *InjectedData) Unmarshal(dAtA []byte) error
func (*InjectedData) XXX_DiscardUnknown ¶
func (m *InjectedData) XXX_DiscardUnknown()
func (*InjectedData) XXX_Marshal ¶
func (m *InjectedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InjectedData) XXX_Merge ¶
func (m *InjectedData) XXX_Merge(src proto.Message)
func (*InjectedData) XXX_Size ¶
func (m *InjectedData) XXX_Size() int
func (*InjectedData) XXX_Unmarshal ¶
func (m *InjectedData) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { // SetCelestiaAddress allows a validator to configure their Celestia address for feegranting SetCelestiaAddress(ctx context.Context, in *MsgSetCelestiaAddress, opts ...grpc.CallOption) (*MsgSetCelestiaAddressResponse, 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 MsgServer ¶
type MsgServer interface { // SetCelestiaAddress allows a validator to configure their Celestia address for feegranting SetCelestiaAddress(context.Context, *MsgSetCelestiaAddress) (*MsgSetCelestiaAddressResponse, error) }
MsgServer is the server API for Msg service.
type MsgSetCelestiaAddress ¶
type MsgSetCelestiaAddress struct { ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"` CelestiaAddress string `protobuf:"bytes,2,opt,name=celestia_address,json=celestiaAddress,proto3" json:"celestia_address,omitempty"` }
MsgSetCelestiaAddress defines a SDK message for validators to set their Celestia address
func (*MsgSetCelestiaAddress) Descriptor ¶
func (*MsgSetCelestiaAddress) Descriptor() ([]byte, []int)
func (*MsgSetCelestiaAddress) Marshal ¶
func (m *MsgSetCelestiaAddress) Marshal() (dAtA []byte, err error)
func (*MsgSetCelestiaAddress) MarshalTo ¶
func (m *MsgSetCelestiaAddress) MarshalTo(dAtA []byte) (int, error)
func (*MsgSetCelestiaAddress) MarshalToSizedBuffer ¶
func (m *MsgSetCelestiaAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetCelestiaAddress) ProtoMessage ¶
func (*MsgSetCelestiaAddress) ProtoMessage()
func (*MsgSetCelestiaAddress) Reset ¶
func (m *MsgSetCelestiaAddress) Reset()
func (*MsgSetCelestiaAddress) Size ¶
func (m *MsgSetCelestiaAddress) Size() (n int)
func (*MsgSetCelestiaAddress) String ¶
func (m *MsgSetCelestiaAddress) String() string
func (*MsgSetCelestiaAddress) Unmarshal ¶
func (m *MsgSetCelestiaAddress) Unmarshal(dAtA []byte) error
func (*MsgSetCelestiaAddress) Validate ¶
func (msg *MsgSetCelestiaAddress) Validate(ac address.Codec) ([]byte, error)
func (*MsgSetCelestiaAddress) XXX_DiscardUnknown ¶
func (m *MsgSetCelestiaAddress) XXX_DiscardUnknown()
func (*MsgSetCelestiaAddress) XXX_Marshal ¶
func (m *MsgSetCelestiaAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetCelestiaAddress) XXX_Merge ¶
func (m *MsgSetCelestiaAddress) XXX_Merge(src proto.Message)
func (*MsgSetCelestiaAddress) XXX_Size ¶
func (m *MsgSetCelestiaAddress) XXX_Size() int
func (*MsgSetCelestiaAddress) XXX_Unmarshal ¶
func (m *MsgSetCelestiaAddress) XXX_Unmarshal(b []byte) error
type MsgSetCelestiaAddressResponse ¶
type MsgSetCelestiaAddressResponse struct { }
MsgSetCelestiaAddressResponse is the response type for the Msg/SetCelestiaAddress RPC method.
func (*MsgSetCelestiaAddressResponse) Descriptor ¶
func (*MsgSetCelestiaAddressResponse) Descriptor() ([]byte, []int)
func (*MsgSetCelestiaAddressResponse) Marshal ¶
func (m *MsgSetCelestiaAddressResponse) Marshal() (dAtA []byte, err error)
func (*MsgSetCelestiaAddressResponse) MarshalTo ¶
func (m *MsgSetCelestiaAddressResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgSetCelestiaAddressResponse) MarshalToSizedBuffer ¶
func (m *MsgSetCelestiaAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetCelestiaAddressResponse) ProtoMessage ¶
func (*MsgSetCelestiaAddressResponse) ProtoMessage()
func (*MsgSetCelestiaAddressResponse) Reset ¶
func (m *MsgSetCelestiaAddressResponse) Reset()
func (*MsgSetCelestiaAddressResponse) Size ¶
func (m *MsgSetCelestiaAddressResponse) Size() (n int)
func (*MsgSetCelestiaAddressResponse) String ¶
func (m *MsgSetCelestiaAddressResponse) String() string
func (*MsgSetCelestiaAddressResponse) Unmarshal ¶
func (m *MsgSetCelestiaAddressResponse) Unmarshal(dAtA []byte) error
func (*MsgSetCelestiaAddressResponse) XXX_DiscardUnknown ¶
func (m *MsgSetCelestiaAddressResponse) XXX_DiscardUnknown()
func (*MsgSetCelestiaAddressResponse) XXX_Marshal ¶
func (m *MsgSetCelestiaAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetCelestiaAddressResponse) XXX_Merge ¶
func (m *MsgSetCelestiaAddressResponse) XXX_Merge(src proto.Message)
func (*MsgSetCelestiaAddressResponse) XXX_Size ¶
func (m *MsgSetCelestiaAddressResponse) XXX_Size() int
func (*MsgSetCelestiaAddressResponse) XXX_Unmarshal ¶
func (m *MsgSetCelestiaAddressResponse) XXX_Unmarshal(b []byte) error
type PendingBlocks ¶
type PendingBlocks struct {
BlockHeights []int64 `protobuf:"varint,1,rep,packed,name=block_heights,json=blockHeights,proto3" json:"block_heights,omitempty"`
}
func (*PendingBlocks) Descriptor ¶
func (*PendingBlocks) Descriptor() ([]byte, []int)
func (*PendingBlocks) GetBlockHeights ¶
func (m *PendingBlocks) GetBlockHeights() []int64
func (*PendingBlocks) Marshal ¶
func (m *PendingBlocks) Marshal() (dAtA []byte, err error)
func (*PendingBlocks) MarshalToSizedBuffer ¶
func (m *PendingBlocks) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PendingBlocks) ProtoMessage ¶
func (*PendingBlocks) ProtoMessage()
func (*PendingBlocks) Reset ¶
func (m *PendingBlocks) Reset()
func (*PendingBlocks) Size ¶
func (m *PendingBlocks) Size() (n int)
func (*PendingBlocks) String ¶
func (m *PendingBlocks) String() string
func (*PendingBlocks) Unmarshal ¶
func (m *PendingBlocks) Unmarshal(dAtA []byte) error
func (*PendingBlocks) XXX_DiscardUnknown ¶
func (m *PendingBlocks) XXX_DiscardUnknown()
func (*PendingBlocks) XXX_Marshal ¶
func (m *PendingBlocks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PendingBlocks) XXX_Merge ¶
func (m *PendingBlocks) XXX_Merge(src proto.Message)
func (*PendingBlocks) XXX_Size ¶
func (m *PendingBlocks) XXX_Size() int
func (*PendingBlocks) XXX_Unmarshal ¶
func (m *PendingBlocks) XXX_Unmarshal(b []byte) error
type QueryCelestiaAddressRequest ¶
type QueryCelestiaAddressRequest struct {
ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}
QueryCelestiaAddressRequest is the request type for the Query/CelestiaAddress RPC method.
func (*QueryCelestiaAddressRequest) Descriptor ¶
func (*QueryCelestiaAddressRequest) Descriptor() ([]byte, []int)
func (*QueryCelestiaAddressRequest) GetValidatorAddress ¶
func (m *QueryCelestiaAddressRequest) GetValidatorAddress() string
func (*QueryCelestiaAddressRequest) Marshal ¶
func (m *QueryCelestiaAddressRequest) Marshal() (dAtA []byte, err error)
func (*QueryCelestiaAddressRequest) MarshalTo ¶
func (m *QueryCelestiaAddressRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryCelestiaAddressRequest) MarshalToSizedBuffer ¶
func (m *QueryCelestiaAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCelestiaAddressRequest) ProtoMessage ¶
func (*QueryCelestiaAddressRequest) ProtoMessage()
func (*QueryCelestiaAddressRequest) Reset ¶
func (m *QueryCelestiaAddressRequest) Reset()
func (*QueryCelestiaAddressRequest) Size ¶
func (m *QueryCelestiaAddressRequest) Size() (n int)
func (*QueryCelestiaAddressRequest) String ¶
func (m *QueryCelestiaAddressRequest) String() string
func (*QueryCelestiaAddressRequest) Unmarshal ¶
func (m *QueryCelestiaAddressRequest) Unmarshal(dAtA []byte) error
func (*QueryCelestiaAddressRequest) XXX_DiscardUnknown ¶
func (m *QueryCelestiaAddressRequest) XXX_DiscardUnknown()
func (*QueryCelestiaAddressRequest) XXX_Marshal ¶
func (m *QueryCelestiaAddressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCelestiaAddressRequest) XXX_Merge ¶
func (m *QueryCelestiaAddressRequest) XXX_Merge(src proto.Message)
func (*QueryCelestiaAddressRequest) XXX_Size ¶
func (m *QueryCelestiaAddressRequest) XXX_Size() int
func (*QueryCelestiaAddressRequest) XXX_Unmarshal ¶
func (m *QueryCelestiaAddressRequest) XXX_Unmarshal(b []byte) error
type QueryCelestiaAddressResponse ¶
type QueryCelestiaAddressResponse struct {
CelestiaAddress string `protobuf:"bytes,1,opt,name=celestia_address,json=celestiaAddress,proto3" json:"celestia_address,omitempty"`
}
QueryCelestiaAddressResponse is the response type for the Query/CelestiaAddress RPC method.
func (*QueryCelestiaAddressResponse) Descriptor ¶
func (*QueryCelestiaAddressResponse) Descriptor() ([]byte, []int)
func (*QueryCelestiaAddressResponse) GetCelestiaAddress ¶
func (m *QueryCelestiaAddressResponse) GetCelestiaAddress() string
func (*QueryCelestiaAddressResponse) Marshal ¶
func (m *QueryCelestiaAddressResponse) Marshal() (dAtA []byte, err error)
func (*QueryCelestiaAddressResponse) MarshalTo ¶
func (m *QueryCelestiaAddressResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryCelestiaAddressResponse) MarshalToSizedBuffer ¶
func (m *QueryCelestiaAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCelestiaAddressResponse) ProtoMessage ¶
func (*QueryCelestiaAddressResponse) ProtoMessage()
func (*QueryCelestiaAddressResponse) Reset ¶
func (m *QueryCelestiaAddressResponse) Reset()
func (*QueryCelestiaAddressResponse) Size ¶
func (m *QueryCelestiaAddressResponse) Size() (n int)
func (*QueryCelestiaAddressResponse) String ¶
func (m *QueryCelestiaAddressResponse) String() string
func (*QueryCelestiaAddressResponse) Unmarshal ¶
func (m *QueryCelestiaAddressResponse) Unmarshal(dAtA []byte) error
func (*QueryCelestiaAddressResponse) XXX_DiscardUnknown ¶
func (m *QueryCelestiaAddressResponse) XXX_DiscardUnknown()
func (*QueryCelestiaAddressResponse) XXX_Marshal ¶
func (m *QueryCelestiaAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCelestiaAddressResponse) XXX_Merge ¶
func (m *QueryCelestiaAddressResponse) XXX_Merge(src proto.Message)
func (*QueryCelestiaAddressResponse) XXX_Size ¶
func (m *QueryCelestiaAddressResponse) XXX_Size() int
func (*QueryCelestiaAddressResponse) XXX_Unmarshal ¶
func (m *QueryCelestiaAddressResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Validators returns registered validators of the module. Validators(ctx context.Context, in *QueryValidatorsRequest, opts ...grpc.CallOption) (*QueryValidatorsResponse, error) CelestiaAddress(ctx context.Context, in *QueryCelestiaAddressRequest, opts ...grpc.CallOption) (*QueryCelestiaAddressResponse, error) ProvenHeight(ctx context.Context, in *QueryProvenHeightRequest, opts ...grpc.CallOption) (*QueryProvenHeightResponse, error) PendingBlocks(ctx context.Context, in *QueryPendingBlocksRequest, opts ...grpc.CallOption) (*QueryPendingBlocksResponse, error) ExpiredBlocks(ctx context.Context, in *QueryExpiredBlocksRequest, opts ...grpc.CallOption) (*QueryExpiredBlocksResponse, 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 QueryExpiredBlocksRequest ¶
type QueryExpiredBlocksRequest struct { }
func (*QueryExpiredBlocksRequest) Descriptor ¶
func (*QueryExpiredBlocksRequest) Descriptor() ([]byte, []int)
func (*QueryExpiredBlocksRequest) Marshal ¶
func (m *QueryExpiredBlocksRequest) Marshal() (dAtA []byte, err error)
func (*QueryExpiredBlocksRequest) MarshalTo ¶
func (m *QueryExpiredBlocksRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryExpiredBlocksRequest) MarshalToSizedBuffer ¶
func (m *QueryExpiredBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExpiredBlocksRequest) ProtoMessage ¶
func (*QueryExpiredBlocksRequest) ProtoMessage()
func (*QueryExpiredBlocksRequest) Reset ¶
func (m *QueryExpiredBlocksRequest) Reset()
func (*QueryExpiredBlocksRequest) Size ¶
func (m *QueryExpiredBlocksRequest) Size() (n int)
func (*QueryExpiredBlocksRequest) String ¶
func (m *QueryExpiredBlocksRequest) String() string
func (*QueryExpiredBlocksRequest) Unmarshal ¶
func (m *QueryExpiredBlocksRequest) Unmarshal(dAtA []byte) error
func (*QueryExpiredBlocksRequest) XXX_DiscardUnknown ¶
func (m *QueryExpiredBlocksRequest) XXX_DiscardUnknown()
func (*QueryExpiredBlocksRequest) XXX_Marshal ¶
func (m *QueryExpiredBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExpiredBlocksRequest) XXX_Merge ¶
func (m *QueryExpiredBlocksRequest) XXX_Merge(src proto.Message)
func (*QueryExpiredBlocksRequest) XXX_Size ¶
func (m *QueryExpiredBlocksRequest) XXX_Size() int
func (*QueryExpiredBlocksRequest) XXX_Unmarshal ¶
func (m *QueryExpiredBlocksRequest) XXX_Unmarshal(b []byte) error
type QueryExpiredBlocksResponse ¶
type QueryExpiredBlocksResponse struct { CurrentTime time.Time `protobuf:"bytes,1,opt,name=current_time,json=currentTime,proto3,stdtime" json:"current_time"` ExpiredBlocks []*BlockWithExpiration `protobuf:"bytes,2,rep,name=expired_blocks,json=expiredBlocks,proto3" json:"expired_blocks,omitempty"` }
func (*QueryExpiredBlocksResponse) Descriptor ¶
func (*QueryExpiredBlocksResponse) Descriptor() ([]byte, []int)
func (*QueryExpiredBlocksResponse) GetCurrentTime ¶
func (m *QueryExpiredBlocksResponse) GetCurrentTime() time.Time
func (*QueryExpiredBlocksResponse) GetExpiredBlocks ¶
func (m *QueryExpiredBlocksResponse) GetExpiredBlocks() []*BlockWithExpiration
func (*QueryExpiredBlocksResponse) Marshal ¶
func (m *QueryExpiredBlocksResponse) Marshal() (dAtA []byte, err error)
func (*QueryExpiredBlocksResponse) MarshalTo ¶
func (m *QueryExpiredBlocksResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryExpiredBlocksResponse) MarshalToSizedBuffer ¶
func (m *QueryExpiredBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExpiredBlocksResponse) ProtoMessage ¶
func (*QueryExpiredBlocksResponse) ProtoMessage()
func (*QueryExpiredBlocksResponse) Reset ¶
func (m *QueryExpiredBlocksResponse) Reset()
func (*QueryExpiredBlocksResponse) Size ¶
func (m *QueryExpiredBlocksResponse) Size() (n int)
func (*QueryExpiredBlocksResponse) String ¶
func (m *QueryExpiredBlocksResponse) String() string
func (*QueryExpiredBlocksResponse) Unmarshal ¶
func (m *QueryExpiredBlocksResponse) Unmarshal(dAtA []byte) error
func (*QueryExpiredBlocksResponse) XXX_DiscardUnknown ¶
func (m *QueryExpiredBlocksResponse) XXX_DiscardUnknown()
func (*QueryExpiredBlocksResponse) XXX_Marshal ¶
func (m *QueryExpiredBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExpiredBlocksResponse) XXX_Merge ¶
func (m *QueryExpiredBlocksResponse) XXX_Merge(src proto.Message)
func (*QueryExpiredBlocksResponse) XXX_Size ¶
func (m *QueryExpiredBlocksResponse) XXX_Size() int
func (*QueryExpiredBlocksResponse) XXX_Unmarshal ¶
func (m *QueryExpiredBlocksResponse) XXX_Unmarshal(b []byte) error
type QueryPendingBlocksRequest ¶
type QueryPendingBlocksRequest struct { }
func (*QueryPendingBlocksRequest) Descriptor ¶
func (*QueryPendingBlocksRequest) Descriptor() ([]byte, []int)
func (*QueryPendingBlocksRequest) Marshal ¶
func (m *QueryPendingBlocksRequest) Marshal() (dAtA []byte, err error)
func (*QueryPendingBlocksRequest) MarshalTo ¶
func (m *QueryPendingBlocksRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPendingBlocksRequest) MarshalToSizedBuffer ¶
func (m *QueryPendingBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPendingBlocksRequest) ProtoMessage ¶
func (*QueryPendingBlocksRequest) ProtoMessage()
func (*QueryPendingBlocksRequest) Reset ¶
func (m *QueryPendingBlocksRequest) Reset()
func (*QueryPendingBlocksRequest) Size ¶
func (m *QueryPendingBlocksRequest) Size() (n int)
func (*QueryPendingBlocksRequest) String ¶
func (m *QueryPendingBlocksRequest) String() string
func (*QueryPendingBlocksRequest) Unmarshal ¶
func (m *QueryPendingBlocksRequest) Unmarshal(dAtA []byte) error
func (*QueryPendingBlocksRequest) XXX_DiscardUnknown ¶
func (m *QueryPendingBlocksRequest) XXX_DiscardUnknown()
func (*QueryPendingBlocksRequest) XXX_Marshal ¶
func (m *QueryPendingBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPendingBlocksRequest) XXX_Merge ¶
func (m *QueryPendingBlocksRequest) XXX_Merge(src proto.Message)
func (*QueryPendingBlocksRequest) XXX_Size ¶
func (m *QueryPendingBlocksRequest) XXX_Size() int
func (*QueryPendingBlocksRequest) XXX_Unmarshal ¶
func (m *QueryPendingBlocksRequest) XXX_Unmarshal(b []byte) error
type QueryPendingBlocksResponse ¶
type QueryPendingBlocksResponse struct {
PendingBlocks []*BlockWithExpiration `protobuf:"bytes,1,rep,name=pending_blocks,json=pendingBlocks,proto3" json:"pending_blocks,omitempty"`
}
func (*QueryPendingBlocksResponse) Descriptor ¶
func (*QueryPendingBlocksResponse) Descriptor() ([]byte, []int)
func (*QueryPendingBlocksResponse) GetPendingBlocks ¶
func (m *QueryPendingBlocksResponse) GetPendingBlocks() []*BlockWithExpiration
func (*QueryPendingBlocksResponse) Marshal ¶
func (m *QueryPendingBlocksResponse) Marshal() (dAtA []byte, err error)
func (*QueryPendingBlocksResponse) MarshalTo ¶
func (m *QueryPendingBlocksResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPendingBlocksResponse) MarshalToSizedBuffer ¶
func (m *QueryPendingBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPendingBlocksResponse) ProtoMessage ¶
func (*QueryPendingBlocksResponse) ProtoMessage()
func (*QueryPendingBlocksResponse) Reset ¶
func (m *QueryPendingBlocksResponse) Reset()
func (*QueryPendingBlocksResponse) Size ¶
func (m *QueryPendingBlocksResponse) Size() (n int)
func (*QueryPendingBlocksResponse) String ¶
func (m *QueryPendingBlocksResponse) String() string
func (*QueryPendingBlocksResponse) Unmarshal ¶
func (m *QueryPendingBlocksResponse) Unmarshal(dAtA []byte) error
func (*QueryPendingBlocksResponse) XXX_DiscardUnknown ¶
func (m *QueryPendingBlocksResponse) XXX_DiscardUnknown()
func (*QueryPendingBlocksResponse) XXX_Marshal ¶
func (m *QueryPendingBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPendingBlocksResponse) XXX_Merge ¶
func (m *QueryPendingBlocksResponse) XXX_Merge(src proto.Message)
func (*QueryPendingBlocksResponse) XXX_Size ¶
func (m *QueryPendingBlocksResponse) XXX_Size() int
func (*QueryPendingBlocksResponse) XXX_Unmarshal ¶
func (m *QueryPendingBlocksResponse) XXX_Unmarshal(b []byte) error
type QueryProvenHeightRequest ¶
type QueryProvenHeightRequest struct { }
func (*QueryProvenHeightRequest) Descriptor ¶
func (*QueryProvenHeightRequest) Descriptor() ([]byte, []int)
func (*QueryProvenHeightRequest) Marshal ¶
func (m *QueryProvenHeightRequest) Marshal() (dAtA []byte, err error)
func (*QueryProvenHeightRequest) MarshalTo ¶
func (m *QueryProvenHeightRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryProvenHeightRequest) MarshalToSizedBuffer ¶
func (m *QueryProvenHeightRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryProvenHeightRequest) ProtoMessage ¶
func (*QueryProvenHeightRequest) ProtoMessage()
func (*QueryProvenHeightRequest) Reset ¶
func (m *QueryProvenHeightRequest) Reset()
func (*QueryProvenHeightRequest) Size ¶
func (m *QueryProvenHeightRequest) Size() (n int)
func (*QueryProvenHeightRequest) String ¶
func (m *QueryProvenHeightRequest) String() string
func (*QueryProvenHeightRequest) Unmarshal ¶
func (m *QueryProvenHeightRequest) Unmarshal(dAtA []byte) error
func (*QueryProvenHeightRequest) XXX_DiscardUnknown ¶
func (m *QueryProvenHeightRequest) XXX_DiscardUnknown()
func (*QueryProvenHeightRequest) XXX_Marshal ¶
func (m *QueryProvenHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryProvenHeightRequest) XXX_Merge ¶
func (m *QueryProvenHeightRequest) XXX_Merge(src proto.Message)
func (*QueryProvenHeightRequest) XXX_Size ¶
func (m *QueryProvenHeightRequest) XXX_Size() int
func (*QueryProvenHeightRequest) XXX_Unmarshal ¶
func (m *QueryProvenHeightRequest) XXX_Unmarshal(b []byte) error
type QueryProvenHeightResponse ¶
type QueryProvenHeightResponse struct {
ProvenHeight int64 `protobuf:"varint,1,opt,name=proven_height,json=provenHeight,proto3" json:"proven_height,omitempty"`
}
func (*QueryProvenHeightResponse) Descriptor ¶
func (*QueryProvenHeightResponse) Descriptor() ([]byte, []int)
func (*QueryProvenHeightResponse) GetProvenHeight ¶
func (m *QueryProvenHeightResponse) GetProvenHeight() int64
func (*QueryProvenHeightResponse) Marshal ¶
func (m *QueryProvenHeightResponse) Marshal() (dAtA []byte, err error)
func (*QueryProvenHeightResponse) MarshalTo ¶
func (m *QueryProvenHeightResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryProvenHeightResponse) MarshalToSizedBuffer ¶
func (m *QueryProvenHeightResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryProvenHeightResponse) ProtoMessage ¶
func (*QueryProvenHeightResponse) ProtoMessage()
func (*QueryProvenHeightResponse) Reset ¶
func (m *QueryProvenHeightResponse) Reset()
func (*QueryProvenHeightResponse) Size ¶
func (m *QueryProvenHeightResponse) Size() (n int)
func (*QueryProvenHeightResponse) String ¶
func (m *QueryProvenHeightResponse) String() string
func (*QueryProvenHeightResponse) Unmarshal ¶
func (m *QueryProvenHeightResponse) Unmarshal(dAtA []byte) error
func (*QueryProvenHeightResponse) XXX_DiscardUnknown ¶
func (m *QueryProvenHeightResponse) XXX_DiscardUnknown()
func (*QueryProvenHeightResponse) XXX_Marshal ¶
func (m *QueryProvenHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryProvenHeightResponse) XXX_Merge ¶
func (m *QueryProvenHeightResponse) XXX_Merge(src proto.Message)
func (*QueryProvenHeightResponse) XXX_Size ¶
func (m *QueryProvenHeightResponse) XXX_Size() int
func (*QueryProvenHeightResponse) XXX_Unmarshal ¶
func (m *QueryProvenHeightResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Validators returns registered validators of the module. Validators(context.Context, *QueryValidatorsRequest) (*QueryValidatorsResponse, error) CelestiaAddress(context.Context, *QueryCelestiaAddressRequest) (*QueryCelestiaAddressResponse, error) ProvenHeight(context.Context, *QueryProvenHeightRequest) (*QueryProvenHeightResponse, error) PendingBlocks(context.Context, *QueryPendingBlocksRequest) (*QueryPendingBlocksResponse, error) ExpiredBlocks(context.Context, *QueryExpiredBlocksRequest) (*QueryExpiredBlocksResponse, error) }
QueryServer is the server API for Query service.
type QueryValidatorsRequest ¶
type QueryValidatorsRequest struct { }
QueryValidatorsRequest is the request type for the Query/Validators RPC method.
func (*QueryValidatorsRequest) Descriptor ¶
func (*QueryValidatorsRequest) Descriptor() ([]byte, []int)
func (*QueryValidatorsRequest) Marshal ¶
func (m *QueryValidatorsRequest) Marshal() (dAtA []byte, err error)
func (*QueryValidatorsRequest) MarshalTo ¶
func (m *QueryValidatorsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryValidatorsRequest) MarshalToSizedBuffer ¶
func (m *QueryValidatorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryValidatorsRequest) ProtoMessage ¶
func (*QueryValidatorsRequest) ProtoMessage()
func (*QueryValidatorsRequest) Reset ¶
func (m *QueryValidatorsRequest) Reset()
func (*QueryValidatorsRequest) Size ¶
func (m *QueryValidatorsRequest) Size() (n int)
func (*QueryValidatorsRequest) String ¶
func (m *QueryValidatorsRequest) String() string
func (*QueryValidatorsRequest) Unmarshal ¶
func (m *QueryValidatorsRequest) Unmarshal(dAtA []byte) error
func (*QueryValidatorsRequest) XXX_DiscardUnknown ¶
func (m *QueryValidatorsRequest) XXX_DiscardUnknown()
func (*QueryValidatorsRequest) XXX_Marshal ¶
func (m *QueryValidatorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryValidatorsRequest) XXX_Merge ¶
func (m *QueryValidatorsRequest) XXX_Merge(src proto.Message)
func (*QueryValidatorsRequest) XXX_Size ¶
func (m *QueryValidatorsRequest) XXX_Size() int
func (*QueryValidatorsRequest) XXX_Unmarshal ¶
func (m *QueryValidatorsRequest) XXX_Unmarshal(b []byte) error
type QueryValidatorsResponse ¶
type QueryValidatorsResponse struct { // validators is the returned validators from the module Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"` }
QueryValidatorResponse is the response type for the Query/Validators RPC method.
func (*QueryValidatorsResponse) Descriptor ¶
func (*QueryValidatorsResponse) Descriptor() ([]byte, []int)
func (*QueryValidatorsResponse) GetValidators ¶
func (m *QueryValidatorsResponse) GetValidators() []Validator
func (*QueryValidatorsResponse) Marshal ¶
func (m *QueryValidatorsResponse) Marshal() (dAtA []byte, err error)
func (*QueryValidatorsResponse) MarshalTo ¶
func (m *QueryValidatorsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryValidatorsResponse) MarshalToSizedBuffer ¶
func (m *QueryValidatorsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryValidatorsResponse) ProtoMessage ¶
func (*QueryValidatorsResponse) ProtoMessage()
func (*QueryValidatorsResponse) Reset ¶
func (m *QueryValidatorsResponse) Reset()
func (*QueryValidatorsResponse) Size ¶
func (m *QueryValidatorsResponse) Size() (n int)
func (*QueryValidatorsResponse) String ¶
func (m *QueryValidatorsResponse) String() string
func (*QueryValidatorsResponse) Unmarshal ¶
func (m *QueryValidatorsResponse) Unmarshal(dAtA []byte) error
func (*QueryValidatorsResponse) XXX_DiscardUnknown ¶
func (m *QueryValidatorsResponse) XXX_DiscardUnknown()
func (*QueryValidatorsResponse) XXX_Marshal ¶
func (m *QueryValidatorsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryValidatorsResponse) XXX_Merge ¶
func (m *QueryValidatorsResponse) XXX_Merge(src proto.Message)
func (*QueryValidatorsResponse) XXX_Size ¶
func (m *QueryValidatorsResponse) XXX_Size() int
func (*QueryValidatorsResponse) XXX_Unmarshal ¶
func (m *QueryValidatorsResponse) XXX_Unmarshal(b []byte) error
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) SetCelestiaAddress ¶
func (*UnimplementedMsgServer) SetCelestiaAddress(ctx context.Context, req *MsgSetCelestiaAddress) (*MsgSetCelestiaAddressResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) CelestiaAddress ¶
func (*UnimplementedQueryServer) CelestiaAddress(ctx context.Context, req *QueryCelestiaAddressRequest) (*QueryCelestiaAddressResponse, error)
func (*UnimplementedQueryServer) ExpiredBlocks ¶
func (*UnimplementedQueryServer) ExpiredBlocks(ctx context.Context, req *QueryExpiredBlocksRequest) (*QueryExpiredBlocksResponse, error)
func (*UnimplementedQueryServer) PendingBlocks ¶
func (*UnimplementedQueryServer) PendingBlocks(ctx context.Context, req *QueryPendingBlocksRequest) (*QueryPendingBlocksResponse, error)
func (*UnimplementedQueryServer) ProvenHeight ¶
func (*UnimplementedQueryServer) ProvenHeight(ctx context.Context, req *QueryProvenHeightRequest) (*QueryProvenHeightResponse, error)
func (*UnimplementedQueryServer) Validators ¶
func (*UnimplementedQueryServer) Validators(ctx context.Context, req *QueryValidatorsRequest) (*QueryValidatorsResponse, error)
type UnprovenBlock ¶
type UnprovenBlock struct { Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"` Block []byte `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"` }
func (*UnprovenBlock) Descriptor ¶
func (*UnprovenBlock) Descriptor() ([]byte, []int)
func (*UnprovenBlock) GetBlock ¶
func (m *UnprovenBlock) GetBlock() []byte
func (*UnprovenBlock) GetHeight ¶
func (m *UnprovenBlock) GetHeight() int64
func (*UnprovenBlock) Marshal ¶
func (m *UnprovenBlock) Marshal() (dAtA []byte, err error)
func (*UnprovenBlock) MarshalToSizedBuffer ¶
func (m *UnprovenBlock) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnprovenBlock) ProtoMessage ¶
func (*UnprovenBlock) ProtoMessage()
func (*UnprovenBlock) Reset ¶
func (m *UnprovenBlock) Reset()
func (*UnprovenBlock) Size ¶
func (m *UnprovenBlock) Size() (n int)
func (*UnprovenBlock) String ¶
func (m *UnprovenBlock) String() string
func (*UnprovenBlock) Unmarshal ¶
func (m *UnprovenBlock) Unmarshal(dAtA []byte) error
func (*UnprovenBlock) XXX_DiscardUnknown ¶
func (m *UnprovenBlock) XXX_DiscardUnknown()
func (*UnprovenBlock) XXX_Marshal ¶
func (m *UnprovenBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnprovenBlock) XXX_Merge ¶
func (m *UnprovenBlock) XXX_Merge(src proto.Message)
func (*UnprovenBlock) XXX_Size ¶
func (m *UnprovenBlock) XXX_Size() int
func (*UnprovenBlock) XXX_Unmarshal ¶
func (m *UnprovenBlock) XXX_Unmarshal(b []byte) error
type Validator ¶
type Validator struct { ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"` CelestiaAddress string `protobuf:"bytes,2,opt,name=celestia_address,json=celestiaAddress,proto3" json:"celestia_address,omitempty"` }
Validator is a mapping of a local validator's address to its Celestia transaction posting address for the purpose of feegranting blob posting on the DA layer.
func (*Validator) Descriptor ¶
func (*Validator) GetCelestiaAddress ¶
func (*Validator) GetValidatorAddress ¶
func (*Validator) MarshalToSizedBuffer ¶
func (*Validator) ProtoMessage ¶
func (*Validator) ProtoMessage()
func (*Validator) XXX_DiscardUnknown ¶
func (m *Validator) XXX_DiscardUnknown()
func (*Validator) XXX_Marshal ¶
func (*Validator) XXX_Unmarshal ¶
type Validators ¶
type Validators struct { // A list of all the validators Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"` }
Validators is a collection of Validators.
func (*Validators) Descriptor ¶
func (*Validators) Descriptor() ([]byte, []int)
func (*Validators) GetValidators ¶
func (m *Validators) GetValidators() []Validator
func (*Validators) Marshal ¶
func (m *Validators) Marshal() (dAtA []byte, err error)
func (*Validators) MarshalToSizedBuffer ¶
func (m *Validators) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Validators) ProtoMessage ¶
func (*Validators) ProtoMessage()
func (*Validators) Reset ¶
func (m *Validators) Reset()
func (*Validators) Size ¶
func (m *Validators) Size() (n int)
func (*Validators) String ¶
func (m *Validators) String() string
func (*Validators) Unmarshal ¶
func (m *Validators) Unmarshal(dAtA []byte) error
func (*Validators) XXX_DiscardUnknown ¶
func (m *Validators) XXX_DiscardUnknown()
func (*Validators) XXX_Marshal ¶
func (m *Validators) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Validators) XXX_Merge ¶
func (m *Validators) XXX_Merge(src proto.Message)
func (*Validators) XXX_Size ¶
func (m *Validators) XXX_Size() int
func (*Validators) XXX_Unmarshal ¶
func (m *Validators) XXX_Unmarshal(b []byte) error
Source Files
¶
Directories
¶
Path | Synopsis |
---|---|
api
|
|
module/v1
Code generated by protoc-gen-go-pulsar.
|
Code generated by protoc-gen-go-pulsar. |
v1
Code generated by protoc-gen-go-pulsar.
|
Code generated by protoc-gen-go-pulsar. |
celestia
|
|
blob/v1
Code generated by protoc-gen-go-pulsar.
|
Code generated by protoc-gen-go-pulsar. |
core/v1/blob
Code generated by protoc-gen-go-pulsar.
|
Code generated by protoc-gen-go-pulsar. |
celestia-node
|
|
client
|
|