Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func CombineKeys(keys ...[]byte) []byte
- func GetKeyPrefixDataCert(dealID uint64, dataHash []byte) []byte
- func GetKeyPrefixDataCertsByDealID(dealID uint64) []byte
- func GetKeyPrefixDeals(dealID uint64) []byte
- func NewDealAddress(dealID uint64) sdk.AccAddress
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type AccountKeeper
- type BankKeeper
- type DataCert
- func (*DataCert) Descriptor() ([]byte, []int)
- func (m *DataCert) GetSignature() []byte
- func (m *DataCert) GetUnsignedCert() *UnsignedDataCert
- func (m *DataCert) Marshal() (dAtA []byte, err error)
- func (m *DataCert) MarshalTo(dAtA []byte) (int, error)
- func (m *DataCert) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DataCert) ProtoMessage()
- func (m *DataCert) Reset()
- func (m *DataCert) Size() (n int)
- func (m *DataCert) String() string
- func (m *DataCert) Unmarshal(dAtA []byte) error
- func (m *DataCert) XXX_DiscardUnknown()
- func (m *DataCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataCert) XXX_Merge(src proto.Message)
- func (m *DataCert) XXX_Size() int
- func (m *DataCert) XXX_Unmarshal(b []byte) error
- type Deal
- func (*Deal) Descriptor() ([]byte, []int)
- func (m *Deal) GetBudget() *types.Coin
- func (m *Deal) GetCurNumData() uint64
- func (m *Deal) GetDataSchema() []string
- func (m *Deal) GetDealAddress() string
- func (m *Deal) GetDealId() uint64
- func (m *Deal) GetMaxNumData() uint64
- func (m *Deal) GetOwner() string
- func (m *Deal) GetStatus() string
- func (m *Deal) GetTrustedOracles() []string
- func (m *Deal) Marshal() (dAtA []byte, err error)
- func (m *Deal) MarshalTo(dAtA []byte) (int, error)
- func (m *Deal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Deal) ProtoMessage()
- func (m *Deal) Reset()
- func (m *Deal) Size() (n int)
- func (m *Deal) String() string
- func (m *Deal) Unmarshal(dAtA []byte) error
- func (m *Deal) XXX_DiscardUnknown()
- func (m *Deal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Deal) XXX_Merge(src proto.Message)
- func (m *Deal) XXX_Size() int
- func (m *Deal) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetDataCerts() map[string]DataCert
- func (m *GenesisState) GetDeals() map[uint64]Deal
- func (m *GenesisState) GetNextDealNumber() uint64
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgCreateDeal
- func (*MsgCreateDeal) Descriptor() ([]byte, []int)
- func (m *MsgCreateDeal) GetBudget() *types.Coin
- func (m *MsgCreateDeal) GetDataSchema() []string
- func (m *MsgCreateDeal) GetMaxNumData() uint64
- func (m *MsgCreateDeal) GetOwner() string
- func (msg *MsgCreateDeal) GetSignBytes() []byte
- func (msg *MsgCreateDeal) GetSigners() []sdk.AccAddress
- func (m *MsgCreateDeal) GetTrustedOracles() []string
- func (m *MsgCreateDeal) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateDeal) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateDeal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateDeal) ProtoMessage()
- func (m *MsgCreateDeal) Reset()
- func (msg *MsgCreateDeal) Route() string
- func (m *MsgCreateDeal) Size() (n int)
- func (m *MsgCreateDeal) String() string
- func (msg *MsgCreateDeal) Type() string
- func (m *MsgCreateDeal) Unmarshal(dAtA []byte) error
- func (msg *MsgCreateDeal) ValidateBasic() error
- func (m *MsgCreateDeal) XXX_DiscardUnknown()
- func (m *MsgCreateDeal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateDeal) XXX_Merge(src proto.Message)
- func (m *MsgCreateDeal) XXX_Size() int
- func (m *MsgCreateDeal) XXX_Unmarshal(b []byte) error
- type MsgCreateDealResponse
- func (*MsgCreateDealResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreateDealResponse) GetDealId() uint64
- func (m *MsgCreateDealResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateDealResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateDealResponse) ProtoMessage()
- func (m *MsgCreateDealResponse) Reset()
- func (m *MsgCreateDealResponse) Size() (n int)
- func (m *MsgCreateDealResponse) String() string
- func (m *MsgCreateDealResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreateDealResponse) XXX_DiscardUnknown()
- func (m *MsgCreateDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateDealResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreateDealResponse) XXX_Size() int
- func (m *MsgCreateDealResponse) XXX_Unmarshal(b []byte) error
- type MsgDeactivateDeal
- func (*MsgDeactivateDeal) Descriptor() ([]byte, []int)
- func (m *MsgDeactivateDeal) GetDeactivateRequester() string
- func (m *MsgDeactivateDeal) GetDealId() uint64
- func (msg *MsgDeactivateDeal) GetSignBytes() []byte
- func (msg *MsgDeactivateDeal) GetSigners() []sdk.AccAddress
- func (m *MsgDeactivateDeal) Marshal() (dAtA []byte, err error)
- func (m *MsgDeactivateDeal) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeactivateDeal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeactivateDeal) ProtoMessage()
- func (m *MsgDeactivateDeal) Reset()
- func (msg *MsgDeactivateDeal) Route() string
- func (m *MsgDeactivateDeal) Size() (n int)
- func (m *MsgDeactivateDeal) String() string
- func (msg *MsgDeactivateDeal) Type() string
- func (m *MsgDeactivateDeal) Unmarshal(dAtA []byte) error
- func (msg *MsgDeactivateDeal) ValidateBasic() error
- func (m *MsgDeactivateDeal) XXX_DiscardUnknown()
- func (m *MsgDeactivateDeal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeactivateDeal) XXX_Merge(src proto.Message)
- func (m *MsgDeactivateDeal) XXX_Size() int
- func (m *MsgDeactivateDeal) XXX_Unmarshal(b []byte) error
- type MsgDeactivateDealResponse
- func (*MsgDeactivateDealResponse) Descriptor() ([]byte, []int)
- func (m *MsgDeactivateDealResponse) GetDealId() uint64
- func (m *MsgDeactivateDealResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgDeactivateDealResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeactivateDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeactivateDealResponse) ProtoMessage()
- func (m *MsgDeactivateDealResponse) Reset()
- func (m *MsgDeactivateDealResponse) Size() (n int)
- func (m *MsgDeactivateDealResponse) String() string
- func (m *MsgDeactivateDealResponse) Unmarshal(dAtA []byte) error
- func (m *MsgDeactivateDealResponse) XXX_DiscardUnknown()
- func (m *MsgDeactivateDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeactivateDealResponse) XXX_Merge(src proto.Message)
- func (m *MsgDeactivateDealResponse) XXX_Size() int
- func (m *MsgDeactivateDealResponse) XXX_Unmarshal(b []byte) error
- type MsgSellData
- func (*MsgSellData) Descriptor() ([]byte, []int)
- func (m *MsgSellData) GetCert() *DataCert
- func (m *MsgSellData) GetSeller() string
- func (msg *MsgSellData) GetSignBytes() []byte
- func (msg *MsgSellData) GetSigners() []sdk.AccAddress
- func (m *MsgSellData) Marshal() (dAtA []byte, err error)
- func (m *MsgSellData) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSellData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSellData) ProtoMessage()
- func (m *MsgSellData) Reset()
- func (msg *MsgSellData) Route() string
- func (m *MsgSellData) Size() (n int)
- func (m *MsgSellData) String() string
- func (msg *MsgSellData) Type() string
- func (m *MsgSellData) Unmarshal(dAtA []byte) error
- func (msg *MsgSellData) ValidateBasic() error
- func (m *MsgSellData) XXX_DiscardUnknown()
- func (m *MsgSellData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSellData) XXX_Merge(src proto.Message)
- func (m *MsgSellData) XXX_Size() int
- func (m *MsgSellData) XXX_Unmarshal(b []byte) error
- type MsgSellDataResponse
- func (*MsgSellDataResponse) Descriptor() ([]byte, []int)
- func (m *MsgSellDataResponse) GetReward() *types.Coin
- func (m *MsgSellDataResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgSellDataResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSellDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSellDataResponse) ProtoMessage()
- func (m *MsgSellDataResponse) Reset()
- func (m *MsgSellDataResponse) Size() (n int)
- func (m *MsgSellDataResponse) String() string
- func (m *MsgSellDataResponse) Unmarshal(dAtA []byte) error
- func (m *MsgSellDataResponse) XXX_DiscardUnknown()
- func (m *MsgSellDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSellDataResponse) XXX_Merge(src proto.Message)
- func (m *MsgSellDataResponse) XXX_Size() int
- func (m *MsgSellDataResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type QueryClient
- type QueryDataCertRequest
- func (*QueryDataCertRequest) Descriptor() ([]byte, []int)
- func (m *QueryDataCertRequest) GetDataHash() string
- func (m *QueryDataCertRequest) GetDealId() uint64
- func (m *QueryDataCertRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDataCertRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDataCertRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDataCertRequest) ProtoMessage()
- func (m *QueryDataCertRequest) Reset()
- func (m *QueryDataCertRequest) Size() (n int)
- func (m *QueryDataCertRequest) String() string
- func (m *QueryDataCertRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDataCertRequest) XXX_DiscardUnknown()
- func (m *QueryDataCertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDataCertRequest) XXX_Merge(src proto.Message)
- func (m *QueryDataCertRequest) XXX_Size() int
- func (m *QueryDataCertRequest) XXX_Unmarshal(b []byte) error
- type QueryDataCertResponse
- func (*QueryDataCertResponse) Descriptor() ([]byte, []int)
- func (m *QueryDataCertResponse) GetDataCert() *DataCert
- func (m *QueryDataCertResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDataCertResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDataCertResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDataCertResponse) ProtoMessage()
- func (m *QueryDataCertResponse) Reset()
- func (m *QueryDataCertResponse) Size() (n int)
- func (m *QueryDataCertResponse) String() string
- func (m *QueryDataCertResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDataCertResponse) XXX_DiscardUnknown()
- func (m *QueryDataCertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDataCertResponse) XXX_Merge(src proto.Message)
- func (m *QueryDataCertResponse) XXX_Size() int
- func (m *QueryDataCertResponse) XXX_Unmarshal(b []byte) error
- type QueryDataCertsRequest
- func (*QueryDataCertsRequest) Descriptor() ([]byte, []int)
- func (m *QueryDataCertsRequest) GetDealId() uint64
- func (m *QueryDataCertsRequest) GetPagination() *query.PageRequest
- func (m *QueryDataCertsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDataCertsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDataCertsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDataCertsRequest) ProtoMessage()
- func (m *QueryDataCertsRequest) Reset()
- func (m *QueryDataCertsRequest) Size() (n int)
- func (m *QueryDataCertsRequest) String() string
- func (m *QueryDataCertsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDataCertsRequest) XXX_DiscardUnknown()
- func (m *QueryDataCertsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDataCertsRequest) XXX_Merge(src proto.Message)
- func (m *QueryDataCertsRequest) XXX_Size() int
- func (m *QueryDataCertsRequest) XXX_Unmarshal(b []byte) error
- type QueryDataCertsResponse
- func (*QueryDataCertsResponse) Descriptor() ([]byte, []int)
- func (m *QueryDataCertsResponse) GetDataCerts() []DataCert
- func (m *QueryDataCertsResponse) GetPagination() *query.PageResponse
- func (m *QueryDataCertsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDataCertsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDataCertsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDataCertsResponse) ProtoMessage()
- func (m *QueryDataCertsResponse) Reset()
- func (m *QueryDataCertsResponse) Size() (n int)
- func (m *QueryDataCertsResponse) String() string
- func (m *QueryDataCertsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDataCertsResponse) XXX_DiscardUnknown()
- func (m *QueryDataCertsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDataCertsResponse) XXX_Merge(src proto.Message)
- func (m *QueryDataCertsResponse) XXX_Size() int
- func (m *QueryDataCertsResponse) XXX_Unmarshal(b []byte) error
- type QueryDealRequest
- func (*QueryDealRequest) Descriptor() ([]byte, []int)
- func (m *QueryDealRequest) GetDealId() uint64
- func (m *QueryDealRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDealRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDealRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDealRequest) ProtoMessage()
- func (m *QueryDealRequest) Reset()
- func (m *QueryDealRequest) Size() (n int)
- func (m *QueryDealRequest) String() string
- func (m *QueryDealRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDealRequest) XXX_DiscardUnknown()
- func (m *QueryDealRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDealRequest) XXX_Merge(src proto.Message)
- func (m *QueryDealRequest) XXX_Size() int
- func (m *QueryDealRequest) XXX_Unmarshal(b []byte) error
- type QueryDealResponse
- func (*QueryDealResponse) Descriptor() ([]byte, []int)
- func (m *QueryDealResponse) GetDeal() *Deal
- func (m *QueryDealResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDealResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDealResponse) ProtoMessage()
- func (m *QueryDealResponse) Reset()
- func (m *QueryDealResponse) Size() (n int)
- func (m *QueryDealResponse) String() string
- func (m *QueryDealResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDealResponse) XXX_DiscardUnknown()
- func (m *QueryDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDealResponse) XXX_Merge(src proto.Message)
- func (m *QueryDealResponse) XXX_Size() int
- func (m *QueryDealResponse) XXX_Unmarshal(b []byte) error
- type QueryDealsRequest
- func (*QueryDealsRequest) Descriptor() ([]byte, []int)
- func (m *QueryDealsRequest) GetPagination() *query.PageRequest
- func (m *QueryDealsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDealsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDealsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDealsRequest) ProtoMessage()
- func (m *QueryDealsRequest) Reset()
- func (m *QueryDealsRequest) Size() (n int)
- func (m *QueryDealsRequest) String() string
- func (m *QueryDealsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDealsRequest) XXX_DiscardUnknown()
- func (m *QueryDealsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDealsRequest) XXX_Merge(src proto.Message)
- func (m *QueryDealsRequest) XXX_Size() int
- func (m *QueryDealsRequest) XXX_Unmarshal(b []byte) error
- type QueryDealsResponse
- func (*QueryDealsResponse) Descriptor() ([]byte, []int)
- func (m *QueryDealsResponse) GetDeals() []Deal
- func (m *QueryDealsResponse) GetPagination() *query.PageResponse
- func (m *QueryDealsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDealsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDealsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDealsResponse) ProtoMessage()
- func (m *QueryDealsResponse) Reset()
- func (m *QueryDealsResponse) Size() (n int)
- func (m *QueryDealsResponse) String() string
- func (m *QueryDealsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDealsResponse) XXX_DiscardUnknown()
- func (m *QueryDealsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDealsResponse) XXX_Merge(src proto.Message)
- func (m *QueryDealsResponse) XXX_Size() int
- func (m *QueryDealsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) CreateDeal(ctx context.Context, req *MsgCreateDeal) (*MsgCreateDealResponse, error)
- func (*UnimplementedMsgServer) DeactivateDeal(ctx context.Context, req *MsgDeactivateDeal) (*MsgDeactivateDealResponse, error)
- func (*UnimplementedMsgServer) SellData(ctx context.Context, req *MsgSellData) (*MsgSellDataResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) DataCert(ctx context.Context, req *QueryDataCertRequest) (*QueryDataCertResponse, error)
- func (*UnimplementedQueryServer) DataCerts(ctx context.Context, req *QueryDataCertsRequest) (*QueryDataCertsResponse, error)
- func (*UnimplementedQueryServer) Deal(ctx context.Context, req *QueryDealRequest) (*QueryDealResponse, error)
- func (*UnimplementedQueryServer) Deals(ctx context.Context, req *QueryDealsRequest) (*QueryDealsResponse, error)
- type UnsignedDataCert
- func (*UnsignedDataCert) Descriptor() ([]byte, []int)
- func (m *UnsignedDataCert) GetDataHash() []byte
- func (m *UnsignedDataCert) GetDealId() uint64
- func (m *UnsignedDataCert) GetEncryptedDataUrl() []byte
- func (m *UnsignedDataCert) GetOracleAddress() string
- func (m *UnsignedDataCert) GetRequesterAddress() string
- func (m *UnsignedDataCert) Marshal() (dAtA []byte, err error)
- func (m *UnsignedDataCert) MarshalTo(dAtA []byte) (int, error)
- func (m *UnsignedDataCert) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnsignedDataCert) ProtoMessage()
- func (m *UnsignedDataCert) Reset()
- func (m *UnsignedDataCert) Size() (n int)
- func (m *UnsignedDataCert) String() string
- func (m *UnsignedDataCert) Unmarshal(dAtA []byte) error
- func (m *UnsignedDataCert) XXX_DiscardUnknown()
- func (m *UnsignedDataCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnsignedDataCert) XXX_Merge(src proto.Message)
- func (m *UnsignedDataCert) XXX_Size() int
- func (m *UnsignedDataCert) XXX_Unmarshal(b []byte) error
Constants ¶
const ( ACTIVE = "ACTIVE" // When deal is activated. INACTIVE = "INACTIVE" // When deal is deactivated. COMPLETED = "COMPLETED" // When deal is completed. )
const ( // ModuleName defines the module name ModuleName = "datadeal" // 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_datadeal" )
Variables ¶
var ( ErrInvalidLengthDeal = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDeal = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDeal = fmt.Errorf("proto: unexpected end of group") )
var ( ErrDealAlreadyExist = sdkerrors.Register(ModuleName, 1, "deal already exist") ErrInvalidSignature = sdkerrors.Register(ModuleName, 2, "invalid oracle signature") ErrDealNotActive = sdkerrors.Register(ModuleName, 3, "the deal is not active") ErrDataAlreadyExist = sdkerrors.Register(ModuleName, 4, "data already exist") ErrDealNotFound = sdkerrors.Register(ModuleName, 5, "deal is not found") ErrDataNotFound = sdkerrors.Register(ModuleName, 6, "data is not found") ErrDealNotInitialized = sdkerrors.Register(ModuleName, 7, "deal has not been initialized") ErrInvalidOracle = sdkerrors.Register(ModuleName, 8, "invalid oracle") ErrInvalidGenesisDeal = sdkerrors.Register(ModuleName, 9, "invalid genesis state of deal") ErrInvalidGenesisDataCert = sdkerrors.Register(ModuleName, 10, "invalid genesis state of data cert") ErrNoTrustedOracle = sdkerrors.Register(ModuleName, 12, "no trusted oracle, but it is required") )
x/datadeal module sentinel errors
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( // KeyDealNextNumber defines key to store the next Deal ID to be used KeyDealNextNumber = []byte{0x01} // KeyPrefixDeals defines key to store deals KeyPrefixDeals = []byte{0x02} // KeyPrefixDataCertStore defines key to store data certificate KeyPrefixDataCertStore = []byte{0x03} KeyIndexSeparator = []byte{0xFF} )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func CombineKeys ¶
CombineKeys function defines combines deal_id with data_hash.
func GetKeyPrefixDataCert ¶
func GetKeyPrefixDeals ¶
func NewDealAddress ¶
func NewDealAddress(dealID uint64) sdk.AccAddress
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
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 NewAccountWithAddress(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI SetAccount(ctx sdk.Context, acc authtypes.AccountI) GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI ValidatePermissions(macc authtypes.ModuleAccountI) error GetModuleAddress(moduleName string) sdk.AccAddress GetModuleAddressAndPermissions(moduleName string) (addr sdk.AccAddress, permissions []string) GetModuleAccountAndPermissions(ctx sdk.Context, moduleName string) (authtypes.ModuleAccountI, []string) GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI SetModuleAccount(ctx sdk.Context, macc authtypes.ModuleAccountI) }
type BankKeeper ¶
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 data validation certificate.
func (*DataCert) Descriptor ¶
func (*DataCert) GetSignature ¶
func (*DataCert) GetUnsignedCert ¶
func (m *DataCert) GetUnsignedCert() *UnsignedDataCert
func (*DataCert) MarshalToSizedBuffer ¶
func (*DataCert) ProtoMessage ¶
func (*DataCert) ProtoMessage()
func (*DataCert) XXX_DiscardUnknown ¶
func (m *DataCert) XXX_DiscardUnknown()
func (*DataCert) XXX_Marshal ¶
func (*DataCert) XXX_Unmarshal ¶
type Deal ¶
type Deal struct { DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` DealAddress string `protobuf:"bytes,2,opt,name=deal_address,json=dealAddress,proto3" json:"deal_address,omitempty"` DataSchema []string `protobuf:"bytes,3,rep,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"` Budget *types.Coin `protobuf:"bytes,4,opt,name=budget,proto3" json:"budget,omitempty"` TrustedOracles []string `protobuf:"bytes,5,rep,name=trusted_oracles,json=trustedOracles,proto3" json:"trusted_oracles,omitempty"` MaxNumData uint64 `protobuf:"varint,6,opt,name=max_num_data,json=maxNumData,proto3" json:"max_num_data,omitempty"` CurNumData uint64 `protobuf:"varint,7,opt,name=cur_num_data,json=curNumData,proto3" json:"cur_num_data,omitempty"` Owner string `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"` Status string `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"` }
Deal defines a deal.
func (*Deal) Descriptor ¶
func (*Deal) GetCurNumData ¶
func (*Deal) GetDataSchema ¶
func (*Deal) GetDealAddress ¶
func (*Deal) GetMaxNumData ¶
func (*Deal) GetTrustedOracles ¶
func (*Deal) ProtoMessage ¶
func (*Deal) ProtoMessage()
func (*Deal) XXX_DiscardUnknown ¶
func (m *Deal) XXX_DiscardUnknown()
func (*Deal) XXX_Unmarshal ¶
type GenesisState ¶
type GenesisState struct { Deals map[uint64]Deal `` /* 142-byte string literal not displayed */ DataCerts map[string]DataCert `` /* 166-byte string literal not displayed */ NextDealNumber uint64 `protobuf:"varint,3,opt,name=next_deal_number,json=nextDealNumber,proto3" json:"next_deal_number,omitempty"` }
GenesisState defines the datadeal 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) GetDataCerts ¶
func (m *GenesisState) GetDataCerts() map[string]DataCert
func (*GenesisState) GetDeals ¶
func (m *GenesisState) GetDeals() map[uint64]Deal
func (*GenesisState) GetNextDealNumber ¶
func (m *GenesisState) GetNextDealNumber() uint64
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err 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 MsgClient ¶
type MsgClient interface { // CreateDeal defines a method for creating a deal. CreateDeal(ctx context.Context, in *MsgCreateDeal, opts ...grpc.CallOption) (*MsgCreateDealResponse, error) // SellData defines a method for selling a data. SellData(ctx context.Context, in *MsgSellData, opts ...grpc.CallOption) (*MsgSellDataResponse, error) // DeactivateDeal defines a method for deactivating a deal. DeactivateDeal(ctx context.Context, in *MsgDeactivateDeal, opts ...grpc.CallOption) (*MsgDeactivateDealResponse, 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 MsgCreateDeal ¶
type MsgCreateDeal struct { DataSchema []string `protobuf:"bytes,1,rep,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"` Budget *types.Coin `protobuf:"bytes,2,opt,name=budget,proto3" json:"budget,omitempty"` MaxNumData uint64 `protobuf:"varint,3,opt,name=max_num_data,json=maxNumData,proto3" json:"max_num_data,omitempty"` TrustedOracles []string `protobuf:"bytes,4,rep,name=trusted_oracles,json=trustedOracles,proto3" json:"trusted_oracles,omitempty"` Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"` }
MsgCreateDeal defines the Msg/CreateDeal request type.
func NewMsgCreateDeal ¶
func (*MsgCreateDeal) Descriptor ¶
func (*MsgCreateDeal) Descriptor() ([]byte, []int)
func (*MsgCreateDeal) GetBudget ¶
func (m *MsgCreateDeal) GetBudget() *types.Coin
func (*MsgCreateDeal) GetDataSchema ¶
func (m *MsgCreateDeal) GetDataSchema() []string
func (*MsgCreateDeal) GetMaxNumData ¶
func (m *MsgCreateDeal) GetMaxNumData() uint64
func (*MsgCreateDeal) GetOwner ¶
func (m *MsgCreateDeal) GetOwner() string
func (*MsgCreateDeal) GetSignBytes ¶
func (msg *MsgCreateDeal) GetSignBytes() []byte
func (*MsgCreateDeal) GetSigners ¶
func (msg *MsgCreateDeal) GetSigners() []sdk.AccAddress
func (*MsgCreateDeal) GetTrustedOracles ¶
func (m *MsgCreateDeal) GetTrustedOracles() []string
func (*MsgCreateDeal) Marshal ¶
func (m *MsgCreateDeal) Marshal() (dAtA []byte, err error)
func (*MsgCreateDeal) MarshalToSizedBuffer ¶
func (m *MsgCreateDeal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateDeal) ProtoMessage ¶
func (*MsgCreateDeal) ProtoMessage()
func (*MsgCreateDeal) Reset ¶
func (m *MsgCreateDeal) Reset()
func (*MsgCreateDeal) Route ¶
func (msg *MsgCreateDeal) Route() string
func (*MsgCreateDeal) Size ¶
func (m *MsgCreateDeal) Size() (n int)
func (*MsgCreateDeal) String ¶
func (m *MsgCreateDeal) String() string
func (*MsgCreateDeal) Type ¶
func (msg *MsgCreateDeal) Type() string
func (*MsgCreateDeal) Unmarshal ¶
func (m *MsgCreateDeal) Unmarshal(dAtA []byte) error
func (*MsgCreateDeal) ValidateBasic ¶
func (msg *MsgCreateDeal) ValidateBasic() error
ValidateBasic is validation for MsgCreateDeal.
func (*MsgCreateDeal) XXX_DiscardUnknown ¶
func (m *MsgCreateDeal) XXX_DiscardUnknown()
func (*MsgCreateDeal) XXX_Marshal ¶
func (m *MsgCreateDeal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateDeal) XXX_Merge ¶
func (m *MsgCreateDeal) XXX_Merge(src proto.Message)
func (*MsgCreateDeal) XXX_Size ¶
func (m *MsgCreateDeal) XXX_Size() int
func (*MsgCreateDeal) XXX_Unmarshal ¶
func (m *MsgCreateDeal) XXX_Unmarshal(b []byte) error
type MsgCreateDealResponse ¶
type MsgCreateDealResponse struct {
DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"`
}
MsgCreateDealResponse defines the Msg/CreateDeal response type.
func (*MsgCreateDealResponse) Descriptor ¶
func (*MsgCreateDealResponse) Descriptor() ([]byte, []int)
func (*MsgCreateDealResponse) GetDealId ¶
func (m *MsgCreateDealResponse) GetDealId() uint64
func (*MsgCreateDealResponse) Marshal ¶
func (m *MsgCreateDealResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreateDealResponse) MarshalTo ¶
func (m *MsgCreateDealResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateDealResponse) MarshalToSizedBuffer ¶
func (m *MsgCreateDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateDealResponse) ProtoMessage ¶
func (*MsgCreateDealResponse) ProtoMessage()
func (*MsgCreateDealResponse) Reset ¶
func (m *MsgCreateDealResponse) Reset()
func (*MsgCreateDealResponse) Size ¶
func (m *MsgCreateDealResponse) Size() (n int)
func (*MsgCreateDealResponse) String ¶
func (m *MsgCreateDealResponse) String() string
func (*MsgCreateDealResponse) Unmarshal ¶
func (m *MsgCreateDealResponse) Unmarshal(dAtA []byte) error
func (*MsgCreateDealResponse) XXX_DiscardUnknown ¶
func (m *MsgCreateDealResponse) XXX_DiscardUnknown()
func (*MsgCreateDealResponse) XXX_Marshal ¶
func (m *MsgCreateDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateDealResponse) XXX_Merge ¶
func (m *MsgCreateDealResponse) XXX_Merge(src proto.Message)
func (*MsgCreateDealResponse) XXX_Size ¶
func (m *MsgCreateDealResponse) XXX_Size() int
func (*MsgCreateDealResponse) XXX_Unmarshal ¶
func (m *MsgCreateDealResponse) XXX_Unmarshal(b []byte) error
type MsgDeactivateDeal ¶
type MsgDeactivateDeal struct { DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` DeactivateRequester string `protobuf:"bytes,2,opt,name=deactivate_requester,json=deactivateRequester,proto3" json:"deactivate_requester,omitempty"` }
MsgDeactivateDeal defines the Msg/DeactivateDeal request type.
func NewMsgDeactivateDeal ¶
func NewMsgDeactivateDeal(dealID uint64, deactivateRequester string) *MsgDeactivateDeal
func (*MsgDeactivateDeal) Descriptor ¶
func (*MsgDeactivateDeal) Descriptor() ([]byte, []int)
func (*MsgDeactivateDeal) GetDeactivateRequester ¶
func (m *MsgDeactivateDeal) GetDeactivateRequester() string
func (*MsgDeactivateDeal) GetDealId ¶
func (m *MsgDeactivateDeal) GetDealId() uint64
func (*MsgDeactivateDeal) GetSignBytes ¶
func (msg *MsgDeactivateDeal) GetSignBytes() []byte
func (*MsgDeactivateDeal) GetSigners ¶
func (msg *MsgDeactivateDeal) GetSigners() []sdk.AccAddress
func (*MsgDeactivateDeal) Marshal ¶
func (m *MsgDeactivateDeal) Marshal() (dAtA []byte, err error)
func (*MsgDeactivateDeal) MarshalTo ¶
func (m *MsgDeactivateDeal) MarshalTo(dAtA []byte) (int, error)
func (*MsgDeactivateDeal) MarshalToSizedBuffer ¶
func (m *MsgDeactivateDeal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeactivateDeal) ProtoMessage ¶
func (*MsgDeactivateDeal) ProtoMessage()
func (*MsgDeactivateDeal) Reset ¶
func (m *MsgDeactivateDeal) Reset()
func (*MsgDeactivateDeal) Route ¶
func (msg *MsgDeactivateDeal) Route() string
func (*MsgDeactivateDeal) Size ¶
func (m *MsgDeactivateDeal) Size() (n int)
func (*MsgDeactivateDeal) String ¶
func (m *MsgDeactivateDeal) String() string
func (*MsgDeactivateDeal) Type ¶
func (msg *MsgDeactivateDeal) Type() string
func (*MsgDeactivateDeal) Unmarshal ¶
func (m *MsgDeactivateDeal) Unmarshal(dAtA []byte) error
func (*MsgDeactivateDeal) ValidateBasic ¶
func (msg *MsgDeactivateDeal) ValidateBasic() error
ValidateBasic is validation for MsgCreateDeal.
func (*MsgDeactivateDeal) XXX_DiscardUnknown ¶
func (m *MsgDeactivateDeal) XXX_DiscardUnknown()
func (*MsgDeactivateDeal) XXX_Marshal ¶
func (m *MsgDeactivateDeal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeactivateDeal) XXX_Merge ¶
func (m *MsgDeactivateDeal) XXX_Merge(src proto.Message)
func (*MsgDeactivateDeal) XXX_Size ¶
func (m *MsgDeactivateDeal) XXX_Size() int
func (*MsgDeactivateDeal) XXX_Unmarshal ¶
func (m *MsgDeactivateDeal) XXX_Unmarshal(b []byte) error
type MsgDeactivateDealResponse ¶
type MsgDeactivateDealResponse struct {
DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"`
}
MsgDeactivateDealResponse defines the Msg/DeactivateDeal response type.
func (*MsgDeactivateDealResponse) Descriptor ¶
func (*MsgDeactivateDealResponse) Descriptor() ([]byte, []int)
func (*MsgDeactivateDealResponse) GetDealId ¶
func (m *MsgDeactivateDealResponse) GetDealId() uint64
func (*MsgDeactivateDealResponse) Marshal ¶
func (m *MsgDeactivateDealResponse) Marshal() (dAtA []byte, err error)
func (*MsgDeactivateDealResponse) MarshalTo ¶
func (m *MsgDeactivateDealResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgDeactivateDealResponse) MarshalToSizedBuffer ¶
func (m *MsgDeactivateDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeactivateDealResponse) ProtoMessage ¶
func (*MsgDeactivateDealResponse) ProtoMessage()
func (*MsgDeactivateDealResponse) Reset ¶
func (m *MsgDeactivateDealResponse) Reset()
func (*MsgDeactivateDealResponse) Size ¶
func (m *MsgDeactivateDealResponse) Size() (n int)
func (*MsgDeactivateDealResponse) String ¶
func (m *MsgDeactivateDealResponse) String() string
func (*MsgDeactivateDealResponse) Unmarshal ¶
func (m *MsgDeactivateDealResponse) Unmarshal(dAtA []byte) error
func (*MsgDeactivateDealResponse) XXX_DiscardUnknown ¶
func (m *MsgDeactivateDealResponse) XXX_DiscardUnknown()
func (*MsgDeactivateDealResponse) XXX_Marshal ¶
func (m *MsgDeactivateDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeactivateDealResponse) XXX_Merge ¶
func (m *MsgDeactivateDealResponse) XXX_Merge(src proto.Message)
func (*MsgDeactivateDealResponse) XXX_Size ¶
func (m *MsgDeactivateDealResponse) XXX_Size() int
func (*MsgDeactivateDealResponse) XXX_Unmarshal ¶
func (m *MsgDeactivateDealResponse) 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 NewMsgSellData ¶
func NewMsgSellData(cert DataCert, seller string) *MsgSellData
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) 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
ValidateBasic is validation for MsgSellData.
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 {
Reward *types.Coin `protobuf:"bytes,1,opt,name=reward,proto3" json:"reward,omitempty"`
}
MsgSellDataResponse defines the Msg/SellData response type.
func (*MsgSellDataResponse) Descriptor ¶
func (*MsgSellDataResponse) Descriptor() ([]byte, []int)
func (*MsgSellDataResponse) GetReward ¶
func (m *MsgSellDataResponse) GetReward() *types.Coin
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 { // CreateDeal defines a method for creating a deal. CreateDeal(context.Context, *MsgCreateDeal) (*MsgCreateDealResponse, error) // SellData defines a method for selling a data. SellData(context.Context, *MsgSellData) (*MsgSellDataResponse, error) // DeactivateDeal defines a method for deactivating a deal. DeactivateDeal(context.Context, *MsgDeactivateDeal) (*MsgDeactivateDealResponse, error) }
MsgServer is the server API for Msg service.
type QueryClient ¶
type QueryClient interface { // Deal returns a Deal. Deal(ctx context.Context, in *QueryDealRequest, opts ...grpc.CallOption) (*QueryDealResponse, error) // Deals returns multiple deals Deals(ctx context.Context, in *QueryDealsRequest, opts ...grpc.CallOption) (*QueryDealsResponse, error) // DataCert returns a DataCert. DataCert(ctx context.Context, in *QueryDataCertRequest, opts ...grpc.CallOption) (*QueryDataCertResponse, error) // DataCerts return DataCerts. DataCerts(ctx context.Context, in *QueryDataCertsRequest, opts ...grpc.CallOption) (*QueryDataCertsResponse, 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 QueryDataCertRequest ¶
type QueryDataCertRequest struct { DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` DataHash string `protobuf:"bytes,2,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"` }
QueryDataCertRequest is the request type for Query/DataCert RPC method.
func (*QueryDataCertRequest) Descriptor ¶
func (*QueryDataCertRequest) Descriptor() ([]byte, []int)
func (*QueryDataCertRequest) GetDataHash ¶
func (m *QueryDataCertRequest) GetDataHash() string
func (*QueryDataCertRequest) GetDealId ¶
func (m *QueryDataCertRequest) GetDealId() uint64
func (*QueryDataCertRequest) Marshal ¶
func (m *QueryDataCertRequest) Marshal() (dAtA []byte, err error)
func (*QueryDataCertRequest) MarshalTo ¶
func (m *QueryDataCertRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryDataCertRequest) MarshalToSizedBuffer ¶
func (m *QueryDataCertRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDataCertRequest) ProtoMessage ¶
func (*QueryDataCertRequest) ProtoMessage()
func (*QueryDataCertRequest) Reset ¶
func (m *QueryDataCertRequest) Reset()
func (*QueryDataCertRequest) Size ¶
func (m *QueryDataCertRequest) Size() (n int)
func (*QueryDataCertRequest) String ¶
func (m *QueryDataCertRequest) String() string
func (*QueryDataCertRequest) Unmarshal ¶
func (m *QueryDataCertRequest) Unmarshal(dAtA []byte) error
func (*QueryDataCertRequest) XXX_DiscardUnknown ¶
func (m *QueryDataCertRequest) XXX_DiscardUnknown()
func (*QueryDataCertRequest) XXX_Marshal ¶
func (m *QueryDataCertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDataCertRequest) XXX_Merge ¶
func (m *QueryDataCertRequest) XXX_Merge(src proto.Message)
func (*QueryDataCertRequest) XXX_Size ¶
func (m *QueryDataCertRequest) XXX_Size() int
func (*QueryDataCertRequest) XXX_Unmarshal ¶
func (m *QueryDataCertRequest) XXX_Unmarshal(b []byte) error
type QueryDataCertResponse ¶
type QueryDataCertResponse struct {
DataCert *DataCert `protobuf:"bytes,1,opt,name=data_cert,json=dataCert,proto3" json:"data_cert,omitempty"`
}
QueryDataCertResponse is the response type for Query/DataCert RPC method.
func (*QueryDataCertResponse) Descriptor ¶
func (*QueryDataCertResponse) Descriptor() ([]byte, []int)
func (*QueryDataCertResponse) GetDataCert ¶
func (m *QueryDataCertResponse) GetDataCert() *DataCert
func (*QueryDataCertResponse) Marshal ¶
func (m *QueryDataCertResponse) Marshal() (dAtA []byte, err error)
func (*QueryDataCertResponse) MarshalTo ¶
func (m *QueryDataCertResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDataCertResponse) MarshalToSizedBuffer ¶
func (m *QueryDataCertResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDataCertResponse) ProtoMessage ¶
func (*QueryDataCertResponse) ProtoMessage()
func (*QueryDataCertResponse) Reset ¶
func (m *QueryDataCertResponse) Reset()
func (*QueryDataCertResponse) Size ¶
func (m *QueryDataCertResponse) Size() (n int)
func (*QueryDataCertResponse) String ¶
func (m *QueryDataCertResponse) String() string
func (*QueryDataCertResponse) Unmarshal ¶
func (m *QueryDataCertResponse) Unmarshal(dAtA []byte) error
func (*QueryDataCertResponse) XXX_DiscardUnknown ¶
func (m *QueryDataCertResponse) XXX_DiscardUnknown()
func (*QueryDataCertResponse) XXX_Marshal ¶
func (m *QueryDataCertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDataCertResponse) XXX_Merge ¶
func (m *QueryDataCertResponse) XXX_Merge(src proto.Message)
func (*QueryDataCertResponse) XXX_Size ¶
func (m *QueryDataCertResponse) XXX_Size() int
func (*QueryDataCertResponse) XXX_Unmarshal ¶
func (m *QueryDataCertResponse) XXX_Unmarshal(b []byte) error
type QueryDataCertsRequest ¶
type QueryDataCertsRequest struct { DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryDataCertsRequest is the request type for Query/DataCerts RPC method.
func (*QueryDataCertsRequest) Descriptor ¶
func (*QueryDataCertsRequest) Descriptor() ([]byte, []int)
func (*QueryDataCertsRequest) GetDealId ¶
func (m *QueryDataCertsRequest) GetDealId() uint64
func (*QueryDataCertsRequest) GetPagination ¶
func (m *QueryDataCertsRequest) GetPagination() *query.PageRequest
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 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 QueryDealRequest ¶
type QueryDealRequest struct {
DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"`
}
QueryDealRequest is the request type for Query/Deal RPC method.
func (*QueryDealRequest) Descriptor ¶
func (*QueryDealRequest) Descriptor() ([]byte, []int)
func (*QueryDealRequest) GetDealId ¶
func (m *QueryDealRequest) GetDealId() uint64
func (*QueryDealRequest) Marshal ¶
func (m *QueryDealRequest) Marshal() (dAtA []byte, err error)
func (*QueryDealRequest) MarshalToSizedBuffer ¶
func (m *QueryDealRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDealRequest) ProtoMessage ¶
func (*QueryDealRequest) ProtoMessage()
func (*QueryDealRequest) Reset ¶
func (m *QueryDealRequest) Reset()
func (*QueryDealRequest) Size ¶
func (m *QueryDealRequest) Size() (n int)
func (*QueryDealRequest) String ¶
func (m *QueryDealRequest) String() string
func (*QueryDealRequest) Unmarshal ¶
func (m *QueryDealRequest) Unmarshal(dAtA []byte) error
func (*QueryDealRequest) XXX_DiscardUnknown ¶
func (m *QueryDealRequest) XXX_DiscardUnknown()
func (*QueryDealRequest) XXX_Marshal ¶
func (m *QueryDealRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDealRequest) XXX_Merge ¶
func (m *QueryDealRequest) XXX_Merge(src proto.Message)
func (*QueryDealRequest) XXX_Size ¶
func (m *QueryDealRequest) XXX_Size() int
func (*QueryDealRequest) XXX_Unmarshal ¶
func (m *QueryDealRequest) XXX_Unmarshal(b []byte) error
type QueryDealResponse ¶
type QueryDealResponse struct {
Deal *Deal `protobuf:"bytes,1,opt,name=deal,proto3" json:"deal,omitempty"`
}
QueryDealResponse is the response type for the Query/Deal RPC method.
func (*QueryDealResponse) Descriptor ¶
func (*QueryDealResponse) Descriptor() ([]byte, []int)
func (*QueryDealResponse) GetDeal ¶
func (m *QueryDealResponse) GetDeal() *Deal
func (*QueryDealResponse) Marshal ¶
func (m *QueryDealResponse) Marshal() (dAtA []byte, err error)
func (*QueryDealResponse) MarshalTo ¶
func (m *QueryDealResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDealResponse) MarshalToSizedBuffer ¶
func (m *QueryDealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDealResponse) ProtoMessage ¶
func (*QueryDealResponse) ProtoMessage()
func (*QueryDealResponse) Reset ¶
func (m *QueryDealResponse) Reset()
func (*QueryDealResponse) Size ¶
func (m *QueryDealResponse) Size() (n int)
func (*QueryDealResponse) String ¶
func (m *QueryDealResponse) String() string
func (*QueryDealResponse) Unmarshal ¶
func (m *QueryDealResponse) Unmarshal(dAtA []byte) error
func (*QueryDealResponse) XXX_DiscardUnknown ¶
func (m *QueryDealResponse) XXX_DiscardUnknown()
func (*QueryDealResponse) XXX_Marshal ¶
func (m *QueryDealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDealResponse) XXX_Merge ¶
func (m *QueryDealResponse) XXX_Merge(src proto.Message)
func (*QueryDealResponse) XXX_Size ¶
func (m *QueryDealResponse) XXX_Size() int
func (*QueryDealResponse) XXX_Unmarshal ¶
func (m *QueryDealResponse) XXX_Unmarshal(b []byte) error
type QueryDealsRequest ¶
type QueryDealsRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
QueryDealsRequest is the request type for Query/Deals RPC method.
func (*QueryDealsRequest) Descriptor ¶
func (*QueryDealsRequest) Descriptor() ([]byte, []int)
func (*QueryDealsRequest) GetPagination ¶
func (m *QueryDealsRequest) GetPagination() *query.PageRequest
func (*QueryDealsRequest) Marshal ¶
func (m *QueryDealsRequest) Marshal() (dAtA []byte, err error)
func (*QueryDealsRequest) MarshalTo ¶
func (m *QueryDealsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryDealsRequest) MarshalToSizedBuffer ¶
func (m *QueryDealsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDealsRequest) ProtoMessage ¶
func (*QueryDealsRequest) ProtoMessage()
func (*QueryDealsRequest) Reset ¶
func (m *QueryDealsRequest) Reset()
func (*QueryDealsRequest) Size ¶
func (m *QueryDealsRequest) Size() (n int)
func (*QueryDealsRequest) String ¶
func (m *QueryDealsRequest) String() string
func (*QueryDealsRequest) Unmarshal ¶
func (m *QueryDealsRequest) Unmarshal(dAtA []byte) error
func (*QueryDealsRequest) XXX_DiscardUnknown ¶
func (m *QueryDealsRequest) XXX_DiscardUnknown()
func (*QueryDealsRequest) XXX_Marshal ¶
func (m *QueryDealsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDealsRequest) XXX_Merge ¶
func (m *QueryDealsRequest) XXX_Merge(src proto.Message)
func (*QueryDealsRequest) XXX_Size ¶
func (m *QueryDealsRequest) XXX_Size() int
func (*QueryDealsRequest) XXX_Unmarshal ¶
func (m *QueryDealsRequest) XXX_Unmarshal(b []byte) error
type QueryDealsResponse ¶
type QueryDealsResponse struct { Deals []Deal `protobuf:"bytes,1,rep,name=deals,proto3" json:"deals"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryDealsResponse is the response type for Query/Deals RPC method.
func (*QueryDealsResponse) Descriptor ¶
func (*QueryDealsResponse) Descriptor() ([]byte, []int)
func (*QueryDealsResponse) GetDeals ¶
func (m *QueryDealsResponse) GetDeals() []Deal
func (*QueryDealsResponse) GetPagination ¶
func (m *QueryDealsResponse) GetPagination() *query.PageResponse
func (*QueryDealsResponse) Marshal ¶
func (m *QueryDealsResponse) Marshal() (dAtA []byte, err error)
func (*QueryDealsResponse) MarshalTo ¶
func (m *QueryDealsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDealsResponse) MarshalToSizedBuffer ¶
func (m *QueryDealsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDealsResponse) ProtoMessage ¶
func (*QueryDealsResponse) ProtoMessage()
func (*QueryDealsResponse) Reset ¶
func (m *QueryDealsResponse) Reset()
func (*QueryDealsResponse) Size ¶
func (m *QueryDealsResponse) Size() (n int)
func (*QueryDealsResponse) String ¶
func (m *QueryDealsResponse) String() string
func (*QueryDealsResponse) Unmarshal ¶
func (m *QueryDealsResponse) Unmarshal(dAtA []byte) error
func (*QueryDealsResponse) XXX_DiscardUnknown ¶
func (m *QueryDealsResponse) XXX_DiscardUnknown()
func (*QueryDealsResponse) XXX_Marshal ¶
func (m *QueryDealsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDealsResponse) XXX_Merge ¶
func (m *QueryDealsResponse) XXX_Merge(src proto.Message)
func (*QueryDealsResponse) XXX_Size ¶
func (m *QueryDealsResponse) XXX_Size() int
func (*QueryDealsResponse) XXX_Unmarshal ¶
func (m *QueryDealsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Deal returns a Deal. Deal(context.Context, *QueryDealRequest) (*QueryDealResponse, error) // Deals returns multiple deals Deals(context.Context, *QueryDealsRequest) (*QueryDealsResponse, error) // DataCert returns a DataCert. DataCert(context.Context, *QueryDataCertRequest) (*QueryDataCertResponse, error) // DataCerts return DataCerts. DataCerts(context.Context, *QueryDataCertsRequest) (*QueryDataCertsResponse, error) }
QueryServer is the server API for Query service.
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) CreateDeal ¶
func (*UnimplementedMsgServer) CreateDeal(ctx context.Context, req *MsgCreateDeal) (*MsgCreateDealResponse, error)
func (*UnimplementedMsgServer) DeactivateDeal ¶
func (*UnimplementedMsgServer) DeactivateDeal(ctx context.Context, req *MsgDeactivateDeal) (*MsgDeactivateDealResponse, 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) DataCert ¶
func (*UnimplementedQueryServer) DataCert(ctx context.Context, req *QueryDataCertRequest) (*QueryDataCertResponse, error)
func (*UnimplementedQueryServer) DataCerts ¶
func (*UnimplementedQueryServer) DataCerts(ctx context.Context, req *QueryDataCertsRequest) (*QueryDataCertsResponse, error)
func (*UnimplementedQueryServer) Deal ¶
func (*UnimplementedQueryServer) Deal(ctx context.Context, req *QueryDealRequest) (*QueryDealResponse, error)
func (*UnimplementedQueryServer) Deals ¶
func (*UnimplementedQueryServer) Deals(ctx context.Context, req *QueryDealsRequest) (*QueryDealsResponse, error)
type UnsignedDataCert ¶
type UnsignedDataCert struct { DealId uint64 `protobuf:"varint,1,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` DataHash []byte `protobuf:"bytes,2,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"` EncryptedDataUrl []byte `protobuf:"bytes,3,opt,name=encrypted_data_url,json=encryptedDataUrl,proto3" json:"encrypted_data_url,omitempty"` OracleAddress string `protobuf:"bytes,4,opt,name=oracle_address,json=oracleAddress,proto3" json:"oracle_address,omitempty"` RequesterAddress string `protobuf:"bytes,5,opt,name=requester_address,json=requesterAddress,proto3" json:"requester_address,omitempty"` }
UnsignedDataCert defines unsigned data validation certificate.
func (*UnsignedDataCert) Descriptor ¶
func (*UnsignedDataCert) Descriptor() ([]byte, []int)
func (*UnsignedDataCert) GetDataHash ¶
func (m *UnsignedDataCert) GetDataHash() []byte
func (*UnsignedDataCert) GetDealId ¶
func (m *UnsignedDataCert) GetDealId() uint64
func (*UnsignedDataCert) GetEncryptedDataUrl ¶
func (m *UnsignedDataCert) GetEncryptedDataUrl() []byte
func (*UnsignedDataCert) GetOracleAddress ¶
func (m *UnsignedDataCert) GetOracleAddress() string
func (*UnsignedDataCert) GetRequesterAddress ¶
func (m *UnsignedDataCert) GetRequesterAddress() string
func (*UnsignedDataCert) Marshal ¶
func (m *UnsignedDataCert) Marshal() (dAtA []byte, err 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