types

package
v2.1.0-alpha2 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "datapool"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_datapool"
)
View Source 
const (
	PENDING = "PENDING"
	ACTIVE  = "ACTIVE"
)

Variables

View Source 
var (
	ErrNotEnoughPoolDeposit     = sdkerrors.Register(ModuleName, 1, "the deposit is not enough to make a data pool")
	ErrNoRegisteredNFTContract  = sdkerrors.Register(ModuleName, 2, "no NFT contract is registered")
	ErrPoolNotFound             = sdkerrors.Register(ModuleName, 3, "pool not found")
	ErrNotEqualsSeller          = sdkerrors.Register(ModuleName, 4, "the requester does not matched certificate information")
	ErrInvalidSignature         = sdkerrors.Register(ModuleName, 5, "failed to signature verify.")
	ErrInvalidDataCert          = sdkerrors.Register(ModuleName, 6, "certificate is not valid")
	ErrExistSameDataHash        = sdkerrors.Register(ModuleName, 7, "data already exists in the pool")
	ErrGetDataCert              = sdkerrors.Register(ModuleName, 8, "failed get certificate.")
	ErrRevenueDistribution      = sdkerrors.Register(ModuleName, 9, "failed to revenue distribution")
	ErrNFTAllIssued             = sdkerrors.Register(ModuleName, 10, "all NFTs issued")
	ErrRoundNotMatched          = sdkerrors.Register(ModuleName, 11, "data pool sales round not matched")
	ErrPaymentNotMatched        = sdkerrors.Register(ModuleName, 12, "payment not matched")
	ErrCreatePool               = sdkerrors.Register(ModuleName, 13, "failed to create data pool")
	ErrMintNFT                  = sdkerrors.Register(ModuleName, 14, "failed to mint NFT")
	ErrInstantiateContract      = sdkerrors.Register(ModuleName, 15, "failed to instantiate contract")
	ErrBuyDataPass              = sdkerrors.Register(ModuleName, 16, "failed to buy data pass")
	ErrGetDataPassRedeemReceipt = sdkerrors.Register(ModuleName, 17, "failed to get data pass receipt")
	ErrRedeemDataPass           = sdkerrors.Register(ModuleName, 18, "failed to redeem data pass")
	ErrNotOwnedRedeemerNft      = sdkerrors.Register(ModuleName, 19, "invalid nft id")
	ErrRedeemDataPassNotFound   = sdkerrors.Register(ModuleName, 20, "redeem data pass not found")
	ErrRedeemHistoryNotFound    = sdkerrors.Register(ModuleName, 21, "redeem history not found")
	ErrNoTrustedOracle          = sdkerrors.Register(ModuleName, 22, "no trusted oracle, but it is required")
)

x/datapool module sentinel errors

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 (
	// KeyPoolNextNumber defines key to store next Pool ID to be used
	KeyPoolNextNumber = []byte{0x01}

	// KeyPrefixPools defines key to store Pools
	KeyPrefixPools = []byte{0x02}

	// KeyPrefixOracleCerts defines key to store oracle certs
	KeyPrefixOracleCerts = []byte{0x03}

	// KeyPrefixNFTRedeemReceipts define key to store redeemed receipts
	KeyPrefixNFTRedeemReceipts = []byte{0x04}

	KeyPrefixSalesHistory = []byte{0x05}

	// KeyPrefixInstantRevenueDistribution defines key to distribution reward pool
	KeyPrefixInstantRevenueDistribution = []byte{0x06}

	// KeyPrefixDataPassRedeemHistory defines key to store redeem receipts by address
	KeyPrefixDataPassRedeemHistory = []byte{0x07}

	KeyIndexSeparator = []byte{0xFF}
)
View Source 
var (
	KeyDataPoolCommissionRate     = []byte("DataPoolCommissionRate")
	KeyDataPoolCodeID             = []byte("DataPoolCodeId")
	KeyDataPoolNFTContractAddress = []byte("DataPoolNftContractAddress")
)
View Source 
var (
	ErrInvalidLengthPool        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPool          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPool = fmt.Errorf("proto: unexpected end of group")
)
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 (
	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 (
	DefaultDataPoolCommissionRate = sdk.NewDecWithPrec(1, 2) // default 1%
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var ZeroFund = sdk.NewCoin(assets.MicroMedDenom, sdk.NewInt(0))

Functions

func CombineKeys 

func CombineKeys(keys ...[]byte) []byte

func GetKeyPrefixDataPassRedeemHistory 

func GetKeyPrefixDataPassRedeemHistory(redeemer string) []byte

func GetKeyPrefixDataPassRedeemHistoryByPool 

func GetKeyPrefixDataPassRedeemHistoryByPool(redeemer string, poolID uint64) []byte

func GetKeyPrefixDataValidateCert 

func GetKeyPrefixDataValidateCert(poolID, round uint64, dataHash []byte) []byte

func GetKeyPrefixDataValidateCerts 

func GetKeyPrefixDataValidateCerts(poolID, round uint64) []byte

func GetKeyPrefixNFTRedeemReceipt 

func GetKeyPrefixNFTRedeemReceipt(poolID, round, dataPassID uint64) []byte

func GetKeyPrefixNFTRedeemReceiptByPoolID 

func GetKeyPrefixNFTRedeemReceiptByPoolID(poolID uint64) []byte

func GetKeyPrefixPools 

func GetKeyPrefixPools(poolID uint64) []byte

func GetKeyPrefixSalesHistories 

func GetKeyPrefixSalesHistories(poolID, round uint64) []byte

func GetKeyPrefixSalesHistory 

func GetKeyPrefixSalesHistory(poolID, round uint64, seller string) []byte

func GetModuleAddress 

func GetModuleAddress() sdk.AccAddress

func NewPoolAddress 

func NewPoolAddress(poolID uint64) sdk.AccAddress

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	NewAccount(sdk.Context, authtypes.AccountI) authtypes.AccountI

	SetAccount(ctx sdk.Context, acc authtypes.AccountI)
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetPubKey(sdk.Context, sdk.AccAddress) (cryptotypes.PubKey, error)
}

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error

	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error

	GetSupply(ctx sdk.Context) exported.SupplyI
	SetSupply(ctx sdk.Context, supply exported.SupplyI)
}

type DataCert 

type DataCert struct {
	UnsignedCert *UnsignedDataCert `protobuf:"bytes,1,opt,name=unsigned_cert,json=unsignedCert,proto3" json:"unsigned_cert,omitempty"`
	Signature    []byte            `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
}

DataCert defines the certificate for data validation w/ data oricle signature.

func (*DataCert) Descriptor 

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

func (*DataCert) GetSignature 

func (m *DataCert) GetSignature() []byte

func (*DataCert) GetUnsignedCert 

func (m *DataCert) GetUnsignedCert() *UnsignedDataCert

func (*DataCert) Marshal 

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

func (*DataCert) MarshalTo 

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

func (*DataCert) MarshalToSizedBuffer 

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

func (*DataCert) ProtoMessage 

func (*DataCert) ProtoMessage()

func (*DataCert) Reset 

func (m *DataCert) Reset()

func (*DataCert) Size 

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

func (*DataCert) String 

func (m *DataCert) String() string

func (*DataCert) Unmarshal 

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

func (*DataCert) XXX_DiscardUnknown 

func (m *DataCert) XXX_DiscardUnknown()

func (*DataCert) XXX_Marshal 

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

func (*DataCert) XXX_Merge 

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

func (*DataCert) XXX_Size 

func (m *DataCert) XXX_Size() int

func (*DataCert) XXX_Unmarshal 

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

type DataPassRedeemHistory 

type DataPassRedeemHistory struct {
	Redeemer               string                  `protobuf:"bytes,1,opt,name=redeemer,proto3" json:"redeemer,omitempty"`
	PoolId                 uint64                  `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	DataPassRedeemReceipts []DataPassRedeemReceipt `protobuf:"bytes,3,rep,name=data_pass_redeem_receipts,json=dataPassRedeemReceipts,proto3" json:"data_pass_redeem_receipts"`
}

DataPassRedeemHistory defines a list of redeem histories

func (*DataPassRedeemHistory) AppendRedeemReceipt 

func (r *DataPassRedeemHistory) AppendRedeemReceipt(redeemReceipt DataPassRedeemReceipt)

func (*DataPassRedeemHistory) Descriptor 

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

func (*DataPassRedeemHistory) GetDataPassRedeemReceipts 

func (m *DataPassRedeemHistory) GetDataPassRedeemReceipts() []DataPassRedeemReceipt

func (*DataPassRedeemHistory) GetPoolId 

func (m *DataPassRedeemHistory) GetPoolId() uint64

func (*DataPassRedeemHistory) GetRedeemer 

func (m *DataPassRedeemHistory) GetRedeemer() string

func (*DataPassRedeemHistory) Marshal 

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

func (*DataPassRedeemHistory) MarshalTo 

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

func (*DataPassRedeemHistory) MarshalToSizedBuffer 

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

func (*DataPassRedeemHistory) ProtoMessage 

func (*DataPassRedeemHistory) ProtoMessage()

func (*DataPassRedeemHistory) Reset 

func (m *DataPassRedeemHistory) Reset()

func (*DataPassRedeemHistory) Size 

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

