schema

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2021 License: Apache-2.0 Imports: 32 Imported by: 41

Documentation

Overview

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package schema is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEmptySet                         = status.New(codes.InvalidArgument, "empty set").Err()
	ErrDuplicatedKeysNotSupported       = status.New(codes.InvalidArgument, "duplicated keys are not supported in single batch transaction").Err()
	ErrDuplicatedZAddNotSupported       = status.New(codes.InvalidArgument, "duplicated index inside zAdd insertions are not supported in single batch transaction").Err()
	ErrDuplicatedReferencesNotSupported = status.New(codes.InvalidArgument, "duplicated references insertions are not supported in single batch transaction").Err()
)
View Source 
var (
	PermissionAction_name = map[int32]string{
		0: "GRANT",
		1: "REVOKE",
	}
	PermissionAction_value = map[string]int32{
		"GRANT":  0,
		"REVOKE": 1,
	}
)

Enum value maps for PermissionAction.

View Source 
var File_schema_proto protoreflect.FileDescriptor

Functions

func DigestFrom added in v0.9.0 

func DigestFrom(slicedDigest []byte) [sha256.Size]byte

func DigestsFrom added in v0.9.0 

func DigestsFrom(slicedTerms [][]byte) [][sha256.Size]byte

func DigestsTo added in v0.9.0 

func DigestsTo(terms [][sha256.Size]byte) [][]byte

func DualProofFrom added in v0.9.0 

func DualProofFrom(dproof *DualProof) *store.DualProof

func InclusionProofFrom added in v0.9.0 

func InclusionProofFrom(iproof *InclusionProof) *htree.InclusionProof

func LinearProofFrom added in v0.9.0 

func LinearProofFrom(lproof *LinearProof) *store.LinearProof

func Pattern_ImmuService_History_0 

func Pattern_ImmuService_History_0() runtime.Pattern

Pattern_ImmuService_History_0 exposes the runtime Pattern need to overwrite history autogenerated request

func Pattern_ImmuService_Set_0 

func Pattern_ImmuService_Set_0() runtime.Pattern

Pattern_ImmuService_Set_0 exposes the runtime Pattern need to overwrite set autogenerated request

func Pattern_ImmuService_UseDatabase_0 added in v0.7.0 

func Pattern_ImmuService_UseDatabase_0() runtime.Pattern

Pattern_ImmuService_UseDatabase_0 exposes the runtime Pattern need to overwrite UseDatabase autogenerated request

func Pattern_ImmuService_VerifiableGet_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableGet_0() runtime.Pattern

Pattern_ImmuService_VerifiableGet_0 exposes the runtime Pattern need to overwrite VerifiableGet autogenerated request

func Pattern_ImmuService_VerifiableSetReference_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableSetReference_0() runtime.Pattern

Pattern_ImmuService_VerifiableSetReference_0 exposes the runtime Pattern need to overwrite VerifiableSetReference autogenerated request

func Pattern_ImmuService_VerifiableSet_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableSet_0() runtime.Pattern

Pattern_ImmuService_VerifiableSet_0 exposes the runtime Pattern need to overwrite VerifiableSet autogenerated request

func Pattern_ImmuService_VerifiableTxById_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableTxById_0() runtime.Pattern

Pattern_ImmuService_VerifiableTxById_0 exposes the runtime Pattern need to overwrite VerifiableTxById autogenerated request

func Pattern_ImmuService_VerifiableZAdd_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableZAdd_0() runtime.Pattern

Pattern_ImmuService_VerifiableZAdd_0 exposes the runtime Pattern need to overwrite VerifiableZAdd autogenerated request

func RawValue added in v1.0.0 

func RawValue(v *SQLValue) interface{}

func RegisterImmuServiceHandler 

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

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

func RegisterImmuServiceHandlerClient 

func RegisterImmuServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ImmuServiceClient) error

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

func RegisterImmuServiceHandlerFromEndpoint 

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

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

func RegisterImmuServiceHandlerServer 

func RegisterImmuServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ImmuServiceServer) error

RegisterImmuServiceHandlerServer registers the http handlers for service ImmuService to "mux". UnaryRPC :call ImmuServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterImmuServiceHandlerFromEndpoint instead.

func RegisterImmuServiceServer 

func RegisterImmuServiceServer(s *grpc.Server, srv ImmuServiceServer)

func RenderValue added in v1.0.0 

func RenderValue(op isSQLValue_Value) string

func RenderValueAsByte added in v1.0.0 

func RenderValueAsByte(op isSQLValue_Value) []byte

func TxFrom added in v0.9.0 

func TxFrom(stx *Tx) *store.Tx

func TxMetadataFrom added in v0.9.0 

func TxMetadataFrom(txMetadata *TxMetadata) *store.TxMetadata

Types

type AuthConfig 

