data

package module
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2021 License: Apache-2.0 Imports: 27 Imported by: 1

Documentation

Overview

Package data is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	IriPrefixRaw   byte = 0
	IriPrefixGraph byte = 1
)
View Source 
const DataCodespace = "regen.data"

Variables

View Source 
var (
	ErrHashVerificationFailed = sdkerrors.Register(DataCodespace, 1, "hash verification failed")
	ErrInvalidIRI             = sdkerrors.Register(DataCodespace, 2, "invalid IRI")
	ErrInvalidMediaExtension  = sdkerrors.Register(DataCodespace, 3, "invalid media extension")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DigestAlgorithm_name = map[int32]string{
	0: "DIGEST_ALGORITHM_UNSPECIFIED",
	1: "DIGEST_ALGORITHM_BLAKE2B_256",
}
View Source 
var DigestAlgorithm_value = map[string]int32{
	"DIGEST_ALGORITHM_UNSPECIFIED": 0,
	"DIGEST_ALGORITHM_BLAKE2B_256": 1,
}
View Source 
var DigestalgorithmLength = map[DigestAlgorithm]int{
	DigestAlgorithm_DIGEST_ALGORITHM_BLAKE2B_256: 256,
}
View Source 
var GraphCanonicalizationAlgorithm_name = map[int32]string{
	0: "GRAPH_CANONICALIZATION_ALGORITHM_UNSPECIFIED",
	1: "GRAPH_CANONICALIZATION_ALGORITHM_URDNA2015",
}
View Source 
var GraphCanonicalizationAlgorithm_value = map[string]int32{
	"GRAPH_CANONICALIZATION_ALGORITHM_UNSPECIFIED": 0,
	"GRAPH_CANONICALIZATION_ALGORITHM_URDNA2015":   1,
}
View Source 
var GraphMerkleTree_name = map[int32]string{
	0: "GRAPH_MERKLE_TREE_NONE_UNSPECIFIED",
}
View Source 
var GraphMerkleTree_value = map[string]int32{
	"GRAPH_MERKLE_TREE_NONE_UNSPECIFIED": 0,
}
View Source 
var MediaType_name = map[int32]string{
	0:  "MEDIA_TYPE_UNSPECIFIED",
	1:  "MEDIA_TYPE_TEXT_PLAIN",
	2:  "MEDIA_TYPE_JSON",
	3:  "MEDIA_TYPE_CSV",
	4:  "MEDIA_TYPE_XML",
	5:  "MEDIA_TYPE_PDF",
	16: "MEDIA_TYPE_TIFF",
	17: "MEDIA_TYPE_JPG",
	18: "MEDIA_TYPE_PNG",
	19: "MEDIA_TYPE_SVG",
	20: "MEDIA_TYPE_WEBP",
	21: "MEDIA_TYPE_AVIF",
	22: "MEDIA_TYPE_GIF",
	23: "MEDIA_TYPE_APNG",
	32: "MEDIA_TYPE_MPEG",
	33: "MEDIA_TYPE_MP4",
	34: "MEDIA_TYPE_WEBM",
	35: "MEDIA_TYPE_OGG",
}
View Source 
var MediaType_value = map[string]int32{
	"MEDIA_TYPE_UNSPECIFIED": 0,
	"MEDIA_TYPE_TEXT_PLAIN":  1,
	"MEDIA_TYPE_JSON":        2,
	"MEDIA_TYPE_CSV":         3,
	"MEDIA_TYPE_XML":         4,
	"MEDIA_TYPE_PDF":         5,
	"MEDIA_TYPE_TIFF":        16,
	"MEDIA_TYPE_JPG":         17,
	"MEDIA_TYPE_PNG":         18,
	"MEDIA_TYPE_SVG":         19,
	"MEDIA_TYPE_WEBP":        20,
	"MEDIA_TYPE_AVIF":        21,
	"MEDIA_TYPE_GIF":         22,
	"MEDIA_TYPE_APNG":        23,
	"MEDIA_TYPE_MPEG":        32,
	"MEDIA_TYPE_MP4":         33,
	"MEDIA_TYPE_WEBM":        34,
	"MEDIA_TYPE_OGG":         35,
}

Functions

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func RegisterTypes 

func RegisterTypes(registry types.InterfaceRegistry)

Types

type ContentEntry 

type ContentEntry struct {
	// hash is the content hash
	Hash *ContentHash `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// iri is the content IRI
	Iri string `protobuf:"bytes,2,opt,name=iri,proto3" json:"iri,omitempty"`
	// timestamp is the anchor Timestamp
	Timestamp *types.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

ContentEntry describes data referenced and possibly stored on chain

func (*ContentEntry) Descriptor 

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

func (*ContentEntry) GetHash 

func (m *ContentEntry) GetHash() *ContentHash

func (*ContentEntry) GetIri 

func (m *ContentEntry) GetIri() string

func (*ContentEntry) GetTimestamp 

func (m *ContentEntry) GetTimestamp() *types.Timestamp

func (*ContentEntry) Marshal 

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

func (*ContentEntry) MarshalTo 

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

func (*ContentEntry) MarshalToSizedBuffer 

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

func (*ContentEntry) ProtoMessage 

func (*ContentEntry) ProtoMessage()

func (*ContentEntry) Reset 

func (m *ContentEntry) Reset()

func (*ContentEntry) Size 

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

func (*ContentEntry) String 

func (m *ContentEntry) String() string

func (*ContentEntry) Unmarshal 

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

func (*ContentEntry) XXX_DiscardUnknown 

func (m *ContentEntry) XXX_DiscardUnknown()

func (*ContentEntry) XXX_Marshal 

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

func (*ContentEntry) XXX_Merge 

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

func (*ContentEntry) XXX_Size 

func (m *ContentEntry) XXX_Size() int

func (*ContentEntry) XXX_Unmarshal 

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

type ContentHash 

type ContentHash struct {
	// sum selects the type of content hash
	//
	// Types that are valid to be assigned to Sum:
	//	*ContentHash_Raw_
	//	*ContentHash_Graph_
	Sum isContentHash_Sum `protobuf_oneof:"sum"`
}

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

func ParseIRI 

func ParseIRI(iri string) (*ContentHash, error)

ParseIRI parses an IRI string representation of a ContentHash into a ContentHash struct Currently IRIs must have a "regen:" prefix, and only ContentHash_Graph and ContentHash_Raw are supported.

func (*ContentHash) Descriptor 

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

func (*ContentHash) GetGraph 

func (m *ContentHash) GetGraph() *ContentHash_Graph

func (*ContentHash) GetRaw 

func (m *ContentHash) GetRaw() *ContentHash_Raw

func (*ContentHash) GetSum 

func (m *ContentHash) GetSum() isContentHash_Sum

func (*ContentHash) Marshal 

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

func (*ContentHash) MarshalTo 

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

func (*ContentHash) MarshalToSizedBuffer 

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

func (*ContentHash) ProtoMessage 

func (*ContentHash) ProtoMessage()

func (*ContentHash) Reset 

func (m *ContentHash) Reset()

func (*ContentHash) Size 

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

func (*ContentHash) String 

func (m *ContentHash) String() string

func (ContentHash) ToIRI 

func (ch ContentHash) ToIRI() (string, error)

ToIRI converts the ContentHash to an IRI (internationalized URI) using the regen IRI scheme. A ContentHash IRI will look something like regen:113gdjFKcVCt13Za6vN7TtbgMM6LMSjRnu89BMCxeuHdkJ1hWUmy.rdf which is some base58check encoded data followed by a file extension or pseudo-extension. See ContentHash_Raw.ToIRI and ContentHash_Graph.ToIRI for more details on specific formatting.

func (*ContentHash) Unmarshal 

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

func (ContentHash) Validate 

func (ch ContentHash) Validate() error

func (*ContentHash) XXX_DiscardUnknown 

func (m *ContentHash) XXX_DiscardUnknown()

func (*ContentHash) XXX_Marshal 

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

func (*ContentHash) XXX_Merge 

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

func (*ContentHash) XXX_OneofWrappers 

func (*ContentHash) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ContentHash) XXX_Size 

func (m *ContentHash) XXX_Size() int

func (*ContentHash) XXX_Unmarshal 

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

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 `` /* 148-byte string literal not displayed */
	// graph_canonicalization_algorithm represents the RDF graph canonicalization algorithm.
	CanonicalizationAlgorithm GraphCanonicalizationAlgorithm `` /* 193-byte string literal not displayed */
	// merkle_tree is the merkle tree type used for the graph hash, if any
	MerkleTree GraphMerkleTree `` /* 133-byte string literal not displayed */
}

Graph is the content hash type used for RDF graph data

func (*ContentHash_Graph) Descriptor 

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

func (*ContentHash_Graph) GetCanonicalizationAlgorithm 

func (m *ContentHash_Graph) GetCanonicalizationAlgorithm() GraphCanonicalizationAlgorithm

func (*ContentHash_Graph) GetDigestAlgorithm 

func (m *ContentHash_Graph) GetDigestAlgorithm() DigestAlgorithm

func (*ContentHash_Graph) GetHash 

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

func (*ContentHash_Graph) GetMerkleTree 

func (m *ContentHash_Graph) GetMerkleTree() GraphMerkleTree

func (*ContentHash_Graph) Marshal 

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

func (*ContentHash_Graph) MarshalTo 

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

func (*ContentHash_Graph) MarshalToSizedBuffer 

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

func (*ContentHash_Graph) ProtoMessage 

func (*ContentHash_Graph) ProtoMessage()

func (*ContentHash_Graph) Reset 

func (m *ContentHash_Graph) Reset()

func (*ContentHash_Graph) Size 

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

func (*ContentHash_Graph) String 

func (m *ContentHash_Graph) String() string

func (ContentHash_Graph) ToIRI 

func (chg ContentHash_Graph) ToIRI() (string, error)

ToIRI converts the ContentHash_Graph to an IRI (internationalized URI) based on the following pattern: regen:{base58check(concat(byte(0x1), byte(canonicalization_algorithm), byte(merkle_tree), byte(digest_algorithm), hash))}.rdf

func (*ContentHash_Graph) Unmarshal 

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

func (ContentHash_Graph) Validate 

func (chg ContentHash_Graph) Validate() error

func (*ContentHash_Graph) XXX_DiscardUnknown 

func (m *ContentHash_Graph) XXX_DiscardUnknown()

func (*ContentHash_Graph) XXX_Marshal 

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

func (*ContentHash_Graph) XXX_Merge 

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

func (*ContentHash_Graph) XXX_Size 

func (m *ContentHash_Graph) XXX_Size() int

func (*ContentHash_Graph) XXX_Unmarshal 

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

type ContentHash_Graph_ 

type ContentHash_Graph_ struct {
	Graph *ContentHash_Graph `protobuf:"bytes,2,opt,name=graph,proto3,oneof" json:"graph,omitempty"`
}

func (*ContentHash_Graph_) MarshalTo 

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

func (*ContentHash_Graph_) MarshalToSizedBuffer 

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

func (*ContentHash_Graph_) Size 

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

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 `` /* 148-byte string literal not displayed */
	// media_type represents the MediaType for raw data.
	MediaType MediaType `protobuf:"varint,3,opt,name=media_type,json=mediaType,proto3,enum=regen.data.v1alpha2.MediaType" json:"media_type,omitempty"`
}

Raw is the content hash type used for raw data

func (*ContentHash_Raw) Descriptor 

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

func (*ContentHash_Raw) GetDigestAlgorithm 

func (m *ContentHash_Raw) GetDigestAlgorithm() DigestAlgorithm

func (*ContentHash_Raw) GetHash 

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

func (*ContentHash_Raw) GetMediaType 

func (m *ContentHash_Raw) GetMediaType() MediaType

func (*ContentHash_Raw) Marshal 

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

func (*ContentHash_Raw) MarshalTo 

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

func (*ContentHash_Raw) MarshalToSizedBuffer 

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

func (*ContentHash_Raw) ProtoMessage 

func (*ContentHash_Raw) ProtoMessage()

func (*ContentHash_Raw) Reset 

func (m *ContentHash_Raw) Reset()

func (*ContentHash_Raw) Size 

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

func (*ContentHash_Raw) String 

func (m *ContentHash_Raw) String() string

func (ContentHash_Raw) ToIRI 

func (chr ContentHash_Raw) ToIRI() (string, error)

ToIRI converts the ContentHash_Raw to an IRI (internationalized URI) based on the following pattern: regen:{base58check(concat( byte(0x0), byte(digest_algorithm), hash))}.{media_type extension}

func (*ContentHash_Raw) Unmarshal 

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

func (ContentHash_Raw) Validate 

func (chr ContentHash_Raw) Validate() error

func (*ContentHash_Raw) XXX_DiscardUnknown 

func (m *ContentHash_Raw) XXX_DiscardUnknown()

func (*ContentHash_Raw) XXX_Marshal 

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

func (*ContentHash_Raw) XXX_Merge 

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

func (*ContentHash_Raw) XXX_Size 

func (m *ContentHash_Raw) XXX_Size() int

func (*ContentHash_Raw) XXX_Unmarshal 

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

type ContentHash_Raw_ 

type ContentHash_Raw_ struct {
	Raw *ContentHash_Raw `protobuf:"bytes,1,opt,name=raw,proto3,oneof" json:"raw,omitempty"`
}

func (*ContentHash_Raw_) MarshalTo 

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

func (*ContentHash_Raw_) MarshalToSizedBuffer 

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

func (*ContentHash_Raw_) Size 

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

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

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

func (DigestAlgorithm) String 

func (x DigestAlgorithm) String() string

func (DigestAlgorithm) Validate 

func (x DigestAlgorithm) Validate(hash []byte) error

type EventAnchorData 

type EventAnchorData struct {
	// iri is the data IRI
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
}

EventAnchorData is an event emitted when data is anchored on-chain.

func (*EventAnchorData) Descriptor 

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

func (*EventAnchorData) GetIri 

func (m *EventAnchorData) GetIri() string

func (*EventAnchorData) Marshal 

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

func (*EventAnchorData) MarshalTo 

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

func (*EventAnchorData) MarshalToSizedBuffer 

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

func (*EventAnchorData) ProtoMessage 

func (*EventAnchorData) ProtoMessage()

func (*EventAnchorData) Reset 

func (m *EventAnchorData) Reset()

func (*EventAnchorData) Size 

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

func (*EventAnchorData) String 

func (m *EventAnchorData) String() string

func (*EventAnchorData) Unmarshal 

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

func (*EventAnchorData) XXX_DiscardUnknown 

func (m *EventAnchorData) XXX_DiscardUnknown()

func (*EventAnchorData) XXX_Marshal 

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

func (*EventAnchorData) XXX_Merge 

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

func (*EventAnchorData) XXX_Size 

func (m *EventAnchorData) XXX_Size() int

func (*EventAnchorData) XXX_Unmarshal 

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

type EventSignData 

type EventSignData struct {
	// iri is the data IRI
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// signers are the addresses of the accounts which have signed the data.
	Signers []string `protobuf:"bytes,2,rep,name=signers,proto3" json:"signers,omitempty"`
}

EventSignData is an event emitted when data is signed on-chain.

func (*EventSignData) Descriptor 

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

func (*EventSignData) GetIri 

func (m *EventSignData) GetIri() string

func (*EventSignData) GetSigners 

func (m *EventSignData) GetSigners() []string

func (*EventSignData) Marshal 

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

func (*EventSignData) MarshalTo 

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

func (*EventSignData) MarshalToSizedBuffer 

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

func (*EventSignData) ProtoMessage 

func (*EventSignData) ProtoMessage()

func (*EventSignData) Reset 

func (m *EventSignData) Reset()

func (*EventSignData) Size 

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

func (*EventSignData) String 

func (m *EventSignData) String() string

func (*EventSignData) Unmarshal 

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

func (*EventSignData) XXX_DiscardUnknown 

func (m *EventSignData) XXX_DiscardUnknown()

func (*EventSignData) XXX_Marshal 

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

func (*EventSignData) XXX_Merge 

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

func (*EventSignData) XXX_Size 

func (m *EventSignData) XXX_Size() int

func (*EventSignData) XXX_Unmarshal 

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

type EventStoreRawData 

type EventStoreRawData struct {
	// iri is the data IRI
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
}

EventStoreRawData is an event emitted when data is stored on-chain.

func (*EventStoreRawData) Descriptor 

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

func (*EventStoreRawData) GetIri 

func (m *EventStoreRawData) GetIri() string

func (*EventStoreRawData) Marshal 

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

func (*EventStoreRawData) MarshalTo 

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

func (*EventStoreRawData) MarshalToSizedBuffer 

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

func (*EventStoreRawData) ProtoMessage 

func (*EventStoreRawData) ProtoMessage()

func (*EventStoreRawData) Reset 

func (m *EventStoreRawData) Reset()

func (*EventStoreRawData) Size 

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

func (*EventStoreRawData) String 

func (m *EventStoreRawData) String() string

func (*EventStoreRawData) Unmarshal 

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

func (*EventStoreRawData) XXX_DiscardUnknown 

func (m *EventStoreRawData) XXX_DiscardUnknown()

func (*EventStoreRawData) XXX_Marshal 

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

func (*EventStoreRawData) XXX_Merge 

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

func (*EventStoreRawData) XXX_Size 

func (m *EventStoreRawData) XXX_Size() int

func (*EventStoreRawData) XXX_Unmarshal 

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

type GenesisContentEntry 

type GenesisContentEntry struct {
	// hash is the ContentHash
	Hash *ContentHash `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// timestamp is the anchor Timestamp
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// signers are the signers, if any
	Signers []*SignerEntry `protobuf:"bytes,3,rep,name=signers,proto3" json:"signers,omitempty"`
}

GenesisContentEntry is a genesis content entry

func (*GenesisContentEntry) Descriptor 

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

func (*GenesisContentEntry) GetHash 

func (m *GenesisContentEntry) GetHash() *ContentHash

func (*GenesisContentEntry) GetSigners 

func (m *GenesisContentEntry) GetSigners() []*SignerEntry

func (*GenesisContentEntry) GetTimestamp 

func (m *GenesisContentEntry) GetTimestamp() *types.Timestamp

func (*GenesisContentEntry) Marshal 

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

func (*GenesisContentEntry) MarshalTo 

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

func (*GenesisContentEntry) MarshalToSizedBuffer 

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

func (*GenesisContentEntry) ProtoMessage 

func (*GenesisContentEntry) ProtoMessage()

func (*GenesisContentEntry) Reset 

func (m *GenesisContentEntry) Reset()

func (*GenesisContentEntry) Size 

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

func (*GenesisContentEntry) String 

func (m *GenesisContentEntry) String() string

func (*GenesisContentEntry) Unmarshal 

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

func (*GenesisContentEntry) XXX_DiscardUnknown 

func (m *GenesisContentEntry) XXX_DiscardUnknown()

func (*GenesisContentEntry) XXX_Marshal 

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

func (*GenesisContentEntry) XXX_Merge 

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

func (*GenesisContentEntry) XXX_Size 

func (m *GenesisContentEntry) XXX_Size() int

func (*GenesisContentEntry) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// entries are the content entries
	Entries []*GenesisContentEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}

