types

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 1, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	CodeInvalidGenesis = 101

	CodeStreamDoesNotExist  = 201
	CodeStreamAlreadyExists = 202
	CodeMissingData         = 203
	CodeContentTooLarge     = 204
	CodeInvalidData         = 205
	CodeNotCancellable      = 206

	CodeInsufficientDeposit = 301
)
View Source 
const (
	EventTypeCreateStreamAction = "create_stream"
	EventTypeDepositToStream    = "stream_deposit"
	EventTypeClaimStreamAction  = "claim_stream"
	EventTypeUpdateFlowRate     = "update_flow_rate"
	EventTypeStreamCancelled    = "cancel_stream"

	AttributeKeyStreamSender        = "sender"
	AttributeKeyStreamReceiver      = "receiver"
	AttributeKeyFlowRate            = "flow_rate"
	AttributeKeyAmountDeposited     = "amount_deposited"
	AttributeKeyDepositDuration     = "deposit_duration"
	AttributeKeyDepositZeroTime     = "deposit_zero_time"
	AttributeKeyClaimAmountReceived = "amount_received"
	AttributeKeyClaimValidatorFee   = "validator_fee"
	AttributeKeyClaimTotal          = "claim_total"
	AttributeKeyOldFlowRate         = "old_flow_rate"
	AttributeKeyNewFlowRate         = "new_flow_rate"
	AttributeKeyRemainingDeposit    = "remaining_deposit"
	AttributeKeyRefundAmount        = "refund_amount"
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "stream"

	// 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_stream"
)
View Source 
const (
	CreateStreamAction   = "create_stream"
	ClaimStreamAction    = "claim_stream"
	TopUpDepositAction   = "top_up_deposit"
	UpdateFlowRateAction = "update_flow_rate"
	CancelStreamAction   = "cancel_stream"
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default global index

Variables

View Source 
var (
	ErrStreamDoesNotExist   = sdkerrors.Register(ModuleName, CodeStreamDoesNotExist, "stream does not exist")
	ErrStreamExists         = sdkerrors.Register(ModuleName, CodeStreamAlreadyExists, "stream exists")
	ErrInvalidData          = sdkerrors.Register(ModuleName, CodeInvalidData, "invalid data")
	ErrMissingData          = sdkerrors.Register(ModuleName, CodeMissingData, "missing data")
	ErrContentTooLarge      = sdkerrors.Register(ModuleName, CodeContentTooLarge, "msg content too large")
	ErrStreamNotCancellable = sdkerrors.Register(ModuleName, CodeNotCancellable, "stream not cancellable")

	ErrInsufficientDeposit = sdkerrors.Register(ModuleName, CodeInsufficientDeposit, "insufficient deposit")
)

x/stream module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ParamsKey is the prefix for the params store
	ParamsKey = []byte{0x01}

	// StreamKeyPrefix prefix for the Stream store
	StreamKeyPrefix = []byte{0x11}
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStream        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStream          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStream = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DefaultValidatorFee = sdk.NewDecWithPrec(1, 2)

DefaultValidatorFee is set to 0%

View Source 
var (
	KeyValidatorFee = []byte("KeyValidatorFee")
)
View Source 
var (

	// ModuleCdc references the global x/bank module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/staking and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var StreamPeriod_name = map[int32]string{
	0: "STREAM_PERIOD_UNSPECIFIED",
	1: "STREAM_PERIOD_SECOND",
	2: "STREAM_PERIOD_MINUTE",
	3: "STREAM_PERIOD_HOUR",
	4: "STREAM_PERIOD_DAY",
	5: "STREAM_PERIOD_WEEK",
	6: "STREAM_PERIOD_MONTH",
	7: "STREAM_PERIOD_YEAR",
}
View Source 
var StreamPeriod_value = map[string]int32{
	"STREAM_PERIOD_UNSPECIFIED": 0,
	"STREAM_PERIOD_SECOND":      1,
	"STREAM_PERIOD_MINUTE":      2,
	"STREAM_PERIOD_HOUR":        3,
	"STREAM_PERIOD_DAY":         4,
	"STREAM_PERIOD_WEEK":        5,
	"STREAM_PERIOD_MONTH":       6,
	"STREAM_PERIOD_YEAR":        7,
}

Functions

func AddressesFromStreamKey 

func AddressesFromStreamKey(key []byte) (sdk.AccAddress, sdk.AccAddress)

AddressesFromStreamKey returns a receiver and sender address from a stream prefix store key.

func CalculateAmountToClaim 

func CalculateAmountToClaim(
	nowTime,
	depositZeroTime,
	lastOutflowTime time.Time,
	deposit sdk.Coin,
	flowRate int64,
) (sdk.Coin, sdk.Coin)

func CalculateDuration 

func CalculateDuration(deposit sdk.Coin, flowRate int64) int64

func CalculateFlowRateForCoin 

func CalculateFlowRateForCoin(coin sdk.Coin, period StreamPeriod, duration uint64) (uint64, sdk.Dec, int64)

func CalculateValidatorFee 

func CalculateValidatorFee(valFee sdk.Dec, amountToClaim sdk.Coin) (sdk.Coin, sdk.Coin)

func FirstAddressFromStreamStoreKey 

func FirstAddressFromStreamStoreKey(key []byte) sdk.AccAddress

FirstAddressFromStreamStoreKey parses the first address only

func GetStreamKey 

func GetStreamKey(receiverAddr sdk.AccAddress, senderAddr sdk.AccAddress) []byte

GetStreamKey creates the key for receiver bond with sender

func GetStreamsByReceiverKey 

func GetStreamsByReceiverKey(receiverAddr sdk.AccAddress) []byte

GetStreamsByReceiverKey creates the prefix for a delegator for all validators

func KeyPrefix 

func KeyPrefix(p string) []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module Deprecated: Type declaration for parameters

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI
	GetModuleAddress(module string) sdk.AccAddress
	SetModuleAccount(sdk.Context, authtypes.ModuleAccountI)
}

AccountKeeper Methods imported from account should be defined here

type BankKeeper 

type BankKeeper interface {
	BlockedAddr(recipient sdk.AccAddress) bool
	GetBlockedAddresses() map[string]bool
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoin(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoins(ctx sdk.Context, from sdk.AccAddress, to sdk.AccAddress, amount sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, fromModule string, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, fromAddr sdk.AccAddress, toModule string, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
}

BankKeeper Methods imported from bank should be defined here

type GenesisState 

type GenesisState struct {
	Params  Params         `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	Streams []StreamExport `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams"`
}

GenesisState defines the stream module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func NewGenesisState 

func NewGenesisState(streams []StreamExport, params Params) *GenesisState

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetStreams 

func (m *GenesisState) GetStreams() []StreamExport

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, 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 MsgCancelStream 

type MsgCancelStream struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the wallet cancelling
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgCancelStream

func NewMsgCancelStream 

func NewMsgCancelStream(
	reciever,
	sender sdk.AccAddress) *MsgCancelStream

NewMsgCancelStream is a constructor function for MsgCancelStream

func (*MsgCancelStream) Descriptor 

func (*MsgCancelStream) Descriptor() ([]byte, []int)

func (MsgCancelStream) GetSignBytes 

func (msg MsgCancelStream) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgCancelStream) GetSigners 

func (msg MsgCancelStream) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCancelStream) Marshal 

func (m *MsgCancelStream) Marshal() (dAtA []byte, err error)

func (*MsgCancelStream) MarshalTo 

func (m *MsgCancelStream) MarshalTo(dAtA []byte) (int, error)

func (*MsgCancelStream) MarshalToSizedBuffer 

func (m *MsgCancelStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCancelStream) ProtoMessage 

func (*MsgCancelStream) ProtoMessage()

func (*MsgCancelStream) Reset 

func (m *MsgCancelStream) Reset()

func (MsgCancelStream) Route 

func (msg MsgCancelStream) Route() string

Route should return the name of the module

func (*MsgCancelStream) Size 

func (m *MsgCancelStream) Size() (n int)

func (*MsgCancelStream) String 

func (m *MsgCancelStream) String() string

func (MsgCancelStream) Type 

func (msg MsgCancelStream) Type() string

Type should return the action

func (*MsgCancelStream) Unmarshal 

func (m *MsgCancelStream) Unmarshal(dAtA []byte) error

func (MsgCancelStream) ValidateBasic 

func (msg MsgCancelStream) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgCancelStream) XXX_DiscardUnknown 

func (m *MsgCancelStream) XXX_DiscardUnknown()

func (*MsgCancelStream) XXX_Marshal 

func (m *MsgCancelStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCancelStream) XXX_Merge 

func (m *MsgCancelStream) XXX_Merge(src proto.Message)

func (*MsgCancelStream) XXX_Size 

func (m *MsgCancelStream) XXX_Size() int

func (*MsgCancelStream) XXX_Unmarshal 

func (m *MsgCancelStream) XXX_Unmarshal(b []byte) error

type MsgCancelStreamResponse 

type MsgCancelStreamResponse struct {
}

MsgCancelStreamResponse

func (*MsgCancelStreamResponse) Descriptor 

func (*MsgCancelStreamResponse) Descriptor() ([]byte, []int)

func (*MsgCancelStreamResponse) Marshal 

func (m *MsgCancelStreamResponse) Marshal() (dAtA []byte, err error)

func (*MsgCancelStreamResponse) MarshalTo 

func (m *MsgCancelStreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCancelStreamResponse) MarshalToSizedBuffer 

func (m *MsgCancelStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCancelStreamResponse) ProtoMessage 

func (*MsgCancelStreamResponse) ProtoMessage()

func (*MsgCancelStreamResponse) Reset 

func (m *MsgCancelStreamResponse) Reset()

func (*MsgCancelStreamResponse) Size 

func (m *MsgCancelStreamResponse) Size() (n int)

func (*MsgCancelStreamResponse) String 

func (m *MsgCancelStreamResponse) String() string

func (*MsgCancelStreamResponse) Unmarshal 

func (m *MsgCancelStreamResponse) Unmarshal(dAtA []byte) error

func (*MsgCancelStreamResponse) XXX_DiscardUnknown 

func (m *MsgCancelStreamResponse) XXX_DiscardUnknown()

func (*MsgCancelStreamResponse) XXX_Marshal 

func (m *MsgCancelStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCancelStreamResponse) XXX_Merge 

func (m *MsgCancelStreamResponse) XXX_Merge(src proto.Message)

func (*MsgCancelStreamResponse) XXX_Size 

func (m *MsgCancelStreamResponse) XXX_Size() int

func (*MsgCancelStreamResponse) XXX_Unmarshal 

func (m *MsgCancelStreamResponse) XXX_Unmarshal(b []byte) error

type MsgClaimStream 

type MsgClaimStream struct {
	// sender is sender wallet of the stream being claimed
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// receiver is the wallet making the claim
	Receiver string `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
}

MsgClaimStream claims pending payments form a stream using the sender and receiver addresses

func NewMsgClaimStream 

func NewMsgClaimStream(
	receiver sdk.AccAddress,
	sender sdk.AccAddress) *MsgClaimStream

NewMsgClaimStream is a constructor function for MsgClaimStream

func (*MsgClaimStream) Descriptor 

func (*MsgClaimStream) Descriptor() ([]byte, []int)

func (MsgClaimStream) GetSignBytes 

func (msg MsgClaimStream) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgClaimStream) GetSigners 

func (msg MsgClaimStream) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgClaimStream) Marshal 

func (m *MsgClaimStream) Marshal() (dAtA []byte, err error)

func (*MsgClaimStream) MarshalTo 

func (m *MsgClaimStream) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimStream) MarshalToSizedBuffer 

func (m *MsgClaimStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimStream) ProtoMessage 

func (*MsgClaimStream) ProtoMessage()

func (*MsgClaimStream) Reset 

func (m *MsgClaimStream) Reset()

func (MsgClaimStream) Route 

func (msg MsgClaimStream) Route() string

Route should return the name of the module

func (*MsgClaimStream) Size 

func (m *MsgClaimStream) Size() (n int)

func (*MsgClaimStream) String 

func (m *MsgClaimStream) String() string

func (MsgClaimStream) Type 

func (msg MsgClaimStream) Type() string

Type should return the action

func (*MsgClaimStream) Unmarshal 

func (m *MsgClaimStream) Unmarshal(dAtA []byte) error

func (MsgClaimStream) ValidateBasic 

func (msg MsgClaimStream) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgClaimStream) XXX_DiscardUnknown 

func (m *MsgClaimStream) XXX_DiscardUnknown()

func (*MsgClaimStream) XXX_Marshal 

func (m *MsgClaimStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgClaimStream) XXX_Merge 

func (m *MsgClaimStream) XXX_Merge(src proto.Message)

func (*MsgClaimStream) XXX_Size 

func (m *MsgClaimStream) XXX_Size() int

func (*MsgClaimStream) XXX_Unmarshal 

func (m *MsgClaimStream) XXX_Unmarshal(b []byte) error

type MsgClaimStreamResponse 

type MsgClaimStreamResponse struct {
	// total_claimed is the total value of the claim
	TotalClaimed types.Coin `protobuf:"bytes,2,opt,name=total_claimed,json=totalClaimed,proto3" json:"total_claimed"`
	// stream_payment is the amount received by the receiver wallet
	StreamPayment types.Coin `protobuf:"bytes,3,opt,name=stream_payment,json=streamPayment,proto3" json:"stream_payment"`
	// validator_fee is the amount sent to validators
	ValidatorFee types.Coin `protobuf:"bytes,4,opt,name=validator_fee,json=validatorFee,proto3" json:"validator_fee"`
	// remaining_deposit is the amount of deposit remaining in the stream
	RemainingDeposit types.Coin `protobuf:"bytes,5,opt,name=remaining_deposit,json=remainingDeposit,proto3" json:"remaining_deposit"`
}

func (*MsgClaimStreamResponse) Descriptor 

func (*MsgClaimStreamResponse) Descriptor() ([]byte, []int)

func (*MsgClaimStreamResponse) GetRemainingDeposit 

func (m *MsgClaimStreamResponse) GetRemainingDeposit() types.Coin

func (*MsgClaimStreamResponse) GetStreamPayment 

func (m *MsgClaimStreamResponse) GetStreamPayment() types.Coin

func (*MsgClaimStreamResponse) GetTotalClaimed 

func (m *MsgClaimStreamResponse) GetTotalClaimed() types.Coin

func (*MsgClaimStreamResponse) GetValidatorFee 

func (m *MsgClaimStreamResponse) GetValidatorFee() types.Coin

func (*MsgClaimStreamResponse) Marshal 

func (m *MsgClaimStreamResponse) Marshal() (dAtA []byte, err error)

func (*MsgClaimStreamResponse) MarshalTo 

func (m *MsgClaimStreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimStreamResponse) MarshalToSizedBuffer 

func (m *MsgClaimStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimStreamResponse) ProtoMessage 

func (*MsgClaimStreamResponse) ProtoMessage()

func (*MsgClaimStreamResponse) Reset 

func (m *MsgClaimStreamResponse) Reset()

func (*MsgClaimStreamResponse) Size 

func (m *MsgClaimStreamResponse) Size() (n int)

func (*MsgClaimStreamResponse) String 

func (m *MsgClaimStreamResponse) String() string

func (*MsgClaimStreamResponse) Unmarshal 

func (m *MsgClaimStreamResponse) Unmarshal(dAtA []byte) error

func (*MsgClaimStreamResponse) XXX_DiscardUnknown 

func (m *MsgClaimStreamResponse) XXX_DiscardUnknown()

func (*MsgClaimStreamResponse) XXX_Marshal 

func (m *MsgClaimStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgClaimStreamResponse) XXX_Merge 

func (m *MsgClaimStreamResponse) XXX_Merge(src proto.Message)

func (*MsgClaimStreamResponse) XXX_Size 

func (m *MsgClaimStreamResponse) XXX_Size() int

func (*MsgClaimStreamResponse) XXX_Unmarshal 

func (m *MsgClaimStreamResponse) XXX_Unmarshal(b []byte) error

type MsgClient 

type MsgClient interface {
	// CreateStream defines a method to create a new stream
	CreateStream(ctx context.Context, in *MsgCreateStream, opts ...grpc.CallOption) (*MsgCreateStreamResponse, error)
	// ClaimStream defines a method for a receiver to claim from a stream using the sender and receiver
	ClaimStream(ctx context.Context, in *MsgClaimStream, opts ...grpc.CallOption) (*MsgClaimStreamResponse, error)
	// TopUpDeposit defines a method for senders to top up their streams
	TopUpDeposit(ctx context.Context, in *MsgTopUpDeposit, opts ...grpc.CallOption) (*MsgTopUpDepositResponse, error)
	// UpdateFlowRate defines a method to update a stream flow rate
	UpdateFlowRate(ctx context.Context, in *MsgUpdateFlowRate, opts ...grpc.CallOption) (*MsgUpdateFlowRateResponse, error)
	// CancelStream defines a method to cancel a stream
	CancelStream(ctx context.Context, in *MsgCancelStream, opts ...grpc.CallOption) (*MsgCancelStreamResponse, error)
	// UpdateParams defines an operation for updating the x/stream module
	// parameters.
	// Since: cosmos-sdk 0.47
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgCreateStream 

type MsgCreateStream struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the address of the stream creator, sending the stream
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// deposit is the amount being sent to deposit for the stream
	Deposit types.Coin `protobuf:"bytes,3,opt,name=deposit,proto3" json:"deposit"`
	// flow_rate is the rate of nund per second
	FlowRate int64 `protobuf:"varint,4,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
}

MsgCreateStream creates a new stream

func NewMsgCreateStream 

func NewMsgCreateStream(
	deposit sdk.Coin,
	flowRate int64,
	receiver,
	sender sdk.AccAddress) *MsgCreateStream

NewMsgCreateStream is a constructor function for MsgCreateStream

func (*MsgCreateStream) Descriptor 

func (*MsgCreateStream) Descriptor() ([]byte, []int)

func (MsgCreateStream) GetSignBytes 

func (msg MsgCreateStream) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgCreateStream) GetSigners 

func (msg MsgCreateStream) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCreateStream) Marshal 

func (m *MsgCreateStream) Marshal() (dAtA []byte, err error)

func (*MsgCreateStream) MarshalTo 

func (m *MsgCreateStream) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateStream) MarshalToSizedBuffer 

func (m *MsgCreateStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateStream) ProtoMessage 

func (*MsgCreateStream) ProtoMessage()

func (*MsgCreateStream) Reset 

func (m *MsgCreateStream) Reset()

func (MsgCreateStream) Route 

func (msg MsgCreateStream) Route() string

Route should return the name of the module

func (*MsgCreateStream) Size 

func (m *MsgCreateStream) Size() (n int)

func (*MsgCreateStream) String 

func (m *MsgCreateStream) String() string

func (MsgCreateStream) Type 

func (msg MsgCreateStream) Type() string

Type should return the action

func (*MsgCreateStream) Unmarshal 

func (m *MsgCreateStream) Unmarshal(dAtA []byte) error

func (MsgCreateStream) ValidateBasic 

func (msg MsgCreateStream) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgCreateStream) XXX_DiscardUnknown 

func (m *MsgCreateStream) XXX_DiscardUnknown()

func (*MsgCreateStream) XXX_Marshal 

func (m *MsgCreateStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateStream) XXX_Merge 

func (m *MsgCreateStream) XXX_Merge(src proto.Message)

func (*MsgCreateStream) XXX_Size 

func (m *MsgCreateStream) XXX_Size() int

func (*MsgCreateStream) XXX_Unmarshal 

func (m *MsgCreateStream) XXX_Unmarshal(b []byte) error

type MsgCreateStreamResponse 

type MsgCreateStreamResponse struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the address of the stream creator, sending the stream
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// deposit is the amount being sent to deposit for the stream
	Deposit types.Coin `protobuf:"bytes,3,opt,name=deposit,proto3" json:"deposit"`
	// flow_rate is the rate of nund per second
	FlowRate int64 `protobuf:"varint,4,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
}

MsgCreateStreamResponse is the response for MsgCreateStream

func (*MsgCreateStreamResponse) Descriptor 

func (*MsgCreateStreamResponse) Descriptor() ([]byte, []int)

func (*MsgCreateStreamResponse) GetDeposit 

func (m *MsgCreateStreamResponse) GetDeposit() types.Coin

func (*MsgCreateStreamResponse) GetFlowRate 

func (m *MsgCreateStreamResponse) GetFlowRate() int64

func (*MsgCreateStreamResponse) GetReceiver 

func (m *MsgCreateStreamResponse) GetReceiver() string

func (*MsgCreateStreamResponse) GetSender 

func (m *MsgCreateStreamResponse) GetSender() string

func (*MsgCreateStreamResponse) Marshal 

func (m *MsgCreateStreamResponse) Marshal() (dAtA []byte, err error)

func (*MsgCreateStreamResponse) MarshalTo 

func (m *MsgCreateStreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateStreamResponse) MarshalToSizedBuffer 

func (m *MsgCreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateStreamResponse) ProtoMessage 

func (*MsgCreateStreamResponse) ProtoMessage()

func (*MsgCreateStreamResponse) Reset 

func (m *MsgCreateStreamResponse) Reset()

func (*MsgCreateStreamResponse) Size 

func (m *MsgCreateStreamResponse) Size() (n int)

func (*MsgCreateStreamResponse) String 

func (m *MsgCreateStreamResponse) String() string

func (*MsgCreateStreamResponse) Unmarshal 

func (m *MsgCreateStreamResponse) Unmarshal(dAtA []byte) error

func (*MsgCreateStreamResponse) XXX_DiscardUnknown 

func (m *MsgCreateStreamResponse) XXX_DiscardUnknown()

func (*MsgCreateStreamResponse) XXX_Marshal 

func (m *MsgCreateStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateStreamResponse) XXX_Merge 

func (m *MsgCreateStreamResponse) XXX_Merge(src proto.Message)

func (*MsgCreateStreamResponse) XXX_Size 

func (m *MsgCreateStreamResponse) XXX_Size() int

func (*MsgCreateStreamResponse) XXX_Unmarshal 

func (m *MsgCreateStreamResponse) XXX_Unmarshal(b []byte) error

type MsgServer 

type MsgServer interface {
	// CreateStream defines a method to create a new stream
	CreateStream(context.Context, *MsgCreateStream) (*MsgCreateStreamResponse, error)
	// ClaimStream defines a method for a receiver to claim from a stream using the sender and receiver
	ClaimStream(context.Context, *MsgClaimStream) (*MsgClaimStreamResponse, error)
	// TopUpDeposit defines a method for senders to top up their streams
	TopUpDeposit(context.Context, *MsgTopUpDeposit) (*MsgTopUpDepositResponse, error)
	// UpdateFlowRate defines a method to update a stream flow rate
	UpdateFlowRate(context.Context, *MsgUpdateFlowRate) (*MsgUpdateFlowRateResponse, error)
	// CancelStream defines a method to cancel a stream
	CancelStream(context.Context, *MsgCancelStream) (*MsgCancelStreamResponse, error)
	// UpdateParams defines an operation for updating the x/stream module
	// parameters.
	// Since: cosmos-sdk 0.47
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgTopUpDeposit 

type MsgTopUpDeposit struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the wallet making the deposit
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// deposit is the amount being sent to deposit for the stream
	Deposit types.Coin `protobuf:"bytes,3,opt,name=deposit,proto3" json:"deposit"`
}

MsgTopUpDeposit tops up deposits in an existing stream

func NewMsgTopUpDeposit 

func NewMsgTopUpDeposit(
	receiver, sender sdk.AccAddress,
	deposit sdk.Coin,
) *MsgTopUpDeposit

NewMsgTopUpDeposit is a constructor function for MsgTopUpDeposit

func (*MsgTopUpDeposit) Descriptor 

func (*MsgTopUpDeposit) Descriptor() ([]byte, []int)

func (MsgTopUpDeposit) GetSignBytes 

func (msg MsgTopUpDeposit) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgTopUpDeposit) GetSigners 

func (msg MsgTopUpDeposit) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgTopUpDeposit) Marshal 

func (m *MsgTopUpDeposit) Marshal() (dAtA []byte, err error)

func (*MsgTopUpDeposit) MarshalTo 

func (m *MsgTopUpDeposit) MarshalTo(dAtA []byte) (int, error)

func (*MsgTopUpDeposit) MarshalToSizedBuffer 

func (m *MsgTopUpDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgTopUpDeposit) ProtoMessage 

func (*MsgTopUpDeposit) ProtoMessage()

func (*MsgTopUpDeposit) Reset 

func (m *MsgTopUpDeposit) Reset()

func (MsgTopUpDeposit) Route 

func (msg MsgTopUpDeposit) Route() string

Route should return the name of the module

func (*MsgTopUpDeposit) Size 

func (m *MsgTopUpDeposit) Size() (n int)

func (*MsgTopUpDeposit) String 

func (m *MsgTopUpDeposit) String() string

func (MsgTopUpDeposit) Type 

func (msg MsgTopUpDeposit) Type() string

Type should return the action

func (*MsgTopUpDeposit) Unmarshal 

func (m *MsgTopUpDeposit) Unmarshal(dAtA []byte) error

func (MsgTopUpDeposit) ValidateBasic 

func (msg MsgTopUpDeposit) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgTopUpDeposit) XXX_DiscardUnknown 

func (m *MsgTopUpDeposit) XXX_DiscardUnknown()

func (*MsgTopUpDeposit) XXX_Marshal 

func (m *MsgTopUpDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgTopUpDeposit) XXX_Merge 

func (m *MsgTopUpDeposit) XXX_Merge(src proto.Message)

func (*MsgTopUpDeposit) XXX_Size 

func (m *MsgTopUpDeposit) XXX_Size() int

func (*MsgTopUpDeposit) XXX_Unmarshal 

func (m *MsgTopUpDeposit) XXX_Unmarshal(b []byte) error

type MsgTopUpDepositResponse 

type MsgTopUpDepositResponse struct {
	// deposit_amount is the amount deposited
	DepositAmount types.Coin `protobuf:"bytes,2,opt,name=deposit_amount,json=depositAmount,proto3" json:"deposit_amount"`
	// current_deposit is the total current deposit in the stream
	CurrentDeposit types.Coin `protobuf:"bytes,3,opt,name=current_deposit,json=currentDeposit,proto3" json:"current_deposit"`
	// deposit_zero_time is the timestamp for when the current deposited amount will run out
	DepositZeroTime time.Time `` /* 131-byte string literal not displayed */
}

MsgTopUpDepositResponse is the response for MsgTopUpDeposit

func (*MsgTopUpDepositResponse) Descriptor 

func (*MsgTopUpDepositResponse) Descriptor() ([]byte, []int)

func (*MsgTopUpDepositResponse) GetCurrentDeposit 

func (m *MsgTopUpDepositResponse) GetCurrentDeposit() types.Coin

func (*MsgTopUpDepositResponse) GetDepositAmount 

func (m *MsgTopUpDepositResponse) GetDepositAmount() types.Coin

func (*MsgTopUpDepositResponse) GetDepositZeroTime 

func (m *MsgTopUpDepositResponse) GetDepositZeroTime() time.Time

func (*MsgTopUpDepositResponse) Marshal 

func (m *MsgTopUpDepositResponse) Marshal() (dAtA []byte, err error)

func (*MsgTopUpDepositResponse) MarshalTo 

func (m *MsgTopUpDepositResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgTopUpDepositResponse) MarshalToSizedBuffer 

func (m *MsgTopUpDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgTopUpDepositResponse) ProtoMessage 

func (*MsgTopUpDepositResponse) ProtoMessage()

func (*MsgTopUpDepositResponse) Reset 

func (m *MsgTopUpDepositResponse) Reset()

func (*MsgTopUpDepositResponse) Size 

func (m *MsgTopUpDepositResponse) Size() (n int)

func (*MsgTopUpDepositResponse) String 

func (m *MsgTopUpDepositResponse) String() string

func (*MsgTopUpDepositResponse) Unmarshal 

func (m *MsgTopUpDepositResponse) Unmarshal(dAtA []byte) error

func (*MsgTopUpDepositResponse) XXX_DiscardUnknown 

func (m *MsgTopUpDepositResponse) XXX_DiscardUnknown()

func (*MsgTopUpDepositResponse) XXX_Marshal 

func (m *MsgTopUpDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgTopUpDepositResponse) XXX_Merge 

func (m *MsgTopUpDepositResponse) XXX_Merge(src proto.Message)

func (*MsgTopUpDepositResponse) XXX_Size 

func (m *MsgTopUpDepositResponse) XXX_Size() int

func (*MsgTopUpDepositResponse) XXX_Unmarshal 

func (m *MsgTopUpDepositResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateFlowRate 

type MsgUpdateFlowRate struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the wallet making the update
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// flow_rate is the rate of nund per second
	FlowRate int64 `protobuf:"varint,3,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
}

MsgUpdateFlowRate updates a stream's flow rate

func NewMsgUpdateFlowRate 

func NewMsgUpdateFlowRate(
	receiver, sender sdk.AccAddress,
	flowRate int64,
) *MsgUpdateFlowRate

NewMsgUpdateFlowRate is a constructor function for MsgUpdateFlowRate

func (*MsgUpdateFlowRate) Descriptor 

func (*MsgUpdateFlowRate) Descriptor() ([]byte, []int)

func (MsgUpdateFlowRate) GetSignBytes 

func (msg MsgUpdateFlowRate) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgUpdateFlowRate) GetSigners 

func (msg MsgUpdateFlowRate) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgUpdateFlowRate) Marshal 

func (m *MsgUpdateFlowRate) Marshal() (dAtA []byte, err error)

func (*MsgUpdateFlowRate) MarshalTo 

func (m *MsgUpdateFlowRate) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateFlowRate) MarshalToSizedBuffer 

func (m *MsgUpdateFlowRate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateFlowRate) ProtoMessage 

func (*MsgUpdateFlowRate) ProtoMessage()

func (*MsgUpdateFlowRate) Reset 

func (m *MsgUpdateFlowRate) Reset()

func (MsgUpdateFlowRate) Route 

func (msg MsgUpdateFlowRate) Route() string

Route should return the name of the module

func (*MsgUpdateFlowRate) Size 

func (m *MsgUpdateFlowRate) Size() (n int)

func (*MsgUpdateFlowRate) String 

func (m *MsgUpdateFlowRate) String() string

func (MsgUpdateFlowRate) Type 

func (msg MsgUpdateFlowRate) Type() string

Type should return the action

func (*MsgUpdateFlowRate) Unmarshal 

func (m *MsgUpdateFlowRate) Unmarshal(dAtA []byte) error

func (MsgUpdateFlowRate) ValidateBasic 

func (msg MsgUpdateFlowRate) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgUpdateFlowRate) XXX_DiscardUnknown 

func (m *MsgUpdateFlowRate) XXX_DiscardUnknown()

func (*MsgUpdateFlowRate) XXX_Marshal 

func (m *MsgUpdateFlowRate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateFlowRate) XXX_Merge 

func (m *MsgUpdateFlowRate) XXX_Merge(src proto.Message)

func (*MsgUpdateFlowRate) XXX_Size 

func (m *MsgUpdateFlowRate) XXX_Size() int

func (*MsgUpdateFlowRate) XXX_Unmarshal 

func (m *MsgUpdateFlowRate) XXX_Unmarshal(b []byte) error

type MsgUpdateFlowRateResponse 

type MsgUpdateFlowRateResponse struct {
	// flow_rate is the rate of nund per second
	FlowRate int64 `protobuf:"varint,2,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
}

MsgUpdateFlowRateResponse is the response for MsgUpdateFlowRate

func (*MsgUpdateFlowRateResponse) Descriptor 

func (*MsgUpdateFlowRateResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateFlowRateResponse) GetFlowRate 

func (m *MsgUpdateFlowRateResponse) GetFlowRate() int64

func (*MsgUpdateFlowRateResponse) Marshal 

func (m *MsgUpdateFlowRateResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateFlowRateResponse) MarshalTo 

func (m *MsgUpdateFlowRateResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateFlowRateResponse) MarshalToSizedBuffer 

func (m *MsgUpdateFlowRateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateFlowRateResponse) ProtoMessage 

func (*MsgUpdateFlowRateResponse) ProtoMessage()

func (*MsgUpdateFlowRateResponse) Reset 

func (m *MsgUpdateFlowRateResponse) Reset()

func (*MsgUpdateFlowRateResponse) Size 

func (m *MsgUpdateFlowRateResponse) Size() (n int)

func (*MsgUpdateFlowRateResponse) String 

func (m *MsgUpdateFlowRateResponse) String() string

func (*MsgUpdateFlowRateResponse) Unmarshal 

func (m *MsgUpdateFlowRateResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateFlowRateResponse) XXX_DiscardUnknown 

func (m *MsgUpdateFlowRateResponse) XXX_DiscardUnknown()

func (*MsgUpdateFlowRateResponse) XXX_Marshal 

func (m *MsgUpdateFlowRateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateFlowRateResponse) XXX_Merge 

func (m *MsgUpdateFlowRateResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateFlowRateResponse) XXX_Size 

func (m *MsgUpdateFlowRateResponse) XXX_Size() int

func (*MsgUpdateFlowRateResponse) XXX_Unmarshal 

func (m *MsgUpdateFlowRateResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateParams 

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/stream 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.

Since: cosmos-sdk 0.47

func (*MsgUpdateParams) Descriptor 

func (*MsgUpdateParams) Descriptor() ([]byte, []int)

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (MsgUpdateParams) GetSignBytes 

func (m MsgUpdateParams) GetSignBytes() []byte

GetSignBytes returns the raw bytes for a MsgUpdateParams message that the expected signer needs to sign.

func (*MsgUpdateParams) GetSigners 

func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal 

func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)

func (*MsgUpdateParams) MarshalTo 

func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateParams) MarshalToSizedBuffer 

func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

func (m *MsgUpdateParams) Size() (n int)

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error

func (*MsgUpdateParams) ValidateBasic 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateParams) XXX_Merge 

func (m *MsgUpdateParams) XXX_Merge(src proto.Message)

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

Since: cosmos-sdk 0.47

func (*MsgUpdateParamsResponse) Descriptor 

func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateParamsResponse) Marshal 

func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateParamsResponse) MarshalTo 

func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

func (m *MsgUpdateParamsResponse) Size() (n int)

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateParamsResponse) XXX_Merge 

func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error

type Params 

type Params struct {
	// validator_fee is the chain-wide fee validators will receive from stream payments
	ValidatorFee github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(validatorFee sdk.Dec) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

type QueryAllStreamsForReceiverRequest 

type QueryAllStreamsForReceiverRequest struct {
	// receiver_addr is the receiver wallet address being queried
	ReceiverAddr string `protobuf:"bytes,1,opt,name=receiver_addr,json=receiverAddr,proto3" json:"receiver_addr,omitempty"`
	// pagination is the pagination parameters for the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllStreamsForReceiverRequest is the request type for the Query/AllStreamsForReceiver RPC method

func (*QueryAllStreamsForReceiverRequest) Descriptor 

func (*QueryAllStreamsForReceiverRequest) Descriptor() ([]byte, []int)

func (*QueryAllStreamsForReceiverRequest) GetPagination 

func (m *QueryAllStreamsForReceiverRequest) GetPagination() *query.PageRequest

func (*QueryAllStreamsForReceiverRequest) GetReceiverAddr 

func (m *QueryAllStreamsForReceiverRequest) GetReceiverAddr() string

func (*QueryAllStreamsForReceiverRequest) Marshal 

func (m *QueryAllStreamsForReceiverRequest) Marshal() (dAtA []byte, err error)

func (*QueryAllStreamsForReceiverRequest) MarshalTo 

func (m *QueryAllStreamsForReceiverRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAllStreamsForReceiverRequest) MarshalToSizedBuffer 

func (m *QueryAllStreamsForReceiverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAllStreamsForReceiverRequest) ProtoMessage 

func (*QueryAllStreamsForReceiverRequest) ProtoMessage()

func (*QueryAllStreamsForReceiverRequest) Reset 

func (m *QueryAllStreamsForReceiverRequest) Reset()

func (*QueryAllStreamsForReceiverRequest) Size 

func (m *QueryAllStreamsForReceiverRequest) Size() (n int)

func (*QueryAllStreamsForReceiverRequest) String 

func (m *QueryAllStreamsForReceiverRequest) String() string

func (*QueryAllStreamsForReceiverRequest) Unmarshal 

func (m *QueryAllStreamsForReceiverRequest) Unmarshal(dAtA []byte) error

func (*QueryAllStreamsForReceiverRequest) XXX_DiscardUnknown 

func (m *QueryAllStreamsForReceiverRequest) XXX_DiscardUnknown()

func (*QueryAllStreamsForReceiverRequest) XXX_Marshal 

func (m *QueryAllStreamsForReceiverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAllStreamsForReceiverRequest) XXX_Merge 

func (m *QueryAllStreamsForReceiverRequest) XXX_Merge(src proto.Message)

func (*QueryAllStreamsForReceiverRequest) XXX_Size 

func (m *QueryAllStreamsForReceiverRequest) XXX_Size() int

func (*QueryAllStreamsForReceiverRequest) XXX_Unmarshal 

func (m *QueryAllStreamsForReceiverRequest) XXX_Unmarshal(b []byte) error

type QueryAllStreamsForReceiverResponse 

type QueryAllStreamsForReceiverResponse struct {
	// receiver_addr is the receiver wallet address being queried
	ReceiverAddr string `protobuf:"bytes,1,opt,name=receiver_addr,json=receiverAddr,proto3" json:"receiver_addr,omitempty"`
	// streams is the list of all streams
	Streams []*StreamResult `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllStreamsForReceiverResponse is the response type for the Query/AllStreamsForReceiver RPC method

func (*QueryAllStreamsForReceiverResponse) Descriptor 

func (*QueryAllStreamsForReceiverResponse) Descriptor() ([]byte, []int)

func (*QueryAllStreamsForReceiverResponse) GetPagination 

func (m *QueryAllStreamsForReceiverResponse) GetPagination() *query.PageResponse

func (*QueryAllStreamsForReceiverResponse) GetReceiverAddr 

func (m *QueryAllStreamsForReceiverResponse) GetReceiverAddr() string

func (*QueryAllStreamsForReceiverResponse) GetStreams 

func (m *QueryAllStreamsForReceiverResponse) GetStreams() []*StreamResult

func (*QueryAllStreamsForReceiverResponse) Marshal 

func (m *QueryAllStreamsForReceiverResponse) Marshal() (dAtA []byte, err error)

func (*QueryAllStreamsForReceiverResponse) MarshalTo 

func (m *QueryAllStreamsForReceiverResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAllStreamsForReceiverResponse) MarshalToSizedBuffer 

func (m *QueryAllStreamsForReceiverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAllStreamsForReceiverResponse) ProtoMessage 

func (*QueryAllStreamsForReceiverResponse) ProtoMessage()

func (*QueryAllStreamsForReceiverResponse) Reset 

func (m *QueryAllStreamsForReceiverResponse) Reset()

func (*QueryAllStreamsForReceiverResponse) Size 

func (m *QueryAllStreamsForReceiverResponse) Size() (n int)

func (*QueryAllStreamsForReceiverResponse) String 

func (m *QueryAllStreamsForReceiverResponse) String() string

func (*QueryAllStreamsForReceiverResponse) Unmarshal 

func (m *QueryAllStreamsForReceiverResponse) Unmarshal(dAtA []byte) error

func (*QueryAllStreamsForReceiverResponse) XXX_DiscardUnknown 

func (m *QueryAllStreamsForReceiverResponse) XXX_DiscardUnknown()

func (*QueryAllStreamsForReceiverResponse) XXX_Marshal 

func (m *QueryAllStreamsForReceiverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAllStreamsForReceiverResponse) XXX_Merge 

func (m *QueryAllStreamsForReceiverResponse) XXX_Merge(src proto.Message)

func (*QueryAllStreamsForReceiverResponse) XXX_Size 

func (m *QueryAllStreamsForReceiverResponse) XXX_Size() int

func (*QueryAllStreamsForReceiverResponse) XXX_Unmarshal 

func (m *QueryAllStreamsForReceiverResponse) XXX_Unmarshal(b []byte) error

type QueryAllStreamsForSenderRequest 

type QueryAllStreamsForSenderRequest struct {
	// sender_addr is the receiver wallet address being queried
	SenderAddr string `protobuf:"bytes,1,opt,name=sender_addr,json=senderAddr,proto3" json:"sender_addr,omitempty"`
	// pagination is the pagination parameters for the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllStreamsForSenderRequest is the request type for the Query/AllStreamsForSender RPC method

func (*QueryAllStreamsForSenderRequest) Descriptor 

func (*QueryAllStreamsForSenderRequest) Descriptor() ([]byte, []int)

func (*QueryAllStreamsForSenderRequest) GetPagination 

func (m *QueryAllStreamsForSenderRequest) GetPagination() *query.PageRequest

func (*QueryAllStreamsForSenderRequest) GetSenderAddr 

func (m *QueryAllStreamsForSenderRequest) GetSenderAddr() string

func (*QueryAllStreamsForSenderRequest) Marshal 

func (m *QueryAllStreamsForSenderRequest) Marshal() (dAtA []byte, err error)

func (*QueryAllStreamsForSenderRequest) MarshalTo 

func (m *QueryAllStreamsForSenderRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAllStreamsForSenderRequest) MarshalToSizedBuffer 

func (m *QueryAllStreamsForSenderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAllStreamsForSenderRequest) ProtoMessage 

func (*QueryAllStreamsForSenderRequest) ProtoMessage()

func (*QueryAllStreamsForSenderRequest) Reset 

func (m *QueryAllStreamsForSenderRequest) Reset()

func (*QueryAllStreamsForSenderRequest) Size 

func (m *QueryAllStreamsForSenderRequest) Size() (n int)

func (*QueryAllStreamsForSenderRequest) String 

func (m *QueryAllStreamsForSenderRequest) String() string

func (*QueryAllStreamsForSenderRequest) Unmarshal 

func (m *QueryAllStreamsForSenderRequest) Unmarshal(dAtA []byte) error

func (*QueryAllStreamsForSenderRequest) XXX_DiscardUnknown 

func (m *QueryAllStreamsForSenderRequest) XXX_DiscardUnknown()

func (*QueryAllStreamsForSenderRequest) XXX_Marshal 

func (m *QueryAllStreamsForSenderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAllStreamsForSenderRequest) XXX_Merge 

func (m *QueryAllStreamsForSenderRequest) XXX_Merge(src proto.Message)

func (*QueryAllStreamsForSenderRequest) XXX_Size 

func (m *QueryAllStreamsForSenderRequest) XXX_Size() int

func (*QueryAllStreamsForSenderRequest) XXX_Unmarshal 

func (m *QueryAllStreamsForSenderRequest) XXX_Unmarshal(b []byte) error

type QueryAllStreamsForSenderResponse 

type QueryAllStreamsForSenderResponse struct {
	// sender_addr is the receiver wallet address being queried
	SenderAddr string `protobuf:"bytes,1,opt,name=sender_addr,json=senderAddr,proto3" json:"sender_addr,omitempty"`
	// streams is the list of all streams
	Streams []*StreamResult `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllStreamsForSenderResponse is the response type for the Query/AllStreamsForSender RPC method

func (*QueryAllStreamsForSenderResponse) Descriptor 

func (*QueryAllStreamsForSenderResponse) Descriptor() ([]byte, []int)

func (*QueryAllStreamsForSenderResponse) GetPagination 

func (m *QueryAllStreamsForSenderResponse) GetPagination() *query.PageResponse

func (*QueryAllStreamsForSenderResponse) GetSenderAddr 

func (m *QueryAllStreamsForSenderResponse) GetSenderAddr() string

func (*QueryAllStreamsForSenderResponse) GetStreams 

func (m *QueryAllStreamsForSenderResponse) GetStreams() []*StreamResult

func (*QueryAllStreamsForSenderResponse) Marshal 

func (m *QueryAllStreamsForSenderResponse) Marshal() (dAtA []byte, err error)

func (*QueryAllStreamsForSenderResponse) MarshalTo 

func (m *QueryAllStreamsForSenderResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAllStreamsForSenderResponse) MarshalToSizedBuffer 

func (m *QueryAllStreamsForSenderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAllStreamsForSenderResponse) ProtoMessage 

func (*QueryAllStreamsForSenderResponse) ProtoMessage()

func (*QueryAllStreamsForSenderResponse) Reset 

func (m *QueryAllStreamsForSenderResponse) Reset()

func (*QueryAllStreamsForSenderResponse) Size 

func (m *QueryAllStreamsForSenderResponse) Size() (n int)

func (*QueryAllStreamsForSenderResponse) String 

func (m *QueryAllStreamsForSenderResponse) String() string

func (*QueryAllStreamsForSenderResponse) Unmarshal 

func (m *QueryAllStreamsForSenderResponse) Unmarshal(dAtA []byte) error

func (*QueryAllStreamsForSenderResponse) XXX_DiscardUnknown 

func (m *QueryAllStreamsForSenderResponse) XXX_DiscardUnknown()

func (*QueryAllStreamsForSenderResponse) XXX_Marshal 

func (m *QueryAllStreamsForSenderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAllStreamsForSenderResponse) XXX_Merge 

func (m *QueryAllStreamsForSenderResponse) XXX_Merge(src proto.Message)

func (*QueryAllStreamsForSenderResponse) XXX_Size 

func (m *QueryAllStreamsForSenderResponse) XXX_Size() int

func (*QueryAllStreamsForSenderResponse) XXX_Unmarshal 

func (m *QueryAllStreamsForSenderResponse) XXX_Unmarshal(b []byte) error

type QueryCalculateFlowRateRequest 

type QueryCalculateFlowRateRequest struct {
	// coin is the coin to be used in the calculation, e.g. 10000000000nund
	Coin string `protobuf:"bytes,1,opt,name=coin,proto3" json:"coin,omitempty"`
	// period is the enumerated value of a period to be used in the calculation, e.g. month = 6
	Period StreamPeriod `protobuf:"varint,2,opt,name=period,proto3,enum=mainchain.stream.v1.StreamPeriod" json:"period,omitempty"`
	// duration is the number of periods to be used in the calculation, e.g. 1 = 1 month
	Duration uint64 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
}

QueryCalculateFlowRateRequest is the request type for the Query/CalculateFlowRate RPC method

func (*QueryCalculateFlowRateRequest) Descriptor 

func (*QueryCalculateFlowRateRequest) Descriptor() ([]byte, []int)

func (*QueryCalculateFlowRateRequest) Marshal 

func (m *QueryCalculateFlowRateRequest) Marshal() (dAtA []byte, err error)

func (*QueryCalculateFlowRateRequest) MarshalTo 

func (m *QueryCalculateFlowRateRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryCalculateFlowRateRequest) MarshalToSizedBuffer 

func (m *QueryCalculateFlowRateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCalculateFlowRateRequest) ProtoMessage 

func (*QueryCalculateFlowRateRequest) ProtoMessage()

func (*QueryCalculateFlowRateRequest) Reset 

func (m *QueryCalculateFlowRateRequest) Reset()

func (*QueryCalculateFlowRateRequest) Size 

func (m *QueryCalculateFlowRateRequest) Size() (n int)

func (*QueryCalculateFlowRateRequest) String 

func (m *QueryCalculateFlowRateRequest) String() string

func (*QueryCalculateFlowRateRequest) Unmarshal 

func (m *QueryCalculateFlowRateRequest) Unmarshal(dAtA []byte) error

func (*QueryCalculateFlowRateRequest) XXX_DiscardUnknown 

func (m *QueryCalculateFlowRateRequest) XXX_DiscardUnknown()

func (*QueryCalculateFlowRateRequest) XXX_Marshal 

func (m *QueryCalculateFlowRateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCalculateFlowRateRequest) XXX_Merge 

func (m *QueryCalculateFlowRateRequest) XXX_Merge(src proto.Message)

func (*QueryCalculateFlowRateRequest) XXX_Size 

func (m *QueryCalculateFlowRateRequest) XXX_Size() int

func (*QueryCalculateFlowRateRequest) XXX_Unmarshal 

func (m *QueryCalculateFlowRateRequest) XXX_Unmarshal(b []byte) error

type QueryCalculateFlowRateResponse 

type QueryCalculateFlowRateResponse struct {
	// coin is the coin used in the calculation
	Coin types.Coin `protobuf:"bytes,1,opt,name=coin,proto3" json:"coin"`
	// period is the enumerated value of a period used in the calculation, e.g. month = 6
	Period StreamPeriod `protobuf:"varint,2,opt,name=period,proto3,enum=mainchain.stream.v1.StreamPeriod" json:"period,omitempty"`
	// duration is the number of periods used in the calculation, e.g. 1 = 1 month
	Duration uint64 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	// seconds is the calculated number of seconds for the stream (period * duration)
	Seconds uint64 `protobuf:"varint,4,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// flow_rate is the calculated rate of coins per second, in the lowest denomination - e.g. nund
	FlowRate int64 `protobuf:"varint,5,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
}

QueryCalculateFlowRateResponse is the response type for the Query/CalculateFlowRate RPC method

func (*QueryCalculateFlowRateResponse) Descriptor 

func (*QueryCalculateFlowRateResponse) Descriptor() ([]byte, []int)

func (*QueryCalculateFlowRateResponse) GetCoin 

func (m *QueryCalculateFlowRateResponse) GetCoin() types.Coin

func (*QueryCalculateFlowRateResponse) GetDuration 

func (m *QueryCalculateFlowRateResponse) GetDuration() uint64

func (*QueryCalculateFlowRateResponse) GetFlowRate 

func (m *QueryCalculateFlowRateResponse) GetFlowRate() int64

func (*QueryCalculateFlowRateResponse) GetPeriod 

func (m *QueryCalculateFlowRateResponse) GetPeriod() StreamPeriod

func (*QueryCalculateFlowRateResponse) GetSeconds 

func (m *QueryCalculateFlowRateResponse) GetSeconds() uint64

func (*QueryCalculateFlowRateResponse) Marshal 

func (m *QueryCalculateFlowRateResponse) Marshal() (dAtA []byte, err error)

func (*QueryCalculateFlowRateResponse) MarshalTo 

func (m *QueryCalculateFlowRateResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryCalculateFlowRateResponse) MarshalToSizedBuffer 

func (m *QueryCalculateFlowRateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCalculateFlowRateResponse) ProtoMessage 

func (*QueryCalculateFlowRateResponse) ProtoMessage()

func (*QueryCalculateFlowRateResponse) Reset 

func (m *QueryCalculateFlowRateResponse) Reset()

func (*QueryCalculateFlowRateResponse) Size 

func (m *QueryCalculateFlowRateResponse) Size() (n int)

func (*QueryCalculateFlowRateResponse) String 

func (m *QueryCalculateFlowRateResponse) String() string

func (*QueryCalculateFlowRateResponse) Unmarshal 

func (m *QueryCalculateFlowRateResponse) Unmarshal(dAtA []byte) error

func (*QueryCalculateFlowRateResponse) XXX_DiscardUnknown 

func (m *QueryCalculateFlowRateResponse) XXX_DiscardUnknown()

func (*QueryCalculateFlowRateResponse) XXX_Marshal 

func (m *QueryCalculateFlowRateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCalculateFlowRateResponse) XXX_Merge 

func (m *QueryCalculateFlowRateResponse) XXX_Merge(src proto.Message)

func (*QueryCalculateFlowRateResponse) XXX_Size 

func (m *QueryCalculateFlowRateResponse) XXX_Size() int

func (*QueryCalculateFlowRateResponse) XXX_Unmarshal 

func (m *QueryCalculateFlowRateResponse) 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)
	// CalculateFlowRate can be used to calculate a flow rate (coins per second) to be used when creating/updating a stream
	CalculateFlowRate(ctx context.Context, in *QueryCalculateFlowRateRequest, opts ...grpc.CallOption) (*QueryCalculateFlowRateResponse, error)
	// Streams queries all Streams.
	Streams(ctx context.Context, in *QueryStreamsRequest, opts ...grpc.CallOption) (*QueryStreamsResponse, error)
	// AllStreamsForReceiver queries all Streams for a given receiver address
	AllStreamsForReceiver(ctx context.Context, in *QueryAllStreamsForReceiverRequest, opts ...grpc.CallOption) (*QueryAllStreamsForReceiverResponse, error)
	// StreamByReceiverSender queries a stream for a given receiver and sender pair
	StreamByReceiverSender(ctx context.Context, in *QueryStreamByReceiverSenderRequest, opts ...grpc.CallOption) (*QueryStreamByReceiverSenderResponse, error)
	// StreamReceiverSenderCurrentFlow queries a stream by the given receiver/sender pair and returns the current flow data
	StreamReceiverSenderCurrentFlow(ctx context.Context, in *QueryStreamReceiverSenderCurrentFlowRequest, opts ...grpc.CallOption) (*QueryStreamReceiverSenderCurrentFlowResponse, error)
	// AllStreamsForSender queries all Streams for a given sender address
	AllStreamsForSender(ctx context.Context, in *QueryAllStreamsForSenderRequest, opts ...grpc.CallOption) (*QueryAllStreamsForSenderResponse, 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 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 QueryServer 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// CalculateFlowRate can be used to calculate a flow rate (coins per second) to be used when creating/updating a stream
	CalculateFlowRate(context.Context, *QueryCalculateFlowRateRequest) (*QueryCalculateFlowRateResponse, error)
	// Streams queries all Streams.
	Streams(context.Context, *QueryStreamsRequest) (*QueryStreamsResponse, error)
	// AllStreamsForReceiver queries all Streams for a given receiver address
	AllStreamsForReceiver(context.Context, *QueryAllStreamsForReceiverRequest) (*QueryAllStreamsForReceiverResponse, error)
	// StreamByReceiverSender queries a stream for a given receiver and sender pair
	StreamByReceiverSender(context.Context, *QueryStreamByReceiverSenderRequest) (*QueryStreamByReceiverSenderResponse, error)
	// StreamReceiverSenderCurrentFlow queries a stream by the given receiver/sender pair and returns the current flow data
	StreamReceiverSenderCurrentFlow(context.Context, *QueryStreamReceiverSenderCurrentFlowRequest) (*QueryStreamReceiverSenderCurrentFlowResponse, error)
	// AllStreamsForSender queries all Streams for a given sender address
	AllStreamsForSender(context.Context, *QueryAllStreamsForSenderRequest) (*QueryAllStreamsForSenderResponse, error)
}

QueryServer is the server API for Query service.

type QueryStreamByReceiverSenderRequest 

type QueryStreamByReceiverSenderRequest struct {
	// receiver_addr is the receiver wallet address being queried
	ReceiverAddr string `protobuf:"bytes,1,opt,name=receiver_addr,json=receiverAddr,proto3" json:"receiver_addr,omitempty"`
	// sender_addr is the sender wallet address being queried
	SenderAddr string `protobuf:"bytes,2,opt,name=sender_addr,json=senderAddr,proto3" json:"sender_addr,omitempty"`
}

QueryStreamByReceiverSenderRequest is the request type for the Query/StreamByReceiverSender RPC method

func (*QueryStreamByReceiverSenderRequest) Descriptor 

func (*QueryStreamByReceiverSenderRequest) Descriptor() ([]byte, []int)

func (*QueryStreamByReceiverSenderRequest) GetReceiverAddr 

func (m *QueryStreamByReceiverSenderRequest) GetReceiverAddr() string

func (*QueryStreamByReceiverSenderRequest) GetSenderAddr 

func (m *QueryStreamByReceiverSenderRequest) GetSenderAddr() string

func (*QueryStreamByReceiverSenderRequest) Marshal 

func (m *QueryStreamByReceiverSenderRequest) Marshal() (dAtA []byte, err error)

func (*QueryStreamByReceiverSenderRequest) MarshalTo 

func (m *QueryStreamByReceiverSenderRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamByReceiverSenderRequest) MarshalToSizedBuffer 

func (m *QueryStreamByReceiverSenderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamByReceiverSenderRequest) ProtoMessage 

func (*QueryStreamByReceiverSenderRequest) ProtoMessage()

func (*QueryStreamByReceiverSenderRequest) Reset 

func (m *QueryStreamByReceiverSenderRequest) Reset()

func (*QueryStreamByReceiverSenderRequest) Size 

func (m *QueryStreamByReceiverSenderRequest) Size() (n int)

func (*QueryStreamByReceiverSenderRequest) String 

func (m *QueryStreamByReceiverSenderRequest) String() string

func (*QueryStreamByReceiverSenderRequest) Unmarshal 

func (m *QueryStreamByReceiverSenderRequest) Unmarshal(dAtA []byte) error

func (*QueryStreamByReceiverSenderRequest) XXX_DiscardUnknown 

func (m *QueryStreamByReceiverSenderRequest) XXX_DiscardUnknown()

func (*QueryStreamByReceiverSenderRequest) XXX_Marshal 

func (m *QueryStreamByReceiverSenderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamByReceiverSenderRequest) XXX_Merge 

func (m *QueryStreamByReceiverSenderRequest) XXX_Merge(src proto.Message)

func (*QueryStreamByReceiverSenderRequest) XXX_Size 

func (m *QueryStreamByReceiverSenderRequest) XXX_Size() int

func (*QueryStreamByReceiverSenderRequest) XXX_Unmarshal 

func (m *QueryStreamByReceiverSenderRequest) XXX_Unmarshal(b []byte) error

type QueryStreamByReceiverSenderResponse 

type QueryStreamByReceiverSenderResponse struct {
	// stream is the StreamResult
	Stream StreamResult `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream"`
}

QueryStreamByReceiverSenderResponse is the response type for the Query/StreamByReceiverSender RPC method

func (*QueryStreamByReceiverSenderResponse) Descriptor 

func (*QueryStreamByReceiverSenderResponse) Descriptor() ([]byte, []int)

func (*QueryStreamByReceiverSenderResponse) GetStream 

func (m *QueryStreamByReceiverSenderResponse) GetStream() StreamResult

func (*QueryStreamByReceiverSenderResponse) Marshal 

func (m *QueryStreamByReceiverSenderResponse) Marshal() (dAtA []byte, err error)

func (*QueryStreamByReceiverSenderResponse) MarshalTo 

func (m *QueryStreamByReceiverSenderResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamByReceiverSenderResponse) MarshalToSizedBuffer 

func (m *QueryStreamByReceiverSenderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamByReceiverSenderResponse) ProtoMessage 

func (*QueryStreamByReceiverSenderResponse) ProtoMessage()

func (*QueryStreamByReceiverSenderResponse) Reset 

func (m *QueryStreamByReceiverSenderResponse) Reset()

func (*QueryStreamByReceiverSenderResponse) Size 

func (m *QueryStreamByReceiverSenderResponse) Size() (n int)

func (*QueryStreamByReceiverSenderResponse) String 

func (m *QueryStreamByReceiverSenderResponse) String() string

func (*QueryStreamByReceiverSenderResponse) Unmarshal 

func (m *QueryStreamByReceiverSenderResponse) Unmarshal(dAtA []byte) error

func (*QueryStreamByReceiverSenderResponse) XXX_DiscardUnknown 

func (m *QueryStreamByReceiverSenderResponse) XXX_DiscardUnknown()

func (*QueryStreamByReceiverSenderResponse) XXX_Marshal 

func (m *QueryStreamByReceiverSenderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamByReceiverSenderResponse) XXX_Merge 

func (m *QueryStreamByReceiverSenderResponse) XXX_Merge(src proto.Message)

func (*QueryStreamByReceiverSenderResponse) XXX_Size 

func (m *QueryStreamByReceiverSenderResponse) XXX_Size() int

func (*QueryStreamByReceiverSenderResponse) XXX_Unmarshal 

func (m *QueryStreamByReceiverSenderResponse) XXX_Unmarshal(b []byte) error

type QueryStreamReceiverSenderCurrentFlowRequest 

type QueryStreamReceiverSenderCurrentFlowRequest struct {
	// receiver_addr is the receiver wallet address being queried
	ReceiverAddr string `protobuf:"bytes,1,opt,name=receiver_addr,json=receiverAddr,proto3" json:"receiver_addr,omitempty"`
	// sender_addr is the sender wallet address being queried
	SenderAddr string `protobuf:"bytes,2,opt,name=sender_addr,json=senderAddr,proto3" json:"sender_addr,omitempty"`
}

QueryStreamReceiverSenderCurrentFlowRequest is the request type for the Query/StreamReceiverSenderCurrentFlow RPC method

func (*QueryStreamReceiverSenderCurrentFlowRequest) Descriptor 

func (*QueryStreamReceiverSenderCurrentFlowRequest) Descriptor() ([]byte, []int)

func (*QueryStreamReceiverSenderCurrentFlowRequest) GetReceiverAddr 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) GetReceiverAddr() string

func (*QueryStreamReceiverSenderCurrentFlowRequest) GetSenderAddr 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) GetSenderAddr() string