func (*DataPassRedeemHistory) String 

func (m *DataPassRedeemHistory) String() string

func (*DataPassRedeemHistory) Unmarshal 

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

func (*DataPassRedeemHistory) XXX_DiscardUnknown 

func (m *DataPassRedeemHistory) XXX_DiscardUnknown()

func (*DataPassRedeemHistory) XXX_Marshal 

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

func (*DataPassRedeemHistory) XXX_Merge 

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

func (*DataPassRedeemHistory) XXX_Size 

func (m *DataPassRedeemHistory) XXX_Size() int

func (*DataPassRedeemHistory) XXX_Unmarshal 

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

type DataPassRedeemReceipt 

type DataPassRedeemReceipt struct {
	PoolId     uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round      uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	DataPassId uint64 `protobuf:"varint,3,opt,name=data_pass_id,json=dataPassId,proto3" json:"data_pass_id,omitempty"`
	Redeemer   string `protobuf:"bytes,4,opt,name=redeemer,proto3" json:"redeemer,omitempty"`
}

DataPassRedeemReceipt defines a receipt for redeeming data pass to get data.

func NewDataPassRedeemReceipt 

func NewDataPassRedeemReceipt(poolID, round, dataPassID uint64, redeemer string) *DataPassRedeemReceipt

func (*DataPassRedeemReceipt) Descriptor 

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

func (*DataPassRedeemReceipt) GetDataPassId 

func (m *DataPassRedeemReceipt) GetDataPassId() uint64

func (*DataPassRedeemReceipt) GetPoolId 

func (m *DataPassRedeemReceipt) GetPoolId() uint64

func (*DataPassRedeemReceipt) GetRedeemer 

func (m *DataPassRedeemReceipt) GetRedeemer() string

func (*DataPassRedeemReceipt) GetRound 

func (m *DataPassRedeemReceipt) GetRound() uint64

func (*DataPassRedeemReceipt) Marshal 

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

func (*DataPassRedeemReceipt) MarshalTo 

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

func (*DataPassRedeemReceipt) MarshalToSizedBuffer 

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

func (*DataPassRedeemReceipt) ProtoMessage 

func (*DataPassRedeemReceipt) ProtoMessage()

func (*DataPassRedeemReceipt) Reset 

func (m *DataPassRedeemReceipt) Reset()

func (*DataPassRedeemReceipt) Size 

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

func (*DataPassRedeemReceipt) String 

func (m *DataPassRedeemReceipt) String() string

func (*DataPassRedeemReceipt) Unmarshal 

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

func (*DataPassRedeemReceipt) XXX_DiscardUnknown 

func (m *DataPassRedeemReceipt) XXX_DiscardUnknown()

func (*DataPassRedeemReceipt) XXX_Marshal 

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

func (*DataPassRedeemReceipt) XXX_Merge 

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

func (*DataPassRedeemReceipt) XXX_Size 

func (m *DataPassRedeemReceipt) XXX_Size() int

func (*DataPassRedeemReceipt) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	NextPoolNumber             uint64                     `protobuf:"varint,2,opt,name=next_pool_number,json=nextPoolNumber,proto3" json:"next_pool_number,omitempty"`
	Pools                      []Pool                     `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools"`
	Params                     Params                     `protobuf:"bytes,4,opt,name=params,proto3" json:"params"`
	DataPassRedeemReceipts     []DataPassRedeemReceipt    `protobuf:"bytes,5,rep,name=data_pass_redeem_receipts,json=dataPassRedeemReceipts,proto3" json:"data_pass_redeem_receipts"`
	InstantRevenueDistribution InstantRevenueDistribution `` /* 131-byte string literal not displayed */
	SalesHistories             []*SalesHistory            `protobuf:"bytes,7,rep,name=sales_histories,json=salesHistories,proto3" json:"sales_histories,omitempty"`
	DataPassRedeemHistories    []DataPassRedeemHistory    `protobuf:"bytes,8,rep,name=data_pass_redeem_histories,json=dataPassRedeemHistories,proto3" json:"data_pass_redeem_histories"`
}

GenesisState defines the datapool module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDataPassRedeemHistories 

func (m *GenesisState) GetDataPassRedeemHistories() []DataPassRedeemHistory

func (*GenesisState) GetDataPassRedeemReceipts 

func (m *GenesisState) GetDataPassRedeemReceipts() []DataPassRedeemReceipt

func (*GenesisState) GetInstantRevenueDistribution 

func (m *GenesisState) GetInstantRevenueDistribution() InstantRevenueDistribution

func (*GenesisState) GetNextPoolNumber 

func (m *GenesisState) GetNextPoolNumber() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPools 

func (m *GenesisState) GetPools() []Pool

func (*GenesisState) GetSalesHistories 

func (m *GenesisState) GetSalesHistories() []*SalesHistory

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

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type InstantRevenueDistribution 

type InstantRevenueDistribution struct {
	PoolIds []uint64 `protobuf:"varint,1,rep,packed,name=pool_ids,json=poolIds,proto3" json:"pool_ids,omitempty"`
}

InstantRevenueDistribution defines poolID information to distribution revenue.

func (*InstantRevenueDistribution) AppendPoolID 

func (d *InstantRevenueDistribution) AppendPoolID(poolID uint64)

AppendPoolID adds the poolID.

func (*InstantRevenueDistribution) Descriptor 

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

func (*InstantRevenueDistribution) GetPoolIds 

func (m *InstantRevenueDistribution) GetPoolIds() []uint64

func (*InstantRevenueDistribution) IsEmpty 

func (d *InstantRevenueDistribution) IsEmpty() bool

func (*InstantRevenueDistribution) Marshal 

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

func (*InstantRevenueDistribution) MarshalTo 

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

func (*InstantRevenueDistribution) MarshalToSizedBuffer 

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

func (*InstantRevenueDistribution) ProtoMessage 

func (*InstantRevenueDistribution) ProtoMessage()

func (*InstantRevenueDistribution) Reset 

func (m *InstantRevenueDistribution) Reset()

func (*InstantRevenueDistribution) Size 

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

func (*InstantRevenueDistribution) String 

func (m *InstantRevenueDistribution) String() string

func (*InstantRevenueDistribution) TruncateFromBeginning 

func (d *InstantRevenueDistribution) TruncateFromBeginning(idx int)

func (*InstantRevenueDistribution) Unmarshal 

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

func (*InstantRevenueDistribution) XXX_DiscardUnknown 

func (m *InstantRevenueDistribution) XXX_DiscardUnknown()

func (*InstantRevenueDistribution) XXX_Marshal 

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

func (*InstantRevenueDistribution) XXX_Merge 

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

func (*InstantRevenueDistribution) XXX_Size 

func (m *InstantRevenueDistribution) XXX_Size() int

func (*InstantRevenueDistribution) XXX_Unmarshal 

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

type InstantiateNFTMsg 

type InstantiateNFTMsg struct {
	Name   string `json:"name"`
	Symbol string `json:"symbol"`
	Minter string `json:"minter"`
}

func NewInstantiateNFTMsg 

func NewInstantiateNFTMsg(name, symbol, minterAddress string) *InstantiateNFTMsg

type MsgBuyDataPass 

type MsgBuyDataPass struct {
	PoolId  uint64      `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round   uint64      `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Payment *types.Coin `protobuf:"bytes,3,opt,name=payment,proto3" json:"payment,omitempty"`
	Buyer   string      `protobuf:"bytes,4,opt,name=buyer,proto3" json:"buyer,omitempty"`
}

MsgBuyDataPass defines the Msg/BuyDataPass request type.

func (*MsgBuyDataPass) Descriptor 

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

func (*MsgBuyDataPass) GetBuyer 

func (m *MsgBuyDataPass) GetBuyer() string

func (*MsgBuyDataPass) GetPayment 

func (m *MsgBuyDataPass) GetPayment() *types.Coin

func (*MsgBuyDataPass) GetPoolId 

func (m *MsgBuyDataPass) GetPoolId() uint64

func (*MsgBuyDataPass) GetRound 

func (m *MsgBuyDataPass) GetRound() uint64

func (*MsgBuyDataPass) GetSignBytes 

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

func (*MsgBuyDataPass) GetSigners 

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

func (*MsgBuyDataPass) Marshal 

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

func (*MsgBuyDataPass) MarshalTo 

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

func (*MsgBuyDataPass) MarshalToSizedBuffer 

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

func (*MsgBuyDataPass) ProtoMessage 

func (*MsgBuyDataPass) ProtoMessage()

func (*MsgBuyDataPass) Reset 

func (m *MsgBuyDataPass) Reset()

func (*MsgBuyDataPass) Route 

func (msg *MsgBuyDataPass) Route() string

func (*MsgBuyDataPass) Size 

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

func (*MsgBuyDataPass) String 

func (m *MsgBuyDataPass) String() string

func (*MsgBuyDataPass) Type 

func (msg *MsgBuyDataPass) Type() string

func (*MsgBuyDataPass) Unmarshal 

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

func (*MsgBuyDataPass) ValidateBasic 

func (msg *MsgBuyDataPass) ValidateBasic() error

func (*MsgBuyDataPass) XXX_DiscardUnknown 

func (m *MsgBuyDataPass) XXX_DiscardUnknown()

