v3

package
v12.0.0-rc8 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 34 Imported by: 1

Documentation

Overview

Package v3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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 (
	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 (
	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 (
	ErrInvalidLengthSession        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSession          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSession = 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 MsgService_serviceDesc = _MsgService_serviceDesc
View Source 
var QueryService_serviceDesc = _QueryService_serviceDesc

Functions

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 ValidateGenesis 

func ValidateGenesis(state *GenesisState) error

Types

type EventAllocate 

type EventAllocate struct {
	ID            uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress    string `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	GrantedBytes  string `protobuf:"bytes,3,opt,name=granted_bytes,json=grantedBytes,proto3" json:"granted_bytes,omitempty"`
	UtilisedBytes string `protobuf:"bytes,4,opt,name=utilised_bytes,json=utilisedBytes,proto3" json:"utilised_bytes,omitempty"`
}

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 EventCreate 

type EventCreate struct {
	ID          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PlanID      uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	AccAddress  string `protobuf:"bytes,3,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	ProvAddress string `protobuf:"bytes,4,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Price       string `protobuf:"bytes,5,opt,name=price,proto3" json:"price,omitempty"`
}

func (*EventCreate) Descriptor 

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

func (*EventCreate) Marshal 

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

func (*EventCreate) MarshalTo 

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

func (*EventCreate) MarshalToSizedBuffer 

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

func (*EventCreate) ProtoMessage 

func (*EventCreate) ProtoMessage()

func (*EventCreate) Reset 

func (m *EventCreate) Reset()

func (*EventCreate) Size 

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

func (*EventCreate) String 

func (m *EventCreate) String() string

func (*EventCreate) Unmarshal 

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

func (*EventCreate) XXX_DiscardUnknown 

func (m *EventCreate) XXX_DiscardUnknown()

func (*EventCreate) XXX_Marshal 

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

func (*EventCreate) XXX_Merge 

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

func (*EventCreate) XXX_Size 

func (m *EventCreate) XXX_Size() int

func (*EventCreate) XXX_Unmarshal 

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

type EventCreateSession 

type EventCreateSession struct {
	ID             uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress     string `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	NodeAddress    string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	SubscriptionID uint64 `protobuf:"varint,4,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
}

func (*EventCreateSession) Descriptor 

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

func (*EventCreateSession) Marshal 

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

func (*EventCreateSession) MarshalTo 

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

func (*EventCreateSession) MarshalToSizedBuffer 

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

func (*EventCreateSession) ProtoMessage 

func (*EventCreateSession) ProtoMessage()

func (*EventCreateSession) Reset 

func (m *EventCreateSession) Reset()

func (*EventCreateSession) Size 

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

func (*EventCreateSession) String 

func (m *EventCreateSession) String() string

func (*EventCreateSession) Unmarshal 

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

func (*EventCreateSession) XXX_DiscardUnknown 

func (m *EventCreateSession) XXX_DiscardUnknown()

func (*EventCreateSession) XXX_Marshal 

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

func (*EventCreateSession) XXX_Merge 

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

func (*EventCreateSession) XXX_Size 

func (m *EventCreateSession) XXX_Size() int

func (*EventCreateSession) XXX_Unmarshal 

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

type EventPay 

type EventPay struct {
	ID            uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PlanID        uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	AccAddress    string `protobuf:"bytes,3,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	ProvAddress   string `protobuf:"bytes,4,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Payment       string `protobuf:"bytes,5,opt,name=payment,proto3" json:"payment,omitempty"`
	StakingReward string `protobuf:"bytes,6,opt,name=staking_reward,json=stakingReward,proto3" json:"staking_reward,omitempty"`
}

func (*EventPay) Descriptor 

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

func (*EventPay) Marshal 

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

func (*EventPay) MarshalTo 

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

func (*EventPay) MarshalToSizedBuffer 

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

func (*EventPay) ProtoMessage 

func (*EventPay) ProtoMessage()

func (*EventPay) Reset 

func (m *EventPay) Reset()

func (*EventPay) Size 

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

func (*EventPay) String 

func (m *EventPay) String() string

func (*EventPay) Unmarshal 

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

func (*EventPay) XXX_DiscardUnknown 

func (m *EventPay) XXX_DiscardUnknown()

func (*EventPay) XXX_Marshal 

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

func (*EventPay) XXX_Merge 

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

func (*EventPay) XXX_Size 

func (m *EventPay) XXX_Size() int

func (*EventPay) XXX_Unmarshal 

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

type EventRenew 

type EventRenew struct {
	ID          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PlanID      uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	AccAddress  string `protobuf:"bytes,3,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	ProvAddress string `protobuf:"bytes,4,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Price       string `protobuf:"bytes,5,opt,name=price,proto3" json:"price,omitempty"`
}

func (*EventRenew) Descriptor 

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

func (*EventRenew) Marshal 

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

func (*EventRenew) MarshalTo 

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

func (*EventRenew) MarshalToSizedBuffer 

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

func (*EventRenew) ProtoMessage 

func (*EventRenew) ProtoMessage()

func (*EventRenew) Reset 

func (m *EventRenew) Reset()

func (*EventRenew) Size 

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

func (*EventRenew) String 

func (m *EventRenew) String() string

func (*EventRenew) Unmarshal 

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

func (*EventRenew) XXX_DiscardUnknown 

func (m *EventRenew) XXX_DiscardUnknown()

func (*EventRenew) XXX_Marshal 

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

func (*EventRenew) XXX_Merge 

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

func (*EventRenew) XXX_Size 

func (m *EventRenew) XXX_Size() int

func (*EventRenew) XXX_Unmarshal 

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

type EventUpdate 

type EventUpdate struct {
	ID                 uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PlanID             uint64    `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	AccAddress         string    `protobuf:"bytes,3,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	RenewalPricePolicy string    `protobuf:"bytes,4,opt,name=renewal_price_policy,json=renewalPricePolicy,proto3" json:"renewal_price_policy,omitempty"`
	Status             v1.Status `protobuf:"varint,5,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	InactiveAt         string    `protobuf:"bytes,6,opt,name=inactive_at,json=inactiveAt,proto3" json:"inactive_at,omitempty"`
	StatusAt           string    `protobuf:"bytes,7,opt,name=status_at,json=statusAt,proto3" json:"status_at,omitempty"`
}

func (*EventUpdate) Descriptor 

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

func (*EventUpdate) Marshal 

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

func (*EventUpdate) MarshalTo 

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

func (*EventUpdate) MarshalToSizedBuffer 

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

func (*EventUpdate) ProtoMessage 

func (*EventUpdate) ProtoMessage()

func (*EventUpdate) Reset 

func (m *EventUpdate) Reset()

func (*EventUpdate) Size 

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

func (*EventUpdate) String 

func (m *EventUpdate) String() string

func (*EventUpdate) Unmarshal 

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

func (*EventUpdate) XXX_DiscardUnknown 

func (m *EventUpdate) XXX_DiscardUnknown()

func (*EventUpdate) XXX_Marshal 

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

func (*EventUpdate) XXX_Merge 

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

func (*EventUpdate) XXX_Size 

func (m *EventUpdate) XXX_Size() int

func (*EventUpdate) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Allocations   []v2.Allocation `protobuf:"bytes,1,rep,name=allocations,proto3" json:"allocations"`
	Subscriptions []Subscription  `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions"`
	Params        v2.Params       `protobuf:"bytes,3,opt,name=params,proto3" json:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(allocations []v2.Allocation, subscriptions []Subscription, params v2.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 MsgCancelSubscriptionRequest 

type MsgCancelSubscriptionRequest struct {
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID   uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

func NewMsgCancelSubscriptionRequest 

func NewMsgCancelSubscriptionRequest(from sdk.AccAddress, id uint64) *MsgCancelSubscriptionRequest

func (*MsgCancelSubscriptionRequest) Descriptor 

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

func (*MsgCancelSubscriptionRequest) GetSigners 

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

func (*MsgCancelSubscriptionRequest) Marshal 

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

func (*MsgCancelSubscriptionRequest) MarshalTo 

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

func (*MsgCancelSubscriptionRequest) MarshalToSizedBuffer 

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

func (*MsgCancelSubscriptionRequest) ProtoMessage 

func (*MsgCancelSubscriptionRequest) ProtoMessage()

func (*MsgCancelSubscriptionRequest) Reset 

func (m *MsgCancelSubscriptionRequest) Reset()

func (*MsgCancelSubscriptionRequest) Size 

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

func (*MsgCancelSubscriptionRequest) String 

func (m *MsgCancelSubscriptionRequest) String() string

func (*MsgCancelSubscriptionRequest) Unmarshal 

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

func (*MsgCancelSubscriptionRequest) ValidateBasic 

func (m *MsgCancelSubscriptionRequest) ValidateBasic() error

func (*MsgCancelSubscriptionRequest) XXX_DiscardUnknown 

func (m *MsgCancelSubscriptionRequest) XXX_DiscardUnknown()

func (*MsgCancelSubscriptionRequest) XXX_Marshal 

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

func (*MsgCancelSubscriptionRequest) XXX_Merge 

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

func (*MsgCancelSubscriptionRequest) XXX_Size 

func (m *MsgCancelSubscriptionRequest) XXX_Size() int

func (*MsgCancelSubscriptionRequest) XXX_Unmarshal 

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

type MsgCancelSubscriptionResponse 

type MsgCancelSubscriptionResponse struct {
}

func (*MsgCancelSubscriptionResponse) Descriptor 

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

func (*MsgCancelSubscriptionResponse) Marshal 

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

func (*MsgCancelSubscriptionResponse) MarshalTo 

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

func (*MsgCancelSubscriptionResponse) MarshalToSizedBuffer 

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

func (*MsgCancelSubscriptionResponse) ProtoMessage 

func (*MsgCancelSubscriptionResponse) ProtoMessage()

func (*MsgCancelSubscriptionResponse) Reset 

func (m *MsgCancelSubscriptionResponse) Reset()

func (*MsgCancelSubscriptionResponse) Size 

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

func (*MsgCancelSubscriptionResponse) String 

func (m *MsgCancelSubscriptionResponse) String() string

func (*MsgCancelSubscriptionResponse) Unmarshal 

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

func (*MsgCancelSubscriptionResponse) XXX_DiscardUnknown 

func (m *MsgCancelSubscriptionResponse) XXX_DiscardUnknown()

func (*MsgCancelSubscriptionResponse) XXX_Marshal 

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

func (*MsgCancelSubscriptionResponse) XXX_Merge 

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

func (*MsgCancelSubscriptionResponse) XXX_Size 

func (m *MsgCancelSubscriptionResponse) XXX_Size() int

func (*MsgCancelSubscriptionResponse) XXX_Unmarshal 

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

type MsgRenewSubscriptionRequest 

type MsgRenewSubscriptionRequest struct {
	From  string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID    uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Denom string `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"`
}

func NewMsgRenewSubscriptionRequest 

func NewMsgRenewSubscriptionRequest(from sdk.AccAddress, id uint64, denom string) *MsgRenewSubscriptionRequest

func (*MsgRenewSubscriptionRequest) Descriptor 

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

func (*MsgRenewSubscriptionRequest) GetSigners 

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

func (*MsgRenewSubscriptionRequest) Marshal 

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

func (*MsgRenewSubscriptionRequest) MarshalTo 

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

func (*MsgRenewSubscriptionRequest) MarshalToSizedBuffer 

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

func (*MsgRenewSubscriptionRequest) ProtoMessage 

func (*MsgRenewSubscriptionRequest) ProtoMessage()

func (*MsgRenewSubscriptionRequest) Reset 

func (m *MsgRenewSubscriptionRequest) Reset()

func (*MsgRenewSubscriptionRequest) Size 

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

func (*MsgRenewSubscriptionRequest) String 

func (m *MsgRenewSubscriptionRequest) String() string

func (*MsgRenewSubscriptionRequest) Unmarshal 

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

func (*MsgRenewSubscriptionRequest) ValidateBasic 

func (m *MsgRenewSubscriptionRequest) ValidateBasic() error

func (*MsgRenewSubscriptionRequest) XXX_DiscardUnknown 

func (m *MsgRenewSubscriptionRequest) XXX_DiscardUnknown()

func (*MsgRenewSubscriptionRequest) XXX_Marshal 

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

func (*MsgRenewSubscriptionRequest) XXX_Merge 

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

func (*MsgRenewSubscriptionRequest) XXX_Size 

func (m *MsgRenewSubscriptionRequest) XXX_Size() int

func (*MsgRenewSubscriptionRequest) XXX_Unmarshal 

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

type MsgRenewSubscriptionResponse 

type MsgRenewSubscriptionResponse struct {
}

func (*MsgRenewSubscriptionResponse) Descriptor 

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

func (*MsgRenewSubscriptionResponse) Marshal 

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

func (*MsgRenewSubscriptionResponse) MarshalTo 

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

func (*MsgRenewSubscriptionResponse) MarshalToSizedBuffer 

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

func (*MsgRenewSubscriptionResponse) ProtoMessage 

func (*MsgRenewSubscriptionResponse) ProtoMessage()

func (*MsgRenewSubscriptionResponse) Reset 

func (m *MsgRenewSubscriptionResponse) Reset()

func (*MsgRenewSubscriptionResponse) Size 

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

func (*MsgRenewSubscriptionResponse) String 

func (m *MsgRenewSubscriptionResponse) String() string

func (*MsgRenewSubscriptionResponse) Unmarshal 

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

func (*MsgRenewSubscriptionResponse) XXX_DiscardUnknown 

func (m *MsgRenewSubscriptionResponse) XXX_DiscardUnknown()

func (*MsgRenewSubscriptionResponse) XXX_Marshal 

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

func (*MsgRenewSubscriptionResponse) XXX_Merge 

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

func (*MsgRenewSubscriptionResponse) XXX_Size 

func (m *MsgRenewSubscriptionResponse) XXX_Size() int

func (*MsgRenewSubscriptionResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	MsgCancelSubscription(ctx context.Context, in *MsgCancelSubscriptionRequest, opts ...grpc.CallOption) (*MsgCancelSubscriptionResponse, error)
	MsgRenewSubscription(ctx context.Context, in *MsgRenewSubscriptionRequest, opts ...grpc.CallOption) (*MsgRenewSubscriptionResponse, error)
	MsgShareSubscription(ctx context.Context, in *MsgShareSubscriptionRequest, opts ...grpc.CallOption) (*MsgShareSubscriptionResponse, error)
	MsgStartSubscription(ctx context.Context, in *MsgStartSubscriptionRequest, opts ...grpc.CallOption) (*MsgStartSubscriptionResponse, error)
	MsgUpdateSubscription(ctx context.Context, in *MsgUpdateSubscriptionRequest, opts ...grpc.CallOption) (*MsgUpdateSubscriptionResponse, error)
	MsgStartSession(ctx context.Context, in *MsgStartSessionRequest, opts ...grpc.CallOption) (*MsgStartSessionResponse, error)
	MsgUpdateParams(ctx context.Context, in *MsgUpdateParamsRequest, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 {
	MsgCancelSubscription(context.Context, *MsgCancelSubscriptionRequest) (*MsgCancelSubscriptionResponse, error)
	MsgRenewSubscription(context.Context, *MsgRenewSubscriptionRequest) (*MsgRenewSubscriptionResponse, error)
	MsgShareSubscription(context.Context, *MsgShareSubscriptionRequest) (*MsgShareSubscriptionResponse, error)
	MsgStartSubscription(context.Context, *MsgStartSubscriptionRequest) (*MsgStartSubscriptionResponse, error)
	MsgUpdateSubscription(context.Context, *MsgUpdateSubscriptionRequest) (*MsgUpdateSubscriptionResponse, error)
	MsgStartSession(context.Context, *MsgStartSessionRequest) (*MsgStartSessionResponse, error)
	MsgUpdateParams(context.Context, *MsgUpdateParamsRequest) (*MsgUpdateParamsResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgShareSubscriptionRequest 

type MsgShareSubscriptionRequest struct {
	From       string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID         uint64                `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress string                `protobuf:"bytes,3,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	Bytes      cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=bytes,proto3,customtype=cosmossdk.io/math.Int" json:"bytes"`
}

func NewMsgShareSubscriptionRequest 

func NewMsgShareSubscriptionRequest(from sdk.AccAddress, id uint64, accAddr sdk.AccAddress, bytes sdkmath.Int) *MsgShareSubscriptionRequest

func (*MsgShareSubscriptionRequest) Descriptor 

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

func (*MsgShareSubscriptionRequest) GetSigners 

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

func (*MsgShareSubscriptionRequest) Marshal 

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

func (*MsgShareSubscriptionRequest) MarshalTo 

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

func (*MsgShareSubscriptionRequest) MarshalToSizedBuffer 

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

func (*MsgShareSubscriptionRequest) ProtoMessage 

func (*MsgShareSubscriptionRequest) ProtoMessage()

func (*MsgShareSubscriptionRequest) Reset 

func (m *MsgShareSubscriptionRequest) Reset()

func (*MsgShareSubscriptionRequest) Size 

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

func (*MsgShareSubscriptionRequest) String 

func (m *MsgShareSubscriptionRequest) String() string

func (*MsgShareSubscriptionRequest) Unmarshal 

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

func (*MsgShareSubscriptionRequest) ValidateBasic 

func (m *MsgShareSubscriptionRequest) ValidateBasic() error

func (*MsgShareSubscriptionRequest) XXX_DiscardUnknown 

func (m *MsgShareSubscriptionRequest) XXX_DiscardUnknown()

func (*MsgShareSubscriptionRequest) XXX_Marshal 

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

func (*MsgShareSubscriptionRequest) XXX_Merge 

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

func (*MsgShareSubscriptionRequest) XXX_Size 

func (m *MsgShareSubscriptionRequest) XXX_Size() int

func (*MsgShareSubscriptionRequest) XXX_Unmarshal 

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

type MsgShareSubscriptionResponse 

type MsgShareSubscriptionResponse struct {
}

func (*MsgShareSubscriptionResponse) Descriptor 

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

func (*MsgShareSubscriptionResponse) Marshal 

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

func (*MsgShareSubscriptionResponse) MarshalTo 

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

func (*MsgShareSubscriptionResponse) MarshalToSizedBuffer 

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

func (*MsgShareSubscriptionResponse) ProtoMessage 

func (*MsgShareSubscriptionResponse) ProtoMessage()

func (*MsgShareSubscriptionResponse) Reset 

func (m *MsgShareSubscriptionResponse) Reset()

func (*MsgShareSubscriptionResponse) Size 

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

func (*MsgShareSubscriptionResponse) String 

func (m *MsgShareSubscriptionResponse) String() string

func (*MsgShareSubscriptionResponse) Unmarshal 

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

func (*MsgShareSubscriptionResponse) XXX_DiscardUnknown 

func (m *MsgShareSubscriptionResponse) XXX_DiscardUnknown()

func (*MsgShareSubscriptionResponse) XXX_Marshal 

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

func (*MsgShareSubscriptionResponse) XXX_Merge 

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

func (*MsgShareSubscriptionResponse) XXX_Size 

func (m *MsgShareSubscriptionResponse) XXX_Size() int

func (*MsgShareSubscriptionResponse) XXX_Unmarshal 

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

type MsgStartSessionRequest 

type MsgStartSessionRequest struct {
	From        string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID          uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func NewMsgStartSessionRequest 

func NewMsgStartSessionRequest(from sdk.AccAddress, id uint64, nodeAddr base.NodeAddress) *MsgStartSessionRequest

func (*MsgStartSessionRequest) Descriptor 

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

func (*MsgStartSessionRequest) GetSigners 

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

func (*MsgStartSessionRequest) Marshal 

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

func (*MsgStartSessionRequest) MarshalTo 

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

func (*MsgStartSessionRequest) MarshalToSizedBuffer 

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

func (*MsgStartSessionRequest) ProtoMessage 

func (*MsgStartSessionRequest) ProtoMessage()

func (*MsgStartSessionRequest) Reset 

func (m *MsgStartSessionRequest) Reset()

func (*MsgStartSessionRequest) Size 

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

func (*MsgStartSessionRequest) String 

func (m *MsgStartSessionRequest) String() string

func (*MsgStartSessionRequest) Unmarshal 

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

func (*MsgStartSessionRequest) ValidateBasic 

func (m *MsgStartSessionRequest) ValidateBasic() error

func (*MsgStartSessionRequest) XXX_DiscardUnknown 

func (m *MsgStartSessionRequest) XXX_DiscardUnknown()

func (*MsgStartSessionRequest) XXX_Marshal 

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

func (*MsgStartSessionRequest) XXX_Merge 

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

func (*MsgStartSessionRequest) XXX_Size 

func (m *MsgStartSessionRequest) XXX_Size() int

func (*MsgStartSessionRequest) XXX_Unmarshal 

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

type MsgStartSessionResponse 

type MsgStartSessionResponse struct {
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*MsgStartSessionResponse) Descriptor 

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

func (*MsgStartSessionResponse) Marshal 

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

func (*MsgStartSessionResponse) MarshalTo 

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

func (*MsgStartSessionResponse) MarshalToSizedBuffer 

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

func (*MsgStartSessionResponse) ProtoMessage 

func (*MsgStartSessionResponse) ProtoMessage()

func (*MsgStartSessionResponse) Reset 

func (m *MsgStartSessionResponse) Reset()

func (*MsgStartSessionResponse) Size 

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

func (*MsgStartSessionResponse) String 

func (m *MsgStartSessionResponse) String() string

func (*MsgStartSessionResponse) Unmarshal 

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

func (*MsgStartSessionResponse) XXX_DiscardUnknown 

func (m *MsgStartSessionResponse) XXX_DiscardUnknown()

func (*MsgStartSessionResponse) XXX_Marshal 

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

func (*MsgStartSessionResponse) XXX_Merge 

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

func (*MsgStartSessionResponse) XXX_Size 

func (m *MsgStartSessionResponse) XXX_Size() int

func (*MsgStartSessionResponse) XXX_Unmarshal 

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

type MsgStartSubscriptionRequest 

type MsgStartSubscriptionRequest struct {
	From               string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID                 uint64                `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Denom              string                `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"`
	RenewalPricePolicy v1.RenewalPricePolicy `` /* 160-byte string literal not displayed */
}

func NewMsgStartSubscriptionRequest 

func NewMsgStartSubscriptionRequest(from sdk.AccAddress, id uint64, denom string, renewalPricePolicy v1base.RenewalPricePolicy) *MsgStartSubscriptionRequest

func (*MsgStartSubscriptionRequest) Descriptor 

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

func (*MsgStartSubscriptionRequest) GetSigners 

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

func (*MsgStartSubscriptionRequest) Marshal 

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

func (*MsgStartSubscriptionRequest) MarshalTo 

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

func (*MsgStartSubscriptionRequest) MarshalToSizedBuffer 

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

func (*MsgStartSubscriptionRequest) ProtoMessage 

func (*MsgStartSubscriptionRequest) ProtoMessage()

func (*MsgStartSubscriptionRequest) Reset 

func (m *MsgStartSubscriptionRequest) Reset()

func (*MsgStartSubscriptionRequest) Size 

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

func (*MsgStartSubscriptionRequest) String 

func (m *MsgStartSubscriptionRequest) String() string

func (*MsgStartSubscriptionRequest) Unmarshal 

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

func (*MsgStartSubscriptionRequest) ValidateBasic 

func (m *MsgStartSubscriptionRequest) ValidateBasic() error

func (*MsgStartSubscriptionRequest) XXX_DiscardUnknown 

func (m *MsgStartSubscriptionRequest) XXX_DiscardUnknown()

func (*MsgStartSubscriptionRequest) XXX_Marshal 

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

func (*MsgStartSubscriptionRequest) XXX_Merge 

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

func (*MsgStartSubscriptionRequest) XXX_Size 

func (m *MsgStartSubscriptionRequest) XXX_Size() int

func (*MsgStartSubscriptionRequest) XXX_Unmarshal 

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

type MsgStartSubscriptionResponse 

type MsgStartSubscriptionResponse struct {
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*MsgStartSubscriptionResponse) Descriptor 

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

func (*MsgStartSubscriptionResponse) Marshal 

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

func (*MsgStartSubscriptionResponse) MarshalTo 

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

func (*MsgStartSubscriptionResponse) MarshalToSizedBuffer 

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

func (*MsgStartSubscriptionResponse) ProtoMessage 

func (*MsgStartSubscriptionResponse) ProtoMessage()

func (*MsgStartSubscriptionResponse) Reset 

func (m *MsgStartSubscriptionResponse) Reset()

func (*MsgStartSubscriptionResponse) Size 

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

func (*MsgStartSubscriptionResponse) String 

func (m *MsgStartSubscriptionResponse) String() string

func (*MsgStartSubscriptionResponse) Unmarshal 

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

func (*MsgStartSubscriptionResponse) XXX_DiscardUnknown 

func (m *MsgStartSubscriptionResponse) XXX_DiscardUnknown()

func (*MsgStartSubscriptionResponse) XXX_Marshal 

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

func (*MsgStartSubscriptionResponse) XXX_Merge 

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

func (*MsgStartSubscriptionResponse) XXX_Size 

func (m *MsgStartSubscriptionResponse) XXX_Size() int

func (*MsgStartSubscriptionResponse) XXX_Unmarshal 

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

type MsgUpdateParamsRequest 

type MsgUpdateParamsRequest struct {
	From   string    `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Params v2.Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

func NewMsgUpdateParamsRequest 

func NewMsgUpdateParamsRequest(from sdk.AccAddress, params v2.Params) *MsgUpdateParamsRequest

func (*MsgUpdateParamsRequest) Descriptor 

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

func (*MsgUpdateParamsRequest) GetSigners 

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

func (*MsgUpdateParamsRequest) Marshal 

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

func (*MsgUpdateParamsRequest) MarshalTo 

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

func (*MsgUpdateParamsRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsRequest) ProtoMessage 

func (*MsgUpdateParamsRequest) ProtoMessage()

func (*MsgUpdateParamsRequest) Reset 

func (m *MsgUpdateParamsRequest) Reset()

func (*MsgUpdateParamsRequest) Size 

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

func (*MsgUpdateParamsRequest) String 

func (m *MsgUpdateParamsRequest) String() string

func (*MsgUpdateParamsRequest) Unmarshal 

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

func (*MsgUpdateParamsRequest) ValidateBasic 

func (m *MsgUpdateParamsRequest) ValidateBasic() error

func (*MsgUpdateParamsRequest) XXX_DiscardUnknown 

func (m *MsgUpdateParamsRequest) XXX_DiscardUnknown()

func (*MsgUpdateParamsRequest) XXX_Marshal 

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

func (*MsgUpdateParamsRequest) XXX_Merge 

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

func (*MsgUpdateParamsRequest) XXX_Size 

func (m *MsgUpdateParamsRequest) XXX_Size() int

func (*MsgUpdateParamsRequest) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MsgUpdateSubscriptionRequest 

type MsgUpdateSubscriptionRequest struct {
	From               string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID                 uint64                `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	RenewalPricePolicy v1.RenewalPricePolicy `` /* 160-byte string literal not displayed */
}

func NewMsgUpdateSubscriptionRequest 

func NewMsgUpdateSubscriptionRequest(from sdk.AccAddress, id uint64, renewalPricePolicy v1base.RenewalPricePolicy) *MsgUpdateSubscriptionRequest

func (*MsgUpdateSubscriptionRequest) Descriptor 

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

func (*MsgUpdateSubscriptionRequest) GetSigners 

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

func (*MsgUpdateSubscriptionRequest) Marshal 

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

func (*MsgUpdateSubscriptionRequest) MarshalTo 

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

func (*MsgUpdateSubscriptionRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateSubscriptionRequest) ProtoMessage 

func (*MsgUpdateSubscriptionRequest) ProtoMessage()

func (*MsgUpdateSubscriptionRequest) Reset 

func (m *MsgUpdateSubscriptionRequest) Reset()

func (*MsgUpdateSubscriptionRequest) Size 

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

func (*MsgUpdateSubscriptionRequest) String 

func (m *MsgUpdateSubscriptionRequest) String() string

func (*MsgUpdateSubscriptionRequest) Unmarshal 

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

func (*MsgUpdateSubscriptionRequest) ValidateBasic 

func (m *MsgUpdateSubscriptionRequest) ValidateBasic() error

func (*MsgUpdateSubscriptionRequest) XXX_DiscardUnknown 

func (m *MsgUpdateSubscriptionRequest) XXX_DiscardUnknown()

func (*MsgUpdateSubscriptionRequest) XXX_Marshal 

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

func (*MsgUpdateSubscriptionRequest) XXX_Merge 

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

func (*MsgUpdateSubscriptionRequest) XXX_Size 

func (m *MsgUpdateSubscriptionRequest) XXX_Size() int

func (*MsgUpdateSubscriptionRequest) XXX_Unmarshal 

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

type MsgUpdateSubscriptionResponse 

type MsgUpdateSubscriptionResponse struct {
}

func (*MsgUpdateSubscriptionResponse) Descriptor 

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

func (*MsgUpdateSubscriptionResponse) Marshal 

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

func (*MsgUpdateSubscriptionResponse) MarshalTo 

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

func (*MsgUpdateSubscriptionResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateSubscriptionResponse) ProtoMessage 

func (*MsgUpdateSubscriptionResponse) ProtoMessage()

func (*MsgUpdateSubscriptionResponse) Reset 

func (m *MsgUpdateSubscriptionResponse) Reset()

func (*MsgUpdateSubscriptionResponse) Size 

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

func (*MsgUpdateSubscriptionResponse) String 

func (m *MsgUpdateSubscriptionResponse) String() string

func (*MsgUpdateSubscriptionResponse) Unmarshal 

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

func (*MsgUpdateSubscriptionResponse) XXX_DiscardUnknown 

func (m *MsgUpdateSubscriptionResponse) XXX_DiscardUnknown()

func (*MsgUpdateSubscriptionResponse) XXX_Marshal 

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

func (*MsgUpdateSubscriptionResponse) XXX_Merge 

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

func (*MsgUpdateSubscriptionResponse) XXX_Size 

func (m *MsgUpdateSubscriptionResponse) XXX_Size() int

func (*MsgUpdateSubscriptionResponse) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	QuerySubscriptions(ctx context.Context, in *QuerySubscriptionsRequest, opts ...grpc.CallOption) (*QuerySubscriptionsResponse, error)
	QuerySubscriptionsForAccount(ctx context.Context, in *QuerySubscriptionsForAccountRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForAccountResponse, error)
	QuerySubscriptionsForPlan(ctx context.Context, in *QuerySubscriptionsForPlanRequest, opts ...grpc.CallOption) (*QuerySubscriptionsForPlanResponse, error)
	QuerySubscription(ctx context.Context, in *QuerySubscriptionRequest, opts ...grpc.CallOption) (*QuerySubscriptionResponse, 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 {
	QuerySubscriptions(context.Context, *QuerySubscriptionsRequest) (*QuerySubscriptionsResponse, error)
	QuerySubscriptionsForAccount(context.Context, *QuerySubscriptionsForAccountRequest) (*QuerySubscriptionsForAccountResponse, error)
	QuerySubscriptionsForPlan(context.Context, *QuerySubscriptionsForPlanRequest) (*QuerySubscriptionsForPlanResponse, error)
	QuerySubscription(context.Context, *QuerySubscriptionRequest) (*QuerySubscriptionResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QuerySubscriptionRequest 

type QuerySubscriptionRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

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 {
	Subscription Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"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 {
	Address    string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySubscriptionsForAccountRequest 

func NewQuerySubscriptionsForAccountRequest(addr sdk.AccAddress, pagination *sdkquery.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 {
	Subscriptions []Subscription      `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
	Pagination    *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

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 QuerySubscriptionsForPlanRequest 

type QuerySubscriptionsForPlanRequest struct {
	Id         uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySubscriptionsForPlanRequest 

func NewQuerySubscriptionsForPlanRequest(id uint64, pagination *sdkquery.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 {
	Subscriptions []Subscription      `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
	Pagination    *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

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 {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySubscriptionsRequest 

func NewQuerySubscriptionsRequest(pagination *sdkquery.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 {
	Subscriptions []Subscription      `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
	Pagination    *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

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 Session 

type Session struct {
	ID             uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress     string                `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	NodeAddress    string                `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	SubscriptionID uint64                `protobuf:"varint,4,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	DownloadBytes  cosmossdk_io_math.Int `protobuf:"bytes,5,opt,name=download_bytes,json=downloadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"download_bytes"`
	UploadBytes    cosmossdk_io_math.Int `protobuf:"bytes,6,opt,name=upload_bytes,json=uploadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"upload_bytes"`
	Duration       time.Duration         `protobuf:"bytes,7,opt,name=duration,proto3,stdduration" json:"duration"`
	Status         v1.Status             `protobuf:"varint,8,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	InactiveAt     time.Time             `protobuf:"bytes,9,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	StatusAt       time.Time             `protobuf:"bytes,10,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Session) Descriptor 

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

func (*Session) GetAccAddress 

func (m *Session) GetAccAddress() string

func (*Session) GetDownloadBytes 

func (m *Session) GetDownloadBytes() sdkmath.Int

func (*Session) GetDuration 

func (m *Session) GetDuration() time.Duration

func (*Session) GetID 

func (m *Session) GetID() uint64

func (*Session) GetInactiveAt 

func (m *Session) GetInactiveAt() time.Time

func (*Session) GetNodeAddress 

func (m *Session) GetNodeAddress() string

func (*Session) GetStatus 

func (m *Session) GetStatus() v1.Status

func (*Session) GetStatusAt 

func (m *Session) GetStatusAt() time.Time

func (*Session) GetSubscriptionID 

func (m *Session) GetSubscriptionID() uint64

func (*Session) GetUploadBytes 

func (m *Session) GetUploadBytes() sdkmath.Int

func (*Session) Marshal 

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

func (*Session) MarshalTo 

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

func (*Session) MarshalToSizedBuffer 

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

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) SetDownloadBytes 

func (m *Session) SetDownloadBytes(v sdkmath.Int)

func (*Session) SetDuration 

func (m *Session) SetDuration(v time.Duration)

func (*Session) SetInactiveAt 

func (m *Session) SetInactiveAt(v time.Time)

func (*Session) SetStatus 

func (m *Session) SetStatus(v v1base.Status)

func (*Session) SetStatusAt 

func (m *Session) SetStatusAt(v time.Time)

func (*Session) SetUploadBytes 

func (m *Session) SetUploadBytes(v sdkmath.Int)

func (*Session) Size 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal 

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

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type Subscription 

type Subscription struct {
	ID                 uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress         string                `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	PlanID             uint64                `protobuf:"varint,3,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	Price              v1.Price              `protobuf:"bytes,4,opt,name=price,proto3" json:"price"`
	RenewalPricePolicy v1.RenewalPricePolicy `` /* 160-byte string literal not displayed */
	Status             v1.Status             `protobuf:"varint,6,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	InactiveAt         time.Time             `protobuf:"bytes,7,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	StatusAt           time.Time             `protobuf:"bytes,8,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Subscription) Descriptor 

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

func (*Subscription) Marshal 

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

func (*Subscription) MarshalTo 

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

func (*Subscription) MarshalToSizedBuffer 

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

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) RenewalAt 

func (m *Subscription) RenewalAt() time.Time

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) Size 

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

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) Unmarshal 

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

func (*Subscription) Validate 

func (m *Subscription) Validate() error

func (*Subscription) ValidateRenewalPolicies 

func (m *Subscription) ValidateRenewalPolicies(price v1base.Price) error

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

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

func (*Subscription) XXX_Merge 

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

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

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

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgCancelSubscription 

func (*UnimplementedMsgServiceServer) MsgCancelSubscription(ctx context.Context, req *MsgCancelSubscriptionRequest) (*MsgCancelSubscriptionResponse, error)

func (*UnimplementedMsgServiceServer) MsgRenewSubscription 

func (*UnimplementedMsgServiceServer) MsgRenewSubscription(ctx context.Context, req *MsgRenewSubscriptionRequest) (*MsgRenewSubscriptionResponse, error)

func (*UnimplementedMsgServiceServer) MsgShareSubscription 

func (*UnimplementedMsgServiceServer) MsgShareSubscription(ctx context.Context, req *MsgShareSubscriptionRequest) (*MsgShareSubscriptionResponse, error)

func (*UnimplementedMsgServiceServer) MsgStartSession 

func (*UnimplementedMsgServiceServer) MsgStartSession(ctx context.Context, req *MsgStartSessionRequest) (*MsgStartSessionResponse, error)

func (*UnimplementedMsgServiceServer) MsgStartSubscription 

func (*UnimplementedMsgServiceServer) MsgStartSubscription(ctx context.Context, req *MsgStartSubscriptionRequest) (*MsgStartSubscriptionResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateParams 

func (*UnimplementedMsgServiceServer) MsgUpdateParams(ctx context.Context, req *MsgUpdateParamsRequest) (*MsgUpdateParamsResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateSubscription 

func (*UnimplementedMsgServiceServer) MsgUpdateSubscription(ctx context.Context, req *MsgUpdateSubscriptionRequest) (*MsgUpdateSubscriptionResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

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) 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.