types

package
v12.0.0-rc4 Latest Latest
Warning

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

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

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName = "subscription"
	Day        = 24 * time.Hour
)

Variables

View Source 
var (
	ErrInvalidLengthAllocation        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAllocation          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAllocation = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrorInvalidMessage = sdkerrors.Register(ModuleName, 101, "invalid message")

	ErrorAllocationNotFound        = sdkerrors.Register(ModuleName, 201, "allocation not found")
	ErrorInsufficientBytes         = sdkerrors.Register(ModuleName, 202, "insufficient bytes")
	ErrorInvalidAllocation         = sdkerrors.Register(ModuleName, 203, "invalid allocation")
	ErrorInvalidNodeStatus         = sdkerrors.Register(ModuleName, 204, "invalid node status")
	ErrorInvalidPlanStatus         = sdkerrors.Register(ModuleName, 205, "invalid plan status")
	ErrorInvalidSubscription       = sdkerrors.Register(ModuleName, 206, "invalid subscription")
	ErrorInvalidSubscriptionStatus = sdkerrors.Register(ModuleName, 207, "invalid subscription status")
	ErrorNodeNotFound              = sdkerrors.Register(ModuleName, 208, "node not found")
	ErrorPayoutNotFound            = sdkerrors.Register(ModuleName, 209, "payout not found")
	ErrorPlanNotFound              = sdkerrors.Register(ModuleName, 210, "plan not found")
	ErrorPriceNotFound             = sdkerrors.Register(ModuleName, 211, "price does not exist")
	ErrorSubscriptionNotFound      = sdkerrors.Register(ModuleName, 212, "subscription not found")
	ErrorUnauthorized              = sdkerrors.Register(ModuleName, 213, "unauthorised")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	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}
	PayoutForAccountByNodeKeyPrefix = []byte{0x34}
)
View Source 
var (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPayout        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPayout          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPayout = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuerier        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuerier          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSubscription        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubscription          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DefaultStatusChangeDelay = 2 * time.Minute
)
View Source 
var (
	KeyStatusChangeDelay = []byte("StatusChangeDelay")
)
View Source 
var SubscriptionType_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "TYPE_NODE",
	2: "TYPE_PLAN",
}
View Source 
var SubscriptionType_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"TYPE_NODE":        1,
	"TYPE_PLAN":        2,
}

Functions

func AccAddrFromSubscriptionForAccountKey 

func AccAddrFromSubscriptionForAccountKey(key []byte) sdk.AccAddress

func AllocationKey 

func AllocationKey(id uint64, addr sdk.AccAddress) []byte

func GetAllocationForSubscriptionKeyPrefix 

func GetAllocationForSubscriptionKeyPrefix(id uint64) []byte

func GetPayoutForAccountByNodeKeyPrefix 

func GetPayoutForAccountByNodeKeyPrefix(accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress) (key []byte)

func GetPayoutForAccountKeyPrefix 

func GetPayoutForAccountKeyPrefix(addr sdk.AccAddress) []byte

func GetPayoutForNextAtKeyPrefix 

func GetPayoutForNextAtKeyPrefix(at time.Time) []byte

func GetPayoutForNodeKeyPrefix 

func GetPayoutForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte

func GetSubscriptionForAccountKeyPrefix 

func GetSubscriptionForAccountKeyPrefix(addr sdk.AccAddress) []byte

func GetSubscriptionForInactiveAtKeyPrefix 

func GetSubscriptionForInactiveAtKeyPrefix(at time.Time) []byte

func GetSubscriptionForNodeKeyPrefix 

func GetSubscriptionForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte

func GetSubscriptionForPlanKeyPrefix 

func GetSubscriptionForPlanKeyPrefix(id uint64) []byte

func IDFromPayoutForAccountByNodeKey 

func IDFromPayoutForAccountByNodeKey(key []byte) uint64

func IDFromPayoutForAccountKey 

func IDFromPayoutForAccountKey(key []byte) uint64

func IDFromPayoutForNextAtKey 

func IDFromPayoutForNextAtKey(key []byte) uint64

func IDFromPayoutForNodeKey 

func IDFromPayoutForNodeKey(key []byte) uint64

func IDFromSubscriptionForAccountKey 

func IDFromSubscriptionForAccountKey(key []byte) uint64

func IDFromSubscriptionForInactiveAtKey 

func IDFromSubscriptionForInactiveAtKey(key []byte) uint64

func IDFromSubscriptionForNodeKey 

func IDFromSubscriptionForNodeKey(key []byte) uint64

func IDFromSubscriptionForPlanKey 

func IDFromSubscriptionForPlanKey(key []byte) uint64

func NewErrorAllocationNotFound 

func NewErrorAllocationNotFound(id uint64, addr interface{}) error

func NewErrorInsufficientBytes 

func NewErrorInsufficientBytes(id uint64, addr interface{}) error

func NewErrorInvalidAllocation 

func NewErrorInvalidAllocation(id uint64, addr interface{}) error

func NewErrorInvalidNodeStatus 

func NewErrorInvalidNodeStatus(addr interface{}, status hubtypes.Status) error

func NewErrorInvalidPlanStatus 

func NewErrorInvalidPlanStatus(id uint64, status hubtypes.Status) error

func NewErrorInvalidSubscription 

func NewErrorInvalidSubscription(id uint64) error

func NewErrorInvalidSubscriptionStatus 

func NewErrorInvalidSubscriptionStatus(id uint64, status hubtypes.Status) error

func NewErrorNodeNotFound 

func NewErrorNodeNotFound(addr interface{}) error

func NewErrorPayoutNotFound 

func NewErrorPayoutNotFound(id uint64) error

func NewErrorPlanNotFound 

func NewErrorPlanNotFound(id uint64) error

func NewErrorPriceNotFound 

func NewErrorPriceNotFound(denom string) error

func NewErrorSubscriptionNotFound 

func NewErrorSubscriptionNotFound(id uint64) error

func NewErrorUnauthorized 

func NewErrorUnauthorized(addr interface{}) error

func ParamsKeyTable 

func ParamsKeyTable() params.KeyTable

func PayoutForAccountByNodeKey 

func PayoutForAccountByNodeKey(accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress, id uint64) []byte

func PayoutForAccountKey 

func PayoutForAccountKey(addr sdk.AccAddress, id uint64) []byte

func PayoutForNextAtKey 

func PayoutForNextAtKey(at time.Time, id uint64) []byte

func PayoutForNodeKey 

func PayoutForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte

func PayoutKey 

func PayoutKey(id uint64) []byte

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler 

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 

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 

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 

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 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func SubscriptionForAccountKey 

func SubscriptionForAccountKey(addr sdk.AccAddress, id uint64) []byte

func SubscriptionForInactiveAtKey 

func SubscriptionForInactiveAtKey(at time.Time, id uint64) []byte

func SubscriptionForNodeKey 

func SubscriptionForNodeKey(addr hubtypes.NodeAddress, id uint64) []byte

func SubscriptionForPlanKey 

func SubscriptionForPlanKey(planID, subscriptionID uint64) []byte

func SubscriptionKey 

func SubscriptionKey(id uint64) []byte

func ValidateGenesis 

func ValidateGenesis(state *GenesisState) error

Types

type Allocation 

type Allocation struct {
	// Field 1: Allocation ID.
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Account address.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Field 3: Granted bytes.
	GrantedBytes cosmossdk_io_math.Int `protobuf:"bytes,3,opt,name=granted_bytes,json=grantedBytes,proto3,customtype=cosmossdk.io/math.Int" json:"granted_bytes"`
	// Field 4: Utilized bytes.
	UtilisedBytes cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=utilised_bytes,json=utilisedBytes,proto3,customtype=cosmossdk.io/math.Int" json:"utilised_bytes"`
}

Allocation represents an allocation.

func (*Allocation) Descriptor 

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

func (*Allocation) GetAddress 

func (m *Allocation) GetAddress() sdk.AccAddress

func (*Allocation) Marshal 

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

func (*Allocation) MarshalTo 

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

func (*Allocation) MarshalToSizedBuffer 

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

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) Reset 

func (m *Allocation) Reset()

func (*Allocation) Size 

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

func (*Allocation) String 

func (m *Allocation) String() string

func (*Allocation) Unmarshal 

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

func (*Allocation) Validate 

func (m *Allocation) Validate() error

func (*Allocation) XXX_DiscardUnknown 

func (m *Allocation) XXX_DiscardUnknown()

func (*Allocation) XXX_Marshal 

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

func (*Allocation) XXX_Merge 

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

func (*Allocation) XXX_Size 

func (m *Allocation) XXX_Size() int

func (*Allocation) XXX_Unmarshal 

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

type Allocations 

type Allocations []Allocation

type BaseSubscription 

