cnidariumv1

package
v8.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCnidarium        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCnidarium          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCnidarium = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

Types

type KeyValueRequest 

type KeyValueRequest struct {
	// If set, the key to fetch from storage.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// whether to return a proof
	Proof bool `protobuf:"varint,3,opt,name=proof,proto3" json:"proof,omitempty"`
}

Performs a key-value query against the JMT, either by key or by key hash.

Proofs are only supported by key.

func (*KeyValueRequest) Descriptor 

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

func (*KeyValueRequest) GetKey 

func (m *KeyValueRequest) GetKey() string

func (*KeyValueRequest) GetProof 

func (m *KeyValueRequest) GetProof() bool

func (*KeyValueRequest) Marshal 

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

func (*KeyValueRequest) MarshalTo 

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

func (*KeyValueRequest) MarshalToSizedBuffer 

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

func (*KeyValueRequest) ProtoMessage 

func (*KeyValueRequest) ProtoMessage()

func (*KeyValueRequest) Reset 

func (m *KeyValueRequest) Reset()

func (*KeyValueRequest) Size 

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

func (*KeyValueRequest) String 

func (m *KeyValueRequest) String() string

func (*KeyValueRequest) Unmarshal 

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

func (*KeyValueRequest) XXX_DiscardUnknown 

func (m *KeyValueRequest) XXX_DiscardUnknown()

func (*KeyValueRequest) XXX_Marshal 

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

func (*KeyValueRequest) XXX_Merge 

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

func (*KeyValueRequest) XXX_Size 

func (m *KeyValueRequest) XXX_Size() int

func (*KeyValueRequest) XXX_Unmarshal 

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

type KeyValueResponse 

type KeyValueResponse struct {
	// The value corresponding to the specified key, if it was found.
	Value *KeyValueResponse_Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// A proof of existence or non-existence.
	Proof *types.MerkleProof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
}

func (*KeyValueResponse) Descriptor 

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

func (*KeyValueResponse) GetProof 

func (m *KeyValueResponse) GetProof() *types.MerkleProof

func (*KeyValueResponse) GetValue 

func (m *KeyValueResponse) GetValue() *KeyValueResponse_Value

func (*KeyValueResponse) Marshal 

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

func (*KeyValueResponse) MarshalTo 

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

func (*KeyValueResponse) MarshalToSizedBuffer 

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

func (*KeyValueResponse) ProtoMessage 

func (*KeyValueResponse) ProtoMessage()

func (*KeyValueResponse) Reset 

func (m *KeyValueResponse) Reset()

func (*KeyValueResponse) Size 

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

func (*KeyValueResponse) String 

func (m *KeyValueResponse) String() string

func (*KeyValueResponse) Unmarshal 

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

func (*KeyValueResponse) XXX_DiscardUnknown 

func (m *KeyValueResponse) XXX_DiscardUnknown()

func (*KeyValueResponse) XXX_Marshal 

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

func (*KeyValueResponse) XXX_Merge 

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

func (*KeyValueResponse) XXX_Size 

func (m *KeyValueResponse) XXX_Size() int

func (*KeyValueResponse) XXX_Unmarshal 

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

type KeyValueResponse_Value 

type KeyValueResponse_Value struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KeyValueResponse_Value) Descriptor 

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

func (*KeyValueResponse_Value) GetValue 

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

func (*KeyValueResponse_Value) Marshal 

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

func (*KeyValueResponse_Value) MarshalTo 

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

func (*KeyValueResponse_Value) MarshalToSizedBuffer 

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

func (*KeyValueResponse_Value) ProtoMessage 

func (*KeyValueResponse_Value) ProtoMessage()

func (*KeyValueResponse_Value) Reset 

func (m *KeyValueResponse_Value) Reset()

func (*KeyValueResponse_Value) Size 

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

func (*KeyValueResponse_Value) String 

func (m *KeyValueResponse_Value) String() string

func (*KeyValueResponse_Value) Unmarshal 

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

func (*KeyValueResponse_Value) XXX_DiscardUnknown 