GenesisState is the genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetEntries 

func (m *GenesisState) GetEntries() []*GenesisContentEntry

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

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

func (GraphCanonicalizationAlgorithm) String 

func (x GraphCanonicalizationAlgorithm) String() string

func (GraphCanonicalizationAlgorithm) Validate 

func (x GraphCanonicalizationAlgorithm) Validate() error

type GraphMerkleTree 

type GraphMerkleTree int32

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

const (
	// no merkle tree
	GraphMerkleTree_GRAPH_MERKLE_TREE_NONE_UNSPECIFIED GraphMerkleTree = 0
)

func (GraphMerkleTree) EnumDescriptor 

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

func (GraphMerkleTree) String 

func (x GraphMerkleTree) String() string

func (GraphMerkleTree) Validate 

func (x GraphMerkleTree) Validate() error

type MediaType 

type MediaType int32

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

const (
	// MEDIA_TYPE_UNSPECIFIED can be used for raw binary data
	MediaType_MEDIA_TYPE_UNSPECIFIED MediaType = 0
	// plain text
	MediaType_MEDIA_TYPE_TEXT_PLAIN MediaType = 1
	// JSON
	MediaType_MEDIA_TYPE_JSON MediaType = 2
	// CSV
	MediaType_MEDIA_TYPE_CSV MediaType = 3
	// XML
	MediaType_MEDIA_TYPE_XML MediaType = 4
	// PDF
	MediaType_MEDIA_TYPE_PDF MediaType = 5
	// TIIF
	MediaType_MEDIA_TYPE_TIFF MediaType = 16
	// JPG
	MediaType_MEDIA_TYPE_JPG MediaType = 17
	// PNG
	MediaType_MEDIA_TYPE_PNG MediaType = 18
	// SVG
	MediaType_MEDIA_TYPE_SVG MediaType = 19
	// WEBP
	MediaType_MEDIA_TYPE_WEBP MediaType = 20
	// AVIF
	MediaType_MEDIA_TYPE_AVIF MediaType = 21
	// GIF
	MediaType_MEDIA_TYPE_GIF MediaType = 22
	// APNG
	MediaType_MEDIA_TYPE_APNG MediaType = 23
	// MPEG
	MediaType_MEDIA_TYPE_MPEG MediaType = 32
	// MP4
	MediaType_MEDIA_TYPE_MP4 MediaType = 33
	// WEBM
	MediaType_MEDIA_TYPE_WEBM MediaType = 34
	// OGG
	MediaType_MEDIA_TYPE_OGG MediaType = 35
)

