Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyPrefixSteamPayment(p string) []byte
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- func ValidateDuration(d interface{}) error
- func ValidateNextStreamPaymentNumber(n interface{}) error
- func ValidateTimestamp(t interface{}) error
- type AccountKeeper
- type BankKeeper
- type DistributionKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetNextStreamPaymentNumber() uint64
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetStreamPayments() []StreamPayment
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type MsgClaimStreamedAmount
- func (*MsgClaimStreamedAmount) Descriptor() ([]byte, []int)
- func (m *MsgClaimStreamedAmount) GetClaimer() string
- func (msg *MsgClaimStreamedAmount) GetSignBytes() []byte
- func (msg MsgClaimStreamedAmount) GetSigners() []sdk.AccAddress
- func (m *MsgClaimStreamedAmount) GetStreamId() string
- func (m *MsgClaimStreamedAmount) Marshal() (dAtA []byte, err error)
- func (m *MsgClaimStreamedAmount) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgClaimStreamedAmount) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgClaimStreamedAmount) ProtoMessage()
- func (m *MsgClaimStreamedAmount) Reset()
- func (msg MsgClaimStreamedAmount) Route() string
- func (m *MsgClaimStreamedAmount) Size() (n int)
- func (m *MsgClaimStreamedAmount) String() string
- func (msg MsgClaimStreamedAmount) Type() string
- func (m *MsgClaimStreamedAmount) Unmarshal(dAtA []byte) error
- func (msg MsgClaimStreamedAmount) ValidateBasic() error
- func (m *MsgClaimStreamedAmount) XXX_DiscardUnknown()
- func (m *MsgClaimStreamedAmount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgClaimStreamedAmount) XXX_Merge(src proto.Message)
- func (m *MsgClaimStreamedAmount) XXX_Size() int
- func (m *MsgClaimStreamedAmount) XXX_Unmarshal(b []byte) error
- type MsgClaimStreamedAmountResponse
- func (*MsgClaimStreamedAmountResponse) Descriptor() ([]byte, []int)
- func (m *MsgClaimStreamedAmountResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgClaimStreamedAmountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgClaimStreamedAmountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgClaimStreamedAmountResponse) ProtoMessage()
- func (m *MsgClaimStreamedAmountResponse) Reset()
- func (m *MsgClaimStreamedAmountResponse) Size() (n int)
- func (m *MsgClaimStreamedAmountResponse) String() string
- func (m *MsgClaimStreamedAmountResponse) Unmarshal(dAtA []byte) error
- func (m *MsgClaimStreamedAmountResponse) XXX_DiscardUnknown()
- func (m *MsgClaimStreamedAmountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgClaimStreamedAmountResponse) XXX_Merge(src proto.Message)
- func (m *MsgClaimStreamedAmountResponse) XXX_Size() int
- func (m *MsgClaimStreamedAmountResponse) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgServer
- type MsgStopStream
- func (*MsgStopStream) Descriptor() ([]byte, []int)
- func (m *MsgStopStream) GetSender() string
- func (msg *MsgStopStream) GetSignBytes() []byte
- func (msg MsgStopStream) GetSigners() []sdk.AccAddress
- func (m *MsgStopStream) GetStreamId() string
- func (m *MsgStopStream) Marshal() (dAtA []byte, err error)
- func (m *MsgStopStream) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgStopStream) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgStopStream) ProtoMessage()
- func (m *MsgStopStream) Reset()
- func (msg MsgStopStream) Route() string
- func (m *MsgStopStream) Size() (n int)
- func (m *MsgStopStream) String() string
- func (msg MsgStopStream) Type() string
- func (m *MsgStopStream) Unmarshal(dAtA []byte) error
- func (msg MsgStopStream) ValidateBasic() error
- func (m *MsgStopStream) XXX_DiscardUnknown()
- func (m *MsgStopStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgStopStream) XXX_Merge(src proto.Message)
- func (m *MsgStopStream) XXX_Size() int
- func (m *MsgStopStream) XXX_Unmarshal(b []byte) error
- type MsgStopStreamResponse
- func (*MsgStopStreamResponse) Descriptor() ([]byte, []int)
- func (m *MsgStopStreamResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgStopStreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgStopStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgStopStreamResponse) ProtoMessage()
- func (m *MsgStopStreamResponse) Reset()
- func (m *MsgStopStreamResponse) Size() (n int)
- func (m *MsgStopStreamResponse) String() string
- func (m *MsgStopStreamResponse) Unmarshal(dAtA []byte) error
- func (m *MsgStopStreamResponse) XXX_DiscardUnknown()
- func (m *MsgStopStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgStopStreamResponse) XXX_Merge(src proto.Message)
- func (m *MsgStopStreamResponse) XXX_Size() int
- func (m *MsgStopStreamResponse) XXX_Unmarshal(b []byte) error
- type MsgStreamSend
- func (*MsgStreamSend) Descriptor() ([]byte, []int)
- func (m *MsgStreamSend) GetAmount() types.Coin
- func (m *MsgStreamSend) GetCancellable() bool
- func (m *MsgStreamSend) GetDuration() time.Duration
- func (m *MsgStreamSend) GetPaymentFee() types.Coin
- func (m *MsgStreamSend) GetPeriods() []*Period
- func (m *MsgStreamSend) GetRecipient() string
- func (m *MsgStreamSend) GetSender() string
- func (msg *MsgStreamSend) GetSignBytes() []byte
- func (msg MsgStreamSend) GetSigners() []sdk.AccAddress
- func (m *MsgStreamSend) GetStreamType() StreamType
- func (m *MsgStreamSend) Marshal() (dAtA []byte, err error)
- func (m *MsgStreamSend) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgStreamSend) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgStreamSend) ProtoMessage()
- func (m *MsgStreamSend) Reset()
- func (msg MsgStreamSend) Route() string
- func (m *MsgStreamSend) Size() (n int)
- func (m *MsgStreamSend) String() string
- func (msg MsgStreamSend) Type() string
- func (m *MsgStreamSend) Unmarshal(dAtA []byte) error
- func (msg MsgStreamSend) ValidateBasic() error
- func (m *MsgStreamSend) XXX_DiscardUnknown()
- func (m *MsgStreamSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgStreamSend) XXX_Merge(src proto.Message)
- func (m *MsgStreamSend) XXX_Size() int
- func (m *MsgStreamSend) XXX_Unmarshal(b []byte) error
- type MsgStreamSendResponse
- func (*MsgStreamSendResponse) Descriptor() ([]byte, []int)
- func (m *MsgStreamSendResponse) GetStreamId() string
- func (m *MsgStreamSendResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgStreamSendResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgStreamSendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgStreamSendResponse) ProtoMessage()
- func (m *MsgStreamSendResponse) Reset()
- func (m *MsgStreamSendResponse) Size() (n int)
- func (m *MsgStreamSendResponse) String() string
- func (m *MsgStreamSendResponse) Unmarshal(dAtA []byte) error
- func (m *MsgStreamSendResponse) XXX_DiscardUnknown()
- func (m *MsgStreamSendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgStreamSendResponse) XXX_Merge(src proto.Message)
- func (m *MsgStreamSendResponse) XXX_Size() int
- func (m *MsgStreamSendResponse) XXX_Unmarshal(b []byte) error
- type MsgUpdateParams
- func (*MsgUpdateParams) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParams) GetAuthority() string
- func (m *MsgUpdateParams) GetParams() Params
- func (m MsgUpdateParams) GetSignBytes() []byte
- func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParams) ProtoMessage()
- func (m *MsgUpdateParams) Reset()
- func (m *MsgUpdateParams) Size() (n int)
- func (m *MsgUpdateParams) String() string
- func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParams) ValidateBasic() error
- func (m *MsgUpdateParams) XXX_DiscardUnknown()
- func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParams) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParams) XXX_Size() int
- func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error
- type MsgUpdateParamsResponse
- func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParamsResponse) ProtoMessage()
- func (m *MsgUpdateParamsResponse) Reset()
- func (m *MsgUpdateParamsResponse) Size() (n int)
- func (m *MsgUpdateParamsResponse) String() string
- func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParamsResponse) XXX_Size() int
- func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) ValidateBasic() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type Period
- func (*Period) Descriptor() ([]byte, []int)
- func (m *Period) GetAmount() int64
- func (m *Period) GetDuration() int64
- func (m *Period) Marshal() (dAtA []byte, err error)
- func (m *Period) MarshalTo(dAtA []byte) (int, error)
- func (m *Period) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Period) ProtoMessage()
- func (m *Period) Reset()
- func (m *Period) Size() (n int)
- func (m *Period) String() string
- func (m *Period) Unmarshal(dAtA []byte) error
- func (m *Period) XXX_DiscardUnknown()
- func (m *Period) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Period) XXX_Merge(src proto.Message)
- func (m *Period) XXX_Size() int
- func (m *Period) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() *Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QueryStreamPaymentRequest
- func (*QueryStreamPaymentRequest) Descriptor() ([]byte, []int)
- func (m *QueryStreamPaymentRequest) GetId() string
- func (m *QueryStreamPaymentRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamPaymentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamPaymentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamPaymentRequest) ProtoMessage()
- func (m *QueryStreamPaymentRequest) Reset()
- func (m *QueryStreamPaymentRequest) Size() (n int)
- func (m *QueryStreamPaymentRequest) String() string
- func (m *QueryStreamPaymentRequest) Unmarshal(dAtA []byte) error
- func (m *QueryStreamPaymentRequest) XXX_DiscardUnknown()
- func (m *QueryStreamPaymentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamPaymentRequest) XXX_Merge(src proto.Message)
- func (m *QueryStreamPaymentRequest) XXX_Size() int
- func (m *QueryStreamPaymentRequest) XXX_Unmarshal(b []byte) error
- type QueryStreamPaymentResponse
- func (*QueryStreamPaymentResponse) Descriptor() ([]byte, []int)
- func (m *QueryStreamPaymentResponse) GetStreamPayment() *StreamPayment
- func (m *QueryStreamPaymentResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamPaymentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamPaymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamPaymentResponse) ProtoMessage()
- func (m *QueryStreamPaymentResponse) Reset()
- func (m *QueryStreamPaymentResponse) Size() (n int)
- func (m *QueryStreamPaymentResponse) String() string
- func (m *QueryStreamPaymentResponse) Unmarshal(dAtA []byte) error
- func (m *QueryStreamPaymentResponse) XXX_DiscardUnknown()
- func (m *QueryStreamPaymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamPaymentResponse) XXX_Merge(src proto.Message)
- func (m *QueryStreamPaymentResponse) XXX_Size() int
- func (m *QueryStreamPaymentResponse) XXX_Unmarshal(b []byte) error
- type QueryStreamPaymentsRequest
- func (*QueryStreamPaymentsRequest) Descriptor() ([]byte, []int)
- func (m *QueryStreamPaymentsRequest) GetPagination() *query.PageRequest
- func (m *QueryStreamPaymentsRequest) GetRecipient() string
- func (m *QueryStreamPaymentsRequest) GetSender() string
- func (m *QueryStreamPaymentsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamPaymentsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamPaymentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamPaymentsRequest) ProtoMessage()
- func (m *QueryStreamPaymentsRequest) Reset()
- func (m *QueryStreamPaymentsRequest) Size() (n int)
- func (m *QueryStreamPaymentsRequest) String() string
- func (m *QueryStreamPaymentsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryStreamPaymentsRequest) XXX_DiscardUnknown()
- func (m *QueryStreamPaymentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamPaymentsRequest) XXX_Merge(src proto.Message)
- func (m *QueryStreamPaymentsRequest) XXX_Size() int
- func (m *QueryStreamPaymentsRequest) XXX_Unmarshal(b []byte) error
- type QueryStreamPaymentsResponse
- func (*QueryStreamPaymentsResponse) Descriptor() ([]byte, []int)
- func (m *QueryStreamPaymentsResponse) GetPagination() *query.PageResponse
- func (m *QueryStreamPaymentsResponse) GetStreamPayments() []StreamPayment
- func (m *QueryStreamPaymentsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStreamPaymentsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStreamPaymentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStreamPaymentsResponse) ProtoMessage()
- func (m *QueryStreamPaymentsResponse) Reset()
- func (m *QueryStreamPaymentsResponse) Size() (n int)
- func (m *QueryStreamPaymentsResponse) String() string
- func (m *QueryStreamPaymentsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryStreamPaymentsResponse) XXX_DiscardUnknown()
- func (m *QueryStreamPaymentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStreamPaymentsResponse) XXX_Merge(src proto.Message)
- func (m *QueryStreamPaymentsResponse) XXX_Size() int
- func (m *QueryStreamPaymentsResponse) XXX_Unmarshal(b []byte) error
- type StreamPayment
- func (*StreamPayment) Descriptor() ([]byte, []int)
- func (p StreamPayment) GetAmount() string
- func (m *StreamPayment) GetCancellable() bool
- func (m *StreamPayment) GetEndTime() time.Time
- func (m *StreamPayment) GetId() string
- func (m *StreamPayment) GetLastClaimedAt() time.Time
- func (m *StreamPayment) GetPeriods() []*Period
- func (m *StreamPayment) GetRecipient() string
- func (m *StreamPayment) GetSender() string
- func (m *StreamPayment) GetStartTime() time.Time
- func (m *StreamPayment) GetStatus() StreamStatus
- func (m *StreamPayment) GetStreamType() StreamType
- func (m *StreamPayment) GetStreamedAmount() types.Coin
- func (m *StreamPayment) GetTotalAmount() types.Coin
- func (m *StreamPayment) Marshal() (dAtA []byte, err error)
- func (m *StreamPayment) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamPayment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamPayment) ProtoMessage()
- func (m *StreamPayment) Reset()
- func (m *StreamPayment) Size() (n int)
- func (m *StreamPayment) String() string
- func (m *StreamPayment) Unmarshal(dAtA []byte) error
- func (m *StreamPayment) XXX_DiscardUnknown()
- func (m *StreamPayment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamPayment) XXX_Merge(src proto.Message)
- func (m *StreamPayment) XXX_Size() int
- func (m *StreamPayment) XXX_Unmarshal(b []byte) error
- type StreamStatus
- type StreamType
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) ClaimStreamedAmount(ctx context.Context, req *MsgClaimStreamedAmount) (*MsgClaimStreamedAmountResponse, error)
- func (*UnimplementedMsgServer) StopStream(ctx context.Context, req *MsgStopStream) (*MsgStopStreamResponse, error)
- func (*UnimplementedMsgServer) StreamSend(ctx context.Context, req *MsgStreamSend) (*MsgStreamSendResponse, error)
- func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
- func (*UnimplementedQueryServer) StreamingPayment(ctx context.Context, req *QueryStreamPaymentRequest) (*QueryStreamPaymentResponse, error)
- func (*UnimplementedQueryServer) StreamingPayments(ctx context.Context, req *QueryStreamPaymentsRequest) (*QueryStreamPaymentsResponse, error)
Constants ¶
const ( AminoTypeStreamSendMsg = "OmniFlix/streampay/MsgStreamSend" AminoTypeStopStreamMsg = "OmniFlix/streampay/MsgStopStream" AminoTypeClaimStreamedAmountMsg = "OmniFlix/streampay/MsgClaimStream" AminoTypeStreamPayment = "OmniFlix/streampay/StreamPayment" AminoTypeUpdateParamsMsg = "OmniFlix/streampay/MsgUpdateParams" AminoTypeParams = "OmniFlix/streampay/Params" )
const ( EventTypeEndStreamPayment = "end_stream_payment" EventTypeCreateStreamPayment = "create_stream_payment" EventTypeStopStreamPayment = "stop_stream_payment" EventTypeClaimStreamedAmount = "claim_streamed_amount" EventAttributePaymentId = "payment-id" EventAttributeSender = "sender" EventAttributeRecipient = "recipient" EventAttributeClaimer = "claimer" EventAttributeAmount = "amount" EventAttributePaymentType = "payment-type" EventAttributeEndTime = "endtime" EventAttributeReturnedAmount = "returned-amount" EventAttributeStreamedAmount = "streamed-amount" )
const ( // ModuleName defines the module name ModuleName = "streampay" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey is the message route for slashing RouterKey = ModuleName // QuerierRoute defines the module's query routing key QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_streampay" // StreamPaymentPrefix payment streams id prefix StreamPaymentPrefix = "sp" )
const ( MsgRoute = "streampay" TypeMsgStreamSend = "stream_send" TypeMsgStopStream = "stop_stream" TypeMsgClaimStreamedAmount = "claim_streamed_amount" )
const DefaultNextStreamPaymentNumber uint64 = 1
DefaultNextStreamPaymentNumber is the default number for next stream payment
Variables ¶
var ( ErrInvalidAmount = errorsmod.Register(ModuleName, 2, "invalid amount") ErrInvalidStreamPaymentType = errorsmod.Register(ModuleName, 3, "invalid stream payment type") ErrInvalidNextPaymentNumber = errorsmod.Register(ModuleName, 4, "invalid next payment number") ErrInvalidTimestamp = errorsmod.Register(ModuleName, 5, "invalid timestamp") ErrInvalidStreamPaymentFee = errorsmod.Register(ModuleName, 6, "invalid stream payment fee") ErrInvalidFee = errorsmod.Register(ModuleName, 7, "invalid fee") ErrInvalidPeriods = errorsmod.Register(ModuleName, 8, "invalid periods") ErrInvalidDuration = errorsmod.Register(ModuleName, 9, "invalid duration") )
x/streampay module errors
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( PrefixPaymentStreamId = []byte{0x01} PrefixPaymentStreamCount = []byte{0x02} ParamsKey = []byte{0x03} )
var ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthStreampay = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStreampay = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupStreampay = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var DefaultStreamPaymentFeePercentage = sdk.NewDecWithPrec(1, 2) // 1%
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
var StreamStatus_name = map[int32]string{
0: "STREAM_PAYMENT_STATUS_ACTIVE",
1: "STREAM_PAYMENT_STATUS_COMPLETED",
2: "STREAM_PAYMENT_STATUS_CANCELLED",
}
var StreamStatus_value = map[string]int32{
"STREAM_PAYMENT_STATUS_ACTIVE": 0,
"STREAM_PAYMENT_STATUS_COMPLETED": 1,
"STREAM_PAYMENT_STATUS_CANCELLED": 2,
}
var StreamType_name = map[int32]string{
0: "STREAM_PAYMENT_TYPE_DELAYED",
1: "STREAM_PAYMENT_TYPE_CONTINUOUS",
2: "STREAM_PAYMENT_TYPE_PERIODIC",
}
var StreamType_value = map[string]int32{
"STREAM_PAYMENT_TYPE_DELAYED": 0,
"STREAM_PAYMENT_TYPE_CONTINUOUS": 1,
"STREAM_PAYMENT_TYPE_PERIODIC": 2,
}
Functions ¶
func KeyPrefixSteamPayment ¶
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterLegacyAminoCodec ¶
func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
func ValidateDuration ¶
func ValidateDuration(d interface{}) error
func ValidateNextStreamPaymentNumber ¶
func ValidateNextStreamPaymentNumber(n interface{}) error
func ValidateTimestamp ¶
func ValidateTimestamp(t interface{}) error
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 SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins 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 }
BankKeeper Methods imported from bank should be defined here
type DistributionKeeper ¶
type GenesisState ¶
type GenesisState struct { StreamPayments []StreamPayment `protobuf:"bytes,1,rep,name=stream_payments,json=streamPayments,proto3" json:"stream_payments"` NextStreamPaymentNumber uint64 `` /* 135-byte string literal not displayed */ Params Params `protobuf:"bytes,3,opt,name=params,proto3" json:"params"` }
GenesisState defines the streampay module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default Capability genesis state
func NewGenesisState ¶
func NewGenesisState(streams []StreamPayment, nextStreamPaymentNum uint64) *GenesisState
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetNextStreamPaymentNumber ¶
func (m *GenesisState) GetNextStreamPaymentNumber() uint64
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetStreamPayments ¶
func (m *GenesisState) GetStreamPayments() []StreamPayment
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type MsgClaimStreamedAmount ¶
type MsgClaimStreamedAmount struct { StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty" yaml:"stream_id"` Claimer string `protobuf:"bytes,2,opt,name=claimer,proto3" json:"claimer,omitempty"` }
func NewMsgClaimStreamedAmount ¶
func NewMsgClaimStreamedAmount(streamId string, claimer string) *MsgClaimStreamedAmount
func (*MsgClaimStreamedAmount) Descriptor ¶
func (*MsgClaimStreamedAmount) Descriptor() ([]byte, []int)
func (*MsgClaimStreamedAmount) GetClaimer ¶
func (m *MsgClaimStreamedAmount) GetClaimer() string
func (*MsgClaimStreamedAmount) GetSignBytes ¶
func (msg *MsgClaimStreamedAmount) GetSignBytes() []byte
GetSignBytes Implements Msg.
func (MsgClaimStreamedAmount) GetSigners ¶
func (msg MsgClaimStreamedAmount) GetSigners() []sdk.AccAddress
GetSigners Implements Msg.
func (*MsgClaimStreamedAmount) GetStreamId ¶
func (m *MsgClaimStreamedAmount) GetStreamId() string
func (*MsgClaimStreamedAmount) Marshal ¶
func (m *MsgClaimStreamedAmount) Marshal() (dAtA []byte, err error)
func (*MsgClaimStreamedAmount) MarshalTo ¶
func (m *MsgClaimStreamedAmount) MarshalTo(dAtA []byte) (int, error)
func (*MsgClaimStreamedAmount) MarshalToSizedBuffer ¶
func (m *MsgClaimStreamedAmount) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgClaimStreamedAmount) ProtoMessage ¶
func (*MsgClaimStreamedAmount) ProtoMessage()
func (*MsgClaimStreamedAmount) Reset ¶
func (m *MsgClaimStreamedAmount) Reset()
func (MsgClaimStreamedAmount) Route ¶
func (msg MsgClaimStreamedAmount) Route() string
func (*MsgClaimStreamedAmount) Size ¶
func (m *MsgClaimStreamedAmount) Size() (n int)
func (*MsgClaimStreamedAmount) String ¶
func (m *MsgClaimStreamedAmount) String() string
func (MsgClaimStreamedAmount) Type ¶
func (msg MsgClaimStreamedAmount) Type() string
func (*MsgClaimStreamedAmount) Unmarshal ¶
func (m *MsgClaimStreamedAmount) Unmarshal(dAtA []byte) error
func (MsgClaimStreamedAmount) ValidateBasic ¶
func (msg MsgClaimStreamedAmount) ValidateBasic() error
func (*MsgClaimStreamedAmount) XXX_DiscardUnknown ¶
func (m *MsgClaimStreamedAmount) XXX_DiscardUnknown()
func (*MsgClaimStreamedAmount) XXX_Marshal ¶
func (m *MsgClaimStreamedAmount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgClaimStreamedAmount) XXX_Merge ¶
func (m *MsgClaimStreamedAmount) XXX_Merge(src proto.Message)
func (*MsgClaimStreamedAmount) XXX_Size ¶
func (m *MsgClaimStreamedAmount) XXX_Size() int
func (*MsgClaimStreamedAmount) XXX_Unmarshal ¶
func (m *MsgClaimStreamedAmount) XXX_Unmarshal(b []byte) error
type MsgClaimStreamedAmountResponse ¶
type MsgClaimStreamedAmountResponse struct { }
func (*MsgClaimStreamedAmountResponse) Descriptor ¶
func (*MsgClaimStreamedAmountResponse) Descriptor() ([]byte, []int)
func (*MsgClaimStreamedAmountResponse) Marshal ¶
func (m *MsgClaimStreamedAmountResponse) Marshal() (dAtA []byte, err error)
func (*MsgClaimStreamedAmountResponse) MarshalTo ¶
func (m *MsgClaimStreamedAmountResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgClaimStreamedAmountResponse) MarshalToSizedBuffer ¶
func (m *MsgClaimStreamedAmountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgClaimStreamedAmountResponse) ProtoMessage ¶
func (*MsgClaimStreamedAmountResponse) ProtoMessage()
func (*MsgClaimStreamedAmountResponse) Reset ¶
func (m *MsgClaimStreamedAmountResponse) Reset()
func (*MsgClaimStreamedAmountResponse) Size ¶
func (m *MsgClaimStreamedAmountResponse) Size() (n int)
func (*MsgClaimStreamedAmountResponse) String ¶
func (m *MsgClaimStreamedAmountResponse) String() string
func (*MsgClaimStreamedAmountResponse) Unmarshal ¶
func (m *MsgClaimStreamedAmountResponse) Unmarshal(dAtA []byte) error
func (*MsgClaimStreamedAmountResponse) XXX_DiscardUnknown ¶
func (m *MsgClaimStreamedAmountResponse) XXX_DiscardUnknown()
func (*MsgClaimStreamedAmountResponse) XXX_Marshal ¶
func (m *MsgClaimStreamedAmountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgClaimStreamedAmountResponse) XXX_Merge ¶
func (m *MsgClaimStreamedAmountResponse) XXX_Merge(src proto.Message)
func (*MsgClaimStreamedAmountResponse) XXX_Size ¶
func (m *MsgClaimStreamedAmountResponse) XXX_Size() int
func (*MsgClaimStreamedAmountResponse) XXX_Unmarshal ¶
func (m *MsgClaimStreamedAmountResponse) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { StreamSend(ctx context.Context, in *MsgStreamSend, opts ...grpc.CallOption) (*MsgStreamSendResponse, error) StopStream(ctx context.Context, in *MsgStopStream, opts ...grpc.CallOption) (*MsgStopStreamResponse, error) ClaimStreamedAmount(ctx context.Context, in *MsgClaimStreamedAmount, opts ...grpc.CallOption) (*MsgClaimStreamedAmountResponse, error) // UpdateParams defines a governance operation for updating the x/streampay module // parameters. The authority is hard-coded to the x/gov module account. // // 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 MsgServer ¶
type MsgServer interface { StreamSend(context.Context, *MsgStreamSend) (*MsgStreamSendResponse, error) StopStream(context.Context, *MsgStopStream) (*MsgStopStreamResponse, error) ClaimStreamedAmount(context.Context, *MsgClaimStreamedAmount) (*MsgClaimStreamedAmountResponse, error) // UpdateParams defines a governance operation for updating the x/streampay module // parameters. The authority is hard-coded to the x/gov module account. // // Since: cosmos-sdk 0.47 UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error) }
MsgServer is the server API for Msg service.
type MsgStopStream ¶
type MsgStopStream struct { StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty" yaml:"stream_id"` Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` }
func NewMsgStopStream ¶
func NewMsgStopStream(streamId string, sender string) *MsgStopStream
func (*MsgStopStream) Descriptor ¶
func (*MsgStopStream) Descriptor() ([]byte, []int)
func (*MsgStopStream) GetSender ¶
func (m *MsgStopStream) GetSender() string
func (*MsgStopStream) GetSignBytes ¶
func (msg *MsgStopStream) GetSignBytes() []byte
GetSignBytes Implements Msg.
func (MsgStopStream) GetSigners ¶
func (msg MsgStopStream) GetSigners() []sdk.AccAddress
GetSigners Implements Msg.
func (*MsgStopStream) GetStreamId ¶
func (m *MsgStopStream) GetStreamId() string
func (*MsgStopStream) Marshal ¶
func (m *MsgStopStream) Marshal() (dAtA []byte, err error)
func (*MsgStopStream) MarshalToSizedBuffer ¶
func (m *MsgStopStream) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStopStream) ProtoMessage ¶
func (*MsgStopStream) ProtoMessage()
func (*MsgStopStream) Reset ¶
func (m *MsgStopStream) Reset()
func (MsgStopStream) Route ¶
func (msg MsgStopStream) Route() string
func (*MsgStopStream) Size ¶
func (m *MsgStopStream) Size() (n int)
func (*MsgStopStream) String ¶
func (m *MsgStopStream) String() string
func (MsgStopStream) Type ¶
func (msg MsgStopStream) Type() string
func (*MsgStopStream) Unmarshal ¶
func (m *MsgStopStream) Unmarshal(dAtA []byte) error
func (MsgStopStream) ValidateBasic ¶
func (msg MsgStopStream) ValidateBasic() error
func (*MsgStopStream) XXX_DiscardUnknown ¶
func (m *MsgStopStream) XXX_DiscardUnknown()
func (*MsgStopStream) XXX_Marshal ¶
func (m *MsgStopStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStopStream) XXX_Merge ¶
func (m *MsgStopStream) XXX_Merge(src proto.Message)
func (*MsgStopStream) XXX_Size ¶
func (m *MsgStopStream) XXX_Size() int
func (*MsgStopStream) XXX_Unmarshal ¶
func (m *MsgStopStream) XXX_Unmarshal(b []byte) error
type MsgStopStreamResponse ¶
type MsgStopStreamResponse struct { }
func (*MsgStopStreamResponse) Descriptor ¶
func (*MsgStopStreamResponse) Descriptor() ([]byte, []int)
func (*MsgStopStreamResponse) Marshal ¶
func (m *MsgStopStreamResponse) Marshal() (dAtA []byte, err error)
func (*MsgStopStreamResponse) MarshalTo ¶
func (m *MsgStopStreamResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgStopStreamResponse) MarshalToSizedBuffer ¶
func (m *MsgStopStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStopStreamResponse) ProtoMessage ¶
func (*MsgStopStreamResponse) ProtoMessage()
func (*MsgStopStreamResponse) Reset ¶
func (m *MsgStopStreamResponse) Reset()
func (*MsgStopStreamResponse) Size ¶
func (m *MsgStopStreamResponse) Size() (n int)
func (*MsgStopStreamResponse) String ¶
func (m *MsgStopStreamResponse) String() string
func (*MsgStopStreamResponse) Unmarshal ¶
func (m *MsgStopStreamResponse) Unmarshal(dAtA []byte) error
func (*MsgStopStreamResponse) XXX_DiscardUnknown ¶
func (m *MsgStopStreamResponse) XXX_DiscardUnknown()
func (*MsgStopStreamResponse) XXX_Marshal ¶
func (m *MsgStopStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStopStreamResponse) XXX_Merge ¶
func (m *MsgStopStreamResponse) XXX_Merge(src proto.Message)
func (*MsgStopStreamResponse) XXX_Size ¶
func (m *MsgStopStreamResponse) XXX_Size() int
func (*MsgStopStreamResponse) XXX_Unmarshal ¶
func (m *MsgStopStreamResponse) XXX_Unmarshal(b []byte) error
type MsgStreamSend ¶
type MsgStreamSend struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Recipient string `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"` Amount types.Coin `protobuf:"bytes,3,opt,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coin" json:"amount"` Duration time.Duration `protobuf:"bytes,4,opt,name=duration,proto3,stdduration" json:"duration"` StreamType StreamType `` /* 149-byte string literal not displayed */ Periods []*Period `protobuf:"bytes,6,rep,name=periods,proto3" json:"periods,omitempty"` Cancellable bool `protobuf:"varint,7,opt,name=cancellable,proto3" json:"cancellable,omitempty"` PaymentFee types.Coin `` /* 153-byte string literal not displayed */ }
func NewMsgStreamSend ¶
func (*MsgStreamSend) Descriptor ¶
func (*MsgStreamSend) Descriptor() ([]byte, []int)
func (*MsgStreamSend) GetAmount ¶
func (m *MsgStreamSend) GetAmount() types.Coin
func (*MsgStreamSend) GetCancellable ¶
func (m *MsgStreamSend) GetCancellable() bool
func (*MsgStreamSend) GetDuration ¶
func (m *MsgStreamSend) GetDuration() time.Duration
func (*MsgStreamSend) GetPaymentFee ¶ added in v2.3.0
func (m *MsgStreamSend) GetPaymentFee() types.Coin
func (*MsgStreamSend) GetPeriods ¶
func (m *MsgStreamSend) GetPeriods() []*Period
func (*MsgStreamSend) GetRecipient ¶
func (m *MsgStreamSend) GetRecipient() string
func (*MsgStreamSend) GetSender ¶
func (m *MsgStreamSend) GetSender() string
func (*MsgStreamSend) GetSignBytes ¶
func (msg *MsgStreamSend) GetSignBytes() []byte
GetSignBytes Implements Msg.
func (MsgStreamSend) GetSigners ¶
func (msg MsgStreamSend) GetSigners() []sdk.AccAddress
GetSigners Implements Msg.
func (*MsgStreamSend) GetStreamType ¶
func (m *MsgStreamSend) GetStreamType() StreamType
func (*MsgStreamSend) Marshal ¶
func (m *MsgStreamSend) Marshal() (dAtA []byte, err error)
func (*MsgStreamSend) MarshalToSizedBuffer ¶
func (m *MsgStreamSend) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStreamSend) ProtoMessage ¶
func (*MsgStreamSend) ProtoMessage()
func (*MsgStreamSend) Reset ¶
func (m *MsgStreamSend) Reset()
func (MsgStreamSend) Route ¶
func (msg MsgStreamSend) Route() string
func (*MsgStreamSend) Size ¶
func (m *MsgStreamSend) Size() (n int)
func (*MsgStreamSend) String ¶
func (m *MsgStreamSend) String() string
func (MsgStreamSend) Type ¶
func (msg MsgStreamSend) Type() string
func (*MsgStreamSend) Unmarshal ¶
func (m *MsgStreamSend) Unmarshal(dAtA []byte) error
func (MsgStreamSend) ValidateBasic ¶
func (msg MsgStreamSend) ValidateBasic() error
func (*MsgStreamSend) XXX_DiscardUnknown ¶
func (m *MsgStreamSend) XXX_DiscardUnknown()
func (*MsgStreamSend) XXX_Marshal ¶
func (m *MsgStreamSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStreamSend) XXX_Merge ¶
func (m *MsgStreamSend) XXX_Merge(src proto.Message)
func (*MsgStreamSend) XXX_Size ¶
func (m *MsgStreamSend) XXX_Size() int
func (*MsgStreamSend) XXX_Unmarshal ¶
func (m *MsgStreamSend) XXX_Unmarshal(b []byte) error
type MsgStreamSendResponse ¶
type MsgStreamSendResponse struct {
StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty" yaml:"stream_id"`
}
func (*MsgStreamSendResponse) Descriptor ¶
func (*MsgStreamSendResponse) Descriptor() ([]byte, []int)
func (*MsgStreamSendResponse) GetStreamId ¶
func (m *MsgStreamSendResponse) GetStreamId() string
func (*MsgStreamSendResponse) Marshal ¶
func (m *MsgStreamSendResponse) Marshal() (dAtA []byte, err error)
func (*MsgStreamSendResponse) MarshalTo ¶
func (m *MsgStreamSendResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgStreamSendResponse) MarshalToSizedBuffer ¶
func (m *MsgStreamSendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStreamSendResponse) ProtoMessage ¶
func (*MsgStreamSendResponse) ProtoMessage()
func (*MsgStreamSendResponse) Reset ¶
func (m *MsgStreamSendResponse) Reset()
func (*MsgStreamSendResponse) Size ¶
func (m *MsgStreamSendResponse) Size() (n int)
func (*MsgStreamSendResponse) String ¶
func (m *MsgStreamSendResponse) String() string
func (*MsgStreamSendResponse) Unmarshal ¶
func (m *MsgStreamSendResponse) Unmarshal(dAtA []byte) error
func (*MsgStreamSendResponse) XXX_DiscardUnknown ¶
func (m *MsgStreamSendResponse) XXX_DiscardUnknown()
func (*MsgStreamSendResponse) XXX_Marshal ¶
func (m *MsgStreamSendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStreamSendResponse) XXX_Merge ¶
func (m *MsgStreamSendResponse) XXX_Merge(src proto.Message)
func (*MsgStreamSendResponse) XXX_Size ¶
func (m *MsgStreamSendResponse) XXX_Size() int
func (*MsgStreamSendResponse) XXX_Unmarshal ¶
func (m *MsgStreamSendResponse) XXX_Unmarshal(b []byte) error
type MsgUpdateParams ¶
type MsgUpdateParams struct { // authority is the address of the governance account. Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"` // params defines the x/streampay 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 implements the LegacyMsg interface.
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) 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 {
StreamPaymentFeePercentage github_com_cosmos_cosmos_sdk_types.Dec `` /* 220-byte string literal not displayed */
}
func NewStreampayParams ¶
func (*Params) Descriptor ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (Params) ValidateBasic ¶
ValidateBasic performs basic validation on streampay parameters.
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type Period ¶
type Period struct { Amount int64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty" yaml:"amount"` Duration int64 `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty" yaml:"duration"` }
func (*Period) Descriptor ¶
func (*Period) GetDuration ¶
func (*Period) MarshalToSizedBuffer ¶
func (*Period) ProtoMessage ¶
func (*Period) ProtoMessage()
func (*Period) XXX_DiscardUnknown ¶
func (m *Period) XXX_DiscardUnknown()
func (*Period) XXX_Marshal ¶
func (*Period) XXX_Unmarshal ¶
type QueryClient ¶
type QueryClient interface { StreamingPayments(ctx context.Context, in *QueryStreamPaymentsRequest, opts ...grpc.CallOption) (*QueryStreamPaymentsResponse, error) StreamingPayment(ctx context.Context, in *QueryStreamPaymentRequest, opts ...grpc.CallOption) (*QueryStreamPaymentResponse, error) Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 { }
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 *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}
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 { StreamingPayments(context.Context, *QueryStreamPaymentsRequest) (*QueryStreamPaymentsResponse, error) StreamingPayment(context.Context, *QueryStreamPaymentRequest) (*QueryStreamPaymentResponse, error) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) }
QueryServer is the server API for Query service.
type QueryStreamPaymentRequest ¶
type QueryStreamPaymentRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*QueryStreamPaymentRequest) Descriptor ¶
func (*QueryStreamPaymentRequest) Descriptor() ([]byte, []int)
func (*QueryStreamPaymentRequest) GetId ¶
func (m *QueryStreamPaymentRequest) GetId() string
func (*QueryStreamPaymentRequest) Marshal ¶
func (m *QueryStreamPaymentRequest) Marshal() (dAtA []byte, err error)
func (*QueryStreamPaymentRequest) MarshalTo ¶
func (m *QueryStreamPaymentRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamPaymentRequest) MarshalToSizedBuffer ¶
func (m *QueryStreamPaymentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamPaymentRequest) ProtoMessage ¶
func (*QueryStreamPaymentRequest) ProtoMessage()
func (*QueryStreamPaymentRequest) Reset ¶
func (m *QueryStreamPaymentRequest) Reset()
func (*QueryStreamPaymentRequest) Size ¶
func (m *QueryStreamPaymentRequest) Size() (n int)
func (*QueryStreamPaymentRequest) String ¶
func (m *QueryStreamPaymentRequest) String() string
func (*QueryStreamPaymentRequest) Unmarshal ¶
func (m *QueryStreamPaymentRequest) Unmarshal(dAtA []byte) error
func (*QueryStreamPaymentRequest) XXX_DiscardUnknown ¶
func (m *QueryStreamPaymentRequest) XXX_DiscardUnknown()
func (*QueryStreamPaymentRequest) XXX_Marshal ¶
func (m *QueryStreamPaymentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamPaymentRequest) XXX_Merge ¶
func (m *QueryStreamPaymentRequest) XXX_Merge(src proto.Message)
func (*QueryStreamPaymentRequest) XXX_Size ¶
func (m *QueryStreamPaymentRequest) XXX_Size() int
func (*QueryStreamPaymentRequest) XXX_Unmarshal ¶
func (m *QueryStreamPaymentRequest) XXX_Unmarshal(b []byte) error
type QueryStreamPaymentResponse ¶
type QueryStreamPaymentResponse struct {
StreamPayment *StreamPayment `protobuf:"bytes,1,opt,name=stream_payment,json=streamPayment,proto3" json:"stream_payment,omitempty"`
}
func (*QueryStreamPaymentResponse) Descriptor ¶
func (*QueryStreamPaymentResponse) Descriptor() ([]byte, []int)
func (*QueryStreamPaymentResponse) GetStreamPayment ¶
func (m *QueryStreamPaymentResponse) GetStreamPayment() *StreamPayment
func (*QueryStreamPaymentResponse) Marshal ¶
func (m *QueryStreamPaymentResponse) Marshal() (dAtA []byte, err error)
func (*QueryStreamPaymentResponse) MarshalTo ¶
func (m *QueryStreamPaymentResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamPaymentResponse) MarshalToSizedBuffer ¶
func (m *QueryStreamPaymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamPaymentResponse) ProtoMessage ¶
func (*QueryStreamPaymentResponse) ProtoMessage()
func (*QueryStreamPaymentResponse) Reset ¶
func (m *QueryStreamPaymentResponse) Reset()
func (*QueryStreamPaymentResponse) Size ¶
func (m *QueryStreamPaymentResponse) Size() (n int)
func (*QueryStreamPaymentResponse) String ¶
func (m *QueryStreamPaymentResponse) String() string
func (*QueryStreamPaymentResponse) Unmarshal ¶
func (m *QueryStreamPaymentResponse) Unmarshal(dAtA []byte) error
func (*QueryStreamPaymentResponse) XXX_DiscardUnknown ¶
func (m *QueryStreamPaymentResponse) XXX_DiscardUnknown()
func (*QueryStreamPaymentResponse) XXX_Marshal ¶
func (m *QueryStreamPaymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamPaymentResponse) XXX_Merge ¶
func (m *QueryStreamPaymentResponse) XXX_Merge(src proto.Message)
func (*QueryStreamPaymentResponse) XXX_Size ¶
func (m *QueryStreamPaymentResponse) XXX_Size() int
func (*QueryStreamPaymentResponse) XXX_Unmarshal ¶
func (m *QueryStreamPaymentResponse) XXX_Unmarshal(b []byte) error
type QueryStreamPaymentsRequest ¶
type QueryStreamPaymentsRequest struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Recipient string `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryStreamPaymentsRequest) Descriptor ¶
func (*QueryStreamPaymentsRequest) Descriptor() ([]byte, []int)
func (*QueryStreamPaymentsRequest) GetPagination ¶
func (m *QueryStreamPaymentsRequest) GetPagination() *query.PageRequest
func (*QueryStreamPaymentsRequest) GetRecipient ¶
func (m *QueryStreamPaymentsRequest) GetRecipient() string
func (*QueryStreamPaymentsRequest) GetSender ¶
func (m *QueryStreamPaymentsRequest) GetSender() string
func (*QueryStreamPaymentsRequest) Marshal ¶
func (m *QueryStreamPaymentsRequest) Marshal() (dAtA []byte, err error)
func (*QueryStreamPaymentsRequest) MarshalTo ¶
func (m *QueryStreamPaymentsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamPaymentsRequest) MarshalToSizedBuffer ¶
func (m *QueryStreamPaymentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamPaymentsRequest) ProtoMessage ¶
func (*QueryStreamPaymentsRequest) ProtoMessage()
func (*QueryStreamPaymentsRequest) Reset ¶
func (m *QueryStreamPaymentsRequest) Reset()
func (*QueryStreamPaymentsRequest) Size ¶
func (m *QueryStreamPaymentsRequest) Size() (n int)
func (*QueryStreamPaymentsRequest) String ¶
func (m *QueryStreamPaymentsRequest) String() string
func (*QueryStreamPaymentsRequest) Unmarshal ¶
func (m *QueryStreamPaymentsRequest) Unmarshal(dAtA []byte) error
func (*QueryStreamPaymentsRequest) XXX_DiscardUnknown ¶
func (m *QueryStreamPaymentsRequest) XXX_DiscardUnknown()
func (*QueryStreamPaymentsRequest) XXX_Marshal ¶
func (m *QueryStreamPaymentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamPaymentsRequest) XXX_Merge ¶
func (m *QueryStreamPaymentsRequest) XXX_Merge(src proto.Message)
func (*QueryStreamPaymentsRequest) XXX_Size ¶
func (m *QueryStreamPaymentsRequest) XXX_Size() int
func (*QueryStreamPaymentsRequest) XXX_Unmarshal ¶
func (m *QueryStreamPaymentsRequest) XXX_Unmarshal(b []byte) error
type QueryStreamPaymentsResponse ¶
type QueryStreamPaymentsResponse struct { StreamPayments []StreamPayment `protobuf:"bytes,1,rep,name=stream_payments,json=streamPayments,proto3" json:"stream_payments" yaml:"stream_payments"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryStreamPaymentsResponse) Descriptor ¶
func (*QueryStreamPaymentsResponse) Descriptor() ([]byte, []int)
func (*QueryStreamPaymentsResponse) GetPagination ¶
func (m *QueryStreamPaymentsResponse) GetPagination() *query.PageResponse
func (*QueryStreamPaymentsResponse) GetStreamPayments ¶
func (m *QueryStreamPaymentsResponse) GetStreamPayments() []StreamPayment
func (*QueryStreamPaymentsResponse) Marshal ¶
func (m *QueryStreamPaymentsResponse) Marshal() (dAtA []byte, err error)
func (*QueryStreamPaymentsResponse) MarshalTo ¶
func (m *QueryStreamPaymentsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStreamPaymentsResponse) MarshalToSizedBuffer ¶
func (m *QueryStreamPaymentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStreamPaymentsResponse) ProtoMessage ¶
func (*QueryStreamPaymentsResponse) ProtoMessage()
func (*QueryStreamPaymentsResponse) Reset ¶
func (m *QueryStreamPaymentsResponse) Reset()
func (*QueryStreamPaymentsResponse) Size ¶
func (m *QueryStreamPaymentsResponse) Size() (n int)
func (*QueryStreamPaymentsResponse) String ¶
func (m *QueryStreamPaymentsResponse) String() string
func (*QueryStreamPaymentsResponse) Unmarshal ¶
func (m *QueryStreamPaymentsResponse) Unmarshal(dAtA []byte) error
func (*QueryStreamPaymentsResponse) XXX_DiscardUnknown ¶
func (m *QueryStreamPaymentsResponse) XXX_DiscardUnknown()
func (*QueryStreamPaymentsResponse) XXX_Marshal ¶
func (m *QueryStreamPaymentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStreamPaymentsResponse) XXX_Merge ¶
func (m *QueryStreamPaymentsResponse) XXX_Merge(src proto.Message)
func (*QueryStreamPaymentsResponse) XXX_Size ¶
func (m *QueryStreamPaymentsResponse) XXX_Size() int
func (*QueryStreamPaymentsResponse) XXX_Unmarshal ¶
func (m *QueryStreamPaymentsResponse) XXX_Unmarshal(b []byte) error
type StreamPayment ¶
type StreamPayment struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"` TotalAmount types.Coin `` /* 157-byte string literal not displayed */ StreamType StreamType `` /* 149-byte string literal not displayed */ Periods []*Period `protobuf:"bytes,6,rep,name=periods,proto3" json:"periods,omitempty"` Cancellable bool `protobuf:"varint,7,opt,name=cancellable,proto3" json:"cancellable,omitempty"` StartTime time.Time `protobuf:"bytes,8,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"` EndTime time.Time `protobuf:"bytes,9,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"` StreamedAmount types.Coin `` /* 170-byte string literal not displayed */ LastClaimedAt time.Time `protobuf:"bytes,11,opt,name=last_claimed_at,json=lastClaimedAt,proto3,stdtime" json:"last_claimed_at" yaml:"last_claimed_at"` Status StreamStatus `protobuf:"varint,12,opt,name=status,proto3,enum=OmniFlix.streampay.v1.StreamStatus" json:"status,omitempty"` }
func NewStreamPayment ¶
func (*StreamPayment) Descriptor ¶
func (*StreamPayment) Descriptor() ([]byte, []int)
func (StreamPayment) GetAmount ¶
func (p StreamPayment) GetAmount() string
func (*StreamPayment) GetCancellable ¶
func (m *StreamPayment) GetCancellable() bool
func (*StreamPayment) GetEndTime ¶
func (m *StreamPayment) GetEndTime() time.Time
func (*StreamPayment) GetId ¶
func (m *StreamPayment) GetId() string
func (*StreamPayment) GetLastClaimedAt ¶
func (m *StreamPayment) GetLastClaimedAt() time.Time
func (*StreamPayment) GetPeriods ¶
func (m *StreamPayment) GetPeriods() []*Period
func (*StreamPayment) GetRecipient ¶
func (m *StreamPayment) GetRecipient() string
func (*StreamPayment) GetSender ¶
func (m *StreamPayment) GetSender() string
func (*StreamPayment) GetStartTime ¶
func (m *StreamPayment) GetStartTime() time.Time
func (*StreamPayment) GetStatus ¶
func (m *StreamPayment) GetStatus() StreamStatus
func (*StreamPayment) GetStreamType ¶
func (m *StreamPayment) GetStreamType() StreamType
func (*StreamPayment) GetStreamedAmount ¶
func (m *StreamPayment) GetStreamedAmount() types.Coin
func (*StreamPayment) GetTotalAmount ¶
func (m *StreamPayment) GetTotalAmount() types.Coin
func (*StreamPayment) Marshal ¶
func (m *StreamPayment) Marshal() (dAtA []byte, err error)
func (*StreamPayment) MarshalToSizedBuffer ¶
func (m *StreamPayment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamPayment) ProtoMessage ¶
func (*StreamPayment) ProtoMessage()
func (*StreamPayment) Reset ¶
func (m *StreamPayment) Reset()
func (*StreamPayment) Size ¶
func (m *StreamPayment) Size() (n int)
func (*StreamPayment) String ¶
func (m *StreamPayment) String() string
func (*StreamPayment) Unmarshal ¶
func (m *StreamPayment) Unmarshal(dAtA []byte) error
func (*StreamPayment) XXX_DiscardUnknown ¶
func (m *StreamPayment) XXX_DiscardUnknown()
func (*StreamPayment) XXX_Marshal ¶
func (m *StreamPayment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamPayment) XXX_Merge ¶
func (m *StreamPayment) XXX_Merge(src proto.Message)
func (*StreamPayment) XXX_Size ¶
func (m *StreamPayment) XXX_Size() int
func (*StreamPayment) XXX_Unmarshal ¶
func (m *StreamPayment) XXX_Unmarshal(b []byte) error
type StreamStatus ¶
type StreamStatus int32
const ( StatusActive StreamStatus = 0 StatusCompleted StreamStatus = 1 StatusCancelled StreamStatus = 2 )
func (StreamStatus) EnumDescriptor ¶
func (StreamStatus) EnumDescriptor() ([]byte, []int)
func (StreamStatus) String ¶
func (x StreamStatus) String() string
type StreamType ¶
type StreamType int32
const ( TypeDelayed StreamType = 0 TypeContinuous StreamType = 1 TypePeriodic StreamType = 2 )
func (StreamType) EnumDescriptor ¶
func (StreamType) EnumDescriptor() ([]byte, []int)
func (StreamType) String ¶
func (x StreamType) String() string
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) ClaimStreamedAmount ¶
func (*UnimplementedMsgServer) ClaimStreamedAmount(ctx context.Context, req *MsgClaimStreamedAmount) (*MsgClaimStreamedAmountResponse, error)
func (*UnimplementedMsgServer) StopStream ¶
func (*UnimplementedMsgServer) StopStream(ctx context.Context, req *MsgStopStream) (*MsgStopStreamResponse, error)
func (*UnimplementedMsgServer) StreamSend ¶
func (*UnimplementedMsgServer) StreamSend(ctx context.Context, req *MsgStreamSend) (*MsgStreamSendResponse, 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) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
func (*UnimplementedQueryServer) StreamingPayment ¶
func (*UnimplementedQueryServer) StreamingPayment(ctx context.Context, req *QueryStreamPaymentRequest) (*QueryStreamPaymentResponse, error)
func (*UnimplementedQueryServer) StreamingPayments ¶
func (*UnimplementedQueryServer) StreamingPayments(ctx context.Context, req *QueryStreamPaymentsRequest) (*QueryStreamPaymentsResponse, error)