func (m *KeyValueResponse_Value) XXX_DiscardUnknown()

func (*KeyValueResponse_Value) XXX_Marshal 

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

func (*KeyValueResponse_Value) XXX_Merge 

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

func (*KeyValueResponse_Value) XXX_Size 

func (m *KeyValueResponse_Value) XXX_Size() int

func (*KeyValueResponse_Value) XXX_Unmarshal 

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

type NonVerifiableKeyValueRequest 

type NonVerifiableKeyValueRequest struct {
	Key *NonVerifiableKeyValueRequest_Key `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

Performs a key-value query against the nonverifiable storage, using a byte-encoded key.

func (*NonVerifiableKeyValueRequest) Descriptor 

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

func (*NonVerifiableKeyValueRequest) GetKey 

func (m *NonVerifiableKeyValueRequest) GetKey() *NonVerifiableKeyValueRequest_Key

func (*NonVerifiableKeyValueRequest) Marshal 

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

func (*NonVerifiableKeyValueRequest) MarshalTo 

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

func (*NonVerifiableKeyValueRequest) MarshalToSizedBuffer 

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

func (*NonVerifiableKeyValueRequest) ProtoMessage 

func (*NonVerifiableKeyValueRequest) ProtoMessage()

func (*NonVerifiableKeyValueRequest) Reset 

func (m *NonVerifiableKeyValueRequest) Reset()

func (*NonVerifiableKeyValueRequest) Size 

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

func (*NonVerifiableKeyValueRequest) String 

func (m *NonVerifiableKeyValueRequest) String() string

func (*NonVerifiableKeyValueRequest) Unmarshal 

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

func (*NonVerifiableKeyValueRequest) XXX_DiscardUnknown 

func (m *NonVerifiableKeyValueRequest) XXX_DiscardUnknown()

func (*NonVerifiableKeyValueRequest) XXX_Marshal 

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

func (*NonVerifiableKeyValueRequest) XXX_Merge 

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

func (*NonVerifiableKeyValueRequest) XXX_Size 

func (m *NonVerifiableKeyValueRequest) XXX_Size() int

func (*NonVerifiableKeyValueRequest) XXX_Unmarshal 

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

type NonVerifiableKeyValueRequest_Key 

type NonVerifiableKeyValueRequest_Key struct {
	Inner []byte `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"`
}

func (*NonVerifiableKeyValueRequest_Key) Descriptor 

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

func (*NonVerifiableKeyValueRequest_Key) GetInner 

func (m *NonVerifiableKeyValueRequest_Key) GetInner() []byte

func (*NonVerifiableKeyValueRequest_Key) Marshal 

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

func (*NonVerifiableKeyValueRequest_Key) MarshalTo 

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

func (*NonVerifiableKeyValueRequest_Key) MarshalToSizedBuffer 

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

func (*NonVerifiableKeyValueRequest_Key) ProtoMessage 

func (*NonVerifiableKeyValueRequest_Key) ProtoMessage()

func (*NonVerifiableKeyValueRequest_Key) Reset 

func (m *NonVerifiableKeyValueRequest_Key) Reset()

func (*NonVerifiableKeyValueRequest_Key) Size 

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

func (*NonVerifiableKeyValueRequest_Key) String 

func (m *NonVerifiableKeyValueRequest_Key) String() string

func (*NonVerifiableKeyValueRequest_Key) Unmarshal 

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

func (*NonVerifiableKeyValueRequest_Key) XXX_DiscardUnknown 

func (m *NonVerifiableKeyValueRequest_Key) XXX_DiscardUnknown()

func (*NonVerifiableKeyValueRequest_Key) XXX_Marshal 

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

func (*NonVerifiableKeyValueRequest_Key) XXX_Merge 

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

func (*NonVerifiableKeyValueRequest_Key) XXX_Size 

func (m *NonVerifiableKeyValueRequest_Key) XXX_Size() int

func (*NonVerifiableKeyValueRequest_Key) XXX_Unmarshal 

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