func (*MsgBuyDataPass) XXX_Marshal 

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

func (*MsgBuyDataPass) XXX_Merge 

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

func (*MsgBuyDataPass) XXX_Size 

func (m *MsgBuyDataPass) XXX_Size() int

func (*MsgBuyDataPass) XXX_Unmarshal 

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

type MsgBuyDataPassResponse 

type MsgBuyDataPassResponse struct {
	PoolId     uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round      uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	DataPassId uint64 `protobuf:"varint,3,opt,name=data_pass_id,json=dataPassId,proto3" json:"data_pass_id,omitempty"`
}

MsgBuyDataPassResponse defines the Msg/BuyDataPass response type.

func (*MsgBuyDataPassResponse) Descriptor 

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

func (*MsgBuyDataPassResponse) GetDataPassId 

func (m *MsgBuyDataPassResponse) GetDataPassId() uint64

func (*MsgBuyDataPassResponse) GetPoolId 

func (m *MsgBuyDataPassResponse) GetPoolId() uint64

func (*MsgBuyDataPassResponse) GetRound 

func (m *MsgBuyDataPassResponse) GetRound() uint64

func (*MsgBuyDataPassResponse) Marshal 

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

func (*MsgBuyDataPassResponse) MarshalTo 

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

func (*MsgBuyDataPassResponse) MarshalToSizedBuffer 

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

func (*MsgBuyDataPassResponse) ProtoMessage 

func (*MsgBuyDataPassResponse) ProtoMessage()

func (*MsgBuyDataPassResponse) Reset 

func (m *MsgBuyDataPassResponse) Reset()

func (*MsgBuyDataPassResponse) Size 

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

func (*MsgBuyDataPassResponse) String 

func (m *MsgBuyDataPassResponse) String() string

func (*MsgBuyDataPassResponse) Unmarshal 

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

func (*MsgBuyDataPassResponse) XXX_DiscardUnknown 

func (m *MsgBuyDataPassResponse) XXX_DiscardUnknown()

func (*MsgBuyDataPassResponse) XXX_Marshal 

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

func (*MsgBuyDataPassResponse) XXX_Merge 

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

func (*MsgBuyDataPassResponse) XXX_Size 

func (m *MsgBuyDataPassResponse) XXX_Size() int

