schema

package
Version: v1.3.0 Latest Latest
Warning

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

Go to latest
Published: May 23, 2022 License: Apache-2.0 Imports: 33 Imported by: 15

Documentation

Overview

Copyright 2022 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 2022 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 2022 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 2022 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 2022 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 2022 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 2022 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 2022 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 (
	EntryTypeAction_name = map[int32]string{
		0: "EXCLUDE",
		1: "ONLY_DIGEST",
		2: "RAW_VALUE",
		3: "RESOLVE",
	}
	EntryTypeAction_value = map[string]int32{
		"EXCLUDE":     0,
		"ONLY_DIGEST": 1,
		"RAW_VALUE":   2,
		"RESOLVE":     3,
	}
)

Enum value maps for EntryTypeAction.

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 (
	TxMode_name = map[int32]string{
		0: "ReadOnly",
		1: "WriteOnly",
		2: "ReadWrite",
	}
	TxMode_value = map[string]int32{
		"ReadOnly":  0,
		"WriteOnly": 1,
		"ReadWrite": 2,
	}
)

Enum value maps for TxMode.

View Source
var File_schema_proto protoreflect.FileDescriptor

Functions

func DigestFromProto added in v1.2.0

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

func DigestsFromProto added in v1.2.0

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

func DigestsToProto added in v1.2.0

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

func DualProofFromProto added in v1.2.0

func DualProofFromProto(dproof *DualProof) *store.DualProof

func InclusionProofFromProto added in v1.2.0

func InclusionProofFromProto(iproof *InclusionProof) *htree.InclusionProof

func KVMetadataFromProto added in v1.2.0

func KVMetadataFromProto(md *KVMetadata) *store.KVMetadata

func LinearProofFromProto added in v1.2.0