type NonVerifiableKeyValueResponse 

type NonVerifiableKeyValueResponse struct {
	// The value corresponding to the specified key, if it was found.
	Value *NonVerifiableKeyValueResponse_Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*NonVerifiableKeyValueResponse) Descriptor 

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

func (*NonVerifiableKeyValueResponse) GetValue 

func (m *NonVerifiableKeyValueResponse) GetValue() *NonVerifiableKeyValueResponse_Value

func (*NonVerifiableKeyValueResponse) Marshal 

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

func (*NonVerifiableKeyValueResponse) MarshalTo 

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

func (*NonVerifiableKeyValueResponse) MarshalToSizedBuffer 

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

func (*NonVerifiableKeyValueResponse) ProtoMessage 

func (*NonVerifiableKeyValueResponse) ProtoMessage()

func (*NonVerifiableKeyValueResponse) Reset 

func (m *NonVerifiableKeyValueResponse) Reset()

func (*NonVerifiableKeyValueResponse) Size 

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

func (*NonVerifiableKeyValueResponse) String 

func (m *NonVerifiableKeyValueResponse) String() string

func (*NonVerifiableKeyValueResponse) Unmarshal 

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

func (*NonVerifiableKeyValueResponse) XXX_DiscardUnknown 

func (m *NonVerifiableKeyValueResponse) XXX_DiscardUnknown()

func (*NonVerifiableKeyValueResponse) XXX_Marshal 

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

func (*NonVerifiableKeyValueResponse) XXX_Merge 

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

func (*NonVerifiableKeyValueResponse) XXX_Size 

func (m *NonVerifiableKeyValueResponse) XXX_Size() int

func (*NonVerifiableKeyValueResponse) XXX_Unmarshal 

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

type NonVerifiableKeyValueResponse_Value 

type NonVerifiableKeyValueResponse_Value struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*NonVerifiableKeyValueResponse_Value) Descriptor 

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

func (*NonVerifiableKeyValueResponse_Value) GetValue 

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

func (*NonVerifiableKeyValueResponse_Value) Marshal 

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

func (*NonVerifiableKeyValueResponse_Value) MarshalTo 

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

func (*NonVerifiableKeyValueResponse_Value) MarshalToSizedBuffer 

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

func (*NonVerifiableKeyValueResponse_Value) ProtoMessage 

func (*NonVerifiableKeyValueResponse_Value) ProtoMessage()

func (*NonVerifiableKeyValueResponse_Value) Reset 

func (m *NonVerifiableKeyValueResponse_Value) Reset()

func (*NonVerifiableKeyValueResponse_Value) Size 

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

func (*NonVerifiableKeyValueResponse_Value) String 

func (m *NonVerifiableKeyValueResponse_Value) String() string

func (*NonVerifiableKeyValueResponse_Value) Unmarshal 

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

func (*NonVerifiableKeyValueResponse_Value) XXX_DiscardUnknown 

func (m *NonVerifiableKeyValueResponse_Value) XXX_DiscardUnknown()

func (*NonVerifiableKeyValueResponse_Value) XXX_Marshal 

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

func (*NonVerifiableKeyValueResponse_Value) XXX_Merge 

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

func (*NonVerifiableKeyValueResponse_Value) XXX_Size 

func (m *NonVerifiableKeyValueResponse_Value) XXX_Size() int

func (*NonVerifiableKeyValueResponse_Value) XXX_Unmarshal 

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

type PrefixValueRequest 

type PrefixValueRequest struct {
	// The prefix to fetch subkeys from storage.
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
}

Performs a prefixed key-value query, by string prefix.

func (*PrefixValueRequest) Descriptor 

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

func (*PrefixValueRequest) GetPrefix 

func (m *PrefixValueRequest) GetPrefix() string

func (*PrefixValueRequest) Marshal 

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

func (*PrefixValueRequest) MarshalTo 

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

func (*PrefixValueRequest) MarshalToSizedBuffer 

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

func (*PrefixValueRequest) ProtoMessage 

func (*PrefixValueRequest) ProtoMessage()