type AuthConfig struct {
	Kind uint32 `protobuf:"varint,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthConfig) Descriptor deprecated 

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

Deprecated: Use AuthConfig.ProtoReflect.Descriptor instead.

func (*AuthConfig) GetKind 

func (x *AuthConfig) GetKind() uint32

func (*AuthConfig) ProtoMessage 

func (*AuthConfig) ProtoMessage()

func (*AuthConfig) ProtoReflect added in v0.9.0 

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

func (*AuthConfig) Reset 

func (x *AuthConfig) Reset()

func (*AuthConfig) String 

func (x *AuthConfig) String() string

type ChangePasswordRequest 

type ChangePasswordRequest struct {
	User        []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	OldPassword []byte `protobuf:"bytes,2,opt,name=oldPassword,proto3" json:"oldPassword,omitempty"`
	NewPassword []byte `protobuf:"bytes,3,opt,name=newPassword,proto3" json:"newPassword,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangePasswordRequest) Descriptor deprecated 

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

Deprecated: Use ChangePasswordRequest.ProtoReflect.Descriptor instead.

func (*ChangePasswordRequest) GetNewPassword 

func (x *ChangePasswordRequest) GetNewPassword() []byte

func (*ChangePasswordRequest) GetOldPassword 

func (x *ChangePasswordRequest) GetOldPassword() []byte

func (*ChangePasswordRequest) GetUser 

func (x *ChangePasswordRequest) GetUser() []byte

func (*ChangePasswordRequest) ProtoMessage 

func (*ChangePasswordRequest) ProtoMessage()

func (*ChangePasswordRequest) ProtoReflect added in v0.9.0 

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

func (*ChangePasswordRequest) Reset 

func (x *ChangePasswordRequest) Reset()

func (*ChangePasswordRequest) String 

func (x *ChangePasswordRequest) String() string

type ChangePermissionRequest added in v0.7.0 

type ChangePermissionRequest struct {
	Action     PermissionAction `protobuf:"varint,1,opt,name=action,proto3,enum=immudb.schema.PermissionAction" json:"action,omitempty"`
	Username   string           `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Database   string           `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	Permission uint32           `protobuf:"varint,4,opt,name=permission,proto3" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangePermissionRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ChangePermissionRequest.ProtoReflect.Descriptor instead.

func (*ChangePermissionRequest) GetAction added in v0.7.0 

func (x *ChangePermissionRequest) GetAction() PermissionAction

func (*ChangePermissionRequest) GetDatabase added in v0.7.0 

func (x *ChangePermissionRequest) GetDatabase() string

func (*ChangePermissionRequest) GetPermission added in v0.7.0 

func (x *ChangePermissionRequest) GetPermission() uint32

func (*ChangePermissionRequest) GetUsername added in v0.7.0 

func (x *ChangePermissionRequest) GetUsername() string

func (*ChangePermissionRequest) ProtoMessage added in v0.7.0 

func (*ChangePermissionRequest) ProtoMessage()

func (*ChangePermissionRequest) ProtoReflect added in v0.9.0 

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

func (*ChangePermissionRequest) Reset added in v0.7.0 

func (x *ChangePermissionRequest) Reset()

func (*ChangePermissionRequest) String added in v0.7.0 

func (x *ChangePermissionRequest) String() string

type Chunk added in v0.9.2 

type Chunk struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetContent added in v0.9.2 

func (x *Chunk) GetContent() []byte

func (*Chunk) ProtoMessage added in v0.9.2 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect added in v0.9.2 

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

func (*Chunk) Reset added in v0.9.2 

func (x *Chunk) Reset()

func (*Chunk) String added in v0.9.2 

func (x *Chunk) String() string

type Column added in v1.0.0 

type Column struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetName added in v1.0.0 

func (x *Column) GetName() string

func (*Column) GetType added in v1.0.0 

func (x *Column) GetType() string

func (*Column) ProtoMessage added in v1.0.0 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect added in v1.0.0 

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

func (*Column) Reset added in v1.0.0 

func (x *Column) Reset()

func (*Column) String added in v1.0.0 

func (x *Column) String() string

type CreateUserRequest 

type CreateUserRequest struct {
	User       []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password   []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Permission uint32 `protobuf:"varint,3,opt,name=permission,proto3" json:"permission,omitempty"`
	Database   string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetDatabase added in v0.7.0 

func (x *CreateUserRequest) GetDatabase() string

func (*CreateUserRequest) GetPassword 

func (x *CreateUserRequest) GetPassword() []byte

func (*CreateUserRequest) GetPermission added in v0.7.0 

func (x *CreateUserRequest) GetPermission() uint32

func (*CreateUserRequest) GetUser 

func (x *CreateUserRequest) GetUser() []byte

func (*CreateUserRequest) ProtoMessage 

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect added in v0.9.0 

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

func (*CreateUserRequest) Reset 

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String 

func (x *CreateUserRequest) String() string

type Database added in v0.7.0 

type Database struct {
	DatabaseName string `protobuf:"bytes,1,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	// contains filtered or unexported fields
}

func (*Database) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetDatabaseName added in v1.0.0 

func (x *Database) GetDatabaseName() string

func (*Database) ProtoMessage added in v0.7.0 

func (*Database) ProtoMessage()

func (*Database) ProtoReflect added in v0.9.0 

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

func (*Database) Reset added in v0.7.0 

func (x *Database) Reset()

func (*Database) String added in v0.7.0 

func (x *Database) String() string

type DatabaseListResponse added in v0.7.0 

type DatabaseListResponse struct {
	Databases []*Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseListResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DatabaseListResponse.ProtoReflect.Descriptor instead.

func (*DatabaseListResponse) GetDatabases added in v0.7.0 

func (x *DatabaseListResponse) GetDatabases() []*Database

func (*DatabaseListResponse) ProtoMessage added in v0.7.0 

func (*DatabaseListResponse) ProtoMessage()

func (*DatabaseListResponse) ProtoReflect added in v0.9.0 

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

func (*DatabaseListResponse) Reset added in v0.7.0 

func (x *DatabaseListResponse) Reset()

func (*DatabaseListResponse) String added in v0.7.0 

func (x *DatabaseListResponse) String() string

type DatabaseSettings added in v1.0.5 

type DatabaseSettings struct {
	DatabaseName      string `protobuf:"bytes,1,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	Replica           bool   `protobuf:"varint,2,opt,name=replica,proto3" json:"replica,omitempty"`
	MasterDatabase    string `protobuf:"bytes,3,opt,name=masterDatabase,proto3" json:"masterDatabase,omitempty"`
	MasterAddress     string `protobuf:"bytes,4,opt,name=masterAddress,proto3" json:"masterAddress,omitempty"`
	MasterPort        uint32 `protobuf:"varint,5,opt,name=masterPort,proto3" json:"masterPort,omitempty"`
	FollowerUsername  string `protobuf:"bytes,6,opt,name=followerUsername,proto3" json:"followerUsername,omitempty"`
	FollowerPassword  string `protobuf:"bytes,7,opt,name=followerPassword,proto3" json:"followerPassword,omitempty"`
	FileSize          uint32 `protobuf:"varint,8,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	MaxKeyLen         uint32 `protobuf:"varint,9,opt,name=maxKeyLen,proto3" json:"maxKeyLen,omitempty"`
	MaxValueLen       uint32 `protobuf:"varint,10,opt,name=maxValueLen,proto3" json:"maxValueLen,omitempty"`
	MaxTxEntries      uint32 `protobuf:"varint,11,opt,name=maxTxEntries,proto3" json:"maxTxEntries,omitempty"`
	ExcludeCommitTime bool   `protobuf:"varint,12,opt,name=excludeCommitTime,proto3" json:"excludeCommitTime,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseSettings) Descriptor deprecated added in v1.0.5 

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

Deprecated: Use DatabaseSettings.ProtoReflect.Descriptor instead.

func (*DatabaseSettings) GetDatabaseName added in v1.0.5 

func (x *DatabaseSettings) GetDatabaseName() string

func (*DatabaseSettings) GetExcludeCommitTime added in v1.1.0 

func (x *DatabaseSettings) GetExcludeCommitTime() bool

func (*DatabaseSettings) GetFileSize added in v1.1.0 

func (x *DatabaseSettings) GetFileSize() uint32

func (*DatabaseSettings) GetFollowerPassword added in v1.1.0 

func (x *DatabaseSettings) GetFollowerPassword() string

func (*DatabaseSettings) GetFollowerUsername added in v1.1.0 

func (x *DatabaseSettings) GetFollowerUsername() string

func (*DatabaseSettings) GetMasterAddress added in v1.1.0 

func (x *DatabaseSettings) GetMasterAddress() string

func (*DatabaseSettings) GetMasterDatabase added in v1.1.0 

func (x *DatabaseSettings) GetMasterDatabase() string

func (*DatabaseSettings) GetMasterPort added in v1.1.0 

func (x *DatabaseSettings) GetMasterPort() uint32

func (*DatabaseSettings) GetMaxKeyLen added in v1.1.0 

func (x *DatabaseSettings) GetMaxKeyLen() uint32

func (*DatabaseSettings) GetMaxTxEntries added in v1.1.0 

func (x *DatabaseSettings) GetMaxTxEntries() uint32

func (*DatabaseSettings) GetMaxValueLen added in v1.1.0 

func (x *DatabaseSettings) GetMaxValueLen() uint32

func (*DatabaseSettings) GetReplica added in v1.0.5 

func (x *DatabaseSettings) GetReplica() bool

func (*DatabaseSettings) ProtoMessage added in v1.0.5 

func (*DatabaseSettings) ProtoMessage()

func (*DatabaseSettings) ProtoReflect added in v1.0.5 

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

func (*DatabaseSettings) Reset added in v1.0.5 

func (x *DatabaseSettings) Reset()

func (*DatabaseSettings) String added in v1.0.5 

func (x *DatabaseSettings) String() string

type DebugInfo added in v1.0.5 

type DebugInfo struct {
	Stack string `protobuf:"bytes,1,opt,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugInfo) Descriptor deprecated added in v1.0.5 

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

Deprecated: Use DebugInfo.ProtoReflect.Descriptor instead.

func (*DebugInfo) GetStack added in v1.0.5 

func (x *DebugInfo) GetStack() string

func (*DebugInfo) ProtoMessage added in v1.0.5 

func (*DebugInfo) ProtoMessage()

func (*DebugInfo) ProtoReflect added in v1.0.5 

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

func (*DebugInfo) Reset added in v1.0.5 

func (x *DebugInfo) Reset()

func (*DebugInfo) String added in v1.0.5 

func (x *DebugInfo) String() string

type DualProof added in v0.9.0 

type DualProof struct {
	SourceTxMetadata   *TxMetadata  `protobuf:"bytes,1,opt,name=sourceTxMetadata,proto3" json:"sourceTxMetadata,omitempty"`
	TargetTxMetadata   *TxMetadata  `protobuf:"bytes,2,opt,name=targetTxMetadata,proto3" json:"targetTxMetadata,omitempty"`
	InclusionProof     [][]byte     `protobuf:"bytes,3,rep,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	ConsistencyProof   [][]byte     `protobuf:"bytes,4,rep,name=consistencyProof,proto3" json:"consistencyProof,omitempty"`
	TargetBlTxAlh      []byte       `protobuf:"bytes,5,opt,name=targetBlTxAlh,proto3" json:"targetBlTxAlh,omitempty"`
	LastInclusionProof [][]byte     `protobuf:"bytes,6,rep,name=lastInclusionProof,proto3" json:"lastInclusionProof,omitempty"`
	LinearProof        *LinearProof `protobuf:"bytes,7,opt,name=linearProof,proto3" json:"linearProof,omitempty"`
	// contains filtered or unexported fields
}

func DualProofTo added in v0.9.0 

func DualProofTo(dualProof *store.DualProof) *DualProof

func (*DualProof) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DualProof.ProtoReflect.Descriptor instead.

func (*DualProof) GetConsistencyProof added in v0.9.0 

func (x *DualProof) GetConsistencyProof() [][]byte

func (*DualProof) GetInclusionProof added in v0.9.0 

func (x *DualProof) GetInclusionProof() [][]byte

func (*DualProof) GetLastInclusionProof added in v0.9.0 

func (x *DualProof) GetLastInclusionProof() [][]byte

func (*DualProof) GetLinearProof added in v0.9.0 

func (x *DualProof) GetLinearProof() *LinearProof

func (*DualProof) GetSourceTxMetadata added in v0.9.0 

func (x *DualProof) GetSourceTxMetadata() *TxMetadata

func (*DualProof) GetTargetBlTxAlh added in v0.9.0 

func (x *DualProof) GetTargetBlTxAlh() []byte

func (*DualProof) GetTargetTxMetadata added in v0.9.0 

func (x *DualProof) GetTargetTxMetadata() *TxMetadata

func (*DualProof) ProtoMessage added in v0.9.0 

func (*DualProof) ProtoMessage()

func (*DualProof) ProtoReflect added in v0.9.0 

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

func (*DualProof) Reset added in v0.9.0 

func (x *DualProof) Reset()

func (*DualProof) String added in v0.9.0 

func (x *DualProof) String() string

type Entries added in v0.9.0 

type Entries struct {
	Entries []*Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*Entries) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Entries.ProtoReflect.Descriptor instead.

func (*Entries) GetEntries added in v0.9.0 

func (x *Entries) GetEntries() []*Entry

func (*Entries) ProtoMessage added in v0.9.0 

func (*Entries) ProtoMessage()

func (*Entries) ProtoReflect added in v0.9.0 

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

func (*Entries) Reset added in v0.9.0 

func (x *Entries) Reset()

func (*Entries) String added in v0.9.0 

func (x *Entries) String() string

type Entry added in v0.9.0 

type Entry struct {
	Tx           uint64     `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Key          []byte     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value        []byte     `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	ReferencedBy *Reference `protobuf:"bytes,4,opt,name=referencedBy,proto3" json:"referencedBy,omitempty"`
	// contains filtered or unexported fields
}

func (*Entry) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetKey added in v0.9.0 

func (x *Entry) GetKey() []byte

func (*Entry) GetReferencedBy added in v0.9.0 

func (x *Entry) GetReferencedBy() *Reference

func (*Entry) GetTx added in v0.9.0 

func (x *Entry) GetTx() uint64

func (*Entry) GetValue added in v0.9.0 

func (x *Entry) GetValue() []byte

func (*Entry) ProtoMessage added in v0.9.0 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect added in v0.9.0 

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

func (*Entry) Reset added in v0.9.0 

func (x *Entry) Reset()

func (*Entry) String added in v0.9.0 

func (x *Entry) String() string

type EntryCount added in v0.9.0 

type EntryCount struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*EntryCount) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use EntryCount.ProtoReflect.Descriptor instead.

func (*EntryCount) GetCount added in v0.9.0 

func (x *EntryCount) GetCount() uint64

func (*EntryCount) ProtoMessage added in v0.9.0 

func (*EntryCount) ProtoMessage()

func (*EntryCount) ProtoReflect added in v0.9.0 

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

func (*EntryCount) Reset added in v0.9.0 

func (x *EntryCount) Reset()

func (*EntryCount) String added in v0.9.0 

func (x *EntryCount) String() string

type ErrorInfo added in v1.0.5 

type ErrorInfo struct {
	Code  string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Cause string `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorInfo) Descriptor deprecated added in v1.0.5 

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

Deprecated: Use ErrorInfo.ProtoReflect.Descriptor instead.

func (*ErrorInfo) GetCause added in v1.0.5 

func (x *ErrorInfo) GetCause() string

func (*ErrorInfo) GetCode added in v1.0.5 

func (x *ErrorInfo) GetCode() string

func (*ErrorInfo) ProtoMessage added in v1.0.5 

func (*ErrorInfo) ProtoMessage()

func (*ErrorInfo) ProtoReflect added in v1.0.5 

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

func (*ErrorInfo) Reset added in v1.0.5 

func (x *ErrorInfo) Reset()

func (*ErrorInfo) String added in v1.0.5 

func (x *ErrorInfo) String() string

type ExecAllRequest added in v0.9.0 

type ExecAllRequest struct {
	Operations []*Op `protobuf:"bytes,1,rep,name=Operations,proto3" json:"Operations,omitempty"`
	NoWait     bool  `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecAllRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ExecAllRequest.ProtoReflect.Descriptor instead.

func (*ExecAllRequest) GetNoWait added in v0.9.2 

func (x *ExecAllRequest) GetNoWait() bool

func (*ExecAllRequest) GetOperations added in v0.9.0 

func (x *ExecAllRequest) GetOperations() []*Op

func (*ExecAllRequest) ProtoMessage added in v0.9.0 

func (*ExecAllRequest) ProtoMessage()

func (*ExecAllRequest) ProtoReflect added in v0.9.0 

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

func (*ExecAllRequest) Reset added in v0.9.0 

func (x *ExecAllRequest) Reset()

func (*ExecAllRequest) String added in v0.9.0 

func (x *ExecAllRequest) String() string

func (*ExecAllRequest) Validate added in v0.9.0 

func (m *ExecAllRequest) Validate() error

type HealthResponse 

type HealthResponse struct {
	Status  bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthResponse) Descriptor deprecated 

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

Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.

func (*HealthResponse) GetStatus 

func (x *HealthResponse) GetStatus() bool

func (*HealthResponse) GetVersion added in v0.7.0 

func (x *HealthResponse) GetVersion() string

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) ProtoReflect added in v0.9.0 

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

func (*HealthResponse) Reset 

func (x *HealthResponse) Reset()

func (*HealthResponse) String 

func (x *HealthResponse) String() string

type HistoryRequest added in v0.9.0 

type HistoryRequest struct {
	Key     []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Offset  uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit   int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Desc    bool   `protobuf:"varint,4,opt,name=desc,proto3" json:"desc,omitempty"`
	SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetDesc added in v0.9.0 

func (x *HistoryRequest) GetDesc() bool

func (*HistoryRequest) GetKey added in v0.9.0 

func (x *HistoryRequest) GetKey() []byte

func (*HistoryRequest) GetLimit added in v0.9.0 

func (x *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetOffset added in v0.9.0 

func (x *HistoryRequest) GetOffset() uint64

func (*HistoryRequest) GetSinceTx added in v0.9.0 

func (x *HistoryRequest) GetSinceTx() uint64

func (*HistoryRequest) ProtoMessage added in v0.9.0 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect added in v0.9.0 

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

func (*HistoryRequest) Reset added in v0.9.0 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String added in v0.9.0 

func (x *HistoryRequest) String() string

type ImmuServiceClient 

type ImmuServiceClient interface {
	ListUsers(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*UserList, error)
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ChangePassword(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateAuthConfig(ctx context.Context, in *AuthConfig, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateMTLSConfig(ctx context.Context, in *MTLSConfig, opts ...grpc.CallOption) (*empty.Empty, error)
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	Logout(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*TxMetadata, error)
	VerifiableSet(ctx context.Context, in *VerifiableSetRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	Get(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*Entry, error)
	VerifiableGet(ctx context.Context, in *VerifiableGetRequest, opts ...grpc.CallOption) (*VerifiableEntry, error)
	GetAll(ctx context.Context, in *KeyListRequest, opts ...grpc.CallOption) (*Entries, error)
	ExecAll(ctx context.Context, in *ExecAllRequest, opts ...grpc.CallOption) (*TxMetadata, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*Entries, error)
	// NOT YET SUPPORTED
	Count(ctx context.Context, in *KeyPrefix, opts ...grpc.CallOption) (*EntryCount, error)
	// NOT YET SUPPORTED
	CountAll(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EntryCount, error)
	TxById(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (*Tx, error)
	VerifiableTxById(ctx context.Context, in *VerifiableTxRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	TxScan(ctx context.Context, in *TxScanRequest, opts ...grpc.CallOption) (*TxList, error)
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*Entries, error)
	Health(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
	CurrentState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ImmutableState, error)
	SetReference(ctx context.Context, in *ReferenceRequest, opts ...grpc.CallOption) (*TxMetadata, error)
	VerifiableSetReference(ctx context.Context, in *VerifiableReferenceRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	ZAdd(ctx context.Context, in *ZAddRequest, opts ...grpc.CallOption) (*TxMetadata, error)
	VerifiableZAdd(ctx context.Context, in *VerifiableZAddRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	ZScan(ctx context.Context, in *ZScanRequest, opts ...grpc.CallOption) (*ZEntries, error)
	// DEPRECATED: kept for backward compatibility
	CreateDatabase(ctx context.Context, in *Database, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateDatabaseWith(ctx context.Context, in *DatabaseSettings, opts ...grpc.CallOption) (*empty.Empty, error)
	DatabaseList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DatabaseListResponse, error)
	UseDatabase(ctx context.Context, in *Database, opts ...grpc.CallOption) (*UseDatabaseReply, error)
	UpdateDatabase(ctx context.Context, in *DatabaseSettings, opts ...grpc.CallOption) (*empty.Empty, error)
	CompactIndex(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	ChangePermission(ctx context.Context, in *ChangePermissionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetActiveUser(ctx context.Context, in *SetActiveUserRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Streams
	StreamGet(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (ImmuService_StreamGetClient, error)
	StreamSet(ctx context.Context, opts ...grpc.CallOption) (ImmuService_StreamSetClient, error)
	StreamVerifiableGet(ctx context.Context, in *VerifiableGetRequest, opts ...grpc.CallOption) (ImmuService_StreamVerifiableGetClient, error)
	StreamVerifiableSet(ctx context.Context, opts ...grpc.CallOption) (ImmuService_StreamVerifiableSetClient, error)
	StreamScan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (ImmuService_StreamScanClient, error)
	StreamZScan(ctx context.Context, in *ZScanRequest, opts ...grpc.CallOption) (ImmuService_StreamZScanClient, error)
	StreamHistory(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (ImmuService_StreamHistoryClient, error)
	StreamExecAll(ctx context.Context, opts ...grpc.CallOption) (ImmuService_StreamExecAllClient, error)
	// Replication
	ExportTx(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (ImmuService_ExportTxClient, error)
	ReplicateTx(ctx context.Context, opts ...grpc.CallOption) (ImmuService_ReplicateTxClient, error)
	// SQL
	UseSnapshot(ctx context.Context, in *UseSnapshotRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SQLExec(ctx context.Context, in *SQLExecRequest, opts ...grpc.CallOption) (*SQLExecResult, error)
	SQLQuery(ctx context.Context, in *SQLQueryRequest, opts ...grpc.CallOption) (*SQLQueryResult, error)
	ListTables(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*SQLQueryResult, error)
	DescribeTable(ctx context.Context, in *Table, opts ...grpc.CallOption) (*SQLQueryResult, error)
	VerifiableSQLGet(ctx context.Context, in *VerifiableSQLGetRequest, opts ...grpc.CallOption) (*VerifiableSQLEntry, error)
}

ImmuServiceClient is the client API for ImmuService service.

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

func NewImmuServiceClient 

func NewImmuServiceClient(cc grpc.ClientConnInterface) ImmuServiceClient

type ImmuServiceServer 

type ImmuServiceServer interface {
	ListUsers(context.Context, *empty.Empty) (*UserList, error)
	CreateUser(context.Context, *CreateUserRequest) (*empty.Empty, error)
	ChangePassword(context.Context, *ChangePasswordRequest) (*empty.Empty, error)
	UpdateAuthConfig(context.Context, *AuthConfig) (*empty.Empty, error)
	UpdateMTLSConfig(context.Context, *MTLSConfig) (*empty.Empty, error)
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	Logout(context.Context, *empty.Empty) (*empty.Empty, error)
	Set(context.Context, *SetRequest) (*TxMetadata, error)
	VerifiableSet(context.Context, *VerifiableSetRequest) (*VerifiableTx, error)
	Get(context.Context, *KeyRequest) (*Entry, error)
	VerifiableGet(context.Context, *VerifiableGetRequest) (*VerifiableEntry, error)
	GetAll(context.Context, *KeyListRequest) (*Entries, error)
	ExecAll(context.Context, *ExecAllRequest) (*TxMetadata, error)
	Scan(context.Context, *ScanRequest) (*Entries, error)
	// NOT YET SUPPORTED
	Count(context.Context, *KeyPrefix) (*EntryCount, error)
	// NOT YET SUPPORTED
	CountAll(context.Context, *empty.Empty) (*EntryCount, error)
	TxById(context.Context, *TxRequest) (*Tx, error)
	VerifiableTxById(context.Context, *VerifiableTxRequest) (*VerifiableTx, error)
	TxScan(context.Context, *TxScanRequest) (*TxList, error)
	History(context.Context, *HistoryRequest) (*Entries, error)
	Health(context.Context, *empty.Empty) (*HealthResponse, error)
	CurrentState(context.Context, *empty.Empty) (*ImmutableState, error)
	SetReference(context.Context, *ReferenceRequest) (*TxMetadata, error)
	VerifiableSetReference(context.Context, *VerifiableReferenceRequest) (*VerifiableTx, error)
	ZAdd(context.Context, *ZAddRequest) (*TxMetadata, error)
	VerifiableZAdd(context.Context, *VerifiableZAddRequest) (*VerifiableTx, error)
	ZScan(context.Context, *ZScanRequest) (*ZEntries, error)
	// DEPRECATED: kept for backward compatibility
	CreateDatabase(context.Context, *Database) (*empty.Empty, error)
	CreateDatabaseWith(context.Context, *DatabaseSettings) (*empty.Empty, error)
	DatabaseList(context.Context, *empty.Empty) (*DatabaseListResponse, error)
	UseDatabase(context.Context, *Database) (*UseDatabaseReply, error)
	UpdateDatabase(context.Context, *DatabaseSettings) (*empty.Empty, error)
	CompactIndex(context.Context, *empty.Empty) (*empty.Empty, error)
	ChangePermission(context.Context, *ChangePermissionRequest) (*empty.Empty, error)
	SetActiveUser(context.Context, *SetActiveUserRequest) (*empty.Empty, error)
	// Streams
	StreamGet(*KeyRequest, ImmuService_StreamGetServer) error
	StreamSet(ImmuService_StreamSetServer) error
	StreamVerifiableGet(*VerifiableGetRequest, ImmuService_StreamVerifiableGetServer) error
	StreamVerifiableSet(ImmuService_StreamVerifiableSetServer) error
	StreamScan(*ScanRequest, ImmuService_StreamScanServer) error
	StreamZScan(*ZScanRequest, ImmuService_StreamZScanServer) error
	StreamHistory(*HistoryRequest, ImmuService_StreamHistoryServer) error
	StreamExecAll(ImmuService_StreamExecAllServer) error
	// Replication
	ExportTx(*TxRequest, ImmuService_ExportTxServer) error
	ReplicateTx(ImmuService_ReplicateTxServer) error
	// SQL
	UseSnapshot(context.Context, *UseSnapshotRequest) (*empty.Empty, error)
	SQLExec(context.Context, *SQLExecRequest) (*SQLExecResult, error)
	SQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
	ListTables(context.Context, *empty.Empty) (*SQLQueryResult, error)
	DescribeTable(context.Context, *Table) (*SQLQueryResult, error)
	VerifiableSQLGet(context.Context, *VerifiableSQLGetRequest) (*VerifiableSQLEntry, error)
}

ImmuServiceServer is the server API for ImmuService service.

type ImmuService_ExportTxClient added in v1.0.5 

type ImmuService_ExportTxClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_ExportTxServer added in v1.0.5 

type ImmuService_ExportTxServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmuService_ReplicateTxClient added in v1.0.5 

type ImmuService_ReplicateTxClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*TxMetadata, error)
	grpc.ClientStream
}

type ImmuService_ReplicateTxServer added in v1.0.5 

type ImmuService_ReplicateTxServer interface {
	SendAndClose(*TxMetadata) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type ImmuService_StreamExecAllClient added in v0.9.2 

type ImmuService_StreamExecAllClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*TxMetadata, error)
	grpc.ClientStream
}

type ImmuService_StreamExecAllServer added in v0.9.2 

type ImmuService_StreamExecAllServer interface {
	SendAndClose(*TxMetadata) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type ImmuService_StreamGetClient added in v0.9.2 

type ImmuService_StreamGetClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamGetServer added in v0.9.2 

type ImmuService_StreamGetServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmuService_StreamHistoryClient added in v0.9.2 

type ImmuService_StreamHistoryClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamHistoryServer added in v0.9.2 

type ImmuService_StreamHistoryServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmuService_StreamScanClient added in v0.9.2 

type ImmuService_StreamScanClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamScanServer added in v0.9.2 

type ImmuService_StreamScanServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmuService_StreamSetClient added in v0.9.2 

type ImmuService_StreamSetClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*TxMetadata, error)
	grpc.ClientStream
}

type ImmuService_StreamSetServer added in v0.9.2 

type ImmuService_StreamSetServer interface {
	SendAndClose(*TxMetadata) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type ImmuService_StreamVerifiableGetClient added in v0.9.2 

type ImmuService_StreamVerifiableGetClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamVerifiableGetServer added in v0.9.2 

type ImmuService_StreamVerifiableGetServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmuService_StreamVerifiableSetClient added in v0.9.2 

type ImmuService_StreamVerifiableSetClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*VerifiableTx, error)
	grpc.ClientStream
}

type ImmuService_StreamVerifiableSetServer added in v0.9.2 

type ImmuService_StreamVerifiableSetServer interface {
	SendAndClose(*VerifiableTx) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type ImmuService_StreamZScanClient added in v0.9.2 

type ImmuService_StreamZScanClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamZScanServer added in v0.9.2 

type ImmuService_StreamZScanServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type ImmutableState added in v0.9.0 

type ImmutableState struct {
	Db        string     `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	TxId      uint64     `protobuf:"varint,2,opt,name=txId,proto3" json:"txId,omitempty"`
	TxHash    []byte     `protobuf:"bytes,3,opt,name=txHash,proto3" json:"txHash,omitempty"`
	Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ImmutableState) CheckSignature added in v0.9.0 

func (state *ImmutableState) CheckSignature(key *ecdsa.PublicKey) (ok bool, err error)

CheckSignature

func (*ImmutableState) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ImmutableState.ProtoReflect.Descriptor instead.

func (*ImmutableState) GetDb added in v0.9.1 

func (x *ImmutableState) GetDb() string

func (*ImmutableState) GetSignature added in v0.9.0 

func (x *ImmutableState) GetSignature() *Signature

func (*ImmutableState) GetTxHash added in v0.9.0 

func (x *ImmutableState) GetTxHash() []byte

func (*ImmutableState) GetTxId added in v0.9.0 

func (x *ImmutableState) GetTxId() uint64

func (*ImmutableState) ProtoMessage added in v0.9.0 

func (*ImmutableState) ProtoMessage()

func (*ImmutableState) ProtoReflect added in v0.9.0 

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

func (*ImmutableState) Reset added in v0.9.0 

func (x *ImmutableState) Reset()

func (*ImmutableState) String added in v0.9.0 

func (x *ImmutableState) String() string

func (*ImmutableState) ToBytes added in v0.9.0 

func (state *ImmutableState) ToBytes() []byte

type InclusionProof 

type InclusionProof struct {
	Leaf  int32    `protobuf:"varint,1,opt,name=leaf,proto3" json:"leaf,omitempty"`
	Width int32    `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	Terms [][]byte `protobuf:"bytes,3,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

func InclusionProofTo added in v0.9.0 

func InclusionProofTo(iproof *htree.InclusionProof) *InclusionProof

func (*InclusionProof) Descriptor deprecated 

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

Deprecated: Use InclusionProof.ProtoReflect.Descriptor instead.

func (*InclusionProof) GetLeaf 

func (x *InclusionProof) GetLeaf() int32

func (*InclusionProof) GetTerms added in v0.9.0 

func (x *InclusionProof) GetTerms() [][]byte

func (*InclusionProof) GetWidth added in v0.9.0 

func (x *InclusionProof) GetWidth() int32

func (*InclusionProof) ProtoMessage 

func (*InclusionProof) ProtoMessage()

func (*InclusionProof) ProtoReflect added in v0.9.0 

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

func (*InclusionProof) Reset 

func (x *InclusionProof) Reset()

func (*InclusionProof) String 

func (x *InclusionProof) String() string

type Key 

type Key struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetKey 

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

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect added in v0.9.0 

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

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) String 

func (x *Key) String() string

type KeyListRequest added in v0.9.0 

type KeyListRequest struct {
	Keys    [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	SinceTx uint64   `protobuf:"varint,2,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyListRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use KeyListRequest.ProtoReflect.Descriptor instead.

func (*KeyListRequest) GetKeys added in v0.9.0 

func (x *KeyListRequest) GetKeys() [][]byte

func (*KeyListRequest) GetSinceTx added in v0.9.0 

func (x *KeyListRequest) GetSinceTx() uint64

func (*KeyListRequest) ProtoMessage added in v0.9.0 

func (*KeyListRequest) ProtoMessage()

func (*KeyListRequest) ProtoReflect added in v0.9.0 

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

func (*KeyListRequest) Reset added in v0.9.0 

func (x *KeyListRequest) Reset()

func (*KeyListRequest) String added in v0.9.0 

func (x *KeyListRequest) String() string

type KeyPrefix 

type KeyPrefix struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyPrefix) Descriptor deprecated 

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

Deprecated: Use KeyPrefix.ProtoReflect.Descriptor instead.

func (*KeyPrefix) GetPrefix 

func (x *KeyPrefix) GetPrefix() []byte

func (*KeyPrefix) ProtoMessage 

func (*KeyPrefix) ProtoMessage()

func (*KeyPrefix) ProtoReflect added in v0.9.0 

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

func (*KeyPrefix) Reset 

func (x *KeyPrefix) Reset()

func (*KeyPrefix) String 

func (x *KeyPrefix) String() string

type KeyRequest added in v0.9.0 

type KeyRequest struct {
	Key     []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	AtTx    uint64 `protobuf:"varint,2,opt,name=atTx,proto3" json:"atTx,omitempty"`
	SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetAtTx added in v0.9.1 

func (x *KeyRequest) GetAtTx() uint64

func (*KeyRequest) GetKey added in v0.9.0 

func (x *KeyRequest) GetKey() []byte

func (*KeyRequest) GetSinceTx added in v0.9.0 

func (x *KeyRequest) GetSinceTx() uint64

func (*KeyRequest) ProtoMessage added in v0.9.0 

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect added in v0.9.0 

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

func (*KeyRequest) Reset added in v0.9.0 

func (x *KeyRequest) Reset()

func (*KeyRequest) String added in v0.9.0 

func (x *KeyRequest) String() string

type KeyValue 

type KeyValue 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"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

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

func (*KeyValue) GetValue 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect added in v0.9.0 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type LinearProof added in v0.9.0 

type LinearProof struct {
	SourceTxId uint64   `protobuf:"varint,1,opt,name=sourceTxId,proto3" json:"sourceTxId,omitempty"`
	TargetTxId uint64   `protobuf:"varint,2,opt,name=TargetTxId,proto3" json:"TargetTxId,omitempty"`
	Terms      [][]byte `protobuf:"bytes,3,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

func LinearProofTo added in v0.9.0 

func LinearProofTo(linearProof *store.LinearProof) *LinearProof

func (*LinearProof) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use LinearProof.ProtoReflect.Descriptor instead.

func (*LinearProof) GetSourceTxId added in v0.9.0 

func (x *LinearProof) GetSourceTxId() uint64

func (*LinearProof) GetTargetTxId added in v0.9.0 

func (x *LinearProof) GetTargetTxId() uint64

func (*LinearProof) GetTerms added in v0.9.0 

func (x *LinearProof) GetTerms() [][]byte

func (*LinearProof) ProtoMessage added in v0.9.0 

func (*LinearProof) ProtoMessage()

func (*LinearProof) ProtoReflect added in v0.9.0 

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

func (*LinearProof) Reset added in v0.9.0 

func (x *LinearProof) Reset()

func (*LinearProof) String added in v0.9.0 

func (x *LinearProof) String() string

type LoginRequest 

type LoginRequest struct {
	User     []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated 

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetPassword 

func (x *LoginRequest) GetPassword() []byte

func (*LoginRequest) GetUser 

func (x *LoginRequest) GetUser() []byte

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect added in v0.9.0 

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

func (*LoginRequest) Reset 

func (x *LoginRequest) Reset()

func (*LoginRequest) String 

func (x *LoginRequest) String() string

type LoginResponse 

type LoginResponse struct {
	Token   string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Warning []byte `protobuf:"bytes,2,opt,name=warning,proto3" json:"warning,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated 

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

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetToken 

func (x *LoginResponse) GetToken() string

func (*LoginResponse) GetWarning added in v0.6.2 

func (x *LoginResponse) GetWarning() []byte

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect added in v0.9.0 

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

func (*LoginResponse) Reset 

func (x *LoginResponse) Reset()

func (*LoginResponse) String 

func (x *LoginResponse) String() string

type MTLSConfig 

type MTLSConfig struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*MTLSConfig) Descriptor deprecated 

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

Deprecated: Use MTLSConfig.ProtoReflect.Descriptor instead.

func (*MTLSConfig) GetEnabled 

func (x *MTLSConfig) GetEnabled() bool

func (*MTLSConfig) ProtoMessage 

func (*MTLSConfig) ProtoMessage()

func (*MTLSConfig) ProtoReflect added in v0.9.0 

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

func (*MTLSConfig) Reset 

func (x *MTLSConfig) Reset()

func (*MTLSConfig) String 

func (x *MTLSConfig) String() string

type NamedParam added in v1.0.0 

type NamedParam struct {
	Name  string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *SQLValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func EncodeParams added in v1.0.5 

func EncodeParams(params map[string]interface{}) ([]*NamedParam, error)

func (*NamedParam) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use NamedParam.ProtoReflect.Descriptor instead.

func (*NamedParam) GetName added in v1.0.0 

func (x *NamedParam) GetName() string

func (*NamedParam) GetValue added in v1.0.0 

func (x *NamedParam) GetValue() *SQLValue

func (*NamedParam) ProtoMessage added in v1.0.0 

func (*NamedParam) ProtoMessage()

func (*NamedParam) ProtoReflect added in v1.0.0 

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

func (*NamedParam) Reset added in v1.0.0 

func (x *NamedParam) Reset()

func (*NamedParam) String added in v1.0.0 

func (x *NamedParam) String() string

type Op added in v0.8.1 

type Op struct {

	// Types that are assignable to Operation:
	//	*Op_Kv
	//	*Op_ZAdd
	//	*Op_Ref
	Operation isOp_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

func (*Op) Descriptor deprecated added in v0.8.1 

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

Deprecated: Use Op.ProtoReflect.Descriptor instead.

func (*Op) GetKv added in v0.9.0 

func (x *Op) GetKv() *KeyValue

func (*Op) GetOperation added in v0.8.1 

func (m *Op) GetOperation() isOp_Operation

func (*Op) GetRef added in v0.9.0 

func (x *Op) GetRef() *ReferenceRequest

func (*Op) GetZAdd added in v0.9.0 

func (x *Op) GetZAdd() *ZAddRequest

func (*Op) ProtoMessage added in v0.8.1 

func (*Op) ProtoMessage()

func (*Op) ProtoReflect added in v0.9.0 

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

func (*Op) Reset added in v0.8.1 

func (x *Op) Reset()

func (*Op) String added in v0.8.1 

func (x *Op) String() string

type Op_Kv added in v0.9.0 

type Op_Kv struct {
	Kv *KeyValue `protobuf:"bytes,1,opt,name=kv,proto3,oneof"`
}

type Op_Ref added in v0.9.0 

type Op_Ref struct {
	Ref *ReferenceRequest `protobuf:"bytes,3,opt,name=ref,proto3,oneof"`
}

type Op_Unexpected added in v0.8.1 

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

type Op_ZAdd added in v0.9.0 

type Op_ZAdd struct {
	ZAdd *ZAddRequest `protobuf:"bytes,2,opt,name=zAdd,proto3,oneof"`
}

type Permission added in v0.7.0 

type Permission struct {
	Database   string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Permission uint32 `protobuf:"varint,2,opt,name=permission,proto3" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

func (*Permission) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use Permission.ProtoReflect.Descriptor instead.

func (*Permission) GetDatabase added in v0.7.0 

func (x *Permission) GetDatabase() string

func (*Permission) GetPermission added in v0.7.0 

func (x *Permission) GetPermission() uint32

func (*Permission) ProtoMessage added in v0.7.0 

func (*Permission) ProtoMessage()

func (*Permission) ProtoReflect added in v0.9.0 

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

func (*Permission) Reset added in v0.7.0 

func (x *Permission) Reset()

func (*Permission) String added in v0.7.0 

func (x *Permission) String() string

type PermissionAction added in v0.7.0 

type PermissionAction int32
const (
	PermissionAction_GRANT  PermissionAction = 0
	PermissionAction_REVOKE PermissionAction = 1
)

func (PermissionAction) Descriptor added in v0.9.0 

func (PermissionAction) Descriptor() protoreflect.EnumDescriptor

func (PermissionAction) Enum added in v0.9.0 

func (x PermissionAction) Enum() *PermissionAction

func (PermissionAction) EnumDescriptor deprecated added in v0.7.0 

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

Deprecated: Use PermissionAction.Descriptor instead.

func (PermissionAction) Number added in v0.9.0 

func (x PermissionAction) Number() protoreflect.EnumNumber

func (PermissionAction) String added in v0.7.0 

func (x PermissionAction) String() string

func (PermissionAction) Type added in v0.9.0 

func (PermissionAction) Type() protoreflect.EnumType

type Reference added in v0.9.0 

type Reference struct {
	Tx   uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Key  []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// contains filtered or unexported fields
}

func (*Reference) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Reference.ProtoReflect.Descriptor instead.

func (*Reference) GetAtTx added in v0.9.0 

func (x *Reference) GetAtTx() uint64

func (*Reference) GetKey added in v0.9.0 

func (x *Reference) GetKey() []byte

func (*Reference) GetTx added in v0.9.0 

func (x *Reference) GetTx() uint64

func (*Reference) ProtoMessage added in v0.9.0 

func (*Reference) ProtoMessage()

func (*Reference) ProtoReflect added in v0.9.0 

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

func (*Reference) Reset added in v0.9.0 

func (x *Reference) Reset()

func (*Reference) String added in v0.9.0 

func (x *Reference) String() string

type ReferenceRequest added in v0.9.0 

type ReferenceRequest struct {
	Key           []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ReferencedKey []byte `protobuf:"bytes,2,opt,name=referencedKey,proto3" json:"referencedKey,omitempty"`
	AtTx          uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	BoundRef      bool   `protobuf:"varint,4,opt,name=boundRef,proto3" json:"boundRef,omitempty"`
	NoWait        bool   `protobuf:"varint,5,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ReferenceRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ReferenceRequest.ProtoReflect.Descriptor instead.

func (*ReferenceRequest) GetAtTx added in v0.9.0 

func (x *ReferenceRequest) GetAtTx() uint64

func (*ReferenceRequest) GetBoundRef added in v0.9.1 

func (x *ReferenceRequest) GetBoundRef() bool

func (*ReferenceRequest) GetKey added in v0.9.0 

func (x *ReferenceRequest) GetKey() []byte

func (*ReferenceRequest) GetNoWait added in v0.9.2 

func (x *ReferenceRequest) GetNoWait() bool

func (*ReferenceRequest) GetReferencedKey added in v0.9.0 

func (x *ReferenceRequest) GetReferencedKey() []byte

func (*ReferenceRequest) ProtoMessage added in v0.9.0 

func (*ReferenceRequest) ProtoMessage()

func (*ReferenceRequest) ProtoReflect added in v0.9.0 

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

func (*ReferenceRequest) Reset added in v0.9.0 

func (x *ReferenceRequest) Reset()

func (*ReferenceRequest) String added in v0.9.0 

func (x *ReferenceRequest) String() string

type RetryInfo added in v1.0.5 

type RetryInfo struct {
	RetryDelay int32 `protobuf:"varint,1,opt,name=retry_delay,json=retryDelay,proto3" json:"retry_delay,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryInfo) Descriptor deprecated added in v1.0.5 

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

Deprecated: Use RetryInfo.ProtoReflect.Descriptor instead.

func (*RetryInfo) GetRetryDelay added in v1.0.5 

func (x *RetryInfo) GetRetryDelay() int32

func (*RetryInfo) ProtoMessage added in v1.0.5 

func (*RetryInfo) ProtoMessage()

func (*RetryInfo) ProtoReflect added in v1.0.5 

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

func (*RetryInfo) Reset added in v1.0.5 

func (x *RetryInfo) Reset()

func (*RetryInfo) String added in v1.0.5 

func (x *RetryInfo) String() string

type Row added in v1.0.0 

type Row struct {
	Columns []string    `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Values  []*SQLValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetColumns added in v1.0.0 

func (x *Row) GetColumns() []string

func (*Row) GetValues added in v1.0.0 

func (x *Row) GetValues() []*SQLValue

func (*Row) ProtoMessage added in v1.0.0 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect added in v1.0.0 

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

func (*Row) Reset added in v1.0.0 

func (x *Row) Reset()

func (*Row) String added in v1.0.0 

func (x *Row) String() string

type SQLEntry added in v1.0.0 

type SQLEntry struct {
	Tx    uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLEntry) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLEntry.ProtoReflect.Descriptor instead.

func (*SQLEntry) GetKey added in v1.0.0 

func (x *SQLEntry) GetKey() []byte

func (*SQLEntry) GetTx added in v1.0.0 

func (x *SQLEntry) GetTx() uint64

func (*SQLEntry) GetValue added in v1.0.0 

func (x *SQLEntry) GetValue() []byte

func (*SQLEntry) ProtoMessage added in v1.0.0 

func (*SQLEntry) ProtoMessage()

func (*SQLEntry) ProtoReflect added in v1.0.0 

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

func (*SQLEntry) Reset added in v1.0.0 

func (x *SQLEntry) Reset()

func (*SQLEntry) String added in v1.0.0 

func (x *SQLEntry) String() string

type SQLExecRequest added in v1.0.0 

type SQLExecRequest struct {
	Sql    string        `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Params []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	NoWait bool          `protobuf:"varint,3,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLExecRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLExecRequest.ProtoReflect.Descriptor instead.

func (*SQLExecRequest) GetNoWait added in v1.0.0 

func (x *SQLExecRequest) GetNoWait() bool

func (*SQLExecRequest) GetParams added in v1.0.0 

func (x *SQLExecRequest) GetParams() []*NamedParam

func (*SQLExecRequest) GetSql added in v1.0.0 

func (x *SQLExecRequest) GetSql() string

func (*SQLExecRequest) ProtoMessage added in v1.0.0 

func (*SQLExecRequest) ProtoMessage()

func (*SQLExecRequest) ProtoReflect added in v1.0.0 

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

func (*SQLExecRequest) Reset added in v1.0.0 

func (x *SQLExecRequest) Reset()

func (*SQLExecRequest) String added in v1.0.0 

func (x *SQLExecRequest) String() string

type SQLExecResult added in v1.0.0 

type SQLExecResult struct {
	Ctxs            []*TxMetadata        `protobuf:"bytes,1,rep,name=ctxs,proto3" json:"ctxs,omitempty"`
	Dtxs            []*TxMetadata        `protobuf:"bytes,2,rep,name=dtxs,proto3" json:"dtxs,omitempty"`
	UpdatedRows     uint32               `protobuf:"varint,3,opt,name=updatedRows,proto3" json:"updatedRows,omitempty"`
	LastInsertedPKs map[string]*SQLValue `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SQLExecResult) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLExecResult.ProtoReflect.Descriptor instead.

func (*SQLExecResult) GetCtxs added in v1.0.0 

func (x *SQLExecResult) GetCtxs() []*TxMetadata

func (*SQLExecResult) GetDtxs added in v1.0.0 

func (x *SQLExecResult) GetDtxs() []*TxMetadata

func (*SQLExecResult) GetLastInsertedPKs added in v1.1.0 

func (x *SQLExecResult) GetLastInsertedPKs() map[string]*SQLValue

func (*SQLExecResult) GetUpdatedRows added in v1.1.0 

func (x *SQLExecResult) GetUpdatedRows() uint32

func (*SQLExecResult) ProtoMessage added in v1.0.0 

func (*SQLExecResult) ProtoMessage()

func (*SQLExecResult) ProtoReflect added in v1.0.0 

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

func (*SQLExecResult) Reset added in v1.0.0 

func (x *SQLExecResult) Reset()

func (*SQLExecResult) String added in v1.0.0 

func (x *SQLExecResult) String() string

type SQLGetRequest added in v1.0.0 

type SQLGetRequest struct {
	Table    string      `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	PkValues []*SQLValue `protobuf:"bytes,2,rep,name=pkValues,proto3" json:"pkValues,omitempty"`
	AtTx     uint64      `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	SinceTx  uint64      `protobuf:"varint,4,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLGetRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLGetRequest.ProtoReflect.Descriptor instead.

func (*SQLGetRequest) GetAtTx added in v1.0.0 

func (x *SQLGetRequest) GetAtTx() uint64

func (*SQLGetRequest) GetPkValues added in v1.1.0 

func (x *SQLGetRequest) GetPkValues() []*SQLValue

func (*SQLGetRequest) GetSinceTx added in v1.0.0 

func (x *SQLGetRequest) GetSinceTx() uint64

func (*SQLGetRequest) GetTable added in v1.0.0 

func (x *SQLGetRequest) GetTable() string

func (*SQLGetRequest) ProtoMessage added in v1.0.0 

func (*SQLGetRequest) ProtoMessage()

func (*SQLGetRequest) ProtoReflect added in v1.0.0 

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

func (*SQLGetRequest) Reset added in v1.0.0 

func (x *SQLGetRequest) Reset()

func (*SQLGetRequest) String added in v1.0.0 

func (x *SQLGetRequest) String() string

type SQLQueryRequest added in v1.0.0 

type SQLQueryRequest struct {
	Sql           string        `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Params        []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	ReuseSnapshot bool          `protobuf:"varint,3,opt,name=reuseSnapshot,proto3" json:"reuseSnapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLQueryRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLQueryRequest.ProtoReflect.Descriptor instead.

func (*SQLQueryRequest) GetParams added in v1.0.0 

func (x *SQLQueryRequest) GetParams() []*NamedParam

func (*SQLQueryRequest) GetReuseSnapshot added in v1.0.0 

func (x *SQLQueryRequest) GetReuseSnapshot() bool

func (*SQLQueryRequest) GetSql added in v1.0.0 

func (x *SQLQueryRequest) GetSql() string

func (*SQLQueryRequest) ProtoMessage added in v1.0.0 

func (*SQLQueryRequest) ProtoMessage()

func (*SQLQueryRequest) ProtoReflect added in v1.0.0 

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

func (*SQLQueryRequest) Reset added in v1.0.0 

func (x *SQLQueryRequest) Reset()

func (*SQLQueryRequest) String added in v1.0.0 

func (x *SQLQueryRequest) String() string

type SQLQueryResult added in v1.0.0 

type SQLQueryResult struct {
	Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	Rows    []*Row    `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLQueryResult) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLQueryResult.ProtoReflect.Descriptor instead.

func (*SQLQueryResult) GetColumns added in v1.0.0 

func (x *SQLQueryResult) GetColumns() []*Column

func (*SQLQueryResult) GetRows added in v1.0.0 

func (x *SQLQueryResult) GetRows() []*Row

func (*SQLQueryResult) ProtoMessage added in v1.0.0 

func (*SQLQueryResult) ProtoMessage()

func (*SQLQueryResult) ProtoReflect added in v1.0.0 

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

func (*SQLQueryResult) Reset added in v1.0.0 

func (x *SQLQueryResult) Reset()

func (*SQLQueryResult) String added in v1.0.0 

func (x *SQLQueryResult) String() string

type SQLValue added in v1.0.0 

type SQLValue struct {

	// Types that are assignable to Value:
	//	*SQLValue_Null
	//	*SQLValue_N
	//	*SQLValue_S
	//	*SQLValue_B
	//	*SQLValue_Bs
	Value isSQLValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*SQLValue) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SQLValue.ProtoReflect.Descriptor instead.

func (*SQLValue) GetB added in v1.0.0 

func (x *SQLValue) GetB() bool

func (*SQLValue) GetBs added in v1.0.0 

func (x *SQLValue) GetBs() []byte

func (*SQLValue) GetN added in v1.0.0 

func (x *SQLValue) GetN() int64

func (*SQLValue) GetNull added in v1.0.0 

func (x *SQLValue) GetNull() _struct.NullValue

func (*SQLValue) GetS added in v1.0.0 

func (x *SQLValue) GetS() string

func (*SQLValue) GetValue added in v1.0.0 

func (m *SQLValue) GetValue() isSQLValue_Value

func (*SQLValue) ProtoMessage added in v1.0.0 

func (*SQLValue) ProtoMessage()

func (*SQLValue) ProtoReflect added in v1.0.0 

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

func (*SQLValue) Reset added in v1.0.0 

func (x *SQLValue) Reset()

func (*SQLValue) String added in v1.0.0 

func (x *SQLValue) String() string

type SQLValue_B added in v1.0.0 

type SQLValue_B struct {
	B bool `protobuf:"varint,4,opt,name=b,proto3,oneof"`
}

func (*SQLValue_B) Equal added in v1.0.0 

func (v *SQLValue_B) Equal(sqlv SqlValue) (bool, error)

type SQLValue_Bs added in v1.0.0 

type SQLValue_Bs struct {
	Bs []byte `protobuf:"bytes,5,opt,name=bs,proto3,oneof"`
}

func (*SQLValue_Bs) Equal added in v1.0.0 

func (v *SQLValue_Bs) Equal(sqlv SqlValue) (bool, error)

type SQLValue_N added in v1.0.0 

type SQLValue_N struct {
	N int64 `protobuf:"varint,2,opt,name=n,proto3,oneof"`
}

func (*SQLValue_N) Equal added in v1.0.0 

func (v *SQLValue_N) Equal(sqlv SqlValue) (bool, error)

type SQLValue_Null added in v1.0.0 

type SQLValue_Null struct {
	Null _struct.NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=google.protobuf.NullValue,oneof"`
}

func (*SQLValue_Null) Equal added in v1.0.0 

func (v *SQLValue_Null) Equal(sqlv SqlValue) (bool, error)

type SQLValue_S added in v1.0.0 

type SQLValue_S struct {
	S string `protobuf:"bytes,3,opt,name=s,proto3,oneof"`
}

func (*SQLValue_S) Equal added in v1.0.0 

func (v *SQLValue_S) Equal(sqlv SqlValue) (bool, error)

type ScanRequest added in v0.9.0 

type ScanRequest struct {
	SeekKey []byte `protobuf:"bytes,1,opt,name=seekKey,proto3" json:"seekKey,omitempty"`
	Prefix  []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Desc    bool   `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Limit   uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	NoWait  bool   `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.

func (*ScanRequest) GetDesc added in v0.9.0 

func (x *ScanRequest) GetDesc() bool

func (*ScanRequest) GetLimit added in v0.9.0 

func (x *ScanRequest) GetLimit() uint64

func (*ScanRequest) GetNoWait added in v0.9.0 

func (x *ScanRequest) GetNoWait() bool

func (*ScanRequest) GetPrefix added in v0.9.0 

func (x *ScanRequest) GetPrefix() []byte

func (*ScanRequest) GetSeekKey added in v0.9.0 

func (x *ScanRequest) GetSeekKey() []byte

func (*ScanRequest) GetSinceTx added in v0.9.0 

func (x *ScanRequest) GetSinceTx() uint64

func (*ScanRequest) ProtoMessage added in v0.9.0 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) ProtoReflect added in v0.9.0 

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

func (*ScanRequest) Reset added in v0.9.0 

func (x *ScanRequest) Reset()

func (*ScanRequest) String added in v0.9.0 

func (x *ScanRequest) String() string

type Score added in v0.8.1 

type Score struct {
	Score float64 `protobuf:"fixed64,1,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

func (*Score) Descriptor deprecated added in v0.8.1 

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

Deprecated: Use Score.ProtoReflect.Descriptor instead.

func (*Score) GetScore added in v0.8.1 

func (x *Score) GetScore() float64

func (*Score) ProtoMessage added in v0.8.1 

func (*Score) ProtoMessage()

func (*Score) ProtoReflect added in v0.9.0 

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

func (*Score) Reset added in v0.8.1 

func (x *Score) Reset()

func (*Score) String added in v0.8.1 

func (x *Score) String() string

type SetActiveUserRequest added in v0.7.0 

type SetActiveUserRequest struct {
	Active   bool   `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

func (*SetActiveUserRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use SetActiveUserRequest.ProtoReflect.Descriptor instead.

func (*SetActiveUserRequest) GetActive added in v0.7.0 

func (x *SetActiveUserRequest) GetActive() bool

func (*SetActiveUserRequest) GetUsername added in v0.7.0 

func (x *SetActiveUserRequest) GetUsername() string

func (*SetActiveUserRequest) ProtoMessage added in v0.7.0 

func (*SetActiveUserRequest) ProtoMessage()

func (*SetActiveUserRequest) ProtoReflect added in v0.9.0 

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

func (*SetActiveUserRequest) Reset added in v0.7.0 

func (x *SetActiveUserRequest) Reset()

func (*SetActiveUserRequest) String added in v0.7.0 

func (x *SetActiveUserRequest) String() string

type SetRequest added in v0.9.0 

type SetRequest struct {
	KVs    []*KeyValue `protobuf:"bytes,1,rep,name=KVs,proto3" json:"KVs,omitempty"`
	NoWait bool        `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetKVs added in v0.9.0 

func (x *SetRequest) GetKVs() []*KeyValue

func (*SetRequest) GetNoWait added in v0.9.2 

func (x *SetRequest) GetNoWait() bool

func (*SetRequest) ProtoMessage added in v0.9.0 

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect added in v0.9.0 

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

func (*SetRequest) Reset added in v0.9.0 

func (x *SetRequest) Reset()

func (*SetRequest) String added in v0.9.0 

func (x *SetRequest) String() string

type Signature added in v0.8.0 

type Signature struct {
	PublicKey []byte `protobuf:"bytes,1,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Signature) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetPublicKey added in v0.8.0 

func (x *Signature) GetPublicKey() []byte

func (*Signature) GetSignature added in v0.8.0 

func (x *Signature) GetSignature() []byte

func (*Signature) ProtoMessage added in v0.8.0 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect added in v0.9.0 

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

func (*Signature) Reset added in v0.8.0 

func (x *Signature) Reset()

func (*Signature) String added in v0.8.0 

func (x *Signature) String() string

type SqlValue added in v1.0.0 

type SqlValue interface {
	Equal(sqlv SqlValue) (bool, error)
	// contains filtered or unexported methods
}

type Table added in v1.0.0 

type Table struct {
	TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetTableName added in v1.0.0 

func (x *Table) GetTableName() string

func (*Table) ProtoMessage added in v1.0.0 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect added in v1.0.0 

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

func (*Table) Reset added in v1.0.0 

func (x *Table) Reset()

func (*Table) String added in v1.0.0 

func (x *Table) String() string

type Tx added in v0.9.0 

type Tx struct {
	Metadata *TxMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Entries  []*TxEntry  `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func TxTo added in v0.9.0 

func TxTo(tx *store.Tx) *Tx

func (*Tx) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Tx.ProtoReflect.Descriptor instead.

func (*Tx) GetEntries added in v0.9.0 

func (x *Tx) GetEntries() []*TxEntry

func (*Tx) GetMetadata added in v0.9.0 

func (x *Tx) GetMetadata() *TxMetadata

func (*Tx) ProtoMessage added in v0.9.0 

func (*Tx) ProtoMessage()

func (*Tx) ProtoReflect added in v0.9.0 

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

func (*Tx) Reset added in v0.9.0 

func (x *Tx) Reset()

func (*Tx) String added in v0.9.0 

func (x *Tx) String() string

type TxEntry added in v0.9.0 

type TxEntry struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	HValue []byte `protobuf:"bytes,2,opt,name=hValue,proto3" json:"hValue,omitempty"`
	VLen   int32  `protobuf:"varint,4,opt,name=vLen,proto3" json:"vLen,omitempty"`
	// contains filtered or unexported fields
}

func (*TxEntry) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TxEntry.ProtoReflect.Descriptor instead.

func (*TxEntry) GetHValue added in v0.9.0 

func (x *TxEntry) GetHValue() []byte

func (*TxEntry) GetKey added in v0.9.0 

func (x *TxEntry) GetKey() []byte

func (*TxEntry) GetVLen added in v0.9.0 

func (x *TxEntry) GetVLen() int32

func (*TxEntry) ProtoMessage added in v0.9.0 

func (*TxEntry) ProtoMessage()

func (*TxEntry) ProtoReflect added in v0.9.0 

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

func (*TxEntry) Reset added in v0.9.0 

func (x *TxEntry) Reset()

func (*TxEntry) String added in v0.9.0 

func (x *TxEntry) String() string

type TxList added in v0.9.1 

type TxList struct {
	Txs []*Tx `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	// contains filtered or unexported fields
}

func (*TxList) Descriptor deprecated added in v0.9.1 

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

Deprecated: Use TxList.ProtoReflect.Descriptor instead.

func (*TxList) GetTxs added in v0.9.1 

func (x *TxList) GetTxs() []*Tx

func (*TxList) ProtoMessage added in v0.9.1 

func (*TxList) ProtoMessage()

func (*TxList) ProtoReflect added in v0.9.1 

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

func (*TxList) Reset added in v0.9.1 

func (x *TxList) Reset()

func (*TxList) String added in v0.9.1 

func (x *TxList) String() string

type TxMetadata added in v0.9.0 

type TxMetadata struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PrevAlh  []byte `protobuf:"bytes,2,opt,name=prevAlh,proto3" json:"prevAlh,omitempty"`
	Ts       int64  `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Nentries int32  `protobuf:"varint,4,opt,name=nentries,proto3" json:"nentries,omitempty"`
	EH       []byte `protobuf:"bytes,5,opt,name=eH,proto3" json:"eH,omitempty"`
	BlTxId   uint64 `protobuf:"varint,6,opt,name=blTxId,proto3" json:"blTxId,omitempty"`
	BlRoot   []byte `protobuf:"bytes,7,opt,name=blRoot,proto3" json:"blRoot,omitempty"`
	// contains filtered or unexported fields
}

func TxMetatadaTo added in v0.9.0 

func TxMetatadaTo(txMetadata *store.TxMetadata) *TxMetadata

func (*TxMetadata) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TxMetadata.ProtoReflect.Descriptor instead.

func (*TxMetadata) GetBlRoot added in v0.9.0 

func (x *TxMetadata) GetBlRoot() []byte

func (*TxMetadata) GetBlTxId added in v0.9.0 

func (x *TxMetadata) GetBlTxId() uint64

func (*TxMetadata) GetEH added in v0.9.0 

func (x *TxMetadata) GetEH() []byte

func (*TxMetadata) GetId added in v0.9.0 

func (x *TxMetadata) GetId() uint64

func (*TxMetadata) GetNentries added in v0.9.0 

func (x *TxMetadata) GetNentries() int32

func (*TxMetadata) GetPrevAlh added in v0.9.0 

func (x *TxMetadata) GetPrevAlh() []byte

func (*TxMetadata) GetTs added in v0.9.0 

func (x *TxMetadata) GetTs() int64

func (*TxMetadata) ProtoMessage added in v0.9.0 

func (*TxMetadata) ProtoMessage()

func (*TxMetadata) ProtoReflect added in v0.9.0 

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

func (*TxMetadata) Reset added in v0.9.0 

func (x *TxMetadata) Reset()

func (*TxMetadata) String added in v0.9.0 

func (x *TxMetadata) String() string

type TxRequest added in v0.9.0 

type TxRequest struct {
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

func (*TxRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TxRequest.ProtoReflect.Descriptor instead.

func (*TxRequest) GetTx added in v0.9.0 

func (x *TxRequest) GetTx() uint64

func (*TxRequest) ProtoMessage added in v0.9.0 

func (*TxRequest) ProtoMessage()

func (*TxRequest) ProtoReflect added in v0.9.0 

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

func (*TxRequest) Reset added in v0.9.0 

func (x *TxRequest) Reset()

func (*TxRequest) String added in v0.9.0 

func (x *TxRequest) String() string

type TxScanRequest added in v0.9.1 

type TxScanRequest struct {
	InitialTx uint64 `protobuf:"varint,1,opt,name=initialTx,proto3" json:"initialTx,omitempty"`
	Limit     uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Desc      bool   `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

func (*TxScanRequest) Descriptor deprecated added in v0.9.1 

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

Deprecated: Use TxScanRequest.ProtoReflect.Descriptor instead.

func (*TxScanRequest) GetDesc added in v0.9.1 

func (x *TxScanRequest) GetDesc() bool

func (*TxScanRequest) GetInitialTx added in v0.9.1 

func (x *TxScanRequest) GetInitialTx() uint64

func (*TxScanRequest) GetLimit added in v0.9.1 

func (x *TxScanRequest) GetLimit() uint32

func (*TxScanRequest) ProtoMessage added in v0.9.1 

func (*TxScanRequest) ProtoMessage()

func (*TxScanRequest) ProtoReflect added in v0.9.1 

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

func (*TxScanRequest) Reset added in v0.9.1 

func (x *TxScanRequest) Reset()

func (*TxScanRequest) String added in v0.9.1 

func (x *TxScanRequest) String() string

type UnimplementedImmuServiceServer 

type UnimplementedImmuServiceServer struct {
}

UnimplementedImmuServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedImmuServiceServer) ChangePassword 

func (*UnimplementedImmuServiceServer) ChangePassword(context.Context, *ChangePasswordRequest) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) ChangePermission added in v0.7.0 

func (*UnimplementedImmuServiceServer) ChangePermission(context.Context, *ChangePermissionRequest) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) CompactIndex added in v1.0.5 

func (*UnimplementedImmuServiceServer) CompactIndex(context.Context, *empty.Empty) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) Count 

func (*UnimplementedImmuServiceServer) Count(context.Context, *KeyPrefix) (*EntryCount, error)

func (*UnimplementedImmuServiceServer) CountAll added in v0.8.1 

func (*UnimplementedImmuServiceServer) CountAll(context.Context, *empty.Empty) (*EntryCount, error)

func (*UnimplementedImmuServiceServer) CreateDatabase added in v0.7.0 

func (*UnimplementedImmuServiceServer) CreateDatabase(context.Context, *Database) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) CreateDatabaseWith added in v1.0.5 

func (*UnimplementedImmuServiceServer) CreateDatabaseWith(context.Context, *DatabaseSettings) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) CreateUser 

func (*UnimplementedImmuServiceServer) CreateUser(context.Context, *CreateUserRequest) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) CurrentState added in v0.9.0 

func (*UnimplementedImmuServiceServer) CurrentState(context.Context, *empty.Empty) (*ImmutableState, error)

func (*UnimplementedImmuServiceServer) DatabaseList added in v0.7.0 

func (*UnimplementedImmuServiceServer) DatabaseList(context.Context, *empty.Empty) (*DatabaseListResponse, error)

func (*UnimplementedImmuServiceServer) DescribeTable added in v1.0.0 

func (*UnimplementedImmuServiceServer) DescribeTable(context.Context, *Table) (*SQLQueryResult, error)

func (*UnimplementedImmuServiceServer) ExecAll added in v0.9.0 

func (*UnimplementedImmuServiceServer) ExecAll(context.Context, *ExecAllRequest) (*TxMetadata, error)

func (*UnimplementedImmuServiceServer) ExportTx added in v1.0.5 

func (*UnimplementedImmuServiceServer) ExportTx(*TxRequest, ImmuService_ExportTxServer) error

func (*UnimplementedImmuServiceServer) Get 

func (*UnimplementedImmuServiceServer) Get(context.Context, *KeyRequest) (*Entry, error)

func (*UnimplementedImmuServiceServer) GetAll added in v0.9.0 

func (*UnimplementedImmuServiceServer) GetAll(context.Context, *KeyListRequest) (*Entries, error)

func (*UnimplementedImmuServiceServer) Health 

func (*UnimplementedImmuServiceServer) Health(context.Context, *empty.Empty) (*HealthResponse, error)

func (*UnimplementedImmuServiceServer) History 

func (*UnimplementedImmuServiceServer) History(context.Context, *HistoryRequest) (*Entries, error)

func (*UnimplementedImmuServiceServer) ListTables added in v1.0.0 

func (*UnimplementedImmuServiceServer) ListTables(context.Context, *empty.Empty) (*SQLQueryResult, error)

func (*UnimplementedImmuServiceServer) ListUsers 

func (*UnimplementedImmuServiceServer) ListUsers(context.Context, *empty.Empty) (*UserList, error)

func (*UnimplementedImmuServiceServer) Login 

func (*UnimplementedImmuServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)

func (*UnimplementedImmuServiceServer) Logout added in v0.6.1 

func (*UnimplementedImmuServiceServer) Logout(context.Context, *empty.Empty) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) ReplicateTx added in v1.0.5 

func (*UnimplementedImmuServiceServer) ReplicateTx(ImmuService_ReplicateTxServer) error

func (*UnimplementedImmuServiceServer) SQLExec added in v1.0.0 

func (*UnimplementedImmuServiceServer) SQLExec(context.Context, *SQLExecRequest) (*SQLExecResult, error)

func (*UnimplementedImmuServiceServer) SQLQuery added in v1.0.0 

func (*UnimplementedImmuServiceServer) SQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)

func (*UnimplementedImmuServiceServer) Scan 

func (*UnimplementedImmuServiceServer) Scan(context.Context, *ScanRequest) (*Entries, error)

func (*UnimplementedImmuServiceServer) Set 

func (*UnimplementedImmuServiceServer) Set(context.Context, *SetRequest) (*TxMetadata, error)

func (*UnimplementedImmuServiceServer) SetActiveUser added in v0.7.0 

func (*UnimplementedImmuServiceServer) SetActiveUser(context.Context, *SetActiveUserRequest) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) SetReference added in v0.9.0 

func (*UnimplementedImmuServiceServer) SetReference(context.Context, *ReferenceRequest) (*TxMetadata, error)

func (*UnimplementedImmuServiceServer) StreamExecAll added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamExecAll(ImmuService_StreamExecAllServer) error

func (*UnimplementedImmuServiceServer) StreamGet added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamGet(*KeyRequest, ImmuService_StreamGetServer) error

func (*UnimplementedImmuServiceServer) StreamHistory added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamHistory(*HistoryRequest, ImmuService_StreamHistoryServer) error

func (*UnimplementedImmuServiceServer) StreamScan added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamScan(*ScanRequest, ImmuService_StreamScanServer) error

func (*UnimplementedImmuServiceServer) StreamSet added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamSet(ImmuService_StreamSetServer) error

func (*UnimplementedImmuServiceServer) StreamVerifiableGet added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamVerifiableGet(*VerifiableGetRequest, ImmuService_StreamVerifiableGetServer) error

func (*UnimplementedImmuServiceServer) StreamVerifiableSet added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamVerifiableSet(ImmuService_StreamVerifiableSetServer) error

func (*UnimplementedImmuServiceServer) StreamZScan added in v0.9.2 

func (*UnimplementedImmuServiceServer) StreamZScan(*ZScanRequest, ImmuService_StreamZScanServer) error

func (*UnimplementedImmuServiceServer) TxById added in v0.9.0 

func (*UnimplementedImmuServiceServer) TxById(context.Context, *TxRequest) (*Tx, error)

func (*UnimplementedImmuServiceServer) TxScan added in v0.9.1 

func (*UnimplementedImmuServiceServer) TxScan(context.Context, *TxScanRequest) (*TxList, error)

func (*UnimplementedImmuServiceServer) UpdateAuthConfig 

func (*UnimplementedImmuServiceServer) UpdateAuthConfig(context.Context, *AuthConfig) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) UpdateDatabase added in v1.0.5 

func (*UnimplementedImmuServiceServer) UpdateDatabase(context.Context, *DatabaseSettings) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) UpdateMTLSConfig 