func (*QueryStreamReceiverSenderCurrentFlowRequest) Marshal 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) Marshal() (dAtA []byte, err error)

func (*QueryStreamReceiverSenderCurrentFlowRequest) MarshalTo 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamReceiverSenderCurrentFlowRequest) MarshalToSizedBuffer 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamReceiverSenderCurrentFlowRequest) ProtoMessage 

func (*QueryStreamReceiverSenderCurrentFlowRequest) ProtoMessage()

func (*QueryStreamReceiverSenderCurrentFlowRequest) Reset 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) Reset()

func (*QueryStreamReceiverSenderCurrentFlowRequest) Size 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) Size() (n int)

func (*QueryStreamReceiverSenderCurrentFlowRequest) String 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) String() string

func (*QueryStreamReceiverSenderCurrentFlowRequest) Unmarshal 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) Unmarshal(dAtA []byte) error

func (*QueryStreamReceiverSenderCurrentFlowRequest) XXX_DiscardUnknown 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) XXX_DiscardUnknown()

func (*QueryStreamReceiverSenderCurrentFlowRequest) XXX_Marshal 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamReceiverSenderCurrentFlowRequest) XXX_Merge 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) XXX_Merge(src proto.Message)

func (*QueryStreamReceiverSenderCurrentFlowRequest) XXX_Size 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) XXX_Size() int