func (*MsgBuyDataPassResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreatePool defines a method for creating data pool.
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	// SellData defines a method for selling data
	SellData(ctx context.Context, in *MsgSellData, opts ...grpc.CallOption) (*MsgSellDataResponse, error)
	// BuyDataPass defines a method for buying data pass
	BuyDataPass(ctx context.Context, in *MsgBuyDataPass, opts ...grpc.CallOption) (*MsgBuyDataPassResponse, error)
	// RedeemDataPass defines a method for redeeming data pass to get data
	RedeemDataPass(ctx context.Context, in *MsgRedeemDataPass, opts ...grpc.CallOption) (*MsgRedeemDataPassResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreatePool 

type MsgCreatePool struct {
	Curator    string      `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"`
	Deposit    types.Coin  `protobuf:"bytes,2,opt,name=deposit,proto3" json:"deposit"`
	PoolParams *PoolParams `protobuf:"bytes,3,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty"`
}

MsgCreatePool defines the Msg/CreatePool request type.

func NewMsgCreatePool 

func NewMsgCreatePool(poolParams *PoolParams, deposit sdk.Coin, curator string) *MsgCreatePool

func (*MsgCreatePool) Descriptor 

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

func (*MsgCreatePool) GetCurator 

func (m *MsgCreatePool) GetCurator() string

func (*MsgCreatePool) GetDeposit 

func (m *MsgCreatePool) GetDeposit() types.Coin

func (*MsgCreatePool) GetPoolParams 

func (m *MsgCreatePool) GetPoolParams() *PoolParams

func (*MsgCreatePool) GetSignBytes 

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

func (*MsgCreatePool) GetSigners 

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

func (*MsgCreatePool) Marshal 

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

func (*MsgCreatePool) MarshalTo 

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

func (*MsgCreatePool) MarshalToSizedBuffer 

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

func (*MsgCreatePool) ProtoMessage 

func (*MsgCreatePool) ProtoMessage()

func (*MsgCreatePool) Reset 

func (m *MsgCreatePool) Reset()

func (*MsgCreatePool) Route 

func (msg *MsgCreatePool) Route() string

func (*MsgCreatePool) Size 

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

func (*MsgCreatePool) String 

func (m *MsgCreatePool) String() string

func (*MsgCreatePool) Type 

func (msg *MsgCreatePool) Type() string

func (*MsgCreatePool) Unmarshal 

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

func (*MsgCreatePool) ValidateBasic 

func (msg *MsgCreatePool) ValidateBasic() error

func (*MsgCreatePool) XXX_DiscardUnknown 

func (m *MsgCreatePool) XXX_DiscardUnknown()

func (*MsgCreatePool) XXX_Marshal 

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

func (*MsgCreatePool) XXX_Merge 

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

func (*MsgCreatePool) XXX_Size 

func (m *MsgCreatePool) XXX_Size() int

func (*MsgCreatePool) XXX_Unmarshal 

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

type MsgCreatePoolResponse 

type MsgCreatePoolResponse struct {
	PoolId        uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round         uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	CurationNftId uint64 `protobuf:"varint,3,opt,name=curation_nft_id,json=curationNftId,proto3" json:"curation_nft_id,omitempty"`
}

MsgCreatePoolResponse defines the Msg/CreatePool response type.

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) GetCurationNftId 

func (m *MsgCreatePoolResponse) GetCurationNftId() uint64

func (*MsgCreatePoolResponse) GetPoolId 

func (m *MsgCreatePoolResponse) GetPoolId() uint64

func (*MsgCreatePoolResponse) GetRound 

func (m *MsgCreatePoolResponse) GetRound() uint64

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type MsgMintNFT 

type MsgMintNFT struct {
	// contains filtered or unexported fields
}

func NewMsgMintCuratorNFT 

func NewMsgMintCuratorNFT(poolID uint64, owner string) *MsgMintNFT

func NewMsgMintDataPass 

func NewMsgMintDataPass(numNFT uint64, owner string) *MsgMintNFT

type MsgRedeemDataPass 

type MsgRedeemDataPass struct {
	PoolId     uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round      uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	DataPassId uint64 `protobuf:"varint,3,opt,name=data_pass_id,json=dataPassId,proto3" json:"data_pass_id,omitempty"`
	Redeemer   string `protobuf:"bytes,4,opt,name=redeemer,proto3" json:"redeemer,omitempty"`
}

MsgRedeemDataPass defines the Msg/RedeemDataPass request type.

func NewMsgRedeemDataPass 

func NewMsgRedeemDataPass(poolID, round, dataPassID uint64, redeemer string) *MsgRedeemDataPass

func (*MsgRedeemDataPass) Descriptor 

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

func (*MsgRedeemDataPass) GetDataPassId 

func (m *MsgRedeemDataPass) GetDataPassId() uint64

func (*MsgRedeemDataPass) GetPoolId 

func (m *MsgRedeemDataPass) GetPoolId() uint64

func (*MsgRedeemDataPass) GetRedeemer 

func (m *MsgRedeemDataPass) GetRedeemer() string

func (*MsgRedeemDataPass) GetRound 

func (m *MsgRedeemDataPass) GetRound() uint64

func (*MsgRedeemDataPass) GetSignBytes 

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

func (*MsgRedeemDataPass) GetSigners 

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

func (*MsgRedeemDataPass) Marshal 

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

func (*MsgRedeemDataPass) MarshalTo 

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

func (*MsgRedeemDataPass) MarshalToSizedBuffer 

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

func (*MsgRedeemDataPass) ProtoMessage 

func (*MsgRedeemDataPass) ProtoMessage()

func (*MsgRedeemDataPass) Reset 

func (m *MsgRedeemDataPass) Reset()

func (*MsgRedeemDataPass) Route 

func (msg *MsgRedeemDataPass) Route() string

func (*MsgRedeemDataPass) Size 

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

func (*MsgRedeemDataPass) String 

func (m *MsgRedeemDataPass) String() string

func (*MsgRedeemDataPass) Type 

func (msg *MsgRedeemDataPass) Type() string

func (*MsgRedeemDataPass) Unmarshal 

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

func (*MsgRedeemDataPass) ValidateBasic 

func (msg *MsgRedeemDataPass) ValidateBasic() error

func (*MsgRedeemDataPass) XXX_DiscardUnknown 

func (m *MsgRedeemDataPass) XXX_DiscardUnknown()

func (*MsgRedeemDataPass) XXX_Marshal 

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

func (*MsgRedeemDataPass) XXX_Merge 

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

func (*MsgRedeemDataPass) XXX_Size 

func (m *MsgRedeemDataPass) XXX_Size() int

func (*MsgRedeemDataPass) XXX_Unmarshal 

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

type MsgRedeemDataPassResponse 

type MsgRedeemDataPassResponse struct {
	Receipt *DataPassRedeemReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"`
}

MsgRedeemDataPassResponse defines the Msg/RedeemDataPass response type.

func (*MsgRedeemDataPassResponse) Descriptor 

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

func (*MsgRedeemDataPassResponse) GetReceipt 

func (m *MsgRedeemDataPassResponse) GetReceipt() *DataPassRedeemReceipt

func (*MsgRedeemDataPassResponse) Marshal 

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

func (*MsgRedeemDataPassResponse) MarshalTo 

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

func (*MsgRedeemDataPassResponse) MarshalToSizedBuffer 

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

func (*MsgRedeemDataPassResponse) ProtoMessage 

func (*MsgRedeemDataPassResponse) ProtoMessage()

func (*MsgRedeemDataPassResponse) Reset 

func (m *MsgRedeemDataPassResponse) Reset()

func (*MsgRedeemDataPassResponse) Size 

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

func (*MsgRedeemDataPassResponse) String 

func (m *MsgRedeemDataPassResponse) String() string

func (*MsgRedeemDataPassResponse) Unmarshal 

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

func (*MsgRedeemDataPassResponse) XXX_DiscardUnknown 

func (m *MsgRedeemDataPassResponse) XXX_DiscardUnknown()

func (*MsgRedeemDataPassResponse) XXX_Marshal 

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

func (*MsgRedeemDataPassResponse) XXX_Merge 

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

func (*MsgRedeemDataPassResponse) XXX_Size 

func (m *MsgRedeemDataPassResponse) XXX_Size() int

func (*MsgRedeemDataPassResponse) XXX_Unmarshal 

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

type MsgSellData 

type MsgSellData struct {
	Cert   *DataCert `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"`
	Seller string    `protobuf:"bytes,2,opt,name=seller,proto3" json:"seller,omitempty"`
}

MsgSellData defines the Msg/SellData request type.

func (*MsgSellData) Descriptor 

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

func (*MsgSellData) GetCert 

func (m *MsgSellData) GetCert() *DataCert

func (*MsgSellData) GetSeller 

func (m *MsgSellData) GetSeller() string

func (*MsgSellData) GetSignBytes 

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

func (*MsgSellData) GetSigners 

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

func (*MsgSellData) Marshal 

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

func (*MsgSellData) MarshalTo 

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

func (*MsgSellData) MarshalToSizedBuffer 

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

func (*MsgSellData) ProtoMessage 

func (*MsgSellData) ProtoMessage()

func (*MsgSellData) Reset 

func (m *MsgSellData) Reset()

func (*MsgSellData) Route 

func (msg *MsgSellData) Route() string

func (*MsgSellData) Size 

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

func (*MsgSellData) String 

func (m *MsgSellData) String() string

func (*MsgSellData) Type 

func (msg *MsgSellData) Type() string

func (*MsgSellData) Unmarshal 

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

func (*MsgSellData) ValidateBasic 

func (msg *MsgSellData) ValidateBasic() error

func (*MsgSellData) XXX_DiscardUnknown 

func (m *MsgSellData) XXX_DiscardUnknown()

func (*MsgSellData) XXX_Marshal 

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

func (*MsgSellData) XXX_Merge 

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

func (*MsgSellData) XXX_Size 

func (m *MsgSellData) XXX_Size() int

func (*MsgSellData) XXX_Unmarshal 

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

type MsgSellDataResponse 

type MsgSellDataResponse struct {
}

MsgSellDataResponse defines the Msg/SellData response type.

func (*MsgSellDataResponse) Descriptor 

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

func (*MsgSellDataResponse) Marshal 

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

func (*MsgSellDataResponse) MarshalTo 

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

func (*MsgSellDataResponse) MarshalToSizedBuffer 

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

func (*MsgSellDataResponse) ProtoMessage 

func (*MsgSellDataResponse) ProtoMessage()

func (*MsgSellDataResponse) Reset 

func (m *MsgSellDataResponse) Reset()

func (*MsgSellDataResponse) Size 

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

func (*MsgSellDataResponse) String 

func (m *MsgSellDataResponse) String() string

func (*MsgSellDataResponse) Unmarshal 

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

func (*MsgSellDataResponse) XXX_DiscardUnknown 

func (m *MsgSellDataResponse) XXX_DiscardUnknown()

func (*MsgSellDataResponse) XXX_Marshal 

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

func (*MsgSellDataResponse) XXX_Merge 

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

func (*MsgSellDataResponse) XXX_Size 

func (m *MsgSellDataResponse) XXX_Size() int

func (*MsgSellDataResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreatePool defines a method for creating data pool.
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	// SellData defines a method for selling data
	SellData(context.Context, *MsgSellData) (*MsgSellDataResponse, error)
	// BuyDataPass defines a method for buying data pass
	BuyDataPass(context.Context, *MsgBuyDataPass) (*MsgBuyDataPassResponse, error)
	// RedeemDataPass defines a method for redeeming data pass to get data
	RedeemDataPass(context.Context, *MsgRedeemDataPass) (*MsgRedeemDataPassResponse, error)
}

MsgServer is the server API for Msg service.

type MsgTransferDataPass 

type MsgTransferDataPass struct {
	// contains filtered or unexported fields
}

func NewTransferNFTMsg 

func NewTransferNFTMsg(recipient, tokenID string) *MsgTransferDataPass

type Params 

type Params struct {
	DataPoolCommissionRate     github_com_cosmos_cosmos_sdk_types.Dec `` /* 204-byte string literal not displayed */
	DataPoolCodeId             uint64                                 `protobuf:"varint,2,opt,name=data_pool_code_id,json=dataPoolCodeId,proto3" json:"data_pool_code_id,omitempty"`
	DataPoolNftContractAddress string                                 `` /* 145-byte string literal not displayed */
}

Params define parameters of datapool module

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(dataPoolCuratorCommissionRate sdk.Dec) Params

func (*Params) Descriptor 

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

func (*Params) GetDataPoolCodeId 

func (m *Params) GetDataPoolCodeId() uint64

func (*Params) GetDataPoolNftContractAddress 

func (m *Params) GetDataPoolNftContractAddress() string

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type Pool 

type Pool struct {
	PoolId                uint64                                 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	PoolAddress           string                                 `protobuf:"bytes,2,opt,name=pool_address,json=poolAddress,proto3" json:"pool_address,omitempty"`
	Round                 uint64                                 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	PoolParams            *PoolParams                            `protobuf:"bytes,4,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty"`
	CurNumData            uint64                                 `protobuf:"varint,5,opt,name=cur_num_data,json=curNumData,proto3" json:"cur_num_data,omitempty"`
	NumIssuedNfts         uint64                                 `protobuf:"varint,6,opt,name=num_issued_nfts,json=numIssuedNfts,proto3" json:"num_issued_nfts,omitempty"`
	Status                string                                 `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	Curator               string                                 `protobuf:"bytes,8,opt,name=curator,proto3" json:"curator,omitempty"`
	Deposit               types.Coin                             `protobuf:"bytes,9,opt,name=deposit,proto3" json:"deposit"`
	NftContractAddr       string                                 `protobuf:"bytes,10,opt,name=nft_contract_addr,json=nftContractAddr,proto3" json:"nft_contract_addr,omitempty"`
	WasDepositReturned    bool                                   `protobuf:"varint,11,opt,name=was_deposit_returned,json=wasDepositReturned,proto3" json:"was_deposit_returned,omitempty"`
	CuratorCommission     map[uint64]types.Coin                  `` /* 192-byte string literal not displayed */
	CuratorCommissionRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 198-byte string literal not displayed */
}

Pool defines a data pool

func NewPool 

func NewPool(poolID uint64, curator sdk.AccAddress, poolParams PoolParams) *Pool

func (*Pool) Descriptor 

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

func (*Pool) GetCurNumData 

func (m *Pool) GetCurNumData() uint64

func (*Pool) GetCurator 

func (m *Pool) GetCurator() string

func (*Pool) GetCuratorCommission 

func (m *Pool) GetCuratorCommission() map[uint64]types.Coin

func (*Pool) GetDeposit 

func (m *Pool) GetDeposit() types.Coin

func (*Pool) GetNftContractAddr 

func (m *Pool) GetNftContractAddr() string

func (*Pool) GetNumIssuedNfts 

func (m *Pool) GetNumIssuedNfts() uint64

func (*Pool) GetPoolAddress 

func (m *Pool) GetPoolAddress() string

func (*Pool) GetPoolId 

func (m *Pool) GetPoolId() uint64

func (*Pool) GetPoolParams 

func (m *Pool) GetPoolParams() *PoolParams

func (*Pool) GetRound 

func (m *Pool) GetRound() uint64

func (*Pool) GetStatus 

func (m *Pool) GetStatus() string

func (*Pool) GetWasDepositReturned 

func (m *Pool) GetWasDepositReturned() bool

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) Unmarshal 

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

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolParams 

type PoolParams struct {
	DataSchema         []string    `protobuf:"bytes,1,rep,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"`
	TargetNumData      uint64      `protobuf:"varint,2,opt,name=target_num_data,json=targetNumData,proto3" json:"target_num_data,omitempty"`
	MaxNftSupply       uint64      `protobuf:"varint,3,opt,name=max_nft_supply,json=maxNftSupply,proto3" json:"max_nft_supply,omitempty"`
	NftPrice           *types.Coin `protobuf:"bytes,4,opt,name=nft_price,json=nftPrice,proto3" json:"nft_price,omitempty"`
	TrustedOracles     []string    `protobuf:"bytes,5,rep,name=trusted_oracles,json=trustedOracles,proto3" json:"trusted_oracles,omitempty"`
	TrustedDataIssuers []string    `protobuf:"bytes,6,rep,name=trusted_data_issuers,json=trustedDataIssuers,proto3" json:"trusted_data_issuers,omitempty"`
}

PoolParams defines parameters for data pool

func (*PoolParams) Descriptor 

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

func (*PoolParams) GetDataSchema 

func (m *PoolParams) GetDataSchema() []string

func (*PoolParams) GetMaxNftSupply 

func (m *PoolParams) GetMaxNftSupply() uint64

func (*PoolParams) GetNftPrice 

func (m *PoolParams) GetNftPrice() *types.Coin

func (*PoolParams) GetTargetNumData 

func (m *PoolParams) GetTargetNumData() uint64

func (*PoolParams) GetTrustedDataIssuers 

func (m *PoolParams) GetTrustedDataIssuers() []string

func (*PoolParams) GetTrustedOracles 

func (m *PoolParams) GetTrustedOracles() []string

func (*PoolParams) Marshal 

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

func (*PoolParams) MarshalTo 

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

func (*PoolParams) MarshalToSizedBuffer 

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

func (*PoolParams) ProtoMessage 

func (*PoolParams) ProtoMessage()

func (*PoolParams) Reset 

func (m *PoolParams) Reset()

func (*PoolParams) Size 

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

func (*PoolParams) String 

func (m *PoolParams) String() string

func (*PoolParams) Unmarshal 

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

func (*PoolParams) XXX_DiscardUnknown 

func (m *PoolParams) XXX_DiscardUnknown()

func (*PoolParams) XXX_Marshal 

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

func (*PoolParams) XXX_Merge 

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

func (*PoolParams) XXX_Size 

func (m *PoolParams) XXX_Size() int

func (*PoolParams) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Pool returns a Pool.
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// DataPoolParams returns params of x/datapool module.
	DataPoolParams(ctx context.Context, in *QueryDataPoolParamsRequest, opts ...grpc.CallOption) (*QueryDataPoolParamsResponse, error)
	// DataPoolModuleAddr returns x/datapool module address.
	DataPoolModuleAddr(ctx context.Context, in *QueryDataPoolModuleAddrRequest, opts ...grpc.CallOption) (*QueryDataPoolModuleAddrResponse, error)
	// DataCert returns DataCerts
	DataCerts(ctx context.Context, in *QueryDataCertsRequest, opts ...grpc.CallOption) (*QueryDataCertsResponse, error)
	// DataPassRedeemReceipt returns DataPassRedeemReceipt
	DataPassRedeemReceipt(ctx context.Context, in *QueryDataPassRedeemReceiptRequest, opts ...grpc.CallOption) (*QueryDataPassRedeemReceiptResponse, error)
	// DataPassRedeemReceipts returns DataPassRedeemReceipts
	DataPassRedeemReceipts(ctx context.Context, in *QueryDataPassRedeemReceiptsRequest, opts ...grpc.CallOption) (*QueryDataPassRedeemReceiptsResponse, error)
	// DataPassRedeemHistory returns a list of DataPassRedeemHistories
	DataPassRedeemHistory(ctx context.Context, in *QueryDataPassRedeemHistoryRequest, opts ...grpc.CallOption) (*QueryDataPassRedeemHistoryResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryDataCertsRequest 

type QueryDataCertsRequest struct {
	PoolId     uint64             `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round      uint64             `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataCertsRequest is the request type for the Query/DataCerts RPC method.

func (*QueryDataCertsRequest) Descriptor 

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

func (*QueryDataCertsRequest) GetPagination 

func (m *QueryDataCertsRequest) GetPagination() *query.PageRequest

func (*QueryDataCertsRequest) GetPoolId 

func (m *QueryDataCertsRequest) GetPoolId() uint64

func (*QueryDataCertsRequest) GetRound 

func (m *QueryDataCertsRequest) GetRound() uint64

func (*QueryDataCertsRequest) Marshal 

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

func (*QueryDataCertsRequest) MarshalTo 

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

func (*QueryDataCertsRequest) MarshalToSizedBuffer 

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

func (*QueryDataCertsRequest) ProtoMessage 

func (*QueryDataCertsRequest) ProtoMessage()

func (*QueryDataCertsRequest) Reset 

func (m *QueryDataCertsRequest) Reset()

func (*QueryDataCertsRequest) Size 

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

func (*QueryDataCertsRequest) String 

func (m *QueryDataCertsRequest) String() string

func (*QueryDataCertsRequest) Unmarshal 

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

func (*QueryDataCertsRequest) XXX_DiscardUnknown 

func (m *QueryDataCertsRequest) XXX_DiscardUnknown()

func (*QueryDataCertsRequest) XXX_Marshal 

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

func (*QueryDataCertsRequest) XXX_Merge 

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

func (*QueryDataCertsRequest) XXX_Size 

func (m *QueryDataCertsRequest) XXX_Size() int

func (*QueryDataCertsRequest) XXX_Unmarshal 

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

type QueryDataCertsResponse 

type QueryDataCertsResponse struct {
	DataCerts  []DataCert          `protobuf:"bytes,1,rep,name=data_certs,json=dataCerts,proto3" json:"data_certs"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataCertsResponse is the response type for the Query/DataCerts RPC method.

func (*QueryDataCertsResponse) Descriptor 

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

func (*QueryDataCertsResponse) GetDataCerts 

func (m *QueryDataCertsResponse) GetDataCerts() []DataCert

func (*QueryDataCertsResponse) GetPagination 

func (m *QueryDataCertsResponse) GetPagination() *query.PageResponse

func (*QueryDataCertsResponse) Marshal 

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

func (*QueryDataCertsResponse) MarshalTo 

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

func (*QueryDataCertsResponse) MarshalToSizedBuffer 

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

func (*QueryDataCertsResponse) ProtoMessage 

func (*QueryDataCertsResponse) ProtoMessage()

func (*QueryDataCertsResponse) Reset 

func (m *QueryDataCertsResponse) Reset()

func (*QueryDataCertsResponse) Size 

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

func (*QueryDataCertsResponse) String 

func (m *QueryDataCertsResponse) String() string

func (*QueryDataCertsResponse) Unmarshal 

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

func (*QueryDataCertsResponse) XXX_DiscardUnknown 

func (m *QueryDataCertsResponse) XXX_DiscardUnknown()

func (*QueryDataCertsResponse) XXX_Marshal 

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

func (*QueryDataCertsResponse) XXX_Merge 

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

func (*QueryDataCertsResponse) XXX_Size 

func (m *QueryDataCertsResponse) XXX_Size() int

func (*QueryDataCertsResponse) XXX_Unmarshal 

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

type QueryDataPassRedeemHistoryRequest 

type QueryDataPassRedeemHistoryRequest struct {
	Redeemer string `protobuf:"bytes,1,opt,name=redeemer,proto3" json:"redeemer,omitempty"`
	PoolId   uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryDataPassRedeemHistoryRequest is the request type for the Query/DataPassRedeemHistory RPC method.

func (*QueryDataPassRedeemHistoryRequest) Descriptor 

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

func (*QueryDataPassRedeemHistoryRequest) GetPoolId 

func (m *QueryDataPassRedeemHistoryRequest) GetPoolId() uint64

func (*QueryDataPassRedeemHistoryRequest) GetRedeemer 

func (m *QueryDataPassRedeemHistoryRequest) GetRedeemer() string

func (*QueryDataPassRedeemHistoryRequest) Marshal 

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

func (*QueryDataPassRedeemHistoryRequest) MarshalTo 

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

func (*QueryDataPassRedeemHistoryRequest) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemHistoryRequest) ProtoMessage 

func (*QueryDataPassRedeemHistoryRequest) ProtoMessage()

func (*QueryDataPassRedeemHistoryRequest) Reset 

func (m *QueryDataPassRedeemHistoryRequest) Reset()

func (*QueryDataPassRedeemHistoryRequest) Size 

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

func (*QueryDataPassRedeemHistoryRequest) String 

func (m *QueryDataPassRedeemHistoryRequest) String() string

func (*QueryDataPassRedeemHistoryRequest) Unmarshal 

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

func (*QueryDataPassRedeemHistoryRequest) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemHistoryRequest) XXX_DiscardUnknown()

func (*QueryDataPassRedeemHistoryRequest) XXX_Marshal 

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

func (*QueryDataPassRedeemHistoryRequest) XXX_Merge 

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

func (*QueryDataPassRedeemHistoryRequest) XXX_Size 

func (m *QueryDataPassRedeemHistoryRequest) XXX_Size() int

func (*QueryDataPassRedeemHistoryRequest) XXX_Unmarshal 

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

type QueryDataPassRedeemHistoryResponse 

type QueryDataPassRedeemHistoryResponse struct {
	DataPassRedeemHistories DataPassRedeemHistory `protobuf:"bytes,1,opt,name=data_pass_redeem_histories,json=dataPassRedeemHistories,proto3" json:"data_pass_redeem_histories"`
}

QueryDataPassRedeemHistoryResponse is the response type for the Query/DataPassRedeemHistory RPC method.

func (*QueryDataPassRedeemHistoryResponse) Descriptor 

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

func (*QueryDataPassRedeemHistoryResponse) GetDataPassRedeemHistories 

func (m *QueryDataPassRedeemHistoryResponse) GetDataPassRedeemHistories() DataPassRedeemHistory

func (*QueryDataPassRedeemHistoryResponse) Marshal 

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

func (*QueryDataPassRedeemHistoryResponse) MarshalTo 

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

func (*QueryDataPassRedeemHistoryResponse) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemHistoryResponse) ProtoMessage 

