Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func AllocationKey(id uint64, addr sdk.AccAddress) []byte
- func GetAllocationKeyPrefix(id uint64) []byte
- func GetPayoutForAccountKeyPrefix(addr sdk.AccAddress) []byte
- func GetPayoutForNextAtKeyPrefix(at time.Time) []byte
- func GetPayoutForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte
- func GetSubscriptionForAccountKeyPrefix(addr sdk.AccAddress) []byte
- func GetSubscriptionForInactiveAtKeyPrefix(at time.Time) []byte
- func GetSubscriptionForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte
- func GetSubscriptionForPlanKeyPrefix(id uint64) []byte
- func IDFromPayoutForAccountKey(key []byte) uint64
- func IDFromPayoutForNextAtKey(key []byte) uint64
- func IDFromPayoutForNodeKey(key []byte) uint64
- func IDFromSubscriptionForAccountKey(key []byte) uint64
- func IDFromSubscriptionForInactiveAtKey(key []byte) uint64
- func IDFromSubscriptionForNodeKey(key []byte) uint64
- func IDFromSubscriptionForPlanKey(key []byte) uint64
- func NewErrorAllocationNotFound(id uint64, addr sdk.AccAddress) error
- func NewErrorInsufficientBytes(id uint64, bytes sdk.Int) error
- func NewErrorInvalidAllocation(id uint64, addr sdk.AccAddress) error
- func NewErrorInvalidNodeStatus(addr hubtypes.NodeAddress, status hubtypes.Status) error
- func NewErrorInvalidPlanStatus(id uint64, status hubtypes.Status) error
- func NewErrorInvalidSubscriptionStatus(id uint64, status hubtypes.Status) error
- func NewErrorInvalidSubscriptionType(id uint64, t SubscriptionType) error
- func NewErrorNodeNotFound(addr hubtypes.NodeAddress) error
- func NewErrorPlanNotFound(id uint64) error
- func NewErrorPriceNotFound(denom string) error
- func NewErrorSubscriptionNotFound(id uint64) error
- func NewErrorUnauthorized(addr string) error
- func ParamsKeyTable() params.KeyTable
- func PayoutForAccountKey(addr sdk.AccAddress, id uint64) []byte
- func PayoutForNextAtKey(at time.Time, id uint64) []byte
- func PayoutForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte
- func PayoutKey(id uint64) []byte
- func RegisterInterfaces(registry codectypes.InterfaceRegistry)
- func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)
- func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error
- func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error
- func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)
- func SubscriptionForAccountKey(addr sdk.AccAddress, id uint64) []byte
- func SubscriptionForInactiveAtKey(at time.Time, id uint64) []byte
- func SubscriptionForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte
- func SubscriptionForPlanKey(planID, subscriptionID uint64) []byte
- func SubscriptionKey(id uint64) []byte
- func ValidateGenesis(state *GenesisState) error
- type Allocation
- func (*Allocation) Descriptor() ([]byte, []int)
- func (m *Allocation) GetAddress() sdk.AccAddress
- func (m *Allocation) Marshal() (dAtA []byte, err error)
- func (m *Allocation) MarshalTo(dAtA []byte) (int, error)
- func (m *Allocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Allocation) ProtoMessage()
- func (m *Allocation) Reset()
- func (m *Allocation) Size() (n int)
- func (m *Allocation) String() string
- func (m *Allocation) Unmarshal(dAtA []byte) error
- func (m *Allocation) Validate() error
- func (m *Allocation) XXX_DiscardUnknown()
- func (m *Allocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Allocation) XXX_Merge(src proto.Message)
- func (m *Allocation) XXX_Size() int
- func (m *Allocation) XXX_Unmarshal(b []byte) error
- type Allocations
- type BaseSubscription
- func (*BaseSubscription) Descriptor() ([]byte, []int)
- func (s *BaseSubscription) GetAddress() sdk.AccAddress
- func (s *BaseSubscription) GetID() uint64
- func (s *BaseSubscription) GetInactiveAt() time.Time
- func (s *BaseSubscription) GetStatus() hubtypes.Status
- func (s *BaseSubscription) GetStatusAt() time.Time
- func (m *BaseSubscription) Marshal() (dAtA []byte, err error)
- func (m *BaseSubscription) MarshalTo(dAtA []byte) (int, error)
- func (m *BaseSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BaseSubscription) ProtoMessage()
- func (m *BaseSubscription) Reset()
- func (s *BaseSubscription) SetInactiveAt(v time.Time)
- func (s *BaseSubscription) SetStatus(v hubtypes.Status)
- func (s *BaseSubscription) SetStatusAt(v time.Time)
- func (m *BaseSubscription) Size() (n int)
- func (m *BaseSubscription) String() string
- func (m *BaseSubscription) Unmarshal(dAtA []byte) error
- func (s *BaseSubscription) Validate() error
- func (m *BaseSubscription) XXX_DiscardUnknown()
- func (m *BaseSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BaseSubscription) XXX_Merge(src proto.Message)
- func (m *BaseSubscription) XXX_Size() int
- func (m *BaseSubscription) XXX_Unmarshal(b []byte) error
- type EventAllocate
- func (*EventAllocate) Descriptor() ([]byte, []int)
- func (m *EventAllocate) Marshal() (dAtA []byte, err error)
- func (m *EventAllocate) MarshalTo(dAtA []byte) (int, error)
- func (m *EventAllocate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventAllocate) ProtoMessage()
- func (m *EventAllocate) Reset()
- func (m *EventAllocate) Size() (n int)
- func (m *EventAllocate) String() string
- func (m *EventAllocate) Unmarshal(dAtA []byte) error
- func (m *EventAllocate) XXX_DiscardUnknown()
- func (m *EventAllocate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventAllocate) XXX_Merge(src proto.Message)
- func (m *EventAllocate) XXX_Size() int
- func (m *EventAllocate) XXX_Unmarshal(b []byte) error
- type EventPayout
- func (*EventPayout) Descriptor() ([]byte, []int)
- func (m *EventPayout) Marshal() (dAtA []byte, err error)
- func (m *EventPayout) MarshalTo(dAtA []byte) (int, error)
- func (m *EventPayout) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventPayout) ProtoMessage()
- func (m *EventPayout) Reset()
- func (m *EventPayout) Size() (n int)
- func (m *EventPayout) String() string
- func (m *EventPayout) Unmarshal(dAtA []byte) error
- func (m *EventPayout) XXX_DiscardUnknown()
- func (m *EventPayout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventPayout) XXX_Merge(src proto.Message)
- func (m *EventPayout) XXX_Size() int
- func (m *EventPayout) XXX_Unmarshal(b []byte) error
- type EventUpdateStatus
- func (*EventUpdateStatus) Descriptor() ([]byte, []int)
- func (m *EventUpdateStatus) Marshal() (dAtA []byte, err error)
- func (m *EventUpdateStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *EventUpdateStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventUpdateStatus) ProtoMessage()
- func (m *EventUpdateStatus) Reset()
- func (m *EventUpdateStatus) Size() (n int)
- func (m *EventUpdateStatus) String() string
- func (m *EventUpdateStatus) Unmarshal(dAtA []byte) error
- func (m *EventUpdateStatus) XXX_DiscardUnknown()
- func (m *EventUpdateStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventUpdateStatus) XXX_Merge(src proto.Message)
- func (m *EventUpdateStatus) XXX_Size() int
- func (m *EventUpdateStatus) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- 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 (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 GenesisSubscription
- func (*GenesisSubscription) Descriptor() ([]byte, []int)
- func (m *GenesisSubscription) Marshal() (dAtA []byte, err error)
- func (m *GenesisSubscription) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisSubscription) ProtoMessage()
- func (m *GenesisSubscription) Reset()
- func (m *GenesisSubscription) Size() (n int)
- func (m *GenesisSubscription) String() string
- func (m *GenesisSubscription) Unmarshal(dAtA []byte) error
- func (m *GenesisSubscription) XXX_DiscardUnknown()
- func (m *GenesisSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisSubscription) XXX_Merge(src proto.Message)
- func (m *GenesisSubscription) XXX_Size() int
- func (m *GenesisSubscription) XXX_Unmarshal(b []byte) error
- type GenesisSubscriptions
- type MsgAllocateRequest
- func (*MsgAllocateRequest) Descriptor() ([]byte, []int)
- func (m *MsgAllocateRequest) GetSigners() []sdk.AccAddress
- func (m *MsgAllocateRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgAllocateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAllocateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAllocateRequest) ProtoMessage()
- func (m *MsgAllocateRequest) Reset()
- func (m *MsgAllocateRequest) Size() (n int)
- func (m *MsgAllocateRequest) String() string
- func (m *MsgAllocateRequest) Unmarshal(dAtA []byte) error
- func (m *MsgAllocateRequest) ValidateBasic() error
- func (m *MsgAllocateRequest) XXX_DiscardUnknown()
- func (m *MsgAllocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAllocateRequest) XXX_Merge(src proto.Message)
- func (m *MsgAllocateRequest) XXX_Size() int
- func (m *MsgAllocateRequest) XXX_Unmarshal(b []byte) error
- type MsgAllocateResponse
- func (*MsgAllocateResponse) Descriptor() ([]byte, []int)
- func (m *MsgAllocateResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAllocateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAllocateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAllocateResponse) ProtoMessage()
- func (m *MsgAllocateResponse) Reset()
- func (m *MsgAllocateResponse) Size() (n int)
- func (m *MsgAllocateResponse) String() string
- func (m *MsgAllocateResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAllocateResponse) XXX_DiscardUnknown()
- func (m *MsgAllocateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAllocateResponse) XXX_Merge(src proto.Message)
- func (m *MsgAllocateResponse) XXX_Size() int
- func (m *MsgAllocateResponse) XXX_Unmarshal(b []byte) error
- type MsgCancelRequest
- func (*MsgCancelRequest) Descriptor() ([]byte, []int)
- func (m *MsgCancelRequest) GetSigners() []sdk.AccAddress
- func (m *MsgCancelRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgCancelRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCancelRequest) ProtoMessage()
- func (m *MsgCancelRequest) Reset()
- func (m *MsgCancelRequest) Size() (n int)
- func (m *MsgCancelRequest) String() string
- func (m *MsgCancelRequest) Unmarshal(dAtA []byte) error
- func (m *MsgCancelRequest) ValidateBasic() error
- func (m *MsgCancelRequest) XXX_DiscardUnknown()
- func (m *MsgCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCancelRequest) XXX_Merge(src proto.Message)
- func (m *MsgCancelRequest) XXX_Size() int
- func (m *MsgCancelRequest) XXX_Unmarshal(b []byte) error
- type MsgCancelResponse
- func (*MsgCancelResponse) Descriptor() ([]byte, []int)
- func (m *MsgCancelResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCancelResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCancelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCancelResponse) ProtoMessage()
- func (m *MsgCancelResponse) Reset()
- func (m *MsgCancelResponse) Size() (n int)
- func (m *MsgCancelResponse) String() string
- func (m *MsgCancelResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCancelResponse) XXX_DiscardUnknown()
- func (m *MsgCancelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCancelResponse) XXX_Merge(src proto.Message)
- func (m *MsgCancelResponse) XXX_Size() int
- func (m *MsgCancelResponse) XXX_Unmarshal(b []byte) error
- type MsgServiceClient
- type MsgServiceServer
- type NodeSubscription
- func (*NodeSubscription) Descriptor() ([]byte, []int)
- func (s *NodeSubscription) GetNodeAddress() hubtypes.NodeAddress
- func (m *NodeSubscription) Marshal() (dAtA []byte, err error)
- func (m *NodeSubscription) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeSubscription) ProtoMessage()
- func (m *NodeSubscription) Reset()
- func (m *NodeSubscription) Size() (n int)
- func (m *NodeSubscription) String() string
- func (s *NodeSubscription) Type() SubscriptionType
- func (m *NodeSubscription) Unmarshal(dAtA []byte) error
- func (s *NodeSubscription) Validate() error
- func (m *NodeSubscription) XXX_DiscardUnknown()
- func (m *NodeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeSubscription) XXX_Merge(src proto.Message)
- func (m *NodeSubscription) XXX_Size() int
- func (m *NodeSubscription) 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 (m *Params) ParamSetPairs() params.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (m *Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type Payout
- func (*Payout) Descriptor() ([]byte, []int)
- func (p *Payout) GetAddress() sdk.AccAddress
- func (p *Payout) GetNodeAddress() hubtypes.NodeAddress
- func (m *Payout) Marshal() (dAtA []byte, err error)
- func (m *Payout) MarshalTo(dAtA []byte) (int, error)
- func (m *Payout) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Payout) ProtoMessage()
- func (m *Payout) Reset()
- func (m *Payout) Size() (n int)
- func (m *Payout) String() string
- func (m *Payout) Unmarshal(dAtA []byte) error
- func (p *Payout) Validate() error
- func (m *Payout) XXX_DiscardUnknown()
- func (m *Payout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payout) XXX_Merge(src proto.Message)
- func (m *Payout) XXX_Size() int
- func (m *Payout) XXX_Unmarshal(b []byte) error
- type Payouts
- type PlanSubscription
- func (*PlanSubscription) Descriptor() ([]byte, []int)
- func (m *PlanSubscription) Marshal() (dAtA []byte, err error)
- func (m *PlanSubscription) MarshalTo(dAtA []byte) (int, error)
- func (m *PlanSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PlanSubscription) ProtoMessage()
- func (m *PlanSubscription) Reset()
- func (m *PlanSubscription) Size() (n int)
- func (m *PlanSubscription) String() string
- func (s *PlanSubscription) Type() SubscriptionType
- func (m *PlanSubscription) Unmarshal(dAtA []byte) error
- func (s *PlanSubscription) Validate() error
- func (m *PlanSubscription) XXX_DiscardUnknown()
- func (m *PlanSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PlanSubscription) XXX_Merge(src proto.Message)
- func (m *PlanSubscription) XXX_Size() int
- func (m *PlanSubscription) XXX_Unmarshal(b []byte) error
- type QueryAllocationRequest
- func (*QueryAllocationRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllocationRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllocationRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllocationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllocationRequest) ProtoMessage()
- func (m *QueryAllocationRequest) Reset()
- func (m *QueryAllocationRequest) Size() (n int)
- func (m *QueryAllocationRequest) String() string
- func (m *QueryAllocationRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllocationRequest) XXX_DiscardUnknown()
- func (m *QueryAllocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllocationRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllocationRequest) XXX_Size() int
- func (m *QueryAllocationRequest) XXX_Unmarshal(b []byte) error
- type QueryAllocationResponse
- func (*QueryAllocationResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllocationResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllocationResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllocationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllocationResponse) ProtoMessage()
- func (m *QueryAllocationResponse) Reset()
- func (m *QueryAllocationResponse) Size() (n int)
- func (m *QueryAllocationResponse) String() string
- func (m *QueryAllocationResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllocationResponse) XXX_DiscardUnknown()
- func (m *QueryAllocationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllocationResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllocationResponse) XXX_Size() int
- func (m *QueryAllocationResponse) XXX_Unmarshal(b []byte) error
- type QueryAllocationsRequest
- func (*QueryAllocationsRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllocationsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllocationsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllocationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllocationsRequest) ProtoMessage()
- func (m *QueryAllocationsRequest) Reset()
- func (m *QueryAllocationsRequest) Size() (n int)
- func (m *QueryAllocationsRequest) String() string
- func (m *QueryAllocationsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllocationsRequest) XXX_DiscardUnknown()
- func (m *QueryAllocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllocationsRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllocationsRequest) XXX_Size() int
- func (m *QueryAllocationsRequest) XXX_Unmarshal(b []byte) error
- type QueryAllocationsResponse
- func (*QueryAllocationsResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllocationsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllocationsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllocationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllocationsResponse) ProtoMessage()
- func (m *QueryAllocationsResponse) Reset()
- func (m *QueryAllocationsResponse) Size() (n int)
- func (m *QueryAllocationsResponse) String() string
- func (m *QueryAllocationsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllocationsResponse) XXX_DiscardUnknown()
- func (m *QueryAllocationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllocationsResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllocationsResponse) XXX_Size() int
- func (m *QueryAllocationsResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) 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 QueryPayoutRequest
- func (*QueryPayoutRequest) Descriptor() ([]byte, []int)
- func (m *QueryPayoutRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutRequest) ProtoMessage()
- func (m *QueryPayoutRequest) Reset()
- func (m *QueryPayoutRequest) Size() (n int)
- func (m *QueryPayoutRequest) String() string
- func (m *QueryPayoutRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutRequest) XXX_DiscardUnknown()
- func (m *QueryPayoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutRequest) XXX_Merge(src proto.Message)
- func (m *QueryPayoutRequest) XXX_Size() int
- func (m *QueryPayoutRequest) XXX_Unmarshal(b []byte) error
- type QueryPayoutResponse
- func (*QueryPayoutResponse) Descriptor() ([]byte, []int)
- func (m *QueryPayoutResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutResponse) ProtoMessage()
- func (m *QueryPayoutResponse) Reset()
- func (m *QueryPayoutResponse) Size() (n int)
- func (m *QueryPayoutResponse) String() string
- func (m *QueryPayoutResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutResponse) XXX_DiscardUnknown()
- func (m *QueryPayoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutResponse) XXX_Merge(src proto.Message)
- func (m *QueryPayoutResponse) XXX_Size() int
- func (m *QueryPayoutResponse) XXX_Unmarshal(b []byte) error
- type QueryPayoutsForAccountRequest
- func (*QueryPayoutsForAccountRequest) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsForAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsForAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsForAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsForAccountRequest) ProtoMessage()
- func (m *QueryPayoutsForAccountRequest) Reset()
- func (m *QueryPayoutsForAccountRequest) Size() (n int)
- func (m *QueryPayoutsForAccountRequest) String() string
- func (m *QueryPayoutsForAccountRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsForAccountRequest) XXX_DiscardUnknown()
- func (m *QueryPayoutsForAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsForAccountRequest) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsForAccountRequest) XXX_Size() int
- func (m *QueryPayoutsForAccountRequest) XXX_Unmarshal(b []byte) error
- type QueryPayoutsForAccountResponse
- func (*QueryPayoutsForAccountResponse) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsForAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsForAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsForAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsForAccountResponse) ProtoMessage()
- func (m *QueryPayoutsForAccountResponse) Reset()
- func (m *QueryPayoutsForAccountResponse) Size() (n int)
- func (m *QueryPayoutsForAccountResponse) String() string
- func (m *QueryPayoutsForAccountResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsForAccountResponse) XXX_DiscardUnknown()
- func (m *QueryPayoutsForAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsForAccountResponse) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsForAccountResponse) XXX_Size() int
- func (m *QueryPayoutsForAccountResponse) XXX_Unmarshal(b []byte) error
- type QueryPayoutsForNodeRequest
- func (*QueryPayoutsForNodeRequest) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsForNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsForNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsForNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsForNodeRequest) ProtoMessage()
- func (m *QueryPayoutsForNodeRequest) Reset()
- func (m *QueryPayoutsForNodeRequest) Size() (n int)
- func (m *QueryPayoutsForNodeRequest) String() string
- func (m *QueryPayoutsForNodeRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsForNodeRequest) XXX_DiscardUnknown()
- func (m *QueryPayoutsForNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsForNodeRequest) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsForNodeRequest) XXX_Size() int
- func (m *QueryPayoutsForNodeRequest) XXX_Unmarshal(b []byte) error
- type QueryPayoutsForNodeResponse
- func (*QueryPayoutsForNodeResponse) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsForNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsForNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsForNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsForNodeResponse) ProtoMessage()
- func (m *QueryPayoutsForNodeResponse) Reset()
- func (m *QueryPayoutsForNodeResponse) Size() (n int)
- func (m *QueryPayoutsForNodeResponse) String() string
- func (m *QueryPayoutsForNodeResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsForNodeResponse) XXX_DiscardUnknown()
- func (m *QueryPayoutsForNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsForNodeResponse) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsForNodeResponse) XXX_Size() int
- func (m *QueryPayoutsForNodeResponse) XXX_Unmarshal(b []byte) error
- type QueryPayoutsRequest
- func (*QueryPayoutsRequest) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsRequest) ProtoMessage()
- func (m *QueryPayoutsRequest) Reset()
- func (m *QueryPayoutsRequest) Size() (n int)
- func (m *QueryPayoutsRequest) String() string
- func (m *QueryPayoutsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsRequest) XXX_DiscardUnknown()
- func (m *QueryPayoutsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsRequest) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsRequest) XXX_Size() int
- func (m *QueryPayoutsRequest) XXX_Unmarshal(b []byte) error
- type QueryPayoutsResponse
- func (*QueryPayoutsResponse) Descriptor() ([]byte, []int)
- func (m *QueryPayoutsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPayoutsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPayoutsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPayoutsResponse) ProtoMessage()
- func (m *QueryPayoutsResponse) Reset()
- func (m *QueryPayoutsResponse) Size() (n int)
- func (m *QueryPayoutsResponse) String() string
- func (m *QueryPayoutsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPayoutsResponse) XXX_DiscardUnknown()
- func (m *QueryPayoutsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPayoutsResponse) XXX_Merge(src proto.Message)
- func (m *QueryPayoutsResponse) XXX_Size() int
- func (m *QueryPayoutsResponse) XXX_Unmarshal(b []byte) error
- type QueryServiceClient
- type QueryServiceServer
- type QuerySubscriptionRequest
- func (*QuerySubscriptionRequest) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionRequest) ProtoMessage()
- func (m *QuerySubscriptionRequest) Reset()
- func (m *QuerySubscriptionRequest) Size() (n int)
- func (m *QuerySubscriptionRequest) String() string
- func (m *QuerySubscriptionRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionRequest) XXX_DiscardUnknown()
- func (m *QuerySubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionRequest) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionRequest) XXX_Size() int
- func (m *QuerySubscriptionRequest) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionResponse
- func (*QuerySubscriptionResponse) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionResponse) ProtoMessage()
- func (m *QuerySubscriptionResponse) Reset()
- func (m *QuerySubscriptionResponse) Size() (n int)
- func (m *QuerySubscriptionResponse) String() string
- func (m *QuerySubscriptionResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionResponse) XXX_DiscardUnknown()
- func (m *QuerySubscriptionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionResponse) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionResponse) XXX_Size() int
- func (m *QuerySubscriptionResponse) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForAccountRequest
- func (*QuerySubscriptionsForAccountRequest) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForAccountRequest) ProtoMessage()
- func (m *QuerySubscriptionsForAccountRequest) Reset()
- func (m *QuerySubscriptionsForAccountRequest) Size() (n int)
- func (m *QuerySubscriptionsForAccountRequest) String() string
- func (m *QuerySubscriptionsForAccountRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForAccountRequest) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForAccountRequest) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForAccountRequest) XXX_Size() int
- func (m *QuerySubscriptionsForAccountRequest) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForAccountResponse
- func (*QuerySubscriptionsForAccountResponse) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForAccountResponse) ProtoMessage()
- func (m *QuerySubscriptionsForAccountResponse) Reset()
- func (m *QuerySubscriptionsForAccountResponse) Size() (n int)
- func (m *QuerySubscriptionsForAccountResponse) String() string
- func (m *QuerySubscriptionsForAccountResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForAccountResponse) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForAccountResponse) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForAccountResponse) XXX_Size() int
- func (m *QuerySubscriptionsForAccountResponse) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForNodeRequest
- func (*QuerySubscriptionsForNodeRequest) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForNodeRequest) ProtoMessage()
- func (m *QuerySubscriptionsForNodeRequest) Reset()
- func (m *QuerySubscriptionsForNodeRequest) Size() (n int)
- func (m *QuerySubscriptionsForNodeRequest) String() string
- func (m *QuerySubscriptionsForNodeRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForNodeRequest) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForNodeRequest) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForNodeRequest) XXX_Size() int
- func (m *QuerySubscriptionsForNodeRequest) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForNodeResponse
- func (*QuerySubscriptionsForNodeResponse) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForNodeResponse) ProtoMessage()
- func (m *QuerySubscriptionsForNodeResponse) Reset()
- func (m *QuerySubscriptionsForNodeResponse) Size() (n int)
- func (m *QuerySubscriptionsForNodeResponse) String() string
- func (m *QuerySubscriptionsForNodeResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForNodeResponse) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForNodeResponse) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForNodeResponse) XXX_Size() int
- func (m *QuerySubscriptionsForNodeResponse) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForPlanRequest
- func (*QuerySubscriptionsForPlanRequest) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForPlanRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForPlanRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForPlanRequest) ProtoMessage()
- func (m *QuerySubscriptionsForPlanRequest) Reset()
- func (m *QuerySubscriptionsForPlanRequest) Size() (n int)
- func (m *QuerySubscriptionsForPlanRequest) String() string
- func (m *QuerySubscriptionsForPlanRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForPlanRequest) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForPlanRequest) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForPlanRequest) XXX_Size() int
- func (m *QuerySubscriptionsForPlanRequest) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsForPlanResponse
- func (*QuerySubscriptionsForPlanResponse) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsForPlanResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsForPlanResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsForPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsForPlanResponse) ProtoMessage()
- func (m *QuerySubscriptionsForPlanResponse) Reset()
- func (m *QuerySubscriptionsForPlanResponse) Size() (n int)
- func (m *QuerySubscriptionsForPlanResponse) String() string
- func (m *QuerySubscriptionsForPlanResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsForPlanResponse) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsForPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsForPlanResponse) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsForPlanResponse) XXX_Size() int
- func (m *QuerySubscriptionsForPlanResponse) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsRequest
- func (*QuerySubscriptionsRequest) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsRequest) ProtoMessage()
- func (m *QuerySubscriptionsRequest) Reset()
- func (m *QuerySubscriptionsRequest) Size() (n int)
- func (m *QuerySubscriptionsRequest) String() string
- func (m *QuerySubscriptionsRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsRequest) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsRequest) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsRequest) XXX_Size() int
- func (m *QuerySubscriptionsRequest) XXX_Unmarshal(b []byte) error
- type QuerySubscriptionsResponse
- func (*QuerySubscriptionsResponse) Descriptor() ([]byte, []int)
- func (m *QuerySubscriptionsResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySubscriptionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySubscriptionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySubscriptionsResponse) ProtoMessage()
- func (m *QuerySubscriptionsResponse) Reset()
- func (m *QuerySubscriptionsResponse) Size() (n int)
- func (m *QuerySubscriptionsResponse) String() string
- func (m *QuerySubscriptionsResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySubscriptionsResponse) XXX_DiscardUnknown()
- func (m *QuerySubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySubscriptionsResponse) XXX_Merge(src proto.Message)
- func (m *QuerySubscriptionsResponse) XXX_Size() int
- func (m *QuerySubscriptionsResponse) XXX_Unmarshal(b []byte) error
- type Subscription
- type SubscriptionType
- type Subscriptions
- type UnimplementedMsgServiceServer
- type UnimplementedQueryServiceServer
- func (*UnimplementedQueryServiceServer) QueryAllocation(ctx context.Context, req *QueryAllocationRequest) (*QueryAllocationResponse, error)
- func (*UnimplementedQueryServiceServer) QueryAllocations(ctx context.Context, req *QueryAllocationsRequest) (*QueryAllocationsResponse, error)
- func (*UnimplementedQueryServiceServer) QueryParams(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPayout(ctx context.Context, req *QueryPayoutRequest) (*QueryPayoutResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPayouts(ctx context.Context, req *QueryPayoutsRequest) (*QueryPayoutsResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPayoutsForAccount(ctx context.Context, req *QueryPayoutsForAccountRequest) (*QueryPayoutsForAccountResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPayoutsForNode(ctx context.Context, req *QueryPayoutsForNodeRequest) (*QueryPayoutsForNodeResponse, error)
- func (*UnimplementedQueryServiceServer) QuerySubscription(ctx context.Context, req *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error)
- func (*UnimplementedQueryServiceServer) QuerySubscriptions(ctx context.Context, req *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error)
- func (*UnimplementedQueryServiceServer) QuerySubscriptionsForAccount(ctx context.Context, req *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error)
- func (*UnimplementedQueryServiceServer) QuerySubscriptionsForNode(ctx context.Context, req *QuerySubscriptionsForNodeRequest) (*QuerySubscriptionsForNodeResponse, error)
- func (*UnimplementedQueryServiceServer) QuerySubscriptionsForPlan(ctx context.Context, req *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error)
Constants ¶
const ( ModuleName = "subscription" Year = 365.25 * 24 * time.Hour )
Variables ¶
var ( ErrInvalidLengthAllocation = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAllocation = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAllocation = fmt.Errorf("proto: unexpected end of group") )
var ( ErrorInsufficientBytes = errors.Register(ModuleName, 201, "insufficient bytes") ErrorInvalidAllocation = errors.Register(ModuleName, 202, "invalid allocation") ErrorInvalidStatus = errors.Register(ModuleName, 203, "invalid status") ErrorInvalidType = errors.Register(ModuleName, 204, "invalid type") ErrorNotFound = errors.Register(ModuleName, 205, "not found") )
var ( ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( CountKey = []byte{0x00} SubscriptionKeyPrefix = []byte{0x10} SubscriptionForInactiveAtKeyPrefix = []byte{0x11} SubscriptionForAccountKeyPrefix = []byte{0x12} SubscriptionForNodeKeyPrefix = []byte{0x13} SubscriptionForPlanKeyPrefix = []byte{0x14} AllocationKeyPrefix = []byte{0x20} PayoutKeyPrefix = []byte{0x30} PayoutForNextAtKeyPrefix = []byte{0x31} PayoutForAccountKeyPrefix = []byte{0x32} PayoutForNodeKeyPrefix = []byte{0x33} )
var ( ErrInvalidLengthMsg = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMsg = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group") )
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 ( ErrInvalidLengthPayout = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPayout = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPayout = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuerier = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuerier = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthSubscription = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSubscription = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group") )
var (
DefaultStatusChangeDelay = 2 * time.Minute
)
var (
ErrorInvalidMessage = errors.Register(ModuleName, 101, "invalid message")
)
var (
KeyStatusChangeDelay = []byte("StatusChangeDelay")
)
var SubscriptionType_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "TYPE_NODE",
2: "TYPE_PLAN",
}
var SubscriptionType_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"TYPE_NODE": 1,
"TYPE_PLAN": 2,
}
Functions ¶
func AllocationKey ¶ added in v0.11.0
func AllocationKey(id uint64, addr sdk.AccAddress) []byte
func GetAllocationKeyPrefix ¶
func GetPayoutForAccountKeyPrefix ¶ added in v0.11.0
func GetPayoutForAccountKeyPrefix(addr sdk.AccAddress) []byte
func GetPayoutForNextAtKeyPrefix ¶ added in v0.11.0
func GetPayoutForNodeKeyPrefix ¶ added in v0.11.0
func GetPayoutForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte
func GetSubscriptionForAccountKeyPrefix ¶ added in v0.11.0
func GetSubscriptionForAccountKeyPrefix(addr sdk.AccAddress) []byte
func GetSubscriptionForInactiveAtKeyPrefix ¶ added in v0.11.0
func GetSubscriptionForNodeKeyPrefix ¶
func GetSubscriptionForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte
func IDFromPayoutForAccountKey ¶ added in v0.11.0
func IDFromPayoutForNextAtKey ¶ added in v0.11.0
func IDFromPayoutForNodeKey ¶ added in v0.11.0
func IDFromSubscriptionForAccountKey ¶ added in v0.11.0
func IDFromSubscriptionForInactiveAtKey ¶ added in v0.11.0
func IDFromSubscriptionForNodeKey ¶ added in v0.4.0
func IDFromSubscriptionForPlanKey ¶ added in v0.4.0
func NewErrorAllocationNotFound ¶ added in v0.11.0
func NewErrorAllocationNotFound(id uint64, addr sdk.AccAddress) error
func NewErrorInsufficientBytes ¶ added in v0.11.0
func NewErrorInvalidAllocation ¶ added in v0.11.0
func NewErrorInvalidAllocation(id uint64, addr sdk.AccAddress) error
func NewErrorInvalidNodeStatus ¶ added in v0.11.0
func NewErrorInvalidNodeStatus(addr hubtypes.NodeAddress, status hubtypes.Status) error
func NewErrorInvalidPlanStatus ¶ added in v0.11.0
func NewErrorInvalidSubscriptionStatus ¶ added in v0.11.0
func NewErrorInvalidSubscriptionType ¶ added in v0.11.0
func NewErrorInvalidSubscriptionType(id uint64, t SubscriptionType) error
func NewErrorNodeNotFound ¶ added in v0.11.0
func NewErrorNodeNotFound(addr hubtypes.NodeAddress) error
func NewErrorPlanNotFound ¶ added in v0.11.0
func NewErrorPriceNotFound ¶ added in v0.11.0
func NewErrorSubscriptionNotFound ¶ added in v0.11.0
func NewErrorUnauthorized ¶ added in v0.11.0
func ParamsKeyTable ¶
func PayoutForAccountKey ¶ added in v0.11.0
func PayoutForAccountKey(addr sdk.AccAddress, id uint64) []byte
func PayoutForNodeKey ¶ added in v0.11.0
func PayoutForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte
func RegisterInterfaces ¶ added in v0.6.0
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
func RegisterMsgServiceServer ¶ added in v0.6.0
func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)
func RegisterQueryServiceHandler ¶ added in v0.6.0
func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterQueryServiceHandler registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryServiceHandlerClient ¶ added in v0.6.0
func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error
RegisterQueryServiceHandlerClient registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryServiceClient" to call the correct interceptors.
func RegisterQueryServiceHandlerFromEndpoint ¶ added in v0.6.0
func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryServiceHandlerFromEndpoint is same as RegisterQueryServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryServiceHandlerServer ¶ added in v0.6.0
func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error
RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer 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 RegisterQueryServiceHandlerFromEndpoint instead.
func RegisterQueryServiceServer ¶ added in v0.6.0
func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)
func SubscriptionForAccountKey ¶ added in v0.11.0
func SubscriptionForAccountKey(addr sdk.AccAddress, id uint64) []byte
func SubscriptionForInactiveAtKey ¶ added in v0.11.0
func SubscriptionForNodeKey ¶
func SubscriptionForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte
func SubscriptionForPlanKey ¶
func SubscriptionKey ¶
func ValidateGenesis ¶ added in v0.6.0
func ValidateGenesis(state *GenesisState) error
Types ¶
type Allocation ¶ added in v0.11.0
type Allocation struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` GrantedBytes github_com_cosmos_cosmos_sdk_types.Int `` /* 137-byte string literal not displayed */ UtilisedBytes github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */ }
func (*Allocation) Descriptor ¶ added in v0.11.0
func (*Allocation) Descriptor() ([]byte, []int)
func (*Allocation) GetAddress ¶ added in v0.11.0
func (m *Allocation) GetAddress() sdk.AccAddress
func (*Allocation) Marshal ¶ added in v0.11.0
func (m *Allocation) Marshal() (dAtA []byte, err error)
func (*Allocation) MarshalTo ¶ added in v0.11.0
func (m *Allocation) MarshalTo(dAtA []byte) (int, error)
func (*Allocation) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *Allocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Allocation) ProtoMessage ¶ added in v0.11.0
func (*Allocation) ProtoMessage()
func (*Allocation) Reset ¶ added in v0.11.0
func (m *Allocation) Reset()
func (*Allocation) Size ¶ added in v0.11.0
func (m *Allocation) Size() (n int)
func (*Allocation) String ¶ added in v0.11.0
func (m *Allocation) String() string
func (*Allocation) Unmarshal ¶ added in v0.11.0
func (m *Allocation) Unmarshal(dAtA []byte) error
func (*Allocation) Validate ¶ added in v0.11.0
func (m *Allocation) Validate() error
func (*Allocation) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *Allocation) XXX_DiscardUnknown()
func (*Allocation) XXX_Marshal ¶ added in v0.11.0
func (m *Allocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Allocation) XXX_Merge ¶ added in v0.11.0
func (m *Allocation) XXX_Merge(src proto.Message)
func (*Allocation) XXX_Size ¶ added in v0.11.0
func (m *Allocation) XXX_Size() int
func (*Allocation) XXX_Unmarshal ¶ added in v0.11.0
func (m *Allocation) XXX_Unmarshal(b []byte) error
type Allocations ¶ added in v0.11.0
type Allocations []Allocation
type BaseSubscription ¶ added in v0.11.0
type BaseSubscription struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` InactiveAt time.Time `protobuf:"bytes,3,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"` Status types.Status `protobuf:"varint,4,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` StatusAt time.Time `protobuf:"bytes,5,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"` }
func (*BaseSubscription) Descriptor ¶ added in v0.11.0
func (*BaseSubscription) Descriptor() ([]byte, []int)
func (*BaseSubscription) GetAddress ¶ added in v0.11.0
func (s *BaseSubscription) GetAddress() sdk.AccAddress
func (*BaseSubscription) GetID ¶ added in v0.11.0
func (s *BaseSubscription) GetID() uint64
func (*BaseSubscription) GetInactiveAt ¶ added in v0.11.0
func (s *BaseSubscription) GetInactiveAt() time.Time
func (*BaseSubscription) GetStatus ¶ added in v0.11.0
func (s *BaseSubscription) GetStatus() hubtypes.Status
func (*BaseSubscription) GetStatusAt ¶ added in v0.11.0
func (s *BaseSubscription) GetStatusAt() time.Time
func (*BaseSubscription) Marshal ¶ added in v0.11.0
func (m *BaseSubscription) Marshal() (dAtA []byte, err error)
func (*BaseSubscription) MarshalTo ¶ added in v0.11.0
func (m *BaseSubscription) MarshalTo(dAtA []byte) (int, error)
func (*BaseSubscription) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *BaseSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BaseSubscription) ProtoMessage ¶ added in v0.11.0
func (*BaseSubscription) ProtoMessage()
func (*BaseSubscription) Reset ¶ added in v0.11.0
func (m *BaseSubscription) Reset()
func (*BaseSubscription) SetInactiveAt ¶ added in v0.11.0
func (s *BaseSubscription) SetInactiveAt(v time.Time)
func (*BaseSubscription) SetStatus ¶ added in v0.11.0
func (s *BaseSubscription) SetStatus(v hubtypes.Status)
func (*BaseSubscription) SetStatusAt ¶ added in v0.11.0
func (s *BaseSubscription) SetStatusAt(v time.Time)
func (*BaseSubscription) Size ¶ added in v0.11.0
func (m *BaseSubscription) Size() (n int)
func (*BaseSubscription) String ¶ added in v0.11.0
func (m *BaseSubscription) String() string
func (*BaseSubscription) Unmarshal ¶ added in v0.11.0
func (m *BaseSubscription) Unmarshal(dAtA []byte) error
func (*BaseSubscription) Validate ¶ added in v0.11.0
func (s *BaseSubscription) Validate() error
func (*BaseSubscription) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *BaseSubscription) XXX_DiscardUnknown()
func (*BaseSubscription) XXX_Marshal ¶ added in v0.11.0
func (m *BaseSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BaseSubscription) XXX_Merge ¶ added in v0.11.0
func (m *BaseSubscription) XXX_Merge(src proto.Message)
func (*BaseSubscription) XXX_Size ¶ added in v0.11.0
func (m *BaseSubscription) XXX_Size() int
func (*BaseSubscription) XXX_Unmarshal ¶ added in v0.11.0
func (m *BaseSubscription) XXX_Unmarshal(b []byte) error
type EventAllocate ¶ added in v0.11.0
type EventAllocate struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"` Bytes github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"` }
func (*EventAllocate) Descriptor ¶ added in v0.11.0
func (*EventAllocate) Descriptor() ([]byte, []int)
func (*EventAllocate) Marshal ¶ added in v0.11.0
func (m *EventAllocate) Marshal() (dAtA []byte, err error)
func (*EventAllocate) MarshalTo ¶ added in v0.11.0
func (m *EventAllocate) MarshalTo(dAtA []byte) (int, error)
func (*EventAllocate) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *EventAllocate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventAllocate) ProtoMessage ¶ added in v0.11.0
func (*EventAllocate) ProtoMessage()
func (*EventAllocate) Reset ¶ added in v0.11.0
func (m *EventAllocate) Reset()
func (*EventAllocate) Size ¶ added in v0.11.0
func (m *EventAllocate) Size() (n int)
func (*EventAllocate) String ¶ added in v0.11.0
func (m *EventAllocate) String() string
func (*EventAllocate) Unmarshal ¶ added in v0.11.0
func (m *EventAllocate) Unmarshal(dAtA []byte) error
func (*EventAllocate) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *EventAllocate) XXX_DiscardUnknown()
func (*EventAllocate) XXX_Marshal ¶ added in v0.11.0
func (m *EventAllocate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventAllocate) XXX_Merge ¶ added in v0.11.0
func (m *EventAllocate) XXX_Merge(src proto.Message)
func (*EventAllocate) XXX_Size ¶ added in v0.11.0
func (m *EventAllocate) XXX_Size() int
func (*EventAllocate) XXX_Unmarshal ¶ added in v0.11.0
func (m *EventAllocate) XXX_Unmarshal(b []byte) error
type EventPayout ¶ added in v0.11.0
type EventPayout struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"` NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"` }
func (*EventPayout) Descriptor ¶ added in v0.11.0
func (*EventPayout) Descriptor() ([]byte, []int)
func (*EventPayout) Marshal ¶ added in v0.11.0
func (m *EventPayout) Marshal() (dAtA []byte, err error)
func (*EventPayout) MarshalTo ¶ added in v0.11.0
func (m *EventPayout) MarshalTo(dAtA []byte) (int, error)
func (*EventPayout) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *EventPayout) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventPayout) ProtoMessage ¶ added in v0.11.0
func (*EventPayout) ProtoMessage()
func (*EventPayout) Reset ¶ added in v0.11.0
func (m *EventPayout) Reset()
func (*EventPayout) Size ¶ added in v0.11.0
func (m *EventPayout) Size() (n int)
func (*EventPayout) String ¶ added in v0.11.0
func (m *EventPayout) String() string
func (*EventPayout) Unmarshal ¶ added in v0.11.0
func (m *EventPayout) Unmarshal(dAtA []byte) error
func (*EventPayout) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *EventPayout) XXX_DiscardUnknown()
func (*EventPayout) XXX_Marshal ¶ added in v0.11.0
func (m *EventPayout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventPayout) XXX_Merge ¶ added in v0.11.0
func (m *EventPayout) XXX_Merge(src proto.Message)
func (*EventPayout) XXX_Size ¶ added in v0.11.0
func (m *EventPayout) XXX_Size() int
func (*EventPayout) XXX_Unmarshal ¶ added in v0.11.0
func (m *EventPayout) XXX_Unmarshal(b []byte) error
type EventUpdateStatus ¶ added in v0.11.0
type EventUpdateStatus struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"` Status types.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"` }
func (*EventUpdateStatus) Descriptor ¶ added in v0.11.0
func (*EventUpdateStatus) Descriptor() ([]byte, []int)
func (*EventUpdateStatus) Marshal ¶ added in v0.11.0
func (m *EventUpdateStatus) Marshal() (dAtA []byte, err error)
func (*EventUpdateStatus) MarshalTo ¶ added in v0.11.0
func (m *EventUpdateStatus) MarshalTo(dAtA []byte) (int, error)
func (*EventUpdateStatus) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *EventUpdateStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventUpdateStatus) ProtoMessage ¶ added in v0.11.0
func (*EventUpdateStatus) ProtoMessage()
func (*EventUpdateStatus) Reset ¶ added in v0.11.0
func (m *EventUpdateStatus) Reset()
func (*EventUpdateStatus) Size ¶ added in v0.11.0
func (m *EventUpdateStatus) Size() (n int)
func (*EventUpdateStatus) String ¶ added in v0.11.0
func (m *EventUpdateStatus) String() string
func (*EventUpdateStatus) Unmarshal ¶ added in v0.11.0
func (m *EventUpdateStatus) Unmarshal(dAtA []byte) error
func (*EventUpdateStatus) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *EventUpdateStatus) XXX_DiscardUnknown()
func (*EventUpdateStatus) XXX_Marshal ¶ added in v0.11.0
func (m *EventUpdateStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventUpdateStatus) XXX_Merge ¶ added in v0.11.0
func (m *EventUpdateStatus) XXX_Merge(src proto.Message)
func (*EventUpdateStatus) XXX_Size ¶ added in v0.11.0
func (m *EventUpdateStatus) XXX_Size() int
func (*EventUpdateStatus) XXX_Unmarshal ¶ added in v0.11.0
func (m *EventUpdateStatus) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { Subscriptions []GenesisSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"` Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"` }
func DefaultGenesisState ¶
func DefaultGenesisState() *GenesisState
func NewGenesisState ¶
func NewGenesisState(subscriptions GenesisSubscriptions, params Params) *GenesisState
func (*GenesisState) Descriptor ¶ added in v0.6.0
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) Marshal ¶ added in v0.6.0
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalTo ¶ added in v0.6.0
func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
func (*GenesisState) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶ added in v0.6.0
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶ added in v0.6.0
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶ added in v0.6.0
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶ added in v0.6.0
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶ added in v0.6.0
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (*GenesisState) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶ added in v0.6.0
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶ added in v0.6.0
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶ added in v0.6.0
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶ added in v0.6.0
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type GenesisSubscription ¶
type GenesisSubscription struct { Subscription *types.Any `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` Allocations []Allocation `protobuf:"bytes,2,rep,name=allocations,proto3" json:"allocations"` }
func (*GenesisSubscription) Descriptor ¶ added in v0.6.0
func (*GenesisSubscription) Descriptor() ([]byte, []int)
func (*GenesisSubscription) Marshal ¶ added in v0.6.0
func (m *GenesisSubscription) Marshal() (dAtA []byte, err error)
func (*GenesisSubscription) MarshalTo ¶ added in v0.6.0
func (m *GenesisSubscription) MarshalTo(dAtA []byte) (int, error)
func (*GenesisSubscription) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *GenesisSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisSubscription) ProtoMessage ¶ added in v0.6.0
func (*GenesisSubscription) ProtoMessage()
func (*GenesisSubscription) Reset ¶ added in v0.6.0
func (m *GenesisSubscription) Reset()
func (*GenesisSubscription) Size ¶ added in v0.6.0
func (m *GenesisSubscription) Size() (n int)
func (*GenesisSubscription) String ¶ added in v0.6.0
func (m *GenesisSubscription) String() string
func (*GenesisSubscription) Unmarshal ¶ added in v0.6.0
func (m *GenesisSubscription) Unmarshal(dAtA []byte) error
func (*GenesisSubscription) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *GenesisSubscription) XXX_DiscardUnknown()
func (*GenesisSubscription) XXX_Marshal ¶ added in v0.6.0
func (m *GenesisSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisSubscription) XXX_Merge ¶ added in v0.6.0
func (m *GenesisSubscription) XXX_Merge(src proto.Message)
func (*GenesisSubscription) XXX_Size ¶ added in v0.6.0
func (m *GenesisSubscription) XXX_Size() int
func (*GenesisSubscription) XXX_Unmarshal ¶ added in v0.6.0
func (m *GenesisSubscription) XXX_Unmarshal(b []byte) error
type GenesisSubscriptions ¶
type GenesisSubscriptions []GenesisSubscription
type MsgAllocateRequest ¶ added in v0.11.0
type MsgAllocateRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` Bytes github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,4,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"` }
MsgAllocateRequest defines the SDK message for allocating the bytes of a subscription for an address
func NewMsgAllocateRequest ¶ added in v0.11.0
func NewMsgAllocateRequest(from sdk.AccAddress, id uint64, addr sdk.AccAddress, bytes sdk.Int) *MsgAllocateRequest
NewMsgAllocateRequest creates a new MsgAllocateRequest instance with the given parameters.
func (*MsgAllocateRequest) Descriptor ¶ added in v0.11.0
func (*MsgAllocateRequest) Descriptor() ([]byte, []int)
func (*MsgAllocateRequest) GetSigners ¶ added in v0.11.0
func (m *MsgAllocateRequest) GetSigners() []sdk.AccAddress
GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgAllocateRequest.
func (*MsgAllocateRequest) Marshal ¶ added in v0.11.0
func (m *MsgAllocateRequest) Marshal() (dAtA []byte, err error)
func (*MsgAllocateRequest) MarshalTo ¶ added in v0.11.0
func (m *MsgAllocateRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgAllocateRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *MsgAllocateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAllocateRequest) ProtoMessage ¶ added in v0.11.0
func (*MsgAllocateRequest) ProtoMessage()
func (*MsgAllocateRequest) Reset ¶ added in v0.11.0
func (m *MsgAllocateRequest) Reset()
func (*MsgAllocateRequest) Size ¶ added in v0.11.0
func (m *MsgAllocateRequest) Size() (n int)
func (*MsgAllocateRequest) String ¶ added in v0.11.0
func (m *MsgAllocateRequest) String() string
func (*MsgAllocateRequest) Unmarshal ¶ added in v0.11.0
func (m *MsgAllocateRequest) Unmarshal(dAtA []byte) error
func (*MsgAllocateRequest) ValidateBasic ¶ added in v0.11.0
func (m *MsgAllocateRequest) ValidateBasic() error
ValidateBasic performs basic validation checks on the MsgAllocateRequest fields. It checks if the 'From' field is not empty and represents a valid account address, if the 'ID' field is not zero, if the 'Address' field is not empty and represents a valid account address, and if the 'Bytes' field is not nil and not negative.
func (*MsgAllocateRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *MsgAllocateRequest) XXX_DiscardUnknown()
func (*MsgAllocateRequest) XXX_Marshal ¶ added in v0.11.0
func (m *MsgAllocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAllocateRequest) XXX_Merge ¶ added in v0.11.0
func (m *MsgAllocateRequest) XXX_Merge(src proto.Message)
func (*MsgAllocateRequest) XXX_Size ¶ added in v0.11.0
func (m *MsgAllocateRequest) XXX_Size() int
func (*MsgAllocateRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *MsgAllocateRequest) XXX_Unmarshal(b []byte) error
type MsgAllocateResponse ¶ added in v0.11.0
type MsgAllocateResponse struct { }
MsgAllocateResponse defines the response of message MsgAllocateRequest
func (*MsgAllocateResponse) Descriptor ¶ added in v0.11.0
func (*MsgAllocateResponse) Descriptor() ([]byte, []int)
func (*MsgAllocateResponse) Marshal ¶ added in v0.11.0
func (m *MsgAllocateResponse) Marshal() (dAtA []byte, err error)
func (*MsgAllocateResponse) MarshalTo ¶ added in v0.11.0
func (m *MsgAllocateResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAllocateResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *MsgAllocateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAllocateResponse) ProtoMessage ¶ added in v0.11.0
func (*MsgAllocateResponse) ProtoMessage()
func (*MsgAllocateResponse) Reset ¶ added in v0.11.0
func (m *MsgAllocateResponse) Reset()
func (*MsgAllocateResponse) Size ¶ added in v0.11.0
func (m *MsgAllocateResponse) Size() (n int)
func (*MsgAllocateResponse) String ¶ added in v0.11.0
func (m *MsgAllocateResponse) String() string
func (*MsgAllocateResponse) Unmarshal ¶ added in v0.11.0
func (m *MsgAllocateResponse) Unmarshal(dAtA []byte) error
func (*MsgAllocateResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *MsgAllocateResponse) XXX_DiscardUnknown()
func (*MsgAllocateResponse) XXX_Marshal ¶ added in v0.11.0
func (m *MsgAllocateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAllocateResponse) XXX_Merge ¶ added in v0.11.0
func (m *MsgAllocateResponse) XXX_Merge(src proto.Message)
func (*MsgAllocateResponse) XXX_Size ¶ added in v0.11.0
func (m *MsgAllocateResponse) XXX_Size() int
func (*MsgAllocateResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *MsgAllocateResponse) XXX_Unmarshal(b []byte) error
type MsgCancelRequest ¶ added in v0.6.0
type MsgCancelRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` }
MsgCancelRequest defines the SDK message for cancelling a subscription
func NewMsgCancelRequest ¶ added in v0.6.0
func NewMsgCancelRequest(from sdk.AccAddress, id uint64) *MsgCancelRequest
NewMsgCancelRequest creates a new MsgCancelRequest instance with the given parameters.
func (*MsgCancelRequest) Descriptor ¶ added in v0.6.0
func (*MsgCancelRequest) Descriptor() ([]byte, []int)
func (*MsgCancelRequest) GetSigners ¶ added in v0.6.0
func (m *MsgCancelRequest) GetSigners() []sdk.AccAddress
GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgCancelRequest.
func (*MsgCancelRequest) Marshal ¶ added in v0.6.0
func (m *MsgCancelRequest) Marshal() (dAtA []byte, err error)
func (*MsgCancelRequest) MarshalTo ¶ added in v0.6.0
func (m *MsgCancelRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgCancelRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCancelRequest) ProtoMessage ¶ added in v0.6.0
func (*MsgCancelRequest) ProtoMessage()
func (*MsgCancelRequest) Reset ¶ added in v0.6.0
func (m *MsgCancelRequest) Reset()
func (*MsgCancelRequest) Size ¶ added in v0.6.0
func (m *MsgCancelRequest) Size() (n int)
func (*MsgCancelRequest) String ¶ added in v0.6.0
func (m *MsgCancelRequest) String() string
func (*MsgCancelRequest) Unmarshal ¶ added in v0.6.0
func (m *MsgCancelRequest) Unmarshal(dAtA []byte) error
func (*MsgCancelRequest) ValidateBasic ¶ added in v0.6.0
func (m *MsgCancelRequest) ValidateBasic() error
ValidateBasic performs basic validation checks on the MsgCancelRequest fields. It checks if the 'From' field is not empty and represents a valid account address, and if the 'ID' field is not zero.
func (*MsgCancelRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgCancelRequest) XXX_DiscardUnknown()
func (*MsgCancelRequest) XXX_Marshal ¶ added in v0.6.0
func (m *MsgCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCancelRequest) XXX_Merge ¶ added in v0.6.0
func (m *MsgCancelRequest) XXX_Merge(src proto.Message)
func (*MsgCancelRequest) XXX_Size ¶ added in v0.6.0
func (m *MsgCancelRequest) XXX_Size() int
func (*MsgCancelRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgCancelRequest) XXX_Unmarshal(b []byte) error
type MsgCancelResponse ¶ added in v0.6.0
type MsgCancelResponse struct { }
MsgCancelResponse defines the response of message MsgCancelRequest
func (*MsgCancelResponse) Descriptor ¶ added in v0.6.0
func (*MsgCancelResponse) Descriptor() ([]byte, []int)
func (*MsgCancelResponse) Marshal ¶ added in v0.6.0
func (m *MsgCancelResponse) Marshal() (dAtA []byte, err error)
func (*MsgCancelResponse) MarshalTo ¶ added in v0.6.0
func (m *MsgCancelResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCancelResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgCancelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCancelResponse) ProtoMessage ¶ added in v0.6.0
func (*MsgCancelResponse) ProtoMessage()
func (*MsgCancelResponse) Reset ¶ added in v0.6.0
func (m *MsgCancelResponse) Reset()
func (*MsgCancelResponse) Size ¶ added in v0.6.0
func (m *MsgCancelResponse) Size() (n int)
func (*MsgCancelResponse) String ¶ added in v0.6.0
func (m *MsgCancelResponse) String() string
func (*MsgCancelResponse) Unmarshal ¶ added in v0.6.0
func (m *MsgCancelResponse) Unmarshal(dAtA []byte) error
func (*MsgCancelResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgCancelResponse) XXX_DiscardUnknown()
func (*MsgCancelResponse) XXX_Marshal ¶ added in v0.6.0
func (m *MsgCancelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCancelResponse) XXX_Merge ¶ added in v0.6.0
func (m *MsgCancelResponse) XXX_Merge(src proto.Message)
func (*MsgCancelResponse) XXX_Size ¶ added in v0.6.0
func (m *MsgCancelResponse) XXX_Size() int
func (*MsgCancelResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgCancelResponse) XXX_Unmarshal(b []byte) error
type MsgServiceClient ¶ added in v0.6.0
type MsgServiceClient interface { MsgCancel(ctx context.Context, in *MsgCancelRequest, opts ...grpc.CallOption) (*MsgCancelResponse, error) MsgAllocate(ctx context.Context, in *MsgAllocateRequest, opts ...grpc.CallOption) (*MsgAllocateResponse, error) }
MsgServiceClient is the client API for MsgService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgServiceClient ¶ added in v0.6.0
func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient
type MsgServiceServer ¶ added in v0.6.0
type MsgServiceServer interface { MsgCancel(context.Context, *MsgCancelRequest) (*MsgCancelResponse, error) MsgAllocate(context.Context, *MsgAllocateRequest) (*MsgAllocateResponse, error) }
MsgServiceServer is the server API for MsgService service.
type NodeSubscription ¶ added in v0.11.0
type NodeSubscription struct { *BaseSubscription `protobuf:"bytes,1,opt,name=base,proto3,embedded=base" json:"base,omitempty"` NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"` Gigabytes int64 `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"` Hours int64 `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"` Deposit types1.Coin `protobuf:"bytes,5,opt,name=deposit,proto3" json:"deposit"` }
func (*NodeSubscription) Descriptor ¶ added in v0.11.0
func (*NodeSubscription) Descriptor() ([]byte, []int)
func (*NodeSubscription) GetNodeAddress ¶ added in v0.11.0
func (s *NodeSubscription) GetNodeAddress() hubtypes.NodeAddress
func (*NodeSubscription) Marshal ¶ added in v0.11.0
func (m *NodeSubscription) Marshal() (dAtA []byte, err error)
func (*NodeSubscription) MarshalTo ¶ added in v0.11.0
func (m *NodeSubscription) MarshalTo(dAtA []byte) (int, error)
func (*NodeSubscription) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *NodeSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeSubscription) ProtoMessage ¶ added in v0.11.0
func (*NodeSubscription) ProtoMessage()
func (*NodeSubscription) Reset ¶ added in v0.11.0
func (m *NodeSubscription) Reset()
func (*NodeSubscription) Size ¶ added in v0.11.0
func (m *NodeSubscription) Size() (n int)
func (*NodeSubscription) String ¶ added in v0.11.0
func (m *NodeSubscription) String() string
func (*NodeSubscription) Type ¶ added in v0.11.0
func (s *NodeSubscription) Type() SubscriptionType
func (*NodeSubscription) Unmarshal ¶ added in v0.11.0
func (m *NodeSubscription) Unmarshal(dAtA []byte) error
func (*NodeSubscription) Validate ¶ added in v0.11.0
func (s *NodeSubscription) Validate() error
func (*NodeSubscription) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *NodeSubscription) XXX_DiscardUnknown()
func (*NodeSubscription) XXX_Marshal ¶ added in v0.11.0
func (m *NodeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeSubscription) XXX_Merge ¶ added in v0.11.0
func (m *NodeSubscription) XXX_Merge(src proto.Message)
func (*NodeSubscription) XXX_Size ¶ added in v0.11.0
func (m *NodeSubscription) XXX_Size() int
func (*NodeSubscription) XXX_Unmarshal ¶ added in v0.11.0
func (m *NodeSubscription) XXX_Unmarshal(b []byte) error
type Params ¶
type Params struct {
StatusChangeDelay time.Duration `protobuf:"bytes,1,opt,name=status_change_delay,json=statusChangeDelay,proto3,stdduration" json:"status_change_delay"`
}
func DefaultParams ¶
func DefaultParams() Params
func (*Params) Descriptor ¶ added in v0.6.0
func (*Params) MarshalToSizedBuffer ¶ added in v0.6.0
func (*Params) ParamSetPairs ¶
func (m *Params) ParamSetPairs() params.ParamSetPairs
func (*Params) ProtoMessage ¶ added in v0.6.0
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶ added in v0.6.0
func (*Params) XXX_Unmarshal ¶ added in v0.6.0
type Payout ¶ added in v0.11.0
type Payout struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"` Hours int64 `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"` Price types.Coin `protobuf:"bytes,5,opt,name=price,proto3" json:"price"` NextAt time.Time `protobuf:"bytes,6,opt,name=next_at,json=nextAt,proto3,stdtime" json:"next_at"` }
func (*Payout) Descriptor ¶ added in v0.11.0
func (*Payout) GetAddress ¶ added in v0.11.0
func (p *Payout) GetAddress() sdk.AccAddress
func (*Payout) GetNodeAddress ¶ added in v0.11.0
func (p *Payout) GetNodeAddress() hubtypes.NodeAddress
func (*Payout) MarshalToSizedBuffer ¶ added in v0.11.0
func (*Payout) ProtoMessage ¶ added in v0.11.0
func (*Payout) ProtoMessage()
func (*Payout) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *Payout) XXX_DiscardUnknown()
func (*Payout) XXX_Marshal ¶ added in v0.11.0
func (*Payout) XXX_Unmarshal ¶ added in v0.11.0
type PlanSubscription ¶ added in v0.11.0
type PlanSubscription struct { *BaseSubscription `protobuf:"bytes,1,opt,name=base,proto3,embedded=base" json:"base,omitempty"` PlanID uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"` Denom string `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"` }
func (*PlanSubscription) Descriptor ¶ added in v0.11.0
func (*PlanSubscription) Descriptor() ([]byte, []int)
func (*PlanSubscription) Marshal ¶ added in v0.11.0
func (m *PlanSubscription) Marshal() (dAtA []byte, err error)
func (*PlanSubscription) MarshalTo ¶ added in v0.11.0
func (m *PlanSubscription) MarshalTo(dAtA []byte) (int, error)
func (*PlanSubscription) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *PlanSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PlanSubscription) ProtoMessage ¶ added in v0.11.0
func (*PlanSubscription) ProtoMessage()
func (*PlanSubscription) Reset ¶ added in v0.11.0
func (m *PlanSubscription) Reset()
func (*PlanSubscription) Size ¶ added in v0.11.0
func (m *PlanSubscription) Size() (n int)
func (*PlanSubscription) String ¶ added in v0.11.0
func (m *PlanSubscription) String() string
func (*PlanSubscription) Type ¶ added in v0.11.0
func (s *PlanSubscription) Type() SubscriptionType
func (*PlanSubscription) Unmarshal ¶ added in v0.11.0
func (m *PlanSubscription) Unmarshal(dAtA []byte) error
func (*PlanSubscription) Validate ¶ added in v0.11.0
func (s *PlanSubscription) Validate() error
func (*PlanSubscription) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *PlanSubscription) XXX_DiscardUnknown()
func (*PlanSubscription) XXX_Marshal ¶ added in v0.11.0
func (m *PlanSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PlanSubscription) XXX_Merge ¶ added in v0.11.0
func (m *PlanSubscription) XXX_Merge(src proto.Message)
func (*PlanSubscription) XXX_Size ¶ added in v0.11.0
func (m *PlanSubscription) XXX_Size() int
func (*PlanSubscription) XXX_Unmarshal ¶ added in v0.11.0
func (m *PlanSubscription) XXX_Unmarshal(b []byte) error
type QueryAllocationRequest ¶ added in v0.11.0
type QueryAllocationRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` }
func NewQueryAllocationRequest ¶ added in v0.11.0
func NewQueryAllocationRequest(id uint64, addr sdk.AccAddress) *QueryAllocationRequest
func (*QueryAllocationRequest) Descriptor ¶ added in v0.11.0
func (*QueryAllocationRequest) Descriptor() ([]byte, []int)
func (*QueryAllocationRequest) Marshal ¶ added in v0.11.0
func (m *QueryAllocationRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllocationRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryAllocationRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllocationRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryAllocationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllocationRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryAllocationRequest) ProtoMessage()
func (*QueryAllocationRequest) Reset ¶ added in v0.11.0
func (m *QueryAllocationRequest) Reset()
func (*QueryAllocationRequest) Size ¶ added in v0.11.0
func (m *QueryAllocationRequest) Size() (n int)
func (*QueryAllocationRequest) String ¶ added in v0.11.0
func (m *QueryAllocationRequest) String() string
func (*QueryAllocationRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationRequest) Unmarshal(dAtA []byte) error
func (*QueryAllocationRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryAllocationRequest) XXX_DiscardUnknown()
func (*QueryAllocationRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryAllocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllocationRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryAllocationRequest) XXX_Merge(src proto.Message)
func (*QueryAllocationRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryAllocationRequest) XXX_Size() int
func (*QueryAllocationRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationRequest) XXX_Unmarshal(b []byte) error
type QueryAllocationResponse ¶ added in v0.11.0
type QueryAllocationResponse struct {
Allocation Allocation `protobuf:"bytes,1,opt,name=allocation,proto3" json:"allocation"`
}
func (*QueryAllocationResponse) Descriptor ¶ added in v0.11.0
func (*QueryAllocationResponse) Descriptor() ([]byte, []int)
func (*QueryAllocationResponse) Marshal ¶ added in v0.11.0
func (m *QueryAllocationResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllocationResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryAllocationResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllocationResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryAllocationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllocationResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryAllocationResponse) ProtoMessage()
func (*QueryAllocationResponse) Reset ¶ added in v0.11.0
func (m *QueryAllocationResponse) Reset()
func (*QueryAllocationResponse) Size ¶ added in v0.11.0
func (m *QueryAllocationResponse) Size() (n int)
func (*QueryAllocationResponse) String ¶ added in v0.11.0
func (m *QueryAllocationResponse) String() string
func (*QueryAllocationResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationResponse) Unmarshal(dAtA []byte) error
func (*QueryAllocationResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryAllocationResponse) XXX_DiscardUnknown()
func (*QueryAllocationResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryAllocationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllocationResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryAllocationResponse) XXX_Merge(src proto.Message)
func (*QueryAllocationResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryAllocationResponse) XXX_Size() int
func (*QueryAllocationResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationResponse) XXX_Unmarshal(b []byte) error
type QueryAllocationsRequest ¶ added in v0.11.0
type QueryAllocationsRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQueryAllocationsRequest ¶ added in v0.11.0
func NewQueryAllocationsRequest(id uint64, pagination *query.PageRequest) *QueryAllocationsRequest
func (*QueryAllocationsRequest) Descriptor ¶ added in v0.11.0
func (*QueryAllocationsRequest) Descriptor() ([]byte, []int)
func (*QueryAllocationsRequest) Marshal ¶ added in v0.11.0
func (m *QueryAllocationsRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllocationsRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryAllocationsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllocationsRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryAllocationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllocationsRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryAllocationsRequest) ProtoMessage()
func (*QueryAllocationsRequest) Reset ¶ added in v0.11.0
func (m *QueryAllocationsRequest) Reset()
func (*QueryAllocationsRequest) Size ¶ added in v0.11.0
func (m *QueryAllocationsRequest) Size() (n int)
func (*QueryAllocationsRequest) String ¶ added in v0.11.0
func (m *QueryAllocationsRequest) String() string
func (*QueryAllocationsRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationsRequest) Unmarshal(dAtA []byte) error
func (*QueryAllocationsRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryAllocationsRequest) XXX_DiscardUnknown()
func (*QueryAllocationsRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryAllocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllocationsRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryAllocationsRequest) XXX_Merge(src proto.Message)
func (*QueryAllocationsRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryAllocationsRequest) XXX_Size() int
func (*QueryAllocationsRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationsRequest) XXX_Unmarshal(b []byte) error
type QueryAllocationsResponse ¶ added in v0.11.0
type QueryAllocationsResponse struct { Allocations []Allocation `protobuf:"bytes,1,rep,name=allocations,proto3" json:"allocations"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryAllocationsResponse) Descriptor ¶ added in v0.11.0
func (*QueryAllocationsResponse) Descriptor() ([]byte, []int)
func (*QueryAllocationsResponse) Marshal ¶ added in v0.11.0
func (m *QueryAllocationsResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllocationsResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryAllocationsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllocationsResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryAllocationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllocationsResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryAllocationsResponse) ProtoMessage()
func (*QueryAllocationsResponse) Reset ¶ added in v0.11.0
func (m *QueryAllocationsResponse) Reset()
func (*QueryAllocationsResponse) Size ¶ added in v0.11.0
func (m *QueryAllocationsResponse) Size() (n int)
func (*QueryAllocationsResponse) String ¶ added in v0.11.0
func (m *QueryAllocationsResponse) String() string
func (*QueryAllocationsResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationsResponse) Unmarshal(dAtA []byte) error
func (*QueryAllocationsResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryAllocationsResponse) XXX_DiscardUnknown()
func (*QueryAllocationsResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryAllocationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllocationsResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryAllocationsResponse) XXX_Merge(src proto.Message)
func (*QueryAllocationsResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryAllocationsResponse) XXX_Size() int
func (*QueryAllocationsResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryAllocationsResponse) XXX_Unmarshal(b []byte) error
type QueryParamsRequest ¶ added in v0.6.1
type QueryParamsRequest struct { }
func NewQueryParamsRequest ¶ added in v0.6.1
func NewQueryParamsRequest() *QueryParamsRequest
func (*QueryParamsRequest) Descriptor ¶ added in v0.6.1
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
func (*QueryParamsRequest) Marshal ¶ added in v0.6.1
func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsRequest) MarshalTo ¶ added in v0.6.1
func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsRequest) MarshalToSizedBuffer ¶ added in v0.6.1
func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsRequest) ProtoMessage ¶ added in v0.6.1
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) Reset ¶ added in v0.6.1
func (m *QueryParamsRequest) Reset()
func (*QueryParamsRequest) Size ¶ added in v0.6.1
func (m *QueryParamsRequest) Size() (n int)
func (*QueryParamsRequest) String ¶ added in v0.6.1
func (m *QueryParamsRequest) String() string
func (*QueryParamsRequest) Unmarshal ¶ added in v0.6.1
func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsRequest) XXX_DiscardUnknown ¶ added in v0.6.1
func (m *QueryParamsRequest) XXX_DiscardUnknown()
func (*QueryParamsRequest) XXX_Marshal ¶ added in v0.6.1
func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsRequest) XXX_Merge ¶ added in v0.6.1
func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
func (*QueryParamsRequest) XXX_Size ¶ added in v0.6.1
func (m *QueryParamsRequest) XXX_Size() int
func (*QueryParamsRequest) XXX_Unmarshal ¶ added in v0.6.1
func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
type QueryParamsResponse ¶ added in v0.6.1
type QueryParamsResponse struct {
Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}
func (*QueryParamsResponse) Descriptor ¶ added in v0.6.1
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
func (*QueryParamsResponse) Marshal ¶ added in v0.6.1
func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsResponse) MarshalTo ¶ added in v0.6.1
func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsResponse) MarshalToSizedBuffer ¶ added in v0.6.1
func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsResponse) ProtoMessage ¶ added in v0.6.1
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) Reset ¶ added in v0.6.1
func (m *QueryParamsResponse) Reset()
func (*QueryParamsResponse) Size ¶ added in v0.6.1
func (m *QueryParamsResponse) Size() (n int)
func (*QueryParamsResponse) String ¶ added in v0.6.1
func (m *QueryParamsResponse) String() string
func (*QueryParamsResponse) Unmarshal ¶ added in v0.6.1
func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsResponse) XXX_DiscardUnknown ¶ added in v0.6.1
func (m *QueryParamsResponse) XXX_DiscardUnknown()
func (*QueryParamsResponse) XXX_Marshal ¶ added in v0.6.1
func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsResponse) XXX_Merge ¶ added in v0.6.1
func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
func (*QueryParamsResponse) XXX_Size ¶ added in v0.6.1
func (m *QueryParamsResponse) XXX_Size() int
func (*QueryParamsResponse) XXX_Unmarshal ¶ added in v0.6.1
func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
type QueryPayoutRequest ¶ added in v0.11.0
type QueryPayoutRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func NewQueryPayoutRequest ¶ added in v0.11.0
func NewQueryPayoutRequest(id uint64) *QueryPayoutRequest
func (*QueryPayoutRequest) Descriptor ¶ added in v0.11.0
func (*QueryPayoutRequest) Descriptor() ([]byte, []int)
func (*QueryPayoutRequest) Marshal ¶ added in v0.11.0
func (m *QueryPayoutRequest) Marshal() (dAtA []byte, err error)
func (*QueryPayoutRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutRequest) ProtoMessage()
func (*QueryPayoutRequest) Reset ¶ added in v0.11.0
func (m *QueryPayoutRequest) Reset()
func (*QueryPayoutRequest) Size ¶ added in v0.11.0
func (m *QueryPayoutRequest) Size() (n int)
func (*QueryPayoutRequest) String ¶ added in v0.11.0
func (m *QueryPayoutRequest) String() string
func (*QueryPayoutRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutRequest) Unmarshal(dAtA []byte) error
func (*QueryPayoutRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutRequest) XXX_DiscardUnknown()
func (*QueryPayoutRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutRequest) XXX_Merge(src proto.Message)
func (*QueryPayoutRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutRequest) XXX_Size() int
func (*QueryPayoutRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutRequest) XXX_Unmarshal(b []byte) error
type QueryPayoutResponse ¶ added in v0.11.0
type QueryPayoutResponse struct {
Payout Payout `protobuf:"bytes,1,opt,name=payout,proto3" json:"payout"`
}
func (*QueryPayoutResponse) Descriptor ¶ added in v0.11.0
func (*QueryPayoutResponse) Descriptor() ([]byte, []int)
func (*QueryPayoutResponse) Marshal ¶ added in v0.11.0
func (m *QueryPayoutResponse) Marshal() (dAtA []byte, err error)
func (*QueryPayoutResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutResponse) ProtoMessage()
func (*QueryPayoutResponse) Reset ¶ added in v0.11.0
func (m *QueryPayoutResponse) Reset()
func (*QueryPayoutResponse) Size ¶ added in v0.11.0
func (m *QueryPayoutResponse) Size() (n int)
func (*QueryPayoutResponse) String ¶ added in v0.11.0
func (m *QueryPayoutResponse) String() string
func (*QueryPayoutResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutResponse) Unmarshal(dAtA []byte) error
func (*QueryPayoutResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutResponse) XXX_DiscardUnknown()
func (*QueryPayoutResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutResponse) XXX_Merge(src proto.Message)
func (*QueryPayoutResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutResponse) XXX_Size() int
func (*QueryPayoutResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutResponse) XXX_Unmarshal(b []byte) error
type QueryPayoutsForAccountRequest ¶ added in v0.11.0
type QueryPayoutsForAccountRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPayoutsForAccountRequest) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsForAccountRequest) Descriptor() ([]byte, []int)
func (*QueryPayoutsForAccountRequest) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsForAccountRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsForAccountRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsForAccountRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsForAccountRequest) ProtoMessage()
func (*QueryPayoutsForAccountRequest) Reset ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) Reset()
func (*QueryPayoutsForAccountRequest) Size ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) Size() (n int)
func (*QueryPayoutsForAccountRequest) String ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) String() string
func (*QueryPayoutsForAccountRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) Unmarshal(dAtA []byte) error
func (*QueryPayoutsForAccountRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) XXX_DiscardUnknown()
func (*QueryPayoutsForAccountRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsForAccountRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) XXX_Merge(src proto.Message)
func (*QueryPayoutsForAccountRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) XXX_Size() int
func (*QueryPayoutsForAccountRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountRequest) XXX_Unmarshal(b []byte) error
type QueryPayoutsForAccountResponse ¶ added in v0.11.0
type QueryPayoutsForAccountResponse struct { Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPayoutsForAccountResponse) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsForAccountResponse) Descriptor() ([]byte, []int)
func (*QueryPayoutsForAccountResponse) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsForAccountResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsForAccountResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsForAccountResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsForAccountResponse) ProtoMessage()
func (*QueryPayoutsForAccountResponse) Reset ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) Reset()
func (*QueryPayoutsForAccountResponse) Size ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) Size() (n int)
func (*QueryPayoutsForAccountResponse) String ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) String() string
func (*QueryPayoutsForAccountResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) Unmarshal(dAtA []byte) error
func (*QueryPayoutsForAccountResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) XXX_DiscardUnknown()
func (*QueryPayoutsForAccountResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsForAccountResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) XXX_Merge(src proto.Message)
func (*QueryPayoutsForAccountResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) XXX_Size() int
func (*QueryPayoutsForAccountResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForAccountResponse) XXX_Unmarshal(b []byte) error
type QueryPayoutsForNodeRequest ¶ added in v0.11.0
type QueryPayoutsForNodeRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQueryPayoutsForAccountRequest ¶ added in v0.11.0
func NewQueryPayoutsForAccountRequest(addr sdk.AccAddress, pagination *query.PageRequest) *QueryPayoutsForNodeRequest
func NewQueryPayoutsForNodeRequest ¶ added in v0.11.0
func NewQueryPayoutsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.PageRequest) *QueryPayoutsForNodeRequest
func (*QueryPayoutsForNodeRequest) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsForNodeRequest) Descriptor() ([]byte, []int)
func (*QueryPayoutsForNodeRequest) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsForNodeRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsForNodeRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsForNodeRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsForNodeRequest) ProtoMessage()
func (*QueryPayoutsForNodeRequest) Reset ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) Reset()
func (*QueryPayoutsForNodeRequest) Size ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) Size() (n int)
func (*QueryPayoutsForNodeRequest) String ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) String() string
func (*QueryPayoutsForNodeRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) Unmarshal(dAtA []byte) error
func (*QueryPayoutsForNodeRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) XXX_DiscardUnknown()
func (*QueryPayoutsForNodeRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsForNodeRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) XXX_Merge(src proto.Message)
func (*QueryPayoutsForNodeRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) XXX_Size() int
func (*QueryPayoutsForNodeRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeRequest) XXX_Unmarshal(b []byte) error
type QueryPayoutsForNodeResponse ¶ added in v0.11.0
type QueryPayoutsForNodeResponse struct { Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPayoutsForNodeResponse) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsForNodeResponse) Descriptor() ([]byte, []int)
func (*QueryPayoutsForNodeResponse) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsForNodeResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsForNodeResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsForNodeResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsForNodeResponse) ProtoMessage()
func (*QueryPayoutsForNodeResponse) Reset ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) Reset()
func (*QueryPayoutsForNodeResponse) Size ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) Size() (n int)
func (*QueryPayoutsForNodeResponse) String ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) String() string
func (*QueryPayoutsForNodeResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) Unmarshal(dAtA []byte) error
func (*QueryPayoutsForNodeResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) XXX_DiscardUnknown()
func (*QueryPayoutsForNodeResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsForNodeResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) XXX_Merge(src proto.Message)
func (*QueryPayoutsForNodeResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) XXX_Size() int
func (*QueryPayoutsForNodeResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsForNodeResponse) XXX_Unmarshal(b []byte) error
type QueryPayoutsRequest ¶ added in v0.11.0
type QueryPayoutsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func NewQueryPayoutsRequest ¶ added in v0.11.0
func NewQueryPayoutsRequest(pagination *query.PageRequest) *QueryPayoutsRequest
func (*QueryPayoutsRequest) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsRequest) Descriptor() ([]byte, []int)
func (*QueryPayoutsRequest) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsRequest) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsRequest) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsRequest) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsRequest) ProtoMessage()
func (*QueryPayoutsRequest) Reset ¶ added in v0.11.0
func (m *QueryPayoutsRequest) Reset()
func (*QueryPayoutsRequest) Size ¶ added in v0.11.0
func (m *QueryPayoutsRequest) Size() (n int)
func (*QueryPayoutsRequest) String ¶ added in v0.11.0
func (m *QueryPayoutsRequest) String() string
func (*QueryPayoutsRequest) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsRequest) Unmarshal(dAtA []byte) error
func (*QueryPayoutsRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsRequest) XXX_DiscardUnknown()
func (*QueryPayoutsRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsRequest) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsRequest) XXX_Merge(src proto.Message)
func (*QueryPayoutsRequest) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsRequest) XXX_Size() int
func (*QueryPayoutsRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsRequest) XXX_Unmarshal(b []byte) error
type QueryPayoutsResponse ¶ added in v0.11.0
type QueryPayoutsResponse struct { Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPayoutsResponse) Descriptor ¶ added in v0.11.0
func (*QueryPayoutsResponse) Descriptor() ([]byte, []int)
func (*QueryPayoutsResponse) Marshal ¶ added in v0.11.0
func (m *QueryPayoutsResponse) Marshal() (dAtA []byte, err error)
func (*QueryPayoutsResponse) MarshalTo ¶ added in v0.11.0
func (m *QueryPayoutsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPayoutsResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QueryPayoutsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPayoutsResponse) ProtoMessage ¶ added in v0.11.0
func (*QueryPayoutsResponse) ProtoMessage()
func (*QueryPayoutsResponse) Reset ¶ added in v0.11.0
func (m *QueryPayoutsResponse) Reset()
func (*QueryPayoutsResponse) Size ¶ added in v0.11.0
func (m *QueryPayoutsResponse) Size() (n int)
func (*QueryPayoutsResponse) String ¶ added in v0.11.0
func (m *QueryPayoutsResponse) String() string
func (*QueryPayoutsResponse) Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsResponse) Unmarshal(dAtA []byte) error
func (*QueryPayoutsResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QueryPayoutsResponse) XXX_DiscardUnknown()
func (*QueryPayoutsResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QueryPayoutsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPayoutsResponse) XXX_Merge ¶ added in v0.11.0
func (m *QueryPayoutsResponse) XXX_Merge(src proto.Message)
func (*QueryPayoutsResponse) XXX_Size ¶ added in v0.11.0
func (m *QueryPayoutsResponse) XXX_Size() int
func (*QueryPayoutsResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QueryPayoutsResponse) XXX_Unmarshal(b []byte) error
type QueryServiceClient ¶ added in v0.6.0
type QueryServiceClient interface { QuerySubscriptions(ctx context.Context, in *QuerySubscriptionsRequest, opts ...grpc.CallOption) (*QuerySubscriptionsResponse, error) QuerySubscriptionsForAccount(ctx context.Context, in *QuerySubscriptionsForAccountRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForAccountResponse, error) QuerySubscriptionsForNode(ctx context.Context, in *QuerySubscriptionsForNodeRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForNodeResponse, error) QuerySubscriptionsForPlan(ctx context.Context, in *QuerySubscriptionsForPlanRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForPlanResponse, error) QuerySubscription(ctx context.Context, in *QuerySubscriptionRequest, opts ...grpc.CallOption) (*QuerySubscriptionResponse, error) QueryAllocations(ctx context.Context, in *QueryAllocationsRequest, opts ...grpc.CallOption) (*QueryAllocationsResponse, error) QueryAllocation(ctx context.Context, in *QueryAllocationRequest, opts ...grpc.CallOption) (*QueryAllocationResponse, error) QueryPayouts(ctx context.Context, in *QueryPayoutsRequest, opts ...grpc.CallOption) (*QueryPayoutsResponse, error) QueryPayoutsForAccount(ctx context.Context, in *QueryPayoutsForAccountRequest, opts ...grpc.CallOption) (*QueryPayoutsForAccountResponse, error) QueryPayoutsForNode(ctx context.Context, in *QueryPayoutsForNodeRequest, opts ...grpc.CallOption) (*QueryPayoutsForNodeResponse, error) QueryPayout(ctx context.Context, in *QueryPayoutRequest, opts ...grpc.CallOption) (*QueryPayoutResponse, error) QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) }
QueryServiceClient is the client API for QueryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryServiceClient ¶ added in v0.6.0
func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient
type QueryServiceServer ¶ added in v0.6.0
type QueryServiceServer interface { QuerySubscriptions(context.Context, *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error) QuerySubscriptionsForAccount(context.Context, *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error) QuerySubscriptionsForNode(context.Context, *QuerySubscriptionsForNodeRequest) (*QuerySubscriptionsForNodeResponse, error) QuerySubscriptionsForPlan(context.Context, *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error) QuerySubscription(context.Context, *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error) QueryAllocations(context.Context, *QueryAllocationsRequest) (*QueryAllocationsResponse, error) QueryAllocation(context.Context, *QueryAllocationRequest) (*QueryAllocationResponse, error) QueryPayouts(context.Context, *QueryPayoutsRequest) (*QueryPayoutsResponse, error) QueryPayoutsForAccount(context.Context, *QueryPayoutsForAccountRequest) (*QueryPayoutsForAccountResponse, error) QueryPayoutsForNode(context.Context, *QueryPayoutsForNodeRequest) (*QueryPayoutsForNodeResponse, error) QueryPayout(context.Context, *QueryPayoutRequest) (*QueryPayoutResponse, error) QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) }
QueryServiceServer is the server API for QueryService service.
type QuerySubscriptionRequest ¶ added in v0.6.0
type QuerySubscriptionRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func NewQuerySubscriptionRequest ¶ added in v0.6.0
func NewQuerySubscriptionRequest(id uint64) *QuerySubscriptionRequest
func (*QuerySubscriptionRequest) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionRequest) Descriptor() ([]byte, []int)
func (*QuerySubscriptionRequest) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionRequest) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionRequest) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionRequest) ProtoMessage()
func (*QuerySubscriptionRequest) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) Reset()
func (*QuerySubscriptionRequest) Size ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) Size() (n int)
func (*QuerySubscriptionRequest) String ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) String() string
func (*QuerySubscriptionRequest) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) XXX_DiscardUnknown()
func (*QuerySubscriptionRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionRequest) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) XXX_Merge(src proto.Message)
func (*QuerySubscriptionRequest) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) XXX_Size() int
func (*QuerySubscriptionRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionRequest) XXX_Unmarshal(b []byte) error
type QuerySubscriptionResponse ¶ added in v0.6.0
type QuerySubscriptionResponse struct {
Subscription *types.Any `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
}
func (*QuerySubscriptionResponse) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionResponse) Descriptor() ([]byte, []int)
func (*QuerySubscriptionResponse) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionResponse) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionResponse) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionResponse) ProtoMessage()
func (*QuerySubscriptionResponse) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) Reset()
func (*QuerySubscriptionResponse) Size ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) Size() (n int)
func (*QuerySubscriptionResponse) String ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) String() string
func (*QuerySubscriptionResponse) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) XXX_DiscardUnknown()
func (*QuerySubscriptionResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionResponse) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) XXX_Merge(src proto.Message)
func (*QuerySubscriptionResponse) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) XXX_Size() int
func (*QuerySubscriptionResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionResponse) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForAccountRequest ¶ added in v0.11.0
type QuerySubscriptionsForAccountRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQuerySubscriptionsForAccountRequest ¶ added in v0.11.0
func NewQuerySubscriptionsForAccountRequest(addr sdk.AccAddress, pagination *query.PageRequest) *QuerySubscriptionsForAccountRequest
func (*QuerySubscriptionsForAccountRequest) Descriptor ¶ added in v0.11.0
func (*QuerySubscriptionsForAccountRequest) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForAccountRequest) Marshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForAccountRequest) MarshalTo ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForAccountRequest) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForAccountRequest) ProtoMessage ¶ added in v0.11.0
func (*QuerySubscriptionsForAccountRequest) ProtoMessage()
func (*QuerySubscriptionsForAccountRequest) Reset ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) Reset()
func (*QuerySubscriptionsForAccountRequest) Size ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) Size() (n int)
func (*QuerySubscriptionsForAccountRequest) String ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) String() string
func (*QuerySubscriptionsForAccountRequest) Unmarshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForAccountRequest) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) XXX_DiscardUnknown()
func (*QuerySubscriptionsForAccountRequest) XXX_Marshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForAccountRequest) XXX_Merge ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForAccountRequest) XXX_Size ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) XXX_Size() int
func (*QuerySubscriptionsForAccountRequest) XXX_Unmarshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountRequest) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForAccountResponse ¶ added in v0.11.0
type QuerySubscriptionsForAccountResponse struct { Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QuerySubscriptionsForAccountResponse) Descriptor ¶ added in v0.11.0
func (*QuerySubscriptionsForAccountResponse) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForAccountResponse) Marshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForAccountResponse) MarshalTo ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForAccountResponse) MarshalToSizedBuffer ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForAccountResponse) ProtoMessage ¶ added in v0.11.0
func (*QuerySubscriptionsForAccountResponse) ProtoMessage()
func (*QuerySubscriptionsForAccountResponse) Reset ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) Reset()
func (*QuerySubscriptionsForAccountResponse) Size ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) Size() (n int)
func (*QuerySubscriptionsForAccountResponse) String ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) String() string
func (*QuerySubscriptionsForAccountResponse) Unmarshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForAccountResponse) XXX_DiscardUnknown ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) XXX_DiscardUnknown()
func (*QuerySubscriptionsForAccountResponse) XXX_Marshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForAccountResponse) XXX_Merge ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForAccountResponse) XXX_Size ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) XXX_Size() int
func (*QuerySubscriptionsForAccountResponse) XXX_Unmarshal ¶ added in v0.11.0
func (m *QuerySubscriptionsForAccountResponse) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForNodeRequest ¶ added in v0.6.0
type QuerySubscriptionsForNodeRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQuerySubscriptionsForNodeRequest ¶ added in v0.6.0
func NewQuerySubscriptionsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.PageRequest) *QuerySubscriptionsForNodeRequest
func (*QuerySubscriptionsForNodeRequest) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsForNodeRequest) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForNodeRequest) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForNodeRequest) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForNodeRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForNodeRequest) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsForNodeRequest) ProtoMessage()
func (*QuerySubscriptionsForNodeRequest) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) Reset()
func (*QuerySubscriptionsForNodeRequest) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) Size() (n int)
func (*QuerySubscriptionsForNodeRequest) String ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) String() string
func (*QuerySubscriptionsForNodeRequest) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForNodeRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) XXX_DiscardUnknown()
func (*QuerySubscriptionsForNodeRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForNodeRequest) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForNodeRequest) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) XXX_Size() int
func (*QuerySubscriptionsForNodeRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeRequest) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForNodeResponse ¶ added in v0.6.0
type QuerySubscriptionsForNodeResponse struct { Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QuerySubscriptionsForNodeResponse) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsForNodeResponse) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForNodeResponse) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForNodeResponse) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForNodeResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForNodeResponse) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsForNodeResponse) ProtoMessage()
func (*QuerySubscriptionsForNodeResponse) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) Reset()
func (*QuerySubscriptionsForNodeResponse) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) Size() (n int)
func (*QuerySubscriptionsForNodeResponse) String ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) String() string
func (*QuerySubscriptionsForNodeResponse) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForNodeResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) XXX_DiscardUnknown()
func (*QuerySubscriptionsForNodeResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForNodeResponse) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForNodeResponse) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) XXX_Size() int
func (*QuerySubscriptionsForNodeResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForNodeResponse) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForPlanRequest ¶ added in v0.6.0
type QuerySubscriptionsForPlanRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQuerySubscriptionsForPlanRequest ¶ added in v0.6.0
func NewQuerySubscriptionsForPlanRequest(id uint64, pagination *query.PageRequest) *QuerySubscriptionsForPlanRequest
func (*QuerySubscriptionsForPlanRequest) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsForPlanRequest) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForPlanRequest) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForPlanRequest) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForPlanRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForPlanRequest) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsForPlanRequest) ProtoMessage()
func (*QuerySubscriptionsForPlanRequest) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) Reset()
func (*QuerySubscriptionsForPlanRequest) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) Size() (n int)
func (*QuerySubscriptionsForPlanRequest) String ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) String() string
func (*QuerySubscriptionsForPlanRequest) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForPlanRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) XXX_DiscardUnknown()
func (*QuerySubscriptionsForPlanRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForPlanRequest) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForPlanRequest) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) XXX_Size() int
func (*QuerySubscriptionsForPlanRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanRequest) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsForPlanResponse ¶ added in v0.6.0
type QuerySubscriptionsForPlanResponse struct { Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QuerySubscriptionsForPlanResponse) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsForPlanResponse) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsForPlanResponse) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsForPlanResponse) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsForPlanResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsForPlanResponse) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsForPlanResponse) ProtoMessage()
func (*QuerySubscriptionsForPlanResponse) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) Reset()
func (*QuerySubscriptionsForPlanResponse) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) Size() (n int)
func (*QuerySubscriptionsForPlanResponse) String ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) String() string
func (*QuerySubscriptionsForPlanResponse) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsForPlanResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) XXX_DiscardUnknown()
func (*QuerySubscriptionsForPlanResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsForPlanResponse) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsForPlanResponse) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) XXX_Size() int
func (*QuerySubscriptionsForPlanResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsForPlanResponse) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsRequest ¶ added in v0.6.0
type QuerySubscriptionsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func NewQuerySubscriptionsRequest ¶ added in v0.6.0
func NewQuerySubscriptionsRequest(pagination *query.PageRequest) *QuerySubscriptionsRequest
func (*QuerySubscriptionsRequest) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsRequest) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsRequest) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsRequest) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsRequest) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsRequest) ProtoMessage()
func (*QuerySubscriptionsRequest) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) Reset()
func (*QuerySubscriptionsRequest) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) Size() (n int)
func (*QuerySubscriptionsRequest) String ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) String() string
func (*QuerySubscriptionsRequest) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) XXX_DiscardUnknown()
func (*QuerySubscriptionsRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsRequest) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsRequest) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) XXX_Size() int
func (*QuerySubscriptionsRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsRequest) XXX_Unmarshal(b []byte) error
type QuerySubscriptionsResponse ¶ added in v0.6.0
type QuerySubscriptionsResponse struct { Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QuerySubscriptionsResponse) Descriptor ¶ added in v0.6.0
func (*QuerySubscriptionsResponse) Descriptor() ([]byte, []int)
func (*QuerySubscriptionsResponse) Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) Marshal() (dAtA []byte, err error)
func (*QuerySubscriptionsResponse) MarshalTo ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySubscriptionsResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySubscriptionsResponse) ProtoMessage ¶ added in v0.6.0
func (*QuerySubscriptionsResponse) ProtoMessage()
func (*QuerySubscriptionsResponse) Reset ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) Reset()
func (*QuerySubscriptionsResponse) Size ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) Size() (n int)
func (*QuerySubscriptionsResponse) String ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) String() string
func (*QuerySubscriptionsResponse) Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) Unmarshal(dAtA []byte) error
func (*QuerySubscriptionsResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) XXX_DiscardUnknown()
func (*QuerySubscriptionsResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySubscriptionsResponse) XXX_Merge ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) XXX_Merge(src proto.Message)
func (*QuerySubscriptionsResponse) XXX_Size ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) XXX_Size() int
func (*QuerySubscriptionsResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QuerySubscriptionsResponse) XXX_Unmarshal(b []byte) error
type Subscription ¶
type SubscriptionType ¶ added in v0.11.0
type SubscriptionType int32
const ( TypeUnspecified SubscriptionType = 0 TypeNode SubscriptionType = 1 TypePlan SubscriptionType = 2 )
func (SubscriptionType) EnumDescriptor ¶ added in v0.11.0
func (SubscriptionType) EnumDescriptor() ([]byte, []int)
func (SubscriptionType) String ¶ added in v0.11.0
func (x SubscriptionType) String() string
type Subscriptions ¶
type Subscriptions []Subscription
type UnimplementedMsgServiceServer ¶ added in v0.6.0
type UnimplementedMsgServiceServer struct { }
UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServiceServer) MsgAllocate ¶ added in v0.11.0
func (*UnimplementedMsgServiceServer) MsgAllocate(ctx context.Context, req *MsgAllocateRequest) (*MsgAllocateResponse, error)
func (*UnimplementedMsgServiceServer) MsgCancel ¶ added in v0.6.0
func (*UnimplementedMsgServiceServer) MsgCancel(ctx context.Context, req *MsgCancelRequest) (*MsgCancelResponse, error)
type UnimplementedQueryServiceServer ¶ added in v0.6.0
type UnimplementedQueryServiceServer struct { }
UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServiceServer) QueryAllocation ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryAllocation(ctx context.Context, req *QueryAllocationRequest) (*QueryAllocationResponse, error)
func (*UnimplementedQueryServiceServer) QueryAllocations ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryAllocations(ctx context.Context, req *QueryAllocationsRequest) (*QueryAllocationsResponse, error)
func (*UnimplementedQueryServiceServer) QueryParams ¶ added in v0.6.1
func (*UnimplementedQueryServiceServer) QueryParams(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
func (*UnimplementedQueryServiceServer) QueryPayout ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryPayout(ctx context.Context, req *QueryPayoutRequest) (*QueryPayoutResponse, error)
func (*UnimplementedQueryServiceServer) QueryPayouts ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryPayouts(ctx context.Context, req *QueryPayoutsRequest) (*QueryPayoutsResponse, error)
func (*UnimplementedQueryServiceServer) QueryPayoutsForAccount ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryPayoutsForAccount(ctx context.Context, req *QueryPayoutsForAccountRequest) (*QueryPayoutsForAccountResponse, error)
func (*UnimplementedQueryServiceServer) QueryPayoutsForNode ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QueryPayoutsForNode(ctx context.Context, req *QueryPayoutsForNodeRequest) (*QueryPayoutsForNodeResponse, error)
func (*UnimplementedQueryServiceServer) QuerySubscription ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QuerySubscription(ctx context.Context, req *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error)
func (*UnimplementedQueryServiceServer) QuerySubscriptions ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QuerySubscriptions(ctx context.Context, req *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error)
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForAccount ¶ added in v0.11.0
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForAccount(ctx context.Context, req *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error)
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForNode ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForNode(ctx context.Context, req *QuerySubscriptionsForNodeRequest) (*QuerySubscriptionsForNodeResponse, error)
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForPlan ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QuerySubscriptionsForPlan(ctx context.Context, req *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error)