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.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 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 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 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 ( 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.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.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 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 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 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
|
|
lightclients
|
|