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 RegisterInterfaces(registry cdctypes.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 AccountKeeper
- type AccountedPool
- func (*AccountedPool) Descriptor() ([]byte, []int)
- func (m *AccountedPool) GetNonAmmPoolTokens() []types.Coin
- func (ap AccountedPool) GetNonAmmTokenBalance(denom string) (math.Int, error)
- func (m *AccountedPool) GetPoolId() uint64
- func (m *AccountedPool) GetTotalTokens() []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 LegacyAccountedPool
- func (*LegacyAccountedPool) Descriptor() ([]byte, []int)
- func (m *LegacyAccountedPool) GetNonAmmPoolTokens() []types.Coin
- func (m *LegacyAccountedPool) GetPoolAssets() []types1.PoolAsset
- func (m *LegacyAccountedPool) GetPoolId() uint64
- func (m *LegacyAccountedPool) GetTotalShares() types.Coin
- func (m *LegacyAccountedPool) Marshal() (dAtA []byte, err error)
- func (m *LegacyAccountedPool) MarshalTo(dAtA []byte) (int, error)
- func (m *LegacyAccountedPool) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LegacyAccountedPool) ProtoMessage()
- func (m *LegacyAccountedPool) Reset()
- func (m *LegacyAccountedPool) Size() (n int)
- func (m *LegacyAccountedPool) String() string
- func (m *LegacyAccountedPool) Unmarshal(dAtA []byte) error
- func (m *LegacyAccountedPool) XXX_DiscardUnknown()
- func (m *LegacyAccountedPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LegacyAccountedPool) XXX_Merge(src proto.Message)
- func (m *LegacyAccountedPool) XXX_Size() int
- func (m *LegacyAccountedPool) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgServer
- type PerpetualKeeper
- 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 )
const (
// AccountedPoolKeyPrefix is the prefix to retrieve all AccountedPool
AccountedPoolKeyPrefix = "AccountedPool/value/"
)
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, "accounted pool does not exist") ErrPoolAlreadyExist = errorsmod.Register(ModuleName, 2, "accounted pool already exist") ErrDuplicatedAccountedPoolId = errorsmod.Register(ModuleName, 3, "duplicated poolId for accountedPool") )
x/accountedpool module sentinel errors
Functions ¶
func AccountedPoolKey ¶
AccountedPoolKey returns the store key to retrieve a AccountedPool from the index fields
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterLegacyAminoCodec ¶ added in v0.50.0
func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
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"` TotalTokens []types.Coin `protobuf:"bytes,2,rep,name=total_tokens,json=totalTokens,proto3" json:"total_tokens"` NonAmmPoolTokens []types.Coin `protobuf:"bytes,3,rep,name=non_amm_pool_tokens,json=nonAmmPoolTokens,proto3" json:"non_amm_pool_tokens"` }
func (*AccountedPool) Descriptor ¶
func (*AccountedPool) Descriptor() ([]byte, []int)
func (*AccountedPool) GetNonAmmPoolTokens ¶ added in v0.48.0
func (m *AccountedPool) GetNonAmmPoolTokens() []types.Coin
func (AccountedPool) GetNonAmmTokenBalance ¶ added in v0.48.0
func (ap AccountedPool) GetNonAmmTokenBalance(denom string) (math.Int, error)
func (*AccountedPool) GetPoolId ¶
func (m *AccountedPool) GetPoolId() uint64
func (*AccountedPool) GetTotalTokens ¶ added in v0.53.0
func (m *AccountedPool) GetTotalTokens() []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 context.Context, addr sdk.AccAddress) sdk.Coins GetBalance(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins SendCoinsFromModuleToModule(ctx context.Context, senderModule string, recipientModule string, amt sdk.Coins) error SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error BlockedAddr(addr sdk.AccAddress) bool HasBalance(ctx context.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 LegacyAccountedPool ¶ added in v0.53.0
type LegacyAccountedPool 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 cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=total_weight,json=totalWeight,proto3,customtype=cosmossdk.io/math.Int" json:"total_weight"` NonAmmPoolTokens []types.Coin `protobuf:"bytes,5,rep,name=non_amm_pool_tokens,json=nonAmmPoolTokens,proto3" json:"non_amm_pool_tokens"` }
func (*LegacyAccountedPool) Descriptor ¶ added in v0.53.0
func (*LegacyAccountedPool) Descriptor() ([]byte, []int)
func (*LegacyAccountedPool) GetNonAmmPoolTokens ¶ added in v0.53.0
func (m *LegacyAccountedPool) GetNonAmmPoolTokens() []types.Coin
func (*LegacyAccountedPool) GetPoolAssets ¶ added in v0.53.0
func (m *LegacyAccountedPool) GetPoolAssets() []types1.PoolAsset
func (*LegacyAccountedPool) GetPoolId ¶ added in v0.53.0
func (m *LegacyAccountedPool) GetPoolId() uint64
func (*LegacyAccountedPool) GetTotalShares ¶ added in v0.53.0
func (m *LegacyAccountedPool) GetTotalShares() types.Coin
func (*LegacyAccountedPool) Marshal ¶ added in v0.53.0
func (m *LegacyAccountedPool) Marshal() (dAtA []byte, err error)
func (*LegacyAccountedPool) MarshalTo ¶ added in v0.53.0
func (m *LegacyAccountedPool) MarshalTo(dAtA []byte) (int, error)
func (*LegacyAccountedPool) MarshalToSizedBuffer ¶ added in v0.53.0
func (m *LegacyAccountedPool) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LegacyAccountedPool) ProtoMessage ¶ added in v0.53.0
func (*LegacyAccountedPool) ProtoMessage()
func (*LegacyAccountedPool) Reset ¶ added in v0.53.0
func (m *LegacyAccountedPool) Reset()
func (*LegacyAccountedPool) Size ¶ added in v0.53.0
func (m *LegacyAccountedPool) Size() (n int)
func (*LegacyAccountedPool) String ¶ added in v0.53.0
func (m *LegacyAccountedPool) String() string
func (*LegacyAccountedPool) Unmarshal ¶ added in v0.53.0
func (m *LegacyAccountedPool) Unmarshal(dAtA []byte) error
func (*LegacyAccountedPool) XXX_DiscardUnknown ¶ added in v0.53.0
func (m *LegacyAccountedPool) XXX_DiscardUnknown()
func (*LegacyAccountedPool) XXX_Marshal ¶ added in v0.53.0
func (m *LegacyAccountedPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LegacyAccountedPool) XXX_Merge ¶ added in v0.53.0
func (m *LegacyAccountedPool) XXX_Merge(src proto.Message)
func (*LegacyAccountedPool) XXX_Size ¶ added in v0.53.0
func (m *LegacyAccountedPool) XXX_Size() int
func (*LegacyAccountedPool) XXX_Unmarshal ¶ added in v0.53.0
func (m *LegacyAccountedPool) 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 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)