func (*QueryStreamReceiverSenderCurrentFlowRequest) XXX_Unmarshal 

func (m *QueryStreamReceiverSenderCurrentFlowRequest) XXX_Unmarshal(b []byte) error

type QueryStreamReceiverSenderCurrentFlowResponse 

type QueryStreamReceiverSenderCurrentFlowResponse struct {
	// configured_flow_rate is the flow rate configured in the stream
	ConfiguredFlowRate int64 `protobuf:"varint,1,opt,name=configured_flow_rate,json=configuredFlowRate,proto3" json:"configured_flow_rate,omitempty"`
	// current_flow_rate is the actual flow rate. This will be zero if the depositZeroTime has passed, or deposit is zero
	CurrentFlowRate int64 `protobuf:"varint,2,opt,name=current_flow_rate,json=currentFlowRate,proto3" json:"current_flow_rate,omitempty"`
}

QueryStreamReceiverSenderCurrentFlowResponse is the response type for the Query/StreamReceiverSenderCurrentFlow RPC method

func (*QueryStreamReceiverSenderCurrentFlowResponse) Descriptor 

func (*QueryStreamReceiverSenderCurrentFlowResponse) Descriptor() ([]byte, []int)

func (*QueryStreamReceiverSenderCurrentFlowResponse) GetConfiguredFlowRate 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) GetConfiguredFlowRate() int64

func (*QueryStreamReceiverSenderCurrentFlowResponse) GetCurrentFlowRate 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) GetCurrentFlowRate() int64

func (*QueryStreamReceiverSenderCurrentFlowResponse) Marshal 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) Marshal() (dAtA []byte, err error)

func (*QueryStreamReceiverSenderCurrentFlowResponse) MarshalTo 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamReceiverSenderCurrentFlowResponse) MarshalToSizedBuffer 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamReceiverSenderCurrentFlowResponse) ProtoMessage 

func (*QueryStreamReceiverSenderCurrentFlowResponse) ProtoMessage()

func (*QueryStreamReceiverSenderCurrentFlowResponse) Reset 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) Reset()

func (*QueryStreamReceiverSenderCurrentFlowResponse) Size 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) Size() (n int)

func (*QueryStreamReceiverSenderCurrentFlowResponse) String 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) String() string

func (*QueryStreamReceiverSenderCurrentFlowResponse) Unmarshal 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) Unmarshal(dAtA []byte) error

func (*QueryStreamReceiverSenderCurrentFlowResponse) XXX_DiscardUnknown 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) XXX_DiscardUnknown()

func (*QueryStreamReceiverSenderCurrentFlowResponse) XXX_Marshal 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamReceiverSenderCurrentFlowResponse) XXX_Merge 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) XXX_Merge(src proto.Message)

func (*QueryStreamReceiverSenderCurrentFlowResponse) XXX_Size 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) XXX_Size() int

func (*QueryStreamReceiverSenderCurrentFlowResponse) XXX_Unmarshal 

func (m *QueryStreamReceiverSenderCurrentFlowResponse) XXX_Unmarshal(b []byte) error

type QueryStreamsRequest 

type QueryStreamsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStreamsRequest is the request type for the Query/Streams RPC method

func (*QueryStreamsRequest) Descriptor 

func (*QueryStreamsRequest) Descriptor() ([]byte, []int)

func (*QueryStreamsRequest) GetPagination 

func (m *QueryStreamsRequest) GetPagination() *query.PageRequest

func (*QueryStreamsRequest) Marshal 

func (m *QueryStreamsRequest) Marshal() (dAtA []byte, err error)

func (*QueryStreamsRequest) MarshalTo 

func (m *QueryStreamsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamsRequest) MarshalToSizedBuffer 

func (m *QueryStreamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamsRequest) ProtoMessage 

func (*QueryStreamsRequest) ProtoMessage()

func (*QueryStreamsRequest) Reset 

func (m *QueryStreamsRequest) Reset()

func (*QueryStreamsRequest) Size 

func (m *QueryStreamsRequest) Size() (n int)

func (*QueryStreamsRequest) String 

func (m *QueryStreamsRequest) String() string

func (*QueryStreamsRequest) Unmarshal 

func (m *QueryStreamsRequest) Unmarshal(dAtA []byte) error

func (*QueryStreamsRequest) XXX_DiscardUnknown 

func (m *QueryStreamsRequest) XXX_DiscardUnknown()

func (*QueryStreamsRequest) XXX_Marshal 

func (m *QueryStreamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamsRequest) XXX_Merge 

func (m *QueryStreamsRequest) XXX_Merge(src proto.Message)

func (*QueryStreamsRequest) XXX_Size 

func (m *QueryStreamsRequest) XXX_Size() int

func (*QueryStreamsRequest) XXX_Unmarshal 

func (m *QueryStreamsRequest) XXX_Unmarshal(b []byte) error

type QueryStreamsResponse 