func (*UnimplementedImmuServiceServer) UpdateMTLSConfig(context.Context, *MTLSConfig) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) UseDatabase added in v0.7.0 

func (*UnimplementedImmuServiceServer) UseDatabase(context.Context, *Database) (*UseDatabaseReply, error)

func (*UnimplementedImmuServiceServer) UseSnapshot added in v1.0.0 

func (*UnimplementedImmuServiceServer) UseSnapshot(context.Context, *UseSnapshotRequest) (*empty.Empty, error)

func (*UnimplementedImmuServiceServer) VerifiableGet added in v0.9.0 

func (*UnimplementedImmuServiceServer) VerifiableGet(context.Context, *VerifiableGetRequest) (*VerifiableEntry, error)

func (*UnimplementedImmuServiceServer) VerifiableSQLGet added in v1.0.0 

func (*UnimplementedImmuServiceServer) VerifiableSQLGet(context.Context, *VerifiableSQLGetRequest) (*VerifiableSQLEntry, error)

func (*UnimplementedImmuServiceServer) VerifiableSet added in v0.9.0 

func (*UnimplementedImmuServiceServer) VerifiableSet(context.Context, *VerifiableSetRequest) (*VerifiableTx, error)

func (*UnimplementedImmuServiceServer) VerifiableSetReference added in v0.9.0 