func LinearProofFromProto(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 TxFromProto added in v1.2.0

func TxFromProto(stx *Tx) *store.Tx

func TxHeaderFromProto added in v1.2.0

func TxHeaderFromProto(hdr *TxHeader) *store.TxHeader

func TxMetadataFromProto added in v1.2.0

func TxMetadataFromProto(md *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 (*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 CommittedSQLTx added in v1.2.0

type CommittedSQLTx struct {
	Header           *TxHeader            `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	UpdatedRows      uint32               `protobuf:"varint,2,opt,name=updatedRows,proto3" json:"updatedRows,omitempty"`
	LastInsertedPKs  map[string]*SQLValue `` /* 171-byte string literal not displayed */
	FirstInsertedPKs map[string]*SQLValue `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CommittedSQLTx) Descriptor deprecated added in v1.2.0

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

Deprecated: Use CommittedSQLTx.ProtoReflect.Descriptor instead.

func (*CommittedSQLTx) GetFirstInsertedPKs added in v1.2.2

func (x *CommittedSQLTx) GetFirstInsertedPKs() map[string]*SQLValue

func (*CommittedSQLTx) GetHeader added in v1.2.0

func (x *CommittedSQLTx) GetHeader() *TxHeader

func (*CommittedSQLTx) GetLastInsertedPKs added in v1.2.0

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

func (*CommittedSQLTx) GetUpdatedRows added in v1.2.0

func (x *CommittedSQLTx) GetUpdatedRows() uint32

func (*CommittedSQLTx) ProtoMessage added in v1.2.0

func (*CommittedSQLTx) ProtoMessage()

func (*CommittedSQLTx) ProtoReflect added in v1.2.0

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

func (*CommittedSQLTx) Reset added in v1.2.0

func (x *CommittedSQLTx) Reset()

func (*CommittedSQLTx) String added in v1.2.0

func (x *CommittedSQLTx) String() string

type CreateDatabaseRequest added in v1.2.3

type CreateDatabaseRequest struct {
	Name        string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Settings    *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	IfNotExists bool                      `protobuf:"varint,3,opt,name=ifNotExists,proto3" json:"ifNotExists,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.

func (*CreateDatabaseRequest) GetIfNotExists added in v1.3.0

func (x *CreateDatabaseRequest) GetIfNotExists() bool

func (*CreateDatabaseRequest) GetName added in v1.2.3

func (x *CreateDatabaseRequest) GetName() string

func (*CreateDatabaseRequest) GetSettings added in v1.2.3

func (*CreateDatabaseRequest) ProtoMessage added in v1.2.3

func (*CreateDatabaseRequest) ProtoMessage()

func (*CreateDatabaseRequest) ProtoReflect added in v1.2.3

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

func (*CreateDatabaseRequest) Reset added in v1.2.3

func (x *CreateDatabaseRequest) Reset()

func (*CreateDatabaseRequest) String added in v1.2.3

func (x *CreateDatabaseRequest) String() string

type CreateDatabaseResponse added in v1.2.3

type CreateDatabaseResponse struct {
	Name           string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Settings       *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	AlreadyExisted bool                      `protobuf:"varint,3,opt,name=alreadyExisted,proto3" json:"alreadyExisted,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use CreateDatabaseResponse.ProtoReflect.Descriptor instead.

func (*CreateDatabaseResponse) GetAlreadyExisted added in v1.3.0

func (x *CreateDatabaseResponse) GetAlreadyExisted() bool

func (*CreateDatabaseResponse) GetName added in v1.2.3

func (x *CreateDatabaseResponse) GetName() string

func (*CreateDatabaseResponse) GetSettings added in v1.2.3

func (*CreateDatabaseResponse) ProtoMessage added in v1.2.3

func (*CreateDatabaseResponse) ProtoMessage()

func (*CreateDatabaseResponse) ProtoReflect added in v1.2.3

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

func (*CreateDatabaseResponse) Reset added in v1.2.3

func (x *CreateDatabaseResponse) Reset()

func (*CreateDatabaseResponse) String added in v1.2.3

func (x *CreateDatabaseResponse) 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 DatabaseHealthResponse added in v1.2.3

type DatabaseHealthResponse struct {
	PendingRequests        uint32 `protobuf:"varint,1,opt,name=pendingRequests,proto3" json:"pendingRequests,omitempty"`
	LastRequestCompletedAt int64  `protobuf:"varint,2,opt,name=lastRequestCompletedAt,proto3" json:"lastRequestCompletedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseHealthResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseHealthResponse.ProtoReflect.Descriptor instead.

func (*DatabaseHealthResponse) GetLastRequestCompletedAt added in v1.2.3

func (x *DatabaseHealthResponse) GetLastRequestCompletedAt() int64

func (*DatabaseHealthResponse) GetPendingRequests added in v1.2.3

func (x *DatabaseHealthResponse) GetPendingRequests() uint32

func (*DatabaseHealthResponse) ProtoMessage added in v1.2.3

func (*DatabaseHealthResponse) ProtoMessage()

func (*DatabaseHealthResponse) ProtoReflect added in v1.2.3

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

func (*DatabaseHealthResponse) Reset added in v1.2.3

func (x *DatabaseHealthResponse) Reset()

func (*DatabaseHealthResponse) String added in v1.2.3

func (x *DatabaseHealthResponse) String() string

type DatabaseListRequestV2 added in v1.2.3

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

func (*DatabaseListRequestV2) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseListRequestV2.ProtoReflect.Descriptor instead.

func (*DatabaseListRequestV2) ProtoMessage added in v1.2.3

func (*DatabaseListRequestV2) ProtoMessage()

func (*DatabaseListRequestV2) ProtoReflect added in v1.2.3

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

func (*DatabaseListRequestV2) Reset added in v1.2.3

func (x *DatabaseListRequestV2) Reset()

func (*DatabaseListRequestV2) String added in v1.2.3

func (x *DatabaseListRequestV2) 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 DatabaseListResponseV2 added in v1.2.3

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

func (*DatabaseListResponseV2) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseListResponseV2.ProtoReflect.Descriptor instead.

func (*DatabaseListResponseV2) GetDatabases added in v1.2.3

func (x *DatabaseListResponseV2) GetDatabases() []*DatabaseWithSettings

func (*DatabaseListResponseV2) ProtoMessage added in v1.2.3

func (*DatabaseListResponseV2) ProtoMessage()

func (*DatabaseListResponseV2) ProtoReflect added in v1.2.3

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

func (*DatabaseListResponseV2) Reset added in v1.2.3

func (x *DatabaseListResponseV2) Reset()

func (*DatabaseListResponseV2) String added in v1.2.3

func (x *DatabaseListResponseV2) String() string

type DatabaseNullableSettings added in v1.2.3

type DatabaseNullableSettings struct {
	ReplicationSettings     *ReplicationNullableSettings `protobuf:"bytes,2,opt,name=replicationSettings,proto3" json:"replicationSettings,omitempty"`
	FileSize                *NullableUint32              `protobuf:"bytes,8,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	MaxKeyLen               *NullableUint32              `protobuf:"bytes,9,opt,name=maxKeyLen,proto3" json:"maxKeyLen,omitempty"`
	MaxValueLen             *NullableUint32              `protobuf:"bytes,10,opt,name=maxValueLen,proto3" json:"maxValueLen,omitempty"`
	MaxTxEntries            *NullableUint32              `protobuf:"bytes,11,opt,name=maxTxEntries,proto3" json:"maxTxEntries,omitempty"`
	ExcludeCommitTime       *NullableBool                `protobuf:"bytes,12,opt,name=excludeCommitTime,proto3" json:"excludeCommitTime,omitempty"`
	MaxConcurrency          *NullableUint32              `protobuf:"bytes,13,opt,name=maxConcurrency,proto3" json:"maxConcurrency,omitempty"`
	MaxIOConcurrency        *NullableUint32              `protobuf:"bytes,14,opt,name=maxIOConcurrency,proto3" json:"maxIOConcurrency,omitempty"`
	TxLogCacheSize          *NullableUint32              `protobuf:"bytes,15,opt,name=txLogCacheSize,proto3" json:"txLogCacheSize,omitempty"`
	VLogMaxOpenedFiles      *NullableUint32              `protobuf:"bytes,16,opt,name=vLogMaxOpenedFiles,proto3" json:"vLogMaxOpenedFiles,omitempty"`
	TxLogMaxOpenedFiles     *NullableUint32              `protobuf:"bytes,17,opt,name=txLogMaxOpenedFiles,proto3" json:"txLogMaxOpenedFiles,omitempty"`
	CommitLogMaxOpenedFiles *NullableUint32              `protobuf:"bytes,18,opt,name=commitLogMaxOpenedFiles,proto3" json:"commitLogMaxOpenedFiles,omitempty"`
	IndexSettings           *IndexNullableSettings       `protobuf:"bytes,19,opt,name=indexSettings,proto3" json:"indexSettings,omitempty"`
	WriteTxHeaderVersion    *NullableUint32              `protobuf:"bytes,20,opt,name=writeTxHeaderVersion,proto3" json:"writeTxHeaderVersion,omitempty"`
	Autoload                *NullableBool                `protobuf:"bytes,21,opt,name=autoload,proto3" json:"autoload,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseNullableSettings) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseNullableSettings.ProtoReflect.Descriptor instead.

func (*DatabaseNullableSettings) GetAutoload added in v1.2.3

func (x *DatabaseNullableSettings) GetAutoload() *NullableBool

func (*DatabaseNullableSettings) GetCommitLogMaxOpenedFiles added in v1.2.3

func (x *DatabaseNullableSettings) GetCommitLogMaxOpenedFiles() *NullableUint32

func (*DatabaseNullableSettings) GetExcludeCommitTime added in v1.2.3

func (x *DatabaseNullableSettings) GetExcludeCommitTime() *NullableBool

func (*DatabaseNullableSettings) GetFileSize added in v1.2.3

func (x *DatabaseNullableSettings) GetFileSize() *NullableUint32

func (*DatabaseNullableSettings) GetIndexSettings added in v1.2.3

func (x *DatabaseNullableSettings) GetIndexSettings() *IndexNullableSettings

func (*DatabaseNullableSettings) GetMaxConcurrency added in v1.2.3

func (x *DatabaseNullableSettings) GetMaxConcurrency() *NullableUint32

func (*DatabaseNullableSettings) GetMaxIOConcurrency added in v1.2.3

func (x *DatabaseNullableSettings) GetMaxIOConcurrency() *NullableUint32

func (*DatabaseNullableSettings) GetMaxKeyLen added in v1.2.3

func (x *DatabaseNullableSettings) GetMaxKeyLen() *NullableUint32

func (*DatabaseNullableSettings) GetMaxTxEntries added in v1.2.3

func (x *DatabaseNullableSettings) GetMaxTxEntries() *NullableUint32

func (*DatabaseNullableSettings) GetMaxValueLen added in v1.2.3

func (x *DatabaseNullableSettings) GetMaxValueLen() *NullableUint32

func (*DatabaseNullableSettings) GetReplicationSettings added in v1.2.3

func (x *DatabaseNullableSettings) GetReplicationSettings() *ReplicationNullableSettings

func (*DatabaseNullableSettings) GetTxLogCacheSize added in v1.2.3

func (x *DatabaseNullableSettings) GetTxLogCacheSize() *NullableUint32

func (*DatabaseNullableSettings) GetTxLogMaxOpenedFiles added in v1.2.3

func (x *DatabaseNullableSettings) GetTxLogMaxOpenedFiles() *NullableUint32

func (*DatabaseNullableSettings) GetVLogMaxOpenedFiles added in v1.2.3

func (x *DatabaseNullableSettings) GetVLogMaxOpenedFiles() *NullableUint32

func (*DatabaseNullableSettings) GetWriteTxHeaderVersion added in v1.2.3

func (x *DatabaseNullableSettings) GetWriteTxHeaderVersion() *NullableUint32

func (*DatabaseNullableSettings) ProtoMessage added in v1.2.3

func (*DatabaseNullableSettings) ProtoMessage()

func (*DatabaseNullableSettings) ProtoReflect added in v1.2.3

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

func (*DatabaseNullableSettings) Reset added in v1.2.3

func (x *DatabaseNullableSettings) Reset()

func (*DatabaseNullableSettings) String added in v1.2.3

func (x *DatabaseNullableSettings) 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 DatabaseSettingsRequest added in v1.2.3

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

func (*DatabaseSettingsRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseSettingsRequest.ProtoReflect.Descriptor instead.

func (*DatabaseSettingsRequest) ProtoMessage added in v1.2.3

func (*DatabaseSettingsRequest) ProtoMessage()

func (*DatabaseSettingsRequest) ProtoReflect added in v1.2.3

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

func (*DatabaseSettingsRequest) Reset added in v1.2.3

func (x *DatabaseSettingsRequest) Reset()

func (*DatabaseSettingsRequest) String added in v1.2.3

func (x *DatabaseSettingsRequest) String() string

type DatabaseSettingsResponse added in v1.2.3

type DatabaseSettingsResponse struct {
	Database string                    `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseSettingsResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseSettingsResponse.ProtoReflect.Descriptor instead.

func (*DatabaseSettingsResponse) GetDatabase added in v1.2.3

func (x *DatabaseSettingsResponse) GetDatabase() string

func (*DatabaseSettingsResponse) GetSettings added in v1.2.3

func (*DatabaseSettingsResponse) ProtoMessage added in v1.2.3

func (*DatabaseSettingsResponse) ProtoMessage()

func (*DatabaseSettingsResponse) ProtoReflect added in v1.2.3

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

func (*DatabaseSettingsResponse) Reset added in v1.2.3

func (x *DatabaseSettingsResponse) Reset()

func (*DatabaseSettingsResponse) String added in v1.2.3

func (x *DatabaseSettingsResponse) String() string

type DatabaseWithSettings added in v1.2.3

type DatabaseWithSettings struct {
	Name     string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	Loaded   bool                      `protobuf:"varint,3,opt,name=loaded,proto3" json:"loaded,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseWithSettings) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DatabaseWithSettings.ProtoReflect.Descriptor instead.

func (*DatabaseWithSettings) GetLoaded added in v1.2.3

func (x *DatabaseWithSettings) GetLoaded() bool

func (*DatabaseWithSettings) GetName added in v1.2.3

func (x *DatabaseWithSettings) GetName() string

func (*DatabaseWithSettings) GetSettings added in v1.2.3

func (*DatabaseWithSettings) ProtoMessage added in v1.2.3

func (*DatabaseWithSettings) ProtoMessage()

func (*DatabaseWithSettings) ProtoReflect added in v1.2.3

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

func (*DatabaseWithSettings) Reset added in v1.2.3

func (x *DatabaseWithSettings) Reset()

func (*DatabaseWithSettings) String added in v1.2.3

func (x *DatabaseWithSettings) 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 DeleteDatabaseRequest added in v1.2.3

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

func (*DeleteDatabaseRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DeleteDatabaseRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseRequest) GetDatabase added in v1.2.3

func (x *DeleteDatabaseRequest) GetDatabase() string

func (*DeleteDatabaseRequest) ProtoMessage added in v1.2.3

func (*DeleteDatabaseRequest) ProtoMessage()

func (*DeleteDatabaseRequest) ProtoReflect added in v1.2.3

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

func (*DeleteDatabaseRequest) Reset added in v1.2.3

func (x *DeleteDatabaseRequest) Reset()

func (*DeleteDatabaseRequest) String added in v1.2.3

func (x *DeleteDatabaseRequest) String() string

type DeleteDatabaseResponse added in v1.2.3

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

func (*DeleteDatabaseResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use DeleteDatabaseResponse.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseResponse) GetDatabase added in v1.2.3

func (x *DeleteDatabaseResponse) GetDatabase() string

func (*DeleteDatabaseResponse) ProtoMessage added in v1.2.3

func (*DeleteDatabaseResponse) ProtoMessage()

func (*DeleteDatabaseResponse) ProtoReflect added in v1.2.3

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

func (*DeleteDatabaseResponse) Reset added in v1.2.3

func (x *DeleteDatabaseResponse) Reset()

func (*DeleteDatabaseResponse) String added in v1.2.3

func (x *DeleteDatabaseResponse) String() string

type DeleteKeysRequest added in v1.2.0

type DeleteKeysRequest 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"`
	NoWait  bool     `protobuf:"varint,3,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeysRequest) Descriptor deprecated added in v1.2.0

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

Deprecated: Use DeleteKeysRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeysRequest) GetKeys added in v1.2.0

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

func (*DeleteKeysRequest) GetNoWait added in v1.2.0

func (x *DeleteKeysRequest) GetNoWait() bool

func (*DeleteKeysRequest) GetSinceTx added in v1.2.0

func (x *DeleteKeysRequest) GetSinceTx() uint64

func (*DeleteKeysRequest) ProtoMessage added in v1.2.0

func (*DeleteKeysRequest) ProtoMessage()

func (*DeleteKeysRequest) ProtoReflect added in v1.2.0

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

func (*DeleteKeysRequest) Reset added in v1.2.0

func (x *DeleteKeysRequest) Reset()

func (*DeleteKeysRequest) String added in v1.2.0

func (x *DeleteKeysRequest) String() string

type DualProof added in v0.9.0

type DualProof struct {
	SourceTxHeader     *TxHeader    `protobuf:"bytes,1,opt,name=sourceTxHeader,proto3" json:"sourceTxHeader,omitempty"`
	TargetTxHeader     *TxHeader    `protobuf:"bytes,2,opt,name=targetTxHeader,proto3" json:"targetTxHeader,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 DualProofToProto added in v1.2.0

func DualProofToProto(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) GetSourceTxHeader added in v1.2.0

func (x *DualProof) GetSourceTxHeader() *TxHeader

func (*DualProof) GetTargetBlTxAlh added in v0.9.0

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

func (*DualProof) GetTargetTxHeader added in v1.2.0

func (x *DualProof) GetTargetTxHeader() *TxHeader

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 EntriesSpec added in v1.2.3

type EntriesSpec struct {
	KvEntriesSpec  *EntryTypeSpec `protobuf:"bytes,1,opt,name=kvEntriesSpec,proto3" json:"kvEntriesSpec,omitempty"`
	ZEntriesSpec   *EntryTypeSpec `protobuf:"bytes,2,opt,name=zEntriesSpec,proto3" json:"zEntriesSpec,omitempty"`
	SqlEntriesSpec *EntryTypeSpec `protobuf:"bytes,3,opt,name=sqlEntriesSpec,proto3" json:"sqlEntriesSpec,omitempty"`
	// contains filtered or unexported fields
}

func (*EntriesSpec) Descriptor deprecated added in v1.2.3

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

Deprecated: Use EntriesSpec.ProtoReflect.Descriptor instead.

func (*EntriesSpec) GetKvEntriesSpec added in v1.2.3

func (x *EntriesSpec) GetKvEntriesSpec() *EntryTypeSpec

func (*EntriesSpec) GetSqlEntriesSpec added in v1.2.3

func (x *EntriesSpec) GetSqlEntriesSpec() *EntryTypeSpec

func (*EntriesSpec) GetZEntriesSpec added in v1.2.3

func (x *EntriesSpec) GetZEntriesSpec() *EntryTypeSpec

func (*EntriesSpec) ProtoMessage added in v1.2.3

func (*EntriesSpec) ProtoMessage()

func (*EntriesSpec) ProtoReflect added in v1.2.3

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

func (*EntriesSpec) Reset added in v1.2.3

func (x *EntriesSpec) Reset()

func (*EntriesSpec) String added in v1.2.3

func (x *EntriesSpec) 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"`
	Metadata     *KVMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Expired      bool        `protobuf:"varint,6,opt,name=expired,proto3" json:"expired,omitempty"`
	Revision     uint64      `protobuf:"varint,7,opt,name=revision,proto3" json:"revision,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) GetExpired added in v1.2.0

func (x *Entry) GetExpired() bool

func (*Entry) GetKey added in v0.9.0

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

func (*Entry) GetMetadata added in v1.2.0

func (x *Entry) GetMetadata() *KVMetadata

func (*Entry) GetReferencedBy added in v0.9.0

func (x *Entry) GetReferencedBy() *Reference

func (*Entry) GetRevision added in v1.3.0

func (x *Entry) GetRevision() uint64

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 EntryTypeAction added in v1.2.3

type EntryTypeAction int32
const (
	EntryTypeAction_EXCLUDE     EntryTypeAction = 0
	EntryTypeAction_ONLY_DIGEST EntryTypeAction = 1
	EntryTypeAction_RAW_VALUE   EntryTypeAction = 2
	EntryTypeAction_RESOLVE     EntryTypeAction = 3
)

func (EntryTypeAction) Descriptor added in v1.2.3

func (EntryTypeAction) Enum added in v1.2.3

func (x EntryTypeAction) Enum() *EntryTypeAction

func (EntryTypeAction) EnumDescriptor deprecated added in v1.2.3

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

Deprecated: Use EntryTypeAction.Descriptor instead.

func (EntryTypeAction) Number added in v1.2.3

func (EntryTypeAction) String added in v1.2.3

func (x EntryTypeAction) String() string

func (EntryTypeAction) Type added in v1.2.3

type EntryTypeSpec added in v1.2.3

type EntryTypeSpec struct {
	Action EntryTypeAction `protobuf:"varint,1,opt,name=action,proto3,enum=immudb.schema.EntryTypeAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*EntryTypeSpec) Descriptor deprecated added in v1.2.3

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

Deprecated: Use EntryTypeSpec.ProtoReflect.Descriptor instead.

func (*EntryTypeSpec) GetAction added in v1.2.3

func (x *EntryTypeSpec) GetAction() EntryTypeAction

func (*EntryTypeSpec) ProtoMessage added in v1.2.3

func (*EntryTypeSpec) ProtoMessage()

func (*EntryTypeSpec) ProtoReflect added in v1.2.3

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

func (*EntryTypeSpec) Reset added in v1.2.3

func (x *EntryTypeSpec) Reset()

func (*EntryTypeSpec) String added in v1.2.3

func (x *EntryTypeSpec) 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"`
	Preconditions []*Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions,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) GetPreconditions added in v1.2.3

func (x *ExecAllRequest) GetPreconditions() []*Precondition

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 Expiration added in v1.2.0

type Expiration struct {
	ExpiresAt int64 `protobuf:"varint,1,opt,name=expiresAt,proto3" json:"expiresAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Expiration) Descriptor deprecated added in v1.2.0

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

Deprecated: Use Expiration.ProtoReflect.Descriptor instead.

func (*Expiration) GetExpiresAt added in v1.2.0

func (x *Expiration) GetExpiresAt() int64

func (*Expiration) ProtoMessage added in v1.2.0

func (*Expiration) ProtoMessage()

func (*Expiration) ProtoReflect added in v1.2.0

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

func (*Expiration) Reset added in v1.2.0

func (x *Expiration) Reset()

func (*Expiration) String added in v1.2.0

func (x *Expiration) String() string

type ExportTxRequest added in v1.2.3

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

func (*ExportTxRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use ExportTxRequest.ProtoReflect.Descriptor instead.

func (*ExportTxRequest) GetTx added in v1.2.3

func (x *ExportTxRequest) GetTx() uint64

func (*ExportTxRequest) ProtoMessage added in v1.2.3

func (*ExportTxRequest) ProtoMessage()

func (*ExportTxRequest) ProtoReflect added in v1.2.3

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

func (*ExportTxRequest) Reset added in v1.2.3

func (x *ExportTxRequest) Reset()

func (*ExportTxRequest) String added in v1.2.3

func (x *ExportTxRequest) String() string

type FlushIndexRequest added in v1.2.3

type FlushIndexRequest struct {
	CleanupPercentage float32 `protobuf:"fixed32,1,opt,name=cleanupPercentage,proto3" json:"cleanupPercentage,omitempty"`
	Synced            bool    `protobuf:"varint,2,opt,name=synced,proto3" json:"synced,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushIndexRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use FlushIndexRequest.ProtoReflect.Descriptor instead.

func (*FlushIndexRequest) GetCleanupPercentage added in v1.2.3

func (x *FlushIndexRequest) GetCleanupPercentage() float32

func (*FlushIndexRequest) GetSynced added in v1.2.3

func (x *FlushIndexRequest) GetSynced() bool

func (*FlushIndexRequest) ProtoMessage added in v1.2.3

func (*FlushIndexRequest) ProtoMessage()

func (*FlushIndexRequest) ProtoReflect added in v1.2.3

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

func (*FlushIndexRequest) Reset added in v1.2.3

func (x *FlushIndexRequest) Reset()

func (*FlushIndexRequest) String added in v1.2.3

func (x *FlushIndexRequest) String() string

type FlushIndexResponse added in v1.2.3

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

func (*FlushIndexResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use FlushIndexResponse.ProtoReflect.Descriptor instead.

func (*FlushIndexResponse) GetDatabase added in v1.2.3

func (x *FlushIndexResponse) GetDatabase() string

func (*FlushIndexResponse) ProtoMessage added in v1.2.3

func (*FlushIndexResponse) ProtoMessage()

func (*FlushIndexResponse) ProtoReflect added in v1.2.3

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

func (*FlushIndexResponse) Reset added in v1.2.3

func (x *FlushIndexResponse) Reset()

func (*FlushIndexResponse) String added in v1.2.3

func (x *FlushIndexResponse) String() string

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)
	ChangePermission(ctx context.Context, in *ChangePermissionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetActiveUser(ctx context.Context, in *SetActiveUserRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deprecated: Do not use.
	UpdateAuthConfig(ctx context.Context, in *AuthConfig, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deprecated: Do not use.
	UpdateMTLSConfig(ctx context.Context, in *MTLSConfig, opts ...grpc.CallOption) (*empty.Empty, error)
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	KeepAlive(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	NewTx(ctx context.Context, in *NewTxRequest, opts ...grpc.CallOption) (*NewTxResponse, error)
	Commit(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CommittedSQLTx, error)
	Rollback(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	TxSQLExec(ctx context.Context, in *SQLExecRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	TxSQLQuery(ctx context.Context, in *SQLQueryRequest, opts ...grpc.CallOption) (*SQLQueryResult, error)
	// Deprecated: Do not use.
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	// Deprecated: Do not use.
	Logout(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*TxHeader, 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)
	Delete(ctx context.Context, in *DeleteKeysRequest, opts ...grpc.CallOption) (*TxHeader, error)
	GetAll(ctx context.Context, in *KeyListRequest, opts ...grpc.CallOption) (*Entries, error)
	ExecAll(ctx context.Context, in *ExecAllRequest, opts ...grpc.CallOption) (*TxHeader, 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)
	DatabaseHealth(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DatabaseHealthResponse, error)
	CurrentState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ImmutableState, error)
	SetReference(ctx context.Context, in *ReferenceRequest, opts ...grpc.CallOption) (*TxHeader, error)
	VerifiableSetReference(ctx context.Context, in *VerifiableReferenceRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	ZAdd(ctx context.Context, in *ZAddRequest, opts ...grpc.CallOption) (*TxHeader, error)
	VerifiableZAdd(ctx context.Context, in *VerifiableZAddRequest, opts ...grpc.CallOption) (*VerifiableTx, error)
	ZScan(ctx context.Context, in *ZScanRequest, opts ...grpc.CallOption) (*ZEntries, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabase(ctx context.Context, in *Database, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabaseWith(ctx context.Context, in *DatabaseSettings, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateDatabaseV2(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	LoadDatabase(ctx context.Context, in *LoadDatabaseRequest, opts ...grpc.CallOption) (*LoadDatabaseResponse, error)
	UnloadDatabase(ctx context.Context, in *UnloadDatabaseRequest, opts ...grpc.CallOption) (*UnloadDatabaseResponse, error)
	DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*DeleteDatabaseResponse, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use DatabaseListV2
	DatabaseList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DatabaseListResponse, error)
	DatabaseListV2(ctx context.Context, in *DatabaseListRequestV2, opts ...grpc.CallOption) (*DatabaseListResponseV2, error)
	UseDatabase(ctx context.Context, in *Database, opts ...grpc.CallOption) (*UseDatabaseReply, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use UpdateDatabaseV2
	UpdateDatabase(ctx context.Context, in *DatabaseSettings, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateDatabaseV2(ctx context.Context, in *UpdateDatabaseRequest, opts ...grpc.CallOption) (*UpdateDatabaseResponse, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use GetDatabaseSettingsV2
	GetDatabaseSettings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DatabaseSettings, error)
	GetDatabaseSettingsV2(ctx context.Context, in *DatabaseSettingsRequest, opts ...grpc.CallOption) (*DatabaseSettingsResponse, error)
	FlushIndex(ctx context.Context, in *FlushIndexRequest, opts ...grpc.CallOption) (*FlushIndexResponse, error)
	CompactIndex(ctx context.Context, in *empty.Empty, 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 *ExportTxRequest, opts ...grpc.CallOption) (ImmuService_ExportTxClient, error)
	ReplicateTx(ctx context.Context, opts ...grpc.CallOption) (ImmuService_ReplicateTxClient, 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.

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)
	ChangePermission(context.Context, *ChangePermissionRequest) (*empty.Empty, error)
	SetActiveUser(context.Context, *SetActiveUserRequest) (*empty.Empty, error)
	// Deprecated: Do not use.
	UpdateAuthConfig(context.Context, *AuthConfig) (*empty.Empty, error)
	// Deprecated: Do not use.
	UpdateMTLSConfig(context.Context, *MTLSConfig) (*empty.Empty, error)
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *empty.Empty) (*empty.Empty, error)
	KeepAlive(context.Context, *empty.Empty) (*empty.Empty, error)
	NewTx(context.Context, *NewTxRequest) (*NewTxResponse, error)
	Commit(context.Context, *empty.Empty) (*CommittedSQLTx, error)
	Rollback(context.Context, *empty.Empty) (*empty.Empty, error)
	TxSQLExec(context.Context, *SQLExecRequest) (*empty.Empty, error)
	TxSQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
	// Deprecated: Do not use.
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	// Deprecated: Do not use.
	Logout(context.Context, *empty.Empty) (*empty.Empty, error)
	Set(context.Context, *SetRequest) (*TxHeader, error)
	VerifiableSet(context.Context, *VerifiableSetRequest) (*VerifiableTx, error)
	Get(context.Context, *KeyRequest) (*Entry, error)
	VerifiableGet(context.Context, *VerifiableGetRequest) (*VerifiableEntry, error)
	Delete(context.Context, *DeleteKeysRequest) (*TxHeader, error)
	GetAll(context.Context, *KeyListRequest) (*Entries, error)
	ExecAll(context.Context, *ExecAllRequest) (*TxHeader, 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)
	DatabaseHealth(context.Context, *empty.Empty) (*DatabaseHealthResponse, error)
	CurrentState(context.Context, *empty.Empty) (*ImmutableState, error)
	SetReference(context.Context, *ReferenceRequest) (*TxHeader, error)
	VerifiableSetReference(context.Context, *VerifiableReferenceRequest) (*VerifiableTx, error)
	ZAdd(context.Context, *ZAddRequest) (*TxHeader, error)
	VerifiableZAdd(context.Context, *VerifiableZAddRequest) (*VerifiableTx, error)
	ZScan(context.Context, *ZScanRequest) (*ZEntries, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabase(context.Context, *Database) (*empty.Empty, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabaseWith(context.Context, *DatabaseSettings) (*empty.Empty, error)
	CreateDatabaseV2(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	LoadDatabase(context.Context, *LoadDatabaseRequest) (*LoadDatabaseResponse, error)
	UnloadDatabase(context.Context, *UnloadDatabaseRequest) (*UnloadDatabaseResponse, error)
	DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use DatabaseListV2
	DatabaseList(context.Context, *empty.Empty) (*DatabaseListResponse, error)
	DatabaseListV2(context.Context, *DatabaseListRequestV2) (*DatabaseListResponseV2, error)
	UseDatabase(context.Context, *Database) (*UseDatabaseReply, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use UpdateDatabaseV2
	UpdateDatabase(context.Context, *DatabaseSettings) (*empty.Empty, error)
	UpdateDatabaseV2(context.Context, *UpdateDatabaseRequest) (*UpdateDatabaseResponse, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use GetDatabaseSettingsV2
	GetDatabaseSettings(context.Context, *empty.Empty) (*DatabaseSettings, error)
	GetDatabaseSettingsV2(context.Context, *DatabaseSettingsRequest) (*DatabaseSettingsResponse, error)
	FlushIndex(context.Context, *FlushIndexRequest) (*FlushIndexResponse, error)
	CompactIndex(context.Context, *empty.Empty) (*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(*ExportTxRequest, ImmuService_ExportTxServer) error
	ReplicateTx(ImmuService_ReplicateTxServer) 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() (*TxHeader, error)
	grpc.ClientStream
}

type ImmuService_ReplicateTxServer added in v1.0.5

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

type ImmuService_StreamExecAllClient added in v0.9.2

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

type ImmuService_StreamExecAllServer added in v0.9.2

type ImmuService_StreamExecAllServer interface {
	SendAndClose(*TxHeader) 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() (*TxHeader, error)
	grpc.ClientStream
}

type ImmuService_StreamSetServer added in v0.9.2

type ImmuService_StreamSetServer interface {
	SendAndClose(*TxHeader) 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 InclusionProofToProto added in v1.2.0

func InclusionProofToProto(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 IndexNullableSettings added in v1.2.3

type IndexNullableSettings struct {
	FlushThreshold           *NullableUint32 `protobuf:"bytes,1,opt,name=flushThreshold,proto3" json:"flushThreshold,omitempty"`
	SyncThreshold            *NullableUint32 `protobuf:"bytes,2,opt,name=syncThreshold,proto3" json:"syncThreshold,omitempty"`
	CacheSize                *NullableUint32 `protobuf:"bytes,3,opt,name=cacheSize,proto3" json:"cacheSize,omitempty"`
	MaxNodeSize              *NullableUint32 `protobuf:"bytes,4,opt,name=maxNodeSize,proto3" json:"maxNodeSize,omitempty"`
	MaxActiveSnapshots       *NullableUint32 `protobuf:"bytes,5,opt,name=maxActiveSnapshots,proto3" json:"maxActiveSnapshots,omitempty"`
	RenewSnapRootAfter       *NullableUint64 `protobuf:"bytes,6,opt,name=renewSnapRootAfter,proto3" json:"renewSnapRootAfter,omitempty"`
	CompactionThld           *NullableUint32 `protobuf:"bytes,7,opt,name=compactionThld,proto3" json:"compactionThld,omitempty"`
	DelayDuringCompaction    *NullableUint32 `protobuf:"bytes,8,opt,name=delayDuringCompaction,proto3" json:"delayDuringCompaction,omitempty"`
	NodesLogMaxOpenedFiles   *NullableUint32 `protobuf:"bytes,9,opt,name=nodesLogMaxOpenedFiles,proto3" json:"nodesLogMaxOpenedFiles,omitempty"`
	HistoryLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,10,opt,name=historyLogMaxOpenedFiles,proto3" json:"historyLogMaxOpenedFiles,omitempty"`
	CommitLogMaxOpenedFiles  *NullableUint32 `protobuf:"bytes,11,opt,name=commitLogMaxOpenedFiles,proto3" json:"commitLogMaxOpenedFiles,omitempty"`
	FlushBufferSize          *NullableUint32 `protobuf:"bytes,12,opt,name=flushBufferSize,proto3" json:"flushBufferSize,omitempty"`
	CleanupPercentage        *NullableFloat  `protobuf:"bytes,13,opt,name=cleanupPercentage,proto3" json:"cleanupPercentage,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexNullableSettings) Descriptor deprecated added in v1.2.3

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

Deprecated: Use IndexNullableSettings.ProtoReflect.Descriptor instead.

func (*IndexNullableSettings) GetCacheSize added in v1.2.3

func (x *IndexNullableSettings) GetCacheSize() *NullableUint32

func (*IndexNullableSettings) GetCleanupPercentage added in v1.2.3

func (x *IndexNullableSettings) GetCleanupPercentage() *NullableFloat

func (*IndexNullableSettings) GetCommitLogMaxOpenedFiles added in v1.2.3

func (x *IndexNullableSettings) GetCommitLogMaxOpenedFiles() *NullableUint32

func (*IndexNullableSettings) GetCompactionThld added in v1.2.3

func (x *IndexNullableSettings) GetCompactionThld() *NullableUint32

func (*IndexNullableSettings) GetDelayDuringCompaction added in v1.2.3

func (x *IndexNullableSettings) GetDelayDuringCompaction() *NullableUint32

func (*IndexNullableSettings) GetFlushBufferSize added in v1.2.3

func (x *IndexNullableSettings) GetFlushBufferSize() *NullableUint32

func (*IndexNullableSettings) GetFlushThreshold added in v1.2.3

func (x *IndexNullableSettings) GetFlushThreshold() *NullableUint32

func (*IndexNullableSettings) GetHistoryLogMaxOpenedFiles added in v1.2.3

func (x *IndexNullableSettings) GetHistoryLogMaxOpenedFiles() *NullableUint32

func (*IndexNullableSettings) GetMaxActiveSnapshots added in v1.2.3

func (x *IndexNullableSettings) GetMaxActiveSnapshots() *NullableUint32

func (*IndexNullableSettings) GetMaxNodeSize added in v1.2.3

func (x *IndexNullableSettings) GetMaxNodeSize() *NullableUint32

func (*IndexNullableSettings) GetNodesLogMaxOpenedFiles added in v1.2.3

func (x *IndexNullableSettings) GetNodesLogMaxOpenedFiles() *NullableUint32

func (*IndexNullableSettings) GetRenewSnapRootAfter added in v1.2.3

func (x *IndexNullableSettings) GetRenewSnapRootAfter() *NullableUint64

func (*IndexNullableSettings) GetSyncThreshold added in v1.2.3

func (x *IndexNullableSettings) GetSyncThreshold() *NullableUint32

func (*IndexNullableSettings) ProtoMessage added in v1.2.3

func (*IndexNullableSettings) ProtoMessage()

func (*IndexNullableSettings) ProtoReflect added in v1.2.3

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

func (*IndexNullableSettings) Reset added in v1.2.3

func (x *IndexNullableSettings) Reset()

func (*IndexNullableSettings) String added in v1.2.3

func (x *IndexNullableSettings) String() string

type KVMetadata added in v1.2.0

type KVMetadata struct {
	Deleted      bool        `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	Expiration   *Expiration `protobuf:"bytes,2,opt,name=expiration,proto3" json:"expiration,omitempty"`
	NonIndexable bool        `protobuf:"varint,3,opt,name=nonIndexable,proto3" json:"nonIndexable,omitempty"`
	// contains filtered or unexported fields
}

func KVMetadataToProto added in v1.2.0

func KVMetadataToProto(md *store.KVMetadata) *KVMetadata

func (*KVMetadata) Descriptor deprecated added in v1.2.0

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

Deprecated: Use KVMetadata.ProtoReflect.Descriptor instead.

func (*KVMetadata) GetDeleted added in v1.2.0

func (x *KVMetadata) GetDeleted() bool

func (*KVMetadata) GetExpiration added in v1.2.0

func (x *KVMetadata) GetExpiration() *Expiration

func (*KVMetadata) GetNonIndexable added in v1.2.3

func (x *KVMetadata) GetNonIndexable() bool

func (*KVMetadata) ProtoMessage added in v1.2.0

func (*KVMetadata) ProtoMessage()

func (*KVMetadata) ProtoReflect added in v1.2.0

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

func (*KVMetadata) Reset added in v1.2.0

func (x *KVMetadata) Reset()

func (*KVMetadata) String added in v1.2.0

func (x *KVMetadata) 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"` // if > 0, query for the value exactly at given transaction
	// if 0 (and nowait=false), wait for the index to be up=to-date
	SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// if set to true - do not wait for any indexing update considering only the currently indexed state
	NoWait bool `protobuf:"varint,4,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// if > 0, get the nth version of the value, 1 being the first version, 2 being the second and so on
	// if < 0, get the historical nth value of the key, -1 being the previous version, -2 being the one before and so on
	AtRevision int64 `protobuf:"varint,5,opt,name=atRevision,proto3" json:"atRevision,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) GetAtRevision added in v1.3.0

func (x *KeyRequest) GetAtRevision() int64

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) GetNoWait added in v1.2.3

func (x *KeyRequest) GetNoWait() bool

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"`
	Metadata *KVMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,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) GetMetadata added in v1.2.0

func (x *KeyValue) GetMetadata() *KVMetadata

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 LinearProofToProto added in v1.2.0

func LinearProofToProto(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 LoadDatabaseRequest added in v1.2.3

type LoadDatabaseRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // may add createIfNotExist
	// contains filtered or unexported fields
}

func (*LoadDatabaseRequest) Descriptor deprecated added in v1.2.3

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

Deprecated: Use LoadDatabaseRequest.ProtoReflect.Descriptor instead.

func (*LoadDatabaseRequest) GetDatabase added in v1.2.3

func (x *LoadDatabaseRequest) GetDatabase() string

func (*LoadDatabaseRequest) ProtoMessage added in v1.2.3

func (*LoadDatabaseRequest) ProtoMessage()

func (*LoadDatabaseRequest) ProtoReflect added in v1.2.3

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

func (*LoadDatabaseRequest) Reset added in v1.2.3

func (x *LoadDatabaseRequest) Reset()

func (*LoadDatabaseRequest) String added in v1.2.3

func (x *LoadDatabaseRequest) String() string

type LoadDatabaseResponse added in v1.2.3

type LoadDatabaseResponse struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // may add setttings
	// contains filtered or unexported fields
}

func (*LoadDatabaseResponse) Descriptor deprecated added in v1.2.3

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

Deprecated: Use LoadDatabaseResponse.ProtoReflect.Descriptor instead.

func (*LoadDatabaseResponse) GetDatabase added in v1.2.3

func (x *LoadDatabaseResponse) GetDatabase() string

func (*LoadDatabaseResponse) ProtoMessage added in v1.2.3

func (*LoadDatabaseResponse) ProtoMessage()

func (*LoadDatabaseResponse) ProtoReflect added in v1.2.3

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

func (*LoadDatabaseResponse) Reset added in v1.2.3

func (x *LoadDatabaseResponse) Reset()

func (*LoadDatabaseResponse) String added in v1.2.3

func (x *LoadDatabaseResponse) 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