datav1

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Nov 22, 2022 License: Apache-2.0 Imports: 19 Imported by: 3

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source
var (
	DigestAlgorithm_name = map[int32]string{
		0: "DIGEST_ALGORITHM_UNSPECIFIED",
		1: "DIGEST_ALGORITHM_BLAKE2B_256",
	}
	DigestAlgorithm_value = map[string]int32{
		"DIGEST_ALGORITHM_UNSPECIFIED": 0,
		"DIGEST_ALGORITHM_BLAKE2B_256": 1,
	}
)

Enum value maps for DigestAlgorithm.

View Source
var (
	RawMediaType_name = map[int32]string{
		0:  "RAW_MEDIA_TYPE_UNSPECIFIED",
		1:  "RAW_MEDIA_TYPE_TEXT_PLAIN",
		2:  "RAW_MEDIA_TYPE_JSON",
		3:  "RAW_MEDIA_TYPE_CSV",
		4:  "RAW_MEDIA_TYPE_XML",
		5:  "RAW_MEDIA_TYPE_PDF",
		16: "RAW_MEDIA_TYPE_TIFF",
		17: "RAW_MEDIA_TYPE_JPG",
		18: "RAW_MEDIA_TYPE_PNG",
		19: "RAW_MEDIA_TYPE_SVG",
		20: "RAW_MEDIA_TYPE_WEBP",
		21: "RAW_MEDIA_TYPE_AVIF",
		22: "RAW_MEDIA_TYPE_GIF",
		23: "RAW_MEDIA_TYPE_APNG",
		32: "RAW_MEDIA_TYPE_MPEG",
		33: "RAW_MEDIA_TYPE_MP4",
		34: "RAW_MEDIA_TYPE_WEBM",
		35: "RAW_MEDIA_TYPE_OGG",
	}
	RawMediaType_value = map[string]int32{
		"RAW_MEDIA_TYPE_UNSPECIFIED": 0,
		"RAW_MEDIA_TYPE_TEXT_PLAIN":  1,
		"RAW_MEDIA_TYPE_JSON":        2,
		"RAW_MEDIA_TYPE_CSV":         3,
		"RAW_MEDIA_TYPE_XML":         4,
		"RAW_MEDIA_TYPE_PDF":         5,
		"RAW_MEDIA_TYPE_TIFF":        16,
		"RAW_MEDIA_TYPE_JPG":         17,
		"RAW_MEDIA_TYPE_PNG":         18,
		"RAW_MEDIA_TYPE_SVG":         19,
		"RAW_MEDIA_TYPE_WEBP":        20,
		"RAW_MEDIA_TYPE_AVIF":        21,
		"RAW_MEDIA_TYPE_GIF":         22,
		"RAW_MEDIA_TYPE_APNG":        23,
		"RAW_MEDIA_TYPE_MPEG":        32,
		"RAW_MEDIA_TYPE_MP4":         33,
		"RAW_MEDIA_TYPE_WEBM":        34,
		"RAW_MEDIA_TYPE_OGG":         35,
	}
)

Enum value maps for RawMediaType.

View Source
var (
	GraphCanonicalizationAlgorithm_name = map[int32]string{
		0: "GRAPH_CANONICALIZATION_ALGORITHM_UNSPECIFIED",
		1: "GRAPH_CANONICALIZATION_ALGORITHM_URDNA2015",
	}
	GraphCanonicalizationAlgorithm_value = map[string]int32{
		"GRAPH_CANONICALIZATION_ALGORITHM_UNSPECIFIED": 0,
		"GRAPH_CANONICALIZATION_ALGORITHM_URDNA2015":   1,
	}
)

Enum value maps for GraphCanonicalizationAlgorithm.

View Source
var (
	GraphMerkleTree_name = map[int32]string{
		0: "GRAPH_MERKLE_TREE_NONE_UNSPECIFIED",
	}
	GraphMerkleTree_value = map[string]int32{
		"GRAPH_MERKLE_TREE_NONE_UNSPECIFIED": 0,
	}
)

Enum value maps for GraphMerkleTree.

View Source
var File_regen_data_v1_events_proto protoreflect.FileDescriptor
View Source
var File_regen_data_v1_query_proto protoreflect.FileDescriptor
View Source
var File_regen_data_v1_state_proto protoreflect.FileDescriptor
View Source
var File_regen_data_v1_tx_proto protoreflect.FileDescriptor
View Source
var File_regen_data_v1_types_proto protoreflect.FileDescriptor
View Source
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "regen.data.v1.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Anchor",
			Handler:    _Msg_Anchor_Handler,
		},
		{
			MethodName: "Attest",
			Handler:    _Msg_Attest_Handler,
		},
		{
			MethodName: "DefineResolver",
			Handler:    _Msg_DefineResolver_Handler,
		},
		{
			MethodName: "RegisterResolver",
			Handler:    _Msg_RegisterResolver_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "regen/data/v1/tx.proto",
}

Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "regen.data.v1.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AnchorByIRI",
			Handler:    _Query_AnchorByIRI_Handler,
		},
		{
			MethodName: "AnchorByHash",
			Handler:    _Query_AnchorByHash_Handler,
		},
		{
			MethodName: "AttestationsByAttestor",
			Handler:    _Query_AttestationsByAttestor_Handler,
		},
		{
			MethodName: "AttestationsByIRI",
			Handler:    _Query_AttestationsByIRI_Handler,
		},
		{
			MethodName: "AttestationsByHash",
			Handler:    _Query_AttestationsByHash_Handler,
		},
		{
			MethodName: "Resolver",
			Handler:    _Query_Resolver_Handler,
		},
		{
			MethodName: "ResolversByIRI",
			Handler:    _Query_ResolversByIRI_Handler,
		},
		{
			MethodName: "ResolversByHash",
			Handler:    _Query_ResolversByHash_Handler,
		},
		{
			MethodName: "ResolversByURL",
			Handler:    _Query_ResolversByURL_Handler,
		},
		{
			MethodName: "ConvertIRIToHash",
			Handler:    _Query_ConvertIRIToHash_Handler,
		},
		{
			MethodName: "ConvertHashToIRI",
			Handler:    _Query_ConvertHashToIRI_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "regen/data/v1/query.proto",
}

Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMsgServer

func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)

func RegisterQueryServer

func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

Types

type AnchorInfo