func (*UnimplementedImmuServiceServer) VerifiableSetReference(context.Context, *VerifiableReferenceRequest) (*VerifiableTx, error)

func (*UnimplementedImmuServiceServer) VerifiableTxById added in v0.9.0 

func (*UnimplementedImmuServiceServer) VerifiableTxById(context.Context, *VerifiableTxRequest) (*VerifiableTx, error)

func (*UnimplementedImmuServiceServer) VerifiableZAdd added in v0.9.0 

func (*UnimplementedImmuServiceServer) VerifiableZAdd(context.Context, *VerifiableZAddRequest) (*VerifiableTx, error)

func (*UnimplementedImmuServiceServer) ZAdd 

func (*UnimplementedImmuServiceServer) ZAdd(context.Context, *ZAddRequest) (*TxMetadata, error)

func (*UnimplementedImmuServiceServer) ZScan 

func (*UnimplementedImmuServiceServer) ZScan(context.Context, *ZScanRequest) (*ZEntries, error)

type UseDatabaseReply added in v0.7.0 

type UseDatabaseReply struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*UseDatabaseReply) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use UseDatabaseReply.ProtoReflect.Descriptor instead.

func (*UseDatabaseReply) GetToken added in v0.7.0 

func (x *UseDatabaseReply) GetToken() string