func (*QueryDataPassRedeemHistoryResponse) ProtoMessage()

func (*QueryDataPassRedeemHistoryResponse) Reset 

func (m *QueryDataPassRedeemHistoryResponse) Reset()

func (*QueryDataPassRedeemHistoryResponse) Size 

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

func (*QueryDataPassRedeemHistoryResponse) String 

func (m *QueryDataPassRedeemHistoryResponse) String() string

func (*QueryDataPassRedeemHistoryResponse) Unmarshal 

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

func (*QueryDataPassRedeemHistoryResponse) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemHistoryResponse) XXX_DiscardUnknown()

func (*QueryDataPassRedeemHistoryResponse) XXX_Marshal 

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

func (*QueryDataPassRedeemHistoryResponse) XXX_Merge 

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

func (*QueryDataPassRedeemHistoryResponse) XXX_Size 

func (m *QueryDataPassRedeemHistoryResponse) XXX_Size() int

func (*QueryDataPassRedeemHistoryResponse) XXX_Unmarshal 

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

type QueryDataPassRedeemReceiptRequest 

type QueryDataPassRedeemReceiptRequest struct {
	PoolId     uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round      uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	DataPassId uint64 `protobuf:"varint,3,opt,name=data_pass_id,json=dataPassId,proto3" json:"data_pass_id,omitempty"`
}