func (MediaType) EnumDescriptor 

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

func (MediaType) String 

func (x MediaType) String() string

func (MediaType) ToExtension 

func (mt MediaType) ToExtension() (string, error)

ToExtension converts the media type to a file extension based on the mediaTypeExtensions map.

func (MediaType) Validate 

func (x MediaType) Validate() error

type MsgAnchorData 

type MsgAnchorData struct {
	// sender is the address of the sender of the transaction.
	// The sender in StoreData is not attesting to the veracity of the underlying
	// data. They can simply be a intermediary providing services.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// hash is the hash-based identifier for the anchored content.
	Hash *ContentHash `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
}

MsgAnchorData is the Msg/AnchorData request type.

func (*MsgAnchorData) Descriptor 

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

func (*MsgAnchorData) GetHash 

func (m *MsgAnchorData) GetHash() *ContentHash

func (*MsgAnchorData) GetSender 

func (m *MsgAnchorData) GetSender() string

func (*MsgAnchorData) GetSigners 

func (m *MsgAnchorData) GetSigners() []sdk.AccAddress

func (*MsgAnchorData) Marshal 

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

func (*MsgAnchorData) MarshalTo 

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

func (*MsgAnchorData) MarshalToSizedBuffer 

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

func (*MsgAnchorData) ProtoMessage 

func (*MsgAnchorData) ProtoMessage()

func (*MsgAnchorData) Reset 

func (m *MsgAnchorData) Reset()

func (*MsgAnchorData) Size 

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

func (*MsgAnchorData) String 

func (m *MsgAnchorData) String() string

func (*MsgAnchorData) Unmarshal 

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

func (*MsgAnchorData) ValidateBasic 

func (m *MsgAnchorData) ValidateBasic() error

func (*MsgAnchorData) XXX_DiscardUnknown 

func (m *MsgAnchorData) XXX_DiscardUnknown()

func (*MsgAnchorData) XXX_Marshal 

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

func (*MsgAnchorData) XXX_Merge 

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

func (*MsgAnchorData) XXX_Size 

func (m *MsgAnchorData) XXX_Size() int

func (*MsgAnchorData) XXX_Unmarshal 

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

type MsgAnchorDataResponse 

type MsgAnchorDataResponse struct {
	// timestamp is the timestamp of the block at which the data was anchored.
	Timestamp *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// iri is the IRI of the data that was anchored.
	Iri string `protobuf:"bytes,2,opt,name=iri,proto3" json:"iri,omitempty"`
}

MsgAnchorData is the Msg/AnchorData response type.

func (*MsgAnchorDataResponse) Descriptor 

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

func (*MsgAnchorDataResponse) GetIri 

func (m *MsgAnchorDataResponse) GetIri() string

func (*MsgAnchorDataResponse) GetTimestamp 

func (m *MsgAnchorDataResponse) GetTimestamp() *types.Timestamp

func (*MsgAnchorDataResponse) Marshal 

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

func (*MsgAnchorDataResponse) MarshalTo 

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

func (*MsgAnchorDataResponse) MarshalToSizedBuffer 

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

func (*MsgAnchorDataResponse) ProtoMessage 

func (*MsgAnchorDataResponse) ProtoMessage()

func (*MsgAnchorDataResponse) Reset 

func (m *MsgAnchorDataResponse) Reset()

func (*MsgAnchorDataResponse) Size 

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

func (*MsgAnchorDataResponse) String 

func (m *MsgAnchorDataResponse) String() string

func (*MsgAnchorDataResponse) Unmarshal 

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

func (*MsgAnchorDataResponse) XXX_DiscardUnknown 

func (m *MsgAnchorDataResponse) XXX_DiscardUnknown()

func (*MsgAnchorDataResponse) XXX_Marshal 

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

func (*MsgAnchorDataResponse) XXX_Merge 

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

func (*MsgAnchorDataResponse) XXX_Size 

func (m *MsgAnchorDataResponse) XXX_Size() int

func (*MsgAnchorDataResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// AnchorData "anchors" a piece of data to the blockchain based on its secure
	// hash, effectively providing a tamper resistant timestamp.
	//
	// The sender in AnchorData is not attesting to the veracity of the underlying
	// data. They can simply be a intermediary providing timestamp services.
	// SignData should be used to create a digital signature attesting to the
	// veracity of some piece of data.
	AnchorData(ctx context.Context, in *MsgAnchorData, opts ...grpc.CallOption) (*MsgAnchorDataResponse, error)
	// SignData allows for signing of an arbitrary piece of data on the
	// blockchain. By "signing" data the signers are 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
	//
	// SignData implicitly calls AnchorData if the data was not already anchored.
	//
	// SignData can be called multiple times for the same content hash with different
	// signers and those signers will be appended to the list of signers.
	SignData(ctx context.Context, in *MsgSignData, opts ...grpc.CallOption) (*MsgSignDataResponse, 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 MsgServer 

type MsgServer interface {
	// AnchorData "anchors" a piece of data to the blockchain based on its secure
	// hash, effectively providing a tamper resistant timestamp.
	//
	// The sender in AnchorData is not attesting to the veracity of the underlying
	// data. They can simply be a intermediary providing timestamp services.
	// SignData should be used to create a digital signature attesting to the
	// veracity of some piece of data.
	AnchorData(context.Context, *MsgAnchorData) (*MsgAnchorDataResponse, error)
	// SignData allows for signing of an arbitrary piece of data on the
	// blockchain. By "signing" data the signers are 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
	//
	// SignData implicitly calls AnchorData if the data was not already anchored.
	//
	// SignData can be called multiple times for the same content hash with different
	// signers and those signers will be appended to the list of signers.
	SignData(context.Context, *MsgSignData) (*MsgSignDataResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSignData 

type MsgSignData struct {
	// signers are the addresses of the accounts signing the data.
	// By making a SignData request, the signers are attesting to the veracity
	// of the data referenced by the cid. The precise meaning of this may vary
	// depending on the underlying data.
	Signers []string `protobuf:"bytes,1,rep,name=signers,proto3" json:"signers,omitempty"`
	// hash is the hash-based identifier for the anchored content. Only RDF graph
	// data can be signed as its data model is intended to specifically convey semantic meaning.
	Hash *ContentHash_Graph `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
}