func (*PrefixValueRequest) Reset 

func (m *PrefixValueRequest) Reset()

func (*PrefixValueRequest) Size 

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

func (*PrefixValueRequest) String 

func (m *PrefixValueRequest) String() string

func (*PrefixValueRequest) Unmarshal 

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

func (*PrefixValueRequest) XXX_DiscardUnknown 

func (m *PrefixValueRequest) XXX_DiscardUnknown()

func (*PrefixValueRequest) XXX_Marshal 

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

func (*PrefixValueRequest) XXX_Merge 

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

func (*PrefixValueRequest) XXX_Size 

func (m *PrefixValueRequest) XXX_Size() int

func (*PrefixValueRequest) XXX_Unmarshal 

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

type PrefixValueResponse 

type PrefixValueResponse struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*PrefixValueResponse) Descriptor 

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

func (*PrefixValueResponse) GetKey 

func (m *PrefixValueResponse) GetKey() string

func (*PrefixValueResponse) GetValue 

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

func (*PrefixValueResponse) Marshal 

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

func (*PrefixValueResponse) MarshalTo 

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

func (*PrefixValueResponse) MarshalToSizedBuffer 

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

func (*PrefixValueResponse) ProtoMessage 

func (*PrefixValueResponse) ProtoMessage()

func (*PrefixValueResponse) Reset 

func (m *PrefixValueResponse) Reset()

func (*PrefixValueResponse) Size 

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

func (*PrefixValueResponse) String 

func (m *PrefixValueResponse) String() string

func (*PrefixValueResponse) Unmarshal 

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

func (*PrefixValueResponse) XXX_DiscardUnknown 

func (m *PrefixValueResponse) XXX_DiscardUnknown()

func (*PrefixValueResponse) XXX_Marshal 

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

func (*PrefixValueResponse) XXX_Merge 

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

func (*PrefixValueResponse) XXX_Size 

func (m *PrefixValueResponse) XXX_Size() int

func (*PrefixValueResponse) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	// General-purpose key-value state query API, that can be used to query
	// arbitrary keys in the JMT storage.
	KeyValue(ctx context.Context, in *KeyValueRequest, opts ...grpc.CallOption) (*KeyValueResponse, error)
	// General-purpose key-value state query API, that can be used to query
	// arbitrary keys in the non-verifiable storage.
	NonVerifiableKeyValue(ctx context.Context, in *NonVerifiableKeyValueRequest, opts ...grpc.CallOption) (*NonVerifiableKeyValueResponse, error)
	// General-purpose prefixed key-value state query API, that can be used to query
	// arbitrary prefixes in the JMT storage.
	PrefixValue(ctx context.Context, in *PrefixValueRequest, opts ...grpc.CallOption) (QueryService_PrefixValueClient, error)
	// Subscribes to a stream of key-value updates, with regex filtering on keys.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (QueryService_WatchClient, error)
}

QueryServiceClient is the client API for QueryService service.

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

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// General-purpose key-value state query API, that can be used to query
	// arbitrary keys in the JMT storage.
	KeyValue(context.Context, *KeyValueRequest) (*KeyValueResponse, error)
	// General-purpose key-value state query API, that can be used to query
	// arbitrary keys in the non-verifiable storage.
	NonVerifiableKeyValue(context.Context, *NonVerifiableKeyValueRequest) (*NonVerifiableKeyValueResponse, error)
	// General-purpose prefixed key-value state query API, that can be used to query
	// arbitrary prefixes in the JMT storage.
	PrefixValue(*PrefixValueRequest, QueryService_PrefixValueServer) error
	// Subscribes to a stream of key-value updates, with regex filtering on keys.
	Watch(*WatchRequest, QueryService_WatchServer) error
}

QueryServiceServer is the server API for QueryService service.

type QueryService_PrefixValueClient 

type QueryService_PrefixValueClient interface {
	Recv() (*PrefixValueResponse, error)
	grpc.ClientStream
}

type QueryService_PrefixValueServer 