QueryDataPassRedeemReceiptRequest is the request type for the Query/DataPassRedeemReceipt RPC method.

func (*QueryDataPassRedeemReceiptRequest) Descriptor 

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

func (*QueryDataPassRedeemReceiptRequest) GetDataPassId 

func (m *QueryDataPassRedeemReceiptRequest) GetDataPassId() uint64

func (*QueryDataPassRedeemReceiptRequest) GetPoolId 

func (m *QueryDataPassRedeemReceiptRequest) GetPoolId() uint64

func (*QueryDataPassRedeemReceiptRequest) GetRound 

func (m *QueryDataPassRedeemReceiptRequest) GetRound() uint64

func (*QueryDataPassRedeemReceiptRequest) Marshal 

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

func (*QueryDataPassRedeemReceiptRequest) MarshalTo 

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

func (*QueryDataPassRedeemReceiptRequest) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemReceiptRequest) ProtoMessage 

func (*QueryDataPassRedeemReceiptRequest) ProtoMessage()

func (*QueryDataPassRedeemReceiptRequest) Reset 

func (m *QueryDataPassRedeemReceiptRequest) Reset()

func (*QueryDataPassRedeemReceiptRequest) Size 

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

func (*QueryDataPassRedeemReceiptRequest) String 

func (m *QueryDataPassRedeemReceiptRequest) String() string

func (*QueryDataPassRedeemReceiptRequest) Unmarshal 

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

func (*QueryDataPassRedeemReceiptRequest) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemReceiptRequest) XXX_DiscardUnknown()

func (*QueryDataPassRedeemReceiptRequest) XXX_Marshal 

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

func (*QueryDataPassRedeemReceiptRequest) XXX_Merge 

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

func (*QueryDataPassRedeemReceiptRequest) XXX_Size 

func (m *QueryDataPassRedeemReceiptRequest) XXX_Size() int

func (*QueryDataPassRedeemReceiptRequest) XXX_Unmarshal 

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

type QueryDataPassRedeemReceiptResponse 

type QueryDataPassRedeemReceiptResponse struct {
	DataPassRedeemReceipt DataPassRedeemReceipt `protobuf:"bytes,1,opt,name=data_pass_redeem_receipt,json=dataPassRedeemReceipt,proto3" json:"data_pass_redeem_receipt"`
}

QueryDataPassRedeemReceiptResponse is the response type for the Query/DataPassRedeemReceipt RPC method.

func (*QueryDataPassRedeemReceiptResponse) Descriptor 

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

func (*QueryDataPassRedeemReceiptResponse) GetDataPassRedeemReceipt 

func (m *QueryDataPassRedeemReceiptResponse) GetDataPassRedeemReceipt() DataPassRedeemReceipt

func (*QueryDataPassRedeemReceiptResponse) Marshal 

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

func (*QueryDataPassRedeemReceiptResponse) MarshalTo 

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

func (*QueryDataPassRedeemReceiptResponse) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemReceiptResponse) ProtoMessage 

func (*QueryDataPassRedeemReceiptResponse) ProtoMessage()

func (*QueryDataPassRedeemReceiptResponse) Reset 

func (m *QueryDataPassRedeemReceiptResponse) Reset()

func (*QueryDataPassRedeemReceiptResponse) Size 

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

func (*QueryDataPassRedeemReceiptResponse) String 

func (m *QueryDataPassRedeemReceiptResponse) String() string

func (*QueryDataPassRedeemReceiptResponse) Unmarshal 

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

func (*QueryDataPassRedeemReceiptResponse) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemReceiptResponse) XXX_DiscardUnknown()

func (*QueryDataPassRedeemReceiptResponse) XXX_Marshal 

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

func (*QueryDataPassRedeemReceiptResponse) XXX_Merge 

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

func (*QueryDataPassRedeemReceiptResponse) XXX_Size 

func (m *QueryDataPassRedeemReceiptResponse) XXX_Size() int

func (*QueryDataPassRedeemReceiptResponse) XXX_Unmarshal 

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

type QueryDataPassRedeemReceiptsRequest 