MsgSignData is the Msg/SignData request type.

func (*MsgSignData) Descriptor 

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

func (*MsgSignData) GetSigners 

func (m *MsgSignData) GetSigners() []sdk.AccAddress

func (*MsgSignData) Marshal 

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

func (*MsgSignData) MarshalTo 

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

func (*MsgSignData) MarshalToSizedBuffer 

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

func (*MsgSignData) ProtoMessage 

func (*MsgSignData) ProtoMessage()

func (*MsgSignData) Reset 

func (m *MsgSignData) Reset()

func (*MsgSignData) Size 

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

func (*MsgSignData) String 

func (m *MsgSignData) String() string

func (*MsgSignData) Unmarshal 

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

func (*MsgSignData) ValidateBasic 

func (m *MsgSignData) ValidateBasic() error

func (*MsgSignData) XXX_DiscardUnknown 

func (m *MsgSignData) XXX_DiscardUnknown()

func (*MsgSignData) XXX_Marshal 

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

func (*MsgSignData) XXX_Merge 

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

func (*MsgSignData) XXX_Size 

func (m *MsgSignData) XXX_Size() int

func (*MsgSignData) XXX_Unmarshal 

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

type MsgSignDataResponse 

type MsgSignDataResponse struct {
}

MsgSignDataResponse is the Msg/SignData response type.

