types

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2022 License: GPL-3.0 Imports: 36 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName   = "iscn"
	StoreKey     = ModuleName
	QuerierRoute = ModuleName
	RouterKey    = ModuleName
)
View Source 
const (
	TypeMsgCreateIscnRecord          = "create_iscn_record"
	TypeMsgUpdateIscnRecord          = "update_iscn_record"
	TypeMsgChangeIscnRecordOwnership = "msg_change_iscn_record_ownership"
)
View Source 
const CidCodecType = 0x0129 // DAG-JSON
View Source 
const IscnIdRegexpPattern = "iscn://([-_.:=+,a-zA-Z0-9]+)/([-_.:=+,a-zA-Z0-9]+)(?:/([0-9]+))?$"

Variables

View Source 
var (
	ErrInvalidIscnRecord  = sdkerrors.Register(ModuleName, 1, "invalid ISCN record")
	ErrInvalidIscnId      = sdkerrors.Register(ModuleName, 2, "invalid ISCN ID")
	ErrReusingIscnId      = sdkerrors.Register(ModuleName, 3, "reusing ISCN ID")
	ErrRecordAlreadyExist = sdkerrors.Register(ModuleName, 4, "record already exist")
	ErrEncodingJsonLd     = sdkerrors.Register(ModuleName, 5, "error when encoding JSON-LD record")
	ErrInvalidIscnVersion = sdkerrors.Register(ModuleName, 6, "invalid ISCN ID version")
	ErrDeductIscnFee      = sdkerrors.Register(ModuleName, 7, "error when deducting fee for ISCN record")
	ErrRecordNotFound     = sdkerrors.Register(ModuleName, 8, "record not found")
)
View Source 
var (
	EventTypeIscnRecord = "iscn_record"

	AttributeKeyIscnId                 = "iscn_id"
	AttributeKeyIscnIdPrefix           = "iscn_id_prefix"
	AttributeKeyIscnOwner              = "owner"
	AttributeKeyIscnRecordIpld         = "ipld"
	AttributeKeyIscnContentFingerprint = "content_fingerprint"
	AttributeValueCategory             = ModuleName
)
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 (
	ErrInvalidLengthIscnid        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIscnid          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIscnid = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	SequenceCountKey            = []byte{0x01}
	SequenceToStoreRecordPrefix = []byte{0x02}
	CidToSequencePrefix         = []byte{0x03}
	IscnIdToSequencePrefix      = []byte{0x04}
	ContentIdRecordPrefix       = []byte{0x05}
	FingerprintSequencePrefix   = []byte{0x06}
	OwnerSequencePrefix         = []byte{0x07}
)
View Source 
var (
	DefaultFeePerByteDenom        = "nanolike"
	DefaultFeePerByteAmount int64 = 10000
	DefaultRegistryName           = "likecoin-chain"
	DefaultFeePerByte             = sdk.NewDecCoin(
		DefaultFeePerByteDenom, sdk.NewInt(DefaultFeePerByteAmount),
	)
)
View Source 
var (
	ParamKeyRegistryName = []byte("RegistryName")
	ParamKeyFeePerByte   = []byte("FeePerByte")
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	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 (
	ErrInvalidLengthStore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStore = 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 IscnIdRegexp *regexp.Regexp = regexp.MustCompile(IscnIdRegexpPattern)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func DecodeUint32 

func DecodeUint32(bz []byte) uint32

func DecodeUint64 

func DecodeUint64(bz []byte) uint64

func EncodeUint32 

func EncodeUint32(n uint32) []byte

func EncodeUint64 

func EncodeUint64(n uint64) []byte

func GetFingerprintSequenceKey 

func GetFingerprintSequenceKey(fingerprint string, seq uint64) []byte

func GetFingerprintStorePrefix 

func GetFingerprintStorePrefix(fingerprint string) []byte

one fingerprint points to many sequence key structure:

  • 4 bytes fingerprint length
  • fpLen bytes fingerprint
  • 8 bytes sequence

func GetOwnerSequenceKey 

func GetOwnerSequenceKey(owner sdk.AccAddress, seq uint64) []byte

func GetOwnerStorePrefix 

func GetOwnerStorePrefix(owner sdk.AccAddress) []byte

one owner points to many sequence key structure:

  • 4 bytes owner address bytes length
  • addrLen bytes owner address
  • 8 bytes sequence

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

func ParseFingerprintSequenceBytes 

func ParseFingerprintSequenceBytes(key []byte) (fingerprint string, seq uint64)

func ParseOwnerSequenceBytes 

func ParseOwnerSequenceBytes(key []byte) (owner sdk.AccAddress, seq uint64)

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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 to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateFingerprints 

func ValidateFingerprints(fingerprints []string) error

Types

type CID 

type CID = gocid.Cid

func ComputeDataCid 

func ComputeDataCid(record []byte) CID

func MustCidFromBytes 

func MustCidFromBytes(bz []byte) CID

type ContentIdRecord 

type ContentIdRecord struct {
	OwnerAddressBytes []byte `protobuf:"bytes,1,opt,name=owner_address_bytes,json=ownerAddressBytes,proto3" json:"owner_address_bytes,omitempty"`
	LatestVersion     uint64 `protobuf:"varint,2,opt,name=latest_version,json=latestVersion,proto3" json:"latest_version,omitempty"`
}

func (*ContentIdRecord) Descriptor 

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

func (*ContentIdRecord) GetLatestVersion 

func (m *ContentIdRecord) GetLatestVersion() uint64

func (*ContentIdRecord) GetOwnerAddressBytes 

func (m *ContentIdRecord) GetOwnerAddressBytes() []byte

func (*ContentIdRecord) Marshal 

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

func (*ContentIdRecord) MarshalTo 

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

func (*ContentIdRecord) MarshalToSizedBuffer 

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

func (ContentIdRecord) OwnerAddress 

func (record ContentIdRecord) OwnerAddress() sdk.AccAddress

func (*ContentIdRecord) ProtoMessage 

func (*ContentIdRecord) ProtoMessage()

func (*ContentIdRecord) Reset 

func (m *ContentIdRecord) Reset()

func (*ContentIdRecord) Size 

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

func (*ContentIdRecord) String 

func (m *ContentIdRecord) String() string

func (*ContentIdRecord) Unmarshal 

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

func (*ContentIdRecord) XXX_DiscardUnknown 

func (m *ContentIdRecord) XXX_DiscardUnknown()

func (*ContentIdRecord) XXX_Marshal 

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

func (*ContentIdRecord) XXX_Merge 

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

func (*ContentIdRecord) XXX_Size 

func (m *ContentIdRecord) XXX_Size() int

func (*ContentIdRecord) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params           Params                         `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	ContentIdRecords []GenesisState_ContentIdRecord `protobuf:"bytes,2,rep,name=content_id_records,json=contentIdRecords,proto3" json:"content_id_records"`
	IscnRecords      []IscnInput                    `protobuf:"bytes,3,rep,name=iscn_records,json=iscnRecords,proto3,customtype=IscnInput" json:"iscn_records"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func GetGenesisStateFromAppState 

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

func NewGenesisState 

func NewGenesisState(params Params, contentIdRecords []GenesisState_ContentIdRecord, iscnRecords []IscnInput) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetContentIdRecords 

func (m *GenesisState) GetContentIdRecords() []GenesisState_ContentIdRecord

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

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 (genesis GenesisState) Validate() error

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type GenesisState_ContentIdRecord 

type GenesisState_ContentIdRecord struct {
	IscnId        string `protobuf:"bytes,1,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	Owner         string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	LatestVersion uint64 `protobuf:"varint,3,opt,name=latest_version,json=latestVersion,proto3" json:"latest_version,omitempty"`
}

func (*GenesisState_ContentIdRecord) Descriptor 

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

func (*GenesisState_ContentIdRecord) GetIscnId 

func (m *GenesisState_ContentIdRecord) GetIscnId() string

func (*GenesisState_ContentIdRecord) GetLatestVersion 

func (m *GenesisState_ContentIdRecord) GetLatestVersion() uint64

func (*GenesisState_ContentIdRecord) GetOwner 

func (m *GenesisState_ContentIdRecord) GetOwner() string

func (*GenesisState_ContentIdRecord) Marshal 

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

func (*GenesisState_ContentIdRecord) MarshalTo 

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

func (*GenesisState_ContentIdRecord) MarshalToSizedBuffer 

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

func (*GenesisState_ContentIdRecord) ProtoMessage 

func (*GenesisState_ContentIdRecord) ProtoMessage()

func (*GenesisState_ContentIdRecord) Reset 

func (m *GenesisState_ContentIdRecord) Reset()

func (*GenesisState_ContentIdRecord) Size 

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

func (*GenesisState_ContentIdRecord) String 

func (m *GenesisState_ContentIdRecord) String() string

func (*GenesisState_ContentIdRecord) Unmarshal 

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

func (*GenesisState_ContentIdRecord) XXX_DiscardUnknown 

func (m *GenesisState_ContentIdRecord) XXX_DiscardUnknown()

func (*GenesisState_ContentIdRecord) XXX_Marshal 

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

func (*GenesisState_ContentIdRecord) XXX_Merge 

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

func (*GenesisState_ContentIdRecord) XXX_Size 

func (m *GenesisState_ContentIdRecord) XXX_Size() int

func (*GenesisState_ContentIdRecord) XXX_Unmarshal 

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

type IscnId 

type IscnId struct {
	Prefix  IscnIdPrefix `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix"`
	Version uint64       `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

func GenerateNewIscnIdWithSeed 

func GenerateNewIscnIdWithSeed(registryName string, seed []byte) IscnId

func NewIscnId 

func NewIscnId(registryName, contentId string, version uint64) IscnId

func ParseIscnId 

func ParseIscnId(s string) (IscnId, error)

func (*IscnId) Descriptor 

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

func (*IscnId) Equal 

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

func (*IscnId) GetPrefix 

func (m *IscnId) GetPrefix() IscnIdPrefix

func (*IscnId) GetVersion 

func (m *IscnId) GetVersion() uint64

func (*IscnId) Marshal 

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

func (IscnId) MarshalJSON 

func (iscnId IscnId) MarshalJSON() ([]byte, error)

func (*IscnId) MarshalTo 

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

func (*IscnId) MarshalToSizedBuffer 

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

func (*IscnId) PrefixEqual 

func (iscnId *IscnId) PrefixEqual(iscnId2 *IscnId) bool

func (IscnId) PrefixId 

func (iscnId IscnId) PrefixId() IscnId

func (*IscnId) ProtoMessage 

func (*IscnId) ProtoMessage()

func (*IscnId) Reset 

func (m *IscnId) Reset()

func (*IscnId) Size 

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

func (IscnId) String 

func (iscnId IscnId) String() string

func (*IscnId) Unmarshal 

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

func (*IscnId) UnmarshalJSON 

func (iscnId *IscnId) UnmarshalJSON(bz []byte) error

func (*IscnId) XXX_DiscardUnknown 

func (m *IscnId) XXX_DiscardUnknown()

func (*IscnId) XXX_Marshal 

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

func (*IscnId) XXX_Merge 

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

func (*IscnId) XXX_Size 

func (m *IscnId) XXX_Size() int

func (*IscnId) XXX_Unmarshal 

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

type IscnIdPrefix 

type IscnIdPrefix struct {
	RegistryName string `protobuf:"bytes,1,opt,name=registry_name,json=registryName,proto3" json:"registry_name,omitempty"`
	ContentId    string `protobuf:"bytes,2,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
}

func (*IscnIdPrefix) Descriptor 

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

func (*IscnIdPrefix) Equal 

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

func (*IscnIdPrefix) GetContentId 

func (m *IscnIdPrefix) GetContentId() string

func (*IscnIdPrefix) GetRegistryName 

func (m *IscnIdPrefix) GetRegistryName() string

func (*IscnIdPrefix) Marshal 

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

func (*IscnIdPrefix) MarshalTo 

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

func (*IscnIdPrefix) MarshalToSizedBuffer 

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

func (*IscnIdPrefix) ProtoMessage 

func (*IscnIdPrefix) ProtoMessage()

func (*IscnIdPrefix) Reset 

func (m *IscnIdPrefix) Reset()

func (*IscnIdPrefix) Size 

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

func (IscnIdPrefix) String 

func (prefix IscnIdPrefix) String() string

func (*IscnIdPrefix) Unmarshal 

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

func (*IscnIdPrefix) XXX_DiscardUnknown 

func (m *IscnIdPrefix) XXX_DiscardUnknown()

func (*IscnIdPrefix) XXX_Marshal 

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

func (*IscnIdPrefix) XXX_Merge 

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

func (*IscnIdPrefix) XXX_Size 

func (m *IscnIdPrefix) XXX_Size() int

func (*IscnIdPrefix) XXX_Unmarshal 

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

type IscnInput 

type IscnInput json.RawMessage // JSON encoded

func (IscnInput) GetPath 

func (input IscnInput) GetPath(path ...interface{}) (interface{}, bool)

for testing

func (IscnInput) Marshal 

func (input IscnInput) Marshal() ([]byte, error)

func (IscnInput) MarshalJSON 

func (input IscnInput) MarshalJSON() ([]byte, error)

func (*IscnInput) MarshalTo 

func (input *IscnInput) MarshalTo(dAtA []byte) (int, error)

func (IscnInput) Normalize 

func (input IscnInput) Normalize() (json.RawMessage, error)

Normalize returns a sorted JSON without indentation

func (IscnInput) Size 

func (input IscnInput) Size() int

func (IscnInput) String 

func (input IscnInput) String() string

func (*IscnInput) Unmarshal 

func (input *IscnInput) Unmarshal(bz []byte) error

func (*IscnInput) UnmarshalJSON 

func (input *IscnInput) UnmarshalJSON(bz []byte) error

func (IscnInput) Validate 

func (input IscnInput) Validate() error

type IscnRecord 

type IscnRecord struct {
	// Using camelCases to make the record JSON in tx more like general JSON documents
	RecordNotes         string   `protobuf:"bytes,1,opt,name=recordNotes,proto3" json:"recordNotes,omitempty"`
	ContentFingerprints []string `protobuf:"bytes,2,rep,name=contentFingerprints,proto3" json:"contentFingerprints,omitempty"`
	// Here, `IscnInput` is JSON encoded bytes
	Stakeholders    []IscnInput `protobuf:"bytes,3,rep,name=stakeholders,proto3,customtype=IscnInput" json:"stakeholders,omitempty"`
	ContentMetadata IscnInput   `protobuf:"bytes,4,opt,name=contentMetadata,proto3,customtype=IscnInput" json:"contentMetadata"`
}

func (*IscnRecord) Descriptor 

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

func (*IscnRecord) GetContentFingerprints 

func (m *IscnRecord) GetContentFingerprints() []string

func (*IscnRecord) GetRecordNotes 

func (m *IscnRecord) GetRecordNotes() string

func (*IscnRecord) Marshal 

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

func (*IscnRecord) MarshalTo 

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

func (*IscnRecord) MarshalToSizedBuffer 

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

func (*IscnRecord) ProtoMessage 

func (*IscnRecord) ProtoMessage()

func (*IscnRecord) Reset 

func (m *IscnRecord) Reset()

func (*IscnRecord) Size 

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

func (*IscnRecord) String 

func (m *IscnRecord) String() string

func (*IscnRecord) ToJsonLd 

func (record *IscnRecord) ToJsonLd(info *IscnRecordJsonLdInfo) ([]byte, error)

func (*IscnRecord) Unmarshal 

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

func (*IscnRecord) Validate 

func (record *IscnRecord) Validate() error

func (*IscnRecord) XXX_DiscardUnknown 

func (m *IscnRecord) XXX_DiscardUnknown()

func (*IscnRecord) XXX_Marshal 

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

func (*IscnRecord) XXX_Merge 

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

func (*IscnRecord) XXX_Size 

func (m *IscnRecord) XXX_Size() int

func (*IscnRecord) XXX_Unmarshal 

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

type IscnRecordJsonLdInfo 

type IscnRecordJsonLdInfo struct {
	Id         IscnId
	Timestamp  time.Time
	ParentIpld *CID
}

type MsgChangeIscnRecordOwnership 

type MsgChangeIscnRecordOwnership struct {
	From     string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	IscnId   string `protobuf:"bytes,2,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	NewOwner string `protobuf:"bytes,3,opt,name=new_owner,json=newOwner,proto3" json:"new_owner,omitempty"`
}

func NewMsgChangeIscnRecordOwnership 

func NewMsgChangeIscnRecordOwnership(from sdk.AccAddress, iscnId IscnId, newOwner sdk.AccAddress) *MsgChangeIscnRecordOwnership

func (*MsgChangeIscnRecordOwnership) Descriptor 

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

func (*MsgChangeIscnRecordOwnership) GetFrom 

func (m *MsgChangeIscnRecordOwnership) GetFrom() string

func (*MsgChangeIscnRecordOwnership) GetIscnId 

func (m *MsgChangeIscnRecordOwnership) GetIscnId() string

func (*MsgChangeIscnRecordOwnership) GetNewOwner 

func (m *MsgChangeIscnRecordOwnership) GetNewOwner() string

func (MsgChangeIscnRecordOwnership) GetSignBytes 

func (m MsgChangeIscnRecordOwnership) GetSignBytes() []byte

func (MsgChangeIscnRecordOwnership) GetSigners 

func (m MsgChangeIscnRecordOwnership) GetSigners() []sdk.AccAddress

func (*MsgChangeIscnRecordOwnership) Marshal 

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

func (*MsgChangeIscnRecordOwnership) MarshalTo 

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

func (*MsgChangeIscnRecordOwnership) MarshalToSizedBuffer 

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

func (*MsgChangeIscnRecordOwnership) ProtoMessage 

func (*MsgChangeIscnRecordOwnership) ProtoMessage()

func (*MsgChangeIscnRecordOwnership) Reset 

func (m *MsgChangeIscnRecordOwnership) Reset()

func (MsgChangeIscnRecordOwnership) Route 

func (msg MsgChangeIscnRecordOwnership) Route() string

func (*MsgChangeIscnRecordOwnership) Size 

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

func (*MsgChangeIscnRecordOwnership) String 

func (m *MsgChangeIscnRecordOwnership) String() string

func (MsgChangeIscnRecordOwnership) Type 

func (msg MsgChangeIscnRecordOwnership) Type() string

func (*MsgChangeIscnRecordOwnership) Unmarshal 

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

func (MsgChangeIscnRecordOwnership) ValidateBasic 

func (msg MsgChangeIscnRecordOwnership) ValidateBasic() error

func (*MsgChangeIscnRecordOwnership) XXX_DiscardUnknown 

func (m *MsgChangeIscnRecordOwnership) XXX_DiscardUnknown()

func (*MsgChangeIscnRecordOwnership) XXX_Marshal 

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

func (*MsgChangeIscnRecordOwnership) XXX_Merge 

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

func (*MsgChangeIscnRecordOwnership) XXX_Size 

func (m *MsgChangeIscnRecordOwnership) XXX_Size() int

func (*MsgChangeIscnRecordOwnership) XXX_Unmarshal 

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

type MsgChangeIscnRecordOwnershipResponse 

type MsgChangeIscnRecordOwnershipResponse struct {
}

func (*MsgChangeIscnRecordOwnershipResponse) Descriptor 

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

func (*MsgChangeIscnRecordOwnershipResponse) Marshal 

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

func (*MsgChangeIscnRecordOwnershipResponse) MarshalTo 

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

func (*MsgChangeIscnRecordOwnershipResponse) MarshalToSizedBuffer 

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

func (*MsgChangeIscnRecordOwnershipResponse) ProtoMessage 

func (*MsgChangeIscnRecordOwnershipResponse) ProtoMessage()

func (*MsgChangeIscnRecordOwnershipResponse) Reset 

func (m *MsgChangeIscnRecordOwnershipResponse) Reset()

func (*MsgChangeIscnRecordOwnershipResponse) Size 

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

func (*MsgChangeIscnRecordOwnershipResponse) String 

func (m *MsgChangeIscnRecordOwnershipResponse) String() string

func (*MsgChangeIscnRecordOwnershipResponse) Unmarshal 

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

func (*MsgChangeIscnRecordOwnershipResponse) XXX_DiscardUnknown 

func (m *MsgChangeIscnRecordOwnershipResponse) XXX_DiscardUnknown()

func (*MsgChangeIscnRecordOwnershipResponse) XXX_Marshal 

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

func (*MsgChangeIscnRecordOwnershipResponse) XXX_Merge 

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

func (*MsgChangeIscnRecordOwnershipResponse) XXX_Size 

func (m *MsgChangeIscnRecordOwnershipResponse) XXX_Size() int

func (*MsgChangeIscnRecordOwnershipResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreateIscnRecord defines a method to create ISCN metadata
	CreateIscnRecord(ctx context.Context, in *MsgCreateIscnRecord, opts ...grpc.CallOption) (*MsgCreateIscnRecordResponse, error)
	// UpdateIscnRecord defines a method to update existing ISCN metadata
	UpdateIscnRecord(ctx context.Context, in *MsgUpdateIscnRecord, opts ...grpc.CallOption) (*MsgUpdateIscnRecordResponse, error)
	// ChangeIscnRecordOwnership defines a method to update the ownership of existing ISCN metadata
	ChangeIscnRecordOwnership(ctx context.Context, in *MsgChangeIscnRecordOwnership, opts ...grpc.CallOption) (*MsgChangeIscnRecordOwnershipResponse, 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 MsgCreateIscnRecord 

type MsgCreateIscnRecord struct {
	From   string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Record IscnRecord `protobuf:"bytes,2,opt,name=record,proto3" json:"record"`
}

func NewMsgCreateIscnRecord 

func NewMsgCreateIscnRecord(from sdk.AccAddress, record *IscnRecord) *MsgCreateIscnRecord

func (*MsgCreateIscnRecord) Descriptor 

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

func (*MsgCreateIscnRecord) GetFrom 

func (m *MsgCreateIscnRecord) GetFrom() string

func (*MsgCreateIscnRecord) GetRecord 

func (m *MsgCreateIscnRecord) GetRecord() IscnRecord

func (MsgCreateIscnRecord) GetSignBytes 

func (m MsgCreateIscnRecord) GetSignBytes() []byte

func (MsgCreateIscnRecord) GetSigners 

func (m MsgCreateIscnRecord) GetSigners() []sdk.AccAddress

func (*MsgCreateIscnRecord) Marshal 

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

func (*MsgCreateIscnRecord) MarshalTo 

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

func (*MsgCreateIscnRecord) MarshalToSizedBuffer 

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

func (*MsgCreateIscnRecord) ProtoMessage 

func (*MsgCreateIscnRecord) ProtoMessage()

func (*MsgCreateIscnRecord) Reset 

func (m *MsgCreateIscnRecord) Reset()

func (MsgCreateIscnRecord) Route 

func (msg MsgCreateIscnRecord) Route() string

func (*MsgCreateIscnRecord) Size 

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

func (*MsgCreateIscnRecord) String 

func (m *MsgCreateIscnRecord) String() string

func (MsgCreateIscnRecord) Type 

func (msg MsgCreateIscnRecord) Type() string

func (*MsgCreateIscnRecord) Unmarshal 

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

func (MsgCreateIscnRecord) ValidateBasic 

func (msg MsgCreateIscnRecord) ValidateBasic() error

func (*MsgCreateIscnRecord) XXX_DiscardUnknown 

func (m *MsgCreateIscnRecord) XXX_DiscardUnknown()

func (*MsgCreateIscnRecord) XXX_Marshal 

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

func (*MsgCreateIscnRecord) XXX_Merge 

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

func (*MsgCreateIscnRecord) XXX_Size 

func (m *MsgCreateIscnRecord) XXX_Size() int

func (*MsgCreateIscnRecord) XXX_Unmarshal 

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

type MsgCreateIscnRecordResponse 

type MsgCreateIscnRecordResponse struct {
	IscnId     string `protobuf:"bytes,1,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	RecordIpld string `protobuf:"bytes,2,opt,name=record_ipld,json=recordIpld,proto3" json:"record_ipld,omitempty"`
}

func (*MsgCreateIscnRecordResponse) Descriptor 

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

func (*MsgCreateIscnRecordResponse) GetIscnId 

func (m *MsgCreateIscnRecordResponse) GetIscnId() string

func (*MsgCreateIscnRecordResponse) GetRecordIpld 

func (m *MsgCreateIscnRecordResponse) GetRecordIpld() string

func (*MsgCreateIscnRecordResponse) Marshal 

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

func (*MsgCreateIscnRecordResponse) MarshalTo 

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

func (*MsgCreateIscnRecordResponse) MarshalToSizedBuffer 

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

func (*MsgCreateIscnRecordResponse) ProtoMessage 

func (*MsgCreateIscnRecordResponse) ProtoMessage()

func (*MsgCreateIscnRecordResponse) Reset 

func (m *MsgCreateIscnRecordResponse) Reset()

func (*MsgCreateIscnRecordResponse) Size 

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

func (*MsgCreateIscnRecordResponse) String 

func (m *MsgCreateIscnRecordResponse) String() string

func (*MsgCreateIscnRecordResponse) Unmarshal 

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

func (*MsgCreateIscnRecordResponse) XXX_DiscardUnknown 

func (m *MsgCreateIscnRecordResponse) XXX_DiscardUnknown()

func (*MsgCreateIscnRecordResponse) XXX_Marshal 

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

func (*MsgCreateIscnRecordResponse) XXX_Merge 

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

func (*MsgCreateIscnRecordResponse) XXX_Size 

func (m *MsgCreateIscnRecordResponse) XXX_Size() int

func (*MsgCreateIscnRecordResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateIscnRecord defines a method to create ISCN metadata
	CreateIscnRecord(context.Context, *MsgCreateIscnRecord) (*MsgCreateIscnRecordResponse, error)
	// UpdateIscnRecord defines a method to update existing ISCN metadata
	UpdateIscnRecord(context.Context, *MsgUpdateIscnRecord) (*MsgUpdateIscnRecordResponse, error)
	// ChangeIscnRecordOwnership defines a method to update the ownership of existing ISCN metadata
	ChangeIscnRecordOwnership(context.Context, *MsgChangeIscnRecordOwnership) (*MsgChangeIscnRecordOwnershipResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateIscnRecord 

type MsgUpdateIscnRecord struct {
	From   string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	IscnId string     `protobuf:"bytes,2,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	Record IscnRecord `protobuf:"bytes,3,opt,name=record,proto3" json:"record"`
}

func NewMsgUpdateIscnRecord 

func NewMsgUpdateIscnRecord(from sdk.AccAddress, iscnId IscnId, record *IscnRecord) *MsgUpdateIscnRecord

func (*MsgUpdateIscnRecord) Descriptor 

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

func (*MsgUpdateIscnRecord) GetFrom 

func (m *MsgUpdateIscnRecord) GetFrom() string

func (*MsgUpdateIscnRecord) GetIscnId 

func (m *MsgUpdateIscnRecord) GetIscnId() string

func (*MsgUpdateIscnRecord) GetRecord 

func (m *MsgUpdateIscnRecord) GetRecord() IscnRecord

func (MsgUpdateIscnRecord) GetSignBytes 

func (m MsgUpdateIscnRecord) GetSignBytes() []byte

func (MsgUpdateIscnRecord) GetSigners 

func (m MsgUpdateIscnRecord) GetSigners() []sdk.AccAddress

func (*MsgUpdateIscnRecord) Marshal 

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

func (*MsgUpdateIscnRecord) MarshalTo 

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

func (*MsgUpdateIscnRecord) MarshalToSizedBuffer 

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

func (*MsgUpdateIscnRecord) ProtoMessage 

func (*MsgUpdateIscnRecord) ProtoMessage()

func (*MsgUpdateIscnRecord) Reset 

func (m *MsgUpdateIscnRecord) Reset()

func (MsgUpdateIscnRecord) Route 

func (msg MsgUpdateIscnRecord) Route() string

func (*MsgUpdateIscnRecord) Size 

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

func (*MsgUpdateIscnRecord) String 

func (m *MsgUpdateIscnRecord) String() string

func (MsgUpdateIscnRecord) Type 

func (msg MsgUpdateIscnRecord) Type() string

func (*MsgUpdateIscnRecord) Unmarshal 

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

func (MsgUpdateIscnRecord) ValidateBasic 

func (msg MsgUpdateIscnRecord) ValidateBasic() error

func (*MsgUpdateIscnRecord) XXX_DiscardUnknown 

func (m *MsgUpdateIscnRecord) XXX_DiscardUnknown()

func (*MsgUpdateIscnRecord) XXX_Marshal 

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

func (*MsgUpdateIscnRecord) XXX_Merge 

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

func (*MsgUpdateIscnRecord) XXX_Size 

func (m *MsgUpdateIscnRecord) XXX_Size() int

func (*MsgUpdateIscnRecord) XXX_Unmarshal 

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

type MsgUpdateIscnRecordResponse 

type MsgUpdateIscnRecordResponse struct {
	IscnId     string `protobuf:"bytes,1,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	RecordIpld string `protobuf:"bytes,2,opt,name=record_ipld,json=recordIpld,proto3" json:"record_ipld,omitempty"`
}

func (*MsgUpdateIscnRecordResponse) Descriptor 

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

func (*MsgUpdateIscnRecordResponse) GetIscnId 

func (m *MsgUpdateIscnRecordResponse) GetIscnId() string

func (*MsgUpdateIscnRecordResponse) GetRecordIpld 

func (m *MsgUpdateIscnRecordResponse) GetRecordIpld() string

func (*MsgUpdateIscnRecordResponse) Marshal 

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

func (*MsgUpdateIscnRecordResponse) MarshalTo 

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

func (*MsgUpdateIscnRecordResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateIscnRecordResponse) ProtoMessage 

func (*MsgUpdateIscnRecordResponse) ProtoMessage()

func (*MsgUpdateIscnRecordResponse) Reset 

func (m *MsgUpdateIscnRecordResponse) Reset()

func (*MsgUpdateIscnRecordResponse) Size 

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

func (*MsgUpdateIscnRecordResponse) String 

func (m *MsgUpdateIscnRecordResponse) String() string

func (*MsgUpdateIscnRecordResponse) Unmarshal 

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

func (*MsgUpdateIscnRecordResponse) XXX_DiscardUnknown 

func (m *MsgUpdateIscnRecordResponse) XXX_DiscardUnknown()

func (*MsgUpdateIscnRecordResponse) XXX_Marshal 

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

func (*MsgUpdateIscnRecordResponse) XXX_Merge 

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

func (*MsgUpdateIscnRecordResponse) XXX_Size 

func (m *MsgUpdateIscnRecordResponse) XXX_Size() int

func (*MsgUpdateIscnRecordResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	RegistryName string        `protobuf:"bytes,1,opt,name=registry_name,json=registryName,proto3" json:"registry_name,omitempty"`
	FeePerByte   types.DecCoin `protobuf:"bytes,2,opt,name=fee_per_byte,json=feePerByte,proto3" json:"fee_per_byte"`
}

func DefaultParams 

func DefaultParams() Params

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (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 (p 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 QueryClient 

type QueryClient interface {
	RecordsById(ctx context.Context, in *QueryRecordsByIdRequest, opts ...grpc.CallOption) (*QueryRecordsByIdResponse, error)
	RecordsByFingerprint(ctx context.Context, in *QueryRecordsByFingerprintRequest, opts ...grpc.CallOption) (*QueryRecordsByFingerprintResponse, error)
	RecordsByOwner(ctx context.Context, in *QueryRecordsByOwnerRequest, opts ...grpc.CallOption) (*QueryRecordsByOwnerResponse, error)
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	GetCid(ctx context.Context, in *QueryGetCidRequest, opts ...grpc.CallOption) (*QueryGetCidResponse, error)
	HasCid(ctx context.Context, in *QueryHasCidRequest, opts ...grpc.CallOption) (*QueryHasCidResponse, error)
	GetCidSize(ctx context.Context, in *QueryGetCidSizeRequest, opts ...grpc.CallOption) (*QueryGetCidSizeResponse, 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 QueryGetCidRequest 

type QueryGetCidRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
}

func (*QueryGetCidRequest) Descriptor 

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

func (*QueryGetCidRequest) GetCid 

func (m *QueryGetCidRequest) GetCid() string

func (*QueryGetCidRequest) Marshal 

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

func (*QueryGetCidRequest) MarshalTo 

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

func (*QueryGetCidRequest) MarshalToSizedBuffer 

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

func (*QueryGetCidRequest) ProtoMessage 

func (*QueryGetCidRequest) ProtoMessage()

func (*QueryGetCidRequest) Reset 

func (m *QueryGetCidRequest) Reset()

func (*QueryGetCidRequest) Size 

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

func (*QueryGetCidRequest) String 

func (m *QueryGetCidRequest) String() string

func (*QueryGetCidRequest) Unmarshal 

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

func (*QueryGetCidRequest) XXX_DiscardUnknown 

func (m *QueryGetCidRequest) XXX_DiscardUnknown()

func (*QueryGetCidRequest) XXX_Marshal 

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

func (*QueryGetCidRequest) XXX_Merge 

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

func (*QueryGetCidRequest) XXX_Size 

func (m *QueryGetCidRequest) XXX_Size() int

func (*QueryGetCidRequest) XXX_Unmarshal 

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

type QueryGetCidResponse 

type QueryGetCidResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*QueryGetCidResponse) Descriptor 

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

func (*QueryGetCidResponse) GetData 

func (m *QueryGetCidResponse) GetData() []byte

func (*QueryGetCidResponse) Marshal 

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

func (*QueryGetCidResponse) MarshalTo 

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

func (*QueryGetCidResponse) MarshalToSizedBuffer 

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

func (*QueryGetCidResponse) ProtoMessage 

func (*QueryGetCidResponse) ProtoMessage()

func (*QueryGetCidResponse) Reset 

func (m *QueryGetCidResponse) Reset()

func (*QueryGetCidResponse) Size 

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

func (*QueryGetCidResponse) String 

func (m *QueryGetCidResponse) String() string

func (*QueryGetCidResponse) Unmarshal 

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

func (*QueryGetCidResponse) XXX_DiscardUnknown 

func (m *QueryGetCidResponse) XXX_DiscardUnknown()

func (*QueryGetCidResponse) XXX_Marshal 

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

func (*QueryGetCidResponse) XXX_Merge 

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

func (*QueryGetCidResponse) XXX_Size 

func (m *QueryGetCidResponse) XXX_Size() int

func (*QueryGetCidResponse) XXX_Unmarshal 

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

type QueryGetCidSizeRequest 

type QueryGetCidSizeRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
}

func (*QueryGetCidSizeRequest) Descriptor 

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

func (*QueryGetCidSizeRequest) GetCid 

func (m *QueryGetCidSizeRequest) GetCid() string

func (*QueryGetCidSizeRequest) Marshal 

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

func (*QueryGetCidSizeRequest) MarshalTo 

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

func (*QueryGetCidSizeRequest) MarshalToSizedBuffer 

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

func (*QueryGetCidSizeRequest) ProtoMessage 

func (*QueryGetCidSizeRequest) ProtoMessage()

func (*QueryGetCidSizeRequest) Reset 

func (m *QueryGetCidSizeRequest) Reset()

func (*QueryGetCidSizeRequest) Size 

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

func (*QueryGetCidSizeRequest) String 

func (m *QueryGetCidSizeRequest) String() string

func (*QueryGetCidSizeRequest) Unmarshal 

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

func (*QueryGetCidSizeRequest) XXX_DiscardUnknown 

func (m *QueryGetCidSizeRequest) XXX_DiscardUnknown()

func (*QueryGetCidSizeRequest) XXX_Marshal 

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

func (*QueryGetCidSizeRequest) XXX_Merge 

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

func (*QueryGetCidSizeRequest) XXX_Size 

func (m *QueryGetCidSizeRequest) XXX_Size() int

func (*QueryGetCidSizeRequest) XXX_Unmarshal 

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

type QueryGetCidSizeResponse 

type QueryGetCidSizeResponse struct {
	Size_ uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
}

func (*QueryGetCidSizeResponse) Descriptor 

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

func (*QueryGetCidSizeResponse) GetSize_ 

func (m *QueryGetCidSizeResponse) GetSize_() uint64

func (*QueryGetCidSizeResponse) Marshal 

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

func (*QueryGetCidSizeResponse) MarshalTo 

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

func (*QueryGetCidSizeResponse) MarshalToSizedBuffer 

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

func (*QueryGetCidSizeResponse) ProtoMessage 

func (*QueryGetCidSizeResponse) ProtoMessage()

func (*QueryGetCidSizeResponse) Reset 

func (m *QueryGetCidSizeResponse) Reset()

func (*QueryGetCidSizeResponse) Size 

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

func (*QueryGetCidSizeResponse) String 

func (m *QueryGetCidSizeResponse) String() string

func (*QueryGetCidSizeResponse) Unmarshal 

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

func (*QueryGetCidSizeResponse) XXX_DiscardUnknown 

func (m *QueryGetCidSizeResponse) XXX_DiscardUnknown()

func (*QueryGetCidSizeResponse) XXX_Marshal 

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

func (*QueryGetCidSizeResponse) XXX_Merge 

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

func (*QueryGetCidSizeResponse) XXX_Size 

func (m *QueryGetCidSizeResponse) XXX_Size() int

func (*QueryGetCidSizeResponse) XXX_Unmarshal 

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

type QueryHasCidRequest 

type QueryHasCidRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
}

func (*QueryHasCidRequest) Descriptor 

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

func (*QueryHasCidRequest) GetCid 

func (m *QueryHasCidRequest) GetCid() string

func (*QueryHasCidRequest) Marshal 

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

func (*QueryHasCidRequest) MarshalTo 

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

func (*QueryHasCidRequest) MarshalToSizedBuffer 

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

func (*QueryHasCidRequest) ProtoMessage 

func (*QueryHasCidRequest) ProtoMessage()

func (*QueryHasCidRequest) Reset 

func (m *QueryHasCidRequest) Reset()

func (*QueryHasCidRequest) Size 

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

func (*QueryHasCidRequest) String 

func (m *QueryHasCidRequest) String() string

func (*QueryHasCidRequest) Unmarshal 

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

func (*QueryHasCidRequest) XXX_DiscardUnknown 

func (m *QueryHasCidRequest) XXX_DiscardUnknown()

func (*QueryHasCidRequest) XXX_Marshal 

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

func (*QueryHasCidRequest) XXX_Merge 

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

func (*QueryHasCidRequest) XXX_Size 

func (m *QueryHasCidRequest) XXX_Size() int

func (*QueryHasCidRequest) XXX_Unmarshal 

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

type QueryHasCidResponse 

type QueryHasCidResponse struct {
	Exist bool `protobuf:"varint,1,opt,name=exist,proto3" json:"exist,omitempty"`
}

func (*QueryHasCidResponse) Descriptor 

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

func (*QueryHasCidResponse) GetExist 

func (m *QueryHasCidResponse) GetExist() bool

func (*QueryHasCidResponse) Marshal 

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

func (*QueryHasCidResponse) MarshalTo 

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

func (*QueryHasCidResponse) MarshalToSizedBuffer 

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

func (*QueryHasCidResponse) ProtoMessage 

func (*QueryHasCidResponse) ProtoMessage()

func (*QueryHasCidResponse) Reset 

func (m *QueryHasCidResponse) Reset()

func (*QueryHasCidResponse) Size 

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

func (*QueryHasCidResponse) String 

func (m *QueryHasCidResponse) String() string

func (*QueryHasCidResponse) Unmarshal 

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

func (*QueryHasCidResponse) XXX_DiscardUnknown 

func (m *QueryHasCidResponse) XXX_DiscardUnknown()

func (*QueryHasCidResponse) XXX_Marshal 

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

func (*QueryHasCidResponse) XXX_Merge 

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

func (*QueryHasCidResponse) XXX_Size 

func (m *QueryHasCidResponse) XXX_Size() int

func (*QueryHasCidResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

func NewQueryParamsRequest 

func NewQueryParamsRequest() *QueryParamsRequest

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryRecordsByFingerprintRequest 

type QueryRecordsByFingerprintRequest struct {
	// The fingerprint of the record(s) to be queried.
	// All fingerprints in records should be URIs.
	Fingerprint string `protobuf:"bytes,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// For pagination.
	// For the first query, fill in 0 or just omit this field.
	// For continuous queries, fill in the `next_sequence` field in the previous response.
	FromSequence uint64 `protobuf:"varint,2,opt,name=from_sequence,json=fromSequence,proto3" json:"from_sequence,omitempty"`
}

func NewQueryRecordsByFingerprintRequest 

func NewQueryRecordsByFingerprintRequest(fingerprint string, fromSeq uint64) *QueryRecordsByFingerprintRequest

func (*QueryRecordsByFingerprintRequest) Descriptor 

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

func (*QueryRecordsByFingerprintRequest) GetFingerprint 

func (m *QueryRecordsByFingerprintRequest) GetFingerprint() string

func (*QueryRecordsByFingerprintRequest) GetFromSequence 

func (m *QueryRecordsByFingerprintRequest) GetFromSequence() uint64

func (*QueryRecordsByFingerprintRequest) Marshal 

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

func (*QueryRecordsByFingerprintRequest) MarshalTo 

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

func (*QueryRecordsByFingerprintRequest) MarshalToSizedBuffer 

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

func (*QueryRecordsByFingerprintRequest) ProtoMessage 

func (*QueryRecordsByFingerprintRequest) ProtoMessage()

func (*QueryRecordsByFingerprintRequest) Reset 

func (m *QueryRecordsByFingerprintRequest) Reset()

func (*QueryRecordsByFingerprintRequest) Size 

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

func (*QueryRecordsByFingerprintRequest) String 

func (m *QueryRecordsByFingerprintRequest) String() string

func (*QueryRecordsByFingerprintRequest) Unmarshal 

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

func (*QueryRecordsByFingerprintRequest) XXX_DiscardUnknown 

func (m *QueryRecordsByFingerprintRequest) XXX_DiscardUnknown()

func (*QueryRecordsByFingerprintRequest) XXX_Marshal 

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

func (*QueryRecordsByFingerprintRequest) XXX_Merge 

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

func (*QueryRecordsByFingerprintRequest) XXX_Size 

func (m *QueryRecordsByFingerprintRequest) XXX_Size() int

func (*QueryRecordsByFingerprintRequest) XXX_Unmarshal 

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

type QueryRecordsByFingerprintResponse 

type QueryRecordsByFingerprintResponse struct {
	Records []QueryResponseRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records"`
	// For pagination.
	NextSequence uint64 `protobuf:"varint,2,opt,name=next_sequence,json=nextSequence,proto3" json:"next_sequence,omitempty"`
}

func (*QueryRecordsByFingerprintResponse) Descriptor 

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

func (*QueryRecordsByFingerprintResponse) GetNextSequence 

func (m *QueryRecordsByFingerprintResponse) GetNextSequence() uint64

func (*QueryRecordsByFingerprintResponse) GetRecords 

func (m *QueryRecordsByFingerprintResponse) GetRecords() []QueryResponseRecord

func (*QueryRecordsByFingerprintResponse) Marshal 

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

func (*QueryRecordsByFingerprintResponse) MarshalTo 

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

func (*QueryRecordsByFingerprintResponse) MarshalToSizedBuffer 

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

func (*QueryRecordsByFingerprintResponse) ProtoMessage 

func (*QueryRecordsByFingerprintResponse) ProtoMessage()

func (*QueryRecordsByFingerprintResponse) Reset 

func (m *QueryRecordsByFingerprintResponse) Reset()

func (*QueryRecordsByFingerprintResponse) Size 

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

func (*QueryRecordsByFingerprintResponse) String 

func (m *QueryRecordsByFingerprintResponse) String() string

func (*QueryRecordsByFingerprintResponse) Unmarshal 

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

func (*QueryRecordsByFingerprintResponse) XXX_DiscardUnknown 

func (m *QueryRecordsByFingerprintResponse) XXX_DiscardUnknown()

func (*QueryRecordsByFingerprintResponse) XXX_Marshal 

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

func (*QueryRecordsByFingerprintResponse) XXX_Merge 

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

func (*QueryRecordsByFingerprintResponse) XXX_Size 

func (m *QueryRecordsByFingerprintResponse) XXX_Size() int

func (*QueryRecordsByFingerprintResponse) XXX_Unmarshal 

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

type QueryRecordsByIdRequest 

type QueryRecordsByIdRequest struct {
	// The ISCN ID of the record(s) to be queried.
	// Format: iscn://REGISTRY_NAME/CONTENT_ID[/VERSION]
	// If version part omitted, version is default to 0.
	// if non-zero version exists, then from_version and to_version are ignored.
	IscnId string `protobuf:"bytes,1,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id,omitempty"`
	// The initial version in the resulting records.
	// If omitted or is 0, then it will be interpreted as the latest version.
	FromVersion uint64 `protobuf:"varint,2,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// The final version in the resulting records.
	// If omitted or is 0, then it will be interpreted as the latest version.
	ToVersion uint64 `protobuf:"varint,3,opt,name=to_version,json=toVersion,proto3" json:"to_version,omitempty"`
}

func NewQueryRecordsByIdRequest 

func NewQueryRecordsByIdRequest(iscnId IscnId, fromVersion, toVersion uint64) *QueryRecordsByIdRequest

func (*QueryRecordsByIdRequest) Descriptor 

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

func (*QueryRecordsByIdRequest) GetFromVersion 

func (m *QueryRecordsByIdRequest) GetFromVersion() uint64

func (*QueryRecordsByIdRequest) GetIscnId 

func (m *QueryRecordsByIdRequest) GetIscnId() string

func (*QueryRecordsByIdRequest) GetToVersion 

func (m *QueryRecordsByIdRequest) GetToVersion() uint64

func (*QueryRecordsByIdRequest) Marshal 

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

func (*QueryRecordsByIdRequest) MarshalTo 

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

func (*QueryRecordsByIdRequest) MarshalToSizedBuffer 

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

func (*QueryRecordsByIdRequest) ProtoMessage 

func (*QueryRecordsByIdRequest) ProtoMessage()

func (*QueryRecordsByIdRequest) Reset 

func (m *QueryRecordsByIdRequest) Reset()

func (*QueryRecordsByIdRequest) Size 

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

func (*QueryRecordsByIdRequest) String 

func (m *QueryRecordsByIdRequest) String() string

func (*QueryRecordsByIdRequest) Unmarshal 

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

func (*QueryRecordsByIdRequest) XXX_DiscardUnknown 

func (m *QueryRecordsByIdRequest) XXX_DiscardUnknown()

func (*QueryRecordsByIdRequest) XXX_Marshal 

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

func (*QueryRecordsByIdRequest) XXX_Merge 

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

func (*QueryRecordsByIdRequest) XXX_Size 

func (m *QueryRecordsByIdRequest) XXX_Size() int

func (*QueryRecordsByIdRequest) XXX_Unmarshal 

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

type QueryRecordsByIdResponse 

type QueryRecordsByIdResponse struct {
	Owner         string                `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	LatestVersion uint64                `protobuf:"varint,2,opt,name=latest_version,json=latestVersion,proto3" json:"latest_version,omitempty"`
	Records       []QueryResponseRecord `protobuf:"bytes,3,rep,name=records,proto3" json:"records"`
}

func (*QueryRecordsByIdResponse) Descriptor 

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

func (*QueryRecordsByIdResponse) GetLatestVersion 

func (m *QueryRecordsByIdResponse) GetLatestVersion() uint64

func (*QueryRecordsByIdResponse) GetOwner 

func (m *QueryRecordsByIdResponse) GetOwner() string

func (*QueryRecordsByIdResponse) GetRecords 

func (m *QueryRecordsByIdResponse) GetRecords() []QueryResponseRecord

func (*QueryRecordsByIdResponse) Marshal 

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

func (*QueryRecordsByIdResponse) MarshalTo 

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

func (*QueryRecordsByIdResponse) MarshalToSizedBuffer 

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

func (*QueryRecordsByIdResponse) ProtoMessage 

func (*QueryRecordsByIdResponse) ProtoMessage()

func (*QueryRecordsByIdResponse) Reset 

func (m *QueryRecordsByIdResponse) Reset()

func (*QueryRecordsByIdResponse) Size 

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

func (*QueryRecordsByIdResponse) String 

func (m *QueryRecordsByIdResponse) String() string

func (*QueryRecordsByIdResponse) Unmarshal 

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

func (*QueryRecordsByIdResponse) XXX_DiscardUnknown 

func (m *QueryRecordsByIdResponse) XXX_DiscardUnknown()

func (*QueryRecordsByIdResponse) XXX_Marshal 

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

func (*QueryRecordsByIdResponse) XXX_Merge 

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

func (*QueryRecordsByIdResponse) XXX_Size 

func (m *QueryRecordsByIdResponse) XXX_Size() int

func (*QueryRecordsByIdResponse) XXX_Unmarshal 

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

type QueryRecordsByOwnerRequest 

type QueryRecordsByOwnerRequest struct {
	// Owner address of the record(s) to be queried.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// For pagination.
	// For the first query, fill in 0 or just omit this field.
	// For continuous queries, fill in the `next_sequence` field in the previous response.
	FromSequence uint64 `protobuf:"varint,2,opt,name=from_sequence,json=fromSequence,proto3" json:"from_sequence,omitempty"`
}

func NewQueryRecordsByOwnerRequest 

func NewQueryRecordsByOwnerRequest(owner sdk.AccAddress, fromSeq uint64) *QueryRecordsByOwnerRequest

func (*QueryRecordsByOwnerRequest) Descriptor 

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

func (*QueryRecordsByOwnerRequest) GetFromSequence 

func (m *QueryRecordsByOwnerRequest) GetFromSequence() uint64

func (*QueryRecordsByOwnerRequest) GetOwner 

func (m *QueryRecordsByOwnerRequest) GetOwner() string

func (*QueryRecordsByOwnerRequest) Marshal 

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

func (*QueryRecordsByOwnerRequest) MarshalTo 

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

func (*QueryRecordsByOwnerRequest) MarshalToSizedBuffer 

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

func (*QueryRecordsByOwnerRequest) ProtoMessage 

func (*QueryRecordsByOwnerRequest) ProtoMessage()

func (*QueryRecordsByOwnerRequest) Reset 

func (m *QueryRecordsByOwnerRequest) Reset()

func (*QueryRecordsByOwnerRequest) Size 

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

func (*QueryRecordsByOwnerRequest) String 

func (m *QueryRecordsByOwnerRequest) String() string

func (*QueryRecordsByOwnerRequest) Unmarshal 

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

func (*QueryRecordsByOwnerRequest) XXX_DiscardUnknown 

func (m *QueryRecordsByOwnerRequest) XXX_DiscardUnknown()

func (*QueryRecordsByOwnerRequest) XXX_Marshal 

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

func (*QueryRecordsByOwnerRequest) XXX_Merge 

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

func (*QueryRecordsByOwnerRequest) XXX_Size 

func (m *QueryRecordsByOwnerRequest) XXX_Size() int

func (*QueryRecordsByOwnerRequest) XXX_Unmarshal 

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

type QueryRecordsByOwnerResponse 

type QueryRecordsByOwnerResponse struct {
	Records      []QueryResponseRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records"`
	NextSequence uint64                `protobuf:"varint,2,opt,name=next_sequence,json=nextSequence,proto3" json:"next_sequence,omitempty"`
}

func (*QueryRecordsByOwnerResponse) Descriptor 

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

func (*QueryRecordsByOwnerResponse) GetNextSequence 

func (m *QueryRecordsByOwnerResponse) GetNextSequence() uint64

func (*QueryRecordsByOwnerResponse) GetRecords 

func (m *QueryRecordsByOwnerResponse) GetRecords() []QueryResponseRecord

func (*QueryRecordsByOwnerResponse) Marshal 

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

func (*QueryRecordsByOwnerResponse) MarshalTo 

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

func (*QueryRecordsByOwnerResponse) MarshalToSizedBuffer 

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

func (*QueryRecordsByOwnerResponse) ProtoMessage 

func (*QueryRecordsByOwnerResponse) ProtoMessage()

func (*QueryRecordsByOwnerResponse) Reset 

func (m *QueryRecordsByOwnerResponse) Reset()

func (*QueryRecordsByOwnerResponse) Size 

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

func (*QueryRecordsByOwnerResponse) String 

func (m *QueryRecordsByOwnerResponse) String() string

func (*QueryRecordsByOwnerResponse) Unmarshal 

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

func (*QueryRecordsByOwnerResponse) XXX_DiscardUnknown 

func (m *QueryRecordsByOwnerResponse) XXX_DiscardUnknown()

func (*QueryRecordsByOwnerResponse) XXX_Marshal 

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

func (*QueryRecordsByOwnerResponse) XXX_Merge 

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

func (*QueryRecordsByOwnerResponse) XXX_Size 

func (m *QueryRecordsByOwnerResponse) XXX_Size() int

func (*QueryRecordsByOwnerResponse) XXX_Unmarshal 

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

type QueryResponseRecord 

type QueryResponseRecord struct {
	Ipld string    `protobuf:"bytes,1,opt,name=ipld,proto3" json:"ipld,omitempty"`
	Data IscnInput `protobuf:"bytes,2,opt,name=data,proto3,customtype=IscnInput" json:"data"`
}

func (*QueryResponseRecord) Descriptor 

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

func (*QueryResponseRecord) GetIpld 

func (m *QueryResponseRecord) GetIpld() string

func (*QueryResponseRecord) Marshal 

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

func (*QueryResponseRecord) MarshalTo 

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

func (*QueryResponseRecord) MarshalToSizedBuffer 

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

func (*QueryResponseRecord) ProtoMessage 

func (*QueryResponseRecord) ProtoMessage()

func (*QueryResponseRecord) Reset 

func (m *QueryResponseRecord) Reset()

func (*QueryResponseRecord) Size 

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

func (*QueryResponseRecord) String 

func (m *QueryResponseRecord) String() string

func (*QueryResponseRecord) Unmarshal 

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

func (*QueryResponseRecord) XXX_DiscardUnknown 

func (m *QueryResponseRecord) XXX_DiscardUnknown()

func (*QueryResponseRecord) XXX_Marshal 

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

func (*QueryResponseRecord) XXX_Merge 

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

func (*QueryResponseRecord) XXX_Size 

func (m *QueryResponseRecord) XXX_Size() int

func (*QueryResponseRecord) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	RecordsById(context.Context, *QueryRecordsByIdRequest) (*QueryRecordsByIdResponse, error)
	RecordsByFingerprint(context.Context, *QueryRecordsByFingerprintRequest) (*QueryRecordsByFingerprintResponse, error)
	RecordsByOwner(context.Context, *QueryRecordsByOwnerRequest) (*QueryRecordsByOwnerResponse, error)
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	GetCid(context.Context, *QueryGetCidRequest) (*QueryGetCidResponse, error)
	HasCid(context.Context, *QueryHasCidRequest) (*QueryHasCidResponse, error)
	GetCidSize(context.Context, *QueryGetCidSizeRequest) (*QueryGetCidSizeResponse, error)
}

QueryServer is the server API for Query service.

type StoreRecord 

type StoreRecord struct {
	IscnId   IscnId    `protobuf:"bytes,1,opt,name=iscn_id,json=iscnId,proto3" json:"iscn_id"`
	CidBytes []byte    `protobuf:"bytes,2,opt,name=cid_bytes,json=cidBytes,proto3" json:"cid_bytes,omitempty"`
	Data     IscnInput `protobuf:"bytes,3,opt,name=data,proto3,customtype=IscnInput" json:"data"`
}

func (StoreRecord) Cid 

func (record StoreRecord) Cid() CID

func (*StoreRecord) Descriptor 

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

func (*StoreRecord) GetCidBytes 

func (m *StoreRecord) GetCidBytes() []byte

func (*StoreRecord) GetIscnId 

func (m *StoreRecord) GetIscnId() IscnId

func (*StoreRecord) Marshal 

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

func (*StoreRecord) MarshalTo 

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

func (*StoreRecord) MarshalToSizedBuffer 

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

func (*StoreRecord) ProtoMessage 

func (*StoreRecord) ProtoMessage()

func (*StoreRecord) Reset 

func (m *StoreRecord) Reset()

func (*StoreRecord) Size 

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

func (*StoreRecord) String 

func (m *StoreRecord) String() string

func (*StoreRecord) Unmarshal 

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

func (*StoreRecord) XXX_DiscardUnknown 

func (m *StoreRecord) XXX_DiscardUnknown()

func (*StoreRecord) XXX_Marshal 

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

func (*StoreRecord) XXX_Merge 

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

func (*StoreRecord) XXX_Size 

func (m *StoreRecord) XXX_Size() int

func (*StoreRecord) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ChangeIscnRecordOwnership 

func (*UnimplementedMsgServer) ChangeIscnRecordOwnership(ctx context.Context, req *MsgChangeIscnRecordOwnership) (*MsgChangeIscnRecordOwnershipResponse, error)

func (*UnimplementedMsgServer) CreateIscnRecord 

func (*UnimplementedMsgServer) CreateIscnRecord(ctx context.Context, req *MsgCreateIscnRecord) (*MsgCreateIscnRecordResponse, error)

func (*UnimplementedMsgServer) UpdateIscnRecord 

func (*UnimplementedMsgServer) UpdateIscnRecord(ctx context.Context, req *MsgUpdateIscnRecord) (*MsgUpdateIscnRecordResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetCid 

func (*UnimplementedQueryServer) GetCid(ctx context.Context, req *QueryGetCidRequest) (*QueryGetCidResponse, error)

func (*UnimplementedQueryServer) GetCidSize 

func (*UnimplementedQueryServer) GetCidSize(ctx context.Context, req *QueryGetCidSizeRequest) (*QueryGetCidSizeResponse, error)

func (*UnimplementedQueryServer) HasCid 

func (*UnimplementedQueryServer) HasCid(ctx context.Context, req *QueryHasCidRequest) (*QueryHasCidResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) RecordsByFingerprint 

func (*UnimplementedQueryServer) RecordsByFingerprint(ctx context.Context, req *QueryRecordsByFingerprintRequest) (*QueryRecordsByFingerprintResponse, error)

func (*UnimplementedQueryServer) RecordsById 

func (*UnimplementedQueryServer) RecordsById(ctx context.Context, req *QueryRecordsByIdRequest) (*QueryRecordsByIdResponse, error)

func (*UnimplementedQueryServer) RecordsByOwner 

func (*UnimplementedQueryServer) RecordsByOwner(ctx context.Context, req *QueryRecordsByOwnerRequest) (*QueryRecordsByOwnerResponse, 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.