type QueryDataPassRedeemReceiptsRequest struct {
	PoolId     uint64             `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataPassRedeemReceiptsRequest is the request type for the Query/DataPassRedeemReceipts RPC method.

func (*QueryDataPassRedeemReceiptsRequest) Descriptor 

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

func (*QueryDataPassRedeemReceiptsRequest) GetPagination 

func (m *QueryDataPassRedeemReceiptsRequest) GetPagination() *query.PageRequest

func (*QueryDataPassRedeemReceiptsRequest) GetPoolId 

func (m *QueryDataPassRedeemReceiptsRequest) GetPoolId() uint64

func (*QueryDataPassRedeemReceiptsRequest) Marshal 

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

func (*QueryDataPassRedeemReceiptsRequest) MarshalTo 

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

func (*QueryDataPassRedeemReceiptsRequest) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemReceiptsRequest) ProtoMessage 

func (*QueryDataPassRedeemReceiptsRequest) ProtoMessage()

func (*QueryDataPassRedeemReceiptsRequest) Reset 

func (m *QueryDataPassRedeemReceiptsRequest) Reset()

func (*QueryDataPassRedeemReceiptsRequest) Size 

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

func (*QueryDataPassRedeemReceiptsRequest) String 

func (m *QueryDataPassRedeemReceiptsRequest) String() string

func (*QueryDataPassRedeemReceiptsRequest) Unmarshal 

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

func (*QueryDataPassRedeemReceiptsRequest) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemReceiptsRequest) XXX_DiscardUnknown()

func (*QueryDataPassRedeemReceiptsRequest) XXX_Marshal 

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

func (*QueryDataPassRedeemReceiptsRequest) XXX_Merge 

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

func (*QueryDataPassRedeemReceiptsRequest) XXX_Size 

func (m *QueryDataPassRedeemReceiptsRequest) XXX_Size() int

func (*QueryDataPassRedeemReceiptsRequest) XXX_Unmarshal 

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

type QueryDataPassRedeemReceiptsResponse 

type QueryDataPassRedeemReceiptsResponse struct {
	DataPassRedeemReceipts []DataPassRedeemReceipt `protobuf:"bytes,1,rep,name=data_pass_redeem_receipts,json=dataPassRedeemReceipts,proto3" json:"data_pass_redeem_receipts"`
	Pagination             *query.PageResponse     `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataPassRedeemReceiptsResponse is the response type for the Query/DataPassRedeemReceipts RPC method.

func (*QueryDataPassRedeemReceiptsResponse) Descriptor 

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

func (*QueryDataPassRedeemReceiptsResponse) GetDataPassRedeemReceipts 

func (m *QueryDataPassRedeemReceiptsResponse) GetDataPassRedeemReceipts() []DataPassRedeemReceipt

func (*QueryDataPassRedeemReceiptsResponse) GetPagination 

func (m *QueryDataPassRedeemReceiptsResponse) GetPagination() *query.PageResponse

func (*QueryDataPassRedeemReceiptsResponse) Marshal 

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

func (*QueryDataPassRedeemReceiptsResponse) MarshalTo 

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

func (*QueryDataPassRedeemReceiptsResponse) MarshalToSizedBuffer 

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

func (*QueryDataPassRedeemReceiptsResponse) ProtoMessage 

func (*QueryDataPassRedeemReceiptsResponse) ProtoMessage()

func (*QueryDataPassRedeemReceiptsResponse) Reset 

func (m *QueryDataPassRedeemReceiptsResponse) Reset()

func (*QueryDataPassRedeemReceiptsResponse) Size 

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

func (*QueryDataPassRedeemReceiptsResponse) String 

func (m *QueryDataPassRedeemReceiptsResponse) String() string

func (*QueryDataPassRedeemReceiptsResponse) Unmarshal 

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

func (*QueryDataPassRedeemReceiptsResponse) XXX_DiscardUnknown 

func (m *QueryDataPassRedeemReceiptsResponse) XXX_DiscardUnknown()

func (*QueryDataPassRedeemReceiptsResponse) XXX_Marshal 

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

func (*QueryDataPassRedeemReceiptsResponse) XXX_Merge 

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

func (*QueryDataPassRedeemReceiptsResponse) XXX_Size 

func (m *QueryDataPassRedeemReceiptsResponse) XXX_Size() int

func (*QueryDataPassRedeemReceiptsResponse) XXX_Unmarshal 

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

type QueryDataPoolModuleAddrRequest 

type QueryDataPoolModuleAddrRequest struct {
}

QueryDataPoolModuleAddrRequest is the request type for the Query/DataPoolModuleAddr RPC method.

func (*QueryDataPoolModuleAddrRequest) Descriptor 

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

func (*QueryDataPoolModuleAddrRequest) Marshal 

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

func (*QueryDataPoolModuleAddrRequest) MarshalTo 

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

func (*QueryDataPoolModuleAddrRequest) MarshalToSizedBuffer 

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

func (*QueryDataPoolModuleAddrRequest) ProtoMessage 

func (*QueryDataPoolModuleAddrRequest) ProtoMessage()

func (*QueryDataPoolModuleAddrRequest) Reset 

func (m *QueryDataPoolModuleAddrRequest) Reset()

func (*QueryDataPoolModuleAddrRequest) Size 

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

func (*QueryDataPoolModuleAddrRequest) String 

func (m *QueryDataPoolModuleAddrRequest) String() string

func (*QueryDataPoolModuleAddrRequest) Unmarshal 

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

func (*QueryDataPoolModuleAddrRequest) XXX_DiscardUnknown 

func (m *QueryDataPoolModuleAddrRequest) XXX_DiscardUnknown()

func (*QueryDataPoolModuleAddrRequest) XXX_Marshal 

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

func (*QueryDataPoolModuleAddrRequest) XXX_Merge 

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

func (*QueryDataPoolModuleAddrRequest) XXX_Size 

func (m *QueryDataPoolModuleAddrRequest) XXX_Size() int

func (*QueryDataPoolModuleAddrRequest) XXX_Unmarshal 

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

type QueryDataPoolModuleAddrResponse 

type QueryDataPoolModuleAddrResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryDataPoolModuleAddrResponse is the response type for the Query/DataPoolModuleAddr RPC method.

func (*QueryDataPoolModuleAddrResponse) Descriptor 

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

func (*QueryDataPoolModuleAddrResponse) GetAddress 

func (m *QueryDataPoolModuleAddrResponse) GetAddress() string

func (*QueryDataPoolModuleAddrResponse) Marshal 

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

func (*QueryDataPoolModuleAddrResponse) MarshalTo 

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

func (*QueryDataPoolModuleAddrResponse) MarshalToSizedBuffer 

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

func (*QueryDataPoolModuleAddrResponse) ProtoMessage 

func (*QueryDataPoolModuleAddrResponse) ProtoMessage()

func (*QueryDataPoolModuleAddrResponse) Reset 

func (m *QueryDataPoolModuleAddrResponse) Reset()

func (*QueryDataPoolModuleAddrResponse) Size 

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

func (*QueryDataPoolModuleAddrResponse) String 

func (m *QueryDataPoolModuleAddrResponse) String() string

func (*QueryDataPoolModuleAddrResponse) Unmarshal 

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

func (*QueryDataPoolModuleAddrResponse) XXX_DiscardUnknown 

func (m *QueryDataPoolModuleAddrResponse) XXX_DiscardUnknown()

func (*QueryDataPoolModuleAddrResponse) XXX_Marshal 

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

func (*QueryDataPoolModuleAddrResponse) XXX_Merge 

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

func (*QueryDataPoolModuleAddrResponse) XXX_Size 

func (m *QueryDataPoolModuleAddrResponse) XXX_Size() int

func (*QueryDataPoolModuleAddrResponse) XXX_Unmarshal 

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

type QueryDataPoolParamsRequest 

type QueryDataPoolParamsRequest struct {
}

QueryDataPoolParamsRequest is the request type for the Query/DataPoolParams RPC method.

func (*QueryDataPoolParamsRequest) Descriptor 

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

func (*QueryDataPoolParamsRequest) Marshal 

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

func (*QueryDataPoolParamsRequest) MarshalTo 

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

func (*QueryDataPoolParamsRequest) MarshalToSizedBuffer 

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

func (*QueryDataPoolParamsRequest) ProtoMessage 

func (*QueryDataPoolParamsRequest) ProtoMessage()

func (*QueryDataPoolParamsRequest) Reset 

func (m *QueryDataPoolParamsRequest) Reset()

func (*QueryDataPoolParamsRequest) Size 

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

func (*QueryDataPoolParamsRequest) String 

func (m *QueryDataPoolParamsRequest) String() string

func (*QueryDataPoolParamsRequest) Unmarshal 

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

func (*QueryDataPoolParamsRequest) XXX_DiscardUnknown 

func (m *QueryDataPoolParamsRequest) XXX_DiscardUnknown()

func (*QueryDataPoolParamsRequest) XXX_Marshal 

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

func (*QueryDataPoolParamsRequest) XXX_Merge 

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

func (*QueryDataPoolParamsRequest) XXX_Size 

func (m *QueryDataPoolParamsRequest) XXX_Size() int

func (*QueryDataPoolParamsRequest) XXX_Unmarshal 

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

type QueryDataPoolParamsResponse 

type QueryDataPoolParamsResponse struct {
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}

QueryDataPoolParamsResponse is the response type for the Query/DataPoolParams RPC method.

func (*QueryDataPoolParamsResponse) Descriptor 

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

func (*QueryDataPoolParamsResponse) GetParams 

func (m *QueryDataPoolParamsResponse) GetParams() *Params

func (*QueryDataPoolParamsResponse) Marshal 

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

func (*QueryDataPoolParamsResponse) MarshalTo 

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

func (*QueryDataPoolParamsResponse) MarshalToSizedBuffer 

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

func (*QueryDataPoolParamsResponse) ProtoMessage 

func (*QueryDataPoolParamsResponse) ProtoMessage()

func (*QueryDataPoolParamsResponse) Reset 

func (m *QueryDataPoolParamsResponse) Reset()

func (*QueryDataPoolParamsResponse) Size 

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

func (*QueryDataPoolParamsResponse) String 

func (m *QueryDataPoolParamsResponse) String() string

func (*QueryDataPoolParamsResponse) Unmarshal 

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

func (*QueryDataPoolParamsResponse) XXX_DiscardUnknown 

func (m *QueryDataPoolParamsResponse) XXX_DiscardUnknown()

func (*QueryDataPoolParamsResponse) XXX_Marshal 

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

func (*QueryDataPoolParamsResponse) XXX_Merge 

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

func (*QueryDataPoolParamsResponse) XXX_Size 

func (m *QueryDataPoolParamsResponse) XXX_Size() int

func (*QueryDataPoolParamsResponse) XXX_Unmarshal 

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

type QueryPoolRequest 

type QueryPoolRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryPoolRequest is the request type for the Query/Pool RPC method.

func (*QueryPoolRequest) Descriptor 

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

func (*QueryPoolRequest) GetPoolId 

func (m *QueryPoolRequest) GetPoolId() uint64

func (*QueryPoolRequest) Marshal 

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

func (*QueryPoolRequest) MarshalTo 

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

func (*QueryPoolRequest) MarshalToSizedBuffer 

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

func (*QueryPoolRequest) ProtoMessage 

func (*QueryPoolRequest) ProtoMessage()

func (*QueryPoolRequest) Reset 

func (m *QueryPoolRequest) Reset()

func (*QueryPoolRequest) Size 

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

func (*QueryPoolRequest) String 

func (m *QueryPoolRequest) String() string

func (*QueryPoolRequest) Unmarshal 

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

func (*QueryPoolRequest) XXX_DiscardUnknown 

func (m *QueryPoolRequest) XXX_DiscardUnknown()

func (*QueryPoolRequest) XXX_Marshal 

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

func (*QueryPoolRequest) XXX_Merge 

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

func (*QueryPoolRequest) XXX_Size 

func (m *QueryPoolRequest) XXX_Size() int

func (*QueryPoolRequest) XXX_Unmarshal 

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

type QueryPoolResponse 

type QueryPoolResponse struct {
	Pool *Pool `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
}

QueryPoolResponse is the response type for the Query/Pool RPC method.

func (*QueryPoolResponse) Descriptor 

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

func (*QueryPoolResponse) GetPool 

func (m *QueryPoolResponse) GetPool() *Pool

func (*QueryPoolResponse) Marshal 

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

func (*QueryPoolResponse) MarshalTo 

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

func (*QueryPoolResponse) MarshalToSizedBuffer 

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

func (*QueryPoolResponse) ProtoMessage 

func (*QueryPoolResponse) ProtoMessage()

func (*QueryPoolResponse) Reset 

func (m *QueryPoolResponse) Reset()

func (*QueryPoolResponse) Size 

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

func (*QueryPoolResponse) String 

func (m *QueryPoolResponse) String() string

func (*QueryPoolResponse) Unmarshal 

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

func (*QueryPoolResponse) XXX_DiscardUnknown 

func (m *QueryPoolResponse) XXX_DiscardUnknown()

func (*QueryPoolResponse) XXX_Marshal 

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

func (*QueryPoolResponse) XXX_Merge 

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

func (*QueryPoolResponse) XXX_Size 

func (m *QueryPoolResponse) XXX_Size() int

func (*QueryPoolResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Pool returns a Pool.
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
	// DataPoolParams returns params of x/datapool module.
	DataPoolParams(context.Context, *QueryDataPoolParamsRequest) (*QueryDataPoolParamsResponse, error)
	// DataPoolModuleAddr returns x/datapool module address.
	DataPoolModuleAddr(context.Context, *QueryDataPoolModuleAddrRequest) (*QueryDataPoolModuleAddrResponse, error)
	// DataCert returns DataCerts
	DataCerts(context.Context, *QueryDataCertsRequest) (*QueryDataCertsResponse, error)
	// DataPassRedeemReceipt returns DataPassRedeemReceipt
	DataPassRedeemReceipt(context.Context, *QueryDataPassRedeemReceiptRequest) (*QueryDataPassRedeemReceiptResponse, error)
	// DataPassRedeemReceipts returns DataPassRedeemReceipts
	DataPassRedeemReceipts(context.Context, *QueryDataPassRedeemReceiptsRequest) (*QueryDataPassRedeemReceiptsResponse, error)
	// DataPassRedeemHistory returns a list of DataPassRedeemHistories
	DataPassRedeemHistory(context.Context, *QueryDataPassRedeemHistoryRequest) (*QueryDataPassRedeemHistoryResponse, error)
}

QueryServer is the server API for Query service.

type QueryTokensRequest 

type QueryTokensRequest struct {
	// contains filtered or unexported fields
}

func NewQueryTokensRequest 

func NewQueryTokensRequest(owner string) *QueryTokensRequest

type QueryTokensResponse 

type QueryTokensResponse struct {
	Tokens []string `json:"tokens"`
}

type SalesHistory 

type SalesHistory struct {
	PoolId        uint64      `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round         uint64      `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	SellerAddress string      `protobuf:"bytes,3,opt,name=seller_address,json=sellerAddress,proto3" json:"seller_address,omitempty"`
	DataHashes    [][]byte    `protobuf:"bytes,4,rep,name=data_hashes,json=dataHashes,proto3" json:"data_hashes,omitempty"`
	PaidCoin      *types.Coin `protobuf:"bytes,5,opt,name=paid_coin,json=paidCoin,proto3" json:"paid_coin,omitempty"`
}

SalesInfo defines sales information

func (*SalesHistory) AddDataHash 

func (m *SalesHistory) AddDataHash(dataHash []byte)

func (*SalesHistory) DataCount 

func (m *SalesHistory) DataCount() int

func (*SalesHistory) Descriptor 

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

func (*SalesHistory) GetDataHashes 

func (m *SalesHistory) GetDataHashes() [][]byte

func (*SalesHistory) GetPaidCoin 

func (m *SalesHistory) GetPaidCoin() *types.Coin

func (*SalesHistory) GetPoolId 

func (m *SalesHistory) GetPoolId() uint64

func (*SalesHistory) GetRound 

func (m *SalesHistory) GetRound() uint64

func (*SalesHistory) GetSellerAddress 

func (m *SalesHistory) GetSellerAddress() string

func (*SalesHistory) Marshal 

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

func (*SalesHistory) MarshalTo 

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

func (*SalesHistory) MarshalToSizedBuffer 

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

func (*SalesHistory) ProtoMessage 

func (*SalesHistory) ProtoMessage()

func (*SalesHistory) Reset 

func (m *SalesHistory) Reset()

func (*SalesHistory) Size 

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

func (*SalesHistory) String 

func (m *SalesHistory) String() string

func (*SalesHistory) Unmarshal 

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

func (*SalesHistory) XXX_DiscardUnknown 

func (m *SalesHistory) XXX_DiscardUnknown()

func (*SalesHistory) XXX_Marshal 

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

func (*SalesHistory) XXX_Merge 

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

func (*SalesHistory) XXX_Size 

func (m *SalesHistory) XXX_Size() int

func (*SalesHistory) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) BuyDataPass 

func (*UnimplementedMsgServer) BuyDataPass(ctx context.Context, req *MsgBuyDataPass) (*MsgBuyDataPassResponse, error)

func (*UnimplementedMsgServer) CreatePool 

func (*UnimplementedMsgServer) CreatePool(ctx context.Context, req *MsgCreatePool) (*MsgCreatePoolResponse, error)

func (*UnimplementedMsgServer) RedeemDataPass 

func (*UnimplementedMsgServer) RedeemDataPass(ctx context.Context, req *MsgRedeemDataPass) (*MsgRedeemDataPassResponse, error)

func (*UnimplementedMsgServer) SellData 

func (*UnimplementedMsgServer) SellData(ctx context.Context, req *MsgSellData) (*MsgSellDataResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) DataCerts 

func (*UnimplementedQueryServer) DataCerts(ctx context.Context, req *QueryDataCertsRequest) (*QueryDataCertsResponse, error)

func (*UnimplementedQueryServer) DataPassRedeemHistory 

func (*UnimplementedQueryServer) DataPassRedeemHistory(ctx context.Context, req *QueryDataPassRedeemHistoryRequest) (*QueryDataPassRedeemHistoryResponse, error)

func (*UnimplementedQueryServer) DataPassRedeemReceipt 

func (*UnimplementedQueryServer) DataPassRedeemReceipt(ctx context.Context, req *QueryDataPassRedeemReceiptRequest) (*QueryDataPassRedeemReceiptResponse, error)

func (*UnimplementedQueryServer) DataPassRedeemReceipts 

func (*UnimplementedQueryServer) DataPassRedeemReceipts(ctx context.Context, req *QueryDataPassRedeemReceiptsRequest) (*QueryDataPassRedeemReceiptsResponse, error)

func (*UnimplementedQueryServer) DataPoolModuleAddr 

func (*UnimplementedQueryServer) DataPoolModuleAddr(ctx context.Context, req *QueryDataPoolModuleAddrRequest) (*QueryDataPoolModuleAddrResponse, error)

func (*UnimplementedQueryServer) DataPoolParams 

func (*UnimplementedQueryServer) DataPoolParams(ctx context.Context, req *QueryDataPoolParamsRequest) (*QueryDataPoolParamsResponse, error)

func (*UnimplementedQueryServer) Pool 

func (*UnimplementedQueryServer) Pool(ctx context.Context, req *QueryPoolRequest) (*QueryPoolResponse, error)

type UnsignedDataCert 

type UnsignedDataCert struct {
	PoolId    uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Round     uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	DataHash  []byte `protobuf:"bytes,3,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	Oracle    string `protobuf:"bytes,4,opt,name=oracle,proto3" json:"oracle,omitempty"`
	Requester string `protobuf:"bytes,5,opt,name=requester,proto3" json:"requester,omitempty"`
}

UnsignedDataCert defines the unsigned certificate for data validation.

func (*UnsignedDataCert) Descriptor 

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

func (*UnsignedDataCert) GetDataHash 

func (m *UnsignedDataCert) GetDataHash() []byte

func (*UnsignedDataCert) GetOracle 

func (m *UnsignedDataCert) GetOracle() string

func (*UnsignedDataCert) GetPoolId 

func (m *UnsignedDataCert) GetPoolId() uint64

func (*UnsignedDataCert) GetRequester 

func (m *UnsignedDataCert) GetRequester() string

func (*UnsignedDataCert) GetRound 

func (m *UnsignedDataCert) GetRound() uint64

func (*UnsignedDataCert) Marshal 

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

func (*UnsignedDataCert) MarshalTo 

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

func (*UnsignedDataCert) MarshalToSizedBuffer 

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

func (*UnsignedDataCert) ProtoMessage 

func (*UnsignedDataCert) ProtoMessage()

func (*UnsignedDataCert) Reset 

func (m *UnsignedDataCert) Reset()

func (*UnsignedDataCert) Size 

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

func (*UnsignedDataCert) String 

func (m *UnsignedDataCert) String() string

func (*UnsignedDataCert) Unmarshal 

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

func (*UnsignedDataCert) XXX_DiscardUnknown 

func (m *UnsignedDataCert) XXX_DiscardUnknown()

func (*UnsignedDataCert) XXX_Marshal 

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

func (*UnsignedDataCert) XXX_Merge 

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

func (*UnsignedDataCert) XXX_Size 

func (m *UnsignedDataCert) XXX_Size() int

func (*UnsignedDataCert) XXX_Unmarshal 

func (m *UnsignedDataCert) XXX_Unmarshal(b []byte) 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.