func (*MsgSignDataResponse) Descriptor 

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

func (*MsgSignDataResponse) Marshal 

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

func (*MsgSignDataResponse) MarshalTo 

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

func (*MsgSignDataResponse) MarshalToSizedBuffer 

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

func (*MsgSignDataResponse) ProtoMessage 

func (*MsgSignDataResponse) ProtoMessage()

func (*MsgSignDataResponse) Reset 

func (m *MsgSignDataResponse) Reset()

func (*MsgSignDataResponse) Size 

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

func (*MsgSignDataResponse) String 

func (m *MsgSignDataResponse) String() string

func (*MsgSignDataResponse) Unmarshal 

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

func (*MsgSignDataResponse) XXX_DiscardUnknown 

func (m *MsgSignDataResponse) XXX_DiscardUnknown()

func (*MsgSignDataResponse) XXX_Marshal 

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

func (*MsgSignDataResponse) XXX_Merge 

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

func (*MsgSignDataResponse) XXX_Size 

func (m *MsgSignDataResponse) XXX_Size() int

func (*MsgSignDataResponse) XXX_Unmarshal 

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

type QueryByIRIRequest 

type QueryByIRIRequest struct {
	// hash is the hash-based identifier for the anchored content.
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
}

QueryByContentHashRequest is the Query/ByContentHash request type.