type QueryService_PrefixValueServer interface {
	Send(*PrefixValueResponse) error
	grpc.ServerStream
}

type QueryService_WatchClient 

type QueryService_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type QueryService_WatchServer 

type QueryService_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) KeyValue 

func (*UnimplementedQueryServiceServer) KeyValue(ctx context.Context, req *KeyValueRequest) (*KeyValueResponse, error)

func (*UnimplementedQueryServiceServer) NonVerifiableKeyValue 

func (*UnimplementedQueryServiceServer) NonVerifiableKeyValue(ctx context.Context, req *NonVerifiableKeyValueRequest) (*NonVerifiableKeyValueResponse, error)

func (*UnimplementedQueryServiceServer) PrefixValue 

func (*UnimplementedQueryServiceServer) PrefixValue(req *PrefixValueRequest, srv QueryService_PrefixValueServer) error

func (*UnimplementedQueryServiceServer) Watch 

func (*UnimplementedQueryServiceServer) Watch(req *WatchRequest, srv QueryService_WatchServer) error

type WatchRequest 

type WatchRequest struct {
	// A regex for keys in the verifiable storage.
	//
	// Only key-value updates whose keys match this regex will be returned.
	// Note that the empty string matches all keys.
	// To exclude all keys, use the regex "$^", which matches no strings.
	KeyRegex string `protobuf:"bytes,1,opt,name=key_regex,json=keyRegex,proto3" json:"key_regex,omitempty"`
	// A regex for keys in the nonverifiable storage.
	//
	// Only key-value updates whose keys match this regex will be returned.
	// Note that the empty string matches all keys.
	// To exclude all keys, use the regex "$^", which matches no strings.
	NvKeyRegex string `protobuf:"bytes,2,opt,name=nv_key_regex,json=nvKeyRegex,proto3" json:"nv_key_regex,omitempty"`
}

Requests a stream of new key-value pairs that have been committed to the state.

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetKeyRegex 

func (m *WatchRequest) GetKeyRegex() string

func (*WatchRequest) GetNvKeyRegex 

func (m *WatchRequest) GetNvKeyRegex() string

func (*WatchRequest) Marshal 

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

func (*WatchRequest) MarshalTo 

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

func (*WatchRequest) MarshalToSizedBuffer 

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

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size 

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

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) Unmarshal 

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

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

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

func (*WatchRequest) XXX_Merge 

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

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

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

type WatchResponse 

type WatchResponse struct {
	// The state version the key-value pair was committed at.
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// The entry that was committed.
	//
	// Types that are valid to be assigned to Entry:
	//	*WatchResponse_Kv
	//	*WatchResponse_NvKv
	Entry isWatchResponse_Entry `protobuf_oneof:"entry"`
}

A key-value pair that has been committed to the state.

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetEntry 

func (m *WatchResponse) GetEntry() isWatchResponse_Entry

func (*WatchResponse) GetKv 

func (m *WatchResponse) GetKv() *WatchResponse_KeyValue

func (*WatchResponse) GetNvKv 

func (m *WatchResponse) GetNvKv() *WatchResponse_NvKeyValue

func (*WatchResponse) GetVersion 

func (m *WatchResponse) GetVersion() uint64

func (*WatchResponse) Marshal 

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

func (*WatchResponse) MarshalTo 

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

func (*WatchResponse) MarshalToSizedBuffer 

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

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) Size 

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

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) Unmarshal 

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

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

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

func (*WatchResponse) XXX_Merge 

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