type AnchorInfo struct {

	// iri is the IRI of the anchored data.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// content_hash is the ContentHash of the anchored data.
	ContentHash *ContentHash `protobuf:"bytes,2,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// timestamp is the time at which the data was anchored.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

AnchorInfo is the information for a data anchor.

func (*AnchorInfo) Descriptor deprecated

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

Deprecated: Use AnchorInfo.ProtoReflect.Descriptor instead.

func (*AnchorInfo) GetContentHash

func (x *AnchorInfo) GetContentHash() *ContentHash

func (*AnchorInfo) GetIri

func (x *AnchorInfo) GetIri() string

func (*AnchorInfo) GetTimestamp

func (x *AnchorInfo) GetTimestamp() *timestamppb.Timestamp

func (*AnchorInfo) ProtoMessage

func (*AnchorInfo) ProtoMessage()

func (*AnchorInfo) ProtoReflect

func (x *AnchorInfo) ProtoReflect() protoreflect.Message

func (*AnchorInfo) Reset

func (x *AnchorInfo) Reset()

func (*AnchorInfo) String

func (x *AnchorInfo) String() string

type AttestationInfo

type AttestationInfo struct {

	// iri is the IRI of the anchored data.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// attestor is the address of the account that attested to the anchored data.
	Attestor string `protobuf:"bytes,2,opt,name=attestor,proto3" json:"attestor,omitempty"`
	// timestamp is the time at which the data was attested to.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

AttestationInfo is the information for an attestation.

func (*AttestationInfo) Descriptor deprecated

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

Deprecated: Use AttestationInfo.ProtoReflect.Descriptor instead.

func (*AttestationInfo) GetAttestor

func (x *AttestationInfo) GetAttestor() string

func (*AttestationInfo) GetIri

func (x *AttestationInfo) GetIri() string

func (*AttestationInfo) GetTimestamp

func (x *AttestationInfo) GetTimestamp() *timestamppb.Timestamp

func (*AttestationInfo) ProtoMessage

func (*AttestationInfo) ProtoMessage()

func (*AttestationInfo) ProtoReflect

func (x *AttestationInfo) ProtoReflect() protoreflect.Message

func (*AttestationInfo) Reset

func (x *AttestationInfo) Reset()

func (*AttestationInfo) String

func (x *AttestationInfo) String() string

type ContentHash

type ContentHash struct {

	// Raw specifies "raw" data which does not specify a deterministic, canonical
	// encoding. Users of these hashes MUST maintain a copy of the hashed data
	// which is preserved bit by bit. All other content encodings specify a
	// deterministic, canonical encoding allowing implementations to choose from a
	// variety of alternative formats for transport and encoding while maintaining
	// the guarantee that the canonical hash will not change. The media type for
	// "raw" data is defined by the MediaType enum.
	Raw *ContentHash_Raw `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// Graph specifies graph data that conforms to the RDF data model.
	// The canonicalization algorithm used for an RDF graph is specified by
	// GraphCanonicalizationAlgorithm.
	Graph *ContentHash_Graph `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	// contains filtered or unexported fields
}

ContentHash specifies a hash-based content identifier for a piece of data.

func (*ContentHash) Descriptor deprecated

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

Deprecated: Use ContentHash.ProtoReflect.Descriptor instead.

func (*ContentHash) GetGraph

func (x *ContentHash) GetGraph() *ContentHash_Graph

func (*ContentHash) GetRaw

func (x *ContentHash) GetRaw() *ContentHash_Raw

func (*ContentHash) ProtoMessage

func (*ContentHash) ProtoMessage()

func (*ContentHash) ProtoReflect

func (x *ContentHash) ProtoReflect() protoreflect.Message

func (*ContentHash) Reset

func (x *ContentHash) Reset()

func (*ContentHash) String

func (x *ContentHash) String() string

type ContentHash_Graph

type ContentHash_Graph struct {

	// hash represents the hash of the data based on the specified
	// digest_algorithm.
	Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// digest_algorithm represents the hash digest algorithm.
	DigestAlgorithm DigestAlgorithm `` /* 142-byte string literal not displayed */
	// graph_canonicalization_algorithm represents the RDF graph
	// canonicalization algorithm.
	CanonicalizationAlgorithm GraphCanonicalizationAlgorithm `` /* 187-byte string literal not displayed */
	// merkle_tree is the merkle tree type used for the graph hash, if any.
	MerkleTree GraphMerkleTree `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Graph is the content hash type used for RDF graph data.

func (*ContentHash_Graph) Descriptor deprecated

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

Deprecated: Use ContentHash_Graph.ProtoReflect.Descriptor instead.

func (*ContentHash_Graph) GetCanonicalizationAlgorithm

func (x *ContentHash_Graph) GetCanonicalizationAlgorithm() GraphCanonicalizationAlgorithm

func (*ContentHash_Graph) GetDigestAlgorithm

func (x *ContentHash_Graph) GetDigestAlgorithm() DigestAlgorithm

func (*ContentHash_Graph) GetHash

func (x *ContentHash_Graph) GetHash() []byte

func (*ContentHash_Graph) GetMerkleTree

func (x *ContentHash_Graph) GetMerkleTree() GraphMerkleTree

func (*ContentHash_Graph) ProtoMessage

func (*ContentHash_Graph) ProtoMessage()

func (*ContentHash_Graph) ProtoReflect

func (x *ContentHash_Graph) ProtoReflect() protoreflect.Message

func (*ContentHash_Graph) Reset

func (x *ContentHash_Graph) Reset()

func (*ContentHash_Graph) String

func (x *ContentHash_Graph) String() string

type ContentHash_Raw

type ContentHash_Raw struct {

	// hash represents the hash of the data based on the specified
	// digest_algorithm.
	Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// digest_algorithm represents the hash digest algorithm.
	DigestAlgorithm DigestAlgorithm `` /* 142-byte string literal not displayed */
	// media_type represents the media type for raw data.
	MediaType RawMediaType `protobuf:"varint,3,opt,name=media_type,json=mediaType,proto3,enum=regen.data.v1.RawMediaType" json:"media_type,omitempty"`
	// contains filtered or unexported fields
}

Raw is the content hash type used for raw data.

func (*ContentHash_Raw) Descriptor deprecated

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

Deprecated: Use ContentHash_Raw.ProtoReflect.Descriptor instead.

func (*ContentHash_Raw) GetDigestAlgorithm

func (x *ContentHash_Raw) GetDigestAlgorithm() DigestAlgorithm

func (*ContentHash_Raw) GetHash

func (x *ContentHash_Raw) GetHash() []byte

func (*ContentHash_Raw) GetMediaType

func (x *ContentHash_Raw) GetMediaType() RawMediaType

func (*ContentHash_Raw) ProtoMessage

func (*ContentHash_Raw) ProtoMessage()

func (*ContentHash_Raw) ProtoReflect

func (x *ContentHash_Raw) ProtoReflect() protoreflect.Message

func (*ContentHash_Raw) Reset

func (x *ContentHash_Raw) Reset()

func (*ContentHash_Raw) String

func (x *ContentHash_Raw) String() string

type ContentHashes

type ContentHashes struct {

	// data is a list of content hashes which the resolver claims to serve.
	ContentHashes []*ContentHash `protobuf:"bytes,1,rep,name=content_hashes,json=contentHashes,proto3" json:"content_hashes,omitempty"`
	// contains filtered or unexported fields
}

ContentHashes contains list of content ContentHash.

func (*ContentHashes) Descriptor deprecated

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

Deprecated: Use ContentHashes.ProtoReflect.Descriptor instead.

func (*ContentHashes) GetContentHashes

func (x *ContentHashes) GetContentHashes() []*ContentHash

func (*ContentHashes) ProtoMessage

func (*ContentHashes) ProtoMessage()

func (*ContentHashes) ProtoReflect

func (x *ContentHashes) ProtoReflect() protoreflect.Message

func (*ContentHashes) Reset

func (x *ContentHashes) Reset()

func (*ContentHashes) String

func (x *ContentHashes) String() string

type ConvertHashToIRIRequest

type ConvertHashToIRIRequest struct {

	// content_hash is the ContentHash to convert to an IRI.
	ContentHash *ContentHash `protobuf:"bytes,1,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// contains filtered or unexported fields
}

ConvertHashToIRIRequest is the Query/ConvertHashToIRI request type.

func (*ConvertHashToIRIRequest) Descriptor deprecated

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

Deprecated: Use ConvertHashToIRIRequest.ProtoReflect.Descriptor instead.

func (*ConvertHashToIRIRequest) GetContentHash

func (x *ConvertHashToIRIRequest) GetContentHash() *ContentHash

func (*ConvertHashToIRIRequest) ProtoMessage

func (*ConvertHashToIRIRequest) ProtoMessage()

func (*ConvertHashToIRIRequest) ProtoReflect

func (x *ConvertHashToIRIRequest) ProtoReflect() protoreflect.Message

func (*ConvertHashToIRIRequest) Reset

func (x *ConvertHashToIRIRequest) Reset()

func (*ConvertHashToIRIRequest) String

func (x *ConvertHashToIRIRequest) String() string

type ConvertHashToIRIResponse

type ConvertHashToIRIResponse struct {

	// iri is the IRI converted from the ContentHash.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

ConvertHashToIRIResponse is the Query/ConvertHashToIRI response type.

func (*ConvertHashToIRIResponse) Descriptor deprecated

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

Deprecated: Use ConvertHashToIRIResponse.ProtoReflect.Descriptor instead.

func (*ConvertHashToIRIResponse) GetIri

func (x *ConvertHashToIRIResponse) GetIri() string

func (*ConvertHashToIRIResponse) ProtoMessage

func (*ConvertHashToIRIResponse) ProtoMessage()

func (*ConvertHashToIRIResponse) ProtoReflect

func (x *ConvertHashToIRIResponse) ProtoReflect() protoreflect.Message

func (*ConvertHashToIRIResponse) Reset

func (x *ConvertHashToIRIResponse) Reset()

func (*ConvertHashToIRIResponse) String

func (x *ConvertHashToIRIResponse) String() string

type ConvertIRIToHashRequest

type ConvertIRIToHashRequest struct {

	// iri is the IRI to convert to a ContentHash.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

ConvertIRIToHashRequest is the Query/ConvertIRIToHash request type.

func (*ConvertIRIToHashRequest) Descriptor deprecated

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

Deprecated: Use ConvertIRIToHashRequest.ProtoReflect.Descriptor instead.

func (*ConvertIRIToHashRequest) GetIri

func (x *ConvertIRIToHashRequest) GetIri() string

func (*ConvertIRIToHashRequest) ProtoMessage

func (*ConvertIRIToHashRequest) ProtoMessage()

func (*ConvertIRIToHashRequest) ProtoReflect

func (x *ConvertIRIToHashRequest) ProtoReflect() protoreflect.Message

func (*ConvertIRIToHashRequest) Reset

func (x *ConvertIRIToHashRequest) Reset()

func (*ConvertIRIToHashRequest) String

func (x *ConvertIRIToHashRequest) String() string

type ConvertIRIToHashResponse

type ConvertIRIToHashResponse struct {

	// content_hash is the ContentHash converted from the IRI.
	ContentHash *ContentHash `protobuf:"bytes,1,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// contains filtered or unexported fields
}

ConvertIRIToHashResponse is the Query/ConvertIRIToHash response type.

func (*ConvertIRIToHashResponse) Descriptor deprecated

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

Deprecated: Use ConvertIRIToHashResponse.ProtoReflect.Descriptor instead.

func (*ConvertIRIToHashResponse) GetContentHash

func (x *ConvertIRIToHashResponse) GetContentHash() *ContentHash

func (*ConvertIRIToHashResponse) ProtoMessage

func (*ConvertIRIToHashResponse) ProtoMessage()

func (*ConvertIRIToHashResponse) ProtoReflect

func (x *ConvertIRIToHashResponse) ProtoReflect() protoreflect.Message

func (*ConvertIRIToHashResponse) Reset

func (x *ConvertIRIToHashResponse) Reset()

func (*ConvertIRIToHashResponse) String

func (x *ConvertIRIToHashResponse) String() string

type DataAnchor

type DataAnchor struct {

	// id is the compact data ID.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// timestamp is the anchor timestamp for this object - the time at which
	// it was first known to the blockchain.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

DataAnchor stores the anchor timestamp for a data object.

func (*DataAnchor) Descriptor deprecated

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

Deprecated: Use DataAnchor.ProtoReflect.Descriptor instead.

func (*DataAnchor) GetId

func (x *DataAnchor) GetId() []byte

func (*DataAnchor) GetTimestamp

func (x *DataAnchor) GetTimestamp() *timestamppb.Timestamp

func (*DataAnchor) ProtoMessage

func (*DataAnchor) ProtoMessage()

func (*DataAnchor) ProtoReflect

func (x *DataAnchor) ProtoReflect() protoreflect.Message

func (*DataAnchor) Reset

func (x *DataAnchor) Reset()

func (*DataAnchor) String

func (x *DataAnchor) String() string

type DataAnchorIdIndexKey

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

func (DataAnchorIdIndexKey) WithId

type DataAnchorIndexKey

type DataAnchorIndexKey interface {
	// contains filtered or unexported methods
}

type DataAnchorIterator

type DataAnchorIterator struct {
	ormtable.Iterator
}

func (DataAnchorIterator) Value

func (i DataAnchorIterator) Value() (*DataAnchor, error)

type DataAnchorPrimaryKey

type DataAnchorPrimaryKey = DataAnchorIdIndexKey

primary key starting index..

type DataAnchorTable

type DataAnchorTable interface {
	Insert(ctx context.Context, dataAnchor *DataAnchor) error
	Update(ctx context.Context, dataAnchor *DataAnchor) error
	Save(ctx context.Context, dataAnchor *DataAnchor) error
	Delete(ctx context.Context, dataAnchor *DataAnchor) error
	Has(ctx context.Context, id []byte) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, id []byte) (*DataAnchor, error)
	List(ctx context.Context, prefixKey DataAnchorIndexKey, opts ...ormlist.Option) (DataAnchorIterator, error)
	ListRange(ctx context.Context, from, to DataAnchorIndexKey, opts ...ormlist.Option) (DataAnchorIterator, error)
	DeleteBy(ctx context.Context, prefixKey DataAnchorIndexKey) error
	DeleteRange(ctx context.Context, from, to DataAnchorIndexKey) error
	// contains filtered or unexported methods
}

func NewDataAnchorTable

func NewDataAnchorTable(db ormtable.Schema) (DataAnchorTable, error)

type DataAttestor

type DataAttestor struct {

	// id is the compact data ID.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// attestor is the account address of the attestor.
	Attestor []byte `protobuf:"bytes,2,opt,name=attestor,proto3" json:"attestor,omitempty"`
	// timestamp is the time at which the attestor signed this data object.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

DataAttestor is a join table for associating data IDs and attestors.

func (*DataAttestor) Descriptor deprecated

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

Deprecated: Use DataAttestor.ProtoReflect.Descriptor instead.

func (*DataAttestor) GetAttestor

func (x *DataAttestor) GetAttestor() []byte

func (*DataAttestor) GetId

func (x *DataAttestor) GetId() []byte

func (*DataAttestor) GetTimestamp

func (x *DataAttestor) GetTimestamp() *timestamppb.Timestamp

func (*DataAttestor) ProtoMessage

func (*DataAttestor) ProtoMessage()

func (*DataAttestor) ProtoReflect

func (x *DataAttestor) ProtoReflect() protoreflect.Message

func (*DataAttestor) Reset

func (x *DataAttestor) Reset()

func (*DataAttestor) String

func (x *DataAttestor) String() string

type DataAttestorAttestorIndexKey

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

func (DataAttestorAttestorIndexKey) WithAttestor

func (this DataAttestorAttestorIndexKey) WithAttestor(attestor []byte) DataAttestorAttestorIndexKey

type DataAttestorIdAttestorIndexKey

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

func (DataAttestorIdAttestorIndexKey) WithId

func (DataAttestorIdAttestorIndexKey) WithIdAttestor

func (this DataAttestorIdAttestorIndexKey) WithIdAttestor(id []byte, attestor []byte) DataAttestorIdAttestorIndexKey

type DataAttestorIndexKey

type DataAttestorIndexKey interface {
	// contains filtered or unexported methods
}

type DataAttestorIterator

type DataAttestorIterator struct {
	ormtable.Iterator
}

func (DataAttestorIterator) Value

func (i DataAttestorIterator) Value() (*DataAttestor, error)

type DataAttestorPrimaryKey

type DataAttestorPrimaryKey = DataAttestorIdAttestorIndexKey

primary key starting index..

type DataAttestorTable

type DataAttestorTable interface {
	Insert(ctx context.Context, dataAttestor *DataAttestor) error
	Update(ctx context.Context, dataAttestor *DataAttestor) error
	Save(ctx context.Context, dataAttestor *DataAttestor) error
	Delete(ctx context.Context, dataAttestor *DataAttestor) error
	Has(ctx context.Context, id []byte, attestor []byte) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, id []byte, attestor []byte) (*DataAttestor, error)
	List(ctx context.Context, prefixKey DataAttestorIndexKey, opts ...ormlist.Option) (DataAttestorIterator, error)
	ListRange(ctx context.Context, from, to DataAttestorIndexKey, opts ...ormlist.Option) (DataAttestorIterator, error)
	DeleteBy(ctx context.Context, prefixKey DataAttestorIndexKey) error
	DeleteRange(ctx context.Context, from, to DataAttestorIndexKey) error
	// contains filtered or unexported methods
}

func NewDataAttestorTable

func NewDataAttestorTable(db ormtable.Schema) (DataAttestorTable, error)

type DataID

type DataID struct {

	// id is the compact automatically-generated data ID.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// iri is the IRI of the data which contains its full ContentHash.
	Iri string `protobuf:"bytes,2,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

DataID stores a compact data ID and its full IRI.

func (*DataID) Descriptor deprecated

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

Deprecated: Use DataID.ProtoReflect.Descriptor instead.

func (*DataID) GetId

func (x *DataID) GetId() []byte

func (*DataID) GetIri

func (x *DataID) GetIri() string

func (*DataID) ProtoMessage

func (*DataID) ProtoMessage()

func (*DataID) ProtoReflect

func (x *DataID) ProtoReflect() protoreflect.Message

func (*DataID) Reset

func (x *DataID) Reset()

func (*DataID) String

func (x *DataID) String() string

type DataIDIdIndexKey

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

func (DataIDIdIndexKey) WithId

func (this DataIDIdIndexKey) WithId(id []byte) DataIDIdIndexKey

type DataIDIndexKey

type DataIDIndexKey interface {
	// contains filtered or unexported methods
}

type DataIDIriIndexKey

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

func (DataIDIriIndexKey) WithIri

func (this DataIDIriIndexKey) WithIri(iri string) DataIDIriIndexKey

type DataIDIterator

type DataIDIterator struct {
	ormtable.Iterator
}

func (DataIDIterator) Value

func (i DataIDIterator) Value() (*DataID, error)

type DataIDPrimaryKey

type DataIDPrimaryKey = DataIDIdIndexKey

primary key starting index..

type DataIDTable

type DataIDTable interface {
	Insert(ctx context.Context, dataID *DataID) error
	Update(ctx context.Context, dataID *DataID) error
	Save(ctx context.Context, dataID *DataID) error
	Delete(ctx context.Context, dataID *DataID) error
	Has(ctx context.Context, id []byte) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, id []byte) (*DataID, error)
	HasByIri(ctx context.Context, iri string) (found bool, err error)
	// GetByIri returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	GetByIri(ctx context.Context, iri string) (*DataID, error)
	List(ctx context.Context, prefixKey DataIDIndexKey, opts ...ormlist.Option) (DataIDIterator, error)
	ListRange(ctx context.Context, from, to DataIDIndexKey, opts ...ormlist.Option) (DataIDIterator, error)
	DeleteBy(ctx context.Context, prefixKey DataIDIndexKey) error
	DeleteRange(ctx context.Context, from, to DataIDIndexKey) error
	// contains filtered or unexported methods
}

func NewDataIDTable

func NewDataIDTable(db ormtable.Schema) (DataIDTable, error)

type DataResolver

type DataResolver struct {

	// id is the compact data ID.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// resolver_id is the ID of the resolver.
	ResolverId uint64 `protobuf:"varint,2,opt,name=resolver_id,json=resolverId,proto3" json:"resolver_id,omitempty"`
	// contains filtered or unexported fields
}

DataResolver is a join table between data objects and resolvers and indicates that a resolver claims to be able to resolve this data object.

func (*DataResolver) Descriptor deprecated

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

Deprecated: Use DataResolver.ProtoReflect.Descriptor instead.

func (*DataResolver) GetId

func (x *DataResolver) GetId() []byte

func (*DataResolver) GetResolverId

func (x *DataResolver) GetResolverId() uint64

func (*DataResolver) ProtoMessage

func (*DataResolver) ProtoMessage()

func (*DataResolver) ProtoReflect

func (x *DataResolver) ProtoReflect() protoreflect.Message

func (*DataResolver) Reset

func (x *DataResolver) Reset()

func (*DataResolver) String

func (x *DataResolver) String() string

type DataResolverIdResolverIdIndexKey

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

func (DataResolverIdResolverIdIndexKey) WithId

func (DataResolverIdResolverIdIndexKey) WithIdResolverId

func (this DataResolverIdResolverIdIndexKey) WithIdResolverId(id []byte, resolver_id uint64) DataResolverIdResolverIdIndexKey

type DataResolverIndexKey

type DataResolverIndexKey interface {
	// contains filtered or unexported methods
}

type DataResolverIterator

type DataResolverIterator struct {
	ormtable.Iterator
}

func (DataResolverIterator) Value

func (i DataResolverIterator) Value() (*DataResolver, error)

type DataResolverPrimaryKey

type DataResolverPrimaryKey = DataResolverIdResolverIdIndexKey

primary key starting index..

type DataResolverTable

type DataResolverTable interface {
	Insert(ctx context.Context, dataResolver *DataResolver) error
	Update(ctx context.Context, dataResolver *DataResolver) error
	Save(ctx context.Context, dataResolver *DataResolver) error
	Delete(ctx context.Context, dataResolver *DataResolver) error
	Has(ctx context.Context, id []byte, resolver_id uint64) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, id []byte, resolver_id uint64) (*DataResolver, error)
	List(ctx context.Context, prefixKey DataResolverIndexKey, opts ...ormlist.Option) (DataResolverIterator, error)
	ListRange(ctx context.Context, from, to DataResolverIndexKey, opts ...ormlist.Option) (DataResolverIterator, error)
	DeleteBy(ctx context.Context, prefixKey DataResolverIndexKey) error
	DeleteRange(ctx context.Context, from, to DataResolverIndexKey) error
	// contains filtered or unexported methods
}

func NewDataResolverTable

func NewDataResolverTable(db ormtable.Schema) (DataResolverTable, error)

type DigestAlgorithm

type DigestAlgorithm int32

DigestAlgorithm is the hash digest algorithm

const (
	// unspecified and invalid
	DigestAlgorithm_DIGEST_ALGORITHM_UNSPECIFIED DigestAlgorithm = 0
	// BLAKE2b-256
	DigestAlgorithm_DIGEST_ALGORITHM_BLAKE2B_256 DigestAlgorithm = 1
)

func (DigestAlgorithm) Descriptor

func (DigestAlgorithm) Enum

func (x DigestAlgorithm) Enum() *DigestAlgorithm

func (DigestAlgorithm) EnumDescriptor deprecated

func (DigestAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use DigestAlgorithm.Descriptor instead.

func (DigestAlgorithm) Number

func (DigestAlgorithm) String

func (x DigestAlgorithm) String() string

func (DigestAlgorithm) Type

type EventAnchor

type EventAnchor struct {

	// iri is the IRI of the data anchored on chain.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

EventAnchor is an event emitted when data is anchored on chain.

func (*EventAnchor) Descriptor deprecated

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

Deprecated: Use EventAnchor.ProtoReflect.Descriptor instead.

func (*EventAnchor) GetIri

func (x *EventAnchor) GetIri() string

func (*EventAnchor) ProtoMessage

func (*EventAnchor) ProtoMessage()

func (*EventAnchor) ProtoReflect

func (x *EventAnchor) ProtoReflect() protoreflect.Message

func (*EventAnchor) Reset

func (x *EventAnchor) Reset()

func (*EventAnchor) String

func (x *EventAnchor) String() string

type EventAttest

type EventAttest struct {

	// iri is the IRI of the data attested to.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// attestor is the address of the account that has attested to the veracity of
	// the data.
	Attestor string `protobuf:"bytes,2,opt,name=attestor,proto3" json:"attestor,omitempty"`
	// contains filtered or unexported fields
}

EventAttest is an event emitted when data is attested to on chain.

func (*EventAttest) Descriptor deprecated

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

Deprecated: Use EventAttest.ProtoReflect.Descriptor instead.

func (*EventAttest) GetAttestor

func (x *EventAttest) GetAttestor() string

func (*EventAttest) GetIri

func (x *EventAttest) GetIri() string

func (*EventAttest) ProtoMessage

func (*EventAttest) ProtoMessage()

func (*EventAttest) ProtoReflect

func (x *EventAttest) ProtoReflect() protoreflect.Message

func (*EventAttest) Reset

func (x *EventAttest) Reset()

func (*EventAttest) String

func (x *EventAttest) String() string

type EventDefineResolver

type EventDefineResolver struct {

	// id is the ID of the defined resolver.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

EventDefineResolver is an event emitted when a resolved is defined on chain.

func (*EventDefineResolver) Descriptor deprecated

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

Deprecated: Use EventDefineResolver.ProtoReflect.Descriptor instead.

func (*EventDefineResolver) GetId

func (x *EventDefineResolver) GetId() uint64

func (*EventDefineResolver) ProtoMessage

func (*EventDefineResolver) ProtoMessage()

func (*EventDefineResolver) ProtoReflect

func (x *EventDefineResolver) ProtoReflect() protoreflect.Message

func (*EventDefineResolver) Reset

func (x *EventDefineResolver) Reset()

func (*EventDefineResolver) String

func (x *EventDefineResolver) String() string

type EventRegisterResolver

type EventRegisterResolver struct {

	// id is the ID of the resolver that the data was registered to.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// iri is the IRI of the data that was registered.
	Iri string `protobuf:"bytes,2,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

EventRegisterResolver is an event emitted when data is registered to a resolver on chain.

func (*EventRegisterResolver) Descriptor deprecated

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

Deprecated: Use EventRegisterResolver.ProtoReflect.Descriptor instead.

func (*EventRegisterResolver) GetId

func (x *EventRegisterResolver) GetId() uint64

func (*EventRegisterResolver) GetIri

func (x *EventRegisterResolver) GetIri() string

func (*EventRegisterResolver) ProtoMessage

func (*EventRegisterResolver) ProtoMessage()

func (*EventRegisterResolver) ProtoReflect

func (x *EventRegisterResolver) ProtoReflect() protoreflect.Message

func (*EventRegisterResolver) Reset

func (x *EventRegisterResolver) Reset()

func (*EventRegisterResolver) String

func (x *EventRegisterResolver) String() string

type GraphCanonicalizationAlgorithm

type GraphCanonicalizationAlgorithm int32

GraphCanonicalizationAlgorithm is the graph canonicalization algorithm

const (
	// unspecified and invalid
	GraphCanonicalizationAlgorithm_GRAPH_CANONICALIZATION_ALGORITHM_UNSPECIFIED GraphCanonicalizationAlgorithm = 0
	// URDNA2015 graph hashing
	GraphCanonicalizationAlgorithm_GRAPH_CANONICALIZATION_ALGORITHM_URDNA2015 GraphCanonicalizationAlgorithm = 1
)

func (GraphCanonicalizationAlgorithm) Descriptor

func (GraphCanonicalizationAlgorithm) Enum

func (GraphCanonicalizationAlgorithm) EnumDescriptor deprecated

func (GraphCanonicalizationAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use GraphCanonicalizationAlgorithm.Descriptor instead.

func (GraphCanonicalizationAlgorithm) Number

func (GraphCanonicalizationAlgorithm) String

func (GraphCanonicalizationAlgorithm) Type

type GraphMerkleTree

type GraphMerkleTree int32

GraphMerkleTree is the graph merkle tree type used for hashing, if any

const (
	// unspecified and valid
	GraphMerkleTree_GRAPH_MERKLE_TREE_NONE_UNSPECIFIED GraphMerkleTree = 0
)

func (GraphMerkleTree) Descriptor

func (GraphMerkleTree) Enum

func (x GraphMerkleTree) Enum() *GraphMerkleTree

func (GraphMerkleTree) EnumDescriptor deprecated

func (GraphMerkleTree) EnumDescriptor() ([]byte, []int)

Deprecated: Use GraphMerkleTree.Descriptor instead.

func (GraphMerkleTree) Number

func (GraphMerkleTree) String

func (x GraphMerkleTree) String() string

func (GraphMerkleTree) Type

type MsgAnchor

type MsgAnchor struct {

	// sender is the address of the sender of the transaction. The sender in
	// Anchor is not attesting to the veracity of the underlying data. They
	// can simply be an intermediary providing services.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// content_hash is the content hash for the data to anchor.
	ContentHash *ContentHash `protobuf:"bytes,2,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// contains filtered or unexported fields
}

MsgAnchor is the Msg/Anchor request type.

func (*MsgAnchor) Descriptor deprecated

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

Deprecated: Use MsgAnchor.ProtoReflect.Descriptor instead.

func (*MsgAnchor) GetContentHash

func (x *MsgAnchor) GetContentHash() *ContentHash

func (*MsgAnchor) GetSender

func (x *MsgAnchor) GetSender() string

func (*MsgAnchor) ProtoMessage

func (*MsgAnchor) ProtoMessage()

func (*MsgAnchor) ProtoReflect

func (x *MsgAnchor) ProtoReflect() protoreflect.Message

func (*MsgAnchor) Reset

func (x *MsgAnchor) Reset()

func (*MsgAnchor) String

func (x *MsgAnchor) String() string

type MsgAnchorResponse

type MsgAnchorResponse struct {

	// iri is the IRI of the data that was anchored.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// timestamp is the time at which the data was anchored.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

MsgAnchor is the Msg/Anchor response type.

func (*MsgAnchorResponse) Descriptor deprecated

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

Deprecated: Use MsgAnchorResponse.ProtoReflect.Descriptor instead.

func (*MsgAnchorResponse) GetIri

func (x *MsgAnchorResponse) GetIri() string

func (*MsgAnchorResponse) GetTimestamp

func (x *MsgAnchorResponse) GetTimestamp() *timestamppb.Timestamp

func (*MsgAnchorResponse) ProtoMessage

func (*MsgAnchorResponse) ProtoMessage()

func (*MsgAnchorResponse) ProtoReflect

func (x *MsgAnchorResponse) ProtoReflect() protoreflect.Message

func (*MsgAnchorResponse) Reset

func (x *MsgAnchorResponse) Reset()

func (*MsgAnchorResponse) String

func (x *MsgAnchorResponse) String() string

type MsgAttest

type MsgAttest struct {

	// attestor is the addresses of the account attesting to the veracity of the
	// data. By making an Attest request, the attestor is attesting to the
	// veracity of the data referenced by the IRI. The precise meaning of this may
	// vary depending on the underlying data.
	Attestor string `protobuf:"bytes,1,opt,name=attestor,proto3" json:"attestor,omitempty"`
	// content_hashes are the content hashes for anchored data. Only RDF graph
	// data can be signed as its data model is intended to specifically convey
	// semantic meaning.
	ContentHashes []*ContentHash_Graph `protobuf:"bytes,2,rep,name=content_hashes,json=contentHashes,proto3" json:"content_hashes,omitempty"`
	// contains filtered or unexported fields
}

MsgAttest is the Msg/Attest request type.

func (*MsgAttest) Descriptor deprecated

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

Deprecated: Use MsgAttest.ProtoReflect.Descriptor instead.

func (*MsgAttest) GetAttestor

func (x *MsgAttest) GetAttestor() string

func (*MsgAttest) GetContentHashes

func (x *MsgAttest) GetContentHashes() []*ContentHash_Graph

func (*MsgAttest) ProtoMessage

func (*MsgAttest) ProtoMessage()

func (*MsgAttest) ProtoReflect

func (x *MsgAttest) ProtoReflect() protoreflect.Message

func (*MsgAttest) Reset

func (x *MsgAttest) Reset()

func (*MsgAttest) String

func (x *MsgAttest) String() string

type MsgAttestResponse

type MsgAttestResponse struct {

	// iris are the IRIs of the data that was attested to. If the attestor attests
	// to the same piece of data, the previous attestation will not be updated and
	// the IRI will not be included in this list.
	Iris []string `protobuf:"bytes,1,rep,name=iris,proto3" json:"iris,omitempty"`
	// timestamp is the time at which any new attestations were made.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

MsgAttestResponse is the Msg/Attest response type.

func (*MsgAttestResponse) Descriptor deprecated

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

Deprecated: Use MsgAttestResponse.ProtoReflect.Descriptor instead.

func (*MsgAttestResponse) GetIris

func (x *MsgAttestResponse) GetIris() []string

func (*MsgAttestResponse) GetTimestamp

func (x *MsgAttestResponse) GetTimestamp() *timestamppb.Timestamp

func (*MsgAttestResponse) ProtoMessage

func (*MsgAttestResponse) ProtoMessage()

func (*MsgAttestResponse) ProtoReflect

func (x *MsgAttestResponse) ProtoReflect() protoreflect.Message

func (*MsgAttestResponse) Reset

func (x *MsgAttestResponse) Reset()

func (*MsgAttestResponse) String

func (x *MsgAttestResponse) String() string

type MsgClient

type MsgClient interface {
	// Anchor "anchors" a piece of data to the blockchain based on its secure
	// hash, effectively providing a tamper resistant timestamp.
	//
	// The sender in Anchor is not attesting to the veracity of the underlying
	// data. They can simply be an intermediary providing timestamp services.
	// Attest should be used to create a digital signature attesting to the
	// veracity of some piece of data.
	Anchor(ctx context.Context, in *MsgAnchor, opts ...grpc.CallOption) (*MsgAnchorResponse, error)
	// Attest allows for digital signing of an arbitrary piece of data on the
	// blockchain. By attesting to data, the attestor is making a statement about
	// the veracity of the data itself. It is like signing a legal document,
	// meaning that I agree to all conditions and to the best of my knowledge
	// everything is true. When anchoring data, the sender is not attesting to the
	// veracity of the data, they are simply communicating that it exists.
	//
	// On-chain signatures have the following benefits:
	// - on-chain identities can be managed using different cryptographic keys
	//   that change over time through key rotation practices
	// - an on-chain identity may represent an organization and through delegation
	//   individual members may sign on behalf of the group
	// - the blockchain transaction envelope provides built-in replay protection
	//   and timestamping
	//
	// Attest implicitly calls Anchor if the data was not already anchored.
	//
	// Attest can be called multiple times for the same content hash with
	// different attestors and those attestors will be appended to the list of
	// attestors. If the same attestor attempts to attest to the same piece of
	// data, the attestor will be ignored and a new attestation with a new
	// timestamp will not be added.
	Attest(ctx context.Context, in *MsgAttest, opts ...grpc.CallOption) (*MsgAttestResponse, error)
	// DefineResolver defines a resolver URL and assigns it a new integer ID
	// that can be used in calls to RegisterResolver.
	DefineResolver(ctx context.Context, in *MsgDefineResolver, opts ...grpc.CallOption) (*MsgDefineResolverResponse, error)
	// RegisterResolver registers data content hashes
	RegisterResolver(ctx context.Context, in *MsgRegisterResolver, opts ...grpc.CallOption) (*MsgRegisterResolverResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMsgClient

func NewMsgClient(cc grpc.ClientConnInterface) MsgClient

type MsgDefineResolver

type MsgDefineResolver struct {

	// manager is the address of the resolver manager. The manager is able
	// to make future calls using the ID returned by this operation with
	// Msg/RegisterResolver. To authorize other accounts to register resolvers,
	// the manager should make use of cosmos.authz.
	Manager string `protobuf:"bytes,1,opt,name=manager,proto3" json:"manager,omitempty"`
	// resolver_url is a resolver URL which should refer to an HTTP service
	// which will respond to a GET request with the IRI of a ContentHash
	// and return the content if it exists or a 404. For graph data, resolvers
	// should use the HTTP Accept header to negotiate the RDF serialization
	// format.
	ResolverUrl string `protobuf:"bytes,2,opt,name=resolver_url,json=resolverUrl,proto3" json:"resolver_url,omitempty"`
	// contains filtered or unexported fields
}

MsgDefineResolver is the Msg/DefineResolver request type.

func (*MsgDefineResolver) Descriptor deprecated

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

Deprecated: Use MsgDefineResolver.ProtoReflect.Descriptor instead.

func (*MsgDefineResolver) GetManager

func (x *MsgDefineResolver) GetManager() string

func (*MsgDefineResolver) GetResolverUrl

func (x *MsgDefineResolver) GetResolverUrl() string

func (*MsgDefineResolver) ProtoMessage

func (*MsgDefineResolver) ProtoMessage()

func (*MsgDefineResolver) ProtoReflect

func (x *MsgDefineResolver) ProtoReflect() protoreflect.Message

func (*MsgDefineResolver) Reset

func (x *MsgDefineResolver) Reset()

func (*MsgDefineResolver) String

func (x *MsgDefineResolver) String() string

type MsgDefineResolverResponse

type MsgDefineResolverResponse struct {

	// resolver_id is the integer ID of the resolver to be used in
	// MsgRegisterResolver.
	ResolverId uint64 `protobuf:"varint,1,opt,name=resolver_id,json=resolverId,proto3" json:"resolver_id,omitempty"`
	// contains filtered or unexported fields
}

MsgDefineResolverResponse is the Msg/DefineResolver response type.

func (*MsgDefineResolverResponse) Descriptor deprecated

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

Deprecated: Use MsgDefineResolverResponse.ProtoReflect.Descriptor instead.

func (*MsgDefineResolverResponse) GetResolverId

func (x *MsgDefineResolverResponse) GetResolverId() uint64

func (*MsgDefineResolverResponse) ProtoMessage

func (*MsgDefineResolverResponse) ProtoMessage()

func (*MsgDefineResolverResponse) ProtoReflect

func (*MsgDefineResolverResponse) Reset

func (x *MsgDefineResolverResponse) Reset()

func (*MsgDefineResolverResponse) String

func (x *MsgDefineResolverResponse) String() string

type MsgRegisterResolver

type MsgRegisterResolver struct {

	// manager is the address of the resolver manager who registered this
	// resolver with Msg/DefinedResolver.
	Manager string `protobuf:"bytes,1,opt,name=manager,proto3" json:"manager,omitempty"`
	// resolver_id is the ID of a resolver defined with Msg/DefineResolver.
	ResolverId uint64 `protobuf:"varint,2,opt,name=resolver_id,json=resolverId,proto3" json:"resolver_id,omitempty"`
	// content_hashes is a list of content hashes which the resolver claims to
	// serve.
	ContentHashes []*ContentHash `protobuf:"bytes,3,rep,name=content_hashes,json=contentHashes,proto3" json:"content_hashes,omitempty"`
	// contains filtered or unexported fields
}

MsgRegisterResolver is the Msg/RegisterResolver request type.

func (*MsgRegisterResolver) Descriptor deprecated

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

Deprecated: Use MsgRegisterResolver.ProtoReflect.Descriptor instead.

func (*MsgRegisterResolver) GetContentHashes

func (x *MsgRegisterResolver) GetContentHashes() []*ContentHash

func (*MsgRegisterResolver) GetManager

func (x *MsgRegisterResolver) GetManager() string

func (*MsgRegisterResolver) GetResolverId

func (x *MsgRegisterResolver) GetResolverId() uint64

func (*MsgRegisterResolver) ProtoMessage

func (*MsgRegisterResolver) ProtoMessage()

func (*MsgRegisterResolver) ProtoReflect

func (x *MsgRegisterResolver) ProtoReflect() protoreflect.Message

func (*MsgRegisterResolver) Reset

func (x *MsgRegisterResolver) Reset()

func (*MsgRegisterResolver) String

func (x *MsgRegisterResolver) String() string

type MsgRegisterResolverResponse

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

MsgRegisterResolverResponse is the Msg/RegisterResolver response type.

func (*MsgRegisterResolverResponse) Descriptor deprecated

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

Deprecated: Use MsgRegisterResolverResponse.ProtoReflect.Descriptor instead.

func (*MsgRegisterResolverResponse) ProtoMessage

func (*MsgRegisterResolverResponse) ProtoMessage()

func (*MsgRegisterResolverResponse) ProtoReflect

func (*MsgRegisterResolverResponse) Reset

func (x *MsgRegisterResolverResponse) Reset()

func (*MsgRegisterResolverResponse) String

func (x *MsgRegisterResolverResponse) String() string

type MsgServer

type MsgServer interface {
	// Anchor "anchors" a piece of data to the blockchain based on its secure
	// hash, effectively providing a tamper resistant timestamp.
	//
	// The sender in Anchor is not attesting to the veracity of the underlying
	// data. They can simply be an intermediary providing timestamp services.
	// Attest should be used to create a digital signature attesting to the
	// veracity of some piece of data.
	Anchor(context.Context, *MsgAnchor) (*MsgAnchorResponse, error)
	// Attest allows for digital signing of an arbitrary piece of data on the
	// blockchain. By attesting to data, the attestor is making a statement about
	// the veracity of the data itself. It is like signing a legal document,
	// meaning that I agree to all conditions and to the best of my knowledge
	// everything is true. When anchoring data, the sender is not attesting to the
	// veracity of the data, they are simply communicating that it exists.
	//
	// On-chain signatures have the following benefits:
	// - on-chain identities can be managed using different cryptographic keys
	//   that change over time through key rotation practices
	// - an on-chain identity may represent an organization and through delegation
	//   individual members may sign on behalf of the group
	// - the blockchain transaction envelope provides built-in replay protection
	//   and timestamping
	//
	// Attest implicitly calls Anchor if the data was not already anchored.
	//
	// Attest can be called multiple times for the same content hash with
	// different attestors and those attestors will be appended to the list of
	// attestors. If the same attestor attempts to attest to the same piece of
	// data, the attestor will be ignored and a new attestation with a new
	// timestamp will not be added.
	Attest(context.Context, *MsgAttest) (*MsgAttestResponse, error)
	// DefineResolver defines a resolver URL and assigns it a new integer ID
	// that can be used in calls to RegisterResolver.
	DefineResolver(context.Context, *MsgDefineResolver) (*MsgDefineResolverResponse, error)
	// RegisterResolver registers data content hashes
	RegisterResolver(context.Context, *MsgRegisterResolver) (*MsgRegisterResolverResponse, error)
	// contains filtered or unexported methods
}

MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility

type QueryAnchorByHashRequest

type QueryAnchorByHashRequest struct {

	// content_hash is the ContentHash of the anchored data.
	ContentHash *ContentHash `protobuf:"bytes,1,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// contains filtered or unexported fields
}

QueryAnchorByHashRequest is the Query/AnchorByHash request type.

func (*QueryAnchorByHashRequest) Descriptor deprecated

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

Deprecated: Use QueryAnchorByHashRequest.ProtoReflect.Descriptor instead.

func (*QueryAnchorByHashRequest) GetContentHash

func (x *QueryAnchorByHashRequest) GetContentHash() *ContentHash

func (*QueryAnchorByHashRequest) ProtoMessage

func (*QueryAnchorByHashRequest) ProtoMessage()

func (*QueryAnchorByHashRequest) ProtoReflect

func (x *QueryAnchorByHashRequest) ProtoReflect() protoreflect.Message

func (*QueryAnchorByHashRequest) Reset

func (x *QueryAnchorByHashRequest) Reset()

func (*QueryAnchorByHashRequest) String

func (x *QueryAnchorByHashRequest) String() string

type QueryAnchorByHashResponse

type QueryAnchorByHashResponse struct {

	// anchor is information about the data anchor.
	Anchor *AnchorInfo `protobuf:"bytes,1,opt,name=anchor,proto3" json:"anchor,omitempty"`
	// contains filtered or unexported fields
}

QueryAnchorByHashResponse is the Query/AnchorByHash response type.

func (*QueryAnchorByHashResponse) Descriptor deprecated

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

Deprecated: Use QueryAnchorByHashResponse.ProtoReflect.Descriptor instead.

func (*QueryAnchorByHashResponse) GetAnchor

func (x *QueryAnchorByHashResponse) GetAnchor() *AnchorInfo

func (*QueryAnchorByHashResponse) ProtoMessage

func (*QueryAnchorByHashResponse) ProtoMessage()

func (*QueryAnchorByHashResponse) ProtoReflect

func (*QueryAnchorByHashResponse) Reset

func (x *QueryAnchorByHashResponse) Reset()

func (*QueryAnchorByHashResponse) String

func (x *QueryAnchorByHashResponse) String() string

type QueryAnchorByIRIRequest

type QueryAnchorByIRIRequest struct {

	// iri is the IRI of the anchored data.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// contains filtered or unexported fields
}

QueryAnchorByIRIRequest is the Query/AnchorByIRI request type.

func (*QueryAnchorByIRIRequest) Descriptor deprecated

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

Deprecated: Use QueryAnchorByIRIRequest.ProtoReflect.Descriptor instead.

func (*QueryAnchorByIRIRequest) GetIri

func (x *QueryAnchorByIRIRequest) GetIri() string

func (*QueryAnchorByIRIRequest) ProtoMessage

func (*QueryAnchorByIRIRequest) ProtoMessage()

func (*QueryAnchorByIRIRequest) ProtoReflect

func (x *QueryAnchorByIRIRequest) ProtoReflect() protoreflect.Message

func (*QueryAnchorByIRIRequest) Reset

func (x *QueryAnchorByIRIRequest) Reset()

func (*QueryAnchorByIRIRequest) String

func (x *QueryAnchorByIRIRequest) String() string

type QueryAnchorByIRIResponse

type QueryAnchorByIRIResponse struct {

	// anchor is information about the data anchor.
	Anchor *AnchorInfo `protobuf:"bytes,1,opt,name=anchor,proto3" json:"anchor,omitempty"`
	// contains filtered or unexported fields
}

QueryAnchorByIRIResponse is the Query/AnchorByIRI response type.

func (*QueryAnchorByIRIResponse) Descriptor deprecated

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

Deprecated: Use QueryAnchorByIRIResponse.ProtoReflect.Descriptor instead.

func (*QueryAnchorByIRIResponse) GetAnchor

func (x *QueryAnchorByIRIResponse) GetAnchor() *AnchorInfo

func (*QueryAnchorByIRIResponse) ProtoMessage

func (*QueryAnchorByIRIResponse) ProtoMessage()

func (*QueryAnchorByIRIResponse) ProtoReflect

func (x *QueryAnchorByIRIResponse) ProtoReflect() protoreflect.Message

func (*QueryAnchorByIRIResponse) Reset

func (x *QueryAnchorByIRIResponse) Reset()

func (*QueryAnchorByIRIResponse) String

func (x *QueryAnchorByIRIResponse) String() string

type QueryAttestationsByAttestorRequest

type QueryAttestationsByAttestorRequest struct {

	// attestor is the address of the attestor.
	Attestor string `protobuf:"bytes,1,opt,name=attestor,proto3" json:"attestor,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByAttestorRequest is the Query/AttestationsByAttestor request type.

func (*QueryAttestationsByAttestorRequest) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByAttestorRequest.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByAttestorRequest) GetAttestor

func (x *QueryAttestationsByAttestorRequest) GetAttestor() string

func (*QueryAttestationsByAttestorRequest) GetPagination

func (*QueryAttestationsByAttestorRequest) ProtoMessage

func (*QueryAttestationsByAttestorRequest) ProtoMessage()

func (*QueryAttestationsByAttestorRequest) ProtoReflect

func (*QueryAttestationsByAttestorRequest) Reset

func (*QueryAttestationsByAttestorRequest) String

type QueryAttestationsByAttestorResponse

type QueryAttestationsByAttestorResponse struct {

	// attestations are the attestations by the attestor.
	Attestations []*AttestationInfo `protobuf:"bytes,1,rep,name=attestations,proto3" json:"attestations,omitempty"`
	// pagination is the pagination PageResponse.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByAttestorResponse is the Query/AttestationsByAttestor response type.

func (*QueryAttestationsByAttestorResponse) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByAttestorResponse.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByAttestorResponse) GetAttestations

func (x *QueryAttestationsByAttestorResponse) GetAttestations() []*AttestationInfo

func (*QueryAttestationsByAttestorResponse) GetPagination

func (*QueryAttestationsByAttestorResponse) ProtoMessage

func (*QueryAttestationsByAttestorResponse) ProtoMessage()

func (*QueryAttestationsByAttestorResponse) ProtoReflect

func (*QueryAttestationsByAttestorResponse) Reset

func (*QueryAttestationsByAttestorResponse) String

type QueryAttestationsByHashRequest

type QueryAttestationsByHashRequest struct {

	// content_hash is the ContentHash of the anchored data.
	ContentHash *ContentHash `protobuf:"bytes,1,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByHashRequest is the Query/AttestationsByHash request type.

func (*QueryAttestationsByHashRequest) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByHashRequest.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByHashRequest) GetContentHash

func (x *QueryAttestationsByHashRequest) GetContentHash() *ContentHash

func (*QueryAttestationsByHashRequest) GetPagination

func (*QueryAttestationsByHashRequest) ProtoMessage

func (*QueryAttestationsByHashRequest) ProtoMessage()

func (*QueryAttestationsByHashRequest) ProtoReflect

func (*QueryAttestationsByHashRequest) Reset

func (x *QueryAttestationsByHashRequest) Reset()

func (*QueryAttestationsByHashRequest) String

type QueryAttestationsByHashResponse

type QueryAttestationsByHashResponse struct {

	// attestations are the attestations that have been made to the anchored data.
	Attestations []*AttestationInfo `protobuf:"bytes,1,rep,name=attestations,proto3" json:"attestations,omitempty"`
	// pagination is the pagination PageResponse.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByHashResponse is the Query/AttestationsByHash response type.

func (*QueryAttestationsByHashResponse) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByHashResponse.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByHashResponse) GetAttestations

func (x *QueryAttestationsByHashResponse) GetAttestations() []*AttestationInfo

func (*QueryAttestationsByHashResponse) GetPagination

func (*QueryAttestationsByHashResponse) ProtoMessage

func (*QueryAttestationsByHashResponse) ProtoMessage()

func (*QueryAttestationsByHashResponse) ProtoReflect

func (*QueryAttestationsByHashResponse) Reset

func (*QueryAttestationsByHashResponse) String

type QueryAttestationsByIRIRequest

type QueryAttestationsByIRIRequest struct {

	// iri is the IRI of the anchored data.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByIRIRequest is the Query/AttestationsByIRI request type.

func (*QueryAttestationsByIRIRequest) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByIRIRequest.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByIRIRequest) GetIri

func (*QueryAttestationsByIRIRequest) GetPagination

func (*QueryAttestationsByIRIRequest) ProtoMessage

func (*QueryAttestationsByIRIRequest) ProtoMessage()

func (*QueryAttestationsByIRIRequest) ProtoReflect

func (*QueryAttestationsByIRIRequest) Reset

func (x *QueryAttestationsByIRIRequest) Reset()

func (*QueryAttestationsByIRIRequest) String

type QueryAttestationsByIRIResponse

type QueryAttestationsByIRIResponse struct {

	// attestations are the attestations that have been made to the anchored data.
	Attestations []*AttestationInfo `protobuf:"bytes,1,rep,name=attestations,proto3" json:"attestations,omitempty"`
	// pagination is the pagination PageResponse.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryAttestationsByIRIResponse is the Query/AttestationsByIRI response type.

func (*QueryAttestationsByIRIResponse) Descriptor deprecated

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

Deprecated: Use QueryAttestationsByIRIResponse.ProtoReflect.Descriptor instead.

func (*QueryAttestationsByIRIResponse) GetAttestations

func (x *QueryAttestationsByIRIResponse) GetAttestations() []*AttestationInfo

func (*QueryAttestationsByIRIResponse) GetPagination

func (*QueryAttestationsByIRIResponse) ProtoMessage

func (*QueryAttestationsByIRIResponse) ProtoMessage()

func (*QueryAttestationsByIRIResponse) ProtoReflect

func (*QueryAttestationsByIRIResponse) Reset

func (x *QueryAttestationsByIRIResponse) Reset()

func (*QueryAttestationsByIRIResponse) String

type QueryClient

type QueryClient interface {
	// AnchorByIRI queries a data anchor by the IRI of the data.
	AnchorByIRI(ctx context.Context, in *QueryAnchorByIRIRequest, opts ...grpc.CallOption) (*QueryAnchorByIRIResponse, error)
	// AnchorByHash queries a data anchor by the ContentHash of the data.
	AnchorByHash(ctx context.Context, in *QueryAnchorByHashRequest, opts ...grpc.CallOption) (*QueryAnchorByHashResponse, error)
	// AttestationsByAttestor queries data attestations by an attestor.
	AttestationsByAttestor(ctx context.Context, in *QueryAttestationsByAttestorRequest, opts ...grpc.CallOption) (*QueryAttestationsByAttestorResponse, error)
	// AttestationsByIRI queries data attestations by the IRI of the data.
	AttestationsByIRI(ctx context.Context, in *QueryAttestationsByIRIRequest, opts ...grpc.CallOption) (*QueryAttestationsByIRIResponse, error)
	// AttestationsByHash queries data attestations by the ContentHash of the
	// data.
	AttestationsByHash(ctx context.Context, in *QueryAttestationsByHashRequest, opts ...grpc.CallOption) (*QueryAttestationsByHashResponse, error)
	// Resolver queries a resolver by its unique identifier.
	Resolver(ctx context.Context, in *QueryResolverRequest, opts ...grpc.CallOption) (*QueryResolverResponse, error)
	// ResolversByIRI queries resolvers with registered data by the IRI of the
	// data.
	ResolversByIRI(ctx context.Context, in *QueryResolversByIRIRequest, opts ...grpc.CallOption) (*QueryResolversByIRIResponse, error)
	// ResolversByHash queries resolvers with registered data by the ContentHash
	// of the data.
	ResolversByHash(ctx context.Context, in *QueryResolversByHashRequest, opts ...grpc.CallOption) (*QueryResolversByHashResponse, error)
	// ResolversByURL queries resolvers by URL.
	ResolversByURL(ctx context.Context, in *QueryResolversByURLRequest, opts ...grpc.CallOption) (*QueryResolversByURLResponse, error)
	// ConvertIRIToHash converts an IRI to a ContentHash.
	ConvertIRIToHash(ctx context.Context, in *ConvertIRIToHashRequest, opts ...grpc.CallOption) (*ConvertIRIToHashResponse, error)
	// ConvertHashToIRI converts a ContentHash to an IRI.
	ConvertHashToIRI(ctx context.Context, in *ConvertHashToIRIRequest, opts ...grpc.CallOption) (*ConvertHashToIRIResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryClient

func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

type QueryResolverRequest

type QueryResolverRequest struct {

	// id is the ID of the resolver.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

QueryResolverRequest is the Query/Resolver request type.

func (*QueryResolverRequest) Descriptor deprecated

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

Deprecated: Use QueryResolverRequest.ProtoReflect.Descriptor instead.

func (*QueryResolverRequest) GetId

func (x *QueryResolverRequest) GetId() uint64

func (*QueryResolverRequest) ProtoMessage

func (*QueryResolverRequest) ProtoMessage()

func (*QueryResolverRequest) ProtoReflect

func (x *QueryResolverRequest) ProtoReflect() protoreflect.Message

func (*QueryResolverRequest) Reset

func (x *QueryResolverRequest) Reset()

func (*QueryResolverRequest) String

func (x *QueryResolverRequest) String() string

type QueryResolverResponse

type QueryResolverResponse struct {

	// resolver is information about the resolver.
	Resolver *ResolverInfo `protobuf:"bytes,1,opt,name=resolver,proto3" json:"resolver,omitempty"`
	// contains filtered or unexported fields
}

QueryResolverResponse is the Query/Resolver response type.

func (*QueryResolverResponse) Descriptor deprecated

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

Deprecated: Use QueryResolverResponse.ProtoReflect.Descriptor instead.

func (*QueryResolverResponse) GetResolver

func (x *QueryResolverResponse) GetResolver() *ResolverInfo

func (*QueryResolverResponse) ProtoMessage

func (*QueryResolverResponse) ProtoMessage()

func (*QueryResolverResponse) ProtoReflect

func (x *QueryResolverResponse) ProtoReflect() protoreflect.Message

func (*QueryResolverResponse) Reset

func (x *QueryResolverResponse) Reset()

func (*QueryResolverResponse) String

func (x *QueryResolverResponse) String() string

type QueryResolversByHashRequest

type QueryResolversByHashRequest struct {

	// content_hash is the ContentHash of the anchored data.
	ContentHash *ContentHash `protobuf:"bytes,1,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByHashRequest is the Query/ResolversByHash request type.

func (*QueryResolversByHashRequest) Descriptor deprecated

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

Deprecated: Use QueryResolversByHashRequest.ProtoReflect.Descriptor instead.

func (*QueryResolversByHashRequest) GetContentHash

func (x *QueryResolversByHashRequest) GetContentHash() *ContentHash

func (*QueryResolversByHashRequest) GetPagination

func (x *QueryResolversByHashRequest) GetPagination() *v1beta1.PageRequest

func (*QueryResolversByHashRequest) ProtoMessage

func (*QueryResolversByHashRequest) ProtoMessage()

func (*QueryResolversByHashRequest) ProtoReflect

func (*QueryResolversByHashRequest) Reset

func (x *QueryResolversByHashRequest) Reset()

func (*QueryResolversByHashRequest) String

func (x *QueryResolversByHashRequest) String() string

type QueryResolversByHashResponse

type QueryResolversByHashResponse struct {

	// resolvers are the resolvers that have registered the data.
	Resolvers []*ResolverInfo `protobuf:"bytes,1,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	// pagination is the PageResponse to use for pagination.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByHashResponse is the Query/ResolversByHash response type.

func (*QueryResolversByHashResponse) Descriptor deprecated

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

Deprecated: Use QueryResolversByHashResponse.ProtoReflect.Descriptor instead.

func (*QueryResolversByHashResponse) GetPagination

func (*QueryResolversByHashResponse) GetResolvers

func (x *QueryResolversByHashResponse) GetResolvers() []*ResolverInfo

func (*QueryResolversByHashResponse) ProtoMessage

func (*QueryResolversByHashResponse) ProtoMessage()

func (*QueryResolversByHashResponse) ProtoReflect

func (*QueryResolversByHashResponse) Reset

func (x *QueryResolversByHashResponse) Reset()

func (*QueryResolversByHashResponse) String

type QueryResolversByIRIRequest

type QueryResolversByIRIRequest struct {

	// iri is the IRI of the anchored data.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByIRIRequest is the Query/ResolversByIRI request type.

func (*QueryResolversByIRIRequest) Descriptor deprecated

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

Deprecated: Use QueryResolversByIRIRequest.ProtoReflect.Descriptor instead.

func (*QueryResolversByIRIRequest) GetIri

func (x *QueryResolversByIRIRequest) GetIri() string

func (*QueryResolversByIRIRequest) GetPagination

func (x *QueryResolversByIRIRequest) GetPagination() *v1beta1.PageRequest

func (*QueryResolversByIRIRequest) ProtoMessage

func (*QueryResolversByIRIRequest) ProtoMessage()

func (*QueryResolversByIRIRequest) ProtoReflect

func (*QueryResolversByIRIRequest) Reset

func (x *QueryResolversByIRIRequest) Reset()

func (*QueryResolversByIRIRequest) String

func (x *QueryResolversByIRIRequest) String() string

type QueryResolversByIRIResponse

type QueryResolversByIRIResponse struct {

	// resolvers are the resolvers that have registered the anchored data.
	Resolvers []*ResolverInfo `protobuf:"bytes,1,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	// pagination is the PageResponse to use for pagination.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByIRIResponse is the Query/ResolversByIRI response type.

func (*QueryResolversByIRIResponse) Descriptor deprecated

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

Deprecated: Use QueryResolversByIRIResponse.ProtoReflect.Descriptor instead.

func (*QueryResolversByIRIResponse) GetPagination

func (x *QueryResolversByIRIResponse) GetPagination() *v1beta1.PageResponse

func (*QueryResolversByIRIResponse) GetResolvers

func (x *QueryResolversByIRIResponse) GetResolvers() []*ResolverInfo

func (*QueryResolversByIRIResponse) ProtoMessage

func (*QueryResolversByIRIResponse) ProtoMessage()

func (*QueryResolversByIRIResponse) ProtoReflect

func (*QueryResolversByIRIResponse) Reset

func (x *QueryResolversByIRIResponse) Reset()

func (*QueryResolversByIRIResponse) String

func (x *QueryResolversByIRIResponse) String() string

type QueryResolversByURLRequest

type QueryResolversByURLRequest struct {

	// url is the URL of the resolver.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByURLRequest is the Query/ResolversByURL request type.

func (*QueryResolversByURLRequest) Descriptor deprecated

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

Deprecated: Use QueryResolversByURLRequest.ProtoReflect.Descriptor instead.

func (*QueryResolversByURLRequest) GetPagination

func (x *QueryResolversByURLRequest) GetPagination() *v1beta1.PageRequest

func (*QueryResolversByURLRequest) GetUrl

func (x *QueryResolversByURLRequest) GetUrl() string

func (*QueryResolversByURLRequest) ProtoMessage

func (*QueryResolversByURLRequest) ProtoMessage()

func (*QueryResolversByURLRequest) ProtoReflect

func (*QueryResolversByURLRequest) Reset

func (x *QueryResolversByURLRequest) Reset()

func (*QueryResolversByURLRequest) String

func (x *QueryResolversByURLRequest) String() string

type QueryResolversByURLResponse

type QueryResolversByURLResponse struct {

	// resolvers are the resolvers that have a matching URL.
	Resolvers []*ResolverInfo `protobuf:"bytes,1,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	// pagination is the PageResponse to use for pagination.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryResolversByURLResponse is the Query/ResolversByURL response type.

func (*QueryResolversByURLResponse) Descriptor deprecated

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

Deprecated: Use QueryResolversByURLResponse.ProtoReflect.Descriptor instead.

func (*QueryResolversByURLResponse) GetPagination

func (x *QueryResolversByURLResponse) GetPagination() *v1beta1.PageResponse

func (*QueryResolversByURLResponse) GetResolvers

func (x *QueryResolversByURLResponse) GetResolvers() []*ResolverInfo

func (*QueryResolversByURLResponse) ProtoMessage

func (*QueryResolversByURLResponse) ProtoMessage()

func (*QueryResolversByURLResponse) ProtoReflect

func (*QueryResolversByURLResponse) Reset

func (x *QueryResolversByURLResponse) Reset()

func (*QueryResolversByURLResponse) String

func (x *QueryResolversByURLResponse) String() string

type QueryServer

type QueryServer interface {
	// AnchorByIRI queries a data anchor by the IRI of the data.
	AnchorByIRI(context.Context, *QueryAnchorByIRIRequest) (*QueryAnchorByIRIResponse, error)
	// AnchorByHash queries a data anchor by the ContentHash of the data.
	AnchorByHash(context.Context, *QueryAnchorByHashRequest) (*QueryAnchorByHashResponse, error)
	// AttestationsByAttestor queries data attestations by an attestor.
	AttestationsByAttestor(context.Context, *QueryAttestationsByAttestorRequest) (*QueryAttestationsByAttestorResponse, error)
	// AttestationsByIRI queries data attestations by the IRI of the data.
	AttestationsByIRI(context.Context, *QueryAttestationsByIRIRequest) (*QueryAttestationsByIRIResponse, error)
	// AttestationsByHash queries data attestations by the ContentHash of the
	// data.
	AttestationsByHash(context.Context, *QueryAttestationsByHashRequest) (*QueryAttestationsByHashResponse, error)
	// Resolver queries a resolver by its unique identifier.
	Resolver(context.Context, *QueryResolverRequest) (*QueryResolverResponse, error)
	// ResolversByIRI queries resolvers with registered data by the IRI of the
	// data.
	ResolversByIRI(context.Context, *QueryResolversByIRIRequest) (*QueryResolversByIRIResponse, error)
	// ResolversByHash queries resolvers with registered data by the ContentHash
	// of the data.
	ResolversByHash(context.Context, *QueryResolversByHashRequest) (*QueryResolversByHashResponse, error)
	// ResolversByURL queries resolvers by URL.
	ResolversByURL(context.Context, *QueryResolversByURLRequest) (*QueryResolversByURLResponse, error)
	// ConvertIRIToHash converts an IRI to a ContentHash.
	ConvertIRIToHash(context.Context, *ConvertIRIToHashRequest) (*ConvertIRIToHashResponse, error)
	// ConvertHashToIRI converts a ContentHash to an IRI.
	ConvertHashToIRI(context.Context, *ConvertHashToIRIRequest) (*ConvertHashToIRIResponse, error)
	// contains filtered or unexported methods
}

QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility

type RawMediaType

type RawMediaType int32

RawMediaType defines MIME media types to be used with a ContentHash.Raw hash.

const (
	// RAW_MEDIA_TYPE_UNSPECIFIED can be used for raw binary data
	RawMediaType_RAW_MEDIA_TYPE_UNSPECIFIED RawMediaType = 0
	// plain text
	RawMediaType_RAW_MEDIA_TYPE_TEXT_PLAIN RawMediaType = 1
	// JSON
	RawMediaType_RAW_MEDIA_TYPE_JSON RawMediaType = 2
	// CSV
	RawMediaType_RAW_MEDIA_TYPE_CSV RawMediaType = 3
	// XML
	RawMediaType_RAW_MEDIA_TYPE_XML RawMediaType = 4
	// PDF
	RawMediaType_RAW_MEDIA_TYPE_PDF RawMediaType = 5
	// TIIF
	RawMediaType_RAW_MEDIA_TYPE_TIFF RawMediaType = 16
	// JPG
	RawMediaType_RAW_MEDIA_TYPE_JPG RawMediaType = 17
	// PNG
	RawMediaType_RAW_MEDIA_TYPE_PNG RawMediaType = 18
	// SVG
	RawMediaType_RAW_MEDIA_TYPE_SVG RawMediaType = 19
	// WEBP
	RawMediaType_RAW_MEDIA_TYPE_WEBP RawMediaType = 20
	// AVIF
	RawMediaType_RAW_MEDIA_TYPE_AVIF RawMediaType = 21
	// GIF
	RawMediaType_RAW_MEDIA_TYPE_GIF RawMediaType = 22
	// APNG
	RawMediaType_RAW_MEDIA_TYPE_APNG RawMediaType = 23
	// MPEG
	RawMediaType_RAW_MEDIA_TYPE_MPEG RawMediaType = 32
	// MP4
	RawMediaType_RAW_MEDIA_TYPE_MP4 RawMediaType = 33
	// WEBM
	RawMediaType_RAW_MEDIA_TYPE_WEBM RawMediaType = 34
	// OGG
	RawMediaType_RAW_MEDIA_TYPE_OGG RawMediaType = 35
)

func (RawMediaType) Descriptor

func (RawMediaType) Enum

func (x RawMediaType) Enum() *RawMediaType

func (RawMediaType) EnumDescriptor deprecated

func (RawMediaType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RawMediaType.Descriptor instead.

func (RawMediaType) Number

func (RawMediaType) String

func (x RawMediaType) String() string

func (RawMediaType) Type

type Resolver

type Resolver struct {

	// id is the ID of the resolver.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// url is the URL of the resolver.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// manager is the bytes address of the resolver manager who is allowed
	// to make calls to Msg/RegisterResolver for this resolver.
	Manager []byte `protobuf:"bytes,3,opt,name=manager,proto3" json:"manager,omitempty"`
	// contains filtered or unexported fields
}

Resolver describes a data resolver.

func (*Resolver) Descriptor deprecated

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

Deprecated: Use Resolver.ProtoReflect.Descriptor instead.

func (*Resolver) GetId

func (x *Resolver) GetId() uint64

func (*Resolver) GetManager

func (x *Resolver) GetManager() []byte

func (*Resolver) GetUrl

func (x *Resolver) GetUrl() string

func (*Resolver) ProtoMessage

func (*Resolver) ProtoMessage()

func (*Resolver) ProtoReflect

func (x *Resolver) ProtoReflect() protoreflect.Message

func (*Resolver) Reset

func (x *Resolver) Reset()

func (*Resolver) String

func (x *Resolver) String() string

type ResolverIdIndexKey

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

func (ResolverIdIndexKey) WithId

type ResolverIndexKey

type ResolverIndexKey interface {
	// contains filtered or unexported methods
}

type ResolverInfo

type ResolverInfo struct {

	// id is the ID of the resolver.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// url is the URL of the resolver.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// manager is the address of the account that manages the resolver.
	Manager string `protobuf:"bytes,3,opt,name=manager,proto3" json:"manager,omitempty"`
	// contains filtered or unexported fields
}

ResolverInfo is the information for a resolver.

func (*ResolverInfo) Descriptor deprecated

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

Deprecated: Use ResolverInfo.ProtoReflect.Descriptor instead.

func (*ResolverInfo) GetId

func (x *ResolverInfo) GetId() uint64

func (*ResolverInfo) GetManager

func (x *ResolverInfo) GetManager() string

func (*ResolverInfo) GetUrl

func (x *ResolverInfo) GetUrl() string

func (*ResolverInfo) ProtoMessage

func (*ResolverInfo) ProtoMessage()

func (*ResolverInfo) ProtoReflect

func (x *ResolverInfo) ProtoReflect() protoreflect.Message

func (*ResolverInfo) Reset

func (x *ResolverInfo) Reset()

func (*ResolverInfo) String

func (x *ResolverInfo) String() string

type ResolverIterator

type ResolverIterator struct {
	ormtable.Iterator
}

func (ResolverIterator) Value

func (i ResolverIterator) Value() (*Resolver, error)

type ResolverPrimaryKey

type ResolverPrimaryKey = ResolverIdIndexKey

primary key starting index..

type ResolverTable

type ResolverTable interface {
	Insert(ctx context.Context, resolver *Resolver) error
	InsertReturningID(ctx context.Context, resolver *Resolver) (uint64, error)
	Update(ctx context.Context, resolver *Resolver) error
	Save(ctx context.Context, resolver *Resolver) error
	Delete(ctx context.Context, resolver *Resolver) error
	Has(ctx context.Context, id uint64) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, id uint64) (*Resolver, error)
	HasByUrlManager(ctx context.Context, url string, manager []byte) (found bool, err error)
	// GetByUrlManager returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	GetByUrlManager(ctx context.Context, url string, manager []byte) (*Resolver, error)
	List(ctx context.Context, prefixKey ResolverIndexKey, opts ...ormlist.Option) (ResolverIterator, error)
	ListRange(ctx context.Context, from, to ResolverIndexKey, opts ...ormlist.Option) (ResolverIterator, error)
	DeleteBy(ctx context.Context, prefixKey ResolverIndexKey) error
	DeleteRange(ctx context.Context, from, to ResolverIndexKey) error
	// contains filtered or unexported methods
}

func NewResolverTable

func NewResolverTable(db ormtable.Schema) (ResolverTable, error)

type ResolverUrlIndexKey

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

func (ResolverUrlIndexKey) WithUrl

type ResolverUrlManagerIndexKey

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

func (ResolverUrlManagerIndexKey) WithUrl

func (ResolverUrlManagerIndexKey) WithUrlManager

func (this ResolverUrlManagerIndexKey) WithUrlManager(url string, manager []byte) ResolverUrlManagerIndexKey

type StateStore

type StateStore interface {
	DataIDTable() DataIDTable
	DataAnchorTable() DataAnchorTable
	DataAttestorTable() DataAttestorTable
	ResolverTable() ResolverTable
	DataResolverTable() DataResolverTable
	// contains filtered or unexported methods
}

func NewStateStore

func NewStateStore(db ormtable.Schema) (StateStore, error)

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

func (UnimplementedMsgServer) Anchor

func (UnimplementedMsgServer) Attest

func (UnimplementedMsgServer) DefineResolver

func (UnimplementedMsgServer) RegisterResolver

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) ConvertHashToIRI

func (UnimplementedQueryServer) ConvertIRIToHash

func (UnimplementedQueryServer) Resolver

type UnsafeMsgServer

type UnsafeMsgServer interface {
	// contains filtered or unexported methods
}

UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.

type UnsafeQueryServer

type UnsafeQueryServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.

Jump to

Keyboard shortcuts

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