Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func AccountedPoolKey(poolId uint64) []byte
- func KeyPrefix(p string) []byte
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- 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 AccountKeeper
- type AccountedPool
- func (*AccountedPool) Descriptor() ([]byte, []int)
- func (m *AccountedPool) GetPoolAssets() []types1.PoolAsset
- func (m *AccountedPool) GetPoolId() uint64
- func (m *AccountedPool) GetTotalShares() types.Coin
- func (m *AccountedPool) Marshal() (dAtA []byte, err error)
- func (m *AccountedPool) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountedPool) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountedPool) ProtoMessage()
- func (m *AccountedPool) Reset()
- func (m *AccountedPool) Size() (n int)
- func (m *AccountedPool) String() string
- func (m *AccountedPool) Unmarshal(dAtA []byte) error
- func (m *AccountedPool) XXX_DiscardUnknown()
- func (m *AccountedPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountedPool) XXX_Merge(src proto.Message)
- func (m *AccountedPool) XXX_Size() int
- func (m *AccountedPool) XXX_Unmarshal(b []byte) error
- type AmmKeeper
- type BankKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetAccountedPoolList() []AccountedPool
- 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 PerpetualKeeper
- type PoolAsset
- func (*PoolAsset) Descriptor() ([]byte, []int)
- func (m *PoolAsset) GetToken() types.Coin
- func (m *PoolAsset) Marshal() (dAtA []byte, err error)
- func (m *PoolAsset) MarshalTo(dAtA []byte) (int, error)
- func (m *PoolAsset) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PoolAsset) ProtoMessage()
- func (m *PoolAsset) Reset()
- func (m *PoolAsset) Size() (n int)
- func (m *PoolAsset) String() string
- func (m *PoolAsset) Unmarshal(dAtA []byte) error
- func (m *PoolAsset) XXX_DiscardUnknown()
- func (m *PoolAsset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PoolAsset) XXX_Merge(src proto.Message)
- func (m *PoolAsset) XXX_Size() int
- func (m *PoolAsset) XXX_Unmarshal(b []byte) error
- type QueryAllAccountedPoolRequest
- func (*QueryAllAccountedPoolRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllAccountedPoolRequest) GetPagination() *query.PageRequest
- func (m *QueryAllAccountedPoolRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllAccountedPoolRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllAccountedPoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllAccountedPoolRequest) ProtoMessage()
- func (m *QueryAllAccountedPoolRequest) Reset()
- func (m *QueryAllAccountedPoolRequest) Size() (n int)
- func (m *QueryAllAccountedPoolRequest) String() string
- func (m *QueryAllAccountedPoolRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllAccountedPoolRequest) XXX_DiscardUnknown()
- func (m *QueryAllAccountedPoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllAccountedPoolRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllAccountedPoolRequest) XXX_Size() int
- func (m *QueryAllAccountedPoolRequest) XXX_Unmarshal(b []byte) error
- type QueryAllAccountedPoolResponse
- func (*QueryAllAccountedPoolResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllAccountedPoolResponse) GetAccountedPool() []AccountedPool
- func (m *QueryAllAccountedPoolResponse) GetPagination() *query.PageResponse
- func (m *QueryAllAccountedPoolResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllAccountedPoolResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllAccountedPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllAccountedPoolResponse) ProtoMessage()
- func (m *QueryAllAccountedPoolResponse) Reset()
- func (m *QueryAllAccountedPoolResponse) Size() (n int)
- func (m *QueryAllAccountedPoolResponse) String() string
- func (m *QueryAllAccountedPoolResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllAccountedPoolResponse) XXX_DiscardUnknown()
- func (m *QueryAllAccountedPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllAccountedPoolResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllAccountedPoolResponse) XXX_Size() int
- func (m *QueryAllAccountedPoolResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryGetAccountedPoolRequest
- func (*QueryGetAccountedPoolRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetAccountedPoolRequest) GetPoolId() uint64
- func (m *QueryGetAccountedPoolRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetAccountedPoolRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetAccountedPoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetAccountedPoolRequest) ProtoMessage()
- func (m *QueryGetAccountedPoolRequest) Reset()
- func (m *QueryGetAccountedPoolRequest) Size() (n int)
- func (m *QueryGetAccountedPoolRequest) String() string
- func (m *QueryGetAccountedPoolRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetAccountedPoolRequest) XXX_DiscardUnknown()
- func (m *QueryGetAccountedPoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetAccountedPoolRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetAccountedPoolRequest) XXX_Size() int
- func (m *QueryGetAccountedPoolRequest) XXX_Unmarshal(b []byte) error
- type QueryGetAccountedPoolResponse
- func (*QueryGetAccountedPoolResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetAccountedPoolResponse) GetAccountedPool() AccountedPool
- func (m *QueryGetAccountedPoolResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetAccountedPoolResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetAccountedPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetAccountedPoolResponse) ProtoMessage()
- func (m *QueryGetAccountedPoolResponse) Reset()
- func (m *QueryGetAccountedPoolResponse) Size() (n int)
- func (m *QueryGetAccountedPoolResponse) String() string
- func (m *QueryGetAccountedPoolResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetAccountedPoolResponse) XXX_DiscardUnknown()
- func (m *QueryGetAccountedPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetAccountedPoolResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetAccountedPoolResponse) XXX_Size() int
- func (m *QueryGetAccountedPoolResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedMsgServer
- type UnimplementedQueryServer
Constants ¶
const ( // ModuleName defines the module name ModuleName = "poolaccounted" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey defines the module's message routing key RouterKey = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_poolaccounted" )
const (
// AccountedPoolKeyPrefix is the prefix to retrieve all AccountedPool
AccountedPoolKeyPrefix = "AccountedPool/value/"
)
const DefaultIndex uint64 = 1
DefaultIndex is the default global index
Variables ¶
var ( ErrInvalidLengthAccountedPool = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAccountedPool = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAccountedPool = fmt.Errorf("proto: unexpected end of group") )
var ( ErrPoolDoesNotExist = errorsmod.Register(ModuleName, 1, "pool does not exist") ErrDuplicatedAccountedPoolId = errorsmod.Register(ModuleName, 2, "duplicated poolId for accountedPool") )
x/accountedpool module sentinel errors
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 ( ErrInvalidLengthPoolAsset = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPoolAsset = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPoolAsset = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func AccountedPoolKey ¶
AccountedPoolKey returns the store key to retrieve a AccountedPool from the index fields
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
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 AccountKeeper ¶
AccountKeeper defines the expected account keeper used for simulations (noalias)
type AccountedPool ¶
type AccountedPool struct { PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"` PoolAssets []types1.PoolAsset `protobuf:"bytes,3,rep,name=pool_assets,json=poolAssets,proto3" json:"pool_assets"` TotalWeight github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ }
func (*AccountedPool) Descriptor ¶
func (*AccountedPool) Descriptor() ([]byte, []int)
func (*AccountedPool) GetPoolAssets ¶
func (m *AccountedPool) GetPoolAssets() []types1.PoolAsset
func (*AccountedPool) GetPoolId ¶
func (m *AccountedPool) GetPoolId() uint64
func (*AccountedPool) GetTotalShares ¶
func (m *AccountedPool) GetTotalShares() types.Coin
func (*AccountedPool) Marshal ¶
func (m *AccountedPool) Marshal() (dAtA []byte, err error)
func (*AccountedPool) MarshalToSizedBuffer ¶
func (m *AccountedPool) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AccountedPool) ProtoMessage ¶
func (*AccountedPool) ProtoMessage()
func (*AccountedPool) Reset ¶
func (m *AccountedPool) Reset()
func (*AccountedPool) Size ¶
func (m *AccountedPool) Size() (n int)
func (*AccountedPool) String ¶
func (m *AccountedPool) String() string
func (*AccountedPool) Unmarshal ¶
func (m *AccountedPool) Unmarshal(dAtA []byte) error
func (*AccountedPool) XXX_DiscardUnknown ¶
func (m *AccountedPool) XXX_DiscardUnknown()
func (*AccountedPool) XXX_Marshal ¶
func (m *AccountedPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AccountedPool) XXX_Merge ¶
func (m *AccountedPool) XXX_Merge(src proto.Message)
func (*AccountedPool) XXX_Size ¶
func (m *AccountedPool) XXX_Size() int
func (*AccountedPool) XXX_Unmarshal ¶
func (m *AccountedPool) XXX_Unmarshal(b []byte) error
type AmmKeeper ¶
type AmmKeeper interface { // GetPool returns a pool from its index GetPool(sdk.Context, uint64) (ammtypes.Pool, bool) // Get all pools GetAllPool(sdk.Context) []ammtypes.Pool // IterateCommitments iterates over all Commitments and performs a callback. IterateLiquidityPools(sdk.Context, func(ammtypes.Pool) bool) }
AmmKeeper defines the expected interface needed to swap tokens
type BankKeeper ¶
type BankKeeper interface { GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins SendCoinsFromModuleToModule(ctx sdk.Context, senderModule string, recipientModule string, amt sdk.Coins) error SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error BlockedAddr(addr sdk.AccAddress) bool HasBalance(ctx sdk.Context, addr sdk.AccAddress, amt sdk.Coin) bool }
BankKeeper defines the expected interface needed to retrieve account balances.
type GenesisState ¶
type GenesisState struct {
AccountedPoolList []AccountedPool `protobuf:"bytes,1,rep,name=accounted_pool_list,json=accountedPoolList,proto3" json:"accounted_pool_list"`
}
GenesisState defines the tvl module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetAccountedPoolList ¶
func (m *GenesisState) GetAccountedPoolList() []AccountedPool
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 failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { }
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 PerpetualKeeper ¶ added in v0.29.0
type PerpetualKeeper interface { GetPool(ctx sdk.Context, poolId uint64) (perpetualtypes.Pool, bool) IsPoolEnabled(ctx sdk.Context, poolId uint64) bool IsPoolClosed(ctx sdk.Context, poolId uint64) bool GetAllMTPs(ctx sdk.Context) []perpetualtypes.MTP }
PerpetualKeeper defines the expected interface needed
type PoolAsset ¶
type PoolAsset struct { Token types.Coin `protobuf:"bytes,1,opt,name=token,proto3" json:"token"` Weight github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=weight,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"weight"` }
func (*PoolAsset) Descriptor ¶
func (*PoolAsset) MarshalToSizedBuffer ¶
func (*PoolAsset) ProtoMessage ¶
func (*PoolAsset) ProtoMessage()
func (*PoolAsset) XXX_DiscardUnknown ¶
func (m *PoolAsset) XXX_DiscardUnknown()
func (*PoolAsset) XXX_Marshal ¶
func (*PoolAsset) XXX_Unmarshal ¶
type QueryAllAccountedPoolRequest ¶
type QueryAllAccountedPoolRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryAllAccountedPoolRequest) Descriptor ¶
func (*QueryAllAccountedPoolRequest) Descriptor() ([]byte, []int)
func (*QueryAllAccountedPoolRequest) GetPagination ¶
func (m *QueryAllAccountedPoolRequest) GetPagination() *query.PageRequest
func (*QueryAllAccountedPoolRequest) Marshal ¶
func (m *QueryAllAccountedPoolRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllAccountedPoolRequest) MarshalTo ¶
func (m *QueryAllAccountedPoolRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllAccountedPoolRequest) MarshalToSizedBuffer ¶
func (m *QueryAllAccountedPoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllAccountedPoolRequest) ProtoMessage ¶
func (*QueryAllAccountedPoolRequest) ProtoMessage()
func (*QueryAllAccountedPoolRequest) Reset ¶
func (m *QueryAllAccountedPoolRequest) Reset()
func (*QueryAllAccountedPoolRequest) Size ¶
func (m *QueryAllAccountedPoolRequest) Size() (n int)
func (*QueryAllAccountedPoolRequest) String ¶
func (m *QueryAllAccountedPoolRequest) String() string
func (*QueryAllAccountedPoolRequest) Unmarshal ¶
func (m *QueryAllAccountedPoolRequest) Unmarshal(dAtA []byte) error
func (*QueryAllAccountedPoolRequest) XXX_DiscardUnknown ¶
func (m *QueryAllAccountedPoolRequest) XXX_DiscardUnknown()
func (*QueryAllAccountedPoolRequest) XXX_Marshal ¶
func (m *QueryAllAccountedPoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllAccountedPoolRequest) XXX_Merge ¶
func (m *QueryAllAccountedPoolRequest) XXX_Merge(src proto.Message)
func (*QueryAllAccountedPoolRequest) XXX_Size ¶
func (m *QueryAllAccountedPoolRequest) XXX_Size() int
func (*QueryAllAccountedPoolRequest) XXX_Unmarshal ¶
func (m *QueryAllAccountedPoolRequest) XXX_Unmarshal(b []byte) error
type QueryAllAccountedPoolResponse ¶
type QueryAllAccountedPoolResponse struct { AccountedPool []AccountedPool `protobuf:"bytes,1,rep,name=accounted_pool,json=accountedPool,proto3" json:"accounted_pool"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryAllAccountedPoolResponse) Descriptor ¶
func (*QueryAllAccountedPoolResponse) Descriptor() ([]byte, []int)
func (*QueryAllAccountedPoolResponse) GetAccountedPool ¶
func (m *QueryAllAccountedPoolResponse) GetAccountedPool() []AccountedPool
func (*QueryAllAccountedPoolResponse) GetPagination ¶
func (m *QueryAllAccountedPoolResponse) GetPagination() *query.PageResponse
func (*QueryAllAccountedPoolResponse) Marshal ¶
func (m *QueryAllAccountedPoolResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllAccountedPoolResponse) MarshalTo ¶
func (m *QueryAllAccountedPoolResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllAccountedPoolResponse) MarshalToSizedBuffer ¶
func (m *QueryAllAccountedPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllAccountedPoolResponse) ProtoMessage ¶
func (*QueryAllAccountedPoolResponse) ProtoMessage()
func (*QueryAllAccountedPoolResponse) Reset ¶
func (m *QueryAllAccountedPoolResponse) Reset()
func (*QueryAllAccountedPoolResponse) Size ¶
func (m *QueryAllAccountedPoolResponse) Size() (n int)
func (*QueryAllAccountedPoolResponse) String ¶
func (m *QueryAllAccountedPoolResponse) String() string
func (*QueryAllAccountedPoolResponse) Unmarshal ¶
func (m *QueryAllAccountedPoolResponse) Unmarshal(dAtA []byte) error
func (*QueryAllAccountedPoolResponse) XXX_DiscardUnknown ¶
func (m *QueryAllAccountedPoolResponse) XXX_DiscardUnknown()
func (*QueryAllAccountedPoolResponse) XXX_Marshal ¶
func (m *QueryAllAccountedPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllAccountedPoolResponse) XXX_Merge ¶
func (m *QueryAllAccountedPoolResponse) XXX_Merge(src proto.Message)
func (*QueryAllAccountedPoolResponse) XXX_Size ¶
func (m *QueryAllAccountedPoolResponse) XXX_Size() int
func (*QueryAllAccountedPoolResponse) XXX_Unmarshal ¶
func (m *QueryAllAccountedPoolResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Queries a list of AccountedPool items. AccountedPool(ctx context.Context, in *QueryGetAccountedPoolRequest, opts ...grpc.CallOption) (*QueryGetAccountedPoolResponse, error) AccountedPoolAll(ctx context.Context, in *QueryAllAccountedPoolRequest, opts ...grpc.CallOption) (*QueryAllAccountedPoolResponse, 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 QueryGetAccountedPoolRequest ¶
type QueryGetAccountedPoolRequest struct {
PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}
func (*QueryGetAccountedPoolRequest) Descriptor ¶
func (*QueryGetAccountedPoolRequest) Descriptor() ([]byte, []int)
func (*QueryGetAccountedPoolRequest) GetPoolId ¶
func (m *QueryGetAccountedPoolRequest) GetPoolId() uint64
func (*QueryGetAccountedPoolRequest) Marshal ¶
func (m *QueryGetAccountedPoolRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetAccountedPoolRequest) MarshalTo ¶
func (m *QueryGetAccountedPoolRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetAccountedPoolRequest) MarshalToSizedBuffer ¶
func (m *QueryGetAccountedPoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetAccountedPoolRequest) ProtoMessage ¶
func (*QueryGetAccountedPoolRequest) ProtoMessage()
func (*QueryGetAccountedPoolRequest) Reset ¶
func (m *QueryGetAccountedPoolRequest) Reset()
func (*QueryGetAccountedPoolRequest) Size ¶
func (m *QueryGetAccountedPoolRequest) Size() (n int)
func (*QueryGetAccountedPoolRequest) String ¶
func (m *QueryGetAccountedPoolRequest) String() string
func (*QueryGetAccountedPoolRequest) Unmarshal ¶
func (m *QueryGetAccountedPoolRequest) Unmarshal(dAtA []byte) error
func (*QueryGetAccountedPoolRequest) XXX_DiscardUnknown ¶
func (m *QueryGetAccountedPoolRequest) XXX_DiscardUnknown()
func (*QueryGetAccountedPoolRequest) XXX_Marshal ¶
func (m *QueryGetAccountedPoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetAccountedPoolRequest) XXX_Merge ¶
func (m *QueryGetAccountedPoolRequest) XXX_Merge(src proto.Message)
func (*QueryGetAccountedPoolRequest) XXX_Size ¶
func (m *QueryGetAccountedPoolRequest) XXX_Size() int
func (*QueryGetAccountedPoolRequest) XXX_Unmarshal ¶
func (m *QueryGetAccountedPoolRequest) XXX_Unmarshal(b []byte) error
type QueryGetAccountedPoolResponse ¶
type QueryGetAccountedPoolResponse struct {
AccountedPool AccountedPool `protobuf:"bytes,1,opt,name=accounted_pool,json=accountedPool,proto3" json:"accounted_pool"`
}
func (*QueryGetAccountedPoolResponse) Descriptor ¶
func (*QueryGetAccountedPoolResponse) Descriptor() ([]byte, []int)
func (*QueryGetAccountedPoolResponse) GetAccountedPool ¶
func (m *QueryGetAccountedPoolResponse) GetAccountedPool() AccountedPool
func (*QueryGetAccountedPoolResponse) Marshal ¶
func (m *QueryGetAccountedPoolResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetAccountedPoolResponse) MarshalTo ¶
func (m *QueryGetAccountedPoolResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetAccountedPoolResponse) MarshalToSizedBuffer ¶
func (m *QueryGetAccountedPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetAccountedPoolResponse) ProtoMessage ¶
func (*QueryGetAccountedPoolResponse) ProtoMessage()
func (*QueryGetAccountedPoolResponse) Reset ¶
func (m *QueryGetAccountedPoolResponse) Reset()
func (*QueryGetAccountedPoolResponse) Size ¶
func (m *QueryGetAccountedPoolResponse) Size() (n int)
func (*QueryGetAccountedPoolResponse) String ¶
func (m *QueryGetAccountedPoolResponse) String() string
func (*QueryGetAccountedPoolResponse) Unmarshal ¶
func (m *QueryGetAccountedPoolResponse) Unmarshal(dAtA []byte) error
func (*QueryGetAccountedPoolResponse) XXX_DiscardUnknown ¶
func (m *QueryGetAccountedPoolResponse) XXX_DiscardUnknown()
func (*QueryGetAccountedPoolResponse) XXX_Marshal ¶
func (m *QueryGetAccountedPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetAccountedPoolResponse) XXX_Merge ¶
func (m *QueryGetAccountedPoolResponse) XXX_Merge(src proto.Message)
func (*QueryGetAccountedPoolResponse) XXX_Size ¶
func (m *QueryGetAccountedPoolResponse) XXX_Size() int
func (*QueryGetAccountedPoolResponse) XXX_Unmarshal ¶
func (m *QueryGetAccountedPoolResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Queries a list of AccountedPool items. AccountedPool(context.Context, *QueryGetAccountedPoolRequest) (*QueryGetAccountedPoolResponse, error) AccountedPoolAll(context.Context, *QueryAllAccountedPoolRequest) (*QueryAllAccountedPoolResponse, error) }
QueryServer is the server API for Query service.
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) AccountedPool ¶
func (*UnimplementedQueryServer) AccountedPool(ctx context.Context, req *QueryGetAccountedPoolRequest) (*QueryGetAccountedPoolResponse, error)
func (*UnimplementedQueryServer) AccountedPoolAll ¶
func (*UnimplementedQueryServer) AccountedPoolAll(ctx context.Context, req *QueryAllAccountedPoolRequest) (*QueryAllAccountedPoolResponse, error)