func (*QueryByIRIRequest) Descriptor 

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

func (*QueryByIRIRequest) GetIri 

func (m *QueryByIRIRequest) GetIri() string

func (*QueryByIRIRequest) Marshal 

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

func (*QueryByIRIRequest) MarshalTo 

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

func (*QueryByIRIRequest) MarshalToSizedBuffer 

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

func (*QueryByIRIRequest) ProtoMessage 

func (*QueryByIRIRequest) ProtoMessage()

func (*QueryByIRIRequest) Reset 

func (m *QueryByIRIRequest) Reset()

func (*QueryByIRIRequest) Size 

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

func (*QueryByIRIRequest) String 

func (m *QueryByIRIRequest) String() string

func (*QueryByIRIRequest) Unmarshal 

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

func (*QueryByIRIRequest) XXX_DiscardUnknown 

func (m *QueryByIRIRequest) XXX_DiscardUnknown()

func (*QueryByIRIRequest) XXX_Marshal 

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

func (*QueryByIRIRequest) XXX_Merge 

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

func (*QueryByIRIRequest) XXX_Size 

func (m *QueryByIRIRequest) XXX_Size() int

func (*QueryByIRIRequest) XXX_Unmarshal 

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

type QueryByIRIResponse 

type QueryByIRIResponse struct {
	// entry is the ContentEntry
	Entry *ContentEntry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
}

QueryByContentHashResponse is the Query/ByContentHash response type.

func (*QueryByIRIResponse) Descriptor 

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

func (*QueryByIRIResponse) GetEntry 

func (m *QueryByIRIResponse) GetEntry() *ContentEntry

func (*QueryByIRIResponse) Marshal 

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

func (*QueryByIRIResponse) MarshalTo 

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

func (*QueryByIRIResponse) MarshalToSizedBuffer 

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

func (*QueryByIRIResponse) ProtoMessage 

func (*QueryByIRIResponse) ProtoMessage()

func (*QueryByIRIResponse) Reset 

func (m *QueryByIRIResponse) Reset()

func (*QueryByIRIResponse) Size 

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

func (*QueryByIRIResponse) String 

func (m *QueryByIRIResponse) String() string

func (*QueryByIRIResponse) Unmarshal 

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

func (*QueryByIRIResponse) XXX_DiscardUnknown 

func (m *QueryByIRIResponse) XXX_DiscardUnknown()

func (*QueryByIRIResponse) XXX_Marshal 

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

func (*QueryByIRIResponse) XXX_Merge 

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

func (*QueryByIRIResponse) XXX_Size 

func (m *QueryByIRIResponse) XXX_Size() int

func (*QueryByIRIResponse) XXX_Unmarshal 

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

type QueryBySignerRequest 

type QueryBySignerRequest struct {
	// signer is the address of the signer to query by.
	Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryBySignerRequest is the Query/BySigner request type.

func (*QueryBySignerRequest) Descriptor 

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

func (*QueryBySignerRequest) GetPagination 

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

func (*QueryBySignerRequest) GetSigner 

func (m *QueryBySignerRequest) GetSigner() string

func (*QueryBySignerRequest) Marshal 

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

func (*QueryBySignerRequest) MarshalTo 

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

func (*QueryBySignerRequest) MarshalToSizedBuffer 

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

func (*QueryBySignerRequest) ProtoMessage 

func (*QueryBySignerRequest) ProtoMessage()

func (*QueryBySignerRequest) Reset 

func (m *QueryBySignerRequest) Reset()

func (*QueryBySignerRequest) Size 

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

func (*QueryBySignerRequest) String 

func (m *QueryBySignerRequest) String() string

func (*QueryBySignerRequest) Unmarshal 

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

func (*QueryBySignerRequest) XXX_DiscardUnknown 

func (m *QueryBySignerRequest) XXX_DiscardUnknown()

func (*QueryBySignerRequest) XXX_Marshal 

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

func (*QueryBySignerRequest) XXX_Merge 

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

func (*QueryBySignerRequest) XXX_Size 

func (m *QueryBySignerRequest) XXX_Size() int

func (*QueryBySignerRequest) XXX_Unmarshal 

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

type QueryBySignerResponse 

type QueryBySignerResponse struct {
	// entries is the ContentEntry's signed by the queried signer
	Entries []*ContentEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// pagination is the pagination PageResponse.
	Pagination *query.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryBySignerResponse is the Query/BySigner response type.

func (*QueryBySignerResponse) Descriptor 

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

func (*QueryBySignerResponse) GetEntries 

func (m *QueryBySignerResponse) GetEntries() []*ContentEntry

func (*QueryBySignerResponse) GetPagination 

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

func (*QueryBySignerResponse) Marshal 

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

func (*QueryBySignerResponse) MarshalTo 

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

func (*QueryBySignerResponse) MarshalToSizedBuffer 

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

func (*QueryBySignerResponse) ProtoMessage 

func (*QueryBySignerResponse) ProtoMessage()

func (*QueryBySignerResponse) Reset 

func (m *QueryBySignerResponse) Reset()

func (*QueryBySignerResponse) Size 

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

func (*QueryBySignerResponse) String 

func (m *QueryBySignerResponse) String() string

func (*QueryBySignerResponse) Unmarshal 

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

func (*QueryBySignerResponse) XXX_DiscardUnknown 

func (m *QueryBySignerResponse) XXX_DiscardUnknown()

func (*QueryBySignerResponse) XXX_Marshal 

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

func (*QueryBySignerResponse) XXX_Merge 

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

func (*QueryBySignerResponse) XXX_Size 

func (m *QueryBySignerResponse) XXX_Size() int

func (*QueryBySignerResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// ByHash queries data based on its ContentHash.
	ByIRI(ctx context.Context, in *QueryByIRIRequest, opts ...grpc.CallOption) (*QueryByIRIResponse, error)
	// BySigner queries data based on signers.
	BySigner(ctx context.Context, in *QueryBySignerRequest, opts ...grpc.CallOption) (*QueryBySignerResponse, error)
	// Signers queries signers based on IRI.
	Signers(ctx context.Context, in *QuerySignersRequest, opts ...grpc.CallOption) (*QuerySignersResponse, 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 QueryServer 

type QueryServer interface {
	// ByHash queries data based on its ContentHash.
	ByIRI(context.Context, *QueryByIRIRequest) (*QueryByIRIResponse, error)
	// BySigner queries data based on signers.
	BySigner(context.Context, *QueryBySignerRequest) (*QueryBySignerResponse, error)
	// Signers queries signers based on IRI.
	Signers(context.Context, *QuerySignersRequest) (*QuerySignersResponse, error)
}

QueryServer is the server API for Query service.

type QuerySignersRequest 

type QuerySignersRequest struct {
	// iri is the content IRI
	Iri string `protobuf:"bytes,1,opt,name=iri,proto3" json:"iri,omitempty"`
	// pagination is the PageRequest to use for pagination.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySignersRequest is the Query/Signers request type.

func (*QuerySignersRequest) Descriptor 

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

func (*QuerySignersRequest) GetIri 

func (m *QuerySignersRequest) GetIri() string

func (*QuerySignersRequest) GetPagination 

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

func (*QuerySignersRequest) Marshal 

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

func (*QuerySignersRequest) MarshalTo 

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

func (*QuerySignersRequest) MarshalToSizedBuffer 

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

func (*QuerySignersRequest) ProtoMessage 

func (*QuerySignersRequest) ProtoMessage()

func (*QuerySignersRequest) Reset 

func (m *QuerySignersRequest) Reset()

func (*QuerySignersRequest) Size 

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

func (*QuerySignersRequest) String 

func (m *QuerySignersRequest) String() string

func (*QuerySignersRequest) Unmarshal 

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

func (*QuerySignersRequest) XXX_DiscardUnknown 

func (m *QuerySignersRequest) XXX_DiscardUnknown()

func (*QuerySignersRequest) XXX_Marshal 

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

func (*QuerySignersRequest) XXX_Merge 

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

func (*QuerySignersRequest) XXX_Size 

func (m *QuerySignersRequest) XXX_Size() int

func (*QuerySignersRequest) XXX_Unmarshal 

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

type QuerySignersResponse 

type QuerySignersResponse struct {
	// signers are the addresses of the signers.
	Signers []string `protobuf:"bytes,1,rep,name=signers,proto3" json:"signers,omitempty"`
	// pagination is the pagination PageResponse.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySignersResponse is the Query/QuerySigners response type.

func (*QuerySignersResponse) Descriptor 

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

func (*QuerySignersResponse) GetPagination 

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

func (*QuerySignersResponse) GetSigners 

func (m *QuerySignersResponse) GetSigners() []string

func (*QuerySignersResponse) Marshal 

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

func (*QuerySignersResponse) MarshalTo 

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

func (*QuerySignersResponse) MarshalToSizedBuffer 

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

func (*QuerySignersResponse) ProtoMessage 

func (*QuerySignersResponse) ProtoMessage()

func (*QuerySignersResponse) Reset 

func (m *QuerySignersResponse) Reset()

func (*QuerySignersResponse) Size 

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

func (*QuerySignersResponse) String 

func (m *QuerySignersResponse) String() string

func (*QuerySignersResponse) Unmarshal 

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

func (*QuerySignersResponse) XXX_DiscardUnknown 

func (m *QuerySignersResponse) XXX_DiscardUnknown()

func (*QuerySignersResponse) XXX_Marshal 

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

func (*QuerySignersResponse) XXX_Merge 

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

func (*QuerySignersResponse) XXX_Size 

func (m *QuerySignersResponse) XXX_Size() int

func (*QuerySignersResponse) XXX_Unmarshal 

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

type SignerEntry 

type SignerEntry struct {
	// signer is the address of the signer
	Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	// timestamp is the time at which the data was signed
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

SignerEntry is a signer entry wrapping a signer address and timestamp

func (*SignerEntry) Descriptor 

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

func (*SignerEntry) GetSigner 

func (m *SignerEntry) GetSigner() string

func (*SignerEntry) GetTimestamp 

func (m *SignerEntry) GetTimestamp() *types.Timestamp

func (*SignerEntry) Marshal 

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

func (*SignerEntry) MarshalTo 

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

func (*SignerEntry) MarshalToSizedBuffer 

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

func (*SignerEntry) ProtoMessage 

func (*SignerEntry) ProtoMessage()

func (*SignerEntry) Reset 

func (m *SignerEntry) Reset()

func (*SignerEntry) Size 

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

func (*SignerEntry) String 

func (m *SignerEntry) String() string

func (*SignerEntry) Unmarshal 

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

func (*SignerEntry) XXX_DiscardUnknown 

func (m *SignerEntry) XXX_DiscardUnknown()

func (*SignerEntry) XXX_Marshal 

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

func (*SignerEntry) XXX_Merge 

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

func (*SignerEntry) XXX_Size 

func (m *SignerEntry) XXX_Size() int

func (*SignerEntry) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AnchorData 

func (*UnimplementedMsgServer) AnchorData(ctx context.Context, req *MsgAnchorData) (*MsgAnchorDataResponse, error)

func (*UnimplementedMsgServer) SignData 

func (*UnimplementedMsgServer) SignData(ctx context.Context, req *MsgSignData) (*MsgSignDataResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ByIRI 

func (*UnimplementedQueryServer) ByIRI(ctx context.Context, req *QueryByIRIRequest) (*QueryByIRIResponse, error)

func (*UnimplementedQueryServer) BySigner 

func (*UnimplementedQueryServer) BySigner(ctx context.Context, req *QueryBySignerRequest) (*QueryBySignerResponse, error)

func (*UnimplementedQueryServer) Signers 

func (*UnimplementedQueryServer) Signers(ctx context.Context, req *QuerySignersRequest) (*QuerySignersResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
testsuite
lookup
Package lookup provides a key-value store backed data structure which finds and stores a short, unique binary identifier for a longer piece of binary data using an efficient, non-cryptographic hash function.
 Package lookup provides a key-value store backed data structure which finds and stores a short, unique binary identifier for a longer piece of binary data using an efficient, non-cryptographic hash function.
testsuite

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.