type BaseSubscription struct {
	// Field 1: Unique identifier for the subscription.
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Address associated with the subscription.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Field 3: Timestamp indicating when the subscription became inactive.
	InactiveAt time.Time `protobuf:"bytes,3,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	// Field 4: Status of the subscription.
	Status types.Status `protobuf:"varint,4,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	// Field 5: Timestamp indicating when the subscription status was last updated.
	StatusAt time.Time `protobuf:"bytes,5,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

BaseSubscription represents the common base for different subscription types.

func (*BaseSubscription) Descriptor 

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

func (*BaseSubscription) GetAddress 

func (s *BaseSubscription) GetAddress() sdk.AccAddress

func (*BaseSubscription) GetID 

func (s *BaseSubscription) GetID() uint64

func (*BaseSubscription) GetInactiveAt 

func (s *BaseSubscription) GetInactiveAt() time.Time

func (*BaseSubscription) GetStatus 

func (s *BaseSubscription) GetStatus() hubtypes.Status

func (*BaseSubscription) GetStatusAt 

func (s *BaseSubscription) GetStatusAt() time.Time

func (*BaseSubscription) Marshal 

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

func (*BaseSubscription) MarshalTo 

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

func (*BaseSubscription) MarshalToSizedBuffer 

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

func (*BaseSubscription) ProtoMessage 

func (*BaseSubscription) ProtoMessage()

func (*BaseSubscription) Reset 

func (m *BaseSubscription) Reset()

func (*BaseSubscription) SetInactiveAt 

func (s *BaseSubscription) SetInactiveAt(v time.Time)

func (*BaseSubscription) SetStatus 

func (s *BaseSubscription) SetStatus(v hubtypes.Status)

func (*BaseSubscription) SetStatusAt 

func (s *BaseSubscription) SetStatusAt(v time.Time)

func (*BaseSubscription) Size 

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

func (*BaseSubscription) String 

func (m *BaseSubscription) String() string

func (*BaseSubscription) Unmarshal 

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

func (*BaseSubscription) Validate 

func (s *BaseSubscription) Validate() error

func (*BaseSubscription) XXX_DiscardUnknown 

func (m *BaseSubscription) XXX_DiscardUnknown()

func (*BaseSubscription) XXX_Marshal 

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

func (*BaseSubscription) XXX_Merge 

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

func (*BaseSubscription) XXX_Size 

func (m *BaseSubscription) XXX_Size() int

func (*BaseSubscription) XXX_Unmarshal 

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

type EventAllocate 

type EventAllocate struct {
	// Field 1: Address associated with the allocation.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Granted bytes in the allocation.
	GrantedBytes cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=granted_bytes,json=grantedBytes,proto3,customtype=cosmossdk.io/math.Int" json:"granted_bytes"`
	// Field 3: Utilized bytes in the allocation.
	UtilisedBytes cosmossdk_io_math.Int `protobuf:"bytes,3,opt,name=utilised_bytes,json=utilisedBytes,proto3,customtype=cosmossdk.io/math.Int" json:"utilised_bytes"`
	// Field 4: Unique identifier for the allocation.
	ID uint64 `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventAllocate represents an allocation event.

func (*EventAllocate) Descriptor 

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

func (*EventAllocate) Marshal 

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

func (*EventAllocate) MarshalTo 

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

func (*EventAllocate) MarshalToSizedBuffer 

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

func (*EventAllocate) ProtoMessage 

func (*EventAllocate) ProtoMessage()

func (*EventAllocate) Reset 

func (m *EventAllocate) Reset()

func (*EventAllocate) Size 

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

func (*EventAllocate) String 

func (m *EventAllocate) String() string

func (*EventAllocate) Unmarshal 

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

func (*EventAllocate) XXX_DiscardUnknown 

func (m *EventAllocate) XXX_DiscardUnknown()

func (*EventAllocate) XXX_Marshal 

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

func (*EventAllocate) XXX_Merge 

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

func (*EventAllocate) XXX_Size 

func (m *EventAllocate) XXX_Size() int

func (*EventAllocate) XXX_Unmarshal 

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

type EventCreatePayout 

type EventCreatePayout struct {
	// Field 1: Address associated with the payout.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the payout.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: Unique identifier for the payout.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventCreatePayout represents an event for creating a payout.

func (*EventCreatePayout) Descriptor 

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

func (*EventCreatePayout) Marshal 

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

func (*EventCreatePayout) MarshalTo 

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

func (*EventCreatePayout) MarshalToSizedBuffer 

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

func (*EventCreatePayout) ProtoMessage 

func (*EventCreatePayout) ProtoMessage()

func (*EventCreatePayout) Reset 

func (m *EventCreatePayout) Reset()

func (*EventCreatePayout) Size 

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

func (*EventCreatePayout) String 

func (m *EventCreatePayout) String() string

func (*EventCreatePayout) Unmarshal 

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

func (*EventCreatePayout) XXX_DiscardUnknown 

func (m *EventCreatePayout) XXX_DiscardUnknown()

func (*EventCreatePayout) XXX_Marshal 

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

func (*EventCreatePayout) XXX_Merge 

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

func (*EventCreatePayout) XXX_Size 

func (m *EventCreatePayout) XXX_Size() int

func (*EventCreatePayout) XXX_Unmarshal 

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

type EventPayForPayout 

type EventPayForPayout struct {
	// Field 1: Address associated with the payout payment.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the payout payment.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: Payment amount for the payout.
	Payment string `protobuf:"bytes,3,opt,name=payment,proto3" json:"payment,omitempty" yaml:"payment"`
	// Field 4: Staking reward associated with the payout.
	StakingReward string `protobuf:"bytes,4,opt,name=staking_reward,json=stakingReward,proto3" json:"staking_reward,omitempty" yaml:"staking_reward"`
	// Field 5: Unique identifier for the payout.
	ID uint64 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventPayForPayout represents an event for paying for a payout.

func (*EventPayForPayout) Descriptor 

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

func (*EventPayForPayout) Marshal 

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

func (*EventPayForPayout) MarshalTo 

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

func (*EventPayForPayout) MarshalToSizedBuffer 

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

func (*EventPayForPayout) ProtoMessage 

func (*EventPayForPayout) ProtoMessage()

func (*EventPayForPayout) Reset 

func (m *EventPayForPayout) Reset()

func (*EventPayForPayout) Size 

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

func (*EventPayForPayout) String 

func (m *EventPayForPayout) String() string

func (*EventPayForPayout) Unmarshal 

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

func (*EventPayForPayout) XXX_DiscardUnknown 

func (m *EventPayForPayout) XXX_DiscardUnknown()

func (*EventPayForPayout) XXX_Marshal 

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

func (*EventPayForPayout) XXX_Merge 

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

func (*EventPayForPayout) XXX_Size 

func (m *EventPayForPayout) XXX_Size() int

func (*EventPayForPayout) XXX_Unmarshal 

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

type EventPayForPlan 

type EventPayForPlan struct {
	// Field 1: Address associated with the plan payment.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Payment amount for the plan.
	Payment string `protobuf:"bytes,2,opt,name=payment,proto3" json:"payment,omitempty" yaml:"payment"`
	// Field 3: Provider address associated with the plan payment.
	ProviderAddress string `` /* 130-byte string literal not displayed */
	// Field 4: Staking reward associated with the plan.
	StakingReward string `protobuf:"bytes,4,opt,name=staking_reward,json=stakingReward,proto3" json:"staking_reward,omitempty" yaml:"staking_reward"`
	// Field 5: Unique identifier for the plan.
	ID uint64 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventPayForPlan represents an event for paying for a plan.

func (*EventPayForPlan) Descriptor 

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

func (*EventPayForPlan) Marshal 

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

func (*EventPayForPlan) MarshalTo 

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

func (*EventPayForPlan) MarshalToSizedBuffer 

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

func (*EventPayForPlan) ProtoMessage 

func (*EventPayForPlan) ProtoMessage()

func (*EventPayForPlan) Reset 

func (m *EventPayForPlan) Reset()

func (*EventPayForPlan) Size 

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

func (*EventPayForPlan) String 

func (m *EventPayForPlan) String() string

func (*EventPayForPlan) Unmarshal 

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

func (*EventPayForPlan) XXX_DiscardUnknown 

func (m *EventPayForPlan) XXX_DiscardUnknown()

func (*EventPayForPlan) XXX_Marshal 

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

func (*EventPayForPlan) XXX_Merge 

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

func (*EventPayForPlan) XXX_Size 

func (m *EventPayForPlan) XXX_Size() int

func (*EventPayForPlan) XXX_Unmarshal 

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

type EventPayForSession 

type EventPayForSession struct {
	// Field 1: Address associated with the session payment.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the session payment.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: Payment amount for the session.
	Payment string `protobuf:"bytes,3,opt,name=payment,proto3" json:"payment,omitempty" yaml:"payment"`
	// Field 4: Staking reward associated with the session.
	StakingReward string `protobuf:"bytes,4,opt,name=staking_reward,json=stakingReward,proto3" json:"staking_reward,omitempty" yaml:"staking_reward"`
	// Field 5: Unique identifier for the session.
	SessionID uint64 `protobuf:"varint,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" yaml:"session_id"`
	// Field 6: Unique identifier for the subscription.
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
}

EventPayForSession represents an event for paying for a session.

func (*EventPayForSession) Descriptor 

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

func (*EventPayForSession) Marshal 

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

func (*EventPayForSession) MarshalTo 

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

func (*EventPayForSession) MarshalToSizedBuffer 

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

func (*EventPayForSession) ProtoMessage 

func (*EventPayForSession) ProtoMessage()

func (*EventPayForSession) Reset 

func (m *EventPayForSession) Reset()

func (*EventPayForSession) Size 

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

func (*EventPayForSession) String 

func (m *EventPayForSession) String() string

func (*EventPayForSession) Unmarshal 

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

func (*EventPayForSession) XXX_DiscardUnknown 

func (m *EventPayForSession) XXX_DiscardUnknown()

func (*EventPayForSession) XXX_Marshal 

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

func (*EventPayForSession) XXX_Merge 

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

func (*EventPayForSession) XXX_Size 

func (m *EventPayForSession) XXX_Size() int

func (*EventPayForSession) XXX_Unmarshal 

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

type EventRefund 

type EventRefund struct {
	// Field 1: Address associated with the refund.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Amount to be refunded.
	Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty" yaml:"amount"`
	// Field 3: Unique identifier for the refund.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventRefund represents an event for processing a refund.

func (*EventRefund) Descriptor 

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

func (*EventRefund) Marshal 

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

func (*EventRefund) MarshalTo 

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

func (*EventRefund) MarshalToSizedBuffer 

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

func (*EventRefund) ProtoMessage 

func (*EventRefund) ProtoMessage()

func (*EventRefund) Reset 

func (m *EventRefund) Reset()

func (*EventRefund) Size 

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

func (*EventRefund) String 

func (m *EventRefund) String() string

func (*EventRefund) Unmarshal 

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

func (*EventRefund) XXX_DiscardUnknown 

func (m *EventRefund) XXX_DiscardUnknown()

func (*EventRefund) XXX_Marshal 

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

func (*EventRefund) XXX_Merge 

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

func (*EventRefund) XXX_Size 

func (m *EventRefund) XXX_Size() int

func (*EventRefund) XXX_Unmarshal 

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

type EventUpdateStatus 

type EventUpdateStatus struct {
	// Field 1: Status of the event.
	Status types.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"`
	// Field 2: Address associated with the event.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 3: Unique identifier for the event.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	// Field 4: Unique identifier for the associated plan.
	PlanID uint64 `protobuf:"varint,4,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty" yaml:"plan_id"`
}

EventUpdateStatus represents an update to the status of an event.

func (*EventUpdateStatus) Descriptor 

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

func (*EventUpdateStatus) Marshal 

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

func (*EventUpdateStatus) MarshalTo 

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

func (*EventUpdateStatus) MarshalToSizedBuffer 

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

func (*EventUpdateStatus) ProtoMessage 

func (*EventUpdateStatus) ProtoMessage()

func (*EventUpdateStatus) Reset 

func (m *EventUpdateStatus) Reset()

func (*EventUpdateStatus) Size 

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

func (*EventUpdateStatus) String 

func (m *EventUpdateStatus) String() string

func (*EventUpdateStatus) Unmarshal 

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

func (*EventUpdateStatus) XXX_DiscardUnknown 

func (m *EventUpdateStatus) XXX_DiscardUnknown()

func (*EventUpdateStatus) XXX_Marshal 

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

func (*EventUpdateStatus) XXX_Merge 

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

func (*EventUpdateStatus) XXX_Size 

func (m *EventUpdateStatus) XXX_Size() int

func (*EventUpdateStatus) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// Field 1: Subscriptions in the genesis block.
	// Each GenesisSubscription contains subscription information and associated allocations.
	Subscriptions []GenesisSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
	// Field 2: Parameters for the module stored in the genesis block.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

GenesisState represents the initial state of the module in the genesis block.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(subscriptions GenesisSubscriptions, params Params) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type GenesisSubscription 

type GenesisSubscription struct {
	// Field 1: Subscription information stored as a serialized Any message.
	Subscription *types.Any `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Field 2: Allocations associated with the subscription.
	// Each allocation contains information about granted and utilized bytes.
	Allocations []Allocation `protobuf:"bytes,2,rep,name=allocations,proto3" json:"allocations"`
}

GenesisSubscription represents the initial state for a subscription in the genesis block.

func (*GenesisSubscription) Descriptor 

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

func (*GenesisSubscription) Marshal 

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

func (*GenesisSubscription) MarshalTo 

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

func (*GenesisSubscription) MarshalToSizedBuffer 

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

func (*GenesisSubscription) ProtoMessage 

func (*GenesisSubscription) ProtoMessage()

func (*GenesisSubscription) Reset 

func (m *GenesisSubscription) Reset()

func (*GenesisSubscription) Size 

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

func (*GenesisSubscription) String 

func (m *GenesisSubscription) String() string

func (*GenesisSubscription) Unmarshal 

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

func (*GenesisSubscription) XXX_DiscardUnknown 

func (m *GenesisSubscription) XXX_DiscardUnknown()

func (*GenesisSubscription) XXX_Marshal 

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

func (*GenesisSubscription) XXX_Merge 

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

func (*GenesisSubscription) XXX_Size 

func (m *GenesisSubscription) XXX_Size() int

func (*GenesisSubscription) XXX_Unmarshal 

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

type GenesisSubscriptions 

type GenesisSubscriptions []GenesisSubscription

type MsgAllocateRequest 

type MsgAllocateRequest struct {
	// Field 1: Address initiating the allocate request.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Unique identifier for the subscription.
	ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Field 3: Address for which bytes are allocated.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// Field 4: Number of bytes to allocate.
	Bytes cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=bytes,proto3,customtype=cosmossdk.io/math.Int" json:"bytes"`
}

MsgAllocateRequest defines the SDK message for allocating bytes of a subscription for an address.

func NewMsgAllocateRequest 

func NewMsgAllocateRequest(from sdk.AccAddress, id uint64, addr sdk.AccAddress, bytes sdkmath.Int) *MsgAllocateRequest

NewMsgAllocateRequest creates a new MsgAllocateRequest instance with the given parameters.

func (*MsgAllocateRequest) Descriptor 

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

func (*MsgAllocateRequest) GetSigners 

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 

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

func (*MsgAllocateRequest) MarshalTo 

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

func (*MsgAllocateRequest) MarshalToSizedBuffer 

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

func (*MsgAllocateRequest) ProtoMessage 

func (*MsgAllocateRequest) ProtoMessage()

func (*MsgAllocateRequest) Reset 

func (m *MsgAllocateRequest) Reset()

func (*MsgAllocateRequest) Size 

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

func (*MsgAllocateRequest) String 

func (m *MsgAllocateRequest) String() string

func (*MsgAllocateRequest) Unmarshal 

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

func (*MsgAllocateRequest) ValidateBasic 

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 

func (m *MsgAllocateRequest) XXX_DiscardUnknown()

func (*MsgAllocateRequest) XXX_Marshal 

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

func (*MsgAllocateRequest) XXX_Merge 

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

func (*MsgAllocateRequest) XXX_Size 

func (m *MsgAllocateRequest) XXX_Size() int

func (*MsgAllocateRequest) XXX_Unmarshal 

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

type MsgAllocateResponse 

type MsgAllocateResponse struct {
}

MsgAllocateResponse defines the response of message MsgAllocateRequest.

func (*MsgAllocateResponse) Descriptor 

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

func (*MsgAllocateResponse) Marshal 

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

func (*MsgAllocateResponse) MarshalTo 

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

func (*MsgAllocateResponse) MarshalToSizedBuffer 

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

func (*MsgAllocateResponse) ProtoMessage 

func (*MsgAllocateResponse) ProtoMessage()

func (*MsgAllocateResponse) Reset 

func (m *MsgAllocateResponse) Reset()

func (*MsgAllocateResponse) Size 

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

func (*MsgAllocateResponse) String 

func (m *MsgAllocateResponse) String() string

func (*MsgAllocateResponse) Unmarshal 

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

func (*MsgAllocateResponse) XXX_DiscardUnknown 

func (m *MsgAllocateResponse) XXX_DiscardUnknown()

func (*MsgAllocateResponse) XXX_Marshal 

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

func (*MsgAllocateResponse) XXX_Merge 

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

func (*MsgAllocateResponse) XXX_Size 

func (m *MsgAllocateResponse) XXX_Size() int

func (*MsgAllocateResponse) XXX_Unmarshal 

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

type MsgCancelRequest 

type MsgCancelRequest struct {
	// Field 1: Address initiating the cancel request.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Unique identifier for the subscription to be cancelled.
	ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

MsgCancelRequest defines the SDK message for cancelling a subscription.

func NewMsgCancelRequest 

func NewMsgCancelRequest(from sdk.AccAddress, id uint64) *MsgCancelRequest

NewMsgCancelRequest creates a new MsgCancelRequest instance with the given parameters.

func (*MsgCancelRequest) Descriptor 

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

func (*MsgCancelRequest) GetSigners 

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 

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

func (*MsgCancelRequest) MarshalTo 

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

func (*MsgCancelRequest) MarshalToSizedBuffer 

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

func (*MsgCancelRequest) ProtoMessage 

func (*MsgCancelRequest) ProtoMessage()

func (*MsgCancelRequest) Reset 

func (m *MsgCancelRequest) Reset()

func (*MsgCancelRequest) Size 

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

func (*MsgCancelRequest) String 

func (m *MsgCancelRequest) String() string

func (*MsgCancelRequest) Unmarshal 

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

func (*MsgCancelRequest) ValidateBasic 

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 

func (m *MsgCancelRequest) XXX_DiscardUnknown()

func (*MsgCancelRequest) XXX_Marshal 

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

func (*MsgCancelRequest) XXX_Merge 

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

func (*MsgCancelRequest) XXX_Size 

func (m *MsgCancelRequest) XXX_Size() int

func (*MsgCancelRequest) XXX_Unmarshal 

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

type MsgCancelResponse 

type MsgCancelResponse struct {
}

MsgCancelResponse defines the response of message MsgCancelRequest.

func (*MsgCancelResponse) Descriptor 

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

func (*MsgCancelResponse) Marshal 

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

func (*MsgCancelResponse) MarshalTo 

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

func (*MsgCancelResponse) MarshalToSizedBuffer 

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

func (*MsgCancelResponse) ProtoMessage 

func (*MsgCancelResponse) ProtoMessage()

func (*MsgCancelResponse) Reset 

func (m *MsgCancelResponse) Reset()

func (*MsgCancelResponse) Size 

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

func (*MsgCancelResponse) String 

func (m *MsgCancelResponse) String() string

func (*MsgCancelResponse) Unmarshal 

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

func (*MsgCancelResponse) XXX_DiscardUnknown 

func (m *MsgCancelResponse) XXX_DiscardUnknown()

func (*MsgCancelResponse) XXX_Marshal 

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

func (*MsgCancelResponse) XXX_Merge 

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

func (*MsgCancelResponse) XXX_Size 

func (m *MsgCancelResponse) XXX_Size() int

func (*MsgCancelResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	// RPC method for cancelling a subscription.
	MsgCancel(ctx context.Context, in *MsgCancelRequest, opts ...grpc.CallOption) (*MsgCancelResponse, error)
	// RPC method for allocating bytes of a subscription for an address.
	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 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	// RPC method for cancelling a subscription.
	MsgCancel(context.Context, *MsgCancelRequest) (*MsgCancelResponse, error)
	// RPC method for allocating bytes of a subscription for an address.
	MsgAllocate(context.Context, *MsgAllocateRequest) (*MsgAllocateResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type NodeSubscription 

type NodeSubscription struct {
	// Field 1: Common base subscription information.
	*BaseSubscription `protobuf:"bytes,1,opt,name=base,proto3,embedded=base" json:"base,omitempty"`
	// Field 2: Node address associated with the subscription.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// Field 3: Number of gigabytes associated with the subscription.
	Gigabytes int64 `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	// Field 4: Duration, in hours, for which the subscription is active.
	Hours int64 `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	// Field 5: Deposit required for the subscription, represented as a Cosmos Coin.
	// This field is not nullable.
	Deposit types1.Coin `protobuf:"bytes,5,opt,name=deposit,proto3" json:"deposit"`
}

NodeSubscription represents a subscription associated with a node.

func (*NodeSubscription) Descriptor 

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

func (*NodeSubscription) GetNodeAddress 

func (s *NodeSubscription) GetNodeAddress() hubtypes.NodeAddress

func (*NodeSubscription) Marshal 

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

func (*NodeSubscription) MarshalTo 

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

func (*NodeSubscription) MarshalToSizedBuffer 

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

func (*NodeSubscription) ProtoMessage 

func (*NodeSubscription) ProtoMessage()

func (*NodeSubscription) Reset 

func (m *NodeSubscription) Reset()

func (*NodeSubscription) Size 

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

func (*NodeSubscription) String 

func (m *NodeSubscription) String() string

func (*NodeSubscription) Type 

func (s *NodeSubscription) Type() SubscriptionType

func (*NodeSubscription) Unmarshal 

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

func (*NodeSubscription) Validate 

func (s *NodeSubscription) Validate() error

func (*NodeSubscription) XXX_DiscardUnknown 

func (m *NodeSubscription) XXX_DiscardUnknown()

func (*NodeSubscription) XXX_Marshal 

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

func (*NodeSubscription) XXX_Merge 

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

func (*NodeSubscription) XXX_Size 

func (m *NodeSubscription) XXX_Size() int

func (*NodeSubscription) XXX_Unmarshal 

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

type Params 

type Params struct {
	// Field 1: status_change_delay specifies the duration before a subscription status change takes effect.
	// The value is a duration specified in the standard Duration format.
	StatusChangeDelay time.Duration `protobuf:"bytes,1,opt,name=status_change_delay,json=statusChangeDelay,proto3,stdduration" json:"status_change_delay"`
}

Params represents the configurable parameters for subscription status changes.

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(statusChangeDelay time.Duration) Params

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (m *Params) ParamSetPairs() params.ParamSetPairs

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) Validate 

func (m *Params) Validate() error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type Payout 

type Payout struct {
	// Field 1: Unique identifier for the payout.
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Address associated with the payout.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Field 3: Node address associated with the payout.
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// Field 4: Duration, in hours, for which the payout is calculated.
	Hours int64 `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	// Field 5: Price of the payout, represented as a Cosmos Coin.
	// This field is not nullable.
	Price types.Coin `protobuf:"bytes,5,opt,name=price,proto3" json:"price"`
	// Field 6: Timestamp indicating when the next payout is scheduled.
	// This field is not nullable and is represented using the standard Timestamp format.
	NextAt time.Time `protobuf:"bytes,6,opt,name=next_at,json=nextAt,proto3,stdtime" json:"next_at"`
}

Payout represents information about a payout.

func (*Payout) Descriptor 

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

func (*Payout) GetAddress 

func (p *Payout) GetAddress() sdk.AccAddress

func (*Payout) GetNodeAddress 

func (p *Payout) GetNodeAddress() hubtypes.NodeAddress

func (*Payout) Marshal 

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

func (*Payout) MarshalTo 

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

func (*Payout) MarshalToSizedBuffer 

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

func (*Payout) ProtoMessage 

func (*Payout) ProtoMessage()

func (*Payout) Reset 

func (m *Payout) Reset()

func (*Payout) Size 

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

func (*Payout) String 

func (m *Payout) String() string

func (*Payout) Unmarshal 

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

func (*Payout) Validate 

func (p *Payout) Validate() error

func (*Payout) XXX_DiscardUnknown 

func (m *Payout) XXX_DiscardUnknown()

func (*Payout) XXX_Marshal 

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

func (*Payout) XXX_Merge 

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

func (*Payout) XXX_Size 

func (m *Payout) XXX_Size() int

func (*Payout) XXX_Unmarshal 

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

type Payouts 

type Payouts []Payout

type PlanSubscription 

type PlanSubscription struct {
	// Field 1: Common base subscription information.
	*BaseSubscription `protobuf:"bytes,1,opt,name=base,proto3,embedded=base" json:"base,omitempty"`
	// Field 2: Unique identifier for the plan associated with the subscription.
	PlanID uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	// Field 3: Denomination associated with the subscription.
	Denom string `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"`
}

PlanSubscription represents a subscription associated with a plan.

func (*PlanSubscription) Descriptor 

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

func (*PlanSubscription) Marshal 

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

func (*PlanSubscription) MarshalTo 

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

func (*PlanSubscription) MarshalToSizedBuffer 

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

func (*PlanSubscription) ProtoMessage 

func (*PlanSubscription) ProtoMessage()

func (*PlanSubscription) Reset 

func (m *PlanSubscription) Reset()

func (*PlanSubscription) Size 

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

func (*PlanSubscription) String 

func (m *PlanSubscription) String() string

func (*PlanSubscription) Type 

func (s *PlanSubscription) Type() SubscriptionType

func (*PlanSubscription) Unmarshal 

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

func (*PlanSubscription) Validate 

func (s *PlanSubscription) Validate() error

func (*PlanSubscription) XXX_DiscardUnknown 

func (m *PlanSubscription) XXX_DiscardUnknown()

func (*PlanSubscription) XXX_Marshal 

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

func (*PlanSubscription) XXX_Merge 

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

func (*PlanSubscription) XXX_Size 

func (m *PlanSubscription) XXX_Size() int

func (*PlanSubscription) XXX_Unmarshal 

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

type QueryAllocationRequest 

type QueryAllocationRequest struct {
	// Field 1: Unique identifier for the subscription associated with the allocation.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Address for which the allocation is queried.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

QueryAllocationRequest represents the request for querying a specific allocation.

func NewQueryAllocationRequest 

func NewQueryAllocationRequest(id uint64, addr sdk.AccAddress) *QueryAllocationRequest

func (*QueryAllocationRequest) Descriptor 

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

func (*QueryAllocationRequest) Marshal 

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

func (*QueryAllocationRequest) MarshalTo 

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

func (*QueryAllocationRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationRequest) ProtoMessage 

func (*QueryAllocationRequest) ProtoMessage()

func (*QueryAllocationRequest) Reset 

func (m *QueryAllocationRequest) Reset()

func (*QueryAllocationRequest) Size 

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

func (*QueryAllocationRequest) String 

func (m *QueryAllocationRequest) String() string

func (*QueryAllocationRequest) Unmarshal 

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

func (*QueryAllocationRequest) XXX_DiscardUnknown 

func (m *QueryAllocationRequest) XXX_DiscardUnknown()

func (*QueryAllocationRequest) XXX_Marshal 

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

func (*QueryAllocationRequest) XXX_Merge 

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

func (*QueryAllocationRequest) XXX_Size 

func (m *QueryAllocationRequest) XXX_Size() int

func (*QueryAllocationRequest) XXX_Unmarshal 

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

type QueryAllocationResponse 

type QueryAllocationResponse struct {
	// Field 1: Allocation information.
	Allocation Allocation `protobuf:"bytes,1,opt,name=allocation,proto3" json:"allocation"`
}

QueryAllocationResponse represents the response for querying a specific allocation.

func (*QueryAllocationResponse) Descriptor 

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

func (*QueryAllocationResponse) Marshal 

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

func (*QueryAllocationResponse) MarshalTo 

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

func (*QueryAllocationResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationResponse) ProtoMessage 

func (*QueryAllocationResponse) ProtoMessage()

func (*QueryAllocationResponse) Reset 

func (m *QueryAllocationResponse) Reset()

func (*QueryAllocationResponse) Size 

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

func (*QueryAllocationResponse) String 

func (m *QueryAllocationResponse) String() string

func (*QueryAllocationResponse) Unmarshal 

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

func (*QueryAllocationResponse) XXX_DiscardUnknown 

func (m *QueryAllocationResponse) XXX_DiscardUnknown()

func (*QueryAllocationResponse) XXX_Marshal 

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

func (*QueryAllocationResponse) XXX_Merge 

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

func (*QueryAllocationResponse) XXX_Size 

func (m *QueryAllocationResponse) XXX_Size() int

func (*QueryAllocationResponse) XXX_Unmarshal 

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

type QueryAllocationsRequest 

type QueryAllocationsRequest struct {
	// Field 1: Unique identifier for the subscription for which allocations are queried.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllocationsRequest represents the request for querying allocations associated with a subscription.

func NewQueryAllocationsRequest 

func NewQueryAllocationsRequest(id uint64, pagination *query.PageRequest) *QueryAllocationsRequest

func (*QueryAllocationsRequest) Descriptor 

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

func (*QueryAllocationsRequest) Marshal 

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

func (*QueryAllocationsRequest) MarshalTo 

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

func (*QueryAllocationsRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationsRequest) ProtoMessage 

func (*QueryAllocationsRequest) ProtoMessage()

func (*QueryAllocationsRequest) Reset 

func (m *QueryAllocationsRequest) Reset()

func (*QueryAllocationsRequest) Size 

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

func (*QueryAllocationsRequest) String 

func (m *QueryAllocationsRequest) String() string

func (*QueryAllocationsRequest) Unmarshal 

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

func (*QueryAllocationsRequest) XXX_DiscardUnknown 

func (m *QueryAllocationsRequest) XXX_DiscardUnknown()

func (*QueryAllocationsRequest) XXX_Marshal 

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

func (*QueryAllocationsRequest) XXX_Merge 

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

func (*QueryAllocationsRequest) XXX_Size 

func (m *QueryAllocationsRequest) XXX_Size() int

func (*QueryAllocationsRequest) XXX_Unmarshal 

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

type QueryAllocationsResponse 

type QueryAllocationsResponse struct {
	// Field 1: List of allocation information.
	Allocations []Allocation `protobuf:"bytes,1,rep,name=allocations,proto3" json:"allocations"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllocationsResponse represents the response for querying allocations associated with a subscription.

func (*QueryAllocationsResponse) Descriptor 

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

func (*QueryAllocationsResponse) Marshal 

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

func (*QueryAllocationsResponse) MarshalTo 

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

func (*QueryAllocationsResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationsResponse) ProtoMessage 

func (*QueryAllocationsResponse) ProtoMessage()

func (*QueryAllocationsResponse) Reset 

func (m *QueryAllocationsResponse) Reset()

func (*QueryAllocationsResponse) Size 

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

func (*QueryAllocationsResponse) String 

func (m *QueryAllocationsResponse) String() string

func (*QueryAllocationsResponse) Unmarshal 

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

func (*QueryAllocationsResponse) XXX_DiscardUnknown 

func (m *QueryAllocationsResponse) XXX_DiscardUnknown()

func (*QueryAllocationsResponse) XXX_Marshal 

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

func (*QueryAllocationsResponse) XXX_Merge 

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

func (*QueryAllocationsResponse) XXX_Size 

func (m *QueryAllocationsResponse) XXX_Size() int

func (*QueryAllocationsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest represents the request for querying subscription module parameters.

func NewQueryParamsRequest 

func NewQueryParamsRequest() *QueryParamsRequest

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// Field 1: Subscription module parameters.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse represents the response for querying subscription module parameters.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPayoutRequest 

type QueryPayoutRequest struct {
	// Field 1: Unique identifier for the payout being queried.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

QueryPayoutRequest represents the request for querying a specific payout.

func NewQueryPayoutRequest 

func NewQueryPayoutRequest(id uint64) *QueryPayoutRequest

func (*QueryPayoutRequest) Descriptor 

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

func (*QueryPayoutRequest) Marshal 

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

func (*QueryPayoutRequest) MarshalTo 

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

func (*QueryPayoutRequest) MarshalToSizedBuffer 

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

func (*QueryPayoutRequest) ProtoMessage 

func (*QueryPayoutRequest) ProtoMessage()

func (*QueryPayoutRequest) Reset 

func (m *QueryPayoutRequest) Reset()

func (*QueryPayoutRequest) Size 

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

func (*QueryPayoutRequest) String 

func (m *QueryPayoutRequest) String() string

func (*QueryPayoutRequest) Unmarshal 

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

func (*QueryPayoutRequest) XXX_DiscardUnknown 

func (m *QueryPayoutRequest) XXX_DiscardUnknown()

func (*QueryPayoutRequest) XXX_Marshal 

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

func (*QueryPayoutRequest) XXX_Merge 

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

func (*QueryPayoutRequest) XXX_Size 

func (m *QueryPayoutRequest) XXX_Size() int

func (*QueryPayoutRequest) XXX_Unmarshal 

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

type QueryPayoutResponse 

type QueryPayoutResponse struct {
	// Field 1: Payout information.
	Payout Payout `protobuf:"bytes,1,opt,name=payout,proto3" json:"payout"`
}

QueryPayoutResponse represents the response for querying a specific payout.

func (*QueryPayoutResponse) Descriptor 

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

func (*QueryPayoutResponse) Marshal 

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

func (*QueryPayoutResponse) MarshalTo 

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

func (*QueryPayoutResponse) MarshalToSizedBuffer 

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

func (*QueryPayoutResponse) ProtoMessage 

func (*QueryPayoutResponse) ProtoMessage()

func (*QueryPayoutResponse) Reset 

func (m *QueryPayoutResponse) Reset()

func (*QueryPayoutResponse) Size 

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

func (*QueryPayoutResponse) String 

func (m *QueryPayoutResponse) String() string

func (*QueryPayoutResponse) Unmarshal 

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

func (*QueryPayoutResponse) XXX_DiscardUnknown 

func (m *QueryPayoutResponse) XXX_DiscardUnknown()

func (*QueryPayoutResponse) XXX_Marshal 

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

func (*QueryPayoutResponse) XXX_Merge 

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

func (*QueryPayoutResponse) XXX_Size 

func (m *QueryPayoutResponse) XXX_Size() int

func (*QueryPayoutResponse) XXX_Unmarshal 

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

type QueryPayoutsForAccountRequest 

type QueryPayoutsForAccountRequest struct {
	// Field 1: Address of the account for which payouts are queried.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsForAccountRequest represents the request for querying payouts for a specific account.

func NewQueryPayoutsForAccountRequest 

func NewQueryPayoutsForAccountRequest(addr sdk.AccAddress, pagination *query.PageRequest) *QueryPayoutsForAccountRequest

func (*QueryPayoutsForAccountRequest) Descriptor 

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

func (*QueryPayoutsForAccountRequest) Marshal 

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

func (*QueryPayoutsForAccountRequest) MarshalTo 

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

func (*QueryPayoutsForAccountRequest) MarshalToSizedBuffer 

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

func (*QueryPayoutsForAccountRequest) ProtoMessage 

func (*QueryPayoutsForAccountRequest) ProtoMessage()

func (*QueryPayoutsForAccountRequest) Reset 

func (m *QueryPayoutsForAccountRequest) Reset()

func (*QueryPayoutsForAccountRequest) Size 

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

func (*QueryPayoutsForAccountRequest) String 

func (m *QueryPayoutsForAccountRequest) String() string

func (*QueryPayoutsForAccountRequest) Unmarshal 

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

func (*QueryPayoutsForAccountRequest) XXX_DiscardUnknown 

func (m *QueryPayoutsForAccountRequest) XXX_DiscardUnknown()

func (*QueryPayoutsForAccountRequest) XXX_Marshal 

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

func (*QueryPayoutsForAccountRequest) XXX_Merge 

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

func (*QueryPayoutsForAccountRequest) XXX_Size 

func (m *QueryPayoutsForAccountRequest) XXX_Size() int

func (*QueryPayoutsForAccountRequest) XXX_Unmarshal 

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

type QueryPayoutsForAccountResponse 

type QueryPayoutsForAccountResponse struct {
	// Field 1: List of payout information.
	Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsForAccountResponse represents the response for querying payouts for a specific account.

func (*QueryPayoutsForAccountResponse) Descriptor 

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

func (*QueryPayoutsForAccountResponse) Marshal 

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

func (*QueryPayoutsForAccountResponse) MarshalTo 

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

func (*QueryPayoutsForAccountResponse) MarshalToSizedBuffer 

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

func (*QueryPayoutsForAccountResponse) ProtoMessage 

func (*QueryPayoutsForAccountResponse) ProtoMessage()

func (*QueryPayoutsForAccountResponse) Reset 

func (m *QueryPayoutsForAccountResponse) Reset()

func (*QueryPayoutsForAccountResponse) Size 

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

func (*QueryPayoutsForAccountResponse) String 

func (m *QueryPayoutsForAccountResponse) String() string

func (*QueryPayoutsForAccountResponse) Unmarshal 

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

func (*QueryPayoutsForAccountResponse) XXX_DiscardUnknown 

func (m *QueryPayoutsForAccountResponse) XXX_DiscardUnknown()

func (*QueryPayoutsForAccountResponse) XXX_Marshal 

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

func (*QueryPayoutsForAccountResponse) XXX_Merge 

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

func (*QueryPayoutsForAccountResponse) XXX_Size 

func (m *QueryPayoutsForAccountResponse) XXX_Size() int

func (*QueryPayoutsForAccountResponse) XXX_Unmarshal 

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

type QueryPayoutsForNodeRequest 

type QueryPayoutsForNodeRequest struct {
	// Field 1: Address of the node for which payouts are queried.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsForNodeRequest represents the request for querying payouts for a specific node.

func NewQueryPayoutsForNodeRequest 

func NewQueryPayoutsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.PageRequest) *QueryPayoutsForNodeRequest

func (*QueryPayoutsForNodeRequest) Descriptor 

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

func (*QueryPayoutsForNodeRequest) Marshal 

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

func (*QueryPayoutsForNodeRequest) MarshalTo 

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

func (*QueryPayoutsForNodeRequest) MarshalToSizedBuffer 

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

func (*QueryPayoutsForNodeRequest) ProtoMessage 

func (*QueryPayoutsForNodeRequest) ProtoMessage()

func (*QueryPayoutsForNodeRequest) Reset 

func (m *QueryPayoutsForNodeRequest) Reset()

func (*QueryPayoutsForNodeRequest) Size 

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

func (*QueryPayoutsForNodeRequest) String 

func (m *QueryPayoutsForNodeRequest) String() string

func (*QueryPayoutsForNodeRequest) Unmarshal 

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

func (*QueryPayoutsForNodeRequest) XXX_DiscardUnknown 

func (m *QueryPayoutsForNodeRequest) XXX_DiscardUnknown()

func (*QueryPayoutsForNodeRequest) XXX_Marshal 

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

func (*QueryPayoutsForNodeRequest) XXX_Merge 

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

func (*QueryPayoutsForNodeRequest) XXX_Size 

func (m *QueryPayoutsForNodeRequest) XXX_Size() int

func (*QueryPayoutsForNodeRequest) XXX_Unmarshal 

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

type QueryPayoutsForNodeResponse 

type QueryPayoutsForNodeResponse struct {
	// Field 1: List of payout information.
	Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsForNodeResponse represents the response for querying payouts for a specific node.

func (*QueryPayoutsForNodeResponse) Descriptor 

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

func (*QueryPayoutsForNodeResponse) Marshal 

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

func (*QueryPayoutsForNodeResponse) MarshalTo 

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

func (*QueryPayoutsForNodeResponse) MarshalToSizedBuffer 

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

func (*QueryPayoutsForNodeResponse) ProtoMessage 

func (*QueryPayoutsForNodeResponse) ProtoMessage()

func (*QueryPayoutsForNodeResponse) Reset 

func (m *QueryPayoutsForNodeResponse) Reset()

func (*QueryPayoutsForNodeResponse) Size 

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

func (*QueryPayoutsForNodeResponse) String 

func (m *QueryPayoutsForNodeResponse) String() string

func (*QueryPayoutsForNodeResponse) Unmarshal 

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

func (*QueryPayoutsForNodeResponse) XXX_DiscardUnknown 

func (m *QueryPayoutsForNodeResponse) XXX_DiscardUnknown()

func (*QueryPayoutsForNodeResponse) XXX_Marshal 

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

func (*QueryPayoutsForNodeResponse) XXX_Merge 

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

func (*QueryPayoutsForNodeResponse) XXX_Size 

func (m *QueryPayoutsForNodeResponse) XXX_Size() int

func (*QueryPayoutsForNodeResponse) XXX_Unmarshal 

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

type QueryPayoutsRequest 

type QueryPayoutsRequest struct {
	// Field 1: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsRequest represents the request for querying payouts.

func NewQueryPayoutsRequest 

func NewQueryPayoutsRequest(pagination *query.PageRequest) *QueryPayoutsRequest

func (*QueryPayoutsRequest) Descriptor 

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

func (*QueryPayoutsRequest) Marshal 

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

func (*QueryPayoutsRequest) MarshalTo 

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

func (*QueryPayoutsRequest) MarshalToSizedBuffer 

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

func (*QueryPayoutsRequest) ProtoMessage 

func (*QueryPayoutsRequest) ProtoMessage()

func (*QueryPayoutsRequest) Reset 

func (m *QueryPayoutsRequest) Reset()

func (*QueryPayoutsRequest) Size 

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

func (*QueryPayoutsRequest) String 

func (m *QueryPayoutsRequest) String() string

func (*QueryPayoutsRequest) Unmarshal 

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

func (*QueryPayoutsRequest) XXX_DiscardUnknown 

func (m *QueryPayoutsRequest) XXX_DiscardUnknown()

func (*QueryPayoutsRequest) XXX_Marshal 

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

func (*QueryPayoutsRequest) XXX_Merge 

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

func (*QueryPayoutsRequest) XXX_Size 

func (m *QueryPayoutsRequest) XXX_Size() int

func (*QueryPayoutsRequest) XXX_Unmarshal 

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

type QueryPayoutsResponse 

type QueryPayoutsResponse struct {
	// Field 1: List of payout information.
	Payouts []Payout `protobuf:"bytes,1,rep,name=payouts,proto3" json:"payouts"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPayoutsResponse represents the response for querying payouts.

func (*QueryPayoutsResponse) Descriptor 

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

func (*QueryPayoutsResponse) Marshal 

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

func (*QueryPayoutsResponse) MarshalTo 

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

func (*QueryPayoutsResponse) MarshalToSizedBuffer 

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

func (*QueryPayoutsResponse) ProtoMessage 

func (*QueryPayoutsResponse) ProtoMessage()

func (*QueryPayoutsResponse) Reset 

func (m *QueryPayoutsResponse) Reset()

func (*QueryPayoutsResponse) Size 

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

func (*QueryPayoutsResponse) String 

func (m *QueryPayoutsResponse) String() string

func (*QueryPayoutsResponse) Unmarshal 

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

func (*QueryPayoutsResponse) XXX_DiscardUnknown 

func (m *QueryPayoutsResponse) XXX_DiscardUnknown()

func (*QueryPayoutsResponse) XXX_Marshal 

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

func (*QueryPayoutsResponse) XXX_Merge 

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

func (*QueryPayoutsResponse) XXX_Size 

func (m *QueryPayoutsResponse) XXX_Size() int

func (*QueryPayoutsResponse) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	// RPC method for querying subscriptions.
	QuerySubscriptions(ctx context.Context, in *QuerySubscriptionsRequest, opts ...grpc.CallOption) (*QuerySubscriptionsResponse, error)
	// RPC method for querying subscriptions for a specific account.
	QuerySubscriptionsForAccount(ctx context.Context, in *QuerySubscriptionsForAccountRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForAccountResponse, error)
	// RPC method for querying subscriptions for a specific node.
	QuerySubscriptionsForNode(ctx context.Context, in *QuerySubscriptionsForNodeRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForNodeResponse, error)
	// RPC method for querying subscriptions for a specific plan.
	QuerySubscriptionsForPlan(ctx context.Context, in *QuerySubscriptionsForPlanRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForPlanResponse, error)
	// RPC method for querying a specific subscription.
	QuerySubscription(ctx context.Context, in *QuerySubscriptionRequest, opts ...grpc.CallOption) (*QuerySubscriptionResponse, error)
	// RPC method for querying allocations associated with a subscription.
	QueryAllocations(ctx context.Context, in *QueryAllocationsRequest, opts ...grpc.CallOption) (*QueryAllocationsResponse, error)
	// RPC method for querying a specific allocation.
	QueryAllocation(ctx context.Context, in *QueryAllocationRequest, opts ...grpc.CallOption) (*QueryAllocationResponse, error)
	// RPC method for querying payouts.
	QueryPayouts(ctx context.Context, in *QueryPayoutsRequest, opts ...grpc.CallOption) (*QueryPayoutsResponse, error)
	// RPC method for querying payouts for a specific account.
	QueryPayoutsForAccount(ctx context.Context, in *QueryPayoutsForAccountRequest, opts ...grpc.CallOption) (*QueryPayoutsForAccountResponse, error)
	// RPC method for querying payouts for a specific node.
	QueryPayoutsForNode(ctx context.Context, in *QueryPayoutsForNodeRequest, opts ...grpc.CallOption) (*QueryPayoutsForNodeResponse, error)
	// RPC method for querying a specific payout.
	QueryPayout(ctx context.Context, in *QueryPayoutRequest, opts ...grpc.CallOption) (*QueryPayoutResponse, error)
	// RPC method for querying subscription module parameters.
	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 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// RPC method for querying subscriptions.
	QuerySubscriptions(context.Context, *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error)
	// RPC method for querying subscriptions for a specific account.
	QuerySubscriptionsForAccount(context.Context, *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error)
	// RPC method for querying subscriptions for a specific node.
	QuerySubscriptionsForNode(context.Context, *QuerySubscriptionsForNodeRequest) (*QuerySubscriptionsForNodeResponse, error)
	// RPC method for querying subscriptions for a specific plan.
	QuerySubscriptionsForPlan(context.Context, *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error)
	// RPC method for querying a specific subscription.
	QuerySubscription(context.Context, *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error)
	// RPC method for querying allocations associated with a subscription.
	QueryAllocations(context.Context, *QueryAllocationsRequest) (*QueryAllocationsResponse, error)
	// RPC method for querying a specific allocation.
	QueryAllocation(context.Context, *QueryAllocationRequest) (*QueryAllocationResponse, error)
	// RPC method for querying payouts.
	QueryPayouts(context.Context, *QueryPayoutsRequest) (*QueryPayoutsResponse, error)
	// RPC method for querying payouts for a specific account.
	QueryPayoutsForAccount(context.Context, *QueryPayoutsForAccountRequest) (*QueryPayoutsForAccountResponse, error)
	// RPC method for querying payouts for a specific node.
	QueryPayoutsForNode(context.Context, *QueryPayoutsForNodeRequest) (*QueryPayoutsForNodeResponse, error)
	// RPC method for querying a specific payout.
	QueryPayout(context.Context, *QueryPayoutRequest) (*QueryPayoutResponse, error)
	// RPC method for querying subscription module parameters.
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QuerySubscriptionRequest 

type QuerySubscriptionRequest struct {
	// Field 1: Unique identifier for the subscription being queried.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

QuerySubscriptionRequest represents the request for querying a specific subscription.

func NewQuerySubscriptionRequest 

func NewQuerySubscriptionRequest(id uint64) *QuerySubscriptionRequest

func (*QuerySubscriptionRequest) Descriptor 

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

func (*QuerySubscriptionRequest) Marshal 

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

func (*QuerySubscriptionRequest) MarshalTo 

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

func (*QuerySubscriptionRequest) MarshalToSizedBuffer 

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

func (*QuerySubscriptionRequest) ProtoMessage 

func (*QuerySubscriptionRequest) ProtoMessage()

func (*QuerySubscriptionRequest) Reset 

func (m *QuerySubscriptionRequest) Reset()

func (*QuerySubscriptionRequest) Size 

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

func (*QuerySubscriptionRequest) String 

func (m *QuerySubscriptionRequest) String() string

func (*QuerySubscriptionRequest) Unmarshal 

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

func (*QuerySubscriptionRequest) XXX_DiscardUnknown 

func (m *QuerySubscriptionRequest) XXX_DiscardUnknown()

func (*QuerySubscriptionRequest) XXX_Marshal 

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

func (*QuerySubscriptionRequest) XXX_Merge 

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

func (*QuerySubscriptionRequest) XXX_Size 

func (m *QuerySubscriptionRequest) XXX_Size() int

func (*QuerySubscriptionRequest) XXX_Unmarshal 

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

type QuerySubscriptionResponse 

type QuerySubscriptionResponse struct {
	// Field 1: Serialized subscription information.
	Subscription *types.Any `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
}

QuerySubscriptionResponse represents the response for querying a specific subscription.

func (*QuerySubscriptionResponse) Descriptor 

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

func (*QuerySubscriptionResponse) Marshal 

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

func (*QuerySubscriptionResponse) MarshalTo 

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

func (*QuerySubscriptionResponse) MarshalToSizedBuffer 

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

func (*QuerySubscriptionResponse) ProtoMessage 

func (*QuerySubscriptionResponse) ProtoMessage()

func (*QuerySubscriptionResponse) Reset 

func (m *QuerySubscriptionResponse) Reset()

func (*QuerySubscriptionResponse) Size 

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

func (*QuerySubscriptionResponse) String 

func (m *QuerySubscriptionResponse) String() string

func (*QuerySubscriptionResponse) Unmarshal 

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

func (*QuerySubscriptionResponse) XXX_DiscardUnknown 

func (m *QuerySubscriptionResponse) XXX_DiscardUnknown()

func (*QuerySubscriptionResponse) XXX_Marshal 

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

func (*QuerySubscriptionResponse) XXX_Merge 

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

func (*QuerySubscriptionResponse) XXX_Size 

func (m *QuerySubscriptionResponse) XXX_Size() int

func (*QuerySubscriptionResponse) XXX_Unmarshal 

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

type QuerySubscriptionsForAccountRequest 

type QuerySubscriptionsForAccountRequest struct {
	// Field 1: Address of the account for which subscriptions are queried.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForAccountRequest represents the request for querying subscriptions for a specific account.

func NewQuerySubscriptionsForAccountRequest 

func NewQuerySubscriptionsForAccountRequest(addr sdk.AccAddress, pagination *query.PageRequest) *QuerySubscriptionsForAccountRequest

func (*QuerySubscriptionsForAccountRequest) Descriptor 

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

func (*QuerySubscriptionsForAccountRequest) Marshal 

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

func (*QuerySubscriptionsForAccountRequest) MarshalTo 

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

func (*QuerySubscriptionsForAccountRequest) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForAccountRequest) ProtoMessage 

func (*QuerySubscriptionsForAccountRequest) ProtoMessage()

func (*QuerySubscriptionsForAccountRequest) Reset 

func (m *QuerySubscriptionsForAccountRequest) Reset()

func (*QuerySubscriptionsForAccountRequest) Size 

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

func (*QuerySubscriptionsForAccountRequest) String 

func (m *QuerySubscriptionsForAccountRequest) String() string

func (*QuerySubscriptionsForAccountRequest) Unmarshal 

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

func (*QuerySubscriptionsForAccountRequest) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForAccountRequest) XXX_DiscardUnknown()

func (*QuerySubscriptionsForAccountRequest) XXX_Marshal 

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

func (*QuerySubscriptionsForAccountRequest) XXX_Merge 

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

func (*QuerySubscriptionsForAccountRequest) XXX_Size 

func (m *QuerySubscriptionsForAccountRequest) XXX_Size() int

func (*QuerySubscriptionsForAccountRequest) XXX_Unmarshal 

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

type QuerySubscriptionsForAccountResponse 

type QuerySubscriptionsForAccountResponse struct {
	// Field 1: List of serialized subscription information.
	Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForAccountResponse represents the response for querying subscriptions for a specific account.

func (*QuerySubscriptionsForAccountResponse) Descriptor 

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

func (*QuerySubscriptionsForAccountResponse) Marshal 

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

func (*QuerySubscriptionsForAccountResponse) MarshalTo 

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

func (*QuerySubscriptionsForAccountResponse) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForAccountResponse) ProtoMessage 

func (*QuerySubscriptionsForAccountResponse) ProtoMessage()

func (*QuerySubscriptionsForAccountResponse) Reset 

func (m *QuerySubscriptionsForAccountResponse) Reset()

func (*QuerySubscriptionsForAccountResponse) Size 

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

func (*QuerySubscriptionsForAccountResponse) String 

func (m *QuerySubscriptionsForAccountResponse) String() string

func (*QuerySubscriptionsForAccountResponse) Unmarshal 

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

func (*QuerySubscriptionsForAccountResponse) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForAccountResponse) XXX_DiscardUnknown()

func (*QuerySubscriptionsForAccountResponse) XXX_Marshal 

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

func (*QuerySubscriptionsForAccountResponse) XXX_Merge 

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

func (*QuerySubscriptionsForAccountResponse) XXX_Size 

func (m *QuerySubscriptionsForAccountResponse) XXX_Size() int

func (*QuerySubscriptionsForAccountResponse) XXX_Unmarshal 

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

type QuerySubscriptionsForNodeRequest 

type QuerySubscriptionsForNodeRequest struct {
	// Field 1: Address of the node for which subscriptions are queried.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForNodeRequest represents the request for querying subscriptions for a specific node.

func NewQuerySubscriptionsForNodeRequest 

func NewQuerySubscriptionsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.PageRequest) *QuerySubscriptionsForNodeRequest

func (*QuerySubscriptionsForNodeRequest) Descriptor 

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

func (*QuerySubscriptionsForNodeRequest) Marshal 

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

func (*QuerySubscriptionsForNodeRequest) MarshalTo 

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

func (*QuerySubscriptionsForNodeRequest) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForNodeRequest) ProtoMessage 

func (*QuerySubscriptionsForNodeRequest) ProtoMessage()

func (*QuerySubscriptionsForNodeRequest) Reset 

func (m *QuerySubscriptionsForNodeRequest) Reset()

func (*QuerySubscriptionsForNodeRequest) Size 

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

func (*QuerySubscriptionsForNodeRequest) String 

func (m *QuerySubscriptionsForNodeRequest) String() string

func (*QuerySubscriptionsForNodeRequest) Unmarshal 

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

func (*QuerySubscriptionsForNodeRequest) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForNodeRequest) XXX_DiscardUnknown()

func (*QuerySubscriptionsForNodeRequest) XXX_Marshal 

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

func (*QuerySubscriptionsForNodeRequest) XXX_Merge 

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

func (*QuerySubscriptionsForNodeRequest) XXX_Size 

func (m *QuerySubscriptionsForNodeRequest) XXX_Size() int

func (*QuerySubscriptionsForNodeRequest) XXX_Unmarshal 

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

type QuerySubscriptionsForNodeResponse 

type QuerySubscriptionsForNodeResponse struct {
	// Field 1: List of serialized subscription information.
	Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForNodeResponse represents the response for querying subscriptions for a specific node.

func (*QuerySubscriptionsForNodeResponse) Descriptor 

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

func (*QuerySubscriptionsForNodeResponse) Marshal 

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

func (*QuerySubscriptionsForNodeResponse) MarshalTo 

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

func (*QuerySubscriptionsForNodeResponse) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForNodeResponse) ProtoMessage 

func (*QuerySubscriptionsForNodeResponse) ProtoMessage()

func (*QuerySubscriptionsForNodeResponse) Reset 

func (m *QuerySubscriptionsForNodeResponse) Reset()

func (*QuerySubscriptionsForNodeResponse) Size 

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

func (*QuerySubscriptionsForNodeResponse) String 

func (m *QuerySubscriptionsForNodeResponse) String() string

func (*QuerySubscriptionsForNodeResponse) Unmarshal 

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

func (*QuerySubscriptionsForNodeResponse) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForNodeResponse) XXX_DiscardUnknown()

func (*QuerySubscriptionsForNodeResponse) XXX_Marshal 

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

func (*QuerySubscriptionsForNodeResponse) XXX_Merge 

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

func (*QuerySubscriptionsForNodeResponse) XXX_Size 

func (m *QuerySubscriptionsForNodeResponse) XXX_Size() int

func (*QuerySubscriptionsForNodeResponse) XXX_Unmarshal 

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

type QuerySubscriptionsForPlanRequest 

type QuerySubscriptionsForPlanRequest struct {
	// Field 1: Unique identifier for the plan for which subscriptions are queried.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForPlanRequest represents the request for querying subscriptions for a specific plan.

func NewQuerySubscriptionsForPlanRequest 

func NewQuerySubscriptionsForPlanRequest(id uint64, pagination *query.PageRequest) *QuerySubscriptionsForPlanRequest

func (*QuerySubscriptionsForPlanRequest) Descriptor 

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

func (*QuerySubscriptionsForPlanRequest) Marshal 

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

func (*QuerySubscriptionsForPlanRequest) MarshalTo 

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

func (*QuerySubscriptionsForPlanRequest) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForPlanRequest) ProtoMessage 

func (*QuerySubscriptionsForPlanRequest) ProtoMessage()

func (*QuerySubscriptionsForPlanRequest) Reset 

func (m *QuerySubscriptionsForPlanRequest) Reset()

func (*QuerySubscriptionsForPlanRequest) Size 

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

func (*QuerySubscriptionsForPlanRequest) String 

func (m *QuerySubscriptionsForPlanRequest) String() string

func (*QuerySubscriptionsForPlanRequest) Unmarshal 

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

func (*QuerySubscriptionsForPlanRequest) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForPlanRequest) XXX_DiscardUnknown()

func (*QuerySubscriptionsForPlanRequest) XXX_Marshal 

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

func (*QuerySubscriptionsForPlanRequest) XXX_Merge 

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

func (*QuerySubscriptionsForPlanRequest) XXX_Size 

func (m *QuerySubscriptionsForPlanRequest) XXX_Size() int

func (*QuerySubscriptionsForPlanRequest) XXX_Unmarshal 

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

type QuerySubscriptionsForPlanResponse 

type QuerySubscriptionsForPlanResponse struct {
	// Field 1: List of serialized subscription information.
	Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsForPlanResponse represents the response for querying subscriptions for a specific plan.

func (*QuerySubscriptionsForPlanResponse) Descriptor 

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

func (*QuerySubscriptionsForPlanResponse) Marshal 

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

func (*QuerySubscriptionsForPlanResponse) MarshalTo 

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

func (*QuerySubscriptionsForPlanResponse) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsForPlanResponse) ProtoMessage 

func (*QuerySubscriptionsForPlanResponse) ProtoMessage()

func (*QuerySubscriptionsForPlanResponse) Reset 

func (m *QuerySubscriptionsForPlanResponse) Reset()

func (*QuerySubscriptionsForPlanResponse) Size 

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

func (*QuerySubscriptionsForPlanResponse) String 

func (m *QuerySubscriptionsForPlanResponse) String() string

func (*QuerySubscriptionsForPlanResponse) Unmarshal 

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

func (*QuerySubscriptionsForPlanResponse) XXX_DiscardUnknown 

func (m *QuerySubscriptionsForPlanResponse) XXX_DiscardUnknown()

func (*QuerySubscriptionsForPlanResponse) XXX_Marshal 

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

func (*QuerySubscriptionsForPlanResponse) XXX_Merge 

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

func (*QuerySubscriptionsForPlanResponse) XXX_Size 

func (m *QuerySubscriptionsForPlanResponse) XXX_Size() int

func (*QuerySubscriptionsForPlanResponse) XXX_Unmarshal 

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

type QuerySubscriptionsRequest 

type QuerySubscriptionsRequest struct {
	// Field 1: Pagination options for the query.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsRequest represents the request for querying subscriptions.

func NewQuerySubscriptionsRequest 

func NewQuerySubscriptionsRequest(pagination *query.PageRequest) *QuerySubscriptionsRequest

func (*QuerySubscriptionsRequest) Descriptor 

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

func (*QuerySubscriptionsRequest) Marshal 

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

func (*QuerySubscriptionsRequest) MarshalTo 

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

func (*QuerySubscriptionsRequest) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsRequest) ProtoMessage 

func (*QuerySubscriptionsRequest) ProtoMessage()

func (*QuerySubscriptionsRequest) Reset 

func (m *QuerySubscriptionsRequest) Reset()

func (*QuerySubscriptionsRequest) Size 

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

func (*QuerySubscriptionsRequest) String 

func (m *QuerySubscriptionsRequest) String() string

func (*QuerySubscriptionsRequest) Unmarshal 

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

func (*QuerySubscriptionsRequest) XXX_DiscardUnknown 

func (m *QuerySubscriptionsRequest) XXX_DiscardUnknown()

func (*QuerySubscriptionsRequest) XXX_Marshal 

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

func (*QuerySubscriptionsRequest) XXX_Merge 

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

func (*QuerySubscriptionsRequest) XXX_Size 

func (m *QuerySubscriptionsRequest) XXX_Size() int

func (*QuerySubscriptionsRequest) XXX_Unmarshal 

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

type QuerySubscriptionsResponse 

type QuerySubscriptionsResponse struct {
	// Field 1: List of serialized subscription information.
	Subscriptions []*types.Any `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Field 2: Pagination information for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySubscriptionsResponse represents the response for querying subscriptions.

func (*QuerySubscriptionsResponse) Descriptor 

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

func (*QuerySubscriptionsResponse) Marshal 

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

func (*QuerySubscriptionsResponse) MarshalTo 

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

func (*QuerySubscriptionsResponse) MarshalToSizedBuffer 

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

func (*QuerySubscriptionsResponse) ProtoMessage 

func (*QuerySubscriptionsResponse) ProtoMessage()

func (*QuerySubscriptionsResponse) Reset 

func (m *QuerySubscriptionsResponse) Reset()

func (*QuerySubscriptionsResponse) Size 

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

func (*QuerySubscriptionsResponse) String 

func (m *QuerySubscriptionsResponse) String() string

func (*QuerySubscriptionsResponse) Unmarshal 

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

func (*QuerySubscriptionsResponse) XXX_DiscardUnknown 

func (m *QuerySubscriptionsResponse) XXX_DiscardUnknown()

func (*QuerySubscriptionsResponse) XXX_Marshal 

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

func (*QuerySubscriptionsResponse) XXX_Merge 

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

func (*QuerySubscriptionsResponse) XXX_Size 

func (m *QuerySubscriptionsResponse) XXX_Size() int

func (*QuerySubscriptionsResponse) XXX_Unmarshal 

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

type Subscription 

type Subscription interface {
	proto.Message
	Type() SubscriptionType
	Validate() error
	GetID() uint64
	GetAddress() sdk.AccAddress
	GetInactiveAt() time.Time
	GetStatus() hubtypes.Status
	GetStatusAt() time.Time
	SetInactiveAt(v time.Time)
	SetStatus(v hubtypes.Status)
	SetStatusAt(v time.Time)
}

type SubscriptionType 

type SubscriptionType int32

SubscriptionType represents the type of a subscription. 

const (
	// TYPE_UNSPECIFIED indicates an unspecified subscription type.
	TypeUnspecified SubscriptionType = 0
	// TYPE_NODE indicates a subscription associated with a node.
	TypeNode SubscriptionType = 1
	// TYPE_PLAN indicates a subscription associated with a plan.
	TypePlan SubscriptionType = 2
)

func (SubscriptionType) EnumDescriptor 

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

func (SubscriptionType) String 

func (x SubscriptionType) String() string

type Subscriptions 

type Subscriptions []Subscription

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgAllocate 

func (*UnimplementedMsgServiceServer) MsgAllocate(ctx context.Context, req *MsgAllocateRequest) (*MsgAllocateResponse, error)

func (*UnimplementedMsgServiceServer) MsgCancel 

func (*UnimplementedMsgServiceServer) MsgCancel(ctx context.Context, req *MsgCancelRequest) (*MsgCancelResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryAllocation 

func (*UnimplementedQueryServiceServer) QueryAllocation(ctx context.Context, req *QueryAllocationRequest) (*QueryAllocationResponse, error)

func (*UnimplementedQueryServiceServer) QueryAllocations 

func (*UnimplementedQueryServiceServer) QueryAllocations(ctx context.Context, req *QueryAllocationsRequest) (*QueryAllocationsResponse, error)

func (*UnimplementedQueryServiceServer) QueryParams 

func (*UnimplementedQueryServiceServer) QueryParams(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServiceServer) QueryPayout 

func (*UnimplementedQueryServiceServer) QueryPayout(ctx context.Context, req *QueryPayoutRequest) (*QueryPayoutResponse, error)

func (*UnimplementedQueryServiceServer) QueryPayouts 

func (*UnimplementedQueryServiceServer) QueryPayouts(ctx context.Context, req *QueryPayoutsRequest) (*QueryPayoutsResponse, error)

func (*UnimplementedQueryServiceServer) QueryPayoutsForAccount 

func (*UnimplementedQueryServiceServer) QueryPayoutsForAccount(ctx context.Context, req *QueryPayoutsForAccountRequest) (*QueryPayoutsForAccountResponse, error)

func (*UnimplementedQueryServiceServer) QueryPayoutsForNode 

func (*UnimplementedQueryServiceServer) QueryPayoutsForNode(ctx context.Context, req *QueryPayoutsForNodeRequest) (*QueryPayoutsForNodeResponse, error)

func (*UnimplementedQueryServiceServer) QuerySubscription 

func (*UnimplementedQueryServiceServer) QuerySubscription(ctx context.Context, req *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error)

func (*UnimplementedQueryServiceServer) QuerySubscriptions 

func (*UnimplementedQueryServiceServer) QuerySubscriptions(ctx context.Context, req *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error)

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForAccount 

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForAccount(ctx context.Context, req *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error)

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForNode 

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForNode(ctx context.Context, req *QuerySubscriptionsForNodeRequest) (*QuerySubscriptionsForNodeResponse, error)

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForPlan 

func (*UnimplementedQueryServiceServer) QuerySubscriptionsForPlan(ctx context.Context, req *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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