api

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2020 License: AGPL-3.0 Imports: 18 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// MaxDataChunkSize is the buffer size used in data stream handling
	MaxDataChunkSize = 1024 // bytes
)

Variables

View Source 
var Trie_StorageType_name = map[int32]string{
	0: "LOCAL",
	1: "CLOUD",
}
View Source 
var Trie_StorageType_value = map[string]int32{
	"LOCAL": 0,
	"CLOUD": 1,
}

Functions

func Compress 

func Compress(path string, w io.Writer) (er error)

Compress compresses the filesystem in the path as tar.gz stream and writes to the given writer

func Decompress 

func Decompress(path string, r io.Reader) (er error)

Decompress reads from the given reader and decompresses the tar.gz stream back to the filesystem in the path

func NewDataStreamReader 

func NewDataStreamReader(
	dsr DataStreamReciever,
	onMetadata func(md DataChunkMetadata) error,
) io.ReadCloser

NewDataStreamReader creates an io.ReadCloser out of the DataStreamReciever

func NewDataStreamWriter 

func NewDataStreamWriter(
	dss DataStreamSender,
	onMetadata func() (md DataChunkMetadata, er error),
) io.WriteCloser

NewDataStreamWriter creates an io.WriteCloser out of the DataStreamSender

func RegisterAPIServiceServer 

func RegisterAPIServiceServer(s *grpc.Server, srv APIServiceServer)

Types

type APIServiceClient 