func (*WatchResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

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

type WatchResponse_KeyValue 

type WatchResponse_KeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// If set to true, the key-value pair was deleted.
	// This allows distinguishing a deleted key-value pair from a key-value pair whose value is empty.
	Deleted bool `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
}

Elements of the verifiable storage have string keys.

func (*WatchResponse_KeyValue) Descriptor 

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

func (*WatchResponse_KeyValue) GetDeleted 

func (m *WatchResponse_KeyValue) GetDeleted() bool

func (*WatchResponse_KeyValue) GetKey 

func (m *WatchResponse_KeyValue) GetKey() string

func (*WatchResponse_KeyValue) GetValue 

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

func (*WatchResponse_KeyValue) Marshal 

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

func (*WatchResponse_KeyValue) MarshalTo 

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

func (*WatchResponse_KeyValue) MarshalToSizedBuffer 

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

func (*WatchResponse_KeyValue) ProtoMessage 

func (*WatchResponse_KeyValue) ProtoMessage()

func (*WatchResponse_KeyValue) Reset 

func (m *WatchResponse_KeyValue) Reset()

func (*WatchResponse_KeyValue) Size 

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

func (*WatchResponse_KeyValue) String 

func (m *WatchResponse_KeyValue) String() string

func (*WatchResponse_KeyValue) Unmarshal 

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

func (*WatchResponse_KeyValue) XXX_DiscardUnknown 

func (m *WatchResponse_KeyValue) XXX_DiscardUnknown()

func (*WatchResponse_KeyValue) XXX_Marshal 

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

func (*WatchResponse_KeyValue) XXX_Merge 

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

func (*WatchResponse_KeyValue) XXX_Size 

func (m *WatchResponse_KeyValue) XXX_Size() int

func (*WatchResponse_KeyValue) XXX_Unmarshal 

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

type WatchResponse_Kv 

type WatchResponse_Kv struct {
	Kv *WatchResponse_KeyValue `protobuf:"bytes,5,opt,name=kv,proto3,oneof" json:"kv,omitempty"`
}

func (*WatchResponse_Kv) MarshalTo 

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

func (*WatchResponse_Kv) MarshalToSizedBuffer 

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

func (*WatchResponse_Kv) Size 

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

type WatchResponse_NvKeyValue 

type WatchResponse_NvKeyValue struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// If set to true, the key-value pair was deleted.
	// This allows distinguishing a deleted key-value pair from a key-value pair whose value is empty.
	Deleted bool `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
}

Elements of the nonverifiable storage have byte keys.

func (*WatchResponse_NvKeyValue) Descriptor 

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

func (*WatchResponse_NvKeyValue) GetDeleted 

func (m *WatchResponse_NvKeyValue) GetDeleted() bool

func (*WatchResponse_NvKeyValue) GetKey 

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

func (*WatchResponse_NvKeyValue) GetValue 

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

func (*WatchResponse_NvKeyValue) Marshal 

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

func (*WatchResponse_NvKeyValue) MarshalTo 

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

func (*WatchResponse_NvKeyValue) MarshalToSizedBuffer 

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

func (*WatchResponse_NvKeyValue) ProtoMessage 

func (*WatchResponse_NvKeyValue) ProtoMessage()

func (*WatchResponse_NvKeyValue) Reset 

func (m *WatchResponse_NvKeyValue) Reset()

func (*WatchResponse_NvKeyValue) Size 

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

func (*WatchResponse_NvKeyValue) String 

func (m *WatchResponse_NvKeyValue) String() string

func (*WatchResponse_NvKeyValue) Unmarshal 

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

func (*WatchResponse_NvKeyValue) XXX_DiscardUnknown 

func (m *WatchResponse_NvKeyValue) XXX_DiscardUnknown()

func (*WatchResponse_NvKeyValue) XXX_Marshal 

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

func (*WatchResponse_NvKeyValue) XXX_Merge 

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

func (*WatchResponse_NvKeyValue) XXX_Size 

func (m *WatchResponse_NvKeyValue) XXX_Size() int

func (*WatchResponse_NvKeyValue) XXX_Unmarshal 

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

type WatchResponse_NvKv 

type WatchResponse_NvKv struct {
	NvKv *WatchResponse_NvKeyValue `protobuf:"bytes,6,opt,name=nv_kv,json=nvKv,proto3,oneof" json:"nv_kv,omitempty"`
}

func (*WatchResponse_NvKv) MarshalTo 

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

func (*WatchResponse_NvKv) MarshalToSizedBuffer 

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

func (*WatchResponse_NvKv) Size 

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

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.