Documentation ¶
Overview ¶
Package types is a generated GoMock package.
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func AutoResumeRecordKey(timestamp int64, addr sdk.AccAddress) []byte
- func AutoSettleRecordKey(timestamp int64, addr sdk.AccAddress) []byte
- func OutFlowKey(addr sdk.AccAddress, status OutFlowStatus, toAddr sdk.AccAddress) []byte
- func ParamKeyTable() paramtypes.KeyTable
- func ParseOutFlowValue(value []byte) sdkmath.Int
- func PaymentAccountCountKey(owner sdk.AccAddress) []byte
- func PaymentAccountKey(addr sdk.AccAddress) []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)
- func StreamRecordKey(account sdk.AccAddress) []byte
- func VersionedParamsKey(timestamp int64) []byte
- type AccountKeeper
- type AutoResumeRecord
- func (*AutoResumeRecord) Descriptor() ([]byte, []int)
- func (m *AutoResumeRecord) GetAddr() string
- func (m *AutoResumeRecord) GetTimestamp() int64
- func (m *AutoResumeRecord) Marshal() (dAtA []byte, err error)
- func (m *AutoResumeRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *AutoResumeRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AutoResumeRecord) ProtoMessage()
- func (m *AutoResumeRecord) Reset()
- func (m *AutoResumeRecord) Size() (n int)
- func (m *AutoResumeRecord) String() string
- func (m *AutoResumeRecord) Unmarshal(dAtA []byte) error
- func (m *AutoResumeRecord) XXX_DiscardUnknown()
- func (m *AutoResumeRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AutoResumeRecord) XXX_Merge(src proto.Message)
- func (m *AutoResumeRecord) XXX_Size() int
- func (m *AutoResumeRecord) XXX_Unmarshal(b []byte) error
- type AutoSettleRecord
- func (*AutoSettleRecord) Descriptor() ([]byte, []int)
- func (m *AutoSettleRecord) GetAddr() string
- func (m *AutoSettleRecord) GetTimestamp() int64
- func (m *AutoSettleRecord) Marshal() (dAtA []byte, err error)
- func (m *AutoSettleRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *AutoSettleRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AutoSettleRecord) ProtoMessage()
- func (m *AutoSettleRecord) Reset()
- func (m *AutoSettleRecord) Size() (n int)
- func (m *AutoSettleRecord) String() string
- func (m *AutoSettleRecord) Unmarshal(dAtA []byte) error
- func (m *AutoSettleRecord) XXX_DiscardUnknown()
- func (m *AutoSettleRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AutoSettleRecord) XXX_Merge(src proto.Message)
- func (m *AutoSettleRecord) XXX_Size() int
- func (m *AutoSettleRecord) XXX_Unmarshal(b []byte) error
- type BankKeeper
- type EventDeposit
- func (*EventDeposit) Descriptor() ([]byte, []int)
- func (m *EventDeposit) GetFrom() string
- func (m *EventDeposit) GetTo() string
- func (m *EventDeposit) Marshal() (dAtA []byte, err error)
- func (m *EventDeposit) MarshalTo(dAtA []byte) (int, error)
- func (m *EventDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventDeposit) ProtoMessage()
- func (m *EventDeposit) Reset()
- func (m *EventDeposit) Size() (n int)
- func (m *EventDeposit) String() string
- func (m *EventDeposit) Unmarshal(dAtA []byte) error
- func (m *EventDeposit) XXX_DiscardUnknown()
- func (m *EventDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventDeposit) XXX_Merge(src proto.Message)
- func (m *EventDeposit) XXX_Size() int
- func (m *EventDeposit) XXX_Unmarshal(b []byte) error
- type EventFeePreview
- func (*EventFeePreview) Descriptor() ([]byte, []int)
- func (m *EventFeePreview) GetAccount() string
- func (m *EventFeePreview) GetFeePreviewType() FeePreviewType
- func (m *EventFeePreview) Marshal() (dAtA []byte, err error)
- func (m *EventFeePreview) MarshalTo(dAtA []byte) (int, error)
- func (m *EventFeePreview) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventFeePreview) ProtoMessage()
- func (m *EventFeePreview) Reset()
- func (m *EventFeePreview) Size() (n int)
- func (m *EventFeePreview) String() string
- func (m *EventFeePreview) Unmarshal(dAtA []byte) error
- func (m *EventFeePreview) XXX_DiscardUnknown()
- func (m *EventFeePreview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventFeePreview) XXX_Merge(src proto.Message)
- func (m *EventFeePreview) XXX_Size() int
- func (m *EventFeePreview) XXX_Unmarshal(b []byte) error
- type EventForceSettle
- func (*EventForceSettle) Descriptor() ([]byte, []int)
- func (m *EventForceSettle) GetAddr() string
- func (m *EventForceSettle) Marshal() (dAtA []byte, err error)
- func (m *EventForceSettle) MarshalTo(dAtA []byte) (int, error)
- func (m *EventForceSettle) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventForceSettle) ProtoMessage()
- func (m *EventForceSettle) Reset()
- func (m *EventForceSettle) Size() (n int)
- func (m *EventForceSettle) String() string
- func (m *EventForceSettle) Unmarshal(dAtA []byte) error
- func (m *EventForceSettle) XXX_DiscardUnknown()
- func (m *EventForceSettle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventForceSettle) XXX_Merge(src proto.Message)
- func (m *EventForceSettle) XXX_Size() int
- func (m *EventForceSettle) XXX_Unmarshal(b []byte) error
- type EventPaymentAccountUpdate
- func (*EventPaymentAccountUpdate) Descriptor() ([]byte, []int)
- func (m *EventPaymentAccountUpdate) GetAddr() string
- func (m *EventPaymentAccountUpdate) GetOwner() string
- func (m *EventPaymentAccountUpdate) GetRefundable() bool
- func (m *EventPaymentAccountUpdate) Marshal() (dAtA []byte, err error)
- func (m *EventPaymentAccountUpdate) MarshalTo(dAtA []byte) (int, error)
- func (m *EventPaymentAccountUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventPaymentAccountUpdate) ProtoMessage()
- func (m *EventPaymentAccountUpdate) Reset()
- func (m *EventPaymentAccountUpdate) Size() (n int)
- func (m *EventPaymentAccountUpdate) String() string
- func (m *EventPaymentAccountUpdate) Unmarshal(dAtA []byte) error
- func (m *EventPaymentAccountUpdate) XXX_DiscardUnknown()
- func (m *EventPaymentAccountUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventPaymentAccountUpdate) XXX_Merge(src proto.Message)
- func (m *EventPaymentAccountUpdate) XXX_Size() int
- func (m *EventPaymentAccountUpdate) XXX_Unmarshal(b []byte) error
- type EventStreamRecordUpdate
- func (*EventStreamRecordUpdate) Descriptor() ([]byte, []int)
- func (m *EventStreamRecordUpdate) GetAccount() string
- func (m *EventStreamRecordUpdate) GetCrudTimestamp() int64
- func (m *EventStreamRecordUpdate) GetSettleTimestamp() int64
- func (m *EventStreamRecordUpdate) GetStatus() StreamAccountStatus
- func (m *EventStreamRecordUpdate) Marshal() (dAtA []byte, err error)
- func (m *EventStreamRecordUpdate) MarshalTo(dAtA []byte) (int, error)
- func (m *EventStreamRecordUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventStreamRecordUpdate) ProtoMessage()
- func (m *EventStreamRecordUpdate) Reset()
- func (m *EventStreamRecordUpdate) Size() (n int)
- func (m *EventStreamRecordUpdate) String() string
- func (m *EventStreamRecordUpdate) Unmarshal(dAtA []byte) error
- func (m *EventStreamRecordUpdate) XXX_DiscardUnknown()
- func (m *EventStreamRecordUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventStreamRecordUpdate) XXX_Merge(src proto.Message)
- func (m *EventStreamRecordUpdate) XXX_Size() int
- func (m *EventStreamRecordUpdate) XXX_Unmarshal(b []byte) error
- type EventWithdraw
- func (*EventWithdraw) Descriptor() ([]byte, []int)
- func (m *EventWithdraw) GetFrom() string
- func (m *EventWithdraw) GetTo() string
- func (m *EventWithdraw) Marshal() (dAtA []byte, err error)
- func (m *EventWithdraw) MarshalTo(dAtA []byte) (int, error)
- func (m *EventWithdraw) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventWithdraw) ProtoMessage()
- func (m *EventWithdraw) Reset()
- func (m *EventWithdraw) Size() (n int)
- func (m *EventWithdraw) String() string
- func (m *EventWithdraw) Unmarshal(dAtA []byte) error
- func (m *EventWithdraw) XXX_DiscardUnknown()
- func (m *EventWithdraw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventWithdraw) XXX_Merge(src proto.Message)
- func (m *EventWithdraw) XXX_Size() int
- func (m *EventWithdraw) XXX_Unmarshal(b []byte) error
- type FeePreviewType
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetAutoSettleRecordList() []AutoSettleRecord
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetPaymentAccountCountList() []PaymentAccountCount
- func (m *GenesisState) GetPaymentAccountList() []PaymentAccount
- func (m *GenesisState) GetStreamRecordList() []StreamRecord
- 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 MockAccountKeeper
- func (m *MockAccountKeeper) EXPECT() *MockAccountKeeperMockRecorder
- func (m *MockAccountKeeper) GetAccount(ctx types0.Context, addr types0.AccAddress) types1.AccountI
- func (m *MockAccountKeeper) GetModuleAccount(ctx types0.Context, moduleName string) types1.ModuleAccountI
- func (m *MockAccountKeeper) GetModuleAddress(name string) types0.AccAddress
- func (m *MockAccountKeeper) HasAccount(ctx types0.Context, addr types0.AccAddress) bool
- func (m *MockAccountKeeper) SetModuleAccount(arg0 types0.Context, arg1 types1.ModuleAccountI)
- type MockAccountKeeperMockRecorder
- func (mr *MockAccountKeeperMockRecorder) GetAccount(ctx, addr interface{}) *gomock.Call
- func (mr *MockAccountKeeperMockRecorder) GetModuleAccount(ctx, moduleName interface{}) *gomock.Call
- func (mr *MockAccountKeeperMockRecorder) GetModuleAddress(name interface{}) *gomock.Call
- func (mr *MockAccountKeeperMockRecorder) HasAccount(ctx, addr interface{}) *gomock.Call
- func (mr *MockAccountKeeperMockRecorder) SetModuleAccount(arg0, arg1 interface{}) *gomock.Call
- type MockBankKeeper
- func (m *MockBankKeeper) EXPECT() *MockBankKeeperMockRecorder
- func (m *MockBankKeeper) GetAllBalances(ctx types0.Context, addr types0.AccAddress) types0.Coins
- func (m *MockBankKeeper) GetBalance(ctx types0.Context, addr types0.AccAddress, denom string) types0.Coin
- func (m *MockBankKeeper) SendCoinsFromAccountToModule(ctx types0.Context, senderAddr types0.AccAddress, recipientModule string, ...) error
- func (m *MockBankKeeper) SendCoinsFromModuleToAccount(ctx types0.Context, senderModule string, recipientAddr types0.AccAddress, ...) error
- func (m *MockBankKeeper) SpendableCoins(ctx types0.Context, addr types0.AccAddress) types0.Coins
- type MockBankKeeperMockRecorder
- func (mr *MockBankKeeperMockRecorder) GetAllBalances(ctx, addr interface{}) *gomock.Call
- func (mr *MockBankKeeperMockRecorder) GetBalance(ctx, addr, denom interface{}) *gomock.Call
- func (mr *MockBankKeeperMockRecorder) SendCoinsFromAccountToModule(ctx, senderAddr, recipientModule, amt interface{}) *gomock.Call
- func (mr *MockBankKeeperMockRecorder) SendCoinsFromModuleToAccount(ctx, senderModule, recipientAddr, amt interface{}) *gomock.Call
- func (mr *MockBankKeeperMockRecorder) SpendableCoins(ctx, addr interface{}) *gomock.Call
- type MockSpKeeper
- func (m *MockSpKeeper) EXPECT() *MockSpKeeperMockRecorder
- func (m *MockSpKeeper) GetSecondarySpStorePriceByTime(ctx types0.Context, time int64) (types.SecondarySpStorePrice, error)
- func (m *MockSpKeeper) GetSpStoragePriceByTime(ctx types0.Context, spId uint32, time int64) (types.SpStoragePrice, error)
- type MockSpKeeperMockRecorder
- type MsgClient
- type MsgCreatePaymentAccount
- func (*MsgCreatePaymentAccount) Descriptor() ([]byte, []int)
- func (m *MsgCreatePaymentAccount) GetCreator() string
- func (msg *MsgCreatePaymentAccount) GetSignBytes() []byte
- func (msg *MsgCreatePaymentAccount) GetSigners() []sdk.AccAddress
- func (m *MsgCreatePaymentAccount) Marshal() (dAtA []byte, err error)
- func (m *MsgCreatePaymentAccount) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreatePaymentAccount) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreatePaymentAccount) ProtoMessage()
- func (m *MsgCreatePaymentAccount) Reset()
- func (msg *MsgCreatePaymentAccount) Route() string
- func (m *MsgCreatePaymentAccount) Size() (n int)
- func (m *MsgCreatePaymentAccount) String() string
- func (msg *MsgCreatePaymentAccount) Type() string
- func (m *MsgCreatePaymentAccount) Unmarshal(dAtA []byte) error
- func (msg *MsgCreatePaymentAccount) ValidateBasic() error
- func (m *MsgCreatePaymentAccount) XXX_DiscardUnknown()
- func (m *MsgCreatePaymentAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreatePaymentAccount) XXX_Merge(src proto.Message)
- func (m *MsgCreatePaymentAccount) XXX_Size() int
- func (m *MsgCreatePaymentAccount) XXX_Unmarshal(b []byte) error
- type MsgCreatePaymentAccountResponse
- func (*MsgCreatePaymentAccountResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreatePaymentAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreatePaymentAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreatePaymentAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreatePaymentAccountResponse) ProtoMessage()
- func (m *MsgCreatePaymentAccountResponse) Reset()
- func (m *MsgCreatePaymentAccountResponse) Size() (n int)
- func (m *MsgCreatePaymentAccountResponse) String() string
- func (m *MsgCreatePaymentAccountResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreatePaymentAccountResponse) XXX_DiscardUnknown()
- func (m *MsgCreatePaymentAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreatePaymentAccountResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreatePaymentAccountResponse) XXX_Size() int
- func (m *MsgCreatePaymentAccountResponse) XXX_Unmarshal(b []byte) error
- type MsgDeposit
- func (*MsgDeposit) Descriptor() ([]byte, []int)
- func (m *MsgDeposit) GetCreator() string
- func (msg *MsgDeposit) GetSignBytes() []byte
- func (msg *MsgDeposit) GetSigners() []sdk.AccAddress
- func (m *MsgDeposit) GetTo() string
- func (m *MsgDeposit) Marshal() (dAtA []byte, err error)
- func (m *MsgDeposit) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeposit) ProtoMessage()
- func (m *MsgDeposit) Reset()
- func (msg *MsgDeposit) Route() string
- func (m *MsgDeposit) Size() (n int)
- func (m *MsgDeposit) String() string
- func (msg *MsgDeposit) Type() string
- func (m *MsgDeposit) Unmarshal(dAtA []byte) error
- func (msg *MsgDeposit) ValidateBasic() error
- func (m *MsgDeposit) XXX_DiscardUnknown()
- func (m *MsgDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeposit) XXX_Merge(src proto.Message)
- func (m *MsgDeposit) XXX_Size() int
- func (m *MsgDeposit) XXX_Unmarshal(b []byte) error
- type MsgDepositResponse
- func (*MsgDepositResponse) Descriptor() ([]byte, []int)
- func (m *MsgDepositResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgDepositResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDepositResponse) ProtoMessage()
- func (m *MsgDepositResponse) Reset()
- func (m *MsgDepositResponse) Size() (n int)
- func (m *MsgDepositResponse) String() string
- func (m *MsgDepositResponse) Unmarshal(dAtA []byte) error
- func (m *MsgDepositResponse) XXX_DiscardUnknown()
- func (m *MsgDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDepositResponse) XXX_Merge(src proto.Message)
- func (m *MsgDepositResponse) XXX_Size() int
- func (m *MsgDepositResponse) XXX_Unmarshal(b []byte) error
- type MsgDisableRefund
- func (*MsgDisableRefund) Descriptor() ([]byte, []int)
- func (m *MsgDisableRefund) GetAddr() string
- func (m *MsgDisableRefund) GetOwner() string
- func (msg *MsgDisableRefund) GetSignBytes() []byte
- func (msg *MsgDisableRefund) GetSigners() []sdk.AccAddress
- func (m *MsgDisableRefund) Marshal() (dAtA []byte, err error)
- func (m *MsgDisableRefund) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDisableRefund) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDisableRefund) ProtoMessage()
- func (m *MsgDisableRefund) Reset()
- func (msg *MsgDisableRefund) Route() string
- func (m *MsgDisableRefund) Size() (n int)
- func (m *MsgDisableRefund) String() string
- func (msg *MsgDisableRefund) Type() string
- func (m *MsgDisableRefund) Unmarshal(dAtA []byte) error
- func (msg *MsgDisableRefund) ValidateBasic() error
- func (m *MsgDisableRefund) XXX_DiscardUnknown()
- func (m *MsgDisableRefund) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDisableRefund) XXX_Merge(src proto.Message)
- func (m *MsgDisableRefund) XXX_Size() int
- func (m *MsgDisableRefund) XXX_Unmarshal(b []byte) error
- type MsgDisableRefundResponse
- func (*MsgDisableRefundResponse) Descriptor() ([]byte, []int)
- func (m *MsgDisableRefundResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgDisableRefundResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDisableRefundResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDisableRefundResponse) ProtoMessage()
- func (m *MsgDisableRefundResponse) Reset()
- func (m *MsgDisableRefundResponse) Size() (n int)
- func (m *MsgDisableRefundResponse) String() string
- func (m *MsgDisableRefundResponse) Unmarshal(dAtA []byte) error
- func (m *MsgDisableRefundResponse) XXX_DiscardUnknown()
- func (m *MsgDisableRefundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDisableRefundResponse) XXX_Merge(src proto.Message)
- func (m *MsgDisableRefundResponse) XXX_Size() int
- func (m *MsgDisableRefundResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgUpdateParams
- func (*MsgUpdateParams) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParams) GetAuthority() string
- func (m *MsgUpdateParams) GetParams() Params
- func (m MsgUpdateParams) GetSignBytes() []byte
- func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParams) ProtoMessage()
- func (m *MsgUpdateParams) Reset()
- func (m *MsgUpdateParams) Size() (n int)
- func (m *MsgUpdateParams) String() string
- func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParams) ValidateBasic() error
- func (m *MsgUpdateParams) XXX_DiscardUnknown()
- func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParams) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParams) XXX_Size() int
- func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error
- type MsgUpdateParamsResponse
- func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParamsResponse) ProtoMessage()
- func (m *MsgUpdateParamsResponse) Reset()
- func (m *MsgUpdateParamsResponse) Size() (n int)
- func (m *MsgUpdateParamsResponse) String() string
- func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParamsResponse) XXX_Size() int
- func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error
- type MsgWithdraw
- func (*MsgWithdraw) Descriptor() ([]byte, []int)
- func (m *MsgWithdraw) GetCreator() string
- func (m *MsgWithdraw) GetFrom() string
- func (msg *MsgWithdraw) GetSignBytes() []byte
- func (msg *MsgWithdraw) GetSigners() []sdk.AccAddress
- func (m *MsgWithdraw) Marshal() (dAtA []byte, err error)
- func (m *MsgWithdraw) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgWithdraw) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgWithdraw) ProtoMessage()
- func (m *MsgWithdraw) Reset()
- func (msg *MsgWithdraw) Route() string
- func (m *MsgWithdraw) Size() (n int)
- func (m *MsgWithdraw) String() string
- func (msg *MsgWithdraw) Type() string
- func (m *MsgWithdraw) Unmarshal(dAtA []byte) error
- func (msg *MsgWithdraw) ValidateBasic() error
- func (m *MsgWithdraw) XXX_DiscardUnknown()
- func (m *MsgWithdraw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgWithdraw) XXX_Merge(src proto.Message)
- func (m *MsgWithdraw) XXX_Size() int
- func (m *MsgWithdraw) XXX_Unmarshal(b []byte) error
- type MsgWithdrawResponse
- func (*MsgWithdrawResponse) Descriptor() ([]byte, []int)
- func (m *MsgWithdrawResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgWithdrawResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgWithdrawResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgWithdrawResponse) ProtoMessage()
- func (m *MsgWithdrawResponse) Reset()
- func (m *MsgWithdrawResponse) Size() (n int)
- func (m *MsgWithdrawResponse) String() string
- func (m *MsgWithdrawResponse) Unmarshal(dAtA []byte) error
- func (m *MsgWithdrawResponse) XXX_DiscardUnknown()
- func (m *MsgWithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgWithdrawResponse) XXX_Merge(src proto.Message)
- func (m *MsgWithdrawResponse) XXX_Size() int
- func (m *MsgWithdrawResponse) XXX_Unmarshal(b []byte) error
- type OutFlow
- func (*OutFlow) Descriptor() ([]byte, []int)
- func (m *OutFlow) GetStatus() OutFlowStatus
- func (m *OutFlow) GetToAddress() string
- func (m *OutFlow) Marshal() (dAtA []byte, err error)
- func (m *OutFlow) MarshalTo(dAtA []byte) (int, error)
- func (m *OutFlow) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OutFlow) ProtoMessage()
- func (m *OutFlow) Reset()
- func (m *OutFlow) Size() (n int)
- func (m *OutFlow) String() string
- func (m *OutFlow) Unmarshal(dAtA []byte) error
- func (m *OutFlow) XXX_DiscardUnknown()
- func (m *OutFlow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutFlow) XXX_Merge(src proto.Message)
- func (m *OutFlow) XXX_Size() int
- func (m *OutFlow) XXX_Unmarshal(b []byte) error
- type OutFlowStatus
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) GetFeeDenom() string
- func (m *Params) GetForcedSettleTime() uint64
- func (m *Params) GetMaxAutoResumeFlowCount() uint64
- func (m *Params) GetMaxAutoSettleFlowCount() uint64
- func (m *Params) GetPaymentAccountCountLimit() uint64
- func (m *Params) GetVersionedParams() VersionedParams
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type PaymentAccount
- func (*PaymentAccount) Descriptor() ([]byte, []int)
- func (m *PaymentAccount) GetAddr() string
- func (m *PaymentAccount) GetOwner() string
- func (m *PaymentAccount) GetRefundable() bool
- func (m *PaymentAccount) Marshal() (dAtA []byte, err error)
- func (m *PaymentAccount) MarshalTo(dAtA []byte) (int, error)
- func (m *PaymentAccount) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PaymentAccount) ProtoMessage()
- func (m *PaymentAccount) Reset()
- func (m *PaymentAccount) Size() (n int)
- func (m *PaymentAccount) String() string
- func (m *PaymentAccount) Unmarshal(dAtA []byte) error
- func (m *PaymentAccount) XXX_DiscardUnknown()
- func (m *PaymentAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PaymentAccount) XXX_Merge(src proto.Message)
- func (m *PaymentAccount) XXX_Size() int
- func (m *PaymentAccount) XXX_Unmarshal(b []byte) error
- type PaymentAccountCount
- func (*PaymentAccountCount) Descriptor() ([]byte, []int)
- func (m *PaymentAccountCount) GetCount() uint64
- func (m *PaymentAccountCount) GetOwner() string
- func (m *PaymentAccountCount) Marshal() (dAtA []byte, err error)
- func (m *PaymentAccountCount) MarshalTo(dAtA []byte) (int, error)
- func (m *PaymentAccountCount) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PaymentAccountCount) ProtoMessage()
- func (m *PaymentAccountCount) Reset()
- func (m *PaymentAccountCount) Size() (n int)
- func (m *PaymentAccountCount) String() string
- func (m *PaymentAccountCount) Unmarshal(dAtA []byte) error
- func (m *PaymentAccountCount) XXX_DiscardUnknown()
- func (m *PaymentAccountCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PaymentAccountCount) XXX_Merge(src proto.Message)
- func (m *PaymentAccountCount) XXX_Size() int
- func (m *PaymentAccountCount) XXX_Unmarshal(b []byte) error
- type QueryAutoSettleRecordsRequest
- func (*QueryAutoSettleRecordsRequest) Descriptor() ([]byte, []int)
- func (m *QueryAutoSettleRecordsRequest) GetPagination() *query.PageRequest
- func (m *QueryAutoSettleRecordsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAutoSettleRecordsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAutoSettleRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAutoSettleRecordsRequest) ProtoMessage()
- func (m *QueryAutoSettleRecordsRequest) Reset()
- func (m *QueryAutoSettleRecordsRequest) Size() (n int)
- func (m *QueryAutoSettleRecordsRequest) String() string
- func (m *QueryAutoSettleRecordsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAutoSettleRecordsRequest) XXX_DiscardUnknown()
- func (m *QueryAutoSettleRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAutoSettleRecordsRequest) XXX_Merge(src proto.Message)
- func (m *QueryAutoSettleRecordsRequest) XXX_Size() int
- func (m *QueryAutoSettleRecordsRequest) XXX_Unmarshal(b []byte) error
- type QueryAutoSettleRecordsResponse
- func (*QueryAutoSettleRecordsResponse) Descriptor() ([]byte, []int)
- func (m *QueryAutoSettleRecordsResponse) GetAutoSettleRecords() []AutoSettleRecord
- func (m *QueryAutoSettleRecordsResponse) GetPagination() *query.PageResponse
- func (m *QueryAutoSettleRecordsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAutoSettleRecordsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAutoSettleRecordsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAutoSettleRecordsResponse) ProtoMessage()
- func (m *QueryAutoSettleRecordsResponse) Reset()
- func (m *QueryAutoSettleRecordsResponse) Size() (n int)
- func (m *QueryAutoSettleRecordsResponse) String() string
- func (m *QueryAutoSettleRecordsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAutoSettleRecordsResponse) XXX_DiscardUnknown()
- func (m *QueryAutoSettleRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAutoSettleRecordsResponse) XXX_Merge(src proto.Message)
- func (m *QueryAutoSettleRecordsResponse) XXX_Size() int
- func (m *QueryAutoSettleRecordsResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryDynamicBalanceRequest
- func (*QueryDynamicBalanceRequest) Descriptor() ([]byte, []int)
- func (m *QueryDynamicBalanceRequest) GetAccount() string
- func (m *QueryDynamicBalanceRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDynamicBalanceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDynamicBalanceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDynamicBalanceRequest) ProtoMessage()
- func (m *QueryDynamicBalanceRequest) Reset()
- func (m *QueryDynamicBalanceRequest) Size() (n int)
- func (m *QueryDynamicBalanceRequest) String() string
- func (m *QueryDynamicBalanceRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDynamicBalanceRequest) XXX_DiscardUnknown()
- func (m *QueryDynamicBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDynamicBalanceRequest) XXX_Merge(src proto.Message)
- func (m *QueryDynamicBalanceRequest) XXX_Size() int
- func (m *QueryDynamicBalanceRequest) XXX_Unmarshal(b []byte) error
- type QueryDynamicBalanceResponse
- func (*QueryDynamicBalanceResponse) Descriptor() ([]byte, []int)
- func (m *QueryDynamicBalanceResponse) GetCurrentTimestamp() int64
- func (m *QueryDynamicBalanceResponse) GetStreamRecord() StreamRecord
- func (m *QueryDynamicBalanceResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDynamicBalanceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDynamicBalanceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDynamicBalanceResponse) ProtoMessage()
- func (m *QueryDynamicBalanceResponse) Reset()
- func (m *QueryDynamicBalanceResponse) Size() (n int)
- func (m *QueryDynamicBalanceResponse) String() string
- func (m *QueryDynamicBalanceResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDynamicBalanceResponse) XXX_DiscardUnknown()
- func (m *QueryDynamicBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDynamicBalanceResponse) XXX_Merge(src proto.Message)
- func (m *QueryDynamicBalanceResponse) XXX_Size() int
- func (m *QueryDynamicBalanceResponse) XXX_Unmarshal(b []byte) error
- type QueryGetStreamRecordRequest
- func (*QueryGetStreamRecordRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetStreamRecordRequest) GetAccount() string
- func (m *QueryGetStreamRecordRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetStreamRecordRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetStreamRecordRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetStreamRecordRequest) ProtoMessage()
- func (m *QueryGetStreamRecordRequest) Reset()
- func (m *QueryGetStreamRecordRequest) Size() (n int)
- func (m *QueryGetStreamRecordRequest) String() string
- func (m *QueryGetStreamRecordRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetStreamRecordRequest) XXX_DiscardUnknown()
- func (m *QueryGetStreamRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetStreamRecordRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetStreamRecordRequest) XXX_Size() int
- func (m *QueryGetStreamRecordRequest) XXX_Unmarshal(b []byte) error
- type QueryGetStreamRecordResponse
- func (*QueryGetStreamRecordResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetStreamRecordResponse) GetStreamRecord() StreamRecord
- func (m *QueryGetStreamRecordResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetStreamRecordResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetStreamRecordResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetStreamRecordResponse) ProtoMessage()
- func (m *QueryGetStreamRecordResponse) Reset()
- func (m *QueryGetStreamRecordResponse) Size() (n int)
- func (m *QueryGetStreamRecordResponse) String() string
- func (m *QueryGetStreamRecordResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetStreamRecordResponse) XXX_DiscardUnknown()
- func (m *QueryGetStreamRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetStreamRecordResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetStreamRecordResponse) XXX_Size() int
- func (m *QueryGetStreamRecordResponse) XXX_Unmarshal(b []byte) error
- type QueryOutFlowsRequest
- func (*QueryOutFlowsRequest) Descriptor() ([]byte, []int)
- func (m *QueryOutFlowsRequest) GetAccount() string
- func (m *QueryOutFlowsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryOutFlowsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryOutFlowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryOutFlowsRequest) ProtoMessage()
- func (m *QueryOutFlowsRequest) Reset()
- func (m *QueryOutFlowsRequest) Size() (n int)
- func (m *QueryOutFlowsRequest) String() string
- func (m *QueryOutFlowsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryOutFlowsRequest) XXX_DiscardUnknown()
- func (m *QueryOutFlowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryOutFlowsRequest) XXX_Merge(src proto.Message)
- func (m *QueryOutFlowsRequest) XXX_Size() int
- func (m *QueryOutFlowsRequest) XXX_Unmarshal(b []byte) error
- type QueryOutFlowsResponse
- func (*QueryOutFlowsResponse) Descriptor() ([]byte, []int)
- func (m *QueryOutFlowsResponse) GetOutFlows() []OutFlow
- func (m *QueryOutFlowsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryOutFlowsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryOutFlowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryOutFlowsResponse) ProtoMessage()
- func (m *QueryOutFlowsResponse) Reset()
- func (m *QueryOutFlowsResponse) Size() (n int)
- func (m *QueryOutFlowsResponse) String() string
- func (m *QueryOutFlowsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryOutFlowsResponse) XXX_DiscardUnknown()
- func (m *QueryOutFlowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryOutFlowsResponse) XXX_Merge(src proto.Message)
- func (m *QueryOutFlowsResponse) XXX_Size() int
- func (m *QueryOutFlowsResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsByTimestampRequest
- func (*QueryParamsByTimestampRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsByTimestampRequest) GetTimestamp() int64
- func (m *QueryParamsByTimestampRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsByTimestampRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsByTimestampRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsByTimestampRequest) ProtoMessage()
- func (m *QueryParamsByTimestampRequest) Reset()
- func (m *QueryParamsByTimestampRequest) Size() (n int)
- func (m *QueryParamsByTimestampRequest) String() string
- func (m *QueryParamsByTimestampRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsByTimestampRequest) XXX_DiscardUnknown()
- func (m *QueryParamsByTimestampRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsByTimestampRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsByTimestampRequest) XXX_Size() int
- func (m *QueryParamsByTimestampRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsByTimestampResponse
- func (*QueryParamsByTimestampResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsByTimestampResponse) GetParams() Params
- func (m *QueryParamsByTimestampResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsByTimestampResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsByTimestampResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsByTimestampResponse) ProtoMessage()
- func (m *QueryParamsByTimestampResponse) Reset()
- func (m *QueryParamsByTimestampResponse) Size() (n int)
- func (m *QueryParamsByTimestampResponse) String() string
- func (m *QueryParamsByTimestampResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsByTimestampResponse) XXX_DiscardUnknown()
- func (m *QueryParamsByTimestampResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsByTimestampResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsByTimestampResponse) XXX_Size() int
- func (m *QueryParamsByTimestampResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountCountRequest
- func (*QueryPaymentAccountCountRequest) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountCountRequest) GetOwner() string
- func (m *QueryPaymentAccountCountRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountCountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountCountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountCountRequest) ProtoMessage()
- func (m *QueryPaymentAccountCountRequest) Reset()
- func (m *QueryPaymentAccountCountRequest) Size() (n int)
- func (m *QueryPaymentAccountCountRequest) String() string
- func (m *QueryPaymentAccountCountRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountCountRequest) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountCountRequest) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountCountRequest) XXX_Size() int
- func (m *QueryPaymentAccountCountRequest) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountCountResponse
- func (*QueryPaymentAccountCountResponse) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountCountResponse) GetPaymentAccountCount() PaymentAccountCount
- func (m *QueryPaymentAccountCountResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountCountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountCountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountCountResponse) ProtoMessage()
- func (m *QueryPaymentAccountCountResponse) Reset()
- func (m *QueryPaymentAccountCountResponse) Size() (n int)
- func (m *QueryPaymentAccountCountResponse) String() string
- func (m *QueryPaymentAccountCountResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountCountResponse) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountCountResponse) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountCountResponse) XXX_Size() int
- func (m *QueryPaymentAccountCountResponse) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountCountsRequest
- func (*QueryPaymentAccountCountsRequest) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountCountsRequest) GetPagination() *query.PageRequest
- func (m *QueryPaymentAccountCountsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountCountsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountCountsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountCountsRequest) ProtoMessage()
- func (m *QueryPaymentAccountCountsRequest) Reset()
- func (m *QueryPaymentAccountCountsRequest) Size() (n int)
- func (m *QueryPaymentAccountCountsRequest) String() string
- func (m *QueryPaymentAccountCountsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountCountsRequest) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountCountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountCountsRequest) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountCountsRequest) XXX_Size() int
- func (m *QueryPaymentAccountCountsRequest) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountCountsResponse
- func (*QueryPaymentAccountCountsResponse) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountCountsResponse) GetPagination() *query.PageResponse
- func (m *QueryPaymentAccountCountsResponse) GetPaymentAccountCounts() []PaymentAccountCount
- func (m *QueryPaymentAccountCountsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountCountsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountCountsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountCountsResponse) ProtoMessage()
- func (m *QueryPaymentAccountCountsResponse) Reset()
- func (m *QueryPaymentAccountCountsResponse) Size() (n int)
- func (m *QueryPaymentAccountCountsResponse) String() string
- func (m *QueryPaymentAccountCountsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountCountsResponse) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountCountsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountCountsResponse) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountCountsResponse) XXX_Size() int
- func (m *QueryPaymentAccountCountsResponse) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountRequest
- func (*QueryPaymentAccountRequest) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountRequest) GetAddr() string
- func (m *QueryPaymentAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountRequest) ProtoMessage()
- func (m *QueryPaymentAccountRequest) Reset()
- func (m *QueryPaymentAccountRequest) Size() (n int)
- func (m *QueryPaymentAccountRequest) String() string
- func (m *QueryPaymentAccountRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountRequest) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountRequest) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountRequest) XXX_Size() int
- func (m *QueryPaymentAccountRequest) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountResponse
- func (*QueryPaymentAccountResponse) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountResponse) GetPaymentAccount() PaymentAccount
- func (m *QueryPaymentAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountResponse) ProtoMessage()
- func (m *QueryPaymentAccountResponse) Reset()
- func (m *QueryPaymentAccountResponse) Size() (n int)
- func (m *QueryPaymentAccountResponse) String() string
- func (m *QueryPaymentAccountResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountResponse) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountResponse) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountResponse) XXX_Size() int
- func (m *QueryPaymentAccountResponse) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountsByOwnerRequest
- func (*QueryPaymentAccountsByOwnerRequest) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountsByOwnerRequest) GetOwner() string
- func (m *QueryPaymentAccountsByOwnerRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountsByOwnerRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountsByOwnerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountsByOwnerRequest) ProtoMessage()
- func (m *QueryPaymentAccountsByOwnerRequest) Reset()
- func (m *QueryPaymentAccountsByOwnerRequest) Size() (n int)
- func (m *QueryPaymentAccountsByOwnerRequest) String() string
- func (m *QueryPaymentAccountsByOwnerRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountsByOwnerRequest) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountsByOwnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountsByOwnerRequest) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountsByOwnerRequest) XXX_Size() int
- func (m *QueryPaymentAccountsByOwnerRequest) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountsByOwnerResponse
- func (*QueryPaymentAccountsByOwnerResponse) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountsByOwnerResponse) GetPaymentAccounts() []string
- func (m *QueryPaymentAccountsByOwnerResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountsByOwnerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountsByOwnerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountsByOwnerResponse) ProtoMessage()
- func (m *QueryPaymentAccountsByOwnerResponse) Reset()
- func (m *QueryPaymentAccountsByOwnerResponse) Size() (n int)
- func (m *QueryPaymentAccountsByOwnerResponse) String() string
- func (m *QueryPaymentAccountsByOwnerResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountsByOwnerResponse) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountsByOwnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountsByOwnerResponse) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountsByOwnerResponse) XXX_Size() int
- func (m *QueryPaymentAccountsByOwnerResponse) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountsRequest
- func (*QueryPaymentAccountsRequest) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountsRequest) GetPagination() *query.PageRequest
- func (m *QueryPaymentAccountsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountsRequest) ProtoMessage()
- func (m *QueryPaymentAccountsRequest) Reset()
- func (m *QueryPaymentAccountsRequest) Size() (n int)
- func (m *QueryPaymentAccountsRequest) String() string
- func (m *QueryPaymentAccountsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountsRequest) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountsRequest) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountsRequest) XXX_Size() int
- func (m *QueryPaymentAccountsRequest) XXX_Unmarshal(b []byte) error
- type QueryPaymentAccountsResponse
- func (*QueryPaymentAccountsResponse) Descriptor() ([]byte, []int)
- func (m *QueryPaymentAccountsResponse) GetPagination() *query.PageResponse
- func (m *QueryPaymentAccountsResponse) GetPaymentAccounts() []PaymentAccount
- func (m *QueryPaymentAccountsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPaymentAccountsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPaymentAccountsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPaymentAccountsResponse) ProtoMessage()
- func (m *QueryPaymentAccountsResponse) Reset()
- func (m *QueryPaymentAccountsResponse) Size() (n int)
- func (m *QueryPaymentAccountsResponse) String() string
- func (m *QueryPaymentAccountsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPaymentAccountsResponse) XXX_DiscardUnknown()
- func (m *QueryPaymentAccountsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPaymentAccountsResponse) XXX_Merge(src proto.Message)
- func (m *QueryPaymentAccountsResponse) XXX_Size() int
- func (m *QueryPaymentAccountsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QueryStreamRecordsRequest
- func (*QueryStreamRecordsRequest) Descriptor() ([]byte, []int)
- func (m *QueryStreamRecordsRequest) GetPagination() *query.PageRequest
- func (m *QueryStreamRecordsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamRecordsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamRecordsRequest) ProtoMessage()
- func (m *QueryStreamRecordsRequest) Reset()
- func (m *QueryStreamRecordsRequest) Size() (n int)
- func (m *QueryStreamRecordsRequest) String() string
- func (m *QueryStreamRecordsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryStreamRecordsRequest) XXX_DiscardUnknown()
- func (m *QueryStreamRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamRecordsRequest) XXX_Merge(src proto.Message)
- func (m *QueryStreamRecordsRequest) XXX_Size() int
- func (m *QueryStreamRecordsRequest) XXX_Unmarshal(b []byte) error
- type QueryStreamRecordsResponse
- func (*QueryStreamRecordsResponse) Descriptor() ([]byte, []int)
- func (m *QueryStreamRecordsResponse) GetPagination() *query.PageResponse
- func (m *QueryStreamRecordsResponse) GetStreamRecords() []StreamRecord
- func (m *QueryStreamRecordsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamRecordsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamRecordsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamRecordsResponse) ProtoMessage()
- func (m *QueryStreamRecordsResponse) Reset()
- func (m *QueryStreamRecordsResponse) Size() (n int)
- func (m *QueryStreamRecordsResponse) String() string
- func (m *QueryStreamRecordsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryStreamRecordsResponse) XXX_DiscardUnknown()
- func (m *QueryStreamRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamRecordsResponse) XXX_Merge(src proto.Message)
- func (m *QueryStreamRecordsResponse) XXX_Size() int
- func (m *QueryStreamRecordsResponse) XXX_Unmarshal(b []byte) error
- type SpKeeper
- type StoragePrice
- type StoragePriceParams
- type StreamAccountStatus
- type StreamRecord
- func (*StreamRecord) Descriptor() ([]byte, []int)
- func (m *StreamRecord) GetAccount() string
- func (m *StreamRecord) GetCrudTimestamp() int64
- func (m *StreamRecord) GetOutFlowCount() uint64
- func (m *StreamRecord) GetSettleTimestamp() int64
- func (m *StreamRecord) GetStatus() StreamAccountStatus
- func (m *StreamRecord) Marshal() (dAtA []byte, err error)
- func (m *StreamRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamRecord) ProtoMessage()
- func (m *StreamRecord) Reset()
- func (m *StreamRecord) Size() (n int)
- func (m *StreamRecord) String() string
- func (m *StreamRecord) Unmarshal(dAtA []byte) error
- func (m *StreamRecord) XXX_DiscardUnknown()
- func (m *StreamRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamRecord) XXX_Merge(src proto.Message)
- func (m *StreamRecord) XXX_Size() int
- func (m *StreamRecord) XXX_Unmarshal(b []byte) error
- type StreamRecordChange
- func (change *StreamRecordChange) WithFrozenRateChange(frozenRateChange sdkmath.Int) *StreamRecordChange
- func (change *StreamRecordChange) WithLockBalanceChange(lockBalanceChange sdkmath.Int) *StreamRecordChange
- func (change *StreamRecordChange) WithRateChange(rateChange sdkmath.Int) *StreamRecordChange
- func (change *StreamRecordChange) WithStaticBalanceChange(staticBalanceChange sdkmath.Int) *StreamRecordChange
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) CreatePaymentAccount(ctx context.Context, req *MsgCreatePaymentAccount) (*MsgCreatePaymentAccountResponse, error)
- func (*UnimplementedMsgServer) Deposit(ctx context.Context, req *MsgDeposit) (*MsgDepositResponse, error)
- func (*UnimplementedMsgServer) DisableRefund(ctx context.Context, req *MsgDisableRefund) (*MsgDisableRefundResponse, error)
- func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
- func (*UnimplementedMsgServer) Withdraw(ctx context.Context, req *MsgWithdraw) (*MsgWithdrawResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) AutoSettleRecords(ctx context.Context, req *QueryAutoSettleRecordsRequest) (*QueryAutoSettleRecordsResponse, error)
- func (*UnimplementedQueryServer) DynamicBalance(ctx context.Context, req *QueryDynamicBalanceRequest) (*QueryDynamicBalanceResponse, error)
- func (*UnimplementedQueryServer) OutFlows(ctx context.Context, req *QueryOutFlowsRequest) (*QueryOutFlowsResponse, error)
- func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
- func (*UnimplementedQueryServer) ParamsByTimestamp(ctx context.Context, req *QueryParamsByTimestampRequest) (*QueryParamsByTimestampResponse, error)
- func (*UnimplementedQueryServer) PaymentAccount(ctx context.Context, req *QueryPaymentAccountRequest) (*QueryPaymentAccountResponse, error)
- func (*UnimplementedQueryServer) PaymentAccountCount(ctx context.Context, req *QueryPaymentAccountCountRequest) (*QueryPaymentAccountCountResponse, error)
- func (*UnimplementedQueryServer) PaymentAccountCounts(ctx context.Context, req *QueryPaymentAccountCountsRequest) (*QueryPaymentAccountCountsResponse, error)
- func (*UnimplementedQueryServer) PaymentAccounts(ctx context.Context, req *QueryPaymentAccountsRequest) (*QueryPaymentAccountsResponse, error)
- func (*UnimplementedQueryServer) PaymentAccountsByOwner(ctx context.Context, req *QueryPaymentAccountsByOwnerRequest) (*QueryPaymentAccountsByOwnerResponse, error)
- func (*UnimplementedQueryServer) StreamRecord(ctx context.Context, req *QueryGetStreamRecordRequest) (*QueryGetStreamRecordResponse, error)
- func (*UnimplementedQueryServer) StreamRecords(ctx context.Context, req *QueryStreamRecordsRequest) (*QueryStreamRecordsResponse, error)
- type UserFlows
- type VersionedParams
- func (*VersionedParams) Descriptor() ([]byte, []int)
- func (m *VersionedParams) GetReserveTime() uint64
- func (m *VersionedParams) Marshal() (dAtA []byte, err error)
- func (m *VersionedParams) MarshalTo(dAtA []byte) (int, error)
- func (m *VersionedParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VersionedParams) ProtoMessage()
- func (m *VersionedParams) Reset()
- func (m *VersionedParams) Size() (n int)
- func (m *VersionedParams) String() string
- func (m *VersionedParams) Unmarshal(dAtA []byte) error
- func (m *VersionedParams) XXX_DiscardUnknown()
- func (m *VersionedParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VersionedParams) XXX_Merge(src proto.Message)
- func (m *VersionedParams) XXX_Size() int
- func (m *VersionedParams) XXX_Unmarshal(b []byte) error
Constants ¶
const ( // ModuleName defines the module name ModuleName = "payment" // 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_payment" )
const DefaultIndex uint64 = 1
DefaultIndex is the default global index
const (
ForceUpdateStreamRecordKey = "force_update_stream_record"
)
const (
// GovernanceAddressLackBalanceLabel is the metrics label to notify that the governance account has no enough balance
GovernanceAddressLackBalanceLabel = "governance_address_lack_balance"
)
const TypeMsgCreatePaymentAccount = "create_payment_account"
const TypeMsgDeposit = "deposit"
const TypeMsgDisableRefund = "disable_refund"
const TypeMsgWithdraw = "withdraw"
Variables ¶
var ( ErrInvalidLengthAutoResumeRecord = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAutoResumeRecord = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAutoResumeRecord = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthAutoSettleRecord = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAutoSettleRecord = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAutoSettleRecord = fmt.Errorf("proto: unexpected end of group") )
var ( ErrReachPaymentAccountLimit = errorsmod.Register(ModuleName, 1200, "reach payment account count limit") ErrInvalidState = errorsmod.Register(ModuleName, 1201, "invalid state") ErrPaymentAccountNotFound = errorsmod.Register(ModuleName, 1202, "payment account not found") ErrStreamRecordNotFound = errorsmod.Register(ModuleName, 1203, "stream record not found") ErrNotPaymentAccountOwner = errorsmod.Register(ModuleName, 1204, "not payment account owner") ErrPaymentAccountAlreadyNonRefundable = errorsmod.Register(ModuleName, 1205, "payment account has already be set as non-refundable") ErrInsufficientBalance = errorsmod.Register(ModuleName, 1206, "insufficient balance") ErrReceiveAccountNotExist = errorsmod.Register(ModuleName, 1207, "receive account not exist") ErrInvalidStreamAccountStatus = errorsmod.Register(ModuleName, 1208, "invalid stream account status") ErrInvalidParams = errorsmod.Register(ModuleName, 1209, "invalid params") )
x/payment module sentinel errors
var ( ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( AutoSettleRecordKeyPrefix = []byte{0x01} AutoResumeRecordKeyPrefix = []byte{0x02} StreamRecordKeyPrefix = []byte{0x03} PaymentAccountCountKeyPrefix = []byte{0x04} PaymentAccountKeyPrefix = []byte{0x05} OutFlowKeyPrefix = []byte{0x06} ParamsKey = []byte{0x07} VersionedParamsKeyPrefix = []byte{0x08} )
var ( ErrInvalidLengthOutFlow = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOutFlow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupOutFlow = fmt.Errorf("proto: unexpected end of group") )
var ( KeyReserveTime = []byte("ReserveTime") KeyForcedSettleTime = []byte("ForcedSettleTime") KeyPaymentAccountCountLimit = []byte("PaymentAccountCountLimit") KeyMaxAutoSettleFlowCount = []byte("MaxAutoSettleFlowCount") KeyMaxAutoResumeFlowCount = []byte("MaxAutoResumeFlowCount") KeyFeeDenom = []byte("FeeDenom") KeyValidatorTaxRate = []byte("ValidatorTaxRate") DefaultReserveTime uint64 = 180 * 24 * 60 * 60 // 180 days DefaultValidatorTaxRate sdk.Dec = sdk.NewDecWithPrec(1, 2) // 1% DefaultForcedSettleTime uint64 = 24 * 60 * 60 // 1 day DefaultPaymentAccountCountLimit uint64 = 200 DefaultMaxAutoSettleFlowCount uint64 = 100 DefaultMaxAutoResumeFlowCount uint64 = 100 DefaultFeeDenom string = "BNB" )
var ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPaymentAccount = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPaymentAccount = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPaymentAccount = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPaymentAccountCount = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPaymentAccountCount = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPaymentAccountCount = 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 ( ErrInvalidLengthStreamRecord = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStreamRecord = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupStreamRecord = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var ( // GovernanceAddress used to receive fee of storage system, and pay for the potential debt from late forced settlement GovernanceAddress = sdk.AccAddress(address.Module(ModuleName, []byte("governance"))[:sdk.EthAddressLength]) ValidatorTaxPoolAddress = sdk.AccAddress(address.Module(ModuleName, []byte("validator-tax-pool"))[:sdk.EthAddressLength]) )
var FeePreviewType_name = map[int32]string{
0: "FEE_PREVIEW_TYPE_PRELOCKED_FEE",
1: "FEE_PREVIEW_TYPE_UNLOCKED_FEE",
}
var FeePreviewType_value = map[string]int32{
"FEE_PREVIEW_TYPE_PRELOCKED_FEE": 0,
"FEE_PREVIEW_TYPE_UNLOCKED_FEE": 1,
}
var (
ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
var OutFlowStatus_name = map[int32]string{
0: "OUT_FLOW_STATUS_ACTIVE",
1: "OUT_FLOW_STATUS_FROZEN",
}
var OutFlowStatus_value = map[string]int32{
"OUT_FLOW_STATUS_ACTIVE": 0,
"OUT_FLOW_STATUS_FROZEN": 1,
}
var StreamAccountStatus_name = map[int32]string{
0: "STREAM_ACCOUNT_STATUS_ACTIVE",
1: "STREAM_ACCOUNT_STATUS_FROZEN",
}
var StreamAccountStatus_value = map[string]int32{
"STREAM_ACCOUNT_STATUS_ACTIVE": 0,
"STREAM_ACCOUNT_STATUS_FROZEN": 1,
}
Functions ¶
func AutoResumeRecordKey ¶ added in v0.2.3
func AutoResumeRecordKey( timestamp int64, addr sdk.AccAddress, ) []byte
AutoResumeRecordKey returns the store key to retrieve a AutoResumeRecord from the index fields
func AutoSettleRecordKey ¶
func AutoSettleRecordKey( timestamp int64, addr sdk.AccAddress, ) []byte
AutoSettleRecordKey returns the store key to retrieve a AutoSettleRecord from the index fields
func OutFlowKey ¶ added in v0.2.3
func OutFlowKey( addr sdk.AccAddress, status OutFlowStatus, toAddr sdk.AccAddress) []byte
func ParamKeyTable ¶
func ParamKeyTable() paramtypes.KeyTable
ParamKeyTable the param key table for launch module
func ParseOutFlowValue ¶ added in v0.2.3
func PaymentAccountCountKey ¶
func PaymentAccountCountKey( owner sdk.AccAddress, ) []byte
PaymentAccountCountKey returns the store key to retrieve a PaymentAccountCount from the index fields
func PaymentAccountKey ¶
func PaymentAccountKey( addr sdk.AccAddress, ) []byte
PaymentAccountKey returns the store key to retrieve a PaymentAccount 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)
func StreamRecordKey ¶
func StreamRecordKey( account sdk.AccAddress, ) []byte
StreamRecordKey returns the store key to retrieve a StreamRecord from the index fields
func VersionedParamsKey ¶ added in v0.2.3
VersionedParamsKey return multi-version params store key
Types ¶
type AccountKeeper ¶
type AccountKeeper interface { GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI HasAccount(ctx sdk.Context, addr sdk.AccAddress) bool GetModuleAddress(name string) sdk.AccAddress GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI SetModuleAccount(sdk.Context, authtypes.ModuleAccountI) }
AccountKeeper defines the expected account keeper used for simulations (noalias)
type AutoResumeRecord ¶ added in v0.2.3
type AutoResumeRecord struct { // timestamp is the unix timestamp to order the records Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // the stream account address Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` }
AutoResumeRecord is the record keeps the auto resume information. The EndBlocker of payment module will scan the list of AutoResumeRecord and resume the stream account one by one.
func ParseAutoResumeRecordKey ¶ added in v0.2.3
func ParseAutoResumeRecordKey(key []byte) (res AutoResumeRecord)
func (*AutoResumeRecord) Descriptor ¶ added in v0.2.3
func (*AutoResumeRecord) Descriptor() ([]byte, []int)
func (*AutoResumeRecord) GetAddr ¶ added in v0.2.3
func (m *AutoResumeRecord) GetAddr() string
func (*AutoResumeRecord) GetTimestamp ¶ added in v0.2.3
func (m *AutoResumeRecord) GetTimestamp() int64
func (*AutoResumeRecord) Marshal ¶ added in v0.2.3
func (m *AutoResumeRecord) Marshal() (dAtA []byte, err error)
func (*AutoResumeRecord) MarshalTo ¶ added in v0.2.3
func (m *AutoResumeRecord) MarshalTo(dAtA []byte) (int, error)
func (*AutoResumeRecord) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *AutoResumeRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AutoResumeRecord) ProtoMessage ¶ added in v0.2.3
func (*AutoResumeRecord) ProtoMessage()
func (*AutoResumeRecord) Reset ¶ added in v0.2.3
func (m *AutoResumeRecord) Reset()
func (*AutoResumeRecord) Size ¶ added in v0.2.3
func (m *AutoResumeRecord) Size() (n int)
func (*AutoResumeRecord) String ¶ added in v0.2.3
func (m *AutoResumeRecord) String() string
func (*AutoResumeRecord) Unmarshal ¶ added in v0.2.3
func (m *AutoResumeRecord) Unmarshal(dAtA []byte) error
func (*AutoResumeRecord) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *AutoResumeRecord) XXX_DiscardUnknown()
func (*AutoResumeRecord) XXX_Marshal ¶ added in v0.2.3
func (m *AutoResumeRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AutoResumeRecord) XXX_Merge ¶ added in v0.2.3
func (m *AutoResumeRecord) XXX_Merge(src proto.Message)
func (*AutoResumeRecord) XXX_Size ¶ added in v0.2.3
func (m *AutoResumeRecord) XXX_Size() int
func (*AutoResumeRecord) XXX_Unmarshal ¶ added in v0.2.3
func (m *AutoResumeRecord) XXX_Unmarshal(b []byte) error
type AutoSettleRecord ¶
type AutoSettleRecord struct { // timestamp is the unix timestamp when the stream account will be settled. Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // A stream account address Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` }
AutoSettleRecord is the record keeps the auto settle information. The EndBlocker of payment module will scan the list of AutoSettleRecord and settle the stream account if the timestamp is less than the current time.
func ParseAutoSettleRecordKey ¶
func ParseAutoSettleRecordKey(key []byte) (res AutoSettleRecord)
func (*AutoSettleRecord) Descriptor ¶
func (*AutoSettleRecord) Descriptor() ([]byte, []int)
func (*AutoSettleRecord) GetAddr ¶
func (m *AutoSettleRecord) GetAddr() string
func (*AutoSettleRecord) GetTimestamp ¶
func (m *AutoSettleRecord) GetTimestamp() int64
func (*AutoSettleRecord) Marshal ¶
func (m *AutoSettleRecord) Marshal() (dAtA []byte, err error)
func (*AutoSettleRecord) MarshalToSizedBuffer ¶
func (m *AutoSettleRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AutoSettleRecord) ProtoMessage ¶
func (*AutoSettleRecord) ProtoMessage()
func (*AutoSettleRecord) Reset ¶
func (m *AutoSettleRecord) Reset()
func (*AutoSettleRecord) Size ¶
func (m *AutoSettleRecord) Size() (n int)
func (*AutoSettleRecord) String ¶
func (m *AutoSettleRecord) String() string
func (*AutoSettleRecord) Unmarshal ¶
func (m *AutoSettleRecord) Unmarshal(dAtA []byte) error
func (*AutoSettleRecord) XXX_DiscardUnknown ¶
func (m *AutoSettleRecord) XXX_DiscardUnknown()
func (*AutoSettleRecord) XXX_Marshal ¶
func (m *AutoSettleRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AutoSettleRecord) XXX_Merge ¶
func (m *AutoSettleRecord) XXX_Merge(src proto.Message)
func (*AutoSettleRecord) XXX_Size ¶
func (m *AutoSettleRecord) XXX_Size() int
func (*AutoSettleRecord) XXX_Unmarshal ¶
func (m *AutoSettleRecord) XXX_Unmarshal(b []byte) error
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 SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error }
BankKeeper defines the expected interface needed to retrieve account balances.
type EventDeposit ¶ added in v0.0.7
type EventDeposit struct { // from is the the address of the account to deposit from From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // to is the address of the stream account to deposit to To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` // amount is the amount to deposit Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"` }
func (*EventDeposit) Descriptor ¶ added in v0.0.7
func (*EventDeposit) Descriptor() ([]byte, []int)
func (*EventDeposit) GetFrom ¶ added in v0.0.7
func (m *EventDeposit) GetFrom() string
func (*EventDeposit) GetTo ¶ added in v0.0.7
func (m *EventDeposit) GetTo() string
func (*EventDeposit) Marshal ¶ added in v0.0.7
func (m *EventDeposit) Marshal() (dAtA []byte, err error)
func (*EventDeposit) MarshalTo ¶ added in v0.0.7
func (m *EventDeposit) MarshalTo(dAtA []byte) (int, error)
func (*EventDeposit) MarshalToSizedBuffer ¶ added in v0.0.7
func (m *EventDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventDeposit) ProtoMessage ¶ added in v0.0.7
func (*EventDeposit) ProtoMessage()
func (*EventDeposit) Reset ¶ added in v0.0.7
func (m *EventDeposit) Reset()
func (*EventDeposit) Size ¶ added in v0.0.7
func (m *EventDeposit) Size() (n int)
func (*EventDeposit) String ¶ added in v0.0.7
func (m *EventDeposit) String() string
func (*EventDeposit) Unmarshal ¶ added in v0.0.7
func (m *EventDeposit) Unmarshal(dAtA []byte) error
func (*EventDeposit) XXX_DiscardUnknown ¶ added in v0.0.7
func (m *EventDeposit) XXX_DiscardUnknown()
func (*EventDeposit) XXX_Marshal ¶ added in v0.0.7
func (m *EventDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventDeposit) XXX_Merge ¶ added in v0.0.7
func (m *EventDeposit) XXX_Merge(src proto.Message)
func (*EventDeposit) XXX_Size ¶ added in v0.0.7
func (m *EventDeposit) XXX_Size() int
func (*EventDeposit) XXX_Unmarshal ¶ added in v0.0.7
func (m *EventDeposit) XXX_Unmarshal(b []byte) error
type EventFeePreview ¶ added in v0.1.2
type EventFeePreview struct { Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"` FeePreviewType FeePreviewType `` /* 145-byte string literal not displayed */ Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"` }
emit when upload/cancel/delete object, used for frontend to preview the fee changed only emit in tx simulation
func (*EventFeePreview) Descriptor ¶ added in v0.1.2
func (*EventFeePreview) Descriptor() ([]byte, []int)
func (*EventFeePreview) GetAccount ¶ added in v0.1.2
func (m *EventFeePreview) GetAccount() string
func (*EventFeePreview) GetFeePreviewType ¶ added in v0.1.2
func (m *EventFeePreview) GetFeePreviewType() FeePreviewType
func (*EventFeePreview) Marshal ¶ added in v0.1.2
func (m *EventFeePreview) Marshal() (dAtA []byte, err error)
func (*EventFeePreview) MarshalTo ¶ added in v0.1.2
func (m *EventFeePreview) MarshalTo(dAtA []byte) (int, error)
func (*EventFeePreview) MarshalToSizedBuffer ¶ added in v0.1.2
func (m *EventFeePreview) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventFeePreview) ProtoMessage ¶ added in v0.1.2
func (*EventFeePreview) ProtoMessage()
func (*EventFeePreview) Reset ¶ added in v0.1.2
func (m *EventFeePreview) Reset()
func (*EventFeePreview) Size ¶ added in v0.1.2
func (m *EventFeePreview) Size() (n int)
func (*EventFeePreview) String ¶ added in v0.1.2
func (m *EventFeePreview) String() string
func (*EventFeePreview) Unmarshal ¶ added in v0.1.2
func (m *EventFeePreview) Unmarshal(dAtA []byte) error
func (*EventFeePreview) XXX_DiscardUnknown ¶ added in v0.1.2
func (m *EventFeePreview) XXX_DiscardUnknown()
func (*EventFeePreview) XXX_Marshal ¶ added in v0.1.2
func (m *EventFeePreview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventFeePreview) XXX_Merge ¶ added in v0.1.2
func (m *EventFeePreview) XXX_Merge(src proto.Message)
func (*EventFeePreview) XXX_Size ¶ added in v0.1.2
func (m *EventFeePreview) XXX_Size() int
func (*EventFeePreview) XXX_Unmarshal ¶ added in v0.1.2
func (m *EventFeePreview) XXX_Unmarshal(b []byte) error
type EventForceSettle ¶
type EventForceSettle struct { // address of the payment account Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // left balance of the payment account after force settlement // if the balance is positive, it will go to the governance stream account // if the balance is negative, it's the debt of the system, which will be paid by the governance stream account SettledBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 143-byte string literal not displayed */ }
EventForceSettle may be emitted on all Msgs and EndBlocker when a payment account's balance or net outflow rate is changed
func (*EventForceSettle) Descriptor ¶
func (*EventForceSettle) Descriptor() ([]byte, []int)
func (*EventForceSettle) GetAddr ¶
func (m *EventForceSettle) GetAddr() string
func (*EventForceSettle) Marshal ¶
func (m *EventForceSettle) Marshal() (dAtA []byte, err error)
func (*EventForceSettle) MarshalToSizedBuffer ¶
func (m *EventForceSettle) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventForceSettle) ProtoMessage ¶
func (*EventForceSettle) ProtoMessage()
func (*EventForceSettle) Reset ¶
func (m *EventForceSettle) Reset()
func (*EventForceSettle) Size ¶
func (m *EventForceSettle) Size() (n int)
func (*EventForceSettle) String ¶
func (m *EventForceSettle) String() string
func (*EventForceSettle) Unmarshal ¶
func (m *EventForceSettle) Unmarshal(dAtA []byte) error
func (*EventForceSettle) XXX_DiscardUnknown ¶
func (m *EventForceSettle) XXX_DiscardUnknown()
func (*EventForceSettle) XXX_Marshal ¶
func (m *EventForceSettle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventForceSettle) XXX_Merge ¶
func (m *EventForceSettle) XXX_Merge(src proto.Message)
func (*EventForceSettle) XXX_Size ¶
func (m *EventForceSettle) XXX_Size() int
func (*EventForceSettle) XXX_Unmarshal ¶
func (m *EventForceSettle) XXX_Unmarshal(b []byte) error
type EventPaymentAccountUpdate ¶ added in v0.0.7
type EventPaymentAccountUpdate struct { // address of the payment account Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // owner address of the payment account Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` // whether the payment account is refundable Refundable bool `protobuf:"varint,3,opt,name=refundable,proto3" json:"refundable,omitempty"` }
func (*EventPaymentAccountUpdate) Descriptor ¶ added in v0.0.7
func (*EventPaymentAccountUpdate) Descriptor() ([]byte, []int)
func (*EventPaymentAccountUpdate) GetAddr ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) GetAddr() string
func (*EventPaymentAccountUpdate) GetOwner ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) GetOwner() string
func (*EventPaymentAccountUpdate) GetRefundable ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) GetRefundable() bool
func (*EventPaymentAccountUpdate) Marshal ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) Marshal() (dAtA []byte, err error)
func (*EventPaymentAccountUpdate) MarshalTo ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) MarshalTo(dAtA []byte) (int, error)
func (*EventPaymentAccountUpdate) MarshalToSizedBuffer ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventPaymentAccountUpdate) ProtoMessage ¶ added in v0.0.7
func (*EventPaymentAccountUpdate) ProtoMessage()
func (*EventPaymentAccountUpdate) Reset ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) Reset()
func (*EventPaymentAccountUpdate) Size ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) Size() (n int)
func (*EventPaymentAccountUpdate) String ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) String() string
func (*EventPaymentAccountUpdate) Unmarshal ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) Unmarshal(dAtA []byte) error
func (*EventPaymentAccountUpdate) XXX_DiscardUnknown ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) XXX_DiscardUnknown()
func (*EventPaymentAccountUpdate) XXX_Marshal ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventPaymentAccountUpdate) XXX_Merge ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) XXX_Merge(src proto.Message)
func (*EventPaymentAccountUpdate) XXX_Size ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) XXX_Size() int
func (*EventPaymentAccountUpdate) XXX_Unmarshal ¶ added in v0.0.7
func (m *EventPaymentAccountUpdate) XXX_Unmarshal(b []byte) error
type EventStreamRecordUpdate ¶ added in v0.0.7
type EventStreamRecordUpdate struct { // account address Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"` // latest update timestamp of the stream record CrudTimestamp int64 `protobuf:"varint,2,opt,name=crud_timestamp,json=crudTimestamp,proto3" json:"crud_timestamp,omitempty"` // The per-second rate that an account's balance is changing. // It is the sum of the account's inbound and outbound flow rates. NetflowRate github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ // The frozen netflow rate, which is used when resuming stream account FrozenNetflowRate github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */ // The balance of the stream account at the latest CRUD timestamp. StaticBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */ // reserved balance of the stream account // If the netflow rate is negative, the reserved balance is `netflow_rate * reserve_time` BufferBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */ // the locked balance of the stream account after it puts a new object and before the object is sealed LockBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ // the status of the stream account Status StreamAccountStatus `protobuf:"varint,8,opt,name=status,proto3,enum=greenfield.payment.StreamAccountStatus" json:"status,omitempty"` // the unix timestamp when the stream account will be settled SettleTimestamp int64 `protobuf:"varint,9,opt,name=settle_timestamp,json=settleTimestamp,proto3" json:"settle_timestamp,omitempty"` }
Stream Payment Record of a stream account
func (*EventStreamRecordUpdate) Descriptor ¶ added in v0.0.7
func (*EventStreamRecordUpdate) Descriptor() ([]byte, []int)
func (*EventStreamRecordUpdate) GetAccount ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) GetAccount() string
func (*EventStreamRecordUpdate) GetCrudTimestamp ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) GetCrudTimestamp() int64
func (*EventStreamRecordUpdate) GetSettleTimestamp ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) GetSettleTimestamp() int64
func (*EventStreamRecordUpdate) GetStatus ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) GetStatus() StreamAccountStatus
func (*EventStreamRecordUpdate) Marshal ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) Marshal() (dAtA []byte, err error)
func (*EventStreamRecordUpdate) MarshalTo ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) MarshalTo(dAtA []byte) (int, error)
func (*EventStreamRecordUpdate) MarshalToSizedBuffer ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventStreamRecordUpdate) ProtoMessage ¶ added in v0.0.7
func (*EventStreamRecordUpdate) ProtoMessage()
func (*EventStreamRecordUpdate) Reset ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) Reset()
func (*EventStreamRecordUpdate) Size ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) Size() (n int)
func (*EventStreamRecordUpdate) String ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) String() string
func (*EventStreamRecordUpdate) Unmarshal ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) Unmarshal(dAtA []byte) error
func (*EventStreamRecordUpdate) XXX_DiscardUnknown ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) XXX_DiscardUnknown()
func (*EventStreamRecordUpdate) XXX_Marshal ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventStreamRecordUpdate) XXX_Merge ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) XXX_Merge(src proto.Message)
func (*EventStreamRecordUpdate) XXX_Size ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) XXX_Size() int
func (*EventStreamRecordUpdate) XXX_Unmarshal ¶ added in v0.0.7
func (m *EventStreamRecordUpdate) XXX_Unmarshal(b []byte) error
type EventWithdraw ¶ added in v0.0.7
type EventWithdraw struct { // to the address of the receive account To string `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"` // from is the address of the stream account to withdraw from From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` // amount is the amount to withdraw Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"` }
func (*EventWithdraw) Descriptor ¶ added in v0.0.7
func (*EventWithdraw) Descriptor() ([]byte, []int)
func (*EventWithdraw) GetFrom ¶ added in v0.0.7
func (m *EventWithdraw) GetFrom() string
func (*EventWithdraw) GetTo ¶ added in v0.0.7
func (m *EventWithdraw) GetTo() string
func (*EventWithdraw) Marshal ¶ added in v0.0.7
func (m *EventWithdraw) Marshal() (dAtA []byte, err error)
func (*EventWithdraw) MarshalTo ¶ added in v0.0.7
func (m *EventWithdraw) MarshalTo(dAtA []byte) (int, error)
func (*EventWithdraw) MarshalToSizedBuffer ¶ added in v0.0.7
func (m *EventWithdraw) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventWithdraw) ProtoMessage ¶ added in v0.0.7
func (*EventWithdraw) ProtoMessage()
func (*EventWithdraw) Reset ¶ added in v0.0.7
func (m *EventWithdraw) Reset()
func (*EventWithdraw) Size ¶ added in v0.0.7
func (m *EventWithdraw) Size() (n int)
func (*EventWithdraw) String ¶ added in v0.0.7
func (m *EventWithdraw) String() string
func (*EventWithdraw) Unmarshal ¶ added in v0.0.7
func (m *EventWithdraw) Unmarshal(dAtA []byte) error
func (*EventWithdraw) XXX_DiscardUnknown ¶ added in v0.0.7
func (m *EventWithdraw) XXX_DiscardUnknown()
func (*EventWithdraw) XXX_Marshal ¶ added in v0.0.7
func (m *EventWithdraw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventWithdraw) XXX_Merge ¶ added in v0.0.7
func (m *EventWithdraw) XXX_Merge(src proto.Message)
func (*EventWithdraw) XXX_Size ¶ added in v0.0.7
func (m *EventWithdraw) XXX_Size() int
func (*EventWithdraw) XXX_Unmarshal ¶ added in v0.0.7
func (m *EventWithdraw) XXX_Unmarshal(b []byte) error
type FeePreviewType ¶ added in v0.1.2
type FeePreviewType int32
const ( FEE_PREVIEW_TYPE_PRELOCKED_FEE FeePreviewType = 0 FEE_PREVIEW_TYPE_UNLOCKED_FEE FeePreviewType = 1 )
func (FeePreviewType) EnumDescriptor ¶ added in v0.1.2
func (FeePreviewType) EnumDescriptor() ([]byte, []int)
func (FeePreviewType) String ¶ added in v0.1.2
func (x FeePreviewType) String() string
type GenesisState ¶
type GenesisState struct { Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` StreamRecordList []StreamRecord `protobuf:"bytes,2,rep,name=stream_record_list,json=streamRecordList,proto3" json:"stream_record_list"` PaymentAccountCountList []PaymentAccountCount `protobuf:"bytes,3,rep,name=payment_account_count_list,json=paymentAccountCountList,proto3" json:"payment_account_count_list"` PaymentAccountList []PaymentAccount `protobuf:"bytes,4,rep,name=payment_account_list,json=paymentAccountList,proto3" json:"payment_account_list"` AutoSettleRecordList []AutoSettleRecord `protobuf:"bytes,5,rep,name=auto_settle_record_list,json=autoSettleRecordList,proto3" json:"auto_settle_record_list"` }
GenesisState defines the payment 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) GetAutoSettleRecordList ¶
func (m *GenesisState) GetAutoSettleRecordList() []AutoSettleRecord
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetPaymentAccountCountList ¶
func (m *GenesisState) GetPaymentAccountCountList() []PaymentAccountCount
func (*GenesisState) GetPaymentAccountList ¶
func (m *GenesisState) GetPaymentAccountList() []PaymentAccount
func (*GenesisState) GetStreamRecordList ¶
func (m *GenesisState) GetStreamRecordList() []StreamRecord
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 MockAccountKeeper ¶ added in v0.2.0
type MockAccountKeeper struct {
// contains filtered or unexported fields
}
MockAccountKeeper is a mock of AccountKeeper interface.
func NewMockAccountKeeper ¶ added in v0.2.0
func NewMockAccountKeeper(ctrl *gomock.Controller) *MockAccountKeeper
NewMockAccountKeeper creates a new mock instance.
func (*MockAccountKeeper) EXPECT ¶ added in v0.2.0
func (m *MockAccountKeeper) EXPECT() *MockAccountKeeperMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAccountKeeper) GetAccount ¶ added in v0.2.0
func (m *MockAccountKeeper) GetAccount(ctx types0.Context, addr types0.AccAddress) types1.AccountI
GetAccount mocks base method.
func (*MockAccountKeeper) GetModuleAccount ¶ added in v0.2.0
func (m *MockAccountKeeper) GetModuleAccount(ctx types0.Context, moduleName string) types1.ModuleAccountI
GetModuleAccount mocks base method.
func (*MockAccountKeeper) GetModuleAddress ¶ added in v0.2.0
func (m *MockAccountKeeper) GetModuleAddress(name string) types0.AccAddress
GetModuleAddress mocks base method.
func (*MockAccountKeeper) HasAccount ¶ added in v0.2.0
func (m *MockAccountKeeper) HasAccount(ctx types0.Context, addr types0.AccAddress) bool
HasAccount mocks base method.
func (*MockAccountKeeper) SetModuleAccount ¶ added in v0.2.0
func (m *MockAccountKeeper) SetModuleAccount(arg0 types0.Context, arg1 types1.ModuleAccountI)
SetModuleAccount mocks base method.
type MockAccountKeeperMockRecorder ¶ added in v0.2.0
type MockAccountKeeperMockRecorder struct {
// contains filtered or unexported fields
}
MockAccountKeeperMockRecorder is the mock recorder for MockAccountKeeper.
func (*MockAccountKeeperMockRecorder) GetAccount ¶ added in v0.2.0
func (mr *MockAccountKeeperMockRecorder) GetAccount(ctx, addr interface{}) *gomock.Call
GetAccount indicates an expected call of GetAccount.
func (*MockAccountKeeperMockRecorder) GetModuleAccount ¶ added in v0.2.0
func (mr *MockAccountKeeperMockRecorder) GetModuleAccount(ctx, moduleName interface{}) *gomock.Call
GetModuleAccount indicates an expected call of GetModuleAccount.
func (*MockAccountKeeperMockRecorder) GetModuleAddress ¶ added in v0.2.0
func (mr *MockAccountKeeperMockRecorder) GetModuleAddress(name interface{}) *gomock.Call
GetModuleAddress indicates an expected call of GetModuleAddress.
func (*MockAccountKeeperMockRecorder) HasAccount ¶ added in v0.2.0
func (mr *MockAccountKeeperMockRecorder) HasAccount(ctx, addr interface{}) *gomock.Call
HasAccount indicates an expected call of HasAccount.
func (*MockAccountKeeperMockRecorder) SetModuleAccount ¶ added in v0.2.0
func (mr *MockAccountKeeperMockRecorder) SetModuleAccount(arg0, arg1 interface{}) *gomock.Call
SetModuleAccount indicates an expected call of SetModuleAccount.
type MockBankKeeper ¶ added in v0.2.0
type MockBankKeeper struct {
// contains filtered or unexported fields
}
MockBankKeeper is a mock of BankKeeper interface.
func NewMockBankKeeper ¶ added in v0.2.0
func NewMockBankKeeper(ctrl *gomock.Controller) *MockBankKeeper
NewMockBankKeeper creates a new mock instance.
func (*MockBankKeeper) EXPECT ¶ added in v0.2.0
func (m *MockBankKeeper) EXPECT() *MockBankKeeperMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBankKeeper) GetAllBalances ¶ added in v0.2.0
func (m *MockBankKeeper) GetAllBalances(ctx types0.Context, addr types0.AccAddress) types0.Coins
GetAllBalances mocks base method.
func (*MockBankKeeper) GetBalance ¶ added in v0.2.0
func (m *MockBankKeeper) GetBalance(ctx types0.Context, addr types0.AccAddress, denom string) types0.Coin
GetBalance mocks base method.
func (*MockBankKeeper) SendCoinsFromAccountToModule ¶ added in v0.2.0
func (m *MockBankKeeper) SendCoinsFromAccountToModule(ctx types0.Context, senderAddr types0.AccAddress, recipientModule string, amt types0.Coins) error
SendCoinsFromAccountToModule mocks base method.
func (*MockBankKeeper) SendCoinsFromModuleToAccount ¶ added in v0.2.0
func (m *MockBankKeeper) SendCoinsFromModuleToAccount(ctx types0.Context, senderModule string, recipientAddr types0.AccAddress, amt types0.Coins) error
SendCoinsFromModuleToAccount mocks base method.
func (*MockBankKeeper) SpendableCoins ¶ added in v0.2.0
func (m *MockBankKeeper) SpendableCoins(ctx types0.Context, addr types0.AccAddress) types0.Coins
SpendableCoins mocks base method.
type MockBankKeeperMockRecorder ¶ added in v0.2.0
type MockBankKeeperMockRecorder struct {
// contains filtered or unexported fields
}
MockBankKeeperMockRecorder is the mock recorder for MockBankKeeper.
func (*MockBankKeeperMockRecorder) GetAllBalances ¶ added in v0.2.0
func (mr *MockBankKeeperMockRecorder) GetAllBalances(ctx, addr interface{}) *gomock.Call
GetAllBalances indicates an expected call of GetAllBalances.
func (*MockBankKeeperMockRecorder) GetBalance ¶ added in v0.2.0
func (mr *MockBankKeeperMockRecorder) GetBalance(ctx, addr, denom interface{}) *gomock.Call
GetBalance indicates an expected call of GetBalance.
func (*MockBankKeeperMockRecorder) SendCoinsFromAccountToModule ¶ added in v0.2.0
func (mr *MockBankKeeperMockRecorder) SendCoinsFromAccountToModule(ctx, senderAddr, recipientModule, amt interface{}) *gomock.Call
SendCoinsFromAccountToModule indicates an expected call of SendCoinsFromAccountToModule.
func (*MockBankKeeperMockRecorder) SendCoinsFromModuleToAccount ¶ added in v0.2.0
func (mr *MockBankKeeperMockRecorder) SendCoinsFromModuleToAccount(ctx, senderModule, recipientAddr, amt interface{}) *gomock.Call
SendCoinsFromModuleToAccount indicates an expected call of SendCoinsFromModuleToAccount.
func (*MockBankKeeperMockRecorder) SpendableCoins ¶ added in v0.2.0
func (mr *MockBankKeeperMockRecorder) SpendableCoins(ctx, addr interface{}) *gomock.Call
SpendableCoins indicates an expected call of SpendableCoins.
type MockSpKeeper ¶ added in v0.2.0
type MockSpKeeper struct {
// contains filtered or unexported fields
}
MockSpKeeper is a mock of SpKeeper interface.
func NewMockSpKeeper ¶ added in v0.2.0
func NewMockSpKeeper(ctrl *gomock.Controller) *MockSpKeeper
NewMockSpKeeper creates a new mock instance.
func (*MockSpKeeper) EXPECT ¶ added in v0.2.0
func (m *MockSpKeeper) EXPECT() *MockSpKeeperMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSpKeeper) GetSecondarySpStorePriceByTime ¶ added in v0.2.0
func (m *MockSpKeeper) GetSecondarySpStorePriceByTime(ctx types0.Context, time int64) (types.SecondarySpStorePrice, error)
GetSecondarySpStorePriceByTime mocks base method.
func (*MockSpKeeper) GetSpStoragePriceByTime ¶ added in v0.2.0
func (m *MockSpKeeper) GetSpStoragePriceByTime(ctx types0.Context, spId uint32, time int64) (types.SpStoragePrice, error)
GetSpStoragePriceByTime mocks base method.
type MockSpKeeperMockRecorder ¶ added in v0.2.0
type MockSpKeeperMockRecorder struct {
// contains filtered or unexported fields
}
MockSpKeeperMockRecorder is the mock recorder for MockSpKeeper.
func (*MockSpKeeperMockRecorder) GetSecondarySpStorePriceByTime ¶ added in v0.2.0
func (mr *MockSpKeeperMockRecorder) GetSecondarySpStorePriceByTime(ctx, time interface{}) *gomock.Call
GetSecondarySpStorePriceByTime indicates an expected call of GetSecondarySpStorePriceByTime.
func (*MockSpKeeperMockRecorder) GetSpStoragePriceByTime ¶ added in v0.2.0
func (mr *MockSpKeeperMockRecorder) GetSpStoragePriceByTime(ctx, spId, time interface{}) *gomock.Call
GetSpStoragePriceByTime indicates an expected call of GetSpStoragePriceByTime.
type MsgClient ¶
type MsgClient interface { // UpdateParams defines a governance operation for updating the x/payment module parameters. // The authority is defined in the keeper. // // Since: cosmos-sdk 0.47 UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error) CreatePaymentAccount(ctx context.Context, in *MsgCreatePaymentAccount, opts ...grpc.CallOption) (*MsgCreatePaymentAccountResponse, error) Deposit(ctx context.Context, in *MsgDeposit, opts ...grpc.CallOption) (*MsgDepositResponse, error) Withdraw(ctx context.Context, in *MsgWithdraw, opts ...grpc.CallOption) (*MsgWithdrawResponse, error) DisableRefund(ctx context.Context, in *MsgDisableRefund, opts ...grpc.CallOption) (*MsgDisableRefundResponse, 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 MsgCreatePaymentAccount ¶
type MsgCreatePaymentAccount struct { // creator is the address of the stream account that created the payment account Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` }
func NewMsgCreatePaymentAccount ¶
func NewMsgCreatePaymentAccount(creator string) *MsgCreatePaymentAccount
func (*MsgCreatePaymentAccount) Descriptor ¶
func (*MsgCreatePaymentAccount) Descriptor() ([]byte, []int)
func (*MsgCreatePaymentAccount) GetCreator ¶
func (m *MsgCreatePaymentAccount) GetCreator() string
func (*MsgCreatePaymentAccount) GetSignBytes ¶
func (msg *MsgCreatePaymentAccount) GetSignBytes() []byte
func (*MsgCreatePaymentAccount) GetSigners ¶
func (msg *MsgCreatePaymentAccount) GetSigners() []sdk.AccAddress
func (*MsgCreatePaymentAccount) Marshal ¶
func (m *MsgCreatePaymentAccount) Marshal() (dAtA []byte, err error)
func (*MsgCreatePaymentAccount) MarshalTo ¶
func (m *MsgCreatePaymentAccount) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreatePaymentAccount) MarshalToSizedBuffer ¶
func (m *MsgCreatePaymentAccount) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreatePaymentAccount) ProtoMessage ¶
func (*MsgCreatePaymentAccount) ProtoMessage()
func (*MsgCreatePaymentAccount) Reset ¶
func (m *MsgCreatePaymentAccount) Reset()
func (*MsgCreatePaymentAccount) Route ¶
func (msg *MsgCreatePaymentAccount) Route() string
func (*MsgCreatePaymentAccount) Size ¶
func (m *MsgCreatePaymentAccount) Size() (n int)
func (*MsgCreatePaymentAccount) String ¶
func (m *MsgCreatePaymentAccount) String() string
func (*MsgCreatePaymentAccount) Type ¶
func (msg *MsgCreatePaymentAccount) Type() string
func (*MsgCreatePaymentAccount) Unmarshal ¶
func (m *MsgCreatePaymentAccount) Unmarshal(dAtA []byte) error
func (*MsgCreatePaymentAccount) ValidateBasic ¶
func (msg *MsgCreatePaymentAccount) ValidateBasic() error
func (*MsgCreatePaymentAccount) XXX_DiscardUnknown ¶
func (m *MsgCreatePaymentAccount) XXX_DiscardUnknown()
func (*MsgCreatePaymentAccount) XXX_Marshal ¶
func (m *MsgCreatePaymentAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreatePaymentAccount) XXX_Merge ¶
func (m *MsgCreatePaymentAccount) XXX_Merge(src proto.Message)
func (*MsgCreatePaymentAccount) XXX_Size ¶
func (m *MsgCreatePaymentAccount) XXX_Size() int
func (*MsgCreatePaymentAccount) XXX_Unmarshal ¶
func (m *MsgCreatePaymentAccount) XXX_Unmarshal(b []byte) error
type MsgCreatePaymentAccountResponse ¶
type MsgCreatePaymentAccountResponse struct { }
func (*MsgCreatePaymentAccountResponse) Descriptor ¶
func (*MsgCreatePaymentAccountResponse) Descriptor() ([]byte, []int)
func (*MsgCreatePaymentAccountResponse) Marshal ¶
func (m *MsgCreatePaymentAccountResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreatePaymentAccountResponse) MarshalTo ¶
func (m *MsgCreatePaymentAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreatePaymentAccountResponse) MarshalToSizedBuffer ¶
func (m *MsgCreatePaymentAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreatePaymentAccountResponse) ProtoMessage ¶
func (*MsgCreatePaymentAccountResponse) ProtoMessage()
func (*MsgCreatePaymentAccountResponse) Reset ¶
func (m *MsgCreatePaymentAccountResponse) Reset()
func (*MsgCreatePaymentAccountResponse) Size ¶
func (m *MsgCreatePaymentAccountResponse) Size() (n int)
func (*MsgCreatePaymentAccountResponse) String ¶
func (m *MsgCreatePaymentAccountResponse) String() string
func (*MsgCreatePaymentAccountResponse) Unmarshal ¶
func (m *MsgCreatePaymentAccountResponse) Unmarshal(dAtA []byte) error
func (*MsgCreatePaymentAccountResponse) XXX_DiscardUnknown ¶
func (m *MsgCreatePaymentAccountResponse) XXX_DiscardUnknown()
func (*MsgCreatePaymentAccountResponse) XXX_Marshal ¶
func (m *MsgCreatePaymentAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreatePaymentAccountResponse) XXX_Merge ¶
func (m *MsgCreatePaymentAccountResponse) XXX_Merge(src proto.Message)
func (*MsgCreatePaymentAccountResponse) XXX_Size ¶
func (m *MsgCreatePaymentAccountResponse) XXX_Size() int
func (*MsgCreatePaymentAccountResponse) XXX_Unmarshal ¶
func (m *MsgCreatePaymentAccountResponse) XXX_Unmarshal(b []byte) error
type MsgDeposit ¶
type MsgDeposit struct { // creator is the message signer for MsgDeposit and the address of the account to deposit from Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` // to is the address of the account to deposit to To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` // amount is the amount to deposit Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"` }
func NewMsgDeposit ¶
func NewMsgDeposit(creator string, to string, amount sdkmath.Int) *MsgDeposit
func (*MsgDeposit) Descriptor ¶
func (*MsgDeposit) Descriptor() ([]byte, []int)
func (*MsgDeposit) GetCreator ¶
func (m *MsgDeposit) GetCreator() string
func (*MsgDeposit) GetSignBytes ¶
func (msg *MsgDeposit) GetSignBytes() []byte
func (*MsgDeposit) GetSigners ¶
func (msg *MsgDeposit) GetSigners() []sdk.AccAddress
func (*MsgDeposit) GetTo ¶
func (m *MsgDeposit) GetTo() string
func (*MsgDeposit) Marshal ¶
func (m *MsgDeposit) Marshal() (dAtA []byte, err error)
func (*MsgDeposit) MarshalToSizedBuffer ¶
func (m *MsgDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeposit) ProtoMessage ¶
func (*MsgDeposit) ProtoMessage()
func (*MsgDeposit) Reset ¶
func (m *MsgDeposit) Reset()
func (*MsgDeposit) Route ¶
func (msg *MsgDeposit) Route() string
func (*MsgDeposit) Size ¶
func (m *MsgDeposit) Size() (n int)
func (*MsgDeposit) String ¶
func (m *MsgDeposit) String() string
func (*MsgDeposit) Type ¶
func (msg *MsgDeposit) Type() string
func (*MsgDeposit) Unmarshal ¶
func (m *MsgDeposit) Unmarshal(dAtA []byte) error
func (*MsgDeposit) ValidateBasic ¶
func (msg *MsgDeposit) ValidateBasic() error
func (*MsgDeposit) XXX_DiscardUnknown ¶
func (m *MsgDeposit) XXX_DiscardUnknown()
func (*MsgDeposit) XXX_Marshal ¶
func (m *MsgDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeposit) XXX_Merge ¶
func (m *MsgDeposit) XXX_Merge(src proto.Message)
func (*MsgDeposit) XXX_Size ¶
func (m *MsgDeposit) XXX_Size() int
func (*MsgDeposit) XXX_Unmarshal ¶
func (m *MsgDeposit) XXX_Unmarshal(b []byte) error
type MsgDepositResponse ¶
type MsgDepositResponse struct { }
func (*MsgDepositResponse) Descriptor ¶
func (*MsgDepositResponse) Descriptor() ([]byte, []int)
func (*MsgDepositResponse) Marshal ¶
func (m *MsgDepositResponse) Marshal() (dAtA []byte, err error)
func (*MsgDepositResponse) MarshalTo ¶
func (m *MsgDepositResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgDepositResponse) MarshalToSizedBuffer ¶
func (m *MsgDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDepositResponse) ProtoMessage ¶
func (*MsgDepositResponse) ProtoMessage()
func (*MsgDepositResponse) Reset ¶
func (m *MsgDepositResponse) Reset()
func (*MsgDepositResponse) Size ¶
func (m *MsgDepositResponse) Size() (n int)
func (*MsgDepositResponse) String ¶
func (m *MsgDepositResponse) String() string
func (*MsgDepositResponse) Unmarshal ¶
func (m *MsgDepositResponse) Unmarshal(dAtA []byte) error
func (*MsgDepositResponse) XXX_DiscardUnknown ¶
func (m *MsgDepositResponse) XXX_DiscardUnknown()
func (*MsgDepositResponse) XXX_Marshal ¶
func (m *MsgDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDepositResponse) XXX_Merge ¶
func (m *MsgDepositResponse) XXX_Merge(src proto.Message)
func (*MsgDepositResponse) XXX_Size ¶
func (m *MsgDepositResponse) XXX_Size() int
func (*MsgDepositResponse) XXX_Unmarshal ¶
func (m *MsgDepositResponse) XXX_Unmarshal(b []byte) error
type MsgDisableRefund ¶
type MsgDisableRefund struct { // owner is the message signer for MsgDisableRefund and the address of the payment account owner Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` // addr is the address of the payment account to disable refund Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` }
func NewMsgDisableRefund ¶
func NewMsgDisableRefund(owner string, addr string) *MsgDisableRefund
func (*MsgDisableRefund) Descriptor ¶
func (*MsgDisableRefund) Descriptor() ([]byte, []int)
func (*MsgDisableRefund) GetAddr ¶
func (m *MsgDisableRefund) GetAddr() string
func (*MsgDisableRefund) GetOwner ¶
func (m *MsgDisableRefund) GetOwner() string
func (*MsgDisableRefund) GetSignBytes ¶
func (msg *MsgDisableRefund) GetSignBytes() []byte
func (*MsgDisableRefund) GetSigners ¶
func (msg *MsgDisableRefund) GetSigners() []sdk.AccAddress
func (*MsgDisableRefund) Marshal ¶
func (m *MsgDisableRefund) Marshal() (dAtA []byte, err error)
func (*MsgDisableRefund) MarshalToSizedBuffer ¶
func (m *MsgDisableRefund) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDisableRefund) ProtoMessage ¶
func (*MsgDisableRefund) ProtoMessage()
func (*MsgDisableRefund) Reset ¶
func (m *MsgDisableRefund) Reset()
func (*MsgDisableRefund) Route ¶
func (msg *MsgDisableRefund) Route() string
func (*MsgDisableRefund) Size ¶
func (m *MsgDisableRefund) Size() (n int)
func (*MsgDisableRefund) String ¶
func (m *MsgDisableRefund) String() string
func (*MsgDisableRefund) Type ¶
func (msg *MsgDisableRefund) Type() string
func (*MsgDisableRefund) Unmarshal ¶
func (m *MsgDisableRefund) Unmarshal(dAtA []byte) error
func (*MsgDisableRefund) ValidateBasic ¶
func (msg *MsgDisableRefund) ValidateBasic() error
func (*MsgDisableRefund) XXX_DiscardUnknown ¶
func (m *MsgDisableRefund) XXX_DiscardUnknown()
func (*MsgDisableRefund) XXX_Marshal ¶
func (m *MsgDisableRefund) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDisableRefund) XXX_Merge ¶
func (m *MsgDisableRefund) XXX_Merge(src proto.Message)
func (*MsgDisableRefund) XXX_Size ¶
func (m *MsgDisableRefund) XXX_Size() int
func (*MsgDisableRefund) XXX_Unmarshal ¶
func (m *MsgDisableRefund) XXX_Unmarshal(b []byte) error
type MsgDisableRefundResponse ¶
type MsgDisableRefundResponse struct { }
func (*MsgDisableRefundResponse) Descriptor ¶
func (*MsgDisableRefundResponse) Descriptor() ([]byte, []int)
func (*MsgDisableRefundResponse) Marshal ¶
func (m *MsgDisableRefundResponse) Marshal() (dAtA []byte, err error)
func (*MsgDisableRefundResponse) MarshalTo ¶
func (m *MsgDisableRefundResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgDisableRefundResponse) MarshalToSizedBuffer ¶
func (m *MsgDisableRefundResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDisableRefundResponse) ProtoMessage ¶
func (*MsgDisableRefundResponse) ProtoMessage()
func (*MsgDisableRefundResponse) Reset ¶
func (m *MsgDisableRefundResponse) Reset()
func (*MsgDisableRefundResponse) Size ¶
func (m *MsgDisableRefundResponse) Size() (n int)
func (*MsgDisableRefundResponse) String ¶
func (m *MsgDisableRefundResponse) String() string
func (*MsgDisableRefundResponse) Unmarshal ¶
func (m *MsgDisableRefundResponse) Unmarshal(dAtA []byte) error
func (*MsgDisableRefundResponse) XXX_DiscardUnknown ¶
func (m *MsgDisableRefundResponse) XXX_DiscardUnknown()
func (*MsgDisableRefundResponse) XXX_Marshal ¶
func (m *MsgDisableRefundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDisableRefundResponse) XXX_Merge ¶
func (m *MsgDisableRefundResponse) XXX_Merge(src proto.Message)
func (*MsgDisableRefundResponse) XXX_Size ¶
func (m *MsgDisableRefundResponse) XXX_Size() int
func (*MsgDisableRefundResponse) XXX_Unmarshal ¶
func (m *MsgDisableRefundResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // UpdateParams defines a governance operation for updating the x/payment module parameters. // The authority is defined in the keeper. // // Since: cosmos-sdk 0.47 UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error) CreatePaymentAccount(context.Context, *MsgCreatePaymentAccount) (*MsgCreatePaymentAccountResponse, error) Deposit(context.Context, *MsgDeposit) (*MsgDepositResponse, error) Withdraw(context.Context, *MsgWithdraw) (*MsgWithdrawResponse, error) DisableRefund(context.Context, *MsgDisableRefund) (*MsgDisableRefundResponse, error) }
MsgServer is the server API for Msg service.
type MsgUpdateParams ¶ added in v0.2.0
type MsgUpdateParams struct { // authority is the address that controls the module (defaults to x/gov unless overwritten). Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"` // params defines the x/payment parameters to update. // NOTE: All parameters must be supplied. Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"` }
MsgUpdateParams is the Msg/UpdateParams request type.
func (*MsgUpdateParams) Descriptor ¶ added in v0.2.0
func (*MsgUpdateParams) Descriptor() ([]byte, []int)
func (*MsgUpdateParams) GetAuthority ¶ added in v0.2.0
func (m *MsgUpdateParams) GetAuthority() string
func (*MsgUpdateParams) GetParams ¶ added in v0.2.0
func (m *MsgUpdateParams) GetParams() Params
func (MsgUpdateParams) GetSignBytes ¶ added in v0.2.0
func (m MsgUpdateParams) GetSignBytes() []byte
GetSignBytes implements the LegacyMsg interface.
func (*MsgUpdateParams) GetSigners ¶ added in v0.2.0
func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress
GetSigners returns the expected signers for a MsgUpdateParams message.
func (*MsgUpdateParams) Marshal ¶ added in v0.2.0
func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)
func (*MsgUpdateParams) MarshalTo ¶ added in v0.2.0
func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateParams) MarshalToSizedBuffer ¶ added in v0.2.0
func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateParams) ProtoMessage ¶ added in v0.2.0
func (*MsgUpdateParams) ProtoMessage()
func (*MsgUpdateParams) Reset ¶ added in v0.2.0
func (m *MsgUpdateParams) Reset()
func (*MsgUpdateParams) Size ¶ added in v0.2.0
func (m *MsgUpdateParams) Size() (n int)
func (*MsgUpdateParams) String ¶ added in v0.2.0
func (m *MsgUpdateParams) String() string
func (*MsgUpdateParams) Unmarshal ¶ added in v0.2.0
func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error
func (*MsgUpdateParams) ValidateBasic ¶ added in v0.2.0
func (m *MsgUpdateParams) ValidateBasic() error
ValidateBasic does a sanity check on the provided data.
func (*MsgUpdateParams) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *MsgUpdateParams) XXX_DiscardUnknown()
func (*MsgUpdateParams) XXX_Marshal ¶ added in v0.2.0
func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateParams) XXX_Merge ¶ added in v0.2.0
func (m *MsgUpdateParams) XXX_Merge(src proto.Message)
func (*MsgUpdateParams) XXX_Size ¶ added in v0.2.0
func (m *MsgUpdateParams) XXX_Size() int
func (*MsgUpdateParams) XXX_Unmarshal ¶ added in v0.2.0
func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error
type MsgUpdateParamsResponse ¶ added in v0.2.0
type MsgUpdateParamsResponse struct { }
MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.
func (*MsgUpdateParamsResponse) Descriptor ¶ added in v0.2.0
func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
func (*MsgUpdateParamsResponse) Marshal ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)
func (*MsgUpdateParamsResponse) MarshalTo ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateParamsResponse) MarshalToSizedBuffer ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateParamsResponse) ProtoMessage ¶ added in v0.2.0
func (*MsgUpdateParamsResponse) ProtoMessage()
func (*MsgUpdateParamsResponse) Reset ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) Reset()
func (*MsgUpdateParamsResponse) Size ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) Size() (n int)
func (*MsgUpdateParamsResponse) String ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) String() string
func (*MsgUpdateParamsResponse) Unmarshal ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error
func (*MsgUpdateParamsResponse) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()
func (*MsgUpdateParamsResponse) XXX_Marshal ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateParamsResponse) XXX_Merge ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)
func (*MsgUpdateParamsResponse) XXX_Size ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) XXX_Size() int
func (*MsgUpdateParamsResponse) XXX_Unmarshal ¶ added in v0.2.0
func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error
type MsgWithdraw ¶
type MsgWithdraw struct { // creator is the message signer for MsgWithdraw and the address of the receive account Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` // from is the address of the account to withdraw from From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` // amount is the amount to withdraw Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"` }
func NewMsgWithdraw ¶
func NewMsgWithdraw(creator string, from string, amount sdkmath.Int) *MsgWithdraw
func (*MsgWithdraw) Descriptor ¶
func (*MsgWithdraw) Descriptor() ([]byte, []int)
func (*MsgWithdraw) GetCreator ¶
func (m *MsgWithdraw) GetCreator() string
func (*MsgWithdraw) GetFrom ¶
func (m *MsgWithdraw) GetFrom() string
func (*MsgWithdraw) GetSignBytes ¶
func (msg *MsgWithdraw) GetSignBytes() []byte
func (*MsgWithdraw) GetSigners ¶
func (msg *MsgWithdraw) GetSigners() []sdk.AccAddress
func (*MsgWithdraw) Marshal ¶
func (m *MsgWithdraw) Marshal() (dAtA []byte, err error)
func (*MsgWithdraw) MarshalToSizedBuffer ¶
func (m *MsgWithdraw) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgWithdraw) ProtoMessage ¶
func (*MsgWithdraw) ProtoMessage()
func (*MsgWithdraw) Reset ¶
func (m *MsgWithdraw) Reset()
func (*MsgWithdraw) Route ¶
func (msg *MsgWithdraw) Route() string
func (*MsgWithdraw) Size ¶
func (m *MsgWithdraw) Size() (n int)
func (*MsgWithdraw) String ¶
func (m *MsgWithdraw) String() string
func (*MsgWithdraw) Type ¶
func (msg *MsgWithdraw) Type() string
func (*MsgWithdraw) Unmarshal ¶
func (m *MsgWithdraw) Unmarshal(dAtA []byte) error
func (*MsgWithdraw) ValidateBasic ¶
func (msg *MsgWithdraw) ValidateBasic() error
func (*MsgWithdraw) XXX_DiscardUnknown ¶
func (m *MsgWithdraw) XXX_DiscardUnknown()
func (*MsgWithdraw) XXX_Marshal ¶
func (m *MsgWithdraw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgWithdraw) XXX_Merge ¶
func (m *MsgWithdraw) XXX_Merge(src proto.Message)
func (*MsgWithdraw) XXX_Size ¶
func (m *MsgWithdraw) XXX_Size() int
func (*MsgWithdraw) XXX_Unmarshal ¶
func (m *MsgWithdraw) XXX_Unmarshal(b []byte) error
type MsgWithdrawResponse ¶
type MsgWithdrawResponse struct { }
func (*MsgWithdrawResponse) Descriptor ¶
func (*MsgWithdrawResponse) Descriptor() ([]byte, []int)
func (*MsgWithdrawResponse) Marshal ¶
func (m *MsgWithdrawResponse) Marshal() (dAtA []byte, err error)
func (*MsgWithdrawResponse) MarshalTo ¶
func (m *MsgWithdrawResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgWithdrawResponse) MarshalToSizedBuffer ¶
func (m *MsgWithdrawResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgWithdrawResponse) ProtoMessage ¶
func (*MsgWithdrawResponse) ProtoMessage()
func (*MsgWithdrawResponse) Reset ¶
func (m *MsgWithdrawResponse) Reset()
func (*MsgWithdrawResponse) Size ¶
func (m *MsgWithdrawResponse) Size() (n int)
func (*MsgWithdrawResponse) String ¶
func (m *MsgWithdrawResponse) String() string
func (*MsgWithdrawResponse) Unmarshal ¶
func (m *MsgWithdrawResponse) Unmarshal(dAtA []byte) error
func (*MsgWithdrawResponse) XXX_DiscardUnknown ¶
func (m *MsgWithdrawResponse) XXX_DiscardUnknown()
func (*MsgWithdrawResponse) XXX_Marshal ¶
func (m *MsgWithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgWithdrawResponse) XXX_Merge ¶
func (m *MsgWithdrawResponse) XXX_Merge(src proto.Message)
func (*MsgWithdrawResponse) XXX_Size ¶
func (m *MsgWithdrawResponse) XXX_Size() int
func (*MsgWithdrawResponse) XXX_Unmarshal ¶
func (m *MsgWithdrawResponse) XXX_Unmarshal(b []byte) error
type OutFlow ¶ added in v0.0.7
type OutFlow struct { // stream account address who receives the flow, usually SP(service provider) ToAddress string `protobuf:"bytes,1,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"` // flow rate Rate github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=rate,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"rate"` // status Status OutFlowStatus `protobuf:"varint,3,opt,name=status,proto3,enum=greenfield.payment.OutFlowStatus" json:"status,omitempty"` }
OutFlow defines the accumulative outflow stream rate in BNB from a stream account to a Storage Provider
func ParseOutFlowKey ¶ added in v0.2.3
func ParseOutFlowKey(key []byte) (addr sdk.AccAddress, res OutFlow)
func (*OutFlow) Descriptor ¶ added in v0.0.7
func (*OutFlow) GetStatus ¶ added in v0.2.3
func (m *OutFlow) GetStatus() OutFlowStatus
func (*OutFlow) GetToAddress ¶ added in v0.0.7
func (*OutFlow) MarshalToSizedBuffer ¶ added in v0.0.7
func (*OutFlow) ProtoMessage ¶ added in v0.0.7
func (*OutFlow) ProtoMessage()
func (*OutFlow) XXX_DiscardUnknown ¶ added in v0.0.7
func (m *OutFlow) XXX_DiscardUnknown()
func (*OutFlow) XXX_Marshal ¶ added in v0.0.7
func (*OutFlow) XXX_Unmarshal ¶ added in v0.0.7
type OutFlowStatus ¶ added in v0.2.3
type OutFlowStatus int32
OutFlowStatus defines the status of a out flow
const ( // OUT_FLOW_STATUS_ACTIVE defines the active status of a out flow. OUT_FLOW_STATUS_ACTIVE OutFlowStatus = 0 // OUT_FLOW_STATUS_FROZEN defines the frozen status of a out flow. OUT_FLOW_STATUS_FROZEN OutFlowStatus = 1 )
func (OutFlowStatus) EnumDescriptor ¶ added in v0.2.3
func (OutFlowStatus) EnumDescriptor() ([]byte, []int)
func (OutFlowStatus) String ¶ added in v0.2.3
func (x OutFlowStatus) String() string
type Params ¶
type Params struct { VersionedParams VersionedParams `protobuf:"bytes,1,opt,name=versioned_params,json=versionedParams,proto3" json:"versioned_params"` // The maximum number of payment accounts that can be created by one user PaymentAccountCountLimit uint64 `` /* 173-byte string literal not displayed */ // Time duration threshold of forced settlement. // If dynamic balance is less than NetOutFlowRate * forcedSettleTime, the account can be forced settled. ForcedSettleTime uint64 `` /* 138-byte string literal not displayed */ // the maximum number of flows that will be auto forced settled in one block MaxAutoSettleFlowCount uint64 `` /* 168-byte string literal not displayed */ // the maximum number of flows that will be auto resumed in one block MaxAutoResumeFlowCount uint64 `` /* 168-byte string literal not displayed */ // The denom of fee charged in payment module FeeDenom string `protobuf:"bytes,6,opt,name=fee_denom,json=feeDenom,proto3" json:"fee_denom,omitempty" yaml:"fee_denom"` }
Params defines the parameters for the module.
func NewParams ¶
func NewParams( reserveTime uint64, validatorTaxRate sdk.Dec, forcedSettleTime uint64, paymentAccountCountLimit uint64, MaxAutoSettleFlowCount uint64, maxAutoResumeFlowCount uint64, feeDenom string, ) Params
NewParams creates a new Params instance
func (*Params) Descriptor ¶
func (*Params) GetFeeDenom ¶
func (*Params) GetForcedSettleTime ¶
func (*Params) GetMaxAutoResumeFlowCount ¶ added in v0.2.3
func (*Params) GetMaxAutoSettleFlowCount ¶ added in v0.2.3
func (*Params) GetPaymentAccountCountLimit ¶
func (*Params) GetVersionedParams ¶ added in v0.2.3
func (m *Params) GetVersionedParams() VersionedParams
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs get the params.ParamSet
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type PaymentAccount ¶
type PaymentAccount struct { // the address of the payment account Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // the owner address of the payment account Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` // whether the payment account is refundable Refundable bool `protobuf:"varint,3,opt,name=refundable,proto3" json:"refundable,omitempty"` }
PaymentAccount defines a payment account
func (*PaymentAccount) Descriptor ¶
func (*PaymentAccount) Descriptor() ([]byte, []int)
func (*PaymentAccount) GetAddr ¶
func (m *PaymentAccount) GetAddr() string
func (*PaymentAccount) GetOwner ¶
func (m *PaymentAccount) GetOwner() string
func (*PaymentAccount) GetRefundable ¶
func (m *PaymentAccount) GetRefundable() bool
func (*PaymentAccount) Marshal ¶
func (m *PaymentAccount) Marshal() (dAtA []byte, err error)
func (*PaymentAccount) MarshalToSizedBuffer ¶
func (m *PaymentAccount) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PaymentAccount) ProtoMessage ¶
func (*PaymentAccount) ProtoMessage()
func (*PaymentAccount) Reset ¶
func (m *PaymentAccount) Reset()
func (*PaymentAccount) Size ¶
func (m *PaymentAccount) Size() (n int)
func (*PaymentAccount) String ¶
func (m *PaymentAccount) String() string
func (*PaymentAccount) Unmarshal ¶
func (m *PaymentAccount) Unmarshal(dAtA []byte) error
func (*PaymentAccount) XXX_DiscardUnknown ¶
func (m *PaymentAccount) XXX_DiscardUnknown()
func (*PaymentAccount) XXX_Marshal ¶
func (m *PaymentAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PaymentAccount) XXX_Merge ¶
func (m *PaymentAccount) XXX_Merge(src proto.Message)
func (*PaymentAccount) XXX_Size ¶
func (m *PaymentAccount) XXX_Size() int
func (*PaymentAccount) XXX_Unmarshal ¶
func (m *PaymentAccount) XXX_Unmarshal(b []byte) error
type PaymentAccountCount ¶
type PaymentAccountCount struct { // owner is the account address Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` // count is the number of payment accounts for the account Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` }
PaymentAccountCount defines the state struct which stores the number of payment accounts for an account
func (*PaymentAccountCount) Descriptor ¶
func (*PaymentAccountCount) Descriptor() ([]byte, []int)
func (*PaymentAccountCount) GetCount ¶
func (m *PaymentAccountCount) GetCount() uint64
func (*PaymentAccountCount) GetOwner ¶
func (m *PaymentAccountCount) GetOwner() string
func (*PaymentAccountCount) Marshal ¶
func (m *PaymentAccountCount) Marshal() (dAtA []byte, err error)
func (*PaymentAccountCount) MarshalTo ¶
func (m *PaymentAccountCount) MarshalTo(dAtA []byte) (int, error)
func (*PaymentAccountCount) MarshalToSizedBuffer ¶
func (m *PaymentAccountCount) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PaymentAccountCount) ProtoMessage ¶
func (*PaymentAccountCount) ProtoMessage()
func (*PaymentAccountCount) Reset ¶
func (m *PaymentAccountCount) Reset()
func (*PaymentAccountCount) Size ¶
func (m *PaymentAccountCount) Size() (n int)
func (*PaymentAccountCount) String ¶
func (m *PaymentAccountCount) String() string
func (*PaymentAccountCount) Unmarshal ¶
func (m *PaymentAccountCount) Unmarshal(dAtA []byte) error
func (*PaymentAccountCount) XXX_DiscardUnknown ¶
func (m *PaymentAccountCount) XXX_DiscardUnknown()
func (*PaymentAccountCount) XXX_Marshal ¶
func (m *PaymentAccountCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PaymentAccountCount) XXX_Merge ¶
func (m *PaymentAccountCount) XXX_Merge(src proto.Message)
func (*PaymentAccountCount) XXX_Size ¶
func (m *PaymentAccountCount) XXX_Size() int
func (*PaymentAccountCount) XXX_Unmarshal ¶
func (m *PaymentAccountCount) XXX_Unmarshal(b []byte) error
type QueryAutoSettleRecordsRequest ¶ added in v0.2.4
type QueryAutoSettleRecordsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryAutoSettleRecordsRequest) Descriptor ¶ added in v0.2.4
func (*QueryAutoSettleRecordsRequest) Descriptor() ([]byte, []int)
func (*QueryAutoSettleRecordsRequest) GetPagination ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) GetPagination() *query.PageRequest
func (*QueryAutoSettleRecordsRequest) Marshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) Marshal() (dAtA []byte, err error)
func (*QueryAutoSettleRecordsRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAutoSettleRecordsRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAutoSettleRecordsRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryAutoSettleRecordsRequest) ProtoMessage()
func (*QueryAutoSettleRecordsRequest) Reset ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) Reset()
func (*QueryAutoSettleRecordsRequest) Size ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) Size() (n int)
func (*QueryAutoSettleRecordsRequest) String ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) String() string
func (*QueryAutoSettleRecordsRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) Unmarshal(dAtA []byte) error
func (*QueryAutoSettleRecordsRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) XXX_DiscardUnknown()
func (*QueryAutoSettleRecordsRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAutoSettleRecordsRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) XXX_Merge(src proto.Message)
func (*QueryAutoSettleRecordsRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) XXX_Size() int
func (*QueryAutoSettleRecordsRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsRequest) XXX_Unmarshal(b []byte) error
type QueryAutoSettleRecordsResponse ¶ added in v0.2.4
type QueryAutoSettleRecordsResponse struct { AutoSettleRecords []AutoSettleRecord `protobuf:"bytes,1,rep,name=auto_settle_records,json=autoSettleRecords,proto3" json:"auto_settle_records"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryAutoSettleRecordsResponse) Descriptor ¶ added in v0.2.4
func (*QueryAutoSettleRecordsResponse) Descriptor() ([]byte, []int)
func (*QueryAutoSettleRecordsResponse) GetAutoSettleRecords ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) GetAutoSettleRecords() []AutoSettleRecord
func (*QueryAutoSettleRecordsResponse) GetPagination ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) GetPagination() *query.PageResponse
func (*QueryAutoSettleRecordsResponse) Marshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) Marshal() (dAtA []byte, err error)
func (*QueryAutoSettleRecordsResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAutoSettleRecordsResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAutoSettleRecordsResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryAutoSettleRecordsResponse) ProtoMessage()
func (*QueryAutoSettleRecordsResponse) Reset ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) Reset()
func (*QueryAutoSettleRecordsResponse) Size ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) Size() (n int)
func (*QueryAutoSettleRecordsResponse) String ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) String() string
func (*QueryAutoSettleRecordsResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) Unmarshal(dAtA []byte) error
func (*QueryAutoSettleRecordsResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) XXX_DiscardUnknown()
func (*QueryAutoSettleRecordsResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAutoSettleRecordsResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) XXX_Merge(src proto.Message)
func (*QueryAutoSettleRecordsResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) XXX_Size() int
func (*QueryAutoSettleRecordsResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryAutoSettleRecordsResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Parameters queries the parameters of the module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) // ParamsByTimestamp queries the parameter of the module by timestamp. ParamsByTimestamp(ctx context.Context, in *QueryParamsByTimestampRequest, opts ...grpc.CallOption) (*QueryParamsByTimestampResponse, error) // Queries our flows by account. OutFlows(ctx context.Context, in *QueryOutFlowsRequest, opts ...grpc.CallOption) (*QueryOutFlowsResponse, error) // Queries a stream record by account. StreamRecord(ctx context.Context, in *QueryGetStreamRecordRequest, opts ...grpc.CallOption) (*QueryGetStreamRecordResponse, error) // Queries all stream records. StreamRecords(ctx context.Context, in *QueryStreamRecordsRequest, opts ...grpc.CallOption) (*QueryStreamRecordsResponse, error) // Queries the count of payment account by owner. PaymentAccountCount(ctx context.Context, in *QueryPaymentAccountCountRequest, opts ...grpc.CallOption) (*QueryPaymentAccountCountResponse, error) // Queries all counts of payment account for all owners. PaymentAccountCounts(ctx context.Context, in *QueryPaymentAccountCountsRequest, opts ...grpc.CallOption) (*QueryPaymentAccountCountsResponse, error) // Queries a payment account by payment account address. PaymentAccount(ctx context.Context, in *QueryPaymentAccountRequest, opts ...grpc.CallOption) (*QueryPaymentAccountResponse, error) // Queries all payment accounts. PaymentAccounts(ctx context.Context, in *QueryPaymentAccountsRequest, opts ...grpc.CallOption) (*QueryPaymentAccountsResponse, error) // Queries dynamic balance of a payment account. DynamicBalance(ctx context.Context, in *QueryDynamicBalanceRequest, opts ...grpc.CallOption) (*QueryDynamicBalanceResponse, error) // Queries all payment accounts by a owner. PaymentAccountsByOwner(ctx context.Context, in *QueryPaymentAccountsByOwnerRequest, opts ...grpc.CallOption) (*QueryPaymentAccountsByOwnerResponse, error) // Queries all auto settle records. AutoSettleRecords(ctx context.Context, in *QueryAutoSettleRecordsRequest, opts ...grpc.CallOption) (*QueryAutoSettleRecordsResponse, 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 QueryDynamicBalanceRequest ¶
type QueryDynamicBalanceRequest struct {
Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
}
func (*QueryDynamicBalanceRequest) Descriptor ¶
func (*QueryDynamicBalanceRequest) Descriptor() ([]byte, []int)
func (*QueryDynamicBalanceRequest) GetAccount ¶
func (m *QueryDynamicBalanceRequest) GetAccount() string
func (*QueryDynamicBalanceRequest) Marshal ¶
func (m *QueryDynamicBalanceRequest) Marshal() (dAtA []byte, err error)
func (*QueryDynamicBalanceRequest) MarshalTo ¶
func (m *QueryDynamicBalanceRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryDynamicBalanceRequest) MarshalToSizedBuffer ¶
func (m *QueryDynamicBalanceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDynamicBalanceRequest) ProtoMessage ¶
func (*QueryDynamicBalanceRequest) ProtoMessage()
func (*QueryDynamicBalanceRequest) Reset ¶
func (m *QueryDynamicBalanceRequest) Reset()
func (*QueryDynamicBalanceRequest) Size ¶
func (m *QueryDynamicBalanceRequest) Size() (n int)
func (*QueryDynamicBalanceRequest) String ¶
func (m *QueryDynamicBalanceRequest) String() string
func (*QueryDynamicBalanceRequest) Unmarshal ¶
func (m *QueryDynamicBalanceRequest) Unmarshal(dAtA []byte) error
func (*QueryDynamicBalanceRequest) XXX_DiscardUnknown ¶
func (m *QueryDynamicBalanceRequest) XXX_DiscardUnknown()
func (*QueryDynamicBalanceRequest) XXX_Marshal ¶
func (m *QueryDynamicBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDynamicBalanceRequest) XXX_Merge ¶
func (m *QueryDynamicBalanceRequest) XXX_Merge(src proto.Message)
func (*QueryDynamicBalanceRequest) XXX_Size ¶
func (m *QueryDynamicBalanceRequest) XXX_Size() int
func (*QueryDynamicBalanceRequest) XXX_Unmarshal ¶
func (m *QueryDynamicBalanceRequest) XXX_Unmarshal(b []byte) error
type QueryDynamicBalanceResponse ¶
type QueryDynamicBalanceResponse struct { // dynamic balance is static balance + flowDelta DynamicBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 143-byte string literal not displayed */ // the stream record of the given account, if it does not exist, it will be default values StreamRecord StreamRecord `protobuf:"bytes,2,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record"` // the timestamp of the current block CurrentTimestamp int64 `protobuf:"varint,3,opt,name=current_timestamp,json=currentTimestamp,proto3" json:"current_timestamp,omitempty"` // bank_balance is the BNB balance of the bank module BankBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ // available_balance is bank balance + static balance AvailableBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 149-byte string literal not displayed */ // locked_fee is buffer balance + locked balance LockedFee github_com_cosmos_cosmos_sdk_types.Int `` /* 128-byte string literal not displayed */ // change_rate is the netflow rate of the given account ChangeRate github_com_cosmos_cosmos_sdk_types.Int `` /* 131-byte string literal not displayed */ }
func (*QueryDynamicBalanceResponse) Descriptor ¶
func (*QueryDynamicBalanceResponse) Descriptor() ([]byte, []int)
func (*QueryDynamicBalanceResponse) GetCurrentTimestamp ¶
func (m *QueryDynamicBalanceResponse) GetCurrentTimestamp() int64
func (*QueryDynamicBalanceResponse) GetStreamRecord ¶
func (m *QueryDynamicBalanceResponse) GetStreamRecord() StreamRecord
func (*QueryDynamicBalanceResponse) Marshal ¶
func (m *QueryDynamicBalanceResponse) Marshal() (dAtA []byte, err error)
func (*QueryDynamicBalanceResponse) MarshalTo ¶
func (m *QueryDynamicBalanceResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDynamicBalanceResponse) MarshalToSizedBuffer ¶
func (m *QueryDynamicBalanceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDynamicBalanceResponse) ProtoMessage ¶
func (*QueryDynamicBalanceResponse) ProtoMessage()
func (*QueryDynamicBalanceResponse) Reset ¶
func (m *QueryDynamicBalanceResponse) Reset()
func (*QueryDynamicBalanceResponse) Size ¶
func (m *QueryDynamicBalanceResponse) Size() (n int)
func (*QueryDynamicBalanceResponse) String ¶
func (m *QueryDynamicBalanceResponse) String() string
func (*QueryDynamicBalanceResponse) Unmarshal ¶
func (m *QueryDynamicBalanceResponse) Unmarshal(dAtA []byte) error
func (*QueryDynamicBalanceResponse) XXX_DiscardUnknown ¶
func (m *QueryDynamicBalanceResponse) XXX_DiscardUnknown()
func (*QueryDynamicBalanceResponse) XXX_Marshal ¶
func (m *QueryDynamicBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDynamicBalanceResponse) XXX_Merge ¶
func (m *QueryDynamicBalanceResponse) XXX_Merge(src proto.Message)
func (*QueryDynamicBalanceResponse) XXX_Size ¶
func (m *QueryDynamicBalanceResponse) XXX_Size() int
func (*QueryDynamicBalanceResponse) XXX_Unmarshal ¶
func (m *QueryDynamicBalanceResponse) XXX_Unmarshal(b []byte) error
type QueryGetStreamRecordRequest ¶
type QueryGetStreamRecordRequest struct {
Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
}
func (*QueryGetStreamRecordRequest) Descriptor ¶
func (*QueryGetStreamRecordRequest) Descriptor() ([]byte, []int)
func (*QueryGetStreamRecordRequest) GetAccount ¶
func (m *QueryGetStreamRecordRequest) GetAccount() string
func (*QueryGetStreamRecordRequest) Marshal ¶
func (m *QueryGetStreamRecordRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetStreamRecordRequest) MarshalTo ¶
func (m *QueryGetStreamRecordRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetStreamRecordRequest) MarshalToSizedBuffer ¶
func (m *QueryGetStreamRecordRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetStreamRecordRequest) ProtoMessage ¶
func (*QueryGetStreamRecordRequest) ProtoMessage()
func (*QueryGetStreamRecordRequest) Reset ¶
func (m *QueryGetStreamRecordRequest) Reset()
func (*QueryGetStreamRecordRequest) Size ¶
func (m *QueryGetStreamRecordRequest) Size() (n int)
func (*QueryGetStreamRecordRequest) String ¶
func (m *QueryGetStreamRecordRequest) String() string
func (*QueryGetStreamRecordRequest) Unmarshal ¶
func (m *QueryGetStreamRecordRequest) Unmarshal(dAtA []byte) error
func (*QueryGetStreamRecordRequest) XXX_DiscardUnknown ¶
func (m *QueryGetStreamRecordRequest) XXX_DiscardUnknown()
func (*QueryGetStreamRecordRequest) XXX_Marshal ¶
func (m *QueryGetStreamRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetStreamRecordRequest) XXX_Merge ¶
func (m *QueryGetStreamRecordRequest) XXX_Merge(src proto.Message)
func (*QueryGetStreamRecordRequest) XXX_Size ¶
func (m *QueryGetStreamRecordRequest) XXX_Size() int
func (*QueryGetStreamRecordRequest) XXX_Unmarshal ¶
func (m *QueryGetStreamRecordRequest) XXX_Unmarshal(b []byte) error
type QueryGetStreamRecordResponse ¶
type QueryGetStreamRecordResponse struct {
StreamRecord StreamRecord `protobuf:"bytes,1,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record"`
}
func (*QueryGetStreamRecordResponse) Descriptor ¶
func (*QueryGetStreamRecordResponse) Descriptor() ([]byte, []int)
func (*QueryGetStreamRecordResponse) GetStreamRecord ¶
func (m *QueryGetStreamRecordResponse) GetStreamRecord() StreamRecord
func (*QueryGetStreamRecordResponse) Marshal ¶
func (m *QueryGetStreamRecordResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetStreamRecordResponse) MarshalTo ¶
func (m *QueryGetStreamRecordResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetStreamRecordResponse) MarshalToSizedBuffer ¶
func (m *QueryGetStreamRecordResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetStreamRecordResponse) ProtoMessage ¶
func (*QueryGetStreamRecordResponse) ProtoMessage()
func (*QueryGetStreamRecordResponse) Reset ¶
func (m *QueryGetStreamRecordResponse) Reset()
func (*QueryGetStreamRecordResponse) Size ¶
func (m *QueryGetStreamRecordResponse) Size() (n int)
func (*QueryGetStreamRecordResponse) String ¶
func (m *QueryGetStreamRecordResponse) String() string
func (*QueryGetStreamRecordResponse) Unmarshal ¶
func (m *QueryGetStreamRecordResponse) Unmarshal(dAtA []byte) error
func (*QueryGetStreamRecordResponse) XXX_DiscardUnknown ¶
func (m *QueryGetStreamRecordResponse) XXX_DiscardUnknown()
func (*QueryGetStreamRecordResponse) XXX_Marshal ¶
func (m *QueryGetStreamRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetStreamRecordResponse) XXX_Merge ¶
func (m *QueryGetStreamRecordResponse) XXX_Merge(src proto.Message)
func (*QueryGetStreamRecordResponse) XXX_Size ¶
func (m *QueryGetStreamRecordResponse) XXX_Size() int
func (*QueryGetStreamRecordResponse) XXX_Unmarshal ¶
func (m *QueryGetStreamRecordResponse) XXX_Unmarshal(b []byte) error
type QueryOutFlowsRequest ¶ added in v0.2.3
type QueryOutFlowsRequest struct {
Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
}
func (*QueryOutFlowsRequest) Descriptor ¶ added in v0.2.3
func (*QueryOutFlowsRequest) Descriptor() ([]byte, []int)
func (*QueryOutFlowsRequest) GetAccount ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) GetAccount() string
func (*QueryOutFlowsRequest) Marshal ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) Marshal() (dAtA []byte, err error)
func (*QueryOutFlowsRequest) MarshalTo ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryOutFlowsRequest) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryOutFlowsRequest) ProtoMessage ¶ added in v0.2.3
func (*QueryOutFlowsRequest) ProtoMessage()
func (*QueryOutFlowsRequest) Reset ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) Reset()
func (*QueryOutFlowsRequest) Size ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) Size() (n int)
func (*QueryOutFlowsRequest) String ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) String() string
func (*QueryOutFlowsRequest) Unmarshal ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) Unmarshal(dAtA []byte) error
func (*QueryOutFlowsRequest) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) XXX_DiscardUnknown()
func (*QueryOutFlowsRequest) XXX_Marshal ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryOutFlowsRequest) XXX_Merge ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) XXX_Merge(src proto.Message)
func (*QueryOutFlowsRequest) XXX_Size ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) XXX_Size() int
func (*QueryOutFlowsRequest) XXX_Unmarshal ¶ added in v0.2.3
func (m *QueryOutFlowsRequest) XXX_Unmarshal(b []byte) error
type QueryOutFlowsResponse ¶ added in v0.2.3
type QueryOutFlowsResponse struct {
OutFlows []OutFlow `protobuf:"bytes,1,rep,name=out_flows,json=outFlows,proto3" json:"out_flows"`
}
func (*QueryOutFlowsResponse) Descriptor ¶ added in v0.2.3
func (*QueryOutFlowsResponse) Descriptor() ([]byte, []int)
func (*QueryOutFlowsResponse) GetOutFlows ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) GetOutFlows() []OutFlow
func (*QueryOutFlowsResponse) Marshal ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) Marshal() (dAtA []byte, err error)
func (*QueryOutFlowsResponse) MarshalTo ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryOutFlowsResponse) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryOutFlowsResponse) ProtoMessage ¶ added in v0.2.3
func (*QueryOutFlowsResponse) ProtoMessage()
func (*QueryOutFlowsResponse) Reset ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) Reset()
func (*QueryOutFlowsResponse) Size ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) Size() (n int)
func (*QueryOutFlowsResponse) String ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) String() string
func (*QueryOutFlowsResponse) Unmarshal ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) Unmarshal(dAtA []byte) error
func (*QueryOutFlowsResponse) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) XXX_DiscardUnknown()
func (*QueryOutFlowsResponse) XXX_Marshal ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryOutFlowsResponse) XXX_Merge ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) XXX_Merge(src proto.Message)
func (*QueryOutFlowsResponse) XXX_Size ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) XXX_Size() int
func (*QueryOutFlowsResponse) XXX_Unmarshal ¶ added in v0.2.3
func (m *QueryOutFlowsResponse) XXX_Unmarshal(b []byte) error
type QueryParamsByTimestampRequest ¶ added in v0.2.3
type QueryParamsByTimestampRequest struct { // the timestamp of the block time you want to query Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` }
QueryParamsByTimestampRequest is request type for the Query/ParamsByTimestamp RPC method with timestamp.
func (*QueryParamsByTimestampRequest) Descriptor ¶ added in v0.2.3
func (*QueryParamsByTimestampRequest) Descriptor() ([]byte, []int)
func (*QueryParamsByTimestampRequest) GetTimestamp ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) GetTimestamp() int64
func (*QueryParamsByTimestampRequest) Marshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsByTimestampRequest) MarshalTo ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsByTimestampRequest) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsByTimestampRequest) ProtoMessage ¶ added in v0.2.3
func (*QueryParamsByTimestampRequest) ProtoMessage()
func (*QueryParamsByTimestampRequest) Reset ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) Reset()
func (*QueryParamsByTimestampRequest) Size ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) Size() (n int)
func (*QueryParamsByTimestampRequest) String ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) String() string
func (*QueryParamsByTimestampRequest) Unmarshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsByTimestampRequest) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) XXX_DiscardUnknown()
func (*QueryParamsByTimestampRequest) XXX_Marshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsByTimestampRequest) XXX_Merge ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) XXX_Merge(src proto.Message)
func (*QueryParamsByTimestampRequest) XXX_Size ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) XXX_Size() int
func (*QueryParamsByTimestampRequest) XXX_Unmarshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampRequest) XXX_Unmarshal(b []byte) error
type QueryParamsByTimestampResponse ¶ added in v0.2.3
type QueryParamsByTimestampResponse struct { // params holds all the parameters of this module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
QueryParamsByTimestampResponse is response type for the Query/ParamsByTimestamp RPC method with timestamp.
func (*QueryParamsByTimestampResponse) Descriptor ¶ added in v0.2.3
func (*QueryParamsByTimestampResponse) Descriptor() ([]byte, []int)
func (*QueryParamsByTimestampResponse) GetParams ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) GetParams() Params
func (*QueryParamsByTimestampResponse) Marshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsByTimestampResponse) MarshalTo ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsByTimestampResponse) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsByTimestampResponse) ProtoMessage ¶ added in v0.2.3
func (*QueryParamsByTimestampResponse) ProtoMessage()
func (*QueryParamsByTimestampResponse) Reset ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) Reset()
func (*QueryParamsByTimestampResponse) Size ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) Size() (n int)
func (*QueryParamsByTimestampResponse) String ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) String() string
func (*QueryParamsByTimestampResponse) Unmarshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsByTimestampResponse) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) XXX_DiscardUnknown()
func (*QueryParamsByTimestampResponse) XXX_Marshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsByTimestampResponse) XXX_Merge ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) XXX_Merge(src proto.Message)
func (*QueryParamsByTimestampResponse) XXX_Size ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) XXX_Size() int
func (*QueryParamsByTimestampResponse) XXX_Unmarshal ¶ added in v0.2.3
func (m *QueryParamsByTimestampResponse) XXX_Unmarshal(b []byte) error
type QueryParamsRequest ¶
type QueryParamsRequest struct { }
QueryParamsRequest is request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor ¶
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
func (*QueryParamsRequest) Marshal ¶
func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsRequest) MarshalTo ¶
func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsRequest) MarshalToSizedBuffer ¶
func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) Reset ¶
func (m *QueryParamsRequest) Reset()
func (*QueryParamsRequest) Size ¶
func (m *QueryParamsRequest) Size() (n int)
func (*QueryParamsRequest) String ¶
func (m *QueryParamsRequest) String() string
func (*QueryParamsRequest) Unmarshal ¶
func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsRequest) XXX_DiscardUnknown ¶
func (m *QueryParamsRequest) XXX_DiscardUnknown()
func (*QueryParamsRequest) XXX_Marshal ¶
func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsRequest) XXX_Merge ¶
func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
func (*QueryParamsRequest) XXX_Size ¶
func (m *QueryParamsRequest) XXX_Size() int
func (*QueryParamsRequest) XXX_Unmarshal ¶
func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
type QueryParamsResponse ¶
type QueryParamsResponse struct { // params holds all the parameters of this module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
QueryParamsResponse is response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor ¶
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
func (*QueryParamsResponse) GetParams ¶
func (m *QueryParamsResponse) GetParams() Params
func (*QueryParamsResponse) Marshal ¶
func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsResponse) MarshalTo ¶
func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsResponse) MarshalToSizedBuffer ¶
func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) Reset ¶
func (m *QueryParamsResponse) Reset()
func (*QueryParamsResponse) Size ¶
func (m *QueryParamsResponse) Size() (n int)
func (*QueryParamsResponse) String ¶
func (m *QueryParamsResponse) String() string
func (*QueryParamsResponse) Unmarshal ¶
func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsResponse) XXX_DiscardUnknown ¶
func (m *QueryParamsResponse) XXX_DiscardUnknown()
func (*QueryParamsResponse) XXX_Marshal ¶
func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsResponse) XXX_Merge ¶
func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
func (*QueryParamsResponse) XXX_Size ¶
func (m *QueryParamsResponse) XXX_Size() int
func (*QueryParamsResponse) XXX_Unmarshal ¶
func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountCountRequest ¶ added in v0.2.4
type QueryPaymentAccountCountRequest struct {
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
}
func (*QueryPaymentAccountCountRequest) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountCountRequest) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountCountRequest) GetOwner ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) GetOwner() string
func (*QueryPaymentAccountCountRequest) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountCountRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountCountRequest) ProtoMessage()
func (*QueryPaymentAccountCountRequest) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) Reset()
func (*QueryPaymentAccountCountRequest) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) Size() (n int)
func (*QueryPaymentAccountCountRequest) String ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) String() string
func (*QueryPaymentAccountCountRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountCountRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) XXX_DiscardUnknown()
func (*QueryPaymentAccountCountRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountCountRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountCountRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) XXX_Size() int
func (*QueryPaymentAccountCountRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountRequest) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountCountResponse ¶ added in v0.2.4
type QueryPaymentAccountCountResponse struct {
PaymentAccountCount PaymentAccountCount `protobuf:"bytes,1,opt,name=payment_account_count,json=paymentAccountCount,proto3" json:"payment_account_count"`
}
func (*QueryPaymentAccountCountResponse) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountCountResponse) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountCountResponse) GetPaymentAccountCount ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) GetPaymentAccountCount() PaymentAccountCount
func (*QueryPaymentAccountCountResponse) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountCountResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountCountResponse) ProtoMessage()
func (*QueryPaymentAccountCountResponse) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) Reset()
func (*QueryPaymentAccountCountResponse) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) Size() (n int)
func (*QueryPaymentAccountCountResponse) String ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) String() string
func (*QueryPaymentAccountCountResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountCountResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) XXX_DiscardUnknown()
func (*QueryPaymentAccountCountResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountCountResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountCountResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) XXX_Size() int
func (*QueryPaymentAccountCountResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountResponse) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountCountsRequest ¶ added in v0.2.4
type QueryPaymentAccountCountsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryPaymentAccountCountsRequest) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountCountsRequest) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountCountsRequest) GetPagination ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) GetPagination() *query.PageRequest
func (*QueryPaymentAccountCountsRequest) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountCountsRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountsRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountsRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountCountsRequest) ProtoMessage()
func (*QueryPaymentAccountCountsRequest) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) Reset()
func (*QueryPaymentAccountCountsRequest) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) Size() (n int)
func (*QueryPaymentAccountCountsRequest) String ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) String() string
func (*QueryPaymentAccountCountsRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountCountsRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) XXX_DiscardUnknown()
func (*QueryPaymentAccountCountsRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountCountsRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountCountsRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) XXX_Size() int
func (*QueryPaymentAccountCountsRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsRequest) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountCountsResponse ¶ added in v0.2.4
type QueryPaymentAccountCountsResponse struct { PaymentAccountCounts []PaymentAccountCount `protobuf:"bytes,1,rep,name=payment_account_counts,json=paymentAccountCounts,proto3" json:"payment_account_counts"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPaymentAccountCountsResponse) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountCountsResponse) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountCountsResponse) GetPagination ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) GetPagination() *query.PageResponse
func (*QueryPaymentAccountCountsResponse) GetPaymentAccountCounts ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) GetPaymentAccountCounts() []PaymentAccountCount
func (*QueryPaymentAccountCountsResponse) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountCountsResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountsResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountCountsResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountCountsResponse) ProtoMessage()
func (*QueryPaymentAccountCountsResponse) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) Reset()
func (*QueryPaymentAccountCountsResponse) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) Size() (n int)
func (*QueryPaymentAccountCountsResponse) String ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) String() string
func (*QueryPaymentAccountCountsResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountCountsResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) XXX_DiscardUnknown()
func (*QueryPaymentAccountCountsResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountCountsResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountCountsResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) XXX_Size() int
func (*QueryPaymentAccountCountsResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountCountsResponse) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountRequest ¶ added in v0.2.4
type QueryPaymentAccountRequest struct {
Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
}
func (*QueryPaymentAccountRequest) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountRequest) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountRequest) GetAddr ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) GetAddr() string
func (*QueryPaymentAccountRequest) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountRequest) ProtoMessage()
func (*QueryPaymentAccountRequest) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) Reset()
func (*QueryPaymentAccountRequest) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) Size() (n int)
func (*QueryPaymentAccountRequest) String ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) String() string
func (*QueryPaymentAccountRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) XXX_DiscardUnknown()
func (*QueryPaymentAccountRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) XXX_Size() int
func (*QueryPaymentAccountRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountRequest) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountResponse ¶ added in v0.2.4
type QueryPaymentAccountResponse struct {
PaymentAccount PaymentAccount `protobuf:"bytes,1,opt,name=payment_account,json=paymentAccount,proto3" json:"payment_account"`
}
func (*QueryPaymentAccountResponse) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountResponse) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountResponse) GetPaymentAccount ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) GetPaymentAccount() PaymentAccount
func (*QueryPaymentAccountResponse) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountResponse) ProtoMessage()
func (*QueryPaymentAccountResponse) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) Reset()
func (*QueryPaymentAccountResponse) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) Size() (n int)
func (*QueryPaymentAccountResponse) String ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) String() string
func (*QueryPaymentAccountResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) XXX_DiscardUnknown()
func (*QueryPaymentAccountResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) XXX_Size() int
func (*QueryPaymentAccountResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountResponse) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountsByOwnerRequest ¶ added in v0.2.4
type QueryPaymentAccountsByOwnerRequest struct {
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
}
func (*QueryPaymentAccountsByOwnerRequest) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountsByOwnerRequest) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountsByOwnerRequest) GetOwner ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) GetOwner() string
func (*QueryPaymentAccountsByOwnerRequest) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountsByOwnerRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountsByOwnerRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountsByOwnerRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountsByOwnerRequest) ProtoMessage()
func (*QueryPaymentAccountsByOwnerRequest) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) Reset()
func (*QueryPaymentAccountsByOwnerRequest) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) Size() (n int)
func (*QueryPaymentAccountsByOwnerRequest) String ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) String() string
func (*QueryPaymentAccountsByOwnerRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountsByOwnerRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) XXX_DiscardUnknown()
func (*QueryPaymentAccountsByOwnerRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountsByOwnerRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountsByOwnerRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) XXX_Size() int
func (*QueryPaymentAccountsByOwnerRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerRequest) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountsByOwnerResponse ¶ added in v0.2.4
type QueryPaymentAccountsByOwnerResponse struct {
PaymentAccounts []string `protobuf:"bytes,1,rep,name=paymentAccounts,proto3" json:"paymentAccounts,omitempty"`
}
func (*QueryPaymentAccountsByOwnerResponse) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountsByOwnerResponse) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountsByOwnerResponse) GetPaymentAccounts ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) GetPaymentAccounts() []string
func (*QueryPaymentAccountsByOwnerResponse) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountsByOwnerResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountsByOwnerResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountsByOwnerResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountsByOwnerResponse) ProtoMessage()
func (*QueryPaymentAccountsByOwnerResponse) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) Reset()
func (*QueryPaymentAccountsByOwnerResponse) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) Size() (n int)
func (*QueryPaymentAccountsByOwnerResponse) String ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) String() string
func (*QueryPaymentAccountsByOwnerResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountsByOwnerResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) XXX_DiscardUnknown()
func (*QueryPaymentAccountsByOwnerResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountsByOwnerResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountsByOwnerResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) XXX_Size() int
func (*QueryPaymentAccountsByOwnerResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsByOwnerResponse) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountsRequest ¶ added in v0.2.4
type QueryPaymentAccountsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryPaymentAccountsRequest) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountsRequest) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountsRequest) GetPagination ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) GetPagination() *query.PageRequest
func (*QueryPaymentAccountsRequest) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountsRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountsRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountsRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountsRequest) ProtoMessage()
func (*QueryPaymentAccountsRequest) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) Reset()
func (*QueryPaymentAccountsRequest) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) Size() (n int)
func (*QueryPaymentAccountsRequest) String ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) String() string
func (*QueryPaymentAccountsRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountsRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) XXX_DiscardUnknown()
func (*QueryPaymentAccountsRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountsRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountsRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) XXX_Size() int
func (*QueryPaymentAccountsRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsRequest) XXX_Unmarshal(b []byte) error
type QueryPaymentAccountsResponse ¶ added in v0.2.4
type QueryPaymentAccountsResponse struct { PaymentAccounts []PaymentAccount `protobuf:"bytes,1,rep,name=payment_accounts,json=paymentAccounts,proto3" json:"payment_accounts"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPaymentAccountsResponse) Descriptor ¶ added in v0.2.4
func (*QueryPaymentAccountsResponse) Descriptor() ([]byte, []int)
func (*QueryPaymentAccountsResponse) GetPagination ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) GetPagination() *query.PageResponse
func (*QueryPaymentAccountsResponse) GetPaymentAccounts ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) GetPaymentAccounts() []PaymentAccount
func (*QueryPaymentAccountsResponse) Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) Marshal() (dAtA []byte, err error)
func (*QueryPaymentAccountsResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPaymentAccountsResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPaymentAccountsResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryPaymentAccountsResponse) ProtoMessage()
func (*QueryPaymentAccountsResponse) Reset ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) Reset()
func (*QueryPaymentAccountsResponse) Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) Size() (n int)
func (*QueryPaymentAccountsResponse) String ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) String() string
func (*QueryPaymentAccountsResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) Unmarshal(dAtA []byte) error
func (*QueryPaymentAccountsResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) XXX_DiscardUnknown()
func (*QueryPaymentAccountsResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPaymentAccountsResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) XXX_Merge(src proto.Message)
func (*QueryPaymentAccountsResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) XXX_Size() int
func (*QueryPaymentAccountsResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryPaymentAccountsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Parameters queries the parameters of the module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) // ParamsByTimestamp queries the parameter of the module by timestamp. ParamsByTimestamp(context.Context, *QueryParamsByTimestampRequest) (*QueryParamsByTimestampResponse, error) // Queries our flows by account. OutFlows(context.Context, *QueryOutFlowsRequest) (*QueryOutFlowsResponse, error) // Queries a stream record by account. StreamRecord(context.Context, *QueryGetStreamRecordRequest) (*QueryGetStreamRecordResponse, error) // Queries all stream records. StreamRecords(context.Context, *QueryStreamRecordsRequest) (*QueryStreamRecordsResponse, error) // Queries the count of payment account by owner. PaymentAccountCount(context.Context, *QueryPaymentAccountCountRequest) (*QueryPaymentAccountCountResponse, error) // Queries all counts of payment account for all owners. PaymentAccountCounts(context.Context, *QueryPaymentAccountCountsRequest) (*QueryPaymentAccountCountsResponse, error) // Queries a payment account by payment account address. PaymentAccount(context.Context, *QueryPaymentAccountRequest) (*QueryPaymentAccountResponse, error) // Queries all payment accounts. PaymentAccounts(context.Context, *QueryPaymentAccountsRequest) (*QueryPaymentAccountsResponse, error) // Queries dynamic balance of a payment account. DynamicBalance(context.Context, *QueryDynamicBalanceRequest) (*QueryDynamicBalanceResponse, error) // Queries all payment accounts by a owner. PaymentAccountsByOwner(context.Context, *QueryPaymentAccountsByOwnerRequest) (*QueryPaymentAccountsByOwnerResponse, error) // Queries all auto settle records. AutoSettleRecords(context.Context, *QueryAutoSettleRecordsRequest) (*QueryAutoSettleRecordsResponse, error) }
QueryServer is the server API for Query service.
type QueryStreamRecordsRequest ¶ added in v0.2.4
type QueryStreamRecordsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryStreamRecordsRequest) Descriptor ¶ added in v0.2.4
func (*QueryStreamRecordsRequest) Descriptor() ([]byte, []int)
func (*QueryStreamRecordsRequest) GetPagination ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) GetPagination() *query.PageRequest
func (*QueryStreamRecordsRequest) Marshal ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) Marshal() (dAtA []byte, err error)
func (*QueryStreamRecordsRequest) MarshalTo ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamRecordsRequest) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamRecordsRequest) ProtoMessage ¶ added in v0.2.4
func (*QueryStreamRecordsRequest) ProtoMessage()
func (*QueryStreamRecordsRequest) Reset ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) Reset()
func (*QueryStreamRecordsRequest) Size ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) Size() (n int)
func (*QueryStreamRecordsRequest) String ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) String() string
func (*QueryStreamRecordsRequest) Unmarshal ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) Unmarshal(dAtA []byte) error
func (*QueryStreamRecordsRequest) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) XXX_DiscardUnknown()
func (*QueryStreamRecordsRequest) XXX_Marshal ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamRecordsRequest) XXX_Merge ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) XXX_Merge(src proto.Message)
func (*QueryStreamRecordsRequest) XXX_Size ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) XXX_Size() int
func (*QueryStreamRecordsRequest) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryStreamRecordsRequest) XXX_Unmarshal(b []byte) error
type QueryStreamRecordsResponse ¶ added in v0.2.4
type QueryStreamRecordsResponse struct { StreamRecords []StreamRecord `protobuf:"bytes,1,rep,name=stream_records,json=streamRecords,proto3" json:"stream_records"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryStreamRecordsResponse) Descriptor ¶ added in v0.2.4
func (*QueryStreamRecordsResponse) Descriptor() ([]byte, []int)
func (*QueryStreamRecordsResponse) GetPagination ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) GetPagination() *query.PageResponse
func (*QueryStreamRecordsResponse) GetStreamRecords ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) GetStreamRecords() []StreamRecord
func (*QueryStreamRecordsResponse) Marshal ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) Marshal() (dAtA []byte, err error)
func (*QueryStreamRecordsResponse) MarshalTo ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamRecordsResponse) MarshalToSizedBuffer ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamRecordsResponse) ProtoMessage ¶ added in v0.2.4
func (*QueryStreamRecordsResponse) ProtoMessage()
func (*QueryStreamRecordsResponse) Reset ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) Reset()
func (*QueryStreamRecordsResponse) Size ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) Size() (n int)
func (*QueryStreamRecordsResponse) String ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) String() string
func (*QueryStreamRecordsResponse) Unmarshal ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) Unmarshal(dAtA []byte) error
func (*QueryStreamRecordsResponse) XXX_DiscardUnknown ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) XXX_DiscardUnknown()
func (*QueryStreamRecordsResponse) XXX_Marshal ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamRecordsResponse) XXX_Merge ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) XXX_Merge(src proto.Message)
func (*QueryStreamRecordsResponse) XXX_Size ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) XXX_Size() int
func (*QueryStreamRecordsResponse) XXX_Unmarshal ¶ added in v0.2.4
func (m *QueryStreamRecordsResponse) XXX_Unmarshal(b []byte) error
type SpKeeper ¶ added in v0.0.7
type SpKeeper interface { GetSpStoragePriceByTime(ctx sdk.Context, spId uint32, time int64) (val sptypes.SpStoragePrice, err error) GetSecondarySpStorePriceByTime(ctx sdk.Context, time int64) (val sptypes.SecondarySpStorePrice, err error) }
SpKeeper defines the expected interface needed to retrieve storage provider.
type StoragePrice ¶ added in v0.0.7
type StoragePriceParams ¶ added in v0.0.7
type StreamAccountStatus ¶ added in v0.0.7
type StreamAccountStatus int32
StreamAccountStatus defines the status of a stream account
const ( // STREAM_ACCOUNT_STATUS_ACTIVE defines the active status of a stream account. STREAM_ACCOUNT_STATUS_ACTIVE StreamAccountStatus = 0 // STREAM_ACCOUNT_STATUS_FROZEN defines the frozen status of a stream account. // A frozen stream account cannot be used as payment address for buckets. // It can be unfrozen by depositing more BNB to the stream account. STREAM_ACCOUNT_STATUS_FROZEN StreamAccountStatus = 1 )
func (StreamAccountStatus) EnumDescriptor ¶ added in v0.0.7
func (StreamAccountStatus) EnumDescriptor() ([]byte, []int)
func (StreamAccountStatus) String ¶ added in v0.0.7
func (x StreamAccountStatus) String() string
type StreamRecord ¶
type StreamRecord struct { // account address Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"` // latest update timestamp of the stream record CrudTimestamp int64 `protobuf:"varint,2,opt,name=crud_timestamp,json=crudTimestamp,proto3" json:"crud_timestamp,omitempty"` // The per-second rate that an account's balance is changing. // It is the sum of the account's inbound and outbound flow rates. NetflowRate github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ // The balance of the stream account at the latest CRUD timestamp. StaticBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */ // reserved balance of the stream account // If the netflow rate is negative, the reserved balance is `netflow_rate * reserve_time` BufferBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */ // the locked balance of the stream account after it puts a new object and before the object is sealed LockBalance github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */ // the status of the stream account Status StreamAccountStatus `protobuf:"varint,7,opt,name=status,proto3,enum=greenfield.payment.StreamAccountStatus" json:"status,omitempty"` // the unix timestamp when the stream account will be settled SettleTimestamp int64 `protobuf:"varint,8,opt,name=settle_timestamp,json=settleTimestamp,proto3" json:"settle_timestamp,omitempty"` // the count of its out flows OutFlowCount uint64 `protobuf:"varint,9,opt,name=out_flow_count,json=outFlowCount,proto3" json:"out_flow_count,omitempty"` // the frozen netflow rate, which is used when resuming stream account FrozenNetflowRate github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */ }
Stream Payment Record of a stream account
func NewStreamRecord ¶
func NewStreamRecord(account sdk.AccAddress, crudTimestamp int64) *StreamRecord
func (*StreamRecord) Descriptor ¶
func (*StreamRecord) Descriptor() ([]byte, []int)
func (*StreamRecord) GetAccount ¶
func (m *StreamRecord) GetAccount() string
func (*StreamRecord) GetCrudTimestamp ¶
func (m *StreamRecord) GetCrudTimestamp() int64
func (*StreamRecord) GetOutFlowCount ¶ added in v0.2.3
func (m *StreamRecord) GetOutFlowCount() uint64
func (*StreamRecord) GetSettleTimestamp ¶
func (m *StreamRecord) GetSettleTimestamp() int64
func (*StreamRecord) GetStatus ¶
func (m *StreamRecord) GetStatus() StreamAccountStatus
func (*StreamRecord) Marshal ¶
func (m *StreamRecord) Marshal() (dAtA []byte, err error)
func (*StreamRecord) MarshalToSizedBuffer ¶
func (m *StreamRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamRecord) ProtoMessage ¶
func (*StreamRecord) ProtoMessage()
func (*StreamRecord) Reset ¶
func (m *StreamRecord) Reset()
func (*StreamRecord) Size ¶
func (m *StreamRecord) Size() (n int)
func (*StreamRecord) String ¶
func (m *StreamRecord) String() string
func (*StreamRecord) Unmarshal ¶
func (m *StreamRecord) Unmarshal(dAtA []byte) error
func (*StreamRecord) XXX_DiscardUnknown ¶
func (m *StreamRecord) XXX_DiscardUnknown()
func (*StreamRecord) XXX_Marshal ¶
func (m *StreamRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamRecord) XXX_Merge ¶
func (m *StreamRecord) XXX_Merge(src proto.Message)
func (*StreamRecord) XXX_Size ¶
func (m *StreamRecord) XXX_Size() int
func (*StreamRecord) XXX_Unmarshal ¶
func (m *StreamRecord) XXX_Unmarshal(b []byte) error
type StreamRecordChange ¶
type StreamRecordChange struct { Addr sdk.AccAddress RateChange sdkmath.Int StaticBalanceChange sdkmath.Int LockBalanceChange sdkmath.Int FrozenRateChange sdkmath.Int }
func NewDefaultStreamRecordChangeWithAddr ¶
func NewDefaultStreamRecordChangeWithAddr(addr sdk.AccAddress) *StreamRecordChange
func (*StreamRecordChange) WithFrozenRateChange ¶ added in v0.2.3
func (change *StreamRecordChange) WithFrozenRateChange(frozenRateChange sdkmath.Int) *StreamRecordChange
func (*StreamRecordChange) WithLockBalanceChange ¶
func (change *StreamRecordChange) WithLockBalanceChange(lockBalanceChange sdkmath.Int) *StreamRecordChange
func (*StreamRecordChange) WithRateChange ¶
func (change *StreamRecordChange) WithRateChange(rateChange sdkmath.Int) *StreamRecordChange
func (*StreamRecordChange) WithStaticBalanceChange ¶
func (change *StreamRecordChange) WithStaticBalanceChange(staticBalanceChange sdkmath.Int) *StreamRecordChange
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) CreatePaymentAccount ¶
func (*UnimplementedMsgServer) CreatePaymentAccount(ctx context.Context, req *MsgCreatePaymentAccount) (*MsgCreatePaymentAccountResponse, error)
func (*UnimplementedMsgServer) Deposit ¶
func (*UnimplementedMsgServer) Deposit(ctx context.Context, req *MsgDeposit) (*MsgDepositResponse, error)
func (*UnimplementedMsgServer) DisableRefund ¶
func (*UnimplementedMsgServer) DisableRefund(ctx context.Context, req *MsgDisableRefund) (*MsgDisableRefundResponse, error)
func (*UnimplementedMsgServer) UpdateParams ¶ added in v0.2.0
func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
func (*UnimplementedMsgServer) Withdraw ¶
func (*UnimplementedMsgServer) Withdraw(ctx context.Context, req *MsgWithdraw) (*MsgWithdrawResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) AutoSettleRecords ¶ added in v0.2.4
func (*UnimplementedQueryServer) AutoSettleRecords(ctx context.Context, req *QueryAutoSettleRecordsRequest) (*QueryAutoSettleRecordsResponse, error)
func (*UnimplementedQueryServer) DynamicBalance ¶
func (*UnimplementedQueryServer) DynamicBalance(ctx context.Context, req *QueryDynamicBalanceRequest) (*QueryDynamicBalanceResponse, error)
func (*UnimplementedQueryServer) OutFlows ¶ added in v0.2.3
func (*UnimplementedQueryServer) OutFlows(ctx context.Context, req *QueryOutFlowsRequest) (*QueryOutFlowsResponse, error)
func (*UnimplementedQueryServer) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
func (*UnimplementedQueryServer) ParamsByTimestamp ¶ added in v0.2.3
func (*UnimplementedQueryServer) ParamsByTimestamp(ctx context.Context, req *QueryParamsByTimestampRequest) (*QueryParamsByTimestampResponse, error)
func (*UnimplementedQueryServer) PaymentAccount ¶
func (*UnimplementedQueryServer) PaymentAccount(ctx context.Context, req *QueryPaymentAccountRequest) (*QueryPaymentAccountResponse, error)
func (*UnimplementedQueryServer) PaymentAccountCount ¶
func (*UnimplementedQueryServer) PaymentAccountCount(ctx context.Context, req *QueryPaymentAccountCountRequest) (*QueryPaymentAccountCountResponse, error)
func (*UnimplementedQueryServer) PaymentAccountCounts ¶ added in v0.2.4
func (*UnimplementedQueryServer) PaymentAccountCounts(ctx context.Context, req *QueryPaymentAccountCountsRequest) (*QueryPaymentAccountCountsResponse, error)
func (*UnimplementedQueryServer) PaymentAccounts ¶ added in v0.2.4
func (*UnimplementedQueryServer) PaymentAccounts(ctx context.Context, req *QueryPaymentAccountsRequest) (*QueryPaymentAccountsResponse, error)
func (*UnimplementedQueryServer) PaymentAccountsByOwner ¶ added in v0.2.4
func (*UnimplementedQueryServer) PaymentAccountsByOwner(ctx context.Context, req *QueryPaymentAccountsByOwnerRequest) (*QueryPaymentAccountsByOwnerResponse, error)
func (*UnimplementedQueryServer) StreamRecord ¶
func (*UnimplementedQueryServer) StreamRecord(ctx context.Context, req *QueryGetStreamRecordRequest) (*QueryGetStreamRecordResponse, error)
func (*UnimplementedQueryServer) StreamRecords ¶ added in v0.2.4
func (*UnimplementedQueryServer) StreamRecords(ctx context.Context, req *QueryStreamRecordsRequest) (*QueryStreamRecordsResponse, error)
type UserFlows ¶ added in v0.0.7
type UserFlows struct { From sdk.AccAddress Flows []OutFlow }
type VersionedParams ¶ added in v0.2.3
type VersionedParams struct { // Time duration which the buffer balance need to be reserved for NetOutFlow e.g. 6 month ReserveTime uint64 `protobuf:"varint,1,opt,name=reserve_time,json=reserveTime,proto3" json:"reserve_time,omitempty" yaml:"reserve_time"` // The tax rate to pay for validators in storage payment. The default value is 1%(0.01) ValidatorTaxRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 151-byte string literal not displayed */ }
VersionedParams defines the parameters with multiple versions, each version is stored with different timestamp.
func (*VersionedParams) Descriptor ¶ added in v0.2.3
func (*VersionedParams) Descriptor() ([]byte, []int)
func (*VersionedParams) GetReserveTime ¶ added in v0.2.3
func (m *VersionedParams) GetReserveTime() uint64
func (*VersionedParams) Marshal ¶ added in v0.2.3
func (m *VersionedParams) Marshal() (dAtA []byte, err error)
func (*VersionedParams) MarshalTo ¶ added in v0.2.3
func (m *VersionedParams) MarshalTo(dAtA []byte) (int, error)
func (*VersionedParams) MarshalToSizedBuffer ¶ added in v0.2.3
func (m *VersionedParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VersionedParams) ProtoMessage ¶ added in v0.2.3
func (*VersionedParams) ProtoMessage()
func (*VersionedParams) Reset ¶ added in v0.2.3
func (m *VersionedParams) Reset()
func (*VersionedParams) Size ¶ added in v0.2.3
func (m *VersionedParams) Size() (n int)
func (*VersionedParams) String ¶ added in v0.2.3
func (m *VersionedParams) String() string
func (*VersionedParams) Unmarshal ¶ added in v0.2.3
func (m *VersionedParams) Unmarshal(dAtA []byte) error
func (*VersionedParams) XXX_DiscardUnknown ¶ added in v0.2.3
func (m *VersionedParams) XXX_DiscardUnknown()
func (*VersionedParams) XXX_Marshal ¶ added in v0.2.3
func (m *VersionedParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionedParams) XXX_Merge ¶ added in v0.2.3
func (m *VersionedParams) XXX_Merge(src proto.Message)
func (*VersionedParams) XXX_Size ¶ added in v0.2.3
func (m *VersionedParams) XXX_Size() int
func (*VersionedParams) XXX_Unmarshal ¶ added in v0.2.3
func (m *VersionedParams) XXX_Unmarshal(b []byte) error
Source Files ¶
- auto_resume_record.pb.go
- auto_settle_record.pb.go
- codec.go
- errors.go
- events.pb.go
- expected_keepers.go
- expected_keepers_mocks.go
- genesis.go
- genesis.pb.go
- keys.go
- message_create_payment_account.go
- message_deposit.go
- message_disable_refund.go
- message_update_params.go
- message_withdraw.go
- out_flow.pb.go
- params.go
- params.pb.go
- payment_account.pb.go
- payment_account_count.pb.go
- price.go
- query.pb.go
- query.pb.gw.go
- stream_record.go
- stream_record.pb.go
- tx.pb.go
- types.go