type QueryStreamsResponse struct {
	// streams is the list of all streams
	Streams []*StreamResult `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStreamsResponse is the response type for the Query/Streams RPC method

func (*QueryStreamsResponse) Descriptor 

func (*QueryStreamsResponse) Descriptor() ([]byte, []int)

func (*QueryStreamsResponse) GetPagination 

func (m *QueryStreamsResponse) GetPagination() *query.PageResponse

func (*QueryStreamsResponse) GetStreams 

func (m *QueryStreamsResponse) GetStreams() []*StreamResult

func (*QueryStreamsResponse) Marshal 

func (m *QueryStreamsResponse) Marshal() (dAtA []byte, err error)

func (*QueryStreamsResponse) MarshalTo 

func (m *QueryStreamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamsResponse) MarshalToSizedBuffer 

func (m *QueryStreamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamsResponse) ProtoMessage 

func (*QueryStreamsResponse) ProtoMessage()

func (*QueryStreamsResponse) Reset 

func (m *QueryStreamsResponse) Reset()

func (*QueryStreamsResponse) Size 

func (m *QueryStreamsResponse) Size() (n int)

func (*QueryStreamsResponse) String 

func (m *QueryStreamsResponse) String() string

func (*QueryStreamsResponse) Unmarshal 

func (m *QueryStreamsResponse) Unmarshal(dAtA []byte) error

func (*QueryStreamsResponse) XXX_DiscardUnknown 

func (m *QueryStreamsResponse) XXX_DiscardUnknown()

func (*QueryStreamsResponse) XXX_Marshal 

func (m *QueryStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamsResponse) XXX_Merge 

func (m *QueryStreamsResponse) XXX_Merge(src proto.Message)

func (*QueryStreamsResponse) XXX_Size 

func (m *QueryStreamsResponse) XXX_Size() int

func (*QueryStreamsResponse) XXX_Unmarshal 

func (m *QueryStreamsResponse) XXX_Unmarshal(b []byte) error

type Stream 

type Stream struct {
	// deposit tracks the total amount the user has deposited to cover the stream, including any updates to the stream
	Deposit types.Coin `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
	// flow_rate is the current rate of nund per second
	FlowRate int64 `protobuf:"varint,2,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`
	// last_outflow_time is the timestamp of the last claim. Allows for a start point to calculate the next claim
	LastOutflowTime time.Time `` /* 131-byte string literal not displayed */
	// deposit_zero_time is the timestamp for when the current deposited amount will run out
	DepositZeroTime time.Time `` /* 131-byte string literal not displayed */
	// cancellable is whether a stream can be cancelled. Default is true, but will be false for example id eFUND is used
	Cancellable bool `protobuf:"varint,5,opt,name=cancellable,proto3" json:"cancellable,omitempty"`
}

Stream holds data about a stream

func (*Stream) Descriptor 

func (*Stream) Descriptor() ([]byte, []int)

func (*Stream) GetCancellable 

func (m *Stream) GetCancellable() bool

func (*Stream) GetDeposit 

func (m *Stream) GetDeposit() types.Coin

func (*Stream) GetDepositZeroTime 

func (m *Stream) GetDepositZeroTime() time.Time

func (*Stream) GetFlowRate 

func (m *Stream) GetFlowRate() int64

func (*Stream) GetLastOutflowTime 

func (m *Stream) GetLastOutflowTime() time.Time

func (*Stream) Marshal 

func (m *Stream) Marshal() (dAtA []byte, err error)

func (*Stream) MarshalTo 

func (m *Stream) MarshalTo(dAtA []byte) (int, error)

func (*Stream) MarshalToSizedBuffer 

func (m *Stream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

func (m *Stream) Size() (n int)

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Unmarshal 

func (m *Stream) Unmarshal(dAtA []byte) error

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

func (m *Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stream) XXX_Merge 

func (m *Stream) XXX_Merge(src proto.Message)

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

func (m *Stream) XXX_Unmarshal(b []byte) error

type StreamExport 

type StreamExport struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the wallet making the update
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// stream is the stream data
	Stream Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream"`
}

StreamExport holds genesis export data for a stream

func (*StreamExport) Descriptor 

func (*StreamExport) Descriptor() ([]byte, []int)

func (*StreamExport) GetReceiver 

func (m *StreamExport) GetReceiver() string

func (*StreamExport) GetSender 

func (m *StreamExport) GetSender() string

func (*StreamExport) GetStream 

func (m *StreamExport) GetStream() Stream

func (*StreamExport) Marshal 

func (m *StreamExport) Marshal() (dAtA []byte, err error)

func (*StreamExport) MarshalTo 

func (m *StreamExport) MarshalTo(dAtA []byte) (int, error)

func (*StreamExport) MarshalToSizedBuffer 

func (m *StreamExport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamExport) ProtoMessage 

func (*StreamExport) ProtoMessage()

func (*StreamExport) Reset 

func (m *StreamExport) Reset()

func (*StreamExport) Size 

func (m *StreamExport) Size() (n int)

func (*StreamExport) String 

func (m *StreamExport) String() string

func (*StreamExport) Unmarshal 

func (m *StreamExport) Unmarshal(dAtA []byte) error

func (*StreamExport) XXX_DiscardUnknown 

func (m *StreamExport) XXX_DiscardUnknown()

func (*StreamExport) XXX_Marshal 

func (m *StreamExport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamExport) XXX_Merge 

func (m *StreamExport) XXX_Merge(src proto.Message)

func (*StreamExport) XXX_Size 

func (m *StreamExport) XXX_Size() int

func (*StreamExport) XXX_Unmarshal 

func (m *StreamExport) XXX_Unmarshal(b []byte) error

type StreamPeriod 

type StreamPeriod int32

StreamPeriod enumerates the valid periods for calculating flow rates 

const (
	// STREAM_PERIOD_UNSPECIFIED defines unspecified
	StreamPeriodUnspecified StreamPeriod = 0
	// STREAM_PERIOD_SECOND defines second
	StreamPeriodSecond StreamPeriod = 1
	// STREAM_PERIOD_MINUTE defines minute
	StreamPeriodMinute StreamPeriod = 2
	// STREAM_PERIOD_HOUR defines hour
	StreamPeriodHour StreamPeriod = 3
	// STREAM_PERIOD_DAY defines day
	StreamPeriodDay StreamPeriod = 4
	// STREAM_PERIOD_WEEK defines week
	StreamPeriodWeek StreamPeriod = 5
	// STREAM_PERIOD_MONTH defines month
	StreamPeriodMonth StreamPeriod = 6
	// STREAM_PERIOD_YEAR defines year
	StreamPeriodYear StreamPeriod = 7
)

func PeriodEnumFromString 

func PeriodEnumFromString(period string) StreamPeriod

func (StreamPeriod) EnumDescriptor 

func (StreamPeriod) EnumDescriptor() ([]byte, []int)

func (StreamPeriod) String 

func (x StreamPeriod) String() string

type StreamResult 

type StreamResult struct {
	// receiver is the wallet that will receive stream payments
	Receiver string `protobuf:"bytes,1,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// sender is the wallet making the update
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// stream is the stream data
	Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
}

StreamResult contains data about a stream

func (*StreamResult) Descriptor 

func (*StreamResult) Descriptor() ([]byte, []int)

func (*StreamResult) GetReceiver 

func (m *StreamResult) GetReceiver() string

func (*StreamResult) GetSender 

func (m *StreamResult) GetSender() string

func (*StreamResult) GetStream 

func (m *StreamResult) GetStream() *Stream

func (*StreamResult) Marshal 

func (m *StreamResult) Marshal() (dAtA []byte, err error)

func (*StreamResult) MarshalTo 

func (m *StreamResult) MarshalTo(dAtA []byte) (int, error)

func (*StreamResult) MarshalToSizedBuffer 

func (m *StreamResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamResult) ProtoMessage 

func (*StreamResult) ProtoMessage()

func (*StreamResult) Reset 

func (m *StreamResult) Reset()

func (*StreamResult) Size 

func (m *StreamResult) Size() (n int)

func (*StreamResult) String 

func (m *StreamResult) String() string

func (*StreamResult) Unmarshal 

func (m *StreamResult) Unmarshal(dAtA []byte) error

func (*StreamResult) XXX_DiscardUnknown 

func (m *StreamResult) XXX_DiscardUnknown()

func (*StreamResult) XXX_Marshal 

func (m *StreamResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamResult) XXX_Merge 

func (m *StreamResult) XXX_Merge(src proto.Message)

func (*StreamResult) XXX_Size 

func (m *StreamResult) XXX_Size() int

func (*StreamResult) XXX_Unmarshal 

func (m *StreamResult) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CancelStream 

func (*UnimplementedMsgServer) CancelStream(ctx context.Context, req *MsgCancelStream) (*MsgCancelStreamResponse, error)

func (*UnimplementedMsgServer) ClaimStream 

func (*UnimplementedMsgServer) ClaimStream(ctx context.Context, req *MsgClaimStream) (*MsgClaimStreamResponse, error)

func (*UnimplementedMsgServer) CreateStream 

func (*UnimplementedMsgServer) CreateStream(ctx context.Context, req *MsgCreateStream) (*MsgCreateStreamResponse, error)

func (*UnimplementedMsgServer) TopUpDeposit 

func (*UnimplementedMsgServer) TopUpDeposit(ctx context.Context, req *MsgTopUpDeposit) (*MsgTopUpDepositResponse, error)

func (*UnimplementedMsgServer) UpdateFlowRate 

func (*UnimplementedMsgServer) UpdateFlowRate(ctx context.Context, req *MsgUpdateFlowRate) (*MsgUpdateFlowRateResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllStreamsForReceiver 

func (*UnimplementedQueryServer) AllStreamsForReceiver(ctx context.Context, req *QueryAllStreamsForReceiverRequest) (*QueryAllStreamsForReceiverResponse, error)

func (*UnimplementedQueryServer) AllStreamsForSender 

func (*UnimplementedQueryServer) AllStreamsForSender(ctx context.Context, req *QueryAllStreamsForSenderRequest) (*QueryAllStreamsForSenderResponse, error)

func (*UnimplementedQueryServer) CalculateFlowRate 

func (*UnimplementedQueryServer) CalculateFlowRate(ctx context.Context, req *QueryCalculateFlowRateRequest) (*QueryCalculateFlowRateResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) StreamByReceiverSender 

func (*UnimplementedQueryServer) StreamByReceiverSender(ctx context.Context, req *QueryStreamByReceiverSenderRequest) (*QueryStreamByReceiverSenderResponse, error)

func (*UnimplementedQueryServer) StreamReceiverSenderCurrentFlow 

func (*UnimplementedQueryServer) StreamReceiverSenderCurrentFlow(ctx context.Context, req *QueryStreamReceiverSenderCurrentFlowRequest) (*QueryStreamReceiverSenderCurrentFlowResponse, error)

func (*UnimplementedQueryServer) Streams 

func (*UnimplementedQueryServer) Streams(ctx context.Context, req *QueryStreamsRequest) (*QueryStreamsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.