func (*UseDatabaseReply) ProtoMessage added in v0.7.0 

func (*UseDatabaseReply) ProtoMessage()

func (*UseDatabaseReply) ProtoReflect added in v0.9.0 

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

func (*UseDatabaseReply) Reset added in v0.7.0 

func (x *UseDatabaseReply) Reset()

func (*UseDatabaseReply) String added in v0.7.0 

func (x *UseDatabaseReply) String() string

type UseSnapshotRequest added in v1.0.0 

type UseSnapshotRequest struct {
	SinceTx    uint64 `protobuf:"varint,1,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	AsBeforeTx uint64 `protobuf:"varint,2,opt,name=asBeforeTx,proto3" json:"asBeforeTx,omitempty"`
	// contains filtered or unexported fields
}

func (*UseSnapshotRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use UseSnapshotRequest.ProtoReflect.Descriptor instead.

func (*UseSnapshotRequest) GetAsBeforeTx added in v1.0.0 

func (x *UseSnapshotRequest) GetAsBeforeTx() uint64

func (*UseSnapshotRequest) GetSinceTx added in v1.0.0 

func (x *UseSnapshotRequest) GetSinceTx() uint64

func (*UseSnapshotRequest) ProtoMessage added in v1.0.0 

func (*UseSnapshotRequest) ProtoMessage()

func (*UseSnapshotRequest) ProtoReflect added in v1.0.0 

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

func (*UseSnapshotRequest) Reset added in v1.0.0 

func (x *UseSnapshotRequest) Reset()

func (*UseSnapshotRequest) String added in v1.0.0 

func (x *UseSnapshotRequest) String() string

type User 

type User struct {
	User        []byte        `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Permissions []*Permission `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"`
	Createdby   string        `protobuf:"bytes,4,opt,name=createdby,proto3" json:"createdby,omitempty"`
	Createdat   string        `protobuf:"bytes,5,opt,name=createdat,proto3" json:"createdat,omitempty"`
	Active      bool          `protobuf:"varint,6,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetActive added in v0.7.0 

func (x *User) GetActive() bool

func (*User) GetCreatedat added in v0.7.0 

func (x *User) GetCreatedat() string

func (*User) GetCreatedby added in v0.7.0 

func (x *User) GetCreatedby() string

func (*User) GetPermissions 

func (x *User) GetPermissions() []*Permission

func (*User) GetUser 

func (x *User) GetUser() []byte

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v0.9.0 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type UserList 

type UserList struct {
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*UserList) Descriptor deprecated 

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

Deprecated: Use UserList.ProtoReflect.Descriptor instead.

func (*UserList) GetUsers 

func (x *UserList) GetUsers() []*User

func (*UserList) ProtoMessage 

func (*UserList) ProtoMessage()

func (*UserList) ProtoReflect added in v0.9.0 

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

func (*UserList) Reset 

func (x *UserList) Reset()

func (*UserList) String 

func (x *UserList) String() string

type UserRequest 

type UserRequest struct {
	User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*UserRequest) Descriptor deprecated 

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

Deprecated: Use UserRequest.ProtoReflect.Descriptor instead.

func (*UserRequest) GetUser 

func (x *UserRequest) GetUser() []byte

func (*UserRequest) ProtoMessage 

func (*UserRequest) ProtoMessage()

func (*UserRequest) ProtoReflect added in v0.9.0 

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

func (*UserRequest) Reset 

func (x *UserRequest) Reset()

func (*UserRequest) String 

func (x *UserRequest) String() string

type VerifiableEntry added in v0.9.0 

type VerifiableEntry struct {
	Entry          *Entry          `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	VerifiableTx   *VerifiableTx   `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"`
	InclusionProof *InclusionProof `protobuf:"bytes,3,opt,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableEntry) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableEntry.ProtoReflect.Descriptor instead.

func (*VerifiableEntry) GetEntry added in v0.9.0 

func (x *VerifiableEntry) GetEntry() *Entry

func (*VerifiableEntry) GetInclusionProof added in v0.9.0 

func (x *VerifiableEntry) GetInclusionProof() *InclusionProof

func (*VerifiableEntry) GetVerifiableTx added in v0.9.0 

func (x *VerifiableEntry) GetVerifiableTx() *VerifiableTx

func (*VerifiableEntry) ProtoMessage added in v0.9.0 

func (*VerifiableEntry) ProtoMessage()

func (*VerifiableEntry) ProtoReflect added in v0.9.0 

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

func (*VerifiableEntry) Reset added in v0.9.0 

func (x *VerifiableEntry) Reset()

func (*VerifiableEntry) String added in v0.9.0 

func (x *VerifiableEntry) String() string

type VerifiableGetRequest added in v0.9.0 

type VerifiableGetRequest struct {
	KeyRequest   *KeyRequest `protobuf:"bytes,1,opt,name=keyRequest,proto3" json:"keyRequest,omitempty"`
	ProveSinceTx uint64      `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableGetRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableGetRequest.ProtoReflect.Descriptor instead.

func (*VerifiableGetRequest) GetKeyRequest added in v0.9.0 

func (x *VerifiableGetRequest) GetKeyRequest() *KeyRequest

func (*VerifiableGetRequest) GetProveSinceTx added in v0.9.0 

func (x *VerifiableGetRequest) GetProveSinceTx() uint64

func (*VerifiableGetRequest) ProtoMessage added in v0.9.0 

func (*VerifiableGetRequest) ProtoMessage()

func (*VerifiableGetRequest) ProtoReflect added in v0.9.0 

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

func (*VerifiableGetRequest) Reset added in v0.9.0 

func (x *VerifiableGetRequest) Reset()

func (*VerifiableGetRequest) String added in v0.9.0 

func (x *VerifiableGetRequest) String() string

type VerifiableReferenceRequest added in v0.9.0 

type VerifiableReferenceRequest struct {
	ReferenceRequest *ReferenceRequest `protobuf:"bytes,1,opt,name=referenceRequest,proto3" json:"referenceRequest,omitempty"`
	ProveSinceTx     uint64            `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableReferenceRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableReferenceRequest.ProtoReflect.Descriptor instead.

func (*VerifiableReferenceRequest) GetProveSinceTx added in v0.9.0 

func (x *VerifiableReferenceRequest) GetProveSinceTx() uint64

func (*VerifiableReferenceRequest) GetReferenceRequest added in v0.9.0 

func (x *VerifiableReferenceRequest) GetReferenceRequest() *ReferenceRequest

func (*VerifiableReferenceRequest) ProtoMessage added in v0.9.0 

func (*VerifiableReferenceRequest) ProtoMessage()

func (*VerifiableReferenceRequest) ProtoReflect added in v0.9.0 

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

func (*VerifiableReferenceRequest) Reset added in v0.9.0 

func (x *VerifiableReferenceRequest) Reset()

func (*VerifiableReferenceRequest) String added in v0.9.0 

func (x *VerifiableReferenceRequest) String() string

type VerifiableSQLEntry added in v1.0.0 

type VerifiableSQLEntry struct {
	SqlEntry       *SQLEntry         `protobuf:"bytes,1,opt,name=sqlEntry,proto3" json:"sqlEntry,omitempty"`
	VerifiableTx   *VerifiableTx     `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"`
	InclusionProof *InclusionProof   `protobuf:"bytes,3,opt,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	DatabaseId     uint32            `protobuf:"varint,4,opt,name=DatabaseId,proto3" json:"DatabaseId,omitempty"`
	TableId        uint32            `protobuf:"varint,5,opt,name=TableId,proto3" json:"TableId,omitempty"`
	PKIDs          []uint32          `protobuf:"varint,16,rep,packed,name=PKIDs,proto3" json:"PKIDs,omitempty"`
	ColNamesById   map[uint32]string `` /* 166-byte string literal not displayed */
	ColIdsByName   map[string]uint32 `` /* 166-byte string literal not displayed */
	ColTypesById   map[uint32]string `` /* 167-byte string literal not displayed */
	ColLenById     map[uint32]int32  `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VerifiableSQLEntry) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use VerifiableSQLEntry.ProtoReflect.Descriptor instead.

func (*VerifiableSQLEntry) GetColIdsByName added in v1.0.0 

func (x *VerifiableSQLEntry) GetColIdsByName() map[string]uint32

func (*VerifiableSQLEntry) GetColLenById added in v1.1.0 

func (x *VerifiableSQLEntry) GetColLenById() map[uint32]int32

func (*VerifiableSQLEntry) GetColNamesById added in v1.0.5 

func (x *VerifiableSQLEntry) GetColNamesById() map[uint32]string

func (*VerifiableSQLEntry) GetColTypesById added in v1.0.0 

func (x *VerifiableSQLEntry) GetColTypesById() map[uint32]string

func (*VerifiableSQLEntry) GetDatabaseId added in v1.0.0 

func (x *VerifiableSQLEntry) GetDatabaseId() uint32

func (*VerifiableSQLEntry) GetInclusionProof added in v1.0.0 

func (x *VerifiableSQLEntry) GetInclusionProof() *InclusionProof

func (*VerifiableSQLEntry) GetPKIDs added in v1.1.0 

func (x *VerifiableSQLEntry) GetPKIDs() []uint32

func (*VerifiableSQLEntry) GetSqlEntry added in v1.0.0 

func (x *VerifiableSQLEntry) GetSqlEntry() *SQLEntry

func (*VerifiableSQLEntry) GetTableId added in v1.0.0 

func (x *VerifiableSQLEntry) GetTableId() uint32

func (*VerifiableSQLEntry) GetVerifiableTx added in v1.0.0 

func (x *VerifiableSQLEntry) GetVerifiableTx() *VerifiableTx

func (*VerifiableSQLEntry) ProtoMessage added in v1.0.0 

func (*VerifiableSQLEntry) ProtoMessage()

func (*VerifiableSQLEntry) ProtoReflect added in v1.0.0 

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

func (*VerifiableSQLEntry) Reset added in v1.0.0 

func (x *VerifiableSQLEntry) Reset()

func (*VerifiableSQLEntry) String added in v1.0.0 

func (x *VerifiableSQLEntry) String() string

type VerifiableSQLGetRequest added in v1.0.0 

type VerifiableSQLGetRequest struct {
	SqlGetRequest *SQLGetRequest `protobuf:"bytes,1,opt,name=sqlGetRequest,proto3" json:"sqlGetRequest,omitempty"`
	ProveSinceTx  uint64         `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableSQLGetRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use VerifiableSQLGetRequest.ProtoReflect.Descriptor instead.

func (*VerifiableSQLGetRequest) GetProveSinceTx added in v1.0.0 

func (x *VerifiableSQLGetRequest) GetProveSinceTx() uint64

func (*VerifiableSQLGetRequest) GetSqlGetRequest added in v1.0.0 

func (x *VerifiableSQLGetRequest) GetSqlGetRequest() *SQLGetRequest

func (*VerifiableSQLGetRequest) ProtoMessage added in v1.0.0 

func (*VerifiableSQLGetRequest) ProtoMessage()

func (*VerifiableSQLGetRequest) ProtoReflect added in v1.0.0 

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

func (*VerifiableSQLGetRequest) Reset added in v1.0.0 

func (x *VerifiableSQLGetRequest) Reset()

func (*VerifiableSQLGetRequest) String added in v1.0.0 

func (x *VerifiableSQLGetRequest) String() string

type VerifiableSetRequest added in v0.9.0 

type VerifiableSetRequest struct {
	SetRequest   *SetRequest `protobuf:"bytes,1,opt,name=setRequest,proto3" json:"setRequest,omitempty"`
	ProveSinceTx uint64      `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableSetRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableSetRequest.ProtoReflect.Descriptor instead.

func (*VerifiableSetRequest) GetProveSinceTx added in v0.9.0 

func (x *VerifiableSetRequest) GetProveSinceTx() uint64

func (*VerifiableSetRequest) GetSetRequest added in v0.9.0 

func (x *VerifiableSetRequest) GetSetRequest() *SetRequest

func (*VerifiableSetRequest) ProtoMessage added in v0.9.0 

func (*VerifiableSetRequest) ProtoMessage()

func (*VerifiableSetRequest) ProtoReflect added in v0.9.0 

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

func (*VerifiableSetRequest) Reset added in v0.9.0 

func (x *VerifiableSetRequest) Reset()

func (*VerifiableSetRequest) String added in v0.9.0 

func (x *VerifiableSetRequest) String() string

type VerifiableTx added in v0.9.0 

type VerifiableTx struct {
	Tx        *Tx        `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	DualProof *DualProof `protobuf:"bytes,2,opt,name=dualProof,proto3" json:"dualProof,omitempty"`
	Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableTx) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableTx.ProtoReflect.Descriptor instead.

func (*VerifiableTx) GetDualProof added in v0.9.0 

func (x *VerifiableTx) GetDualProof() *DualProof

func (*VerifiableTx) GetSignature added in v0.9.0 

func (x *VerifiableTx) GetSignature() *Signature

func (*VerifiableTx) GetTx added in v0.9.0 

func (x *VerifiableTx) GetTx() *Tx

func (*VerifiableTx) ProtoMessage added in v0.9.0 

func (*VerifiableTx) ProtoMessage()

func (*VerifiableTx) ProtoReflect added in v0.9.0 

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

func (*VerifiableTx) Reset added in v0.9.0 

func (x *VerifiableTx) Reset()

func (*VerifiableTx) String added in v0.9.0 

func (x *VerifiableTx) String() string

type VerifiableTxRequest added in v0.9.0 

type VerifiableTxRequest struct {
	Tx           uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableTxRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableTxRequest.ProtoReflect.Descriptor instead.

func (*VerifiableTxRequest) GetProveSinceTx added in v0.9.0 

func (x *VerifiableTxRequest) GetProveSinceTx() uint64

func (*VerifiableTxRequest) GetTx added in v0.9.0 

func (x *VerifiableTxRequest) GetTx() uint64

func (*VerifiableTxRequest) ProtoMessage added in v0.9.0 

func (*VerifiableTxRequest) ProtoMessage()

func (*VerifiableTxRequest) ProtoReflect added in v0.9.0 

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

func (*VerifiableTxRequest) Reset added in v0.9.0 

func (x *VerifiableTxRequest) Reset()

func (*VerifiableTxRequest) String added in v0.9.0 

func (x *VerifiableTxRequest) String() string

type VerifiableZAddRequest added in v0.9.0 

type VerifiableZAddRequest struct {
	ZAddRequest  *ZAddRequest `protobuf:"bytes,1,opt,name=zAddRequest,proto3" json:"zAddRequest,omitempty"`
	ProveSinceTx uint64       `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableZAddRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use VerifiableZAddRequest.ProtoReflect.Descriptor instead.

func (*VerifiableZAddRequest) GetProveSinceTx added in v0.9.0 

func (x *VerifiableZAddRequest) GetProveSinceTx() uint64

func (*VerifiableZAddRequest) GetZAddRequest added in v0.9.0 

func (x *VerifiableZAddRequest) GetZAddRequest() *ZAddRequest

func (*VerifiableZAddRequest) ProtoMessage added in v0.9.0 

func (*VerifiableZAddRequest) ProtoMessage()

func (*VerifiableZAddRequest) ProtoReflect added in v0.9.0 

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

func (*VerifiableZAddRequest) Reset added in v0.9.0 

func (x *VerifiableZAddRequest) Reset()

func (*VerifiableZAddRequest) String added in v0.9.0 

func (x *VerifiableZAddRequest) String() string

type ZAddRequest added in v0.9.0 

type ZAddRequest struct {
	Set      []byte  `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	Score    float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	Key      []byte  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	AtTx     uint64  `protobuf:"varint,4,opt,name=atTx,proto3" json:"atTx,omitempty"`
	BoundRef bool    `protobuf:"varint,5,opt,name=boundRef,proto3" json:"boundRef,omitempty"`
	NoWait   bool    `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ZAddRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ZAddRequest.ProtoReflect.Descriptor instead.

func (*ZAddRequest) GetAtTx added in v0.9.0 

func (x *ZAddRequest) GetAtTx() uint64

func (*ZAddRequest) GetBoundRef added in v0.9.1 

func (x *ZAddRequest) GetBoundRef() bool

func (*ZAddRequest) GetKey added in v0.9.0 

func (x *ZAddRequest) GetKey() []byte

func (*ZAddRequest) GetNoWait added in v0.9.2 

func (x *ZAddRequest) GetNoWait() bool

func (*ZAddRequest) GetScore added in v0.9.0 

func (x *ZAddRequest) GetScore() float64

func (*ZAddRequest) GetSet added in v0.9.0 

func (x *ZAddRequest) GetSet() []byte

func (*ZAddRequest) ProtoMessage added in v0.9.0 

func (*ZAddRequest) ProtoMessage()

func (*ZAddRequest) ProtoReflect added in v0.9.0 

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

func (*ZAddRequest) Reset added in v0.9.0 

func (x *ZAddRequest) Reset()

func (*ZAddRequest) String added in v0.9.0 

func (x *ZAddRequest) String() string

type ZEntries added in v0.9.0 

type ZEntries struct {
	Entries []*ZEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ZEntries) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ZEntries.ProtoReflect.Descriptor instead.

func (*ZEntries) GetEntries added in v0.9.0 

func (x *ZEntries) GetEntries() []*ZEntry

func (*ZEntries) ProtoMessage added in v0.9.0 

func (*ZEntries) ProtoMessage()

func (*ZEntries) ProtoReflect added in v0.9.0 

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

func (*ZEntries) Reset added in v0.9.0 

func (x *ZEntries) Reset()

func (*ZEntries) String added in v0.9.0 

func (x *ZEntries) String() string

type ZEntry added in v0.9.0 

type ZEntry struct {
	Set   []byte  `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	Key   []byte  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Entry *Entry  `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	Score float64 `protobuf:"fixed64,4,opt,name=score,proto3" json:"score,omitempty"`
	AtTx  uint64  `protobuf:"varint,5,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// contains filtered or unexported fields
}

func (*ZEntry) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ZEntry.ProtoReflect.Descriptor instead.

func (*ZEntry) GetAtTx added in v0.9.0 

func (x *ZEntry) GetAtTx() uint64

func (*ZEntry) GetEntry added in v0.9.0 

func (x *ZEntry) GetEntry() *Entry

func (*ZEntry) GetKey added in v0.9.0 

func (x *ZEntry) GetKey() []byte

func (*ZEntry) GetScore added in v0.9.0 

func (x *ZEntry) GetScore() float64

func (*ZEntry) GetSet added in v0.9.0 

func (x *ZEntry) GetSet() []byte

func (*ZEntry) ProtoMessage added in v0.9.0 

func (*ZEntry) ProtoMessage()

func (*ZEntry) ProtoReflect added in v0.9.0 

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

func (*ZEntry) Reset added in v0.9.0 

func (x *ZEntry) Reset()

func (*ZEntry) String added in v0.9.0 

func (x *ZEntry) String() string

type ZScanRequest added in v0.9.0 

type ZScanRequest struct {
	Set           []byte  `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	SeekKey       []byte  `protobuf:"bytes,2,opt,name=seekKey,proto3" json:"seekKey,omitempty"`
	SeekScore     float64 `protobuf:"fixed64,3,opt,name=seekScore,proto3" json:"seekScore,omitempty"`
	SeekAtTx      uint64  `protobuf:"varint,4,opt,name=seekAtTx,proto3" json:"seekAtTx,omitempty"`
	InclusiveSeek bool    `protobuf:"varint,5,opt,name=inclusiveSeek,proto3" json:"inclusiveSeek,omitempty"`
	Limit         uint64  `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	Desc          bool    `protobuf:"varint,7,opt,name=desc,proto3" json:"desc,omitempty"`
	MinScore      *Score  `protobuf:"bytes,8,opt,name=minScore,proto3" json:"minScore,omitempty"`
	MaxScore      *Score  `protobuf:"bytes,9,opt,name=maxScore,proto3" json:"maxScore,omitempty"`
	SinceTx       uint64  `protobuf:"varint,10,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	NoWait        bool    `protobuf:"varint,11,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ZScanRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ZScanRequest.ProtoReflect.Descriptor instead.

func (*ZScanRequest) GetDesc added in v0.9.0 

func (x *ZScanRequest) GetDesc() bool

func (*ZScanRequest) GetInclusiveSeek added in v0.9.0 

func (x *ZScanRequest) GetInclusiveSeek() bool

func (*ZScanRequest) GetLimit added in v0.9.0 

func (x *ZScanRequest) GetLimit() uint64

func (*ZScanRequest) GetMaxScore added in v0.9.0 

func (x *ZScanRequest) GetMaxScore() *Score

func (*ZScanRequest) GetMinScore added in v0.9.0 

func (x *ZScanRequest) GetMinScore() *Score

func (*ZScanRequest) GetNoWait added in v0.9.0 

func (x *ZScanRequest) GetNoWait() bool

func (*ZScanRequest) GetSeekAtTx added in v0.9.0 

func (x *ZScanRequest) GetSeekAtTx() uint64

func (*ZScanRequest) GetSeekKey added in v0.9.0 

func (x *ZScanRequest) GetSeekKey() []byte

func (*ZScanRequest) GetSeekScore added in v0.9.0 

func (x *ZScanRequest) GetSeekScore() float64

func (*ZScanRequest) GetSet added in v0.9.0 

func (x *ZScanRequest) GetSet() []byte

func (*ZScanRequest) GetSinceTx added in v0.9.0 

func (x *ZScanRequest) GetSinceTx() uint64

func (*ZScanRequest) ProtoMessage added in v0.9.0 

func (*ZScanRequest) ProtoMessage()

func (*ZScanRequest) ProtoReflect added in v0.9.0 

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

func (*ZScanRequest) Reset added in v0.9.0 

func (x *ZScanRequest) Reset()

func (*ZScanRequest) String added in v0.9.0 

func (x *ZScanRequest) String() string

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.