type APIServiceClient interface {
	// GetTries gets all tries. Admin privilege is required
	GetTries(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (APIService_GetTriesClient, error)
	// GetTrie gets a trie
	GetTrie(ctx context.Context, in *TrieRequest, opts ...grpc.CallOption) (*Trie, error)
	// ImportTrie creates a new trie from existing trie data. If the trie ID is
	// not provided in the metadata, a new one will be generated
	ImportTrie(ctx context.Context, opts ...grpc.CallOption) (APIService_ImportTrieClient, error)
	// ExportTrie exports a trie's data
	ExportTrie(ctx context.Context, in *TrieRequest, opts ...grpc.CallOption) (APIService_ExportTrieClient, error)
	// CreateTrie creates an empty trie
	CreateTrie(ctx context.Context, in *CreateTrieRequest, opts ...grpc.CallOption) (*Trie, error)
	// DeleteTrie deletes a trie. This destroys everything of a trie
	DeleteTrie(ctx context.Context, in *TrieRequest, opts ...grpc.CallOption) (*Trie, error)
	// GetTrieKeyValues gets key-values of a trie. The returned KeyValues are
	// ordered by the keys lexicographically
	GetTrieKeyValues(ctx context.Context, in *TrieKeyValuesRequest, opts ...grpc.CallOption) (APIService_GetTrieKeyValuesClient, error)
	// GetTrieKeyValue gets a key-value of a trie
	GetTrieKeyValue(ctx context.Context, in *TrieKeyValueRequest, opts ...grpc.CallOption) (*KeyValue, error)
	// SetTrieKeyValues sets key-values of a trie. Set an empty value for a key to
	// remove that key. Modifications to a trie will change its root hash
	SetTrieKeyValues(ctx context.Context, opts ...grpc.CallOption) (APIService_SetTrieKeyValuesClient, error)
	// GetTrieRoots gets roots of a trie. This is a series of roots showing the
	// modification history of a trie
	GetTrieRoots(ctx context.Context, in *TrieRootsRequest, opts ...grpc.CallOption) (APIService_GetTrieRootsClient, error)
	// SetTrieRoot sets the root of a trie to the given one. This will add an
	// entry in the root history
	SetTrieRoot(ctx context.Context, in *SetTrieRootRequest, opts ...grpc.CallOption) (*Trie, error)
	// SetTrieStorageType sets the storage type of a trie
	SetTrieStorageType(ctx context.Context, in *SetTrieStorageTypeRequest, opts ...grpc.CallOption) (*Trie, error)
	// GetTrieProofs gets proofs of a trie
	GetTrieProofs(ctx context.Context, in *TrieProofsRequest, opts ...grpc.CallOption) (APIService_GetTrieProofsClient, error)
	// GetTrieProof gets a proof of a trie. When not_before is not provided
	// (either nil or zero), the latest proof will be returned
	GetTrieProof(ctx context.Context, in *TrieProofRequest, opts ...grpc.CallOption) (*TrieProof, error)
	// SubscribeTrieProof subscribes to proof changes of a trie. When not_before
	// is not provided (either nil or zero), the latest proof will be returned
	SubscribeTrieProof(ctx context.Context, in *TrieProofRequest, opts ...grpc.CallOption) (APIService_SubscribeTrieProofClient, error)
	// CreateTrieProof creates a proof for a trie root
	CreateTrieProof(ctx context.Context, in *CreateTrieProofRequest, opts ...grpc.CallOption) (*TrieProof, error)
	// DeleteTrieProof deletes a proof for a trie root
	DeleteTrieProof(ctx context.Context, in *DeleteTrieProofRequest, opts ...grpc.CallOption) (*TrieProof, error)
	// VerifyTrieProof verifies a proof for a trie root
	VerifyTrieProof(ctx context.Context, in *VerifyTrieProofRequest, opts ...grpc.CallOption) (APIService_VerifyTrieProofClient, error)
	// CreateKeyValuesProof creates a proof for the provided key-values out of a
	// trie proof. The new proof is self-contained and can be verified
	// independently
	CreateKeyValuesProof(ctx context.Context, in *CreateKeyValuesProofRequest, opts ...grpc.CallOption) (APIService_CreateKeyValuesProofClient, error)
	// VerifyKeyValuesProof verifies a key-values proof
	VerifyKeyValuesProof(ctx context.Context, opts ...grpc.CallOption) (APIService_VerifyKeyValuesProofClient, error)
}

APIServiceClient is the client API for APIService service.

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

func NewAPIServiceClient 

func NewAPIServiceClient(cc *grpc.ClientConn) APIServiceClient

type APIServiceServer 

type APIServiceServer interface {
	// GetTries gets all tries. Admin privilege is required
	GetTries(*empty.Empty, APIService_GetTriesServer) error
	// GetTrie gets a trie
	GetTrie(context.Context, *TrieRequest) (*Trie, error)
	// ImportTrie creates a new trie from existing trie data. If the trie ID is
	// not provided in the metadata, a new one will be generated
	ImportTrie(APIService_ImportTrieServer) error
	// ExportTrie exports a trie's data
	ExportTrie(*TrieRequest, APIService_ExportTrieServer) error
	// CreateTrie creates an empty trie
	CreateTrie(context.Context, *CreateTrieRequest) (*Trie, error)
	// DeleteTrie deletes a trie. This destroys everything of a trie
	DeleteTrie(context.Context, *TrieRequest) (*Trie, error)
	// GetTrieKeyValues gets key-values of a trie. The returned KeyValues are
	// ordered by the keys lexicographically
	GetTrieKeyValues(*TrieKeyValuesRequest, APIService_GetTrieKeyValuesServer) error
	// GetTrieKeyValue gets a key-value of a trie
	GetTrieKeyValue(context.Context, *TrieKeyValueRequest) (*KeyValue, error)
	// SetTrieKeyValues sets key-values of a trie. Set an empty value for a key to
	// remove that key. Modifications to a trie will change its root hash
	SetTrieKeyValues(APIService_SetTrieKeyValuesServer) error
	// GetTrieRoots gets roots of a trie. This is a series of roots showing the
	// modification history of a trie
	GetTrieRoots(*TrieRootsRequest, APIService_GetTrieRootsServer) error
	// SetTrieRoot sets the root of a trie to the given one. This will add an
	// entry in the root history
	SetTrieRoot(context.Context, *SetTrieRootRequest) (*Trie, error)
	// SetTrieStorageType sets the storage type of a trie
	SetTrieStorageType(context.Context, *SetTrieStorageTypeRequest) (*Trie, error)
	// GetTrieProofs gets proofs of a trie
	GetTrieProofs(*TrieProofsRequest, APIService_GetTrieProofsServer) error
	// GetTrieProof gets a proof of a trie. When not_before is not provided
	// (either nil or zero), the latest proof will be returned
	GetTrieProof(context.Context, *TrieProofRequest) (*TrieProof, error)
	// SubscribeTrieProof subscribes to proof changes of a trie. When not_before
	// is not provided (either nil or zero), the latest proof will be returned
	SubscribeTrieProof(*TrieProofRequest, APIService_SubscribeTrieProofServer) error
	// CreateTrieProof creates a proof for a trie root
	CreateTrieProof(context.Context, *CreateTrieProofRequest) (*TrieProof, error)
	// DeleteTrieProof deletes a proof for a trie root
	DeleteTrieProof(context.Context, *DeleteTrieProofRequest) (*TrieProof, error)
	// VerifyTrieProof verifies a proof for a trie root
	VerifyTrieProof(*VerifyTrieProofRequest, APIService_VerifyTrieProofServer) error
	// CreateKeyValuesProof creates a proof for the provided key-values out of a
	// trie proof. The new proof is self-contained and can be verified
	// independently
	CreateKeyValuesProof(*CreateKeyValuesProofRequest, APIService_CreateKeyValuesProofServer) error
	// VerifyKeyValuesProof verifies a key-values proof
	VerifyKeyValuesProof(APIService_VerifyKeyValuesProofServer) error
}

APIServiceServer is the server API for APIService service.

type APIService_CreateKeyValuesProofClient 

type APIService_CreateKeyValuesProofClient interface {
	Recv() (*DataChunk, error)
	grpc.ClientStream
}

type APIService_CreateKeyValuesProofServer 

type APIService_CreateKeyValuesProofServer interface {
	Send(*DataChunk) error
	grpc.ServerStream
}

type APIService_ExportTrieClient 

type APIService_ExportTrieClient interface {
	Recv() (*DataChunk, error)
	grpc.ClientStream
}

type APIService_ExportTrieServer 

type APIService_ExportTrieServer interface {
	Send(*DataChunk) error
	grpc.ServerStream
}

type APIService_GetTrieKeyValuesClient 

type APIService_GetTrieKeyValuesClient interface {
	Recv() (*KeyValue, error)
	grpc.ClientStream
}

type APIService_GetTrieKeyValuesServer 

type APIService_GetTrieKeyValuesServer interface {
	Send(*KeyValue) error
	grpc.ServerStream
}

type APIService_GetTrieProofsClient 

type APIService_GetTrieProofsClient interface {
	Recv() (*TrieProof, error)
	grpc.ClientStream
}

type APIService_GetTrieProofsServer 

type APIService_GetTrieProofsServer interface {
	Send(*TrieProof) error
	grpc.ServerStream
}

type APIService_GetTrieRootsClient 

type APIService_GetTrieRootsClient interface {
	Recv() (*TrieRoot, error)
	grpc.ClientStream
}

type APIService_GetTrieRootsServer 

type APIService_GetTrieRootsServer interface {
	Send(*TrieRoot) error
	grpc.ServerStream
}

type APIService_GetTriesClient 

type APIService_GetTriesClient interface {
	Recv() (*Trie, error)
	grpc.ClientStream
}

type APIService_GetTriesServer 

type APIService_GetTriesServer interface {
	Send(*Trie) error
	grpc.ServerStream
}

type APIService_ImportTrieClient 

type APIService_ImportTrieClient interface {
	Send(*DataChunk) error
	CloseAndRecv() (*Trie, error)
	grpc.ClientStream
}

type APIService_ImportTrieServer 

type APIService_ImportTrieServer interface {
	SendAndClose(*Trie) error
	Recv() (*DataChunk, error)
	grpc.ServerStream
}

type APIService_SetTrieKeyValuesClient 

type APIService_SetTrieKeyValuesClient interface {
	Send(*KeyValue) error
	CloseAndRecv() (*Trie, error)
	grpc.ClientStream
}

type APIService_SetTrieKeyValuesServer 

type APIService_SetTrieKeyValuesServer interface {
	SendAndClose(*Trie) error
	Recv() (*KeyValue, error)
	grpc.ServerStream
}

type APIService_SubscribeTrieProofClient 

type APIService_SubscribeTrieProofClient interface {
	Recv() (*TrieProof, error)
	grpc.ClientStream
}

type APIService_SubscribeTrieProofServer 

type APIService_SubscribeTrieProofServer interface {
	Send(*TrieProof) error
	grpc.ServerStream
}

type APIService_VerifyKeyValuesProofClient 

type APIService_VerifyKeyValuesProofClient interface {
	Send(*DataChunk) error
	Recv() (*VerifyProofReplyChunk, error)
	grpc.ClientStream
}

type APIService_VerifyKeyValuesProofServer 

type APIService_VerifyKeyValuesProofServer interface {
	Send(*VerifyProofReplyChunk) error
	Recv() (*DataChunk, error)
	grpc.ServerStream
}

type APIService_VerifyTrieProofClient 

type APIService_VerifyTrieProofClient interface {
	Recv() (*VerifyProofReplyChunk, error)
	grpc.ClientStream
}

type APIService_VerifyTrieProofServer 

type APIService_VerifyTrieProofServer interface {
	Send(*VerifyProofReplyChunk) error
	grpc.ServerStream
}

type CreateKeyValuesProofRequest 

type CreateKeyValuesProofRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// TrieProof is the trie proof to use. When TrieProof is zero, a new trie
	// proof will be created with current root and ETH
	//
	// Types that are valid to be assigned to TrieProof:
	//	*CreateKeyValuesProofRequest_ProofId
	//	*CreateKeyValuesProofRequest_Request
	TrieProof isCreateKeyValuesProofRequest_TrieProof `protobuf_oneof:"trie_proof"`
	// Filter is the key-values filter (optional). When zero, all key-values will
	// be included in the proof
	Filter               *KeyValuesFilter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

CreateKeyValuesProofRequest represents a create key-values proof request

func (*CreateKeyValuesProofRequest) Descriptor 

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

func (*CreateKeyValuesProofRequest) GetFilter 

func (m *CreateKeyValuesProofRequest) GetFilter() *KeyValuesFilter

func (*CreateKeyValuesProofRequest) GetProofId 

func (m *CreateKeyValuesProofRequest) GetProofId() string

func (*CreateKeyValuesProofRequest) GetRequest 

func (m *CreateKeyValuesProofRequest) GetRequest() *CreateTrieProofRequest

func (*CreateKeyValuesProofRequest) GetTrieId 

func (m *CreateKeyValuesProofRequest) GetTrieId() string

func (*CreateKeyValuesProofRequest) GetTrieProof 

func (m *CreateKeyValuesProofRequest) GetTrieProof() isCreateKeyValuesProofRequest_TrieProof

func (*CreateKeyValuesProofRequest) ProtoMessage 

func (*CreateKeyValuesProofRequest) ProtoMessage()

func (*CreateKeyValuesProofRequest) Reset 

func (m *CreateKeyValuesProofRequest) Reset()

func (*CreateKeyValuesProofRequest) String 

func (m *CreateKeyValuesProofRequest) String() string

func (*CreateKeyValuesProofRequest) XXX_DiscardUnknown 

func (m *CreateKeyValuesProofRequest) XXX_DiscardUnknown()

func (*CreateKeyValuesProofRequest) XXX_Marshal 

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

func (*CreateKeyValuesProofRequest) XXX_Merge 

func (dst *CreateKeyValuesProofRequest) XXX_Merge(src proto.Message)

func (*CreateKeyValuesProofRequest) XXX_OneofFuncs 

func (*CreateKeyValuesProofRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*CreateKeyValuesProofRequest) XXX_Size 

func (m *CreateKeyValuesProofRequest) XXX_Size() int

func (*CreateKeyValuesProofRequest) XXX_Unmarshal 

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

type CreateKeyValuesProofRequest_ProofId 

type CreateKeyValuesProofRequest_ProofId struct {
	ProofId string `protobuf:"bytes,2,opt,name=proof_id,json=proofId,proto3,oneof"`
}

type CreateKeyValuesProofRequest_Request 

type CreateKeyValuesProofRequest_Request struct {
	Request *CreateTrieProofRequest `protobuf:"bytes,3,opt,name=request,proto3,oneof"`
}

type CreateTrieProofRequest 

type CreateTrieProofRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Root is the root hash (optional). When zero, the current root hash of the
	// trie will be used to create the TrieProof, and the request will be blocked
	// until all ongoing updates are finished
	Root string `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	// AnchorType is the anchor type the trie proof should be submitted to.
	// Default to ETH
	AnchorType           anchor.Anchor_Type `protobuf:"varint,3,opt,name=anchor_type,json=anchorType,proto3,enum=anchor.Anchor_Type" json:"anchor_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

CreateTrieProofRequest represents a create trie proof request

func (*CreateTrieProofRequest) Descriptor 

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

func (*CreateTrieProofRequest) GetAnchorType 

func (m *CreateTrieProofRequest) GetAnchorType() anchor.Anchor_Type

func (*CreateTrieProofRequest) GetRoot 

func (m *CreateTrieProofRequest) GetRoot() string

func (*CreateTrieProofRequest) GetTrieId 

func (m *CreateTrieProofRequest) GetTrieId() string

func (*CreateTrieProofRequest) ProtoMessage 

func (*CreateTrieProofRequest) ProtoMessage()

func (*CreateTrieProofRequest) Reset 

func (m *CreateTrieProofRequest) Reset()

func (*CreateTrieProofRequest) String 

func (m *CreateTrieProofRequest) String() string

func (*CreateTrieProofRequest) XXX_DiscardUnknown 

func (m *CreateTrieProofRequest) XXX_DiscardUnknown()

func (*CreateTrieProofRequest) XXX_Marshal 

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

func (*CreateTrieProofRequest) XXX_Merge 

func (dst *CreateTrieProofRequest) XXX_Merge(src proto.Message)

func (*CreateTrieProofRequest) XXX_Size 

func (m *CreateTrieProofRequest) XXX_Size() int

func (*CreateTrieProofRequest) XXX_Unmarshal 

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

type CreateTrieRequest added in v0.3.0 

type CreateTrieRequest struct {
	// StorageType is the storage type of the trie to be created
	StorageType          Trie_StorageType `protobuf:"varint,1,opt,name=storage_type,json=storageType,proto3,enum=api.Trie_StorageType" json:"storage_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

CreateTrieRequest represents a create trie request

func (*CreateTrieRequest) Descriptor added in v0.3.0 

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

func (*CreateTrieRequest) GetStorageType added in v0.3.0 

func (m *CreateTrieRequest) GetStorageType() Trie_StorageType

func (*CreateTrieRequest) ProtoMessage added in v0.3.0 

func (*CreateTrieRequest) ProtoMessage()

func (*CreateTrieRequest) Reset added in v0.3.0 

func (m *CreateTrieRequest) Reset()

func (*CreateTrieRequest) String added in v0.3.0 

func (m *CreateTrieRequest) String() string

func (*CreateTrieRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *CreateTrieRequest) XXX_DiscardUnknown()

func (*CreateTrieRequest) XXX_Marshal added in v0.3.0 

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

func (*CreateTrieRequest) XXX_Merge added in v0.3.0 

func (dst *CreateTrieRequest) XXX_Merge(src proto.Message)

func (*CreateTrieRequest) XXX_Size added in v0.3.0 

func (m *CreateTrieRequest) XXX_Size() int

func (*CreateTrieRequest) XXX_Unmarshal added in v0.3.0 

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

type DataChunk 

type DataChunk struct {
	// Data is the data within the DataChunk
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Metadata is the metadata of the DataChunk stream, which is available in the
	// first DataChunk
	//
	// Types that are valid to be assigned to Metadata:
	//	*DataChunk_ImportTrieRequest
	//	*DataChunk_VerifyKeyValuesProofRequest
	Metadata             isDataChunk_Metadata `protobuf_oneof:"metadata"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

DataChunk represents a chunk of data transmitted in a gRPC stream

func (*DataChunk) Descriptor 

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

func (*DataChunk) GetData 

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

func (*DataChunk) GetImportTrieRequest added in v0.3.0 

func (m *DataChunk) GetImportTrieRequest() *ImportTrieRequest

func (*DataChunk) GetMetadata 

func (m *DataChunk) GetMetadata() isDataChunk_Metadata

func (*DataChunk) GetVerifyKeyValuesProofRequest 

func (m *DataChunk) GetVerifyKeyValuesProofRequest() *VerifyKeyValuesProofRequest

func (*DataChunk) ProtoMessage 

func (*DataChunk) ProtoMessage()

func (*DataChunk) Reset 

func (m *DataChunk) Reset()

func (*DataChunk) String 

func (m *DataChunk) String() string

func (*DataChunk) XXX_DiscardUnknown 

func (m *DataChunk) XXX_DiscardUnknown()

func (*DataChunk) XXX_Marshal 

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

func (*DataChunk) XXX_Merge 

func (dst *DataChunk) XXX_Merge(src proto.Message)

func (*DataChunk) XXX_OneofFuncs 

func (*DataChunk) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*DataChunk) XXX_Size 

func (m *DataChunk) XXX_Size() int

func (*DataChunk) XXX_Unmarshal 

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

type DataChunkMetadata 

type DataChunkMetadata = isDataChunk_Metadata

DataChunkMetadata represents a data chunk metadata

type DataChunk_ImportTrieRequest added in v0.3.0 

type DataChunk_ImportTrieRequest struct {
	ImportTrieRequest *ImportTrieRequest `protobuf:"bytes,2,opt,name=import_trie_request,json=importTrieRequest,proto3,oneof"`
}

type DataChunk_VerifyKeyValuesProofRequest 

type DataChunk_VerifyKeyValuesProofRequest struct {
	VerifyKeyValuesProofRequest *VerifyKeyValuesProofRequest `protobuf:"bytes,3,opt,name=verify_key_values_proof_request,json=verifyKeyValuesProofRequest,proto3,oneof"`
}

type DataStreamReciever 

type DataStreamReciever interface {
	Context() context.Context
	Recv() (*DataChunk, error)
}

DataStreamReciever represents a gRPC data stream receiver

type DataStreamSender 

type DataStreamSender interface {
	Context() context.Context
	Send(*DataChunk) error
}

DataStreamSender represents a gRPC data stream sender

type DeleteTrieProofRequest 

type DeleteTrieProofRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// ProofId is the trie proof ID
	ProofId              string   `protobuf:"bytes,2,opt,name=proof_id,json=proofId,proto3" json:"proof_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteTrieProofRequest represents a delete trie proof request

func (*DeleteTrieProofRequest) Descriptor 

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

func (*DeleteTrieProofRequest) GetProofId 

func (m *DeleteTrieProofRequest) GetProofId() string

func (*DeleteTrieProofRequest) GetTrieId 

func (m *DeleteTrieProofRequest) GetTrieId() string

func (*DeleteTrieProofRequest) ProtoMessage 

func (*DeleteTrieProofRequest) ProtoMessage()

func (*DeleteTrieProofRequest) Reset 

func (m *DeleteTrieProofRequest) Reset()

func (*DeleteTrieProofRequest) String 

func (m *DeleteTrieProofRequest) String() string

func (*DeleteTrieProofRequest) XXX_DiscardUnknown 

func (m *DeleteTrieProofRequest) XXX_DiscardUnknown()

func (*DeleteTrieProofRequest) XXX_Marshal 

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

func (*DeleteTrieProofRequest) XXX_Merge 

func (dst *DeleteTrieProofRequest) XXX_Merge(src proto.Message)

func (*DeleteTrieProofRequest) XXX_Size 

func (m *DeleteTrieProofRequest) XXX_Size() int

func (*DeleteTrieProofRequest) XXX_Unmarshal 

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

type ImportTrieRequest added in v0.3.0 

type ImportTrieRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// StorageType is the storage type of the trie
	StorageType          Trie_StorageType `protobuf:"varint,2,opt,name=storage_type,json=storageType,proto3,enum=api.Trie_StorageType" json:"storage_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

ImportTrieRequest represents an import trie request

func (*ImportTrieRequest) Descriptor added in v0.3.0 

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

func (*ImportTrieRequest) GetStorageType added in v0.3.0 

func (m *ImportTrieRequest) GetStorageType() Trie_StorageType

func (*ImportTrieRequest) GetTrieId added in v0.3.0 

func (m *ImportTrieRequest) GetTrieId() string

func (*ImportTrieRequest) ProtoMessage added in v0.3.0 

func (*ImportTrieRequest) ProtoMessage()

func (*ImportTrieRequest) Reset added in v0.3.0 

func (m *ImportTrieRequest) Reset()

func (*ImportTrieRequest) String added in v0.3.0 

func (m *ImportTrieRequest) String() string

func (*ImportTrieRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *ImportTrieRequest) XXX_DiscardUnknown()

func (*ImportTrieRequest) XXX_Marshal added in v0.3.0 

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

func (*ImportTrieRequest) XXX_Merge added in v0.3.0 

func (dst *ImportTrieRequest) XXX_Merge(src proto.Message)

func (*ImportTrieRequest) XXX_Size added in v0.3.0 

func (m *ImportTrieRequest) XXX_Size() int

func (*ImportTrieRequest) XXX_Unmarshal added in v0.3.0 

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

type Key 

type Key struct {
	// Key is the key of the key-value
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// KeySep is the key separators for chained tries
	KeySep               []uint32 `protobuf:"varint,2,rep,packed,name=key_sep,json=keySep,proto3" json:"key_sep,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Key represents a key of a key-value pair

func (*Key) Descriptor 

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

func (*Key) GetKey 

func (m *Key) GetKey() []byte

func (*Key) GetKeySep 

func (m *Key) GetKeySep() []uint32

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) Reset 

func (m *Key) Reset()

func (*Key) String 

func (m *Key) String() string

func (*Key) XXX_DiscardUnknown 

func (m *Key) XXX_DiscardUnknown()

func (*Key) XXX_Marshal 

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

func (*Key) XXX_Merge 

func (dst *Key) XXX_Merge(src proto.Message)

func (*Key) XXX_Size 

func (m *Key) XXX_Size() int

func (*Key) XXX_Unmarshal 

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

type KeyValue 

type KeyValue struct {
	// Key is the key of the key-value
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// KeySep is the key separators for chained tries
	KeySep []uint32 `protobuf:"varint,2,rep,packed,name=key_sep,json=keySep,proto3" json:"key_sep,omitempty"`
	// Value is the value of the key-value
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Metadata is the metadata of the KeyValue stream, which is available in the
	// first KeyValue
	//
	// Types that are valid to be assigned to Metadata:
	//	*KeyValue_TrieKeyValuesRequest
	Metadata             isKeyValue_Metadata `protobuf_oneof:"metadata"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

KeyValue represents a key-value

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() []byte

func (*KeyValue) GetKeySep 

func (m *KeyValue) GetKeySep() []uint32

func (*KeyValue) GetMetadata 

func (m *KeyValue) GetMetadata() isKeyValue_Metadata

func (*KeyValue) GetTrieKeyValuesRequest 

func (m *KeyValue) GetTrieKeyValuesRequest() *TrieKeyValuesRequest

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (KeyValue) KeyString added in v0.3.0 

func (kv KeyValue) KeyString() string

KeyString returns a human readable string representation of the key

func (*KeyValue) Last added in v0.3.0 

func (kv *KeyValue) Last() []byte

Last returns the last key component

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

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

func (*KeyValue) XXX_Merge 

func (dst *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_OneofFuncs 

func (*KeyValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

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

type KeyValue_TrieKeyValuesRequest 

type KeyValue_TrieKeyValuesRequest struct {
	TrieKeyValuesRequest *TrieKeyValuesRequest `protobuf:"bytes,4,opt,name=trie_key_values_request,json=trieKeyValuesRequest,proto3,oneof"`
}

type KeyValuesFilter 

type KeyValuesFilter struct {
	// Keys are the keys of key-values that should be included in a key-value
	// proof. Only those trie nodes are on the merkle paths of the given keys will
	// be included in the proof
	Keys                 []*Key   `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KeyValuesFilter represents a key-value filter

func (*KeyValuesFilter) Descriptor 

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

func (*KeyValuesFilter) GetKeys 

func (m *KeyValuesFilter) GetKeys() []*Key

func (*KeyValuesFilter) ProtoMessage 

func (*KeyValuesFilter) ProtoMessage()

func (*KeyValuesFilter) Reset 

func (m *KeyValuesFilter) Reset()

func (*KeyValuesFilter) String 

func (m *KeyValuesFilter) String() string

func (*KeyValuesFilter) XXX_DiscardUnknown 

func (m *KeyValuesFilter) XXX_DiscardUnknown()

func (*KeyValuesFilter) XXX_Marshal 

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

func (*KeyValuesFilter) XXX_Merge 

func (dst *KeyValuesFilter) XXX_Merge(src proto.Message)

func (*KeyValuesFilter) XXX_Size 

func (m *KeyValuesFilter) XXX_Size() int

func (*KeyValuesFilter) XXX_Unmarshal 

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

type RootFilter 

type RootFilter struct {
	// Root is the root hash. When zero, the current root hash of the trie will be
	// used to retrieve the TrieProof, and the request will be blocked until all
	// ongoing updates are finished
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// NotBefore is the not before timestamp. When nil, this constraint is not
	// used; when zero, the latest TrieProof for the root hash will be returned
	NotBefore            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

RootFilter represents a root filter to query a proof

func (*RootFilter) Descriptor 

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

func (*RootFilter) GetNotBefore 

func (m *RootFilter) GetNotBefore() *timestamp.Timestamp

func (*RootFilter) GetRoot 

func (m *RootFilter) GetRoot() string

func (*RootFilter) ProtoMessage 

func (*RootFilter) ProtoMessage()

func (*RootFilter) Reset 

func (m *RootFilter) Reset()

func (*RootFilter) String 

func (m *RootFilter) String() string

func (*RootFilter) XXX_DiscardUnknown 

func (m *RootFilter) XXX_DiscardUnknown()

func (*RootFilter) XXX_Marshal 

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

func (*RootFilter) XXX_Merge 

func (dst *RootFilter) XXX_Merge(src proto.Message)

func (*RootFilter) XXX_Size 

func (m *RootFilter) XXX_Size() int

func (*RootFilter) XXX_Unmarshal 

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

type SetTrieRootRequest 

type SetTrieRootRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Root is the root hash to set to
	Root                 string   `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SetTrieRootRequest represents a set trie root request

func (*SetTrieRootRequest) Descriptor 

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

func (*SetTrieRootRequest) GetRoot 

func (m *SetTrieRootRequest) GetRoot() string

func (*SetTrieRootRequest) GetTrieId 

func (m *SetTrieRootRequest) GetTrieId() string

func (*SetTrieRootRequest) ProtoMessage 

func (*SetTrieRootRequest) ProtoMessage()

func (*SetTrieRootRequest) Reset 

func (m *SetTrieRootRequest) Reset()

func (*SetTrieRootRequest) String 

func (m *SetTrieRootRequest) String() string

func (*SetTrieRootRequest) XXX_DiscardUnknown 

func (m *SetTrieRootRequest) XXX_DiscardUnknown()

func (*SetTrieRootRequest) XXX_Marshal 

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

func (*SetTrieRootRequest) XXX_Merge 

func (dst *SetTrieRootRequest) XXX_Merge(src proto.Message)

func (*SetTrieRootRequest) XXX_Size 

func (m *SetTrieRootRequest) XXX_Size() int

func (*SetTrieRootRequest) XXX_Unmarshal 

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

type SetTrieStorageTypeRequest added in v0.3.0 

type SetTrieStorageTypeRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// StorageType is the storage type of the trie to be updated to
	StorageType          Trie_StorageType `protobuf:"varint,2,opt,name=storage_type,json=storageType,proto3,enum=api.Trie_StorageType" json:"storage_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

SetTrieStorageTypeRequest represents a set trie storage type request

func (*SetTrieStorageTypeRequest) Descriptor added in v0.3.0 

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

func (*SetTrieStorageTypeRequest) GetStorageType added in v0.3.0 

func (m *SetTrieStorageTypeRequest) GetStorageType() Trie_StorageType

func (*SetTrieStorageTypeRequest) GetTrieId added in v0.3.0 

func (m *SetTrieStorageTypeRequest) GetTrieId() string

func (*SetTrieStorageTypeRequest) ProtoMessage added in v0.3.0 

func (*SetTrieStorageTypeRequest) ProtoMessage()

func (*SetTrieStorageTypeRequest) Reset added in v0.3.0 

func (m *SetTrieStorageTypeRequest) Reset()

func (*SetTrieStorageTypeRequest) String added in v0.3.0 

func (m *SetTrieStorageTypeRequest) String() string

func (*SetTrieStorageTypeRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *SetTrieStorageTypeRequest) XXX_DiscardUnknown()

func (*SetTrieStorageTypeRequest) XXX_Marshal added in v0.3.0 

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

func (*SetTrieStorageTypeRequest) XXX_Merge added in v0.3.0 

func (dst *SetTrieStorageTypeRequest) XXX_Merge(src proto.Message)

func (*SetTrieStorageTypeRequest) XXX_Size added in v0.3.0 

func (m *SetTrieStorageTypeRequest) XXX_Size() int

func (*SetTrieStorageTypeRequest) XXX_Unmarshal added in v0.3.0 

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

type Trie 

type Trie struct {
	// Id is the trie ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Root is the root hash of the trie
	Root string `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	// StorageType is the storage type of the trie
	StorageType          Trie_StorageType `protobuf:"varint,3,opt,name=storage_type,json=storageType,proto3,enum=api.Trie_StorageType" json:"storage_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Trie represents a dictionary of key-values that can be built incrementally, whose root hash at any given time can be also dervied efficiently. Once the root hash is proven to a blockchain, every key-value is also proven

func (*Trie) Descriptor 

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

func (*Trie) GetId 

func (m *Trie) GetId() string

func (*Trie) GetRoot 

func (m *Trie) GetRoot() string

func (*Trie) GetStorageType added in v0.3.0 

func (m *Trie) GetStorageType() Trie_StorageType

func (*Trie) ProtoMessage 

func (*Trie) ProtoMessage()

func (*Trie) Reset 

func (m *Trie) Reset()

func (*Trie) String 

func (m *Trie) String() string

func (*Trie) XXX_DiscardUnknown 

func (m *Trie) XXX_DiscardUnknown()

func (*Trie) XXX_Marshal 

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

func (*Trie) XXX_Merge 

func (dst *Trie) XXX_Merge(src proto.Message)

func (*Trie) XXX_Size 

func (m *Trie) XXX_Size() int

func (*Trie) XXX_Unmarshal 

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

type TrieKeyValueRequest 

type TrieKeyValueRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Root is the root hash (optional). When zero, the current root hash of the
	// trie will be used to retrieve the TrieKeyValues, and the request will be
	// blocked until all ongoing updates are finished
	Root string `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	// Key is the key of the key-value
	Key                  *Key     `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TrieKeyValueRequest represents a trie key-value request

func (*TrieKeyValueRequest) Descriptor 

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

func (*TrieKeyValueRequest) GetKey 

func (m *TrieKeyValueRequest) GetKey() *Key

func (*TrieKeyValueRequest) GetRoot 

func (m *TrieKeyValueRequest) GetRoot() string

func (*TrieKeyValueRequest) GetTrieId 

func (m *TrieKeyValueRequest) GetTrieId() string

func (*TrieKeyValueRequest) ProtoMessage 

func (*TrieKeyValueRequest) ProtoMessage()

func (*TrieKeyValueRequest) Reset 

func (m *TrieKeyValueRequest) Reset()

func (*TrieKeyValueRequest) String 

func (m *TrieKeyValueRequest) String() string

func (*TrieKeyValueRequest) XXX_DiscardUnknown 

func (m *TrieKeyValueRequest) XXX_DiscardUnknown()

func (*TrieKeyValueRequest) XXX_Marshal 

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

func (*TrieKeyValueRequest) XXX_Merge 

func (dst *TrieKeyValueRequest) XXX_Merge(src proto.Message)

func (*TrieKeyValueRequest) XXX_Size 

func (m *TrieKeyValueRequest) XXX_Size() int

func (*TrieKeyValueRequest) XXX_Unmarshal 

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

type TrieKeyValuesRequest 

type TrieKeyValuesRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Root is the root hash (optional). When zero, the current root hash of the
	// trie will be used to retrieve the TrieKeyValues, and the request will be
	// blocked until all ongoing updates are finished
	Root                 string   `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TrieKeyValuesRequest represents a trie key-values request. The returned KeyValues are ordered by the keys lexicographically

func (*TrieKeyValuesRequest) Descriptor 

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

func (*TrieKeyValuesRequest) GetRoot 

func (m *TrieKeyValuesRequest) GetRoot() string

func (*TrieKeyValuesRequest) GetTrieId 

func (m *TrieKeyValuesRequest) GetTrieId() string

func (*TrieKeyValuesRequest) ProtoMessage 

func (*TrieKeyValuesRequest) ProtoMessage()

func (*TrieKeyValuesRequest) Reset 

func (m *TrieKeyValuesRequest) Reset()

func (*TrieKeyValuesRequest) String 

func (m *TrieKeyValuesRequest) String() string

func (*TrieKeyValuesRequest) XXX_DiscardUnknown 

func (m *TrieKeyValuesRequest) XXX_DiscardUnknown()

func (*TrieKeyValuesRequest) XXX_Marshal 

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

func (*TrieKeyValuesRequest) XXX_Merge 

func (dst *TrieKeyValuesRequest) XXX_Merge(src proto.Message)

func (*TrieKeyValuesRequest) XXX_Size 

func (m *TrieKeyValuesRequest) XXX_Size() int

func (*TrieKeyValuesRequest) XXX_Unmarshal 

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

type TrieProof 

type TrieProof struct {
	// Id is the ID of the trie proof
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,2,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Root is the root hash of the trie proven by this proof
	Root string `protobuf:"bytes,3,opt,name=root,proto3" json:"root,omitempty"`
	// CreatedAt is the created at timestamp. The timestamp when the proof is
	// created
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Status is the anchor batch status of the trie proof
	Status anchor.Batch_Status `protobuf:"varint,5,opt,name=status,proto3,enum=anchor.Batch_Status" json:"status,omitempty"`
	// Error is the error message when status is ERROR
	Error string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// AnchorType is the anchor type the trie proof has been submitted to
	AnchorType anchor.Anchor_Type `protobuf:"varint,7,opt,name=anchor_type,json=anchorType,proto3,enum=anchor.Anchor_Type" json:"anchor_type,omitempty"`
	// TxnId is the blockchain transaction ID
	TxnId string `protobuf:"bytes,8,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	// TxnUri is the explorer URI for the blockchain transaction
	TxnUri string `protobuf:"bytes,12,opt,name=txn_uri,json=txnUri,proto3" json:"txn_uri,omitempty"`
	// BlockTime is the blockchain's block consensus timestamp in seconds
	BlockTime uint64 `protobuf:"varint,9,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	// BlockTimeNano is the Blockcahin's block consensus timestamp's nano part.
	// For most traditional blockchains, this will be zero. For Hedera, this will
	// be the nano part of the transaction's consensus timestamp
	BlockTimeNano uint64 `protobuf:"varint,13,opt,name=block_time_nano,json=blockTimeNano,proto3" json:"block_time_nano,omitempty"`
	// BlockNumber is the blockchain's block number. For Hedera, this will be zero
	// as there is no block concept and each transaction has its own consensus
	// timestamp which defines the transaction order
	BlockNumber uint64 `protobuf:"varint,10,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	// ProofRoot is the root hash of the trie proof, which is the anchor batch's
	// root hash the proof belongs to
	ProofRoot            string   `protobuf:"bytes,11,opt,name=proof_root,json=proofRoot,proto3" json:"proof_root,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TrieProof represents a proof for a trie at a certain root, which can be viewed as a snapshot of all the key-values contained in the trie

func (*TrieProof) Descriptor 

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

func (*TrieProof) GetAnchorType 

func (m *TrieProof) GetAnchorType() anchor.Anchor_Type

func (*TrieProof) GetBlockNumber 

func (m *TrieProof) GetBlockNumber() uint64

func (*TrieProof) GetBlockTime 

func (m *TrieProof) GetBlockTime() uint64

func (*TrieProof) GetBlockTimeNano 

func (m *TrieProof) GetBlockTimeNano() uint64

func (*TrieProof) GetCreatedAt 

func (m *TrieProof) GetCreatedAt() *timestamp.Timestamp

func (*TrieProof) GetError 

func (m *TrieProof) GetError() string

func (*TrieProof) GetId 

func (m *TrieProof) GetId() string

func (*TrieProof) GetProofRoot 

func (m *TrieProof) GetProofRoot() string

func (*TrieProof) GetRoot 

func (m *TrieProof) GetRoot() string

func (*TrieProof) GetStatus 

func (m *TrieProof) GetStatus() anchor.Batch_Status

func (*TrieProof) GetTrieId 

func (m *TrieProof) GetTrieId() string

func (*TrieProof) GetTxnId 

func (m *TrieProof) GetTxnId() string

func (*TrieProof) GetTxnUri 

func (m *TrieProof) GetTxnUri() string

func (*TrieProof) ProtoMessage 

func (*TrieProof) ProtoMessage()

func (*TrieProof) Reset 

func (m *TrieProof) Reset()

func (*TrieProof) String 

func (m *TrieProof) String() string

func (*TrieProof) XXX_DiscardUnknown 

func (m *TrieProof) XXX_DiscardUnknown()

func (*TrieProof) XXX_Marshal 

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

func (*TrieProof) XXX_Merge 

func (dst *TrieProof) XXX_Merge(src proto.Message)

func (*TrieProof) XXX_Size 

func (m *TrieProof) XXX_Size() int

func (*TrieProof) XXX_Unmarshal 

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

type TrieProofRequest 

type TrieProofRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// Query is the query to get the TrieProof
	//
	// Types that are valid to be assigned to Query:
	//	*TrieProofRequest_ProofId
	//	*TrieProofRequest_RootFilter
	Query                isTrieProofRequest_Query `protobuf_oneof:"query"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

TrieProofRequest represents a trie proof request

func (*TrieProofRequest) Descriptor 

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

func (*TrieProofRequest) GetProofId 

func (m *TrieProofRequest) GetProofId() string

func (*TrieProofRequest) GetQuery 

func (m *TrieProofRequest) GetQuery() isTrieProofRequest_Query

func (*TrieProofRequest) GetRootFilter 

func (m *TrieProofRequest) GetRootFilter() *RootFilter

func (*TrieProofRequest) GetTrieId 

func (m *TrieProofRequest) GetTrieId() string

func (*TrieProofRequest) ProtoMessage 

func (*TrieProofRequest) ProtoMessage()

func (*TrieProofRequest) Reset 

func (m *TrieProofRequest) Reset()

func (*TrieProofRequest) String 

func (m *TrieProofRequest) String() string

func (*TrieProofRequest) XXX_DiscardUnknown 

func (m *TrieProofRequest) XXX_DiscardUnknown()

func (*TrieProofRequest) XXX_Marshal 

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

func (*TrieProofRequest) XXX_Merge 

func (dst *TrieProofRequest) XXX_Merge(src proto.Message)

func (*TrieProofRequest) XXX_OneofFuncs 

func (*TrieProofRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TrieProofRequest) XXX_Size 

func (m *TrieProofRequest) XXX_Size() int

func (*TrieProofRequest) XXX_Unmarshal 

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

type TrieProofRequest_ProofId 

type TrieProofRequest_ProofId struct {
	ProofId string `protobuf:"bytes,2,opt,name=proof_id,json=proofId,proto3,oneof"`
}

type TrieProofRequest_RootFilter 

type TrieProofRequest_RootFilter struct {
	RootFilter *RootFilter `protobuf:"bytes,3,opt,name=root_filter,json=rootFilter,proto3,oneof"`
}

type TrieProofsRequest 

type TrieProofsRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// RootFilter is the root filter (optional). When nil, all TrieProofs will be
	// returned
	RootFilter           *RootFilter `protobuf:"bytes,2,opt,name=root_filter,json=rootFilter,proto3" json:"root_filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TrieProofsRequest represents a trie proofs request. The returned TrieProofs are ordered by root lexicographically then by created at timestamp chronologically

func (*TrieProofsRequest) Descriptor 

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

func (*TrieProofsRequest) GetRootFilter 

func (m *TrieProofsRequest) GetRootFilter() *RootFilter

func (*TrieProofsRequest) GetTrieId 

func (m *TrieProofsRequest) GetTrieId() string

func (*TrieProofsRequest) ProtoMessage 

func (*TrieProofsRequest) ProtoMessage()

func (*TrieProofsRequest) Reset 

func (m *TrieProofsRequest) Reset()

func (*TrieProofsRequest) String 

func (m *TrieProofsRequest) String() string

func (*TrieProofsRequest) XXX_DiscardUnknown 

func (m *TrieProofsRequest) XXX_DiscardUnknown()

func (*TrieProofsRequest) XXX_Marshal 

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

func (*TrieProofsRequest) XXX_Merge 

func (dst *TrieProofsRequest) XXX_Merge(src proto.Message)

func (*TrieProofsRequest) XXX_Size 

func (m *TrieProofsRequest) XXX_Size() int

func (*TrieProofsRequest) XXX_Unmarshal 

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

type TrieRequest 

type TrieRequest struct {
	// TrieId is the trie ID
	TrieId               string   `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TrieRequest represents a trie request

func (*TrieRequest) Descriptor 

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

func (*TrieRequest) GetTrieId 

func (m *TrieRequest) GetTrieId() string

func (*TrieRequest) ProtoMessage 

func (*TrieRequest) ProtoMessage()

func (*TrieRequest) Reset 

func (m *TrieRequest) Reset()

func (*TrieRequest) String 

func (m *TrieRequest) String() string

func (*TrieRequest) XXX_DiscardUnknown 

func (m *TrieRequest) XXX_DiscardUnknown()

func (*TrieRequest) XXX_Marshal 

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

func (*TrieRequest) XXX_Merge 

func (dst *TrieRequest) XXX_Merge(src proto.Message)

func (*TrieRequest) XXX_Size 

func (m *TrieRequest) XXX_Size() int

func (*TrieRequest) XXX_Unmarshal 

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

type TrieRoot 

type TrieRoot struct {
	// Root is the root hash of the trie
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// CreatedAt is the created at timestamp. The timestamp when the root is
	// created
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

TrieRoot represents a root of a trie. Each modification made to the trie will lead to a new trie root

func (*TrieRoot) Descriptor 

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

func (*TrieRoot) GetCreatedAt 

func (m *TrieRoot) GetCreatedAt() *timestamp.Timestamp

func (*TrieRoot) GetRoot 

func (m *TrieRoot) GetRoot() string

func (*TrieRoot) ProtoMessage 

func (*TrieRoot) ProtoMessage()

func (*TrieRoot) Reset 

func (m *TrieRoot) Reset()

func (*TrieRoot) String 

func (m *TrieRoot) String() string

func (*TrieRoot) XXX_DiscardUnknown 

func (m *TrieRoot) XXX_DiscardUnknown()

func (*TrieRoot) XXX_Marshal 

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

func (*TrieRoot) XXX_Merge 

func (dst *TrieRoot) XXX_Merge(src proto.Message)

func (*TrieRoot) XXX_Size 

func (m *TrieRoot) XXX_Size() int

func (*TrieRoot) XXX_Unmarshal 

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

type TrieRootsRequest 

type TrieRootsRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// RootFilter is the root filter (optional). When nil, all TrieRoots will be
	// returned
	RootFilter           *RootFilter `protobuf:"bytes,2,opt,name=root_filter,json=rootFilter,proto3" json:"root_filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TrieRootsRequest represents a trie roots request. The returned TrieRoots are in chronological order

func (*TrieRootsRequest) Descriptor 

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

func (*TrieRootsRequest) GetRootFilter 

func (m *TrieRootsRequest) GetRootFilter() *RootFilter

func (*TrieRootsRequest) GetTrieId 

func (m *TrieRootsRequest) GetTrieId() string

func (*TrieRootsRequest) ProtoMessage 

func (*TrieRootsRequest) ProtoMessage()

func (*TrieRootsRequest) Reset 

func (m *TrieRootsRequest) Reset()

func (*TrieRootsRequest) String 

func (m *TrieRootsRequest) String() string

func (*TrieRootsRequest) XXX_DiscardUnknown 

func (m *TrieRootsRequest) XXX_DiscardUnknown()

func (*TrieRootsRequest) XXX_Marshal 

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

func (*TrieRootsRequest) XXX_Merge 

func (dst *TrieRootsRequest) XXX_Merge(src proto.Message)

func (*TrieRootsRequest) XXX_Size 

func (m *TrieRootsRequest) XXX_Size() int

func (*TrieRootsRequest) XXX_Unmarshal 

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

type Trie_StorageType added in v0.3.0 

type Trie_StorageType int32

StorageType represents a trie storage type 

const (
	// LOCAL means the trie is stored temporarily on API Service's local disk
	Trie_LOCAL Trie_StorageType = 0
	// CLOUD means the trie is stored persistently on a cloud storage provider
	Trie_CLOUD Trie_StorageType = 1
)

func (Trie_StorageType) EnumDescriptor added in v0.3.0 

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

func (Trie_StorageType) String added in v0.3.0 

func (x Trie_StorageType) String() string

type VerifyKeyValuesProofRequest 

type VerifyKeyValuesProofRequest struct {
	// OutputKeyValues indicates whether to output key-values contained in the
	// trie
	OutputKeyValues bool `protobuf:"varint,1,opt,name=output_key_values,json=outputKeyValues,proto3" json:"output_key_values,omitempty"`
	// OutputDotGraph indicates whether to output a Graphviz dot graph to
	// visualize the trie
	OutputDotGraph       bool     `protobuf:"varint,2,opt,name=output_dot_graph,json=outputDotGraph,proto3" json:"output_dot_graph,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VerifyKeyValuesProofRequest represents a verify key-values proof request

func (*VerifyKeyValuesProofRequest) Descriptor 

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

func (*VerifyKeyValuesProofRequest) GetOutputDotGraph 

func (m *VerifyKeyValuesProofRequest) GetOutputDotGraph() bool

func (*VerifyKeyValuesProofRequest) GetOutputKeyValues 

func (m *VerifyKeyValuesProofRequest) GetOutputKeyValues() bool

func (*VerifyKeyValuesProofRequest) ProtoMessage 

func (*VerifyKeyValuesProofRequest) ProtoMessage()

func (*VerifyKeyValuesProofRequest) Reset 

func (m *VerifyKeyValuesProofRequest) Reset()

func (*VerifyKeyValuesProofRequest) String 

func (m *VerifyKeyValuesProofRequest) String() string

func (*VerifyKeyValuesProofRequest) XXX_DiscardUnknown 

func (m *VerifyKeyValuesProofRequest) XXX_DiscardUnknown()

func (*VerifyKeyValuesProofRequest) XXX_Marshal 

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

func (*VerifyKeyValuesProofRequest) XXX_Merge 

func (dst *VerifyKeyValuesProofRequest) XXX_Merge(src proto.Message)

func (*VerifyKeyValuesProofRequest) XXX_Size 

func (m *VerifyKeyValuesProofRequest) XXX_Size() int

func (*VerifyKeyValuesProofRequest) XXX_Unmarshal 

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

type VerifyProofReply 

type VerifyProofReply struct {
	// Verified indicates whether the proof is verified
	Verified bool `protobuf:"varint,1,opt,name=verified,proto3" json:"verified,omitempty"`
	// Error is the error message when the proof is falsified
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VerifyProofReply represents a verify proof reply

func (*VerifyProofReply) Descriptor 

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

func (*VerifyProofReply) GetError 

func (m *VerifyProofReply) GetError() string

func (*VerifyProofReply) GetVerified 

func (m *VerifyProofReply) GetVerified() bool

func (*VerifyProofReply) ProtoMessage 

func (*VerifyProofReply) ProtoMessage()

func (*VerifyProofReply) Reset 

func (m *VerifyProofReply) Reset()

func (*VerifyProofReply) String 

func (m *VerifyProofReply) String() string

func (*VerifyProofReply) XXX_DiscardUnknown 

func (m *VerifyProofReply) XXX_DiscardUnknown()

func (*VerifyProofReply) XXX_Marshal 

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

func (*VerifyProofReply) XXX_Merge 

func (dst *VerifyProofReply) XXX_Merge(src proto.Message)

func (*VerifyProofReply) XXX_Size 

func (m *VerifyProofReply) XXX_Size() int

func (*VerifyProofReply) XXX_Unmarshal 

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

type VerifyProofReplyChunk 

type VerifyProofReplyChunk struct {
	// Data is the data contained in the chunk
	//
	// Types that are valid to be assigned to Data:
	//	*VerifyProofReplyChunk_KeyValue
	//	*VerifyProofReplyChunk_DotGraphChunk
	//	*VerifyProofReplyChunk_Reply
	Data                 isVerifyProofReplyChunk_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

VerifyProofReplyChunk represents a chunk of data in the verify proof reply stream

func (*VerifyProofReplyChunk) Descriptor 

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

func (*VerifyProofReplyChunk) GetData 

func (m *VerifyProofReplyChunk) GetData() isVerifyProofReplyChunk_Data

func (*VerifyProofReplyChunk) GetDotGraphChunk 

func (m *VerifyProofReplyChunk) GetDotGraphChunk() *DataChunk

func (*VerifyProofReplyChunk) GetKeyValue 

func (m *VerifyProofReplyChunk) GetKeyValue() *KeyValue

func (*VerifyProofReplyChunk) GetReply 

func (m *VerifyProofReplyChunk) GetReply() *VerifyProofReply

func (*VerifyProofReplyChunk) ProtoMessage 

func (*VerifyProofReplyChunk) ProtoMessage()

func (*VerifyProofReplyChunk) Reset 

func (m *VerifyProofReplyChunk) Reset()

func (*VerifyProofReplyChunk) String 

func (m *VerifyProofReplyChunk) String() string

func (*VerifyProofReplyChunk) XXX_DiscardUnknown 

func (m *VerifyProofReplyChunk) XXX_DiscardUnknown()

func (*VerifyProofReplyChunk) XXX_Marshal 

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

func (*VerifyProofReplyChunk) XXX_Merge 

func (dst *VerifyProofReplyChunk) XXX_Merge(src proto.Message)

func (*VerifyProofReplyChunk) XXX_OneofFuncs 

func (*VerifyProofReplyChunk) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*VerifyProofReplyChunk) XXX_Size 

func (m *VerifyProofReplyChunk) XXX_Size() int

func (*VerifyProofReplyChunk) XXX_Unmarshal 

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

type VerifyProofReplyChunk_DotGraphChunk 

type VerifyProofReplyChunk_DotGraphChunk struct {
	DotGraphChunk *DataChunk `protobuf:"bytes,2,opt,name=dot_graph_chunk,json=dotGraphChunk,proto3,oneof"`
}

type VerifyProofReplyChunk_KeyValue 

type VerifyProofReplyChunk_KeyValue struct {
	KeyValue *KeyValue `protobuf:"bytes,1,opt,name=key_value,json=keyValue,proto3,oneof"`
}

type VerifyProofReplyChunk_Reply 

type VerifyProofReplyChunk_Reply struct {
	Reply *VerifyProofReply `protobuf:"bytes,3,opt,name=reply,proto3,oneof"`
}

type VerifyProofReplyStreamReader 

type VerifyProofReplyStreamReader struct {

	// DotGraph is dot graph reader. It must be closed to ensure all data are read
	DotGraph io.ReadCloser
	// contains filtered or unexported fields
}

VerifyProofReplyStreamReader represents a fan-out reader

func NewVerifyProofReplyStreamReader 

func NewVerifyProofReplyStreamReader(
	vsr VerifyProofReplyStreamReciever,
) (
	sr *VerifyProofReplyStreamReader,
)

NewVerifyProofReplyStreamReader creates a fan-out reader out of the VerifyProofReplyStreamReciever

func (*VerifyProofReplyStreamReader) Close 

func (v *VerifyProofReplyStreamReader) Close(err error)

Close closes the fan-out reader with the error

func (*VerifyProofReplyStreamReader) Context 

func (v *VerifyProofReplyStreamReader) Context() context.Context

Context returns the underlying stream context

func (*VerifyProofReplyStreamReader) Done 

func (v *VerifyProofReplyStreamReader) Done() <-chan struct{}

Done returns the done channel

func (*VerifyProofReplyStreamReader) Err 

func (v *VerifyProofReplyStreamReader) Err() error

Err returns the error when the reader is done

func (*VerifyProofReplyStreamReader) KeyValues 

func (v *VerifyProofReplyStreamReader) KeyValues() <-chan *KeyValue

KeyValues returns the key-value channel

func (*VerifyProofReplyStreamReader) Recv 

func (v *VerifyProofReplyStreamReader) Recv() (dc *DataChunk, er error)

Recv receives a dot graph chunk

func (*VerifyProofReplyStreamReader) Reply 

func (v *VerifyProofReplyStreamReader) Reply() <-chan *VerifyProofReply

Reply returns the reply channel

type VerifyProofReplyStreamReciever 

type VerifyProofReplyStreamReciever interface {
	Context() context.Context
	Recv() (*VerifyProofReplyChunk, error)
}

VerifyProofReplyStreamReciever represents a gRPC verify proof reply stream receiver

type VerifyProofReplyStreamSender 

type VerifyProofReplyStreamSender interface {
	Context() context.Context
	Send(*VerifyProofReplyChunk) error
}

VerifyProofReplyStreamSender represents a gRPC verify proof reply stream sender

type VerifyProofReplyStreamWriter 

type VerifyProofReplyStreamWriter struct {

	// DotGraph is dot graph writer. It must be closed to ensure all data are written
	DotGraph io.WriteCloser
	// contains filtered or unexported fields
}

VerifyProofReplyStreamWriter represents a fan-in writer

func NewVerifyProofReplyStreamWriter 

func NewVerifyProofReplyStreamWriter(
	vss VerifyProofReplyStreamSender,
) (
	sw *VerifyProofReplyStreamWriter,
)

NewVerifyProofReplyStreamWriter creates a fan-in writer out of the VerifyProofReplyStreamSender

func (*VerifyProofReplyStreamWriter) Close 

func (v *VerifyProofReplyStreamWriter) Close(err error)

Close closes the fan-in writer with the error. If error is nil, it will wait until the writer has processed all the inputs

func (*VerifyProofReplyStreamWriter) Context 

func (v *VerifyProofReplyStreamWriter) Context() context.Context

Context returns the underlying stream context

func (*VerifyProofReplyStreamWriter) Done 

func (v *VerifyProofReplyStreamWriter) Done() <-chan struct{}

Done returns the done channel

func (*VerifyProofReplyStreamWriter) Err 

func (v *VerifyProofReplyStreamWriter) Err() error

Err returns the error when the writer is done

func (*VerifyProofReplyStreamWriter) Send 

func (v *VerifyProofReplyStreamWriter) Send(dc *DataChunk) error

Send writes a dot graph chunk

func (*VerifyProofReplyStreamWriter) WriteKeyValue 

func (v *VerifyProofReplyStreamWriter) WriteKeyValue(kv *KeyValue) error

WriteKeyValue writes a key-value pair

func (*VerifyProofReplyStreamWriter) WriteReply 

func (v *VerifyProofReplyStreamWriter) WriteReply(reply *VerifyProofReply) error

WriteReply writes a reply

type VerifyTrieProofRequest 

type VerifyTrieProofRequest struct {
	// TrieId is the trie ID
	TrieId string `protobuf:"bytes,1,opt,name=trie_id,json=trieId,proto3" json:"trie_id,omitempty"`
	// ProofId is the trie proof ID
	ProofId string `protobuf:"bytes,2,opt,name=proof_id,json=proofId,proto3" json:"proof_id,omitempty"`
	// OutputKeyValues indicates whether to output key-values contained in the
	// trie
	OutputKeyValues bool `protobuf:"varint,3,opt,name=output_key_values,json=outputKeyValues,proto3" json:"output_key_values,omitempty"`
	// OutputDotGraph indicates whether to output a Graphviz dot graph to
	// visualize the trie
	OutputDotGraph       bool     `protobuf:"varint,4,opt,name=output_dot_graph,json=outputDotGraph,proto3" json:"output_dot_graph,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VerifyTrieProofRequest represents a verify trie proof request

func (*VerifyTrieProofRequest) Descriptor 

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

func (*VerifyTrieProofRequest) GetOutputDotGraph 

func (m *VerifyTrieProofRequest) GetOutputDotGraph() bool

func (*VerifyTrieProofRequest) GetOutputKeyValues 

func (m *VerifyTrieProofRequest) GetOutputKeyValues() bool

func (*VerifyTrieProofRequest) GetProofId 

func (m *VerifyTrieProofRequest) GetProofId() string

func (*VerifyTrieProofRequest) GetTrieId 

func (m *VerifyTrieProofRequest) GetTrieId() string

func (*VerifyTrieProofRequest) ProtoMessage 

func (*VerifyTrieProofRequest) ProtoMessage()

func (*VerifyTrieProofRequest) Reset 

func (m *VerifyTrieProofRequest) Reset()

func (*VerifyTrieProofRequest) String 

func (m *VerifyTrieProofRequest) String() string

func (*VerifyTrieProofRequest) XXX_DiscardUnknown 

func (m *VerifyTrieProofRequest) XXX_DiscardUnknown()

func (*VerifyTrieProofRequest) XXX_Marshal 

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

func (*VerifyTrieProofRequest) XXX_Merge 

func (dst *VerifyTrieProofRequest) XXX_Merge(src proto.Message)

func (*VerifyTrieProofRequest) XXX_Size 

func (m *VerifyTrieProofRequest) XXX_Size() int

func (*VerifyTrieProofRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.