types

package
v0.12.2 Latest Latest
Warning

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

Go to latest
Published: Oct 30, 2024 License: Apache-2.0 Imports: 42 Imported by: 4

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	// ModuleName is the name of the module
	ModuleName = "sds"

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName

	// RouterKey to be used for routing msgs
	RouterKey = ModuleName
)
View Source
const (
	TypeMsgFileUpload   = "FileUploadTx"
	TypeMsgPrepay       = "SdsPrepayTx"
	TypeMsgUpdateParams = "update_params"
)
View Source
const (
	DefaultBondDenom = stratos.Wei
)

Variables

View Source
var (
	ErrInvalid                = errors.Register(ModuleName, codeErrInvalid, "error invalid")
	ErrInvalidHeight          = errors.Register(ModuleName, codeErrInvalidHeight, "invalid height")
	ErrEmptyUploaderAddr      = errors.Register(ModuleName, codeErrEmptyUploaderAddr, "missing uploader address")
	ErrEmptyReporters         = errors.Register(ModuleName, codeErrEmptyReporters, "missing reporters")
	ErrEmptyFileHash          = errors.Register(ModuleName, codeErrEmptyFileHash, "missing file hash")
	ErrInvalidFileHash        = errors.Register(ModuleName, codeErrInvalidFileHash, "invalid file hash")
	ErrNoFileFound            = errors.Register(ModuleName, codeErrNoFileFound, "file does not exist")
	ErrInvalidDenom           = errors.Register(ModuleName, codeErrInvalidDenom, "invalid denomination")
	ErrPrepayFailure          = errors.Register(ModuleName, codeErrPrepayFailure, "failure during prepay")
	ErrReporterAddressOrOwner = errors.Register(ModuleName, codeErrReporterAddressOrOwner, "invalid reporter address or owner address")
	ErrInvalidSenderAddr      = errors.Register(ModuleName, codeErrInvalidSenderAddr, "invalid sender address")
	ErrInvalidBeneficiaryAddr = errors.Register(ModuleName, codeErrInvalidBeneficiaryAddr, "invalid beneficiary address")
	ErrOzoneLimitNotEnough    = errors.Register(ModuleName, codeErrOzoneLimitNotEnough, "not enough remaining ozone limit to complete prepay")
	ErrEmitEvent              = errors.Register(ModuleName, codeErrEmitEvent, "failed to emit event")
)
View Source
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = 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 (
	FileStoreKeyPrefix = []byte{0x01} // FileStorage prefix for sds store

	ParamsKey = []byte{0x20}
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthSds        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSds          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSds = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	KeyBondDenom = []byte("BondDenom")
)
View Source
var ModuleCdc *codec.LegacyAmino

ModuleCdc references the global x/sds module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding as Amino is still used for that purpose.

The actual codec used for serialization should be provided to x/sds and defined at the application level.

Functions

func GetFileStoreKey added in v0.12.0

func GetFileStoreKey(sender []byte) []byte

GetFileStoreKey turn an address to key used to get it from the account store

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for sds module Deprecated: now params can be accessed on key `0x20` on the sds store.

func RegisterInterfaces added in v0.8.0

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the x/register interfaces types with the interface registry

func RegisterLegacyAminoCodec added in v0.8.0

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on codec

func RegisterMsgServer added in v0.8.0

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v0.8.0

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

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

func RegisterQueryHandlerClient added in v0.8.0

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

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

func RegisterQueryHandlerFromEndpoint added in v0.8.0

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

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

func RegisterQueryHandlerServer added in v0.8.0

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

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

func RegisterQueryServer added in v0.8.0

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateGenesis

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates the sds genesis parameters

Types

type BankKeeper added in v0.12.0

type BankKeeper interface {
	HasBalance(ctx sdk.Context, addr sdk.AccAddress, amt sdk.Coin) bool
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type EventFileUpload added in v0.12.0

type EventFileUpload struct {
	Sender   string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Reporter string `protobuf:"bytes,2,opt,name=reporter,proto3" json:"reporter,omitempty"`
	Uploader string `protobuf:"bytes,3,opt,name=uploader,proto3" json:"uploader,omitempty"`
	FileHash string `protobuf:"bytes,4,opt,name=file_hash,json=fileHash,proto3" json:"file_hash,omitempty"`
}

EventFileUpload is emitted on Msg/MsgFileUpload

func (*EventFileUpload) Descriptor added in v0.12.0

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

func (*EventFileUpload) GetFileHash added in v0.12.0

func (m *EventFileUpload) GetFileHash() string

func (*EventFileUpload) GetReporter added in v0.12.0

func (m *EventFileUpload) GetReporter() string

func (*EventFileUpload) GetSender added in v0.12.0

func (m *EventFileUpload) GetSender() string

func (*EventFileUpload) GetUploader added in v0.12.0

func (m *EventFileUpload) GetUploader() string

func (*EventFileUpload) Marshal added in v0.12.0

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

func (*EventFileUpload) MarshalTo added in v0.12.0

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

func (*EventFileUpload) MarshalToSizedBuffer added in v0.12.0

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

func (*EventFileUpload) ProtoMessage added in v0.12.0

func (*EventFileUpload) ProtoMessage()

func (*EventFileUpload) Reset added in v0.12.0

func (m *EventFileUpload) Reset()

func (*EventFileUpload) Size added in v0.12.0

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

func (*EventFileUpload) String added in v0.12.0

func (m *EventFileUpload) String() string

func (*EventFileUpload) Unmarshal added in v0.12.0

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

func (*EventFileUpload) XXX_DiscardUnknown added in v0.12.0

func (m *EventFileUpload) XXX_DiscardUnknown()

func (*EventFileUpload) XXX_Marshal added in v0.12.0

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

func (*EventFileUpload) XXX_Merge added in v0.12.0

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

func (*EventFileUpload) XXX_Size added in v0.12.0

func (m *EventFileUpload) XXX_Size() int

func (*EventFileUpload) XXX_Unmarshal added in v0.12.0

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

type EventPrePay added in v0.12.0

type EventPrePay struct {
	Sender       string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Beneficiary  string `protobuf:"bytes,2,opt,name=beneficiary,proto3" json:"beneficiary,omitempty"`
	Amount       string `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	PurchasedNoz string `protobuf:"bytes,4,opt,name=purchased_noz,json=purchasedNoz,proto3" json:"purchased_noz,omitempty"`
}

EventPrePay is emitted on Msg/MsgPrepay

func (*EventPrePay) Descriptor added in v0.12.0

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

func (*EventPrePay) GetAmount added in v0.12.0

func (m *EventPrePay) GetAmount() string

func (*EventPrePay) GetBeneficiary added in v0.12.0

func (m *EventPrePay) GetBeneficiary() string

func (*EventPrePay) GetPurchasedNoz added in v0.12.0

func (m *EventPrePay) GetPurchasedNoz() string

func (*EventPrePay) GetSender added in v0.12.0

func (m *EventPrePay) GetSender() string

func (*EventPrePay) Marshal added in v0.12.0

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

func (*EventPrePay) MarshalTo added in v0.12.0

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

func (*EventPrePay) MarshalToSizedBuffer added in v0.12.0

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

func (*EventPrePay) ProtoMessage added in v0.12.0

func (*EventPrePay) ProtoMessage()

func (*EventPrePay) Reset added in v0.12.0

func (m *EventPrePay) Reset()

func (*EventPrePay) Size added in v0.12.0

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

func (*EventPrePay) String added in v0.12.0

func (m *EventPrePay) String() string

func (*EventPrePay) Unmarshal added in v0.12.0

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

func (*EventPrePay) XXX_DiscardUnknown added in v0.12.0

func (m *EventPrePay) XXX_DiscardUnknown()

func (*EventPrePay) XXX_Marshal added in v0.12.0

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

func (*EventPrePay) XXX_Merge added in v0.12.0

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

func (*EventPrePay) XXX_Size added in v0.12.0

func (m *EventPrePay) XXX_Size() int

func (*EventPrePay) XXX_Unmarshal added in v0.12.0

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

type FileInfo

type FileInfo struct {
	Height    github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=height,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"height" yaml:"height"`
	Reporters []byte                                 `protobuf:"bytes,2,opt,name=reporters,proto3" json:"reporters" yaml:"reporters"`
	Uploader  string                                 `protobuf:"bytes,3,opt,name=uploader,proto3" json:"uploader" yaml:"uploader"`
}

func NewFileInfo

func NewFileInfo(height sdkmath.Int, reporters []byte, uploader string) FileInfo

NewFileInfo constructor

func (*FileInfo) Descriptor added in v0.8.0

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

func (*FileInfo) Equal added in v0.12.0

func (this *FileInfo) Equal(that interface{}) bool

func (*FileInfo) GetReporters added in v0.10.0

func (m *FileInfo) GetReporters() []byte

func (*FileInfo) GetUploader added in v0.8.0

func (m *FileInfo) GetUploader() string

func (*FileInfo) Marshal added in v0.8.0

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

func (*FileInfo) MarshalTo added in v0.8.0

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

func (*FileInfo) MarshalToSizedBuffer added in v0.8.0

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

func (*FileInfo) ProtoMessage added in v0.8.0

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset added in v0.8.0

func (m *FileInfo) Reset()

func (*FileInfo) Size added in v0.8.0

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

func (*FileInfo) String

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal added in v0.8.0

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

func (*FileInfo) XXX_DiscardUnknown added in v0.8.0

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal added in v0.8.0

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

func (*FileInfo) XXX_Merge added in v0.8.0

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

func (*FileInfo) XXX_Size added in v0.8.0

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal added in v0.8.0

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

type GenesisFileInfo added in v0.10.0

type GenesisFileInfo struct {
	FileHash string   `protobuf:"bytes,1,opt,name=file_hash,json=fileHash,proto3" json:"file_hash" yaml:"file_hash"`
	FileInfo FileInfo `protobuf:"bytes,2,opt,name=file_info,json=fileInfo,proto3" json:"file_info" yaml:"file_info"`
}

func (*GenesisFileInfo) Descriptor added in v0.10.0

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

func (*GenesisFileInfo) Equal added in v0.12.0

func (this *GenesisFileInfo) Equal(that interface{}) bool

func (*GenesisFileInfo) GetFileHash added in v0.10.0

func (m *GenesisFileInfo) GetFileHash() string

func (*GenesisFileInfo) GetFileInfo added in v0.10.0

func (m *GenesisFileInfo) GetFileInfo() FileInfo

func (*GenesisFileInfo) Marshal added in v0.10.0

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

func (*GenesisFileInfo) MarshalTo added in v0.10.0

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

func (*GenesisFileInfo) MarshalToSizedBuffer added in v0.10.0

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

func (*GenesisFileInfo) ProtoMessage added in v0.10.0

func (*GenesisFileInfo) ProtoMessage()

func (*GenesisFileInfo) Reset added in v0.10.0

func (m *GenesisFileInfo) Reset()

func (*GenesisFileInfo) Size added in v0.10.0

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

func (*GenesisFileInfo) String added in v0.10.0

func (m *GenesisFileInfo) String() string

func (*GenesisFileInfo) Unmarshal added in v0.10.0

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

func (*GenesisFileInfo) XXX_DiscardUnknown added in v0.10.0

func (m *GenesisFileInfo) XXX_DiscardUnknown()

func (*GenesisFileInfo) XXX_Marshal added in v0.10.0

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

func (*GenesisFileInfo) XXX_Merge added in v0.10.0

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

func (*GenesisFileInfo) XXX_Size added in v0.10.0

func (m *GenesisFileInfo) XXX_Size() int

func (*GenesisFileInfo) XXX_Unmarshal added in v0.10.0

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

type GenesisState

type GenesisState struct {
	Params Params            `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
	Files  []GenesisFileInfo `protobuf:"bytes,2,rep,name=files,proto3" json:"files" yaml:"files"`
}

GenesisState defines the register module's genesis state.

func DefaultGenesisState

func DefaultGenesisState() *GenesisState

DefaultGenesisState - default GenesisState used by Cosmos Hub

func GetGenesisStateFromAppState added in v0.6.2

func GetGenesisStateFromAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage) GenesisState

GetGenesisStateFromAppState returns x/auth GenesisState given raw application genesis state.

func NewGenesisState

func NewGenesisState(params Params, files []GenesisFileInfo) *GenesisState

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor added in v0.8.0

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

func (*GenesisState) Equal added in v0.12.0

func (this *GenesisState) Equal(that interface{}) bool

func (*GenesisState) GetFiles added in v0.10.0

func (m *GenesisState) GetFiles() []GenesisFileInfo

func (*GenesisState) GetParams added in v0.8.0

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal added in v0.8.0

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

func (*GenesisState) MarshalTo added in v0.8.0

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

func (*GenesisState) MarshalToSizedBuffer added in v0.8.0

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

func (*GenesisState) ProtoMessage added in v0.8.0

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.8.0

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.8.0

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

func (*GenesisState) String added in v0.8.0

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.8.0

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

func (*GenesisState) XXX_DiscardUnknown added in v0.8.0

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.8.0

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

func (*GenesisState) XXX_Merge added in v0.8.0

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

func (*GenesisState) XXX_Size added in v0.8.0

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.8.0

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

type MsgClient added in v0.8.0

type MsgClient interface {
	// HandleMsgFileUpload defines a method for file uploading
	HandleMsgFileUpload(ctx context.Context, in *MsgFileUpload, opts ...grpc.CallOption) (*MsgFileUploadResponse, error)
	// HandleMsgPrepay defines a method for prepay
	HandleMsgPrepay(ctx context.Context, in *MsgPrepay, opts ...grpc.CallOption) (*MsgPrepayResponse, error)
	// UpdateParams defined a governance operation for updating the x/sds module parameters.
	// The authority is hard-coded to the Cosmos SDK x/gov module account
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient added in v0.8.0

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgFileUpload

type MsgFileUpload struct {
	FileHash string `protobuf:"bytes,1,opt,name=file_hash,json=fileHash,proto3" json:"file_hash" yaml:"file_hash"`
	From     string `protobuf:"bytes,2,opt,name=from,proto3" json:"from" yaml:"from"`
	Reporter string `protobuf:"bytes,3,opt,name=reporter,proto3" json:"reporter" yaml:"reporter"`
	Uploader string `protobuf:"bytes,4,opt,name=uploader,proto3" json:"uploader" yaml:"uploader"`
}

func NewMsgUpload

func NewMsgUpload(fileHash string, from, reporter, uploader string) *MsgFileUpload

NewMsgUpload creates a new Msg<Action> instance

func (*MsgFileUpload) Descriptor added in v0.8.0

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

func (*MsgFileUpload) Equal added in v0.12.0

func (this *MsgFileUpload) Equal(that interface{}) bool

func (*MsgFileUpload) GetFileHash added in v0.8.0

func (m *MsgFileUpload) GetFileHash() string

func (*MsgFileUpload) GetFrom added in v0.8.0

func (m *MsgFileUpload) GetFrom() string

func (*MsgFileUpload) GetReporter added in v0.8.0

func (m *MsgFileUpload) GetReporter() string

func (MsgFileUpload) GetSignBytes

func (msg MsgFileUpload) GetSignBytes() []byte

GetSignBytes gets the bytes for the message signer to sign on

func (MsgFileUpload) GetSigners

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

func (*MsgFileUpload) GetUploader added in v0.8.0

func (m *MsgFileUpload) GetUploader() string

func (*MsgFileUpload) GetWeb3Msg added in v0.12.0

func (m *MsgFileUpload) GetWeb3Msg() (*stratos.Web3Msg, error)

func (*MsgFileUpload) Marshal added in v0.8.0

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

func (*MsgFileUpload) MarshalTo added in v0.8.0

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

func (*MsgFileUpload) MarshalToSizedBuffer added in v0.8.0

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

func (*MsgFileUpload) ProtoMessage added in v0.8.0

func (*MsgFileUpload) ProtoMessage()

func (*MsgFileUpload) Reset added in v0.8.0

func (m *MsgFileUpload) Reset()

func (MsgFileUpload) Route

func (msg MsgFileUpload) Route() string

nolint

func (*MsgFileUpload) Size added in v0.8.0

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

func (*MsgFileUpload) String added in v0.8.0

func (m *MsgFileUpload) String() string

func (MsgFileUpload) Type

func (msg MsgFileUpload) Type() string

func (*MsgFileUpload) Unmarshal added in v0.8.0

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

func (MsgFileUpload) ValidateBasic

func (msg MsgFileUpload) ValidateBasic() error

ValidateBasic validity check for the AnteHandler

func (*MsgFileUpload) XXX_DiscardUnknown added in v0.8.0

func (m *MsgFileUpload) XXX_DiscardUnknown()

func (*MsgFileUpload) XXX_Marshal added in v0.8.0

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

func (*MsgFileUpload) XXX_Merge added in v0.8.0

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

func (*MsgFileUpload) XXX_Size added in v0.8.0

func (m *MsgFileUpload) XXX_Size() int

func (*MsgFileUpload) XXX_Unmarshal added in v0.8.0

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

type MsgFileUploadResponse added in v0.8.0

type MsgFileUploadResponse struct {
}

func (*MsgFileUploadResponse) Descriptor added in v0.8.0

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

func (*MsgFileUploadResponse) Equal added in v0.12.0

func (this *MsgFileUploadResponse) Equal(that interface{}) bool

func (*MsgFileUploadResponse) Marshal added in v0.8.0

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

func (*MsgFileUploadResponse) MarshalTo added in v0.8.0

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

func (*MsgFileUploadResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*MsgFileUploadResponse) ProtoMessage added in v0.8.0

func (*MsgFileUploadResponse) ProtoMessage()

func (*MsgFileUploadResponse) Reset added in v0.8.0

func (m *MsgFileUploadResponse) Reset()

func (*MsgFileUploadResponse) Size added in v0.8.0

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

func (*MsgFileUploadResponse) String added in v0.8.0

func (m *MsgFileUploadResponse) String() string

func (*MsgFileUploadResponse) Unmarshal added in v0.8.0

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

func (*MsgFileUploadResponse) XXX_DiscardUnknown added in v0.8.0

func (m *MsgFileUploadResponse) XXX_DiscardUnknown()

func (*MsgFileUploadResponse) XXX_Marshal added in v0.8.0

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

func (*MsgFileUploadResponse) XXX_Merge added in v0.8.0

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

func (*MsgFileUploadResponse) XXX_Size added in v0.8.0

func (m *MsgFileUploadResponse) XXX_Size() int

func (*MsgFileUploadResponse) XXX_Unmarshal added in v0.8.0

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

type MsgPrepay

type MsgPrepay struct {
	Sender      string                                   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender" yaml:"sender"`
	Beneficiary string                                   `protobuf:"bytes,2,opt,name=beneficiary,proto3" json:"beneficiary" yaml:"beneficiary"`
	Amount      github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount" yaml:"amount"`
}

func NewMsgPrepay

func NewMsgPrepay(sender string, beneficiary string, amount sdk.Coins) *MsgPrepay

NewMsgPrepay NewMsg<Action> creates a new Msg<Action> instance

func (*MsgPrepay) Descriptor added in v0.8.0

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

func (*MsgPrepay) Equal added in v0.12.0

func (this *MsgPrepay) Equal(that interface{}) bool

func (*MsgPrepay) GetAmount added in v0.10.0

func (*MsgPrepay) GetBeneficiary added in v0.10.0

func (m *MsgPrepay) GetBeneficiary() string

func (*MsgPrepay) GetSender added in v0.8.0

func (m *MsgPrepay) GetSender() string

func (MsgPrepay) GetSignBytes

func (msg MsgPrepay) GetSignBytes() []byte

GetSignBytes gets the bytes for the message signer to sign on

func (MsgPrepay) GetSigners

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

func (*MsgPrepay) GetWeb3Msg added in v0.12.0

func (m *MsgPrepay) GetWeb3Msg() (*stratos.Web3Msg, error)

func (*MsgPrepay) Marshal added in v0.8.0

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

func (*MsgPrepay) MarshalTo added in v0.8.0

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

func (*MsgPrepay) MarshalToSizedBuffer added in v0.8.0

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

func (*MsgPrepay) ProtoMessage added in v0.8.0

func (*MsgPrepay) ProtoMessage()

func (*MsgPrepay) Reset added in v0.8.0

func (m *MsgPrepay) Reset()

func (MsgPrepay) Route

func (msg MsgPrepay) Route() string

func (*MsgPrepay) Size added in v0.8.0

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

func (*MsgPrepay) String added in v0.8.0

func (m *MsgPrepay) String() string

func (MsgPrepay) Type

func (msg MsgPrepay) Type() string

func (*MsgPrepay) Unmarshal added in v0.8.0

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

func (MsgPrepay) ValidateBasic

func (msg MsgPrepay) ValidateBasic() error

ValidateBasic validity check for the AnteHandler

func (*MsgPrepay) XXX_DiscardUnknown added in v0.8.0

func (m *MsgPrepay) XXX_DiscardUnknown()

func (*MsgPrepay) XXX_Marshal added in v0.8.0

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

func (*MsgPrepay) XXX_Merge added in v0.8.0

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

func (*MsgPrepay) XXX_Size added in v0.8.0

func (m *MsgPrepay) XXX_Size() int

func (*MsgPrepay) XXX_Unmarshal added in v0.8.0

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

type MsgPrepayResponse added in v0.8.0

type MsgPrepayResponse struct {
}

func (*MsgPrepayResponse) Descriptor added in v0.8.0

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

func (*MsgPrepayResponse) Equal added in v0.12.0

func (this *MsgPrepayResponse) Equal(that interface{}) bool

func (*MsgPrepayResponse) Marshal added in v0.8.0

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

func (*MsgPrepayResponse) MarshalTo added in v0.8.0

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

func (*MsgPrepayResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*MsgPrepayResponse) ProtoMessage added in v0.8.0

func (*MsgPrepayResponse) ProtoMessage()

func (*MsgPrepayResponse) Reset added in v0.8.0

func (m *MsgPrepayResponse) Reset()

func (*MsgPrepayResponse) Size added in v0.8.0

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

func (*MsgPrepayResponse) String added in v0.8.0

func (m *MsgPrepayResponse) String() string

func (*MsgPrepayResponse) Unmarshal added in v0.8.0

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

func (*MsgPrepayResponse) XXX_DiscardUnknown added in v0.8.0

func (m *MsgPrepayResponse) XXX_DiscardUnknown()

func (*MsgPrepayResponse) XXX_Marshal added in v0.8.0

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

func (*MsgPrepayResponse) XXX_Merge added in v0.8.0

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

func (*MsgPrepayResponse) XXX_Size added in v0.8.0

func (m *MsgPrepayResponse) XXX_Size() int

func (*MsgPrepayResponse) XXX_Unmarshal added in v0.8.0

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

type MsgServer added in v0.8.0

type MsgServer interface {
	// HandleMsgFileUpload defines a method for file uploading
	HandleMsgFileUpload(context.Context, *MsgFileUpload) (*MsgFileUploadResponse, error)
	// HandleMsgPrepay defines a method for prepay
	HandleMsgPrepay(context.Context, *MsgPrepay) (*MsgPrepayResponse, error)
	// UpdateParams defined a governance operation for updating the x/sds module parameters.
	// The authority is hard-coded to the Cosmos SDK x/gov module account
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams added in v0.12.0

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/sds parameters to update.
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams defines a Msg for updating the x/sds module parameters.

func NewMsgUpdateParams added in v0.12.0

func NewMsgUpdateParams(params Params, authority string) *MsgUpdateParams

func (*MsgUpdateParams) Descriptor added in v0.12.0

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

func (*MsgUpdateParams) Equal added in v0.12.0

func (this *MsgUpdateParams) Equal(that interface{}) bool

func (*MsgUpdateParams) GetAuthority added in v0.12.0

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams added in v0.12.0

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSignBytes added in v0.12.0

func (msg *MsgUpdateParams) GetSignBytes() []byte

GetSigners implements legacytx.LegacyMsg

func (*MsgUpdateParams) GetSigners added in v0.12.0

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

GetSignBytes implements sdk.Msg

func (*MsgUpdateParams) Marshal added in v0.12.0

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

func (*MsgUpdateParams) MarshalTo added in v0.12.0

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

func (*MsgUpdateParams) MarshalToSizedBuffer added in v0.12.0

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

func (*MsgUpdateParams) ProtoMessage added in v0.12.0

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset added in v0.12.0

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Route added in v0.12.0

func (msg *MsgUpdateParams) Route() string

Route implements legacytx.LegacyMsg

func (*MsgUpdateParams) Size added in v0.12.0

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

func (*MsgUpdateParams) String added in v0.12.0

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Type added in v0.12.0

func (msg *MsgUpdateParams) Type() string

Type implements legacytx.LegacyMsg

func (*MsgUpdateParams) Unmarshal added in v0.12.0

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

func (*MsgUpdateParams) ValidateBasic added in v0.12.0

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgUpdateParams) XXX_DiscardUnknown added in v0.12.0

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal added in v0.12.0

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

func (*MsgUpdateParams) XXX_Merge added in v0.12.0

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

func (*MsgUpdateParams) XXX_Size added in v0.12.0

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal added in v0.12.0

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

type MsgUpdateParamsResponse added in v0.12.0

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor added in v0.12.0

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

func (*MsgUpdateParamsResponse) Equal added in v0.12.0

func (this *MsgUpdateParamsResponse) Equal(that interface{}) bool

func (*MsgUpdateParamsResponse) Marshal added in v0.12.0

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

func (*MsgUpdateParamsResponse) MarshalTo added in v0.12.0

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer added in v0.12.0

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

func (*MsgUpdateParamsResponse) ProtoMessage added in v0.12.0

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset added in v0.12.0

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size added in v0.12.0

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

func (*MsgUpdateParamsResponse) String added in v0.12.0

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal added in v0.12.0

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown added in v0.12.0

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal added in v0.12.0

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

func (*MsgUpdateParamsResponse) XXX_Merge added in v0.12.0

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

func (*MsgUpdateParamsResponse) XXX_Size added in v0.12.0

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal added in v0.12.0

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

type Params

type Params struct {
	BondDenom string `protobuf:"bytes,1,opt,name=bond_denom,json=bondDenom,proto3" json:"bond_denom" yaml:"bond_denom"`
}

Params defines the parameters for the sds module.

func DefaultParams

func DefaultParams() Params

DefaultParams defines the parameters for this module

func NewParams

func NewParams(bondDenom string) Params

NewParams creates a new Params object

func (*Params) Descriptor added in v0.8.0

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

func (*Params) Equal added in v0.12.0

func (this *Params) Equal(that interface{}) bool

func (*Params) GetBondDenom added in v0.8.0

func (m *Params) GetBondDenom() string

func (*Params) Marshal added in v0.8.0

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

func (*Params) MarshalTo added in v0.8.0

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

func (*Params) MarshalToSizedBuffer added in v0.8.0

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

func (*Params) ParamSetPairs

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

ParamSetPairs - Implements params.ParamSet Deprecated.

func (*Params) ProtoMessage added in v0.8.0

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.8.0

func (m *Params) Reset()

func (*Params) Size added in v0.8.0

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

func (*Params) String

func (m *Params) String() string

func (*Params) Unmarshal added in v0.8.0

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

func (Params) Validate added in v0.12.0

func (p Params) Validate() error

func (*Params) XXX_DiscardUnknown added in v0.8.0

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.8.0

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

func (*Params) XXX_Merge added in v0.8.0

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

func (*Params) XXX_Size added in v0.8.0

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.8.0

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

type ParamsSubspace added in v0.12.0

type ParamsSubspace interface {
	GetParamSet(ctx sdk.Context, ps paramstypes.ParamSet)
}

ParamsSubspace defines an interface that implements the legacy x/params ParamsSubspace type.

NOTE: This is used solely for migration of x/params managed parameters.

type PotKeeper added in v0.12.0

type PotKeeper interface {
	GetCurrentNozPrice(St, Pt, Lt sdkmath.Int) (currentNozPrice sdkmath.LegacyDec)
	NozSupply(ctx sdk.Context) (remaining, total sdkmath.Int)
}

type QueryClient added in v0.8.0

type QueryClient interface {
	// Query uploaded file info by hash
	Fileupload(ctx context.Context, in *QueryFileUploadRequest, opts ...grpc.CallOption) (*QueryFileUploadResponse, error)
	SimPrepay(ctx context.Context, in *QuerySimPrepayRequest, opts ...grpc.CallOption) (*QuerySimPrepayResponse, error)
	NozPrice(ctx context.Context, in *QueryNozPriceRequest, opts ...grpc.CallOption) (*QueryNozPriceResponse, error)
	NozSupply(ctx context.Context, in *QueryNozSupplyRequest, opts ...grpc.CallOption) (*QueryNozSupplyResponse, error)
	// Params queries SDS module Params info.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient added in v0.8.0

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryFileUploadRequest added in v0.8.0

type QueryFileUploadRequest struct {
	// network_addr defines the node network address to query for.
	FileHash string `protobuf:"bytes,1,opt,name=file_hash,json=fileHash,proto3" json:"file_hash,omitempty"`
}

QueryFileuploadRequest is request type for the Query/Fileupload RPC method

func (*QueryFileUploadRequest) Descriptor added in v0.8.0

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

func (*QueryFileUploadRequest) GetFileHash added in v0.8.0

func (m *QueryFileUploadRequest) GetFileHash() string

func (*QueryFileUploadRequest) Marshal added in v0.8.0

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

func (*QueryFileUploadRequest) MarshalTo added in v0.8.0

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

func (*QueryFileUploadRequest) MarshalToSizedBuffer added in v0.8.0

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

func (*QueryFileUploadRequest) ProtoMessage added in v0.8.0

func (*QueryFileUploadRequest) ProtoMessage()

func (*QueryFileUploadRequest) Reset added in v0.8.0

func (m *QueryFileUploadRequest) Reset()

func (*QueryFileUploadRequest) Size added in v0.8.0

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

func (*QueryFileUploadRequest) String added in v0.8.0

func (m *QueryFileUploadRequest) String() string

func (*QueryFileUploadRequest) Unmarshal added in v0.8.0

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

func (*QueryFileUploadRequest) XXX_DiscardUnknown added in v0.8.0

func (m *QueryFileUploadRequest) XXX_DiscardUnknown()

func (*QueryFileUploadRequest) XXX_Marshal added in v0.8.0

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

func (*QueryFileUploadRequest) XXX_Merge added in v0.8.0

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

func (*QueryFileUploadRequest) XXX_Size added in v0.8.0

func (m *QueryFileUploadRequest) XXX_Size() int

func (*QueryFileUploadRequest) XXX_Unmarshal added in v0.8.0

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

type QueryFileUploadResponse added in v0.8.0

type QueryFileUploadResponse struct {
	FileInfo *FileInfo `protobuf:"bytes,1,opt,name=file_info,json=fileInfo,proto3" json:"file_info,omitempty"`
}

QueryFileuploadResponse is response type for the Query/Fileupload RPC method

func (*QueryFileUploadResponse) Descriptor added in v0.8.0

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

func (*QueryFileUploadResponse) GetFileInfo added in v0.8.0

func (m *QueryFileUploadResponse) GetFileInfo() *FileInfo

func (*QueryFileUploadResponse) Marshal added in v0.8.0

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

func (*QueryFileUploadResponse) MarshalTo added in v0.8.0

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

func (*QueryFileUploadResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*QueryFileUploadResponse) ProtoMessage added in v0.8.0

func (*QueryFileUploadResponse) ProtoMessage()

func (*QueryFileUploadResponse) Reset added in v0.8.0

func (m *QueryFileUploadResponse) Reset()

func (*QueryFileUploadResponse) Size added in v0.8.0

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

func (*QueryFileUploadResponse) String added in v0.8.0

func (m *QueryFileUploadResponse) String() string

func (*QueryFileUploadResponse) Unmarshal added in v0.8.0

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

func (*QueryFileUploadResponse) XXX_DiscardUnknown added in v0.8.0

func (m *QueryFileUploadResponse) XXX_DiscardUnknown()

func (*QueryFileUploadResponse) XXX_Marshal added in v0.8.0

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

func (*QueryFileUploadResponse) XXX_Merge added in v0.8.0

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

func (*QueryFileUploadResponse) XXX_Size added in v0.8.0

func (m *QueryFileUploadResponse) XXX_Size() int

func (*QueryFileUploadResponse) XXX_Unmarshal added in v0.8.0

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

type QueryNozPriceRequest added in v0.10.0

type QueryNozPriceRequest struct {
}

func (*QueryNozPriceRequest) Descriptor added in v0.10.0

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

func (*QueryNozPriceRequest) Marshal added in v0.10.0

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

func (*QueryNozPriceRequest) MarshalTo added in v0.10.0

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

func (*QueryNozPriceRequest) MarshalToSizedBuffer added in v0.10.0

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

func (*QueryNozPriceRequest) ProtoMessage added in v0.10.0

func (*QueryNozPriceRequest) ProtoMessage()

func (*QueryNozPriceRequest) Reset added in v0.10.0

func (m *QueryNozPriceRequest) Reset()

func (*QueryNozPriceRequest) Size added in v0.10.0

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

func (*QueryNozPriceRequest) String added in v0.10.0

func (m *QueryNozPriceRequest) String() string

func (*QueryNozPriceRequest) Unmarshal added in v0.10.0

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

func (*QueryNozPriceRequest) XXX_DiscardUnknown added in v0.10.0

func (m *QueryNozPriceRequest) XXX_DiscardUnknown()

func (*QueryNozPriceRequest) XXX_Marshal added in v0.10.0

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

func (*QueryNozPriceRequest) XXX_Merge added in v0.10.0

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

func (*QueryNozPriceRequest) XXX_Size added in v0.10.0

func (m *QueryNozPriceRequest) XXX_Size() int

func (*QueryNozPriceRequest) XXX_Unmarshal added in v0.10.0

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

type QueryNozPriceResponse added in v0.10.0

type QueryNozPriceResponse struct {
	Price github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price" yaml:"price"`
}

func (*QueryNozPriceResponse) Descriptor added in v0.10.0

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

func (*QueryNozPriceResponse) Marshal added in v0.10.0

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

func (*QueryNozPriceResponse) MarshalTo added in v0.10.0

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

func (*QueryNozPriceResponse) MarshalToSizedBuffer added in v0.10.0

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

func (*QueryNozPriceResponse) ProtoMessage added in v0.10.0

func (*QueryNozPriceResponse) ProtoMessage()

func (*QueryNozPriceResponse) Reset added in v0.10.0

func (m *QueryNozPriceResponse) Reset()

func (*QueryNozPriceResponse) Size added in v0.10.0

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

func (*QueryNozPriceResponse) String added in v0.10.0

func (m *QueryNozPriceResponse) String() string

func (*QueryNozPriceResponse) Unmarshal added in v0.10.0

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

func (*QueryNozPriceResponse) XXX_DiscardUnknown added in v0.10.0

func (m *QueryNozPriceResponse) XXX_DiscardUnknown()

func (*QueryNozPriceResponse) XXX_Marshal added in v0.10.0

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

func (*QueryNozPriceResponse) XXX_Merge added in v0.10.0

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

func (*QueryNozPriceResponse) XXX_Size added in v0.10.0

func (m *QueryNozPriceResponse) XXX_Size() int

func (*QueryNozPriceResponse) XXX_Unmarshal added in v0.10.0

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

type QueryNozSupplyRequest added in v0.10.0

type QueryNozSupplyRequest struct {
}

func (*QueryNozSupplyRequest) Descriptor added in v0.10.0

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

func (*QueryNozSupplyRequest) Marshal added in v0.10.0

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

func (*QueryNozSupplyRequest) MarshalTo added in v0.10.0

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

func (*QueryNozSupplyRequest) MarshalToSizedBuffer added in v0.10.0

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

func (*QueryNozSupplyRequest) ProtoMessage added in v0.10.0

func (*QueryNozSupplyRequest) ProtoMessage()

func (*QueryNozSupplyRequest) Reset added in v0.10.0

func (m *QueryNozSupplyRequest) Reset()

func (*QueryNozSupplyRequest) Size added in v0.10.0

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

func (*QueryNozSupplyRequest) String added in v0.10.0

func (m *QueryNozSupplyRequest) String() string

func (*QueryNozSupplyRequest) Unmarshal added in v0.10.0

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

func (*QueryNozSupplyRequest) XXX_DiscardUnknown added in v0.10.0

func (m *QueryNozSupplyRequest) XXX_DiscardUnknown()

func (*QueryNozSupplyRequest) XXX_Marshal added in v0.10.0

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

func (*QueryNozSupplyRequest) XXX_Merge added in v0.10.0

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

func (*QueryNozSupplyRequest) XXX_Size added in v0.10.0

func (m *QueryNozSupplyRequest) XXX_Size() int

func (*QueryNozSupplyRequest) XXX_Unmarshal added in v0.10.0

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

type QueryNozSupplyResponse added in v0.10.0

type QueryNozSupplyResponse struct {
	Remaining github_com_cosmos_cosmos_sdk_types.Int `` /* 128-byte string literal not displayed */
	Total     github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=total,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"total" yaml:"total"`
}

func (*QueryNozSupplyResponse) Descriptor added in v0.10.0

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

func (*QueryNozSupplyResponse) Marshal added in v0.10.0

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

func (*QueryNozSupplyResponse) MarshalTo added in v0.10.0

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

func (*QueryNozSupplyResponse) MarshalToSizedBuffer added in v0.10.0

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

func (*QueryNozSupplyResponse) ProtoMessage added in v0.10.0

func (*QueryNozSupplyResponse) ProtoMessage()

func (*QueryNozSupplyResponse) Reset added in v0.10.0

func (m *QueryNozSupplyResponse) Reset()

func (*QueryNozSupplyResponse) Size added in v0.10.0

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

func (*QueryNozSupplyResponse) String added in v0.10.0

func (m *QueryNozSupplyResponse) String() string

func (*QueryNozSupplyResponse) Unmarshal added in v0.10.0

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

func (*QueryNozSupplyResponse) XXX_DiscardUnknown added in v0.10.0

func (m *QueryNozSupplyResponse) XXX_DiscardUnknown()

func (*QueryNozSupplyResponse) XXX_Marshal added in v0.10.0

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

func (*QueryNozSupplyResponse) XXX_Merge added in v0.10.0

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

func (*QueryNozSupplyResponse) XXX_Size added in v0.10.0

func (m *QueryNozSupplyResponse) XXX_Size() int

func (*QueryNozSupplyResponse) XXX_Unmarshal added in v0.10.0

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

type QueryParamsRequest added in v0.8.0

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor added in v0.8.0

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

func (*QueryParamsRequest) Marshal added in v0.8.0

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

func (*QueryParamsRequest) MarshalTo added in v0.8.0

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v0.8.0

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

func (*QueryParamsRequest) ProtoMessage added in v0.8.0

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v0.8.0

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v0.8.0

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

func (*QueryParamsRequest) String added in v0.8.0

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v0.8.0

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v0.8.0

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v0.8.0

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

func (*QueryParamsRequest) XXX_Merge added in v0.8.0

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

func (*QueryParamsRequest) XXX_Size added in v0.8.0

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v0.8.0

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

type QueryParamsResponse added in v0.8.0

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor added in v0.8.0

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

func (*QueryParamsResponse) GetParams added in v0.8.0

func (m *QueryParamsResponse) GetParams() *Params

func (*QueryParamsResponse) Marshal added in v0.8.0

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

func (*QueryParamsResponse) MarshalTo added in v0.8.0

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*QueryParamsResponse) ProtoMessage added in v0.8.0

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v0.8.0

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v0.8.0

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

func (*QueryParamsResponse) String added in v0.8.0

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v0.8.0

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v0.8.0

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v0.8.0

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

func (*QueryParamsResponse) XXX_Merge added in v0.8.0

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

func (*QueryParamsResponse) XXX_Size added in v0.8.0

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v0.8.0

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

type QueryServer added in v0.8.0

type QueryServer interface {
	// Query uploaded file info by hash
	Fileupload(context.Context, *QueryFileUploadRequest) (*QueryFileUploadResponse, error)
	SimPrepay(context.Context, *QuerySimPrepayRequest) (*QuerySimPrepayResponse, error)
	NozPrice(context.Context, *QueryNozPriceRequest) (*QueryNozPriceResponse, error)
	NozSupply(context.Context, *QueryNozSupplyRequest) (*QueryNozSupplyResponse, error)
	// Params queries SDS module Params info.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QuerySimPrepayRequest added in v0.10.0

type QuerySimPrepayRequest struct {
	Amount string `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount,omitempty"`
}

func (*QuerySimPrepayRequest) Descriptor added in v0.10.0

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

func (*QuerySimPrepayRequest) GetAmount added in v0.10.0

func (m *QuerySimPrepayRequest) GetAmount() string

func (*QuerySimPrepayRequest) Marshal added in v0.10.0

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

func (*QuerySimPrepayRequest) MarshalTo added in v0.10.0

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

func (*QuerySimPrepayRequest) MarshalToSizedBuffer added in v0.10.0

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

func (*QuerySimPrepayRequest) ProtoMessage added in v0.10.0

func (*QuerySimPrepayRequest) ProtoMessage()

func (*QuerySimPrepayRequest) Reset added in v0.10.0

func (m *QuerySimPrepayRequest) Reset()

func (*QuerySimPrepayRequest) Size added in v0.10.0

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

func (*QuerySimPrepayRequest) String added in v0.10.0

func (m *QuerySimPrepayRequest) String() string

func (*QuerySimPrepayRequest) Unmarshal added in v0.10.0

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

func (*QuerySimPrepayRequest) XXX_DiscardUnknown added in v0.10.0

func (m *QuerySimPrepayRequest) XXX_DiscardUnknown()

func (*QuerySimPrepayRequest) XXX_Marshal added in v0.10.0

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

func (*QuerySimPrepayRequest) XXX_Merge added in v0.10.0

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

func (*QuerySimPrepayRequest) XXX_Size added in v0.10.0

func (m *QuerySimPrepayRequest) XXX_Size() int

func (*QuerySimPrepayRequest) XXX_Unmarshal added in v0.10.0

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

type QuerySimPrepayResponse added in v0.10.0

type QuerySimPrepayResponse struct {
	Noz github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=noz,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"noz" yaml:"noz"`
}

func (*QuerySimPrepayResponse) Descriptor added in v0.10.0

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

func (*QuerySimPrepayResponse) Marshal added in v0.10.0

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

func (*QuerySimPrepayResponse) MarshalTo added in v0.10.0

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

func (*QuerySimPrepayResponse) MarshalToSizedBuffer added in v0.10.0

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

func (*QuerySimPrepayResponse) ProtoMessage added in v0.10.0

func (*QuerySimPrepayResponse) ProtoMessage()

func (*QuerySimPrepayResponse) Reset added in v0.10.0

func (m *QuerySimPrepayResponse) Reset()

func (*QuerySimPrepayResponse) Size added in v0.10.0

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

func (*QuerySimPrepayResponse) String added in v0.10.0

func (m *QuerySimPrepayResponse) String() string

func (*QuerySimPrepayResponse) Unmarshal added in v0.10.0

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

func (*QuerySimPrepayResponse) XXX_DiscardUnknown added in v0.10.0

func (m *QuerySimPrepayResponse) XXX_DiscardUnknown()

func (*QuerySimPrepayResponse) XXX_Marshal added in v0.10.0

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

func (*QuerySimPrepayResponse) XXX_Merge added in v0.10.0

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

func (*QuerySimPrepayResponse) XXX_Size added in v0.10.0

func (m *QuerySimPrepayResponse) XXX_Size() int

func (*QuerySimPrepayResponse) XXX_Unmarshal added in v0.10.0

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

type RegisterKeeper added in v0.12.0

type RegisterKeeper interface {
	GetCurrNozPriceParams(ctx sdk.Context) (St, Pt, Lt sdkmath.Int)
	GetEffectiveTotalDeposit(ctx sdk.Context) (deposit sdkmath.Int)
	GetMetaNodeBitMapIndex(ctx sdk.Context, networkAddr stratos.SdsAddress) (index int, err error)
	GetRemainingOzoneLimit(ctx sdk.Context) (value sdkmath.Int)
	GetTotalUnissuedPrepay(ctx sdk.Context) (totalUnissuedPrepay sdk.Coin)
	SetRemainingOzoneLimit(ctx sdk.Context, value sdkmath.Int)
	OwnMetaNode(ctx sdk.Context, ownerAddr sdk.AccAddress, p2pAddr stratos.SdsAddress) bool
	CalculatePurchaseAmount(ctx sdk.Context, amount sdkmath.Int) (sdkmath.Int, sdkmath.Int, error)
}

type UnimplementedMsgServer added in v0.8.0

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) HandleMsgFileUpload added in v0.8.0

func (*UnimplementedMsgServer) HandleMsgFileUpload(ctx context.Context, req *MsgFileUpload) (*MsgFileUploadResponse, error)

func (*UnimplementedMsgServer) HandleMsgPrepay added in v0.8.0

func (*UnimplementedMsgServer) HandleMsgPrepay(ctx context.Context, req *MsgPrepay) (*MsgPrepayResponse, error)

func (*UnimplementedMsgServer) UpdateParams added in v0.12.0

type UnimplementedQueryServer added in v0.8.0

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Fileupload added in v0.8.0

func (*UnimplementedQueryServer) NozPrice added in v0.10.0

func (*UnimplementedQueryServer) NozSupply added in v0.10.0

func (*UnimplementedQueryServer) Params added in v0.8.0

func (*UnimplementedQueryServer) SimPrepay added in v0.10.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL