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 ¶
- Variables
- func DigestFromProto(slicedDigest []byte) [sha256.Size]byte
- func DigestsFromProto(slicedTerms [][]byte) [][sha256.Size]byte
- func DigestsToProto(terms [][sha256.Size]byte) [][]byte
- func DualProofFromProto(dproof *DualProof) *store.DualProof
- func InclusionProofFromProto(iproof *InclusionProof) *htree.InclusionProof
- func KVMetadataFromProto(md *KVMetadata) *store.KVMetadata
- func LinearProofFromProto(lproof *LinearProof) *store.LinearProof
- func Pattern_ImmuService_History_0() runtime.Pattern
- func Pattern_ImmuService_Set_0() runtime.Pattern
- func Pattern_ImmuService_UseDatabase_0() runtime.Pattern
- func Pattern_ImmuService_VerifiableGet_0() runtime.Pattern
- func Pattern_ImmuService_VerifiableSetReference_0() runtime.Pattern
- func Pattern_ImmuService_VerifiableSet_0() runtime.Pattern
- func Pattern_ImmuService_VerifiableTxById_0() runtime.Pattern
- func Pattern_ImmuService_VerifiableZAdd_0() runtime.Pattern
- func RawValue(v *SQLValue) interface{}
- func RegisterImmuServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterImmuServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ImmuServiceClient) error
- func RegisterImmuServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterImmuServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ImmuServiceServer) error
- func RegisterImmuServiceServer(s *grpc.Server, srv ImmuServiceServer)
- func RenderValue(op isSQLValue_Value) string
- func RenderValueAsByte(op isSQLValue_Value) []byte
- func TxFromProto(stx *Tx) *store.Tx
- func TxHeaderFromProto(hdr *TxHeader) *store.TxHeader
- func TxMetadataFromProto(md *TxMetadata) *store.TxMetadata
- type AuthConfig
- type ChangePasswordRequest
- func (*ChangePasswordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangePasswordRequest) GetNewPassword() []byte
- func (x *ChangePasswordRequest) GetOldPassword() []byte
- func (x *ChangePasswordRequest) GetUser() []byte
- func (*ChangePasswordRequest) ProtoMessage()
- func (x *ChangePasswordRequest) ProtoReflect() protoreflect.Message
- func (x *ChangePasswordRequest) Reset()
- func (x *ChangePasswordRequest) String() string
- type ChangePermissionRequest
- func (*ChangePermissionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangePermissionRequest) GetAction() PermissionAction
- func (x *ChangePermissionRequest) GetDatabase() string
- func (x *ChangePermissionRequest) GetPermission() uint32
- func (x *ChangePermissionRequest) GetUsername() string
- func (*ChangePermissionRequest) ProtoMessage()
- func (x *ChangePermissionRequest) ProtoReflect() protoreflect.Message
- func (x *ChangePermissionRequest) Reset()
- func (x *ChangePermissionRequest) String() string
- type Chunk
- type Column
- type CommittedSQLTx
- func (*CommittedSQLTx) Descriptor() ([]byte, []int)deprecated
- func (x *CommittedSQLTx) GetFirstInsertedPKs() map[string]*SQLValue
- func (x *CommittedSQLTx) GetHeader() *TxHeader
- func (x *CommittedSQLTx) GetLastInsertedPKs() map[string]*SQLValue
- func (x *CommittedSQLTx) GetUpdatedRows() uint32
- func (*CommittedSQLTx) ProtoMessage()
- func (x *CommittedSQLTx) ProtoReflect() protoreflect.Message
- func (x *CommittedSQLTx) Reset()
- func (x *CommittedSQLTx) String() string
- type CreateDatabaseRequest
- func (*CreateDatabaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDatabaseRequest) GetName() string
- func (x *CreateDatabaseRequest) GetSettings() *DatabaseNullableSettings
- func (*CreateDatabaseRequest) ProtoMessage()
- func (x *CreateDatabaseRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDatabaseRequest) Reset()
- func (x *CreateDatabaseRequest) String() string
- type CreateDatabaseResponse
- func (*CreateDatabaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDatabaseResponse) GetName() string
- func (x *CreateDatabaseResponse) GetSettings() *DatabaseNullableSettings
- func (*CreateDatabaseResponse) ProtoMessage()
- func (x *CreateDatabaseResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDatabaseResponse) Reset()
- func (x *CreateDatabaseResponse) String() string
- type CreateUserRequest
- func (*CreateUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateUserRequest) GetDatabase() string
- func (x *CreateUserRequest) GetPassword() []byte
- func (x *CreateUserRequest) GetPermission() uint32
- func (x *CreateUserRequest) GetUser() []byte
- func (*CreateUserRequest) ProtoMessage()
- func (x *CreateUserRequest) ProtoReflect() protoreflect.Message
- func (x *CreateUserRequest) Reset()
- func (x *CreateUserRequest) String() string
- type Database
- type DatabaseHealthResponse
- func (*DatabaseHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseHealthResponse) GetLastRequestCompletedAt() int64
- func (x *DatabaseHealthResponse) GetPendingRequests() uint32
- func (*DatabaseHealthResponse) ProtoMessage()
- func (x *DatabaseHealthResponse) ProtoReflect() protoreflect.Message
- func (x *DatabaseHealthResponse) Reset()
- func (x *DatabaseHealthResponse) String() string
- type DatabaseListRequestV2
- type DatabaseListResponse
- func (*DatabaseListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseListResponse) GetDatabases() []*Database
- func (*DatabaseListResponse) ProtoMessage()
- func (x *DatabaseListResponse) ProtoReflect() protoreflect.Message
- func (x *DatabaseListResponse) Reset()
- func (x *DatabaseListResponse) String() string
- type DatabaseListResponseV2
- func (*DatabaseListResponseV2) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseListResponseV2) GetDatabases() []*DatabaseWithSettings
- func (*DatabaseListResponseV2) ProtoMessage()
- func (x *DatabaseListResponseV2) ProtoReflect() protoreflect.Message
- func (x *DatabaseListResponseV2) Reset()
- func (x *DatabaseListResponseV2) String() string
- type DatabaseNullableSettings
- func (*DatabaseNullableSettings) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseNullableSettings) GetAutoload() *NullableBool
- func (x *DatabaseNullableSettings) GetCommitLogMaxOpenedFiles() *NullableUint32
- func (x *DatabaseNullableSettings) GetExcludeCommitTime() *NullableBool
- func (x *DatabaseNullableSettings) GetFileSize() *NullableUint32
- func (x *DatabaseNullableSettings) GetIndexSettings() *IndexNullableSettings
- func (x *DatabaseNullableSettings) GetMaxConcurrency() *NullableUint32
- func (x *DatabaseNullableSettings) GetMaxIOConcurrency() *NullableUint32
- func (x *DatabaseNullableSettings) GetMaxKeyLen() *NullableUint32
- func (x *DatabaseNullableSettings) GetMaxTxEntries() *NullableUint32
- func (x *DatabaseNullableSettings) GetMaxValueLen() *NullableUint32
- func (x *DatabaseNullableSettings) GetReplicationSettings() *ReplicationNullableSettings
- func (x *DatabaseNullableSettings) GetTxLogCacheSize() *NullableUint32
- func (x *DatabaseNullableSettings) GetTxLogMaxOpenedFiles() *NullableUint32
- func (x *DatabaseNullableSettings) GetVLogMaxOpenedFiles() *NullableUint32
- func (x *DatabaseNullableSettings) GetWriteTxHeaderVersion() *NullableUint32
- func (*DatabaseNullableSettings) ProtoMessage()
- func (x *DatabaseNullableSettings) ProtoReflect() protoreflect.Message
- func (x *DatabaseNullableSettings) Reset()
- func (x *DatabaseNullableSettings) String() string
- type DatabaseSettings
- func (*DatabaseSettings) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseSettings) GetDatabaseName() string
- func (x *DatabaseSettings) GetExcludeCommitTime() bool
- func (x *DatabaseSettings) GetFileSize() uint32
- func (x *DatabaseSettings) GetFollowerPassword() string
- func (x *DatabaseSettings) GetFollowerUsername() string
- func (x *DatabaseSettings) GetMasterAddress() string
- func (x *DatabaseSettings) GetMasterDatabase() string
- func (x *DatabaseSettings) GetMasterPort() uint32
- func (x *DatabaseSettings) GetMaxKeyLen() uint32
- func (x *DatabaseSettings) GetMaxTxEntries() uint32
- func (x *DatabaseSettings) GetMaxValueLen() uint32
- func (x *DatabaseSettings) GetReplica() bool
- func (*DatabaseSettings) ProtoMessage()
- func (x *DatabaseSettings) ProtoReflect() protoreflect.Message
- func (x *DatabaseSettings) Reset()
- func (x *DatabaseSettings) String() string
- type DatabaseSettingsRequest
- type DatabaseSettingsResponse
- func (*DatabaseSettingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseSettingsResponse) GetDatabase() string
- func (x *DatabaseSettingsResponse) GetSettings() *DatabaseNullableSettings
- func (*DatabaseSettingsResponse) ProtoMessage()
- func (x *DatabaseSettingsResponse) ProtoReflect() protoreflect.Message
- func (x *DatabaseSettingsResponse) Reset()
- func (x *DatabaseSettingsResponse) String() string
- type DatabaseWithSettings
- func (*DatabaseWithSettings) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseWithSettings) GetLoaded() bool
- func (x *DatabaseWithSettings) GetName() string
- func (x *DatabaseWithSettings) GetSettings() *DatabaseNullableSettings
- func (*DatabaseWithSettings) ProtoMessage()
- func (x *DatabaseWithSettings) ProtoReflect() protoreflect.Message
- func (x *DatabaseWithSettings) Reset()
- func (x *DatabaseWithSettings) String() string
- type DebugInfo
- type DeleteDatabaseRequest
- func (*DeleteDatabaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDatabaseRequest) GetDatabase() string
- func (*DeleteDatabaseRequest) ProtoMessage()
- func (x *DeleteDatabaseRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDatabaseRequest) Reset()
- func (x *DeleteDatabaseRequest) String() string
- type DeleteDatabaseResponse
- func (*DeleteDatabaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDatabaseResponse) GetDatabase() string
- func (*DeleteDatabaseResponse) ProtoMessage()
- func (x *DeleteDatabaseResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteDatabaseResponse) Reset()
- func (x *DeleteDatabaseResponse) String() string
- type DeleteKeysRequest
- func (*DeleteKeysRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteKeysRequest) GetKeys() [][]byte
- func (x *DeleteKeysRequest) GetNoWait() bool
- func (x *DeleteKeysRequest) GetSinceTx() uint64
- func (*DeleteKeysRequest) ProtoMessage()
- func (x *DeleteKeysRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteKeysRequest) Reset()
- func (x *DeleteKeysRequest) String() string
- type DualProof
- func (*DualProof) Descriptor() ([]byte, []int)deprecated
- func (x *DualProof) GetConsistencyProof() [][]byte
- func (x *DualProof) GetInclusionProof() [][]byte
- func (x *DualProof) GetLastInclusionProof() [][]byte
- func (x *DualProof) GetLinearProof() *LinearProof
- func (x *DualProof) GetSourceTxHeader() *TxHeader
- func (x *DualProof) GetTargetBlTxAlh() []byte
- func (x *DualProof) GetTargetTxHeader() *TxHeader
- func (*DualProof) ProtoMessage()
- func (x *DualProof) ProtoReflect() protoreflect.Message
- func (x *DualProof) Reset()
- func (x *DualProof) String() string
- type Entries
- type EntriesSpec
- func (*EntriesSpec) Descriptor() ([]byte, []int)deprecated
- func (x *EntriesSpec) GetKvEntriesSpec() *EntryTypeSpec
- func (x *EntriesSpec) GetSqlEntriesSpec() *EntryTypeSpec
- func (x *EntriesSpec) GetZEntriesSpec() *EntryTypeSpec
- func (*EntriesSpec) ProtoMessage()
- func (x *EntriesSpec) ProtoReflect() protoreflect.Message
- func (x *EntriesSpec) Reset()
- func (x *EntriesSpec) String() string
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)deprecated
- func (x *Entry) GetExpired() bool
- func (x *Entry) GetKey() []byte
- func (x *Entry) GetMetadata() *KVMetadata
- func (x *Entry) GetReferencedBy() *Reference
- func (x *Entry) GetTx() uint64
- func (x *Entry) GetValue() []byte
- func (*Entry) ProtoMessage()
- func (x *Entry) ProtoReflect() protoreflect.Message
- func (x *Entry) Reset()
- func (x *Entry) String() string
- type EntryCount
- type EntryTypeAction
- func (EntryTypeAction) Descriptor() protoreflect.EnumDescriptor
- func (x EntryTypeAction) Enum() *EntryTypeAction
- func (EntryTypeAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x EntryTypeAction) Number() protoreflect.EnumNumber
- func (x EntryTypeAction) String() string
- func (EntryTypeAction) Type() protoreflect.EnumType
- type EntryTypeSpec
- type ErrorInfo
- type ExecAllRequest
- func (*ExecAllRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecAllRequest) GetNoWait() bool
- func (x *ExecAllRequest) GetOperations() []*Op
- func (x *ExecAllRequest) GetPreconditions() []*Precondition
- func (*ExecAllRequest) ProtoMessage()
- func (x *ExecAllRequest) ProtoReflect() protoreflect.Message
- func (x *ExecAllRequest) Reset()
- func (x *ExecAllRequest) String() string
- func (m *ExecAllRequest) Validate() error
- type Expiration
- type ExportTxRequest
- type FlushIndexRequest
- func (*FlushIndexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FlushIndexRequest) GetCleanupPercentage() float32
- func (x *FlushIndexRequest) GetSynced() bool
- func (*FlushIndexRequest) ProtoMessage()
- func (x *FlushIndexRequest) ProtoReflect() protoreflect.Message
- func (x *FlushIndexRequest) Reset()
- func (x *FlushIndexRequest) String() string
- type FlushIndexResponse
- func (*FlushIndexResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FlushIndexResponse) GetDatabase() string
- func (*FlushIndexResponse) ProtoMessage()
- func (x *FlushIndexResponse) ProtoReflect() protoreflect.Message
- func (x *FlushIndexResponse) Reset()
- func (x *FlushIndexResponse) String() string
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthResponse) GetStatus() bool
- func (x *HealthResponse) GetVersion() string
- func (*HealthResponse) ProtoMessage()
- func (x *HealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthResponse) Reset()
- func (x *HealthResponse) String() string
- type HistoryRequest
- func (*HistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryRequest) GetDesc() bool
- func (x *HistoryRequest) GetKey() []byte
- func (x *HistoryRequest) GetLimit() int32
- func (x *HistoryRequest) GetOffset() uint64
- func (x *HistoryRequest) GetSinceTx() uint64
- func (*HistoryRequest) ProtoMessage()
- func (x *HistoryRequest) ProtoReflect() protoreflect.Message
- func (x *HistoryRequest) Reset()
- func (x *HistoryRequest) String() string
- type ImmuServiceClient
- type ImmuServiceServer
- type ImmuService_ExportTxClient
- type ImmuService_ExportTxServer
- type ImmuService_ReplicateTxClient
- type ImmuService_ReplicateTxServer
- type ImmuService_StreamExecAllClient
- type ImmuService_StreamExecAllServer
- type ImmuService_StreamGetClient
- type ImmuService_StreamGetServer
- type ImmuService_StreamHistoryClient
- type ImmuService_StreamHistoryServer
- type ImmuService_StreamScanClient
- type ImmuService_StreamScanServer
- type ImmuService_StreamSetClient
- type ImmuService_StreamSetServer
- type ImmuService_StreamVerifiableGetClient
- type ImmuService_StreamVerifiableGetServer
- type ImmuService_StreamVerifiableSetClient
- type ImmuService_StreamVerifiableSetServer
- type ImmuService_StreamZScanClient
- type ImmuService_StreamZScanServer
- type ImmutableState
- func (state *ImmutableState) CheckSignature(key *ecdsa.PublicKey) (ok bool, err error)
- func (*ImmutableState) Descriptor() ([]byte, []int)deprecated
- func (x *ImmutableState) GetDb() string
- func (x *ImmutableState) GetSignature() *Signature
- func (x *ImmutableState) GetTxHash() []byte
- func (x *ImmutableState) GetTxId() uint64
- func (*ImmutableState) ProtoMessage()
- func (x *ImmutableState) ProtoReflect() protoreflect.Message
- func (x *ImmutableState) Reset()
- func (x *ImmutableState) String() string
- func (state *ImmutableState) ToBytes() []byte
- type InclusionProof
- func (*InclusionProof) Descriptor() ([]byte, []int)deprecated
- func (x *InclusionProof) GetLeaf() int32
- func (x *InclusionProof) GetTerms() [][]byte
- func (x *InclusionProof) GetWidth() int32
- func (*InclusionProof) ProtoMessage()
- func (x *InclusionProof) ProtoReflect() protoreflect.Message
- func (x *InclusionProof) Reset()
- func (x *InclusionProof) String() string
- type IndexNullableSettings
- func (*IndexNullableSettings) Descriptor() ([]byte, []int)deprecated
- func (x *IndexNullableSettings) GetCacheSize() *NullableUint32
- func (x *IndexNullableSettings) GetCleanupPercentage() *NullableFloat
- func (x *IndexNullableSettings) GetCommitLogMaxOpenedFiles() *NullableUint32
- func (x *IndexNullableSettings) GetCompactionThld() *NullableUint32
- func (x *IndexNullableSettings) GetDelayDuringCompaction() *NullableUint32
- func (x *IndexNullableSettings) GetFlushBufferSize() *NullableUint32
- func (x *IndexNullableSettings) GetFlushThreshold() *NullableUint32
- func (x *IndexNullableSettings) GetHistoryLogMaxOpenedFiles() *NullableUint32
- func (x *IndexNullableSettings) GetMaxActiveSnapshots() *NullableUint32
- func (x *IndexNullableSettings) GetMaxNodeSize() *NullableUint32
- func (x *IndexNullableSettings) GetNodesLogMaxOpenedFiles() *NullableUint32
- func (x *IndexNullableSettings) GetRenewSnapRootAfter() *NullableUint64
- func (x *IndexNullableSettings) GetSyncThreshold() *NullableUint32
- func (*IndexNullableSettings) ProtoMessage()
- func (x *IndexNullableSettings) ProtoReflect() protoreflect.Message
- func (x *IndexNullableSettings) Reset()
- func (x *IndexNullableSettings) String() string
- type KVMetadata
- func (*KVMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *KVMetadata) GetDeleted() bool
- func (x *KVMetadata) GetExpiration() *Expiration
- func (x *KVMetadata) GetNonIndexable() bool
- func (*KVMetadata) ProtoMessage()
- func (x *KVMetadata) ProtoReflect() protoreflect.Message
- func (x *KVMetadata) Reset()
- func (x *KVMetadata) String() string
- type Key
- type KeyListRequest
- func (*KeyListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeyListRequest) GetKeys() [][]byte
- func (x *KeyListRequest) GetSinceTx() uint64
- func (*KeyListRequest) ProtoMessage()
- func (x *KeyListRequest) ProtoReflect() protoreflect.Message
- func (x *KeyListRequest) Reset()
- func (x *KeyListRequest) String() string
- type KeyPrefix
- type KeyRequest
- func (*KeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeyRequest) GetAtTx() uint64
- func (x *KeyRequest) GetKey() []byte
- func (x *KeyRequest) GetNoWait() bool
- func (x *KeyRequest) GetSinceTx() uint64
- func (*KeyRequest) ProtoMessage()
- func (x *KeyRequest) ProtoReflect() protoreflect.Message
- func (x *KeyRequest) Reset()
- func (x *KeyRequest) String() string
- type KeyValue
- func (*KeyValue) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValue) GetKey() []byte
- func (x *KeyValue) GetMetadata() *KVMetadata
- func (x *KeyValue) GetValue() []byte
- func (*KeyValue) ProtoMessage()
- func (x *KeyValue) ProtoReflect() protoreflect.Message
- func (x *KeyValue) Reset()
- func (x *KeyValue) String() string
- type LinearProof
- func (*LinearProof) Descriptor() ([]byte, []int)deprecated
- func (x *LinearProof) GetSourceTxId() uint64
- func (x *LinearProof) GetTargetTxId() uint64
- func (x *LinearProof) GetTerms() [][]byte
- func (*LinearProof) ProtoMessage()
- func (x *LinearProof) ProtoReflect() protoreflect.Message
- func (x *LinearProof) Reset()
- func (x *LinearProof) String() string
- type LoadDatabaseRequest
- func (*LoadDatabaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadDatabaseRequest) GetDatabase() string
- func (*LoadDatabaseRequest) ProtoMessage()
- func (x *LoadDatabaseRequest) ProtoReflect() protoreflect.Message
- func (x *LoadDatabaseRequest) Reset()
- func (x *LoadDatabaseRequest) String() string
- type LoadDatabaseResponse
- func (*LoadDatabaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadDatabaseResponse) GetDatabase() string
- func (*LoadDatabaseResponse) ProtoMessage()
- func (x *LoadDatabaseResponse) ProtoReflect() protoreflect.Message
- func (x *LoadDatabaseResponse) Reset()
- func (x *LoadDatabaseResponse) String() string
- type LoginRequest
- func (*LoginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoginRequest) GetPassword() []byte
- func (x *LoginRequest) GetUser() []byte
- func (*LoginRequest) ProtoMessage()
- func (x *LoginRequest) ProtoReflect() protoreflect.Message
- func (x *LoginRequest) Reset()
- func (x *LoginRequest) String() string
- type LoginResponse
- func (*LoginResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoginResponse) GetToken() string
- func (x *LoginResponse) GetWarning() []byte
- func (*LoginResponse) ProtoMessage()
- func (x *LoginResponse) ProtoReflect() protoreflect.Message
- func (x *LoginResponse) Reset()
- func (x *LoginResponse) String() string
- type MTLSConfig
- type NamedParam
- type NewTxRequest
- type NewTxResponse
- type NullableBool
- type NullableFloat
- type NullableString
- type NullableUint32
- type NullableUint64
- type Op
- func (*Op) Descriptor() ([]byte, []int)deprecated
- func (x *Op) GetKv() *KeyValue
- func (m *Op) GetOperation() isOp_Operation
- func (x *Op) GetRef() *ReferenceRequest
- func (x *Op) GetZAdd() *ZAddRequest
- func (*Op) ProtoMessage()
- func (x *Op) ProtoReflect() protoreflect.Message
- func (x *Op) Reset()
- func (x *Op) String() string
- type Op_Kv
- type Op_Ref
- type Op_Unexpected
- type Op_ZAdd
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionRequest) GetDatabaseName() string
- func (x *OpenSessionRequest) GetPassword() []byte
- func (x *OpenSessionRequest) GetUsername() []byte
- func (*OpenSessionRequest) ProtoMessage()
- func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
- func (x *OpenSessionRequest) Reset()
- func (x *OpenSessionRequest) String() string
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionResponse) GetServerUUID() string
- func (x *OpenSessionResponse) GetSessionID() string
- func (*OpenSessionResponse) ProtoMessage()
- func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
- func (x *OpenSessionResponse) Reset()
- func (x *OpenSessionResponse) String() string
- type Permission
- func (*Permission) Descriptor() ([]byte, []int)deprecated
- func (x *Permission) GetDatabase() string
- func (x *Permission) GetPermission() uint32
- func (*Permission) ProtoMessage()
- func (x *Permission) ProtoReflect() protoreflect.Message
- func (x *Permission) Reset()
- func (x *Permission) String() string
- type PermissionAction
- func (PermissionAction) Descriptor() protoreflect.EnumDescriptor
- func (x PermissionAction) Enum() *PermissionAction
- func (PermissionAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x PermissionAction) Number() protoreflect.EnumNumber
- func (x PermissionAction) String() string
- func (PermissionAction) Type() protoreflect.EnumType
- type Precondition
- func (*Precondition) Descriptor() ([]byte, []int)deprecated
- func (x *Precondition) GetKeyMustExist() *Precondition_KeyMustExistPrecondition
- func (x *Precondition) GetKeyMustNotExist() *Precondition_KeyMustNotExistPrecondition
- func (x *Precondition) GetKeyNotModifiedAfterTX() *Precondition_KeyNotModifiedAfterTXPrecondition
- func (m *Precondition) GetPrecondition() isPrecondition_Precondition
- func (*Precondition) ProtoMessage()
- func (x *Precondition) ProtoReflect() protoreflect.Message
- func (x *Precondition) Reset()
- func (x *Precondition) String() string
- type Precondition_KeyMustExist
- type Precondition_KeyMustExistPrecondition
- func (*Precondition_KeyMustExistPrecondition) Descriptor() ([]byte, []int)deprecated
- func (x *Precondition_KeyMustExistPrecondition) GetKey() []byte
- func (*Precondition_KeyMustExistPrecondition) ProtoMessage()
- func (x *Precondition_KeyMustExistPrecondition) ProtoReflect() protoreflect.Message
- func (x *Precondition_KeyMustExistPrecondition) Reset()
- func (x *Precondition_KeyMustExistPrecondition) String() string
- type Precondition_KeyMustNotExist
- type Precondition_KeyMustNotExistPrecondition
- func (*Precondition_KeyMustNotExistPrecondition) Descriptor() ([]byte, []int)deprecated
- func (x *Precondition_KeyMustNotExistPrecondition) GetKey() []byte
- func (*Precondition_KeyMustNotExistPrecondition) ProtoMessage()
- func (x *Precondition_KeyMustNotExistPrecondition) ProtoReflect() protoreflect.Message
- func (x *Precondition_KeyMustNotExistPrecondition) Reset()
- func (x *Precondition_KeyMustNotExistPrecondition) String() string
- type Precondition_KeyNotModifiedAfterTX
- type Precondition_KeyNotModifiedAfterTXPrecondition
- func (*Precondition_KeyNotModifiedAfterTXPrecondition) Descriptor() ([]byte, []int)deprecated
- func (x *Precondition_KeyNotModifiedAfterTXPrecondition) GetKey() []byte
- func (x *Precondition_KeyNotModifiedAfterTXPrecondition) GetTxID() uint64
- func (*Precondition_KeyNotModifiedAfterTXPrecondition) ProtoMessage()
- func (x *Precondition_KeyNotModifiedAfterTXPrecondition) ProtoReflect() protoreflect.Message
- func (x *Precondition_KeyNotModifiedAfterTXPrecondition) Reset()
- func (x *Precondition_KeyNotModifiedAfterTXPrecondition) String() string
- type Reference
- func (*Reference) Descriptor() ([]byte, []int)deprecated
- func (x *Reference) GetAtTx() uint64
- func (x *Reference) GetKey() []byte
- func (x *Reference) GetMetadata() *KVMetadata
- func (x *Reference) GetTx() uint64
- func (*Reference) ProtoMessage()
- func (x *Reference) ProtoReflect() protoreflect.Message
- func (x *Reference) Reset()
- func (x *Reference) String() string
- type ReferenceRequest
- func (*ReferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReferenceRequest) GetAtTx() uint64
- func (x *ReferenceRequest) GetBoundRef() bool
- func (x *ReferenceRequest) GetKey() []byte
- func (x *ReferenceRequest) GetNoWait() bool
- func (x *ReferenceRequest) GetPreconditions() []*Precondition
- func (x *ReferenceRequest) GetReferencedKey() []byte
- func (*ReferenceRequest) ProtoMessage()
- func (x *ReferenceRequest) ProtoReflect() protoreflect.Message
- func (x *ReferenceRequest) Reset()
- func (x *ReferenceRequest) String() string
- type ReplicationNullableSettings
- func (*ReplicationNullableSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicationNullableSettings) GetFollowerPassword() *NullableString
- func (x *ReplicationNullableSettings) GetFollowerUsername() *NullableString
- func (x *ReplicationNullableSettings) GetMasterAddress() *NullableString
- func (x *ReplicationNullableSettings) GetMasterDatabase() *NullableString
- func (x *ReplicationNullableSettings) GetMasterPort() *NullableUint32
- func (x *ReplicationNullableSettings) GetReplica() *NullableBool
- func (*ReplicationNullableSettings) ProtoMessage()
- func (x *ReplicationNullableSettings) ProtoReflect() protoreflect.Message
- func (x *ReplicationNullableSettings) Reset()
- func (x *ReplicationNullableSettings) String() string
- type RetryInfo
- type Row
- type SQLEntry
- func (*SQLEntry) Descriptor() ([]byte, []int)deprecated
- func (x *SQLEntry) GetKey() []byte
- func (x *SQLEntry) GetMetadata() *KVMetadata
- func (x *SQLEntry) GetTx() uint64
- func (x *SQLEntry) GetValue() []byte
- func (*SQLEntry) ProtoMessage()
- func (x *SQLEntry) ProtoReflect() protoreflect.Message
- func (x *SQLEntry) Reset()
- func (x *SQLEntry) String() string
- type SQLExecRequest
- func (*SQLExecRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SQLExecRequest) GetNoWait() bool
- func (x *SQLExecRequest) GetParams() []*NamedParam
- func (x *SQLExecRequest) GetSql() string
- func (*SQLExecRequest) ProtoMessage()
- func (x *SQLExecRequest) ProtoReflect() protoreflect.Message
- func (x *SQLExecRequest) Reset()
- func (x *SQLExecRequest) String() string
- type SQLExecResult
- func (*SQLExecResult) Descriptor() ([]byte, []int)deprecated
- func (er *SQLExecResult) FirstInsertedPks() map[string]*SQLValue
- func (x *SQLExecResult) GetOngoingTx() bool
- func (x *SQLExecResult) GetTxs() []*CommittedSQLTx
- func (er *SQLExecResult) LastInsertedPk() map[string]*SQLValue
- func (*SQLExecResult) ProtoMessage()
- func (x *SQLExecResult) ProtoReflect() protoreflect.Message
- func (x *SQLExecResult) Reset()
- func (x *SQLExecResult) String() string
- type SQLGetRequest
- func (*SQLGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SQLGetRequest) GetAtTx() uint64
- func (x *SQLGetRequest) GetPkValues() []*SQLValue
- func (x *SQLGetRequest) GetSinceTx() uint64
- func (x *SQLGetRequest) GetTable() string
- func (*SQLGetRequest) ProtoMessage()
- func (x *SQLGetRequest) ProtoReflect() protoreflect.Message
- func (x *SQLGetRequest) Reset()
- func (x *SQLGetRequest) String() string
- type SQLQueryRequest
- func (*SQLQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SQLQueryRequest) GetParams() []*NamedParam
- func (x *SQLQueryRequest) GetReuseSnapshot() bool
- func (x *SQLQueryRequest) GetSql() string
- func (*SQLQueryRequest) ProtoMessage()
- func (x *SQLQueryRequest) ProtoReflect() protoreflect.Message
- func (x *SQLQueryRequest) Reset()
- func (x *SQLQueryRequest) String() string
- type SQLQueryResult
- func (*SQLQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *SQLQueryResult) GetColumns() []*Column
- func (x *SQLQueryResult) GetRows() []*Row
- func (*SQLQueryResult) ProtoMessage()
- func (x *SQLQueryResult) ProtoReflect() protoreflect.Message
- func (x *SQLQueryResult) Reset()
- func (x *SQLQueryResult) String() string
- type SQLValue
- func (*SQLValue) Descriptor() ([]byte, []int)deprecated
- func (x *SQLValue) GetB() bool
- func (x *SQLValue) GetBs() []byte
- func (x *SQLValue) GetN() int64
- func (x *SQLValue) GetNull() _struct.NullValue
- func (x *SQLValue) GetS() string
- func (x *SQLValue) GetTs() int64
- func (m *SQLValue) GetValue() isSQLValue_Value
- func (*SQLValue) ProtoMessage()
- func (x *SQLValue) ProtoReflect() protoreflect.Message
- func (x *SQLValue) Reset()
- func (x *SQLValue) String() string
- type SQLValue_B
- type SQLValue_Bs
- type SQLValue_N
- type SQLValue_Null
- type SQLValue_S
- type SQLValue_Ts
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScanRequest) GetDesc() bool
- func (x *ScanRequest) GetLimit() uint64
- func (x *ScanRequest) GetNoWait() bool
- func (x *ScanRequest) GetPrefix() []byte
- func (x *ScanRequest) GetSeekKey() []byte
- func (x *ScanRequest) GetSinceTx() uint64
- func (*ScanRequest) ProtoMessage()
- func (x *ScanRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRequest) Reset()
- func (x *ScanRequest) String() string
- type Score
- type SetActiveUserRequest
- func (*SetActiveUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetActiveUserRequest) GetActive() bool
- func (x *SetActiveUserRequest) GetUsername() string
- func (*SetActiveUserRequest) ProtoMessage()
- func (x *SetActiveUserRequest) ProtoReflect() protoreflect.Message
- func (x *SetActiveUserRequest) Reset()
- func (x *SetActiveUserRequest) String() string
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetRequest) GetKVs() []*KeyValue
- func (x *SetRequest) GetNoWait() bool
- func (x *SetRequest) GetPreconditions() []*Precondition
- func (*SetRequest) ProtoMessage()
- func (x *SetRequest) ProtoReflect() protoreflect.Message
- func (x *SetRequest) Reset()
- func (x *SetRequest) String() string
- type Signature
- type SqlValue
- type Table
- type Tx
- func (*Tx) Descriptor() ([]byte, []int)deprecated
- func (x *Tx) GetEntries() []*TxEntry
- func (x *Tx) GetHeader() *TxHeader
- func (x *Tx) GetKvEntries() []*Entry
- func (x *Tx) GetZEntries() []*ZEntry
- func (*Tx) ProtoMessage()
- func (x *Tx) ProtoReflect() protoreflect.Message
- func (x *Tx) Reset()
- func (x *Tx) String() string
- type TxEntry
- func (*TxEntry) Descriptor() ([]byte, []int)deprecated
- func (x *TxEntry) GetHValue() []byte
- func (x *TxEntry) GetKey() []byte
- func (x *TxEntry) GetMetadata() *KVMetadata
- func (x *TxEntry) GetVLen() int32
- func (x *TxEntry) GetValue() []byte
- func (*TxEntry) ProtoMessage()
- func (x *TxEntry) ProtoReflect() protoreflect.Message
- func (x *TxEntry) Reset()
- func (x *TxEntry) String() string
- type TxHeader
- func (*TxHeader) Descriptor() ([]byte, []int)deprecated
- func (x *TxHeader) GetBlRoot() []byte
- func (x *TxHeader) GetBlTxId() uint64
- func (x *TxHeader) GetEH() []byte
- func (x *TxHeader) GetId() uint64
- func (x *TxHeader) GetMetadata() *TxMetadata
- func (x *TxHeader) GetNentries() int32
- func (x *TxHeader) GetPrevAlh() []byte
- func (x *TxHeader) GetTs() int64
- func (x *TxHeader) GetVersion() int32
- func (*TxHeader) ProtoMessage()
- func (x *TxHeader) ProtoReflect() protoreflect.Message
- func (x *TxHeader) Reset()
- func (x *TxHeader) String() string
- type TxList
- type TxMetadata
- type TxMode
- type TxRequest
- func (*TxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TxRequest) GetEntriesSpec() *EntriesSpec
- func (x *TxRequest) GetKeepReferencesUnresolved() bool
- func (x *TxRequest) GetNoWait() bool
- func (x *TxRequest) GetSinceTx() uint64
- func (x *TxRequest) GetTx() uint64
- func (*TxRequest) ProtoMessage()
- func (x *TxRequest) ProtoReflect() protoreflect.Message
- func (x *TxRequest) Reset()
- func (x *TxRequest) String() string
- type TxScanRequest
- func (*TxScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TxScanRequest) GetDesc() bool
- func (x *TxScanRequest) GetEntriesSpec() *EntriesSpec
- func (x *TxScanRequest) GetInitialTx() uint64
- func (x *TxScanRequest) GetLimit() uint32
- func (x *TxScanRequest) GetNoWait() bool
- func (x *TxScanRequest) GetSinceTx() uint64
- func (*TxScanRequest) ProtoMessage()
- func (x *TxScanRequest) ProtoReflect() protoreflect.Message
- func (x *TxScanRequest) Reset()
- func (x *TxScanRequest) String() string
- type UnimplementedImmuServiceServer
- func (*UnimplementedImmuServiceServer) ChangePassword(context.Context, *ChangePasswordRequest) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) ChangePermission(context.Context, *ChangePermissionRequest) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) CloseSession(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) Commit(context.Context, *empty.Empty) (*CommittedSQLTx, error)
- func (*UnimplementedImmuServiceServer) CompactIndex(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) Count(context.Context, *KeyPrefix) (*EntryCount, error)
- func (*UnimplementedImmuServiceServer) CountAll(context.Context, *empty.Empty) (*EntryCount, error)
- func (*UnimplementedImmuServiceServer) CreateDatabase(context.Context, *Database) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) CreateDatabaseV2(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
- func (*UnimplementedImmuServiceServer) CreateDatabaseWith(context.Context, *DatabaseSettings) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) CreateUser(context.Context, *CreateUserRequest) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) CurrentState(context.Context, *empty.Empty) (*ImmutableState, error)
- func (*UnimplementedImmuServiceServer) DatabaseHealth(context.Context, *empty.Empty) (*DatabaseHealthResponse, error)
- func (*UnimplementedImmuServiceServer) DatabaseList(context.Context, *empty.Empty) (*DatabaseListResponse, error)
- func (*UnimplementedImmuServiceServer) DatabaseListV2(context.Context, *DatabaseListRequestV2) (*DatabaseListResponseV2, error)
- func (*UnimplementedImmuServiceServer) Delete(context.Context, *DeleteKeysRequest) (*TxHeader, error)
- func (*UnimplementedImmuServiceServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
- func (*UnimplementedImmuServiceServer) DescribeTable(context.Context, *Table) (*SQLQueryResult, error)
- func (*UnimplementedImmuServiceServer) ExecAll(context.Context, *ExecAllRequest) (*TxHeader, error)
- func (*UnimplementedImmuServiceServer) ExportTx(*ExportTxRequest, ImmuService_ExportTxServer) error
- func (*UnimplementedImmuServiceServer) FlushIndex(context.Context, *FlushIndexRequest) (*FlushIndexResponse, error)
- func (*UnimplementedImmuServiceServer) Get(context.Context, *KeyRequest) (*Entry, error)
- func (*UnimplementedImmuServiceServer) GetAll(context.Context, *KeyListRequest) (*Entries, error)
- func (*UnimplementedImmuServiceServer) GetDatabaseSettings(context.Context, *empty.Empty) (*DatabaseSettings, error)
- func (*UnimplementedImmuServiceServer) GetDatabaseSettingsV2(context.Context, *DatabaseSettingsRequest) (*DatabaseSettingsResponse, error)
- func (*UnimplementedImmuServiceServer) Health(context.Context, *empty.Empty) (*HealthResponse, error)
- func (*UnimplementedImmuServiceServer) History(context.Context, *HistoryRequest) (*Entries, error)
- func (*UnimplementedImmuServiceServer) KeepAlive(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) ListTables(context.Context, *empty.Empty) (*SQLQueryResult, error)
- func (*UnimplementedImmuServiceServer) ListUsers(context.Context, *empty.Empty) (*UserList, error)
- func (*UnimplementedImmuServiceServer) LoadDatabase(context.Context, *LoadDatabaseRequest) (*LoadDatabaseResponse, error)
- func (*UnimplementedImmuServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
- func (*UnimplementedImmuServiceServer) Logout(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) NewTx(context.Context, *NewTxRequest) (*NewTxResponse, error)
- func (*UnimplementedImmuServiceServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
- func (*UnimplementedImmuServiceServer) ReplicateTx(ImmuService_ReplicateTxServer) error
- func (*UnimplementedImmuServiceServer) Rollback(context.Context, *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) SQLExec(context.Context, *SQLExecRequest) (*SQLExecResult, error)
- func (*UnimplementedImmuServiceServer) SQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
- func (*UnimplementedImmuServiceServer) Scan(context.Context, *ScanRequest) (*Entries, error)
- func (*UnimplementedImmuServiceServer) Set(context.Context, *SetRequest) (*TxHeader, error)
- func (*UnimplementedImmuServiceServer) SetActiveUser(context.Context, *SetActiveUserRequest) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) SetReference(context.Context, *ReferenceRequest) (*TxHeader, error)
- func (*UnimplementedImmuServiceServer) StreamExecAll(ImmuService_StreamExecAllServer) error
- func (*UnimplementedImmuServiceServer) StreamGet(*KeyRequest, ImmuService_StreamGetServer) error
- func (*UnimplementedImmuServiceServer) StreamHistory(*HistoryRequest, ImmuService_StreamHistoryServer) error
- func (*UnimplementedImmuServiceServer) StreamScan(*ScanRequest, ImmuService_StreamScanServer) error
- func (*UnimplementedImmuServiceServer) StreamSet(ImmuService_StreamSetServer) error
- func (*UnimplementedImmuServiceServer) StreamVerifiableGet(*VerifiableGetRequest, ImmuService_StreamVerifiableGetServer) error
- func (*UnimplementedImmuServiceServer) StreamVerifiableSet(ImmuService_StreamVerifiableSetServer) error
- func (*UnimplementedImmuServiceServer) StreamZScan(*ZScanRequest, ImmuService_StreamZScanServer) error
- func (*UnimplementedImmuServiceServer) TxById(context.Context, *TxRequest) (*Tx, error)
- func (*UnimplementedImmuServiceServer) TxSQLExec(context.Context, *SQLExecRequest) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) TxSQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
- func (*UnimplementedImmuServiceServer) TxScan(context.Context, *TxScanRequest) (*TxList, error)
- func (*UnimplementedImmuServiceServer) UnloadDatabase(context.Context, *UnloadDatabaseRequest) (*UnloadDatabaseResponse, error)
- func (*UnimplementedImmuServiceServer) UpdateAuthConfig(context.Context, *AuthConfig) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) UpdateDatabase(context.Context, *DatabaseSettings) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) UpdateDatabaseV2(context.Context, *UpdateDatabaseRequest) (*UpdateDatabaseResponse, error)
- func (*UnimplementedImmuServiceServer) UpdateMTLSConfig(context.Context, *MTLSConfig) (*empty.Empty, error)
- func (*UnimplementedImmuServiceServer) UseDatabase(context.Context, *Database) (*UseDatabaseReply, error)
- func (*UnimplementedImmuServiceServer) VerifiableGet(context.Context, *VerifiableGetRequest) (*VerifiableEntry, error)
- func (*UnimplementedImmuServiceServer) VerifiableSQLGet(context.Context, *VerifiableSQLGetRequest) (*VerifiableSQLEntry, error)
- func (*UnimplementedImmuServiceServer) VerifiableSet(context.Context, *VerifiableSetRequest) (*VerifiableTx, error)
- func (*UnimplementedImmuServiceServer) VerifiableSetReference(context.Context, *VerifiableReferenceRequest) (*VerifiableTx, error)
- func (*UnimplementedImmuServiceServer) VerifiableTxById(context.Context, *VerifiableTxRequest) (*VerifiableTx, error)
- func (*UnimplementedImmuServiceServer) VerifiableZAdd(context.Context, *VerifiableZAddRequest) (*VerifiableTx, error)
- func (*UnimplementedImmuServiceServer) ZAdd(context.Context, *ZAddRequest) (*TxHeader, error)
- func (*UnimplementedImmuServiceServer) ZScan(context.Context, *ZScanRequest) (*ZEntries, error)
- type UnloadDatabaseRequest
- func (*UnloadDatabaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnloadDatabaseRequest) GetDatabase() string
- func (*UnloadDatabaseRequest) ProtoMessage()
- func (x *UnloadDatabaseRequest) ProtoReflect() protoreflect.Message
- func (x *UnloadDatabaseRequest) Reset()
- func (x *UnloadDatabaseRequest) String() string
- type UnloadDatabaseResponse
- func (*UnloadDatabaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnloadDatabaseResponse) GetDatabase() string
- func (*UnloadDatabaseResponse) ProtoMessage()
- func (x *UnloadDatabaseResponse) ProtoReflect() protoreflect.Message
- func (x *UnloadDatabaseResponse) Reset()
- func (x *UnloadDatabaseResponse) String() string
- type UpdateDatabaseRequest
- func (*UpdateDatabaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDatabaseRequest) GetDatabase() string
- func (x *UpdateDatabaseRequest) GetSettings() *DatabaseNullableSettings
- func (*UpdateDatabaseRequest) ProtoMessage()
- func (x *UpdateDatabaseRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDatabaseRequest) Reset()
- func (x *UpdateDatabaseRequest) String() string
- type UpdateDatabaseResponse
- func (*UpdateDatabaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDatabaseResponse) GetDatabase() string
- func (x *UpdateDatabaseResponse) GetSettings() *DatabaseNullableSettings
- func (*UpdateDatabaseResponse) ProtoMessage()
- func (x *UpdateDatabaseResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDatabaseResponse) Reset()
- func (x *UpdateDatabaseResponse) String() string
- type UseDatabaseReply
- type UseSnapshotRequest
- func (*UseSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UseSnapshotRequest) GetAsBeforeTx() uint64
- func (x *UseSnapshotRequest) GetSinceTx() uint64
- func (*UseSnapshotRequest) ProtoMessage()
- func (x *UseSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *UseSnapshotRequest) Reset()
- func (x *UseSnapshotRequest) String() string
- type User
- func (*User) Descriptor() ([]byte, []int)deprecated
- func (x *User) GetActive() bool
- func (x *User) GetCreatedat() string
- func (x *User) GetCreatedby() string
- func (x *User) GetPermissions() []*Permission
- func (x *User) GetUser() []byte
- func (*User) ProtoMessage()
- func (x *User) ProtoReflect() protoreflect.Message
- func (x *User) Reset()
- func (x *User) String() string
- type UserList
- type UserRequest
- type VerifiableEntry
- func (*VerifiableEntry) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableEntry) GetEntry() *Entry
- func (x *VerifiableEntry) GetInclusionProof() *InclusionProof
- func (x *VerifiableEntry) GetVerifiableTx() *VerifiableTx
- func (*VerifiableEntry) ProtoMessage()
- func (x *VerifiableEntry) ProtoReflect() protoreflect.Message
- func (x *VerifiableEntry) Reset()
- func (x *VerifiableEntry) String() string
- type VerifiableGetRequest
- func (*VerifiableGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableGetRequest) GetKeyRequest() *KeyRequest
- func (x *VerifiableGetRequest) GetProveSinceTx() uint64
- func (*VerifiableGetRequest) ProtoMessage()
- func (x *VerifiableGetRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableGetRequest) Reset()
- func (x *VerifiableGetRequest) String() string
- type VerifiableReferenceRequest
- func (*VerifiableReferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableReferenceRequest) GetProveSinceTx() uint64
- func (x *VerifiableReferenceRequest) GetReferenceRequest() *ReferenceRequest
- func (*VerifiableReferenceRequest) ProtoMessage()
- func (x *VerifiableReferenceRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableReferenceRequest) Reset()
- func (x *VerifiableReferenceRequest) String() string
- type VerifiableSQLEntry
- func (*VerifiableSQLEntry) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableSQLEntry) GetColIdsByName() map[string]uint32
- func (x *VerifiableSQLEntry) GetColLenById() map[uint32]int32
- func (x *VerifiableSQLEntry) GetColNamesById() map[uint32]string
- func (x *VerifiableSQLEntry) GetColTypesById() map[uint32]string
- func (x *VerifiableSQLEntry) GetDatabaseId() uint32
- func (x *VerifiableSQLEntry) GetInclusionProof() *InclusionProof
- func (x *VerifiableSQLEntry) GetPKIDs() []uint32
- func (x *VerifiableSQLEntry) GetSqlEntry() *SQLEntry
- func (x *VerifiableSQLEntry) GetTableId() uint32
- func (x *VerifiableSQLEntry) GetVerifiableTx() *VerifiableTx
- func (*VerifiableSQLEntry) ProtoMessage()
- func (x *VerifiableSQLEntry) ProtoReflect() protoreflect.Message
- func (x *VerifiableSQLEntry) Reset()
- func (x *VerifiableSQLEntry) String() string
- type VerifiableSQLGetRequest
- func (*VerifiableSQLGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableSQLGetRequest) GetProveSinceTx() uint64
- func (x *VerifiableSQLGetRequest) GetSqlGetRequest() *SQLGetRequest
- func (*VerifiableSQLGetRequest) ProtoMessage()
- func (x *VerifiableSQLGetRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableSQLGetRequest) Reset()
- func (x *VerifiableSQLGetRequest) String() string
- type VerifiableSetRequest
- func (*VerifiableSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableSetRequest) GetProveSinceTx() uint64
- func (x *VerifiableSetRequest) GetSetRequest() *SetRequest
- func (*VerifiableSetRequest) ProtoMessage()
- func (x *VerifiableSetRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableSetRequest) Reset()
- func (x *VerifiableSetRequest) String() string
- type VerifiableTx
- func (*VerifiableTx) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableTx) GetDualProof() *DualProof
- func (x *VerifiableTx) GetSignature() *Signature
- func (x *VerifiableTx) GetTx() *Tx
- func (*VerifiableTx) ProtoMessage()
- func (x *VerifiableTx) ProtoReflect() protoreflect.Message
- func (x *VerifiableTx) Reset()
- func (x *VerifiableTx) String() string
- type VerifiableTxRequest
- func (*VerifiableTxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableTxRequest) GetEntriesSpec() *EntriesSpec
- func (x *VerifiableTxRequest) GetKeepReferencesUnresolved() bool
- func (x *VerifiableTxRequest) GetNoWait() bool
- func (x *VerifiableTxRequest) GetProveSinceTx() uint64
- func (x *VerifiableTxRequest) GetSinceTx() uint64
- func (x *VerifiableTxRequest) GetTx() uint64
- func (*VerifiableTxRequest) ProtoMessage()
- func (x *VerifiableTxRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableTxRequest) Reset()
- func (x *VerifiableTxRequest) String() string
- type VerifiableZAddRequest
- func (*VerifiableZAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableZAddRequest) GetProveSinceTx() uint64
- func (x *VerifiableZAddRequest) GetZAddRequest() *ZAddRequest
- func (*VerifiableZAddRequest) ProtoMessage()
- func (x *VerifiableZAddRequest) ProtoReflect() protoreflect.Message
- func (x *VerifiableZAddRequest) Reset()
- func (x *VerifiableZAddRequest) String() string
- type ZAddRequest
- func (*ZAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ZAddRequest) GetAtTx() uint64
- func (x *ZAddRequest) GetBoundRef() bool
- func (x *ZAddRequest) GetKey() []byte
- func (x *ZAddRequest) GetNoWait() bool
- func (x *ZAddRequest) GetScore() float64
- func (x *ZAddRequest) GetSet() []byte
- func (*ZAddRequest) ProtoMessage()
- func (x *ZAddRequest) ProtoReflect() protoreflect.Message
- func (x *ZAddRequest) Reset()
- func (x *ZAddRequest) String() string
- type ZEntries
- type ZEntry
- func (*ZEntry) Descriptor() ([]byte, []int)deprecated
- func (x *ZEntry) GetAtTx() uint64
- func (x *ZEntry) GetEntry() *Entry
- func (x *ZEntry) GetKey() []byte
- func (x *ZEntry) GetScore() float64
- func (x *ZEntry) GetSet() []byte
- func (*ZEntry) ProtoMessage()
- func (x *ZEntry) ProtoReflect() protoreflect.Message
- func (x *ZEntry) Reset()
- func (x *ZEntry) String() string
- type ZScanRequest
- func (*ZScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ZScanRequest) GetDesc() bool
- func (x *ZScanRequest) GetInclusiveSeek() bool
- func (x *ZScanRequest) GetLimit() uint64
- func (x *ZScanRequest) GetMaxScore() *Score
- func (x *ZScanRequest) GetMinScore() *Score
- func (x *ZScanRequest) GetNoWait() bool
- func (x *ZScanRequest) GetSeekAtTx() uint64
- func (x *ZScanRequest) GetSeekKey() []byte
- func (x *ZScanRequest) GetSeekScore() float64
- func (x *ZScanRequest) GetSet() []byte
- func (x *ZScanRequest) GetSinceTx() uint64
- func (*ZScanRequest) ProtoMessage()
- func (x *ZScanRequest) ProtoReflect() protoreflect.Message
- func (x *ZScanRequest) Reset()
- func (x *ZScanRequest) String() string
Constants ¶
This section is empty.
Variables ¶
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() )
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.
var ( PermissionAction_name = map[int32]string{ 0: "GRANT", 1: "REVOKE", } PermissionAction_value = map[string]int32{ "GRANT": 0, "REVOKE": 1, } )
Enum value maps for PermissionAction.
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.
var File_schema_proto protoreflect.FileDescriptor
Functions ¶
func DigestsFromProto ¶ added in v1.2.0
func DualProofFromProto ¶ added in v1.2.0
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 ¶
Pattern_ImmuService_History_0 exposes the runtime Pattern need to overwrite history autogenerated request
func Pattern_ImmuService_Set_0 ¶
Pattern_ImmuService_Set_0 exposes the runtime Pattern need to overwrite set autogenerated request
func Pattern_ImmuService_UseDatabase_0 ¶ added in v0.7.0
Pattern_ImmuService_UseDatabase_0 exposes the runtime Pattern need to overwrite UseDatabase autogenerated request
func Pattern_ImmuService_VerifiableGet_0 ¶ added in v1.0.0
Pattern_ImmuService_VerifiableGet_0 exposes the runtime Pattern need to overwrite VerifiableGet autogenerated request
func Pattern_ImmuService_VerifiableSetReference_0 ¶ added in v1.0.0
Pattern_ImmuService_VerifiableSetReference_0 exposes the runtime Pattern need to overwrite VerifiableSetReference autogenerated request
func Pattern_ImmuService_VerifiableSet_0 ¶ added in v1.0.0
Pattern_ImmuService_VerifiableSet_0 exposes the runtime Pattern need to overwrite VerifiableSet autogenerated request
func Pattern_ImmuService_VerifiableTxById_0 ¶ added in v1.0.0
Pattern_ImmuService_VerifiableTxById_0 exposes the runtime Pattern need to overwrite VerifiableTxById autogenerated request
func Pattern_ImmuService_VerifiableZAdd_0 ¶ added in v1.0.0
Pattern_ImmuService_VerifiableZAdd_0 exposes the runtime Pattern need to overwrite VerifiableZAdd autogenerated request
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 TxHeaderFromProto ¶ added in v1.2.0
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 (x *ChangePermissionRequest) GetAction() PermissionAction
func (*ChangePermissionRequest) GetDatabase ¶ added in v0.7.0
func (x *ChangePermissionRequest) GetDatabase() string
func (*ChangePermissionRequest) GetPermission ¶ added in v0.7.0
func (x *ChangePermissionRequest) GetPermission() uint32
func (*ChangePermissionRequest) GetUsername ¶ added in v0.7.0
func (x *ChangePermissionRequest) GetUsername() string
func (*ChangePermissionRequest) ProtoMessage ¶ added in v0.7.0
func (*ChangePermissionRequest) ProtoMessage()
func (*ChangePermissionRequest) ProtoReflect ¶ added in v0.9.0
func (x *ChangePermissionRequest) ProtoReflect() protoreflect.Message
func (*ChangePermissionRequest) Reset ¶ added in v0.7.0
func (x *ChangePermissionRequest) Reset()
func (*ChangePermissionRequest) String ¶ added in v0.7.0
func (x *ChangePermissionRequest) String() string
type Chunk ¶ added in v0.9.2
type Chunk struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*Chunk) Descriptor
deprecated
added in
v0.9.2
func (*Chunk) GetContent ¶ added in v0.9.2
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
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) ProtoMessage ¶ added in v1.0.0
func (*Column) ProtoMessage()
func (*Column) ProtoReflect ¶ added in v1.0.0
func (x *Column) ProtoReflect() protoreflect.Message
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"` // 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) GetName ¶ added in v1.2.3
func (x *CreateDatabaseRequest) GetName() string
func (*CreateDatabaseRequest) GetSettings ¶ added in v1.2.3
func (x *CreateDatabaseRequest) GetSettings() *DatabaseNullableSettings
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"` // 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) GetName ¶ added in v1.2.3
func (x *CreateDatabaseResponse) GetName() string
func (*CreateDatabaseResponse) GetSettings ¶ added in v1.2.3
func (x *CreateDatabaseResponse) GetSettings() *DatabaseNullableSettings
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) GetDatabaseName ¶ added in v1.0.0
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
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 (x *DatabaseSettingsResponse) GetSettings() *DatabaseNullableSettings
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 (x *DatabaseWithSettings) GetSettings() *DatabaseNullableSettings
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) ProtoMessage ¶ added in v1.0.5
func (*DebugInfo) ProtoMessage()
func (*DebugInfo) ProtoReflect ¶ added in v1.0.5
func (x *DebugInfo) ProtoReflect() protoreflect.Message
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 (*DualProof) Descriptor
deprecated
added in
v0.9.0
func (*DualProof) GetConsistencyProof ¶ added in v0.9.0
func (*DualProof) GetInclusionProof ¶ added in v0.9.0
func (*DualProof) GetLastInclusionProof ¶ added in v0.9.0
func (*DualProof) GetLinearProof ¶ added in v0.9.0
func (x *DualProof) GetLinearProof() *LinearProof
func (*DualProof) GetSourceTxHeader ¶ added in v1.2.0
func (*DualProof) GetTargetBlTxAlh ¶ added in v0.9.0
func (*DualProof) GetTargetTxHeader ¶ added in v1.2.0
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
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) GetEntries ¶ added in v0.9.0
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
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"` // contains filtered or unexported fields }
func (*Entry) Descriptor
deprecated
added in
v0.9.0
func (*Entry) GetExpired ¶ added in v1.2.0
func (*Entry) GetMetadata ¶ added in v1.2.0
func (x *Entry) GetMetadata() *KVMetadata
func (*Entry) GetReferencedBy ¶ added in v0.9.0
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
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) Descriptor() protoreflect.EnumDescriptor
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 (x EntryTypeAction) Number() protoreflect.EnumNumber
func (EntryTypeAction) String ¶ added in v1.2.3
func (x EntryTypeAction) String() string
func (EntryTypeAction) Type ¶ added in v1.2.3
func (EntryTypeAction) Type() protoreflect.EnumType
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) ProtoMessage ¶ added in v1.0.5
func (*ErrorInfo) ProtoMessage()
func (*ErrorInfo) ProtoReflect ¶ added in v1.0.5
func (x *ErrorInfo) ProtoReflect() protoreflect.Message
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.
func NewImmuServiceClient ¶
func NewImmuServiceClient(cc grpc.ClientConnInterface) ImmuServiceClient
type ImmuServiceServer ¶
type ImmuServiceServer interface { ListUsers(context.Context, *empty.Empty) (*UserList, error) CreateUser(context.Context, *CreateUserRequest) (*empty.Empty, error) ChangePassword(context.Context, *ChangePasswordRequest) (*empty.Empty, error) 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_ReplicateTxServer ¶ added in v1.0.5
type ImmuService_StreamExecAllClient ¶ added in v0.9.2
type ImmuService_StreamExecAllServer ¶ added in v0.9.2
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_StreamSetServer ¶ added in v0.9.2
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) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) ProtoReflect ¶ added in v0.9.0
func (x *Key) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*KeyPrefix) ProtoMessage()
func (*KeyPrefix) ProtoReflect ¶ added in v0.9.0
func (x *KeyPrefix) ProtoReflect() protoreflect.Message
type KeyRequest ¶ added in v0.9.0
type KeyRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` AtTx uint64 `protobuf:"varint,2,opt,name=atTx,proto3" json:"atTx,omitempty"` SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,4,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*KeyRequest) Descriptor
deprecated
added in
v0.9.0
func (*KeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.
func (*KeyRequest) GetAtTx ¶ added in v0.9.1
func (x *KeyRequest) GetAtTx() uint64
func (*KeyRequest) GetKey ¶ added in v0.9.0
func (x *KeyRequest) GetKey() []byte
func (*KeyRequest) 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) GetMetadata ¶ added in v1.2.0
func (x *KeyValue) GetMetadata() *KVMetadata
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶ added in v0.9.0
func (x *KeyValue) ProtoReflect() protoreflect.Message
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 ¶ added in v0.6.2
func (x *LoginResponse) GetWarning() []byte
func (*LoginResponse) ProtoMessage ¶
func (*LoginResponse) ProtoMessage()
func (*LoginResponse) ProtoReflect ¶ added in v0.9.0
func (x *LoginResponse) ProtoReflect() protoreflect.Message
func (*LoginResponse) Reset ¶
func (x *LoginResponse) Reset()
func (*LoginResponse) String ¶
func (x *LoginResponse) String() string
type MTLSConfig ¶
type MTLSConfig struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // contains filtered or unexported fields }
func (*MTLSConfig) Descriptor
deprecated
func (*MTLSConfig) Descriptor() ([]byte, []int)
Deprecated: Use MTLSConfig.ProtoReflect.Descriptor instead.
func (*MTLSConfig) GetEnabled ¶
func (x *MTLSConfig) GetEnabled() bool
func (*MTLSConfig) ProtoMessage ¶
func (*MTLSConfig) ProtoMessage()
func (*MTLSConfig) ProtoReflect ¶ added in v0.9.0
func (x *MTLSConfig) ProtoReflect() protoreflect.Message
func (*MTLSConfig) Reset ¶
func (x *MTLSConfig) Reset()
func (*MTLSConfig) String ¶
func (x *MTLSConfig) String() string
type NamedParam ¶ added in v1.0.0
type NamedParam struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value *SQLValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func EncodeParams ¶ added in v1.0.5
func EncodeParams(params map[string]interface{}) ([]*NamedParam, error)
func (*NamedParam) Descriptor
deprecated
added in
v1.0.0
func (*NamedParam) Descriptor() ([]byte, []int)
Deprecated: Use NamedParam.ProtoReflect.Descriptor instead.
func (*NamedParam) GetName ¶ added in v1.0.0
func (x *NamedParam) GetName() string
func (*NamedParam) GetValue ¶ added in v1.0.0
func (x *NamedParam) GetValue() *SQLValue
func (*NamedParam) ProtoMessage ¶ added in v1.0.0
func (*NamedParam) ProtoMessage()
func (*NamedParam) ProtoReflect ¶ added in v1.0.0
func (x *NamedParam) ProtoReflect() protoreflect.Message
func (*NamedParam) Reset ¶ added in v1.0.0
func (x *NamedParam) Reset()
func (*NamedParam) String ¶ added in v1.0.0
func (x *NamedParam) String() string
type NewTxRequest ¶ added in v1.2.0
type NewTxRequest struct { Mode TxMode `protobuf:"varint,1,opt,name=mode,proto3,enum=immudb.schema.TxMode" json:"mode,omitempty"` // contains filtered or unexported fields }
func (*NewTxRequest) Descriptor
deprecated
added in
v1.2.0
func (*NewTxRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewTxRequest.ProtoReflect.Descriptor instead.
func (*NewTxRequest) GetMode ¶ added in v1.2.0
func (x *NewTxRequest) GetMode() TxMode
func (*NewTxRequest) ProtoMessage ¶ added in v1.2.0
func (*NewTxRequest) ProtoMessage()
func (*NewTxRequest) ProtoReflect ¶ added in v1.2.0
func (x *NewTxRequest) ProtoReflect() protoreflect.Message
func (*NewTxRequest) Reset ¶ added in v1.2.0
func (x *NewTxRequest) Reset()
func (*NewTxRequest) String ¶ added in v1.2.0
func (x *NewTxRequest) String() string
type NewTxResponse ¶ added in v1.2.0
type NewTxResponse struct { TransactionID string `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty"` // contains filtered or unexported fields }
func (*NewTxResponse) Descriptor
deprecated
added in
v1.2.0
func (*NewTxResponse) Descriptor() ([]byte, []int)
Deprecated: Use NewTxResponse.ProtoReflect.Descriptor instead.
func (*NewTxResponse) GetTransactionID ¶ added in v1.2.0
func (x *NewTxResponse) GetTransactionID() string
func (*NewTxResponse) ProtoMessage ¶ added in v1.2.0
func (*NewTxResponse) ProtoMessage()
func (*NewTxResponse) ProtoReflect ¶ added in v1.2.0
func (x *NewTxResponse) ProtoReflect() protoreflect.Message
func (*NewTxResponse) Reset ¶ added in v1.2.0
func (x *NewTxResponse) Reset()
func (*NewTxResponse) String ¶ added in v1.2.0
func (x *NewTxResponse) String() string
type NullableBool ¶ added in v1.2.3
type NullableBool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*NullableBool) Descriptor
deprecated
added in
v1.2.3
func (*NullableBool) Descriptor() ([]byte, []int)
Deprecated: Use NullableBool.ProtoReflect.Descriptor instead.
func (*NullableBool) GetValue ¶ added in v1.2.3
func (x *NullableBool) GetValue() bool
func (*NullableBool) ProtoMessage ¶ added in v1.2.3
func (*NullableBool) ProtoMessage()
func (*NullableBool) ProtoReflect ¶ added in v1.2.3
func (x *NullableBool) ProtoReflect() protoreflect.Message
func (*NullableBool) Reset ¶ added in v1.2.3
func (x *NullableBool) Reset()
func (*NullableBool) String ¶ added in v1.2.3
func (x *NullableBool) String() string
type NullableFloat ¶ added in v1.2.3
type NullableFloat struct { Value float32 `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*NullableFloat) Descriptor
deprecated
added in
v1.2.3
func (*NullableFloat) Descriptor() ([]byte, []int)
Deprecated: Use NullableFloat.ProtoReflect.Descriptor instead.
func (*NullableFloat) GetValue ¶ added in v1.2.3
func (x *NullableFloat) GetValue() float32
func (*NullableFloat) ProtoMessage ¶ added in v1.2.3
func (*NullableFloat) ProtoMessage()
func (*NullableFloat) ProtoReflect ¶ added in v1.2.3
func (x *NullableFloat) ProtoReflect() protoreflect.Message
func (*NullableFloat) Reset ¶ added in v1.2.3
func (x *NullableFloat) Reset()
func (*NullableFloat) String ¶ added in v1.2.3
func (x *NullableFloat) String() string
type NullableString ¶ added in v1.2.3
type NullableString struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*NullableString) Descriptor
deprecated
added in
v1.2.3
func (*NullableString) Descriptor() ([]byte, []int)
Deprecated: Use NullableString.ProtoReflect.Descriptor instead.
func (*NullableString) GetValue ¶ added in v1.2.3
func (x *NullableString) GetValue() string
func (*NullableString) ProtoMessage ¶ added in v1.2.3
func (*NullableString) ProtoMessage()
func (*NullableString) ProtoReflect ¶ added in v1.2.3
func (x *NullableString) ProtoReflect() protoreflect.Message
func (*NullableString) Reset ¶ added in v1.2.3
func (x *NullableString) Reset()
func (*NullableString) String ¶ added in v1.2.3
func (x *NullableString) String() string
type NullableUint32 ¶ added in v1.2.3
type NullableUint32 struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*NullableUint32) Descriptor
deprecated
added in
v1.2.3
func (*NullableUint32) Descriptor() ([]byte, []int)
Deprecated: Use NullableUint32.ProtoReflect.Descriptor instead.
func (*NullableUint32) GetValue ¶ added in v1.2.3
func (x *NullableUint32) GetValue() uint32
func (*NullableUint32) ProtoMessage ¶ added in v1.2.3
func (*NullableUint32) ProtoMessage()
func (*NullableUint32) ProtoReflect ¶ added in v1.2.3
func (x *NullableUint32) ProtoReflect() protoreflect.Message
func (*NullableUint32) Reset ¶ added in v1.2.3
func (x *NullableUint32) Reset()
func (*NullableUint32) String ¶ added in v1.2.3
func (x *NullableUint32) String() string
type NullableUint64 ¶ added in v1.2.3
type NullableUint64 struct { Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*NullableUint64) Descriptor
deprecated
added in
v1.2.3
func (*NullableUint64) Descriptor() ([]byte, []int)
Deprecated: Use NullableUint64.ProtoReflect.Descriptor instead.
func (*NullableUint64) GetValue ¶ added in v1.2.3
func (x *NullableUint64) GetValue() uint64
func (*NullableUint64) ProtoMessage ¶ added in v1.2.3
func (*NullableUint64) ProtoMessage()
func (*NullableUint64) ProtoReflect ¶ added in v1.2.3
func (x *NullableUint64) ProtoReflect() protoreflect.Message
func (*NullableUint64) Reset ¶ added in v1.2.3
func (x *NullableUint64) Reset()
func (*NullableUint64) String ¶ added in v1.2.3
func (x *NullableUint64) String() string
type Op ¶ added in v0.8.1
type Op struct { // Types that are assignable to Operation: // *Op_Kv // *Op_ZAdd // *Op_Ref Operation isOp_Operation `protobuf_oneof:"operation"` // contains filtered or unexported fields }
func (*Op) Descriptor
deprecated
added in
v0.8.1
func (*Op) GetOperation ¶ added in v0.8.1
func (m *Op) GetOperation() isOp_Operation
func (*Op) GetRef ¶ added in v0.9.0
func (x *Op) GetRef() *ReferenceRequest
func (*Op) GetZAdd ¶ added in v0.9.0
func (x *Op) GetZAdd() *ZAddRequest
func (*Op) ProtoMessage ¶ added in v0.8.1
func (*Op) ProtoMessage()
func (*Op) ProtoReflect ¶ added in v0.9.0
func (x *Op) ProtoReflect() protoreflect.Message
type Op_Kv ¶ added in v0.9.0
type Op_Kv struct {
Kv *KeyValue `protobuf:"bytes,1,opt,name=kv,proto3,oneof"`
}
type Op_Ref ¶ added in v0.9.0
type Op_Ref struct {
Ref *ReferenceRequest `protobuf:"bytes,3,opt,name=ref,proto3,oneof"`
}
type Op_Unexpected ¶ added in v0.8.1
type Op_Unexpected struct {
// contains filtered or unexported fields
}
type Op_ZAdd ¶ added in v0.9.0
type Op_ZAdd struct {
ZAdd *ZAddRequest `protobuf:"bytes,2,opt,name=zAdd,proto3,oneof"`
}
type OpenSessionRequest ¶ added in v1.2.0
type OpenSessionRequest struct { Username []byte `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` DatabaseName string `protobuf:"bytes,3,opt,name=databaseName,proto3" json:"databaseName,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionRequest) Descriptor
deprecated
added in
v1.2.0
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.
func (*OpenSessionRequest) GetDatabaseName ¶ added in v1.2.0
func (x *OpenSessionRequest) GetDatabaseName() string
func (*OpenSessionRequest) GetPassword ¶ added in v1.2.0
func (x *OpenSessionRequest) GetPassword() []byte
func (*OpenSessionRequest) GetUsername ¶ added in v1.2.0
func (x *OpenSessionRequest) GetUsername() []byte
func (*OpenSessionRequest) ProtoMessage ¶ added in v1.2.0
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) ProtoReflect ¶ added in v1.2.0
func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
func (*OpenSessionRequest) Reset ¶ added in v1.2.0
func (x *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶ added in v1.2.0
func (x *OpenSessionRequest) String() string
type OpenSessionResponse ¶ added in v1.2.0
type OpenSessionResponse struct { SessionID string `protobuf:"bytes,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"` ServerUUID string `protobuf:"bytes,2,opt,name=serverUUID,proto3" json:"serverUUID,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionResponse) Descriptor
deprecated
added in
v1.2.0
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.
func (*OpenSessionResponse) GetServerUUID ¶ added in v1.2.0
func (x *OpenSessionResponse) GetServerUUID() string
func (*OpenSessionResponse) GetSessionID ¶ added in v1.2.0
func (x *OpenSessionResponse) GetSessionID() string
func (*OpenSessionResponse) ProtoMessage ¶ added in v1.2.0
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) ProtoReflect ¶ added in v1.2.0
func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
func (*OpenSessionResponse) Reset ¶ added in v1.2.0
func (x *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶ added in v1.2.0
func (x *OpenSessionResponse) String() string
type Permission ¶ added in v0.7.0
type Permission struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Permission uint32 `protobuf:"varint,2,opt,name=permission,proto3" json:"permission,omitempty"` // contains filtered or unexported fields }
func (*Permission) Descriptor
deprecated
added in
v0.7.0
func (*Permission) Descriptor() ([]byte, []int)
Deprecated: Use Permission.ProtoReflect.Descriptor instead.
func (*Permission) GetDatabase ¶ added in v0.7.0
func (x *Permission) GetDatabase() string
func (*Permission) GetPermission ¶ added in v0.7.0
func (x *Permission) GetPermission() uint32
func (*Permission) ProtoMessage ¶ added in v0.7.0
func (*Permission) ProtoMessage()
func (*Permission) ProtoReflect ¶ added in v0.9.0
func (x *Permission) ProtoReflect() protoreflect.Message
func (*Permission) Reset ¶ added in v0.7.0
func (x *Permission) Reset()
func (*Permission) String ¶ added in v0.7.0
func (x *Permission) String() string
type PermissionAction ¶ added in v0.7.0
type PermissionAction int32
const ( PermissionAction_GRANT PermissionAction = 0 PermissionAction_REVOKE PermissionAction = 1 )
func (PermissionAction) Descriptor ¶ added in v0.9.0
func (PermissionAction) Descriptor() protoreflect.EnumDescriptor
func (PermissionAction) Enum ¶ added in v0.9.0
func (x PermissionAction) Enum() *PermissionAction
func (PermissionAction) EnumDescriptor
deprecated
added in
v0.7.0
func (PermissionAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use PermissionAction.Descriptor instead.
func (PermissionAction) Number ¶ added in v0.9.0
func (x PermissionAction) Number() protoreflect.EnumNumber
func (PermissionAction) String ¶ added in v0.7.0
func (x PermissionAction) String() string
func (PermissionAction) Type ¶ added in v0.9.0
func (PermissionAction) Type() protoreflect.EnumType
type Precondition ¶ added in v1.2.3
type Precondition struct { // Types that are assignable to Precondition: // *Precondition_KeyMustExist // *Precondition_KeyMustNotExist // *Precondition_KeyNotModifiedAfterTX Precondition isPrecondition_Precondition `protobuf_oneof:"precondition"` // contains filtered or unexported fields }
func PreconditionKeyMustExist ¶ added in v1.2.3
func PreconditionKeyMustExist(key []byte) *Precondition
func PreconditionKeyMustNotExist ¶ added in v1.2.3
func PreconditionKeyMustNotExist(key []byte) *Precondition
func PreconditionKeyNotModifiedAfterTX ¶ added in v1.2.3
func PreconditionKeyNotModifiedAfterTX(key []byte, txID uint64) *Precondition
func (*Precondition) Descriptor
deprecated
added in
v1.2.3
func (*Precondition) Descriptor() ([]byte, []int)
Deprecated: Use Precondition.ProtoReflect.Descriptor instead.
func (*Precondition) GetKeyMustExist ¶ added in v1.2.3
func (x *Precondition) GetKeyMustExist() *Precondition_KeyMustExistPrecondition
func (*Precondition) GetKeyMustNotExist ¶ added in v1.2.3
func (x *Precondition) GetKeyMustNotExist() *Precondition_KeyMustNotExistPrecondition
func (*Precondition) GetKeyNotModifiedAfterTX ¶ added in v1.2.3
func (x *Precondition) GetKeyNotModifiedAfterTX() *Precondition_KeyNotModifiedAfterTXPrecondition
func (*Precondition) GetPrecondition ¶ added in v1.2.3
func (m *Precondition) GetPrecondition() isPrecondition_Precondition
func (*Precondition) ProtoMessage ¶ added in v1.2.3
func (*Precondition) ProtoMessage()
func (*Precondition) ProtoReflect ¶ added in v1.2.3
func (x *Precondition) ProtoReflect() protoreflect.Message
func (*Precondition) Reset ¶ added in v1.2.3
func (x *Precondition) Reset()
func (*Precondition) String ¶ added in v1.2.3
func (x *Precondition) String() string
type Precondition_KeyMustExist ¶ added in v1.2.3
type Precondition_KeyMustExist struct {
KeyMustExist *Precondition_KeyMustExistPrecondition `protobuf:"bytes,1,opt,name=keyMustExist,proto3,oneof"`
}
type Precondition_KeyMustExistPrecondition ¶ added in v1.2.3
type Precondition_KeyMustExistPrecondition struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*Precondition_KeyMustExistPrecondition) Descriptor
deprecated
added in
v1.2.3
func (*Precondition_KeyMustExistPrecondition) Descriptor() ([]byte, []int)
Deprecated: Use Precondition_KeyMustExistPrecondition.ProtoReflect.Descriptor instead.
func (*Precondition_KeyMustExistPrecondition) GetKey ¶ added in v1.2.3
func (x *Precondition_KeyMustExistPrecondition) GetKey() []byte
func (*Precondition_KeyMustExistPrecondition) ProtoMessage ¶ added in v1.2.3
func (*Precondition_KeyMustExistPrecondition) ProtoMessage()
func (*Precondition_KeyMustExistPrecondition) ProtoReflect ¶ added in v1.2.3
func (x *Precondition_KeyMustExistPrecondition) ProtoReflect() protoreflect.Message
func (*Precondition_KeyMustExistPrecondition) Reset ¶ added in v1.2.3
func (x *Precondition_KeyMustExistPrecondition) Reset()
func (*Precondition_KeyMustExistPrecondition) String ¶ added in v1.2.3
func (x *Precondition_KeyMustExistPrecondition) String() string
type Precondition_KeyMustNotExist ¶ added in v1.2.3
type Precondition_KeyMustNotExist struct {
KeyMustNotExist *Precondition_KeyMustNotExistPrecondition `protobuf:"bytes,2,opt,name=keyMustNotExist,proto3,oneof"`
}
type Precondition_KeyMustNotExistPrecondition ¶ added in v1.2.3
type Precondition_KeyMustNotExistPrecondition struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*Precondition_KeyMustNotExistPrecondition) Descriptor
deprecated
added in
v1.2.3
func (*Precondition_KeyMustNotExistPrecondition) Descriptor() ([]byte, []int)
Deprecated: Use Precondition_KeyMustNotExistPrecondition.ProtoReflect.Descriptor instead.
func (*Precondition_KeyMustNotExistPrecondition) GetKey ¶ added in v1.2.3
func (x *Precondition_KeyMustNotExistPrecondition) GetKey() []byte
func (*Precondition_KeyMustNotExistPrecondition) ProtoMessage ¶ added in v1.2.3
func (*Precondition_KeyMustNotExistPrecondition) ProtoMessage()
func (*Precondition_KeyMustNotExistPrecondition) ProtoReflect ¶ added in v1.2.3
func (x *Precondition_KeyMustNotExistPrecondition) ProtoReflect() protoreflect.Message
func (*Precondition_KeyMustNotExistPrecondition) Reset ¶ added in v1.2.3
func (x *Precondition_KeyMustNotExistPrecondition) Reset()
func (*Precondition_KeyMustNotExistPrecondition) String ¶ added in v1.2.3
func (x *Precondition_KeyMustNotExistPrecondition) String() string
type Precondition_KeyNotModifiedAfterTX ¶ added in v1.2.3
type Precondition_KeyNotModifiedAfterTX struct {
KeyNotModifiedAfterTX *Precondition_KeyNotModifiedAfterTXPrecondition `protobuf:"bytes,3,opt,name=keyNotModifiedAfterTX,proto3,oneof"`
}
type Precondition_KeyNotModifiedAfterTXPrecondition ¶ added in v1.2.3
type Precondition_KeyNotModifiedAfterTXPrecondition struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` TxID uint64 `protobuf:"varint,2,opt,name=txID,proto3" json:"txID,omitempty"` // contains filtered or unexported fields }
func (*Precondition_KeyNotModifiedAfterTXPrecondition) Descriptor
deprecated
added in
v1.2.3
func (*Precondition_KeyNotModifiedAfterTXPrecondition) Descriptor() ([]byte, []int)
Deprecated: Use Precondition_KeyNotModifiedAfterTXPrecondition.ProtoReflect.Descriptor instead.
func (*Precondition_KeyNotModifiedAfterTXPrecondition) GetKey ¶ added in v1.2.3
func (x *Precondition_KeyNotModifiedAfterTXPrecondition) GetKey() []byte
func (*Precondition_KeyNotModifiedAfterTXPrecondition) GetTxID ¶ added in v1.2.3
func (x *Precondition_KeyNotModifiedAfterTXPrecondition) GetTxID() uint64
func (*Precondition_KeyNotModifiedAfterTXPrecondition) ProtoMessage ¶ added in v1.2.3
func (*Precondition_KeyNotModifiedAfterTXPrecondition) ProtoMessage()
func (*Precondition_KeyNotModifiedAfterTXPrecondition) ProtoReflect ¶ added in v1.2.3
func (x *Precondition_KeyNotModifiedAfterTXPrecondition) ProtoReflect() protoreflect.Message
func (*Precondition_KeyNotModifiedAfterTXPrecondition) Reset ¶ added in v1.2.3
func (x *Precondition_KeyNotModifiedAfterTXPrecondition) Reset()
func (*Precondition_KeyNotModifiedAfterTXPrecondition) String ¶ added in v1.2.3
func (x *Precondition_KeyNotModifiedAfterTXPrecondition) String() string
type Reference ¶ added in v0.9.0
type Reference struct { Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"` Metadata *KVMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*Reference) Descriptor
deprecated
added in
v0.9.0
func (*Reference) GetMetadata ¶ added in v1.2.0
func (x *Reference) GetMetadata() *KVMetadata
func (*Reference) ProtoMessage ¶ added in v0.9.0
func (*Reference) ProtoMessage()
func (*Reference) ProtoReflect ¶ added in v0.9.0
func (x *Reference) ProtoReflect() protoreflect.Message
type ReferenceRequest ¶ added in v0.9.0
type ReferenceRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` ReferencedKey []byte `protobuf:"bytes,2,opt,name=referencedKey,proto3" json:"referencedKey,omitempty"` AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"` BoundRef bool `protobuf:"varint,4,opt,name=boundRef,proto3" json:"boundRef,omitempty"` NoWait bool `protobuf:"varint,5,opt,name=noWait,proto3" json:"noWait,omitempty"` Preconditions []*Precondition `protobuf:"bytes,6,rep,name=preconditions,proto3" json:"preconditions,omitempty"` // contains filtered or unexported fields }
func (*ReferenceRequest) Descriptor
deprecated
added in
v0.9.0
func (*ReferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReferenceRequest.ProtoReflect.Descriptor instead.
func (*ReferenceRequest) GetAtTx ¶ added in v0.9.0
func (x *ReferenceRequest) GetAtTx() uint64
func (*ReferenceRequest) GetBoundRef ¶ added in v0.9.1
func (x *ReferenceRequest) GetBoundRef() bool
func (*ReferenceRequest) GetKey ¶ added in v0.9.0
func (x *ReferenceRequest) GetKey() []byte
func (*ReferenceRequest) GetNoWait ¶ added in v0.9.2
func (x *ReferenceRequest) GetNoWait() bool
func (*ReferenceRequest) GetPreconditions ¶ added in v1.2.3
func (x *ReferenceRequest) GetPreconditions() []*Precondition
func (*ReferenceRequest) GetReferencedKey ¶ added in v0.9.0
func (x *ReferenceRequest) GetReferencedKey() []byte
func (*ReferenceRequest) ProtoMessage ¶ added in v0.9.0
func (*ReferenceRequest) ProtoMessage()
func (*ReferenceRequest) ProtoReflect ¶ added in v0.9.0
func (x *ReferenceRequest) ProtoReflect() protoreflect.Message
func (*ReferenceRequest) Reset ¶ added in v0.9.0
func (x *ReferenceRequest) Reset()
func (*ReferenceRequest) String ¶ added in v0.9.0
func (x *ReferenceRequest) String() string
type ReplicationNullableSettings ¶ added in v1.2.3
type ReplicationNullableSettings struct { Replica *NullableBool `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"` MasterDatabase *NullableString `protobuf:"bytes,2,opt,name=masterDatabase,proto3" json:"masterDatabase,omitempty"` MasterAddress *NullableString `protobuf:"bytes,3,opt,name=masterAddress,proto3" json:"masterAddress,omitempty"` MasterPort *NullableUint32 `protobuf:"bytes,4,opt,name=masterPort,proto3" json:"masterPort,omitempty"` FollowerUsername *NullableString `protobuf:"bytes,5,opt,name=followerUsername,proto3" json:"followerUsername,omitempty"` FollowerPassword *NullableString `protobuf:"bytes,6,opt,name=followerPassword,proto3" json:"followerPassword,omitempty"` // contains filtered or unexported fields }
func (*ReplicationNullableSettings) Descriptor
deprecated
added in
v1.2.3
func (*ReplicationNullableSettings) Descriptor() ([]byte, []int)
Deprecated: Use ReplicationNullableSettings.ProtoReflect.Descriptor instead.
func (*ReplicationNullableSettings) GetFollowerPassword ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetFollowerPassword() *NullableString
func (*ReplicationNullableSettings) GetFollowerUsername ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetFollowerUsername() *NullableString
func (*ReplicationNullableSettings) GetMasterAddress ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetMasterAddress() *NullableString
func (*ReplicationNullableSettings) GetMasterDatabase ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetMasterDatabase() *NullableString
func (*ReplicationNullableSettings) GetMasterPort ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetMasterPort() *NullableUint32
func (*ReplicationNullableSettings) GetReplica ¶ added in v1.2.3
func (x *ReplicationNullableSettings) GetReplica() *NullableBool
func (*ReplicationNullableSettings) ProtoMessage ¶ added in v1.2.3
func (*ReplicationNullableSettings) ProtoMessage()
func (*ReplicationNullableSettings) ProtoReflect ¶ added in v1.2.3
func (x *ReplicationNullableSettings) ProtoReflect() protoreflect.Message
func (*ReplicationNullableSettings) Reset ¶ added in v1.2.3
func (x *ReplicationNullableSettings) Reset()
func (*ReplicationNullableSettings) String ¶ added in v1.2.3
func (x *ReplicationNullableSettings) String() string
type RetryInfo ¶ added in v1.0.5
type RetryInfo struct { RetryDelay int32 `protobuf:"varint,1,opt,name=retry_delay,json=retryDelay,proto3" json:"retry_delay,omitempty"` // contains filtered or unexported fields }
func (*RetryInfo) Descriptor
deprecated
added in
v1.0.5
func (*RetryInfo) GetRetryDelay ¶ added in v1.0.5
func (*RetryInfo) ProtoMessage ¶ added in v1.0.5
func (*RetryInfo) ProtoMessage()
func (*RetryInfo) ProtoReflect ¶ added in v1.0.5
func (x *RetryInfo) ProtoReflect() protoreflect.Message
type Row ¶ added in v1.0.0
type Row struct { Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` Values []*SQLValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*Row) Descriptor
deprecated
added in
v1.0.0
func (*Row) GetColumns ¶ added in v1.0.0
func (*Row) ProtoMessage ¶ added in v1.0.0
func (*Row) ProtoMessage()
func (*Row) ProtoReflect ¶ added in v1.0.0
func (x *Row) ProtoReflect() protoreflect.Message
type SQLEntry ¶ added in v1.0.0
type SQLEntry struct { Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Metadata *KVMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*SQLEntry) Descriptor
deprecated
added in
v1.0.0
func (*SQLEntry) GetMetadata ¶ added in v1.2.0
func (x *SQLEntry) GetMetadata() *KVMetadata
func (*SQLEntry) ProtoMessage ¶ added in v1.0.0
func (*SQLEntry) ProtoMessage()
func (*SQLEntry) ProtoReflect ¶ added in v1.0.0
func (x *SQLEntry) ProtoReflect() protoreflect.Message
type SQLExecRequest ¶ added in v1.0.0
type SQLExecRequest struct { Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` Params []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"` NoWait bool `protobuf:"varint,3,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*SQLExecRequest) Descriptor
deprecated
added in
v1.0.0
func (*SQLExecRequest) Descriptor() ([]byte, []int)
Deprecated: Use SQLExecRequest.ProtoReflect.Descriptor instead.
func (*SQLExecRequest) GetNoWait ¶ added in v1.0.0
func (x *SQLExecRequest) GetNoWait() bool
func (*SQLExecRequest) GetParams ¶ added in v1.0.0
func (x *SQLExecRequest) GetParams() []*NamedParam
func (*SQLExecRequest) GetSql ¶ added in v1.0.0
func (x *SQLExecRequest) GetSql() string
func (*SQLExecRequest) ProtoMessage ¶ added in v1.0.0
func (*SQLExecRequest) ProtoMessage()
func (*SQLExecRequest) ProtoReflect ¶ added in v1.0.0
func (x *SQLExecRequest) ProtoReflect() protoreflect.Message
func (*SQLExecRequest) Reset ¶ added in v1.0.0
func (x *SQLExecRequest) Reset()
func (*SQLExecRequest) String ¶ added in v1.0.0
func (x *SQLExecRequest) String() string
type SQLExecResult ¶ added in v1.0.0
type SQLExecResult struct { Txs []*CommittedSQLTx `protobuf:"bytes,5,rep,name=txs,proto3" json:"txs,omitempty"` OngoingTx bool `protobuf:"varint,6,opt,name=ongoingTx,proto3" json:"ongoingTx,omitempty"` // contains filtered or unexported fields }
func (*SQLExecResult) Descriptor
deprecated
added in
v1.0.0
func (*SQLExecResult) Descriptor() ([]byte, []int)
Deprecated: Use SQLExecResult.ProtoReflect.Descriptor instead.
func (*SQLExecResult) FirstInsertedPks ¶ added in v1.2.2
func (er *SQLExecResult) FirstInsertedPks() map[string]*SQLValue
FirstInsertedPks returns a map in which the keys are the names of the tables and the values are the primary keys of the first inserted rows.
func (*SQLExecResult) GetOngoingTx ¶ added in v1.2.0
func (x *SQLExecResult) GetOngoingTx() bool
func (*SQLExecResult) GetTxs ¶ added in v1.2.0
func (x *SQLExecResult) GetTxs() []*CommittedSQLTx
func (*SQLExecResult) LastInsertedPk ¶ added in v1.2.2
func (er *SQLExecResult) LastInsertedPk() map[string]*SQLValue
LastInsertedPk returns a map in which the keys are the names of the tables and the values are the primary keys of the last inserted rows.
func (*SQLExecResult) ProtoMessage ¶ added in v1.0.0
func (*SQLExecResult) ProtoMessage()
func (*SQLExecResult) ProtoReflect ¶ added in v1.0.0
func (x *SQLExecResult) ProtoReflect() protoreflect.Message
func (*SQLExecResult) Reset ¶ added in v1.0.0
func (x *SQLExecResult) Reset()
func (*SQLExecResult) String ¶ added in v1.0.0
func (x *SQLExecResult) String() string
type SQLGetRequest ¶ added in v1.0.0
type SQLGetRequest struct { Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` PkValues []*SQLValue `protobuf:"bytes,2,rep,name=pkValues,proto3" json:"pkValues,omitempty"` AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"` SinceTx uint64 `protobuf:"varint,4,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` // contains filtered or unexported fields }
func (*SQLGetRequest) Descriptor
deprecated
added in
v1.0.0
func (*SQLGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SQLGetRequest.ProtoReflect.Descriptor instead.
func (*SQLGetRequest) GetAtTx ¶ added in v1.0.0
func (x *SQLGetRequest) GetAtTx() uint64
func (*SQLGetRequest) GetPkValues ¶ added in v1.1.0
func (x *SQLGetRequest) GetPkValues() []*SQLValue
func (*SQLGetRequest) GetSinceTx ¶ added in v1.0.0
func (x *SQLGetRequest) GetSinceTx() uint64
func (*SQLGetRequest) GetTable ¶ added in v1.0.0
func (x *SQLGetRequest) GetTable() string
func (*SQLGetRequest) ProtoMessage ¶ added in v1.0.0
func (*SQLGetRequest) ProtoMessage()
func (*SQLGetRequest) ProtoReflect ¶ added in v1.0.0
func (x *SQLGetRequest) ProtoReflect() protoreflect.Message
func (*SQLGetRequest) Reset ¶ added in v1.0.0
func (x *SQLGetRequest) Reset()
func (*SQLGetRequest) String ¶ added in v1.0.0
func (x *SQLGetRequest) String() string
type SQLQueryRequest ¶ added in v1.0.0
type SQLQueryRequest struct { Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` Params []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"` ReuseSnapshot bool `protobuf:"varint,3,opt,name=reuseSnapshot,proto3" json:"reuseSnapshot,omitempty"` // contains filtered or unexported fields }
func (*SQLQueryRequest) Descriptor
deprecated
added in
v1.0.0
func (*SQLQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use SQLQueryRequest.ProtoReflect.Descriptor instead.
func (*SQLQueryRequest) GetParams ¶ added in v1.0.0
func (x *SQLQueryRequest) GetParams() []*NamedParam
func (*SQLQueryRequest) GetReuseSnapshot ¶ added in v1.0.0
func (x *SQLQueryRequest) GetReuseSnapshot() bool
func (*SQLQueryRequest) GetSql ¶ added in v1.0.0
func (x *SQLQueryRequest) GetSql() string
func (*SQLQueryRequest) ProtoMessage ¶ added in v1.0.0
func (*SQLQueryRequest) ProtoMessage()
func (*SQLQueryRequest) ProtoReflect ¶ added in v1.0.0
func (x *SQLQueryRequest) ProtoReflect() protoreflect.Message
func (*SQLQueryRequest) Reset ¶ added in v1.0.0
func (x *SQLQueryRequest) Reset()
func (*SQLQueryRequest) String ¶ added in v1.0.0
func (x *SQLQueryRequest) String() string
type SQLQueryResult ¶ added in v1.0.0
type SQLQueryResult struct { Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"` Rows []*Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*SQLQueryResult) Descriptor
deprecated
added in
v1.0.0
func (*SQLQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use SQLQueryResult.ProtoReflect.Descriptor instead.
func (*SQLQueryResult) GetColumns ¶ added in v1.0.0
func (x *SQLQueryResult) GetColumns() []*Column
func (*SQLQueryResult) GetRows ¶ added in v1.0.0
func (x *SQLQueryResult) GetRows() []*Row
func (*SQLQueryResult) ProtoMessage ¶ added in v1.0.0
func (*SQLQueryResult) ProtoMessage()
func (*SQLQueryResult) ProtoReflect ¶ added in v1.0.0
func (x *SQLQueryResult) ProtoReflect() protoreflect.Message
func (*SQLQueryResult) Reset ¶ added in v1.0.0
func (x *SQLQueryResult) Reset()
func (*SQLQueryResult) String ¶ added in v1.0.0
func (x *SQLQueryResult) String() string
type SQLValue ¶ added in v1.0.0
type SQLValue struct { // Types that are assignable to Value: // *SQLValue_Null // *SQLValue_N // *SQLValue_S // *SQLValue_B // *SQLValue_Bs // *SQLValue_Ts Value isSQLValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*SQLValue) Descriptor
deprecated
added in
v1.0.0
func (*SQLValue) ProtoMessage ¶ added in v1.0.0
func (*SQLValue) ProtoMessage()
func (*SQLValue) ProtoReflect ¶ added in v1.0.0
func (x *SQLValue) ProtoReflect() protoreflect.Message
type SQLValue_B ¶ added in v1.0.0
type SQLValue_B struct {
B bool `protobuf:"varint,4,opt,name=b,proto3,oneof"`
}
type SQLValue_Bs ¶ added in v1.0.0
type SQLValue_Bs struct {
Bs []byte `protobuf:"bytes,5,opt,name=bs,proto3,oneof"`
}
type SQLValue_N ¶ added in v1.0.0
type SQLValue_N struct {
N int64 `protobuf:"varint,2,opt,name=n,proto3,oneof"`
}
type SQLValue_Null ¶ added in v1.0.0
type SQLValue_S ¶ added in v1.0.0
type SQLValue_S struct {
S string `protobuf:"bytes,3,opt,name=s,proto3,oneof"`
}
type SQLValue_Ts ¶ added in v1.2.0
type SQLValue_Ts struct {
Ts int64 `protobuf:"varint,6,opt,name=ts,proto3,oneof"`
}
type ScanRequest ¶ added in v0.9.0
type ScanRequest struct { SeekKey []byte `protobuf:"bytes,1,opt,name=seekKey,proto3" json:"seekKey,omitempty"` Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"` Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*ScanRequest) Descriptor
deprecated
added in
v0.9.0
func (*ScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.
func (*ScanRequest) GetDesc ¶ added in v0.9.0
func (x *ScanRequest) GetDesc() bool
func (*ScanRequest) GetLimit ¶ added in v0.9.0
func (x *ScanRequest) GetLimit() uint64
func (*ScanRequest) GetNoWait ¶ added in v0.9.0
func (x *ScanRequest) GetNoWait() bool
func (*ScanRequest) GetPrefix ¶ added in v0.9.0
func (x *ScanRequest) GetPrefix() []byte
func (*ScanRequest) GetSeekKey ¶ added in v0.9.0
func (x *ScanRequest) GetSeekKey() []byte
func (*ScanRequest) GetSinceTx ¶ added in v0.9.0
func (x *ScanRequest) GetSinceTx() uint64
func (*ScanRequest) ProtoMessage ¶ added in v0.9.0
func (*ScanRequest) ProtoMessage()
func (*ScanRequest) ProtoReflect ¶ added in v0.9.0
func (x *ScanRequest) ProtoReflect() protoreflect.Message
func (*ScanRequest) Reset ¶ added in v0.9.0
func (x *ScanRequest) Reset()
func (*ScanRequest) String ¶ added in v0.9.0
func (x *ScanRequest) String() string
type Score ¶ added in v0.8.1
type Score struct { Score float64 `protobuf:"fixed64,1,opt,name=score,proto3" json:"score,omitempty"` // contains filtered or unexported fields }
func (*Score) Descriptor
deprecated
added in
v0.8.1
func (*Score) ProtoMessage ¶ added in v0.8.1
func (*Score) ProtoMessage()
func (*Score) ProtoReflect ¶ added in v0.9.0
func (x *Score) ProtoReflect() protoreflect.Message
type SetActiveUserRequest ¶ added in v0.7.0
type SetActiveUserRequest struct { Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` // contains filtered or unexported fields }
func (*SetActiveUserRequest) Descriptor
deprecated
added in
v0.7.0
func (*SetActiveUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetActiveUserRequest.ProtoReflect.Descriptor instead.
func (*SetActiveUserRequest) GetActive ¶ added in v0.7.0
func (x *SetActiveUserRequest) GetActive() bool
func (*SetActiveUserRequest) GetUsername ¶ added in v0.7.0
func (x *SetActiveUserRequest) GetUsername() string
func (*SetActiveUserRequest) ProtoMessage ¶ added in v0.7.0
func (*SetActiveUserRequest) ProtoMessage()
func (*SetActiveUserRequest) ProtoReflect ¶ added in v0.9.0
func (x *SetActiveUserRequest) ProtoReflect() protoreflect.Message
func (*SetActiveUserRequest) Reset ¶ added in v0.7.0
func (x *SetActiveUserRequest) Reset()
func (*SetActiveUserRequest) String ¶ added in v0.7.0
func (x *SetActiveUserRequest) String() string
type SetRequest ¶ added in v0.9.0
type SetRequest struct { KVs []*KeyValue `protobuf:"bytes,1,rep,name=KVs,proto3" json:"KVs,omitempty"` NoWait bool `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"` Preconditions []*Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions,omitempty"` // contains filtered or unexported fields }
func (*SetRequest) Descriptor
deprecated
added in
v0.9.0
func (*SetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.
func (*SetRequest) GetKVs ¶ added in v0.9.0
func (x *SetRequest) GetKVs() []*KeyValue
func (*SetRequest) GetNoWait ¶ added in v0.9.2
func (x *SetRequest) GetNoWait() bool
func (*SetRequest) GetPreconditions ¶ added in v1.2.3
func (x *SetRequest) GetPreconditions() []*Precondition
func (*SetRequest) ProtoMessage ¶ added in v0.9.0
func (*SetRequest) ProtoMessage()
func (*SetRequest) ProtoReflect ¶ added in v0.9.0
func (x *SetRequest) ProtoReflect() protoreflect.Message
func (*SetRequest) Reset ¶ added in v0.9.0
func (x *SetRequest) Reset()
func (*SetRequest) String ¶ added in v0.9.0
func (x *SetRequest) String() string
type Signature ¶ added in v0.8.0
type Signature struct { PublicKey []byte `protobuf:"bytes,1,opt,name=publicKey,proto3" json:"publicKey,omitempty"` Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*Signature) Descriptor
deprecated
added in
v0.8.0
func (*Signature) GetPublicKey ¶ added in v0.8.0
func (*Signature) GetSignature ¶ added in v0.8.0
func (*Signature) ProtoMessage ¶ added in v0.8.0
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶ added in v0.9.0
func (x *Signature) ProtoReflect() protoreflect.Message
type Table ¶ added in v1.0.0
type Table struct { TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"` // contains filtered or unexported fields }
func (*Table) Descriptor
deprecated
added in
v1.0.0
func (*Table) GetTableName ¶ added in v1.0.0
func (*Table) ProtoMessage ¶ added in v1.0.0
func (*Table) ProtoMessage()
func (*Table) ProtoReflect ¶ added in v1.0.0
func (x *Table) ProtoReflect() protoreflect.Message
type Tx ¶ added in v0.9.0
type Tx struct { Header *TxHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Entries []*TxEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"` KvEntries []*Entry `protobuf:"bytes,3,rep,name=kvEntries,proto3" json:"kvEntries,omitempty"` ZEntries []*ZEntry `protobuf:"bytes,4,rep,name=zEntries,proto3" json:"zEntries,omitempty"` // contains filtered or unexported fields }
func (*Tx) Descriptor
deprecated
added in
v0.9.0
func (*Tx) GetEntries ¶ added in v0.9.0
func (*Tx) GetKvEntries ¶ added in v1.2.3
func (*Tx) GetZEntries ¶ added in v1.2.3
func (*Tx) ProtoMessage ¶ added in v0.9.0
func (*Tx) ProtoMessage()
func (*Tx) ProtoReflect ¶ added in v0.9.0
func (x *Tx) ProtoReflect() protoreflect.Message
type TxEntry ¶ added in v0.9.0
type TxEntry struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` HValue []byte `protobuf:"bytes,2,opt,name=hValue,proto3" json:"hValue,omitempty"` VLen int32 `protobuf:"varint,3,opt,name=vLen,proto3" json:"vLen,omitempty"` Metadata *KVMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` // value must be ignored when len(value) == 0 and vLen > 0. Otherwise, sha256(value) must be equal to hValue // contains filtered or unexported fields }
func TxEntryToProto ¶ added in v1.2.3
func (*TxEntry) Descriptor
deprecated
added in
v0.9.0
func (*TxEntry) GetMetadata ¶ added in v1.2.0
func (x *TxEntry) GetMetadata() *KVMetadata
func (*TxEntry) ProtoMessage ¶ added in v0.9.0
func (*TxEntry) ProtoMessage()
func (*TxEntry) ProtoReflect ¶ added in v0.9.0
func (x *TxEntry) ProtoReflect() protoreflect.Message
type TxHeader ¶ added in v1.2.0
type TxHeader struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` PrevAlh []byte `protobuf:"bytes,2,opt,name=prevAlh,proto3" json:"prevAlh,omitempty"` Ts int64 `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"` Nentries int32 `protobuf:"varint,4,opt,name=nentries,proto3" json:"nentries,omitempty"` EH []byte `protobuf:"bytes,5,opt,name=eH,proto3" json:"eH,omitempty"` BlTxId uint64 `protobuf:"varint,6,opt,name=blTxId,proto3" json:"blTxId,omitempty"` BlRoot []byte `protobuf:"bytes,7,opt,name=blRoot,proto3" json:"blRoot,omitempty"` Version int32 `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"` Metadata *TxMetadata `protobuf:"bytes,9,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func TxHeaderToProto ¶ added in v1.2.0
func (*TxHeader) Descriptor
deprecated
added in
v1.2.0
func (*TxHeader) GetMetadata ¶ added in v1.2.0
func (x *TxHeader) GetMetadata() *TxMetadata
func (*TxHeader) GetNentries ¶ added in v1.2.0
func (*TxHeader) GetPrevAlh ¶ added in v1.2.0
func (*TxHeader) GetVersion ¶ added in v1.2.0
func (*TxHeader) ProtoMessage ¶ added in v1.2.0
func (*TxHeader) ProtoMessage()
func (*TxHeader) ProtoReflect ¶ added in v1.2.0
func (x *TxHeader) ProtoReflect() protoreflect.Message
type TxList ¶ added in v0.9.1
type TxList struct { Txs []*Tx `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"` // contains filtered or unexported fields }
func (*TxList) Descriptor
deprecated
added in
v0.9.1
func (*TxList) ProtoMessage ¶ added in v0.9.1
func (*TxList) ProtoMessage()
func (*TxList) ProtoReflect ¶ added in v0.9.1
func (x *TxList) ProtoReflect() protoreflect.Message
type TxMetadata ¶ added in v0.9.0
type TxMetadata struct {
// contains filtered or unexported fields
}
func TxMetadataToProto ¶ added in v1.2.0
func TxMetadataToProto(md *store.TxMetadata) *TxMetadata
func (*TxMetadata) Descriptor
deprecated
added in
v0.9.0
func (*TxMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TxMetadata.ProtoReflect.Descriptor instead.
func (*TxMetadata) ProtoMessage ¶ added in v0.9.0
func (*TxMetadata) ProtoMessage()
func (*TxMetadata) ProtoReflect ¶ added in v0.9.0
func (x *TxMetadata) ProtoReflect() protoreflect.Message
func (*TxMetadata) Reset ¶ added in v0.9.0
func (x *TxMetadata) Reset()
func (*TxMetadata) String ¶ added in v0.9.0
func (x *TxMetadata) String() string
type TxMode ¶ added in v1.2.0
type TxMode int32
func (TxMode) Descriptor ¶ added in v1.2.0
func (TxMode) Descriptor() protoreflect.EnumDescriptor
func (TxMode) EnumDescriptor
deprecated
added in
v1.2.0
func (TxMode) Number ¶ added in v1.2.0
func (x TxMode) Number() protoreflect.EnumNumber
func (TxMode) Type ¶ added in v1.2.0
func (TxMode) Type() protoreflect.EnumType
type TxRequest ¶ added in v0.9.0
type TxRequest struct { Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"` EntriesSpec *EntriesSpec `protobuf:"bytes,2,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"` SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,4,opt,name=noWait,proto3" json:"noWait,omitempty"` KeepReferencesUnresolved bool `protobuf:"varint,5,opt,name=keepReferencesUnresolved,proto3" json:"keepReferencesUnresolved,omitempty"` // contains filtered or unexported fields }
func (*TxRequest) Descriptor
deprecated
added in
v0.9.0
func (*TxRequest) GetEntriesSpec ¶ added in v1.2.3
func (x *TxRequest) GetEntriesSpec() *EntriesSpec
func (*TxRequest) GetKeepReferencesUnresolved ¶ added in v1.2.4
func (*TxRequest) GetSinceTx ¶ added in v1.2.3
func (*TxRequest) ProtoMessage ¶ added in v0.9.0
func (*TxRequest) ProtoMessage()
func (*TxRequest) ProtoReflect ¶ added in v0.9.0
func (x *TxRequest) ProtoReflect() protoreflect.Message
type TxScanRequest ¶ added in v0.9.1
type TxScanRequest struct { InitialTx uint64 `protobuf:"varint,1,opt,name=initialTx,proto3" json:"initialTx,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"` EntriesSpec *EntriesSpec `protobuf:"bytes,4,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"` SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*TxScanRequest) Descriptor
deprecated
added in
v0.9.1
func (*TxScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use TxScanRequest.ProtoReflect.Descriptor instead.
func (*TxScanRequest) GetDesc ¶ added in v0.9.1
func (x *TxScanRequest) GetDesc() bool
func (*TxScanRequest) GetEntriesSpec ¶ added in v1.2.3
func (x *TxScanRequest) GetEntriesSpec() *EntriesSpec
func (*TxScanRequest) GetInitialTx ¶ added in v0.9.1
func (x *TxScanRequest) GetInitialTx() uint64
func (*TxScanRequest) GetLimit ¶ added in v0.9.1
func (x *TxScanRequest) GetLimit() uint32
func (*TxScanRequest) GetNoWait ¶ added in v1.2.3
func (x *TxScanRequest) GetNoWait() bool
func (*TxScanRequest) GetSinceTx ¶ added in v1.2.3
func (x *TxScanRequest) GetSinceTx() uint64
func (*TxScanRequest) ProtoMessage ¶ added in v0.9.1
func (*TxScanRequest) ProtoMessage()
func (*TxScanRequest) ProtoReflect ¶ added in v0.9.1
func (x *TxScanRequest) ProtoReflect() protoreflect.Message
func (*TxScanRequest) Reset ¶ added in v0.9.1
func (x *TxScanRequest) Reset()
func (*TxScanRequest) String ¶ added in v0.9.1
func (x *TxScanRequest) String() string
type UnimplementedImmuServiceServer ¶
type UnimplementedImmuServiceServer struct { }
UnimplementedImmuServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedImmuServiceServer) ChangePassword ¶
func (*UnimplementedImmuServiceServer) ChangePassword(context.Context, *ChangePasswordRequest) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) ChangePermission ¶ added in v0.7.0
func (*UnimplementedImmuServiceServer) ChangePermission(context.Context, *ChangePermissionRequest) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) CloseSession ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) Commit ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) Commit(context.Context, *empty.Empty) (*CommittedSQLTx, error)
func (*UnimplementedImmuServiceServer) CompactIndex ¶ added in v1.0.5
func (*UnimplementedImmuServiceServer) Count ¶
func (*UnimplementedImmuServiceServer) Count(context.Context, *KeyPrefix) (*EntryCount, error)
func (*UnimplementedImmuServiceServer) CountAll ¶ added in v0.8.1
func (*UnimplementedImmuServiceServer) CountAll(context.Context, *empty.Empty) (*EntryCount, error)
func (*UnimplementedImmuServiceServer) CreateDatabase ¶ added in v0.7.0
func (*UnimplementedImmuServiceServer) CreateDatabaseV2 ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) CreateDatabaseV2(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
func (*UnimplementedImmuServiceServer) CreateDatabaseWith ¶ added in v1.0.5
func (*UnimplementedImmuServiceServer) CreateDatabaseWith(context.Context, *DatabaseSettings) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) CreateUser ¶
func (*UnimplementedImmuServiceServer) CreateUser(context.Context, *CreateUserRequest) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) CurrentState ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) CurrentState(context.Context, *empty.Empty) (*ImmutableState, error)
func (*UnimplementedImmuServiceServer) DatabaseHealth ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) DatabaseHealth(context.Context, *empty.Empty) (*DatabaseHealthResponse, error)
func (*UnimplementedImmuServiceServer) DatabaseList ¶ added in v0.7.0
func (*UnimplementedImmuServiceServer) DatabaseList(context.Context, *empty.Empty) (*DatabaseListResponse, error)
func (*UnimplementedImmuServiceServer) DatabaseListV2 ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) DatabaseListV2(context.Context, *DatabaseListRequestV2) (*DatabaseListResponseV2, error)
func (*UnimplementedImmuServiceServer) Delete ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) Delete(context.Context, *DeleteKeysRequest) (*TxHeader, error)
func (*UnimplementedImmuServiceServer) DeleteDatabase ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
func (*UnimplementedImmuServiceServer) DescribeTable ¶ added in v1.0.0
func (*UnimplementedImmuServiceServer) DescribeTable(context.Context, *Table) (*SQLQueryResult, error)
func (*UnimplementedImmuServiceServer) ExecAll ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) ExecAll(context.Context, *ExecAllRequest) (*TxHeader, error)
func (*UnimplementedImmuServiceServer) ExportTx ¶ added in v1.0.5
func (*UnimplementedImmuServiceServer) ExportTx(*ExportTxRequest, ImmuService_ExportTxServer) error
func (*UnimplementedImmuServiceServer) FlushIndex ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) FlushIndex(context.Context, *FlushIndexRequest) (*FlushIndexResponse, error)
func (*UnimplementedImmuServiceServer) Get ¶
func (*UnimplementedImmuServiceServer) Get(context.Context, *KeyRequest) (*Entry, error)
func (*UnimplementedImmuServiceServer) GetAll ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) GetAll(context.Context, *KeyListRequest) (*Entries, error)
func (*UnimplementedImmuServiceServer) GetDatabaseSettings ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) GetDatabaseSettings(context.Context, *empty.Empty) (*DatabaseSettings, error)
func (*UnimplementedImmuServiceServer) GetDatabaseSettingsV2 ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) GetDatabaseSettingsV2(context.Context, *DatabaseSettingsRequest) (*DatabaseSettingsResponse, error)
func (*UnimplementedImmuServiceServer) Health ¶
func (*UnimplementedImmuServiceServer) Health(context.Context, *empty.Empty) (*HealthResponse, error)
func (*UnimplementedImmuServiceServer) History ¶
func (*UnimplementedImmuServiceServer) History(context.Context, *HistoryRequest) (*Entries, error)
func (*UnimplementedImmuServiceServer) ListTables ¶ added in v1.0.0
func (*UnimplementedImmuServiceServer) ListTables(context.Context, *empty.Empty) (*SQLQueryResult, error)
func (*UnimplementedImmuServiceServer) LoadDatabase ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) LoadDatabase(context.Context, *LoadDatabaseRequest) (*LoadDatabaseResponse, error)
func (*UnimplementedImmuServiceServer) Login ¶
func (*UnimplementedImmuServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
func (*UnimplementedImmuServiceServer) NewTx ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) NewTx(context.Context, *NewTxRequest) (*NewTxResponse, error)
func (*UnimplementedImmuServiceServer) OpenSession ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
func (*UnimplementedImmuServiceServer) ReplicateTx ¶ added in v1.0.5
func (*UnimplementedImmuServiceServer) ReplicateTx(ImmuService_ReplicateTxServer) error
func (*UnimplementedImmuServiceServer) SQLExec ¶ added in v1.0.0
func (*UnimplementedImmuServiceServer) SQLExec(context.Context, *SQLExecRequest) (*SQLExecResult, error)
func (*UnimplementedImmuServiceServer) SQLQuery ¶ added in v1.0.0
func (*UnimplementedImmuServiceServer) SQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
func (*UnimplementedImmuServiceServer) Scan ¶
func (*UnimplementedImmuServiceServer) Scan(context.Context, *ScanRequest) (*Entries, error)
func (*UnimplementedImmuServiceServer) Set ¶
func (*UnimplementedImmuServiceServer) Set(context.Context, *SetRequest) (*TxHeader, error)
func (*UnimplementedImmuServiceServer) SetActiveUser ¶ added in v0.7.0
func (*UnimplementedImmuServiceServer) SetActiveUser(context.Context, *SetActiveUserRequest) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) SetReference ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) SetReference(context.Context, *ReferenceRequest) (*TxHeader, error)
func (*UnimplementedImmuServiceServer) StreamExecAll ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamExecAll(ImmuService_StreamExecAllServer) error
func (*UnimplementedImmuServiceServer) StreamGet ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamGet(*KeyRequest, ImmuService_StreamGetServer) error
func (*UnimplementedImmuServiceServer) StreamHistory ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamHistory(*HistoryRequest, ImmuService_StreamHistoryServer) error
func (*UnimplementedImmuServiceServer) StreamScan ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamScan(*ScanRequest, ImmuService_StreamScanServer) error
func (*UnimplementedImmuServiceServer) StreamSet ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamSet(ImmuService_StreamSetServer) error
func (*UnimplementedImmuServiceServer) StreamVerifiableGet ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamVerifiableGet(*VerifiableGetRequest, ImmuService_StreamVerifiableGetServer) error
func (*UnimplementedImmuServiceServer) StreamVerifiableSet ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamVerifiableSet(ImmuService_StreamVerifiableSetServer) error
func (*UnimplementedImmuServiceServer) StreamZScan ¶ added in v0.9.2
func (*UnimplementedImmuServiceServer) StreamZScan(*ZScanRequest, ImmuService_StreamZScanServer) error
func (*UnimplementedImmuServiceServer) TxSQLExec ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) TxSQLExec(context.Context, *SQLExecRequest) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) TxSQLQuery ¶ added in v1.2.0
func (*UnimplementedImmuServiceServer) TxSQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
func (*UnimplementedImmuServiceServer) TxScan ¶ added in v0.9.1
func (*UnimplementedImmuServiceServer) TxScan(context.Context, *TxScanRequest) (*TxList, error)
func (*UnimplementedImmuServiceServer) UnloadDatabase ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) UnloadDatabase(context.Context, *UnloadDatabaseRequest) (*UnloadDatabaseResponse, error)
func (*UnimplementedImmuServiceServer) UpdateAuthConfig ¶
func (*UnimplementedImmuServiceServer) UpdateAuthConfig(context.Context, *AuthConfig) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) UpdateDatabase ¶ added in v1.0.5
func (*UnimplementedImmuServiceServer) UpdateDatabase(context.Context, *DatabaseSettings) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) UpdateDatabaseV2 ¶ added in v1.2.3
func (*UnimplementedImmuServiceServer) UpdateDatabaseV2(context.Context, *UpdateDatabaseRequest) (*UpdateDatabaseResponse, error)
func (*UnimplementedImmuServiceServer) UpdateMTLSConfig ¶
func (*UnimplementedImmuServiceServer) UpdateMTLSConfig(context.Context, *MTLSConfig) (*empty.Empty, error)
func (*UnimplementedImmuServiceServer) UseDatabase ¶ added in v0.7.0
func (*UnimplementedImmuServiceServer) UseDatabase(context.Context, *Database) (*UseDatabaseReply, error)
func (*UnimplementedImmuServiceServer) VerifiableGet ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) VerifiableGet(context.Context, *VerifiableGetRequest) (*VerifiableEntry, error)
func (*UnimplementedImmuServiceServer) VerifiableSQLGet ¶ added in v1.0.0
func (*UnimplementedImmuServiceServer) VerifiableSQLGet(context.Context, *VerifiableSQLGetRequest) (*VerifiableSQLEntry, error)
func (*UnimplementedImmuServiceServer) VerifiableSet ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) VerifiableSet(context.Context, *VerifiableSetRequest) (*VerifiableTx, error)
func (*UnimplementedImmuServiceServer) VerifiableSetReference ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) VerifiableSetReference(context.Context, *VerifiableReferenceRequest) (*VerifiableTx, error)
func (*UnimplementedImmuServiceServer) VerifiableTxById ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) VerifiableTxById(context.Context, *VerifiableTxRequest) (*VerifiableTx, error)
func (*UnimplementedImmuServiceServer) VerifiableZAdd ¶ added in v0.9.0
func (*UnimplementedImmuServiceServer) VerifiableZAdd(context.Context, *VerifiableZAddRequest) (*VerifiableTx, error)
func (*UnimplementedImmuServiceServer) ZAdd ¶
func (*UnimplementedImmuServiceServer) ZAdd(context.Context, *ZAddRequest) (*TxHeader, error)
func (*UnimplementedImmuServiceServer) ZScan ¶
func (*UnimplementedImmuServiceServer) ZScan(context.Context, *ZScanRequest) (*ZEntries, error)
type UnloadDatabaseRequest ¶ added in v1.2.3
type UnloadDatabaseRequest struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // contains filtered or unexported fields }
func (*UnloadDatabaseRequest) Descriptor
deprecated
added in
v1.2.3
func (*UnloadDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnloadDatabaseRequest.ProtoReflect.Descriptor instead.
func (*UnloadDatabaseRequest) GetDatabase ¶ added in v1.2.3
func (x *UnloadDatabaseRequest) GetDatabase() string
func (*UnloadDatabaseRequest) ProtoMessage ¶ added in v1.2.3
func (*UnloadDatabaseRequest) ProtoMessage()
func (*UnloadDatabaseRequest) ProtoReflect ¶ added in v1.2.3
func (x *UnloadDatabaseRequest) ProtoReflect() protoreflect.Message
func (*UnloadDatabaseRequest) Reset ¶ added in v1.2.3
func (x *UnloadDatabaseRequest) Reset()
func (*UnloadDatabaseRequest) String ¶ added in v1.2.3
func (x *UnloadDatabaseRequest) String() string
type UnloadDatabaseResponse ¶ added in v1.2.3
type UnloadDatabaseResponse struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // contains filtered or unexported fields }
func (*UnloadDatabaseResponse) Descriptor
deprecated
added in
v1.2.3
func (*UnloadDatabaseResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnloadDatabaseResponse.ProtoReflect.Descriptor instead.
func (*UnloadDatabaseResponse) GetDatabase ¶ added in v1.2.3
func (x *UnloadDatabaseResponse) GetDatabase() string
func (*UnloadDatabaseResponse) ProtoMessage ¶ added in v1.2.3
func (*UnloadDatabaseResponse) ProtoMessage()
func (*UnloadDatabaseResponse) ProtoReflect ¶ added in v1.2.3
func (x *UnloadDatabaseResponse) ProtoReflect() protoreflect.Message
func (*UnloadDatabaseResponse) Reset ¶ added in v1.2.3
func (x *UnloadDatabaseResponse) Reset()
func (*UnloadDatabaseResponse) String ¶ added in v1.2.3
func (x *UnloadDatabaseResponse) String() string
type UpdateDatabaseRequest ¶ added in v1.2.3
type UpdateDatabaseRequest 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 (*UpdateDatabaseRequest) Descriptor
deprecated
added in
v1.2.3
func (*UpdateDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDatabaseRequest.ProtoReflect.Descriptor instead.
func (*UpdateDatabaseRequest) GetDatabase ¶ added in v1.2.3
func (x *UpdateDatabaseRequest) GetDatabase() string
func (*UpdateDatabaseRequest) GetSettings ¶ added in v1.2.3
func (x *UpdateDatabaseRequest) GetSettings() *DatabaseNullableSettings
func (*UpdateDatabaseRequest) ProtoMessage ¶ added in v1.2.3
func (*UpdateDatabaseRequest) ProtoMessage()
func (*UpdateDatabaseRequest) ProtoReflect ¶ added in v1.2.3
func (x *UpdateDatabaseRequest) ProtoReflect() protoreflect.Message
func (*UpdateDatabaseRequest) Reset ¶ added in v1.2.3
func (x *UpdateDatabaseRequest) Reset()
func (*UpdateDatabaseRequest) String ¶ added in v1.2.3
func (x *UpdateDatabaseRequest) String() string
type UpdateDatabaseResponse ¶ added in v1.2.3
type UpdateDatabaseResponse 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 (*UpdateDatabaseResponse) Descriptor
deprecated
added in
v1.2.3
func (*UpdateDatabaseResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDatabaseResponse.ProtoReflect.Descriptor instead.
func (*UpdateDatabaseResponse) GetDatabase ¶ added in v1.2.3
func (x *UpdateDatabaseResponse) GetDatabase() string
func (*UpdateDatabaseResponse) GetSettings ¶ added in v1.2.3
func (x *UpdateDatabaseResponse) GetSettings() *DatabaseNullableSettings
func (*UpdateDatabaseResponse) ProtoMessage ¶ added in v1.2.3
func (*UpdateDatabaseResponse) ProtoMessage()
func (*UpdateDatabaseResponse) ProtoReflect ¶ added in v1.2.3
func (x *UpdateDatabaseResponse) ProtoReflect() protoreflect.Message
func (*UpdateDatabaseResponse) Reset ¶ added in v1.2.3
func (x *UpdateDatabaseResponse) Reset()
func (*UpdateDatabaseResponse) String ¶ added in v1.2.3
func (x *UpdateDatabaseResponse) String() string
type UseDatabaseReply ¶ added in v0.7.0
type UseDatabaseReply struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*UseDatabaseReply) Descriptor
deprecated
added in
v0.7.0
func (*UseDatabaseReply) Descriptor() ([]byte, []int)
Deprecated: Use UseDatabaseReply.ProtoReflect.Descriptor instead.
func (*UseDatabaseReply) GetToken ¶ added in v0.7.0
func (x *UseDatabaseReply) GetToken() string
func (*UseDatabaseReply) ProtoMessage ¶ added in v0.7.0
func (*UseDatabaseReply) ProtoMessage()
func (*UseDatabaseReply) ProtoReflect ¶ added in v0.9.0
func (x *UseDatabaseReply) ProtoReflect() protoreflect.Message
func (*UseDatabaseReply) Reset ¶ added in v0.7.0
func (x *UseDatabaseReply) Reset()
func (*UseDatabaseReply) String ¶ added in v0.7.0
func (x *UseDatabaseReply) String() string
type UseSnapshotRequest ¶ added in v1.0.0
type UseSnapshotRequest struct { SinceTx uint64 `protobuf:"varint,1,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` AsBeforeTx uint64 `protobuf:"varint,2,opt,name=asBeforeTx,proto3" json:"asBeforeTx,omitempty"` // contains filtered or unexported fields }
func (*UseSnapshotRequest) Descriptor
deprecated
added in
v1.0.0
func (*UseSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use UseSnapshotRequest.ProtoReflect.Descriptor instead.
func (*UseSnapshotRequest) GetAsBeforeTx ¶ added in v1.0.0
func (x *UseSnapshotRequest) GetAsBeforeTx() uint64
func (*UseSnapshotRequest) GetSinceTx ¶ added in v1.0.0
func (x *UseSnapshotRequest) GetSinceTx() uint64
func (*UseSnapshotRequest) ProtoMessage ¶ added in v1.0.0
func (*UseSnapshotRequest) ProtoMessage()
func (*UseSnapshotRequest) ProtoReflect ¶ added in v1.0.0
func (x *UseSnapshotRequest) ProtoReflect() protoreflect.Message
func (*UseSnapshotRequest) Reset ¶ added in v1.0.0
func (x *UseSnapshotRequest) Reset()
func (*UseSnapshotRequest) String ¶ added in v1.0.0
func (x *UseSnapshotRequest) String() string
type User ¶
type User struct { User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Permissions []*Permission `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"` Createdby string `protobuf:"bytes,4,opt,name=createdby,proto3" json:"createdby,omitempty"` Createdat string `protobuf:"bytes,5,opt,name=createdat,proto3" json:"createdat,omitempty"` Active bool `protobuf:"varint,6,opt,name=active,proto3" json:"active,omitempty"` // contains filtered or unexported fields }
func (*User) Descriptor
deprecated
func (*User) GetCreatedat ¶ added in v0.7.0
func (*User) GetCreatedby ¶ added in v0.7.0
func (*User) GetPermissions ¶
func (x *User) GetPermissions() []*Permission
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶ added in v0.9.0
func (x *User) ProtoReflect() protoreflect.Message
type UserList ¶
type UserList struct { Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*UserList) Descriptor
deprecated
func (*UserList) ProtoMessage ¶
func (*UserList) ProtoMessage()
func (*UserList) ProtoReflect ¶ added in v0.9.0
func (x *UserList) ProtoReflect() protoreflect.Message
type UserRequest ¶
type UserRequest struct { User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*UserRequest) Descriptor
deprecated
func (*UserRequest) Descriptor() ([]byte, []int)
Deprecated: Use UserRequest.ProtoReflect.Descriptor instead.
func (*UserRequest) GetUser ¶
func (x *UserRequest) GetUser() []byte
func (*UserRequest) ProtoMessage ¶
func (*UserRequest) ProtoMessage()
func (*UserRequest) ProtoReflect ¶ added in v0.9.0
func (x *UserRequest) ProtoReflect() protoreflect.Message
func (*UserRequest) Reset ¶
func (x *UserRequest) Reset()
func (*UserRequest) String ¶
func (x *UserRequest) String() string
type VerifiableEntry ¶ added in v0.9.0
type VerifiableEntry struct { Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"` VerifiableTx *VerifiableTx `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"` InclusionProof *InclusionProof `protobuf:"bytes,3,opt,name=inclusionProof,proto3" json:"inclusionProof,omitempty"` // contains filtered or unexported fields }
func (*VerifiableEntry) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableEntry) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableEntry.ProtoReflect.Descriptor instead.
func (*VerifiableEntry) GetEntry ¶ added in v0.9.0
func (x *VerifiableEntry) GetEntry() *Entry
func (*VerifiableEntry) GetInclusionProof ¶ added in v0.9.0
func (x *VerifiableEntry) GetInclusionProof() *InclusionProof
func (*VerifiableEntry) GetVerifiableTx ¶ added in v0.9.0
func (x *VerifiableEntry) GetVerifiableTx() *VerifiableTx
func (*VerifiableEntry) ProtoMessage ¶ added in v0.9.0
func (*VerifiableEntry) ProtoMessage()
func (*VerifiableEntry) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableEntry) ProtoReflect() protoreflect.Message
func (*VerifiableEntry) Reset ¶ added in v0.9.0
func (x *VerifiableEntry) Reset()
func (*VerifiableEntry) String ¶ added in v0.9.0
func (x *VerifiableEntry) String() string
type VerifiableGetRequest ¶ added in v0.9.0
type VerifiableGetRequest struct { KeyRequest *KeyRequest `protobuf:"bytes,1,opt,name=keyRequest,proto3" json:"keyRequest,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` // contains filtered or unexported fields }
func (*VerifiableGetRequest) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableGetRequest.ProtoReflect.Descriptor instead.
func (*VerifiableGetRequest) GetKeyRequest ¶ added in v0.9.0
func (x *VerifiableGetRequest) GetKeyRequest() *KeyRequest
func (*VerifiableGetRequest) GetProveSinceTx ¶ added in v0.9.0
func (x *VerifiableGetRequest) GetProveSinceTx() uint64
func (*VerifiableGetRequest) ProtoMessage ¶ added in v0.9.0
func (*VerifiableGetRequest) ProtoMessage()
func (*VerifiableGetRequest) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableGetRequest) ProtoReflect() protoreflect.Message
func (*VerifiableGetRequest) Reset ¶ added in v0.9.0
func (x *VerifiableGetRequest) Reset()
func (*VerifiableGetRequest) String ¶ added in v0.9.0
func (x *VerifiableGetRequest) String() string
type VerifiableReferenceRequest ¶ added in v0.9.0
type VerifiableReferenceRequest struct { ReferenceRequest *ReferenceRequest `protobuf:"bytes,1,opt,name=referenceRequest,proto3" json:"referenceRequest,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` // contains filtered or unexported fields }
func (*VerifiableReferenceRequest) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableReferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableReferenceRequest.ProtoReflect.Descriptor instead.
func (*VerifiableReferenceRequest) GetProveSinceTx ¶ added in v0.9.0
func (x *VerifiableReferenceRequest) GetProveSinceTx() uint64
func (*VerifiableReferenceRequest) GetReferenceRequest ¶ added in v0.9.0
func (x *VerifiableReferenceRequest) GetReferenceRequest() *ReferenceRequest
func (*VerifiableReferenceRequest) ProtoMessage ¶ added in v0.9.0
func (*VerifiableReferenceRequest) ProtoMessage()
func (*VerifiableReferenceRequest) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableReferenceRequest) ProtoReflect() protoreflect.Message
func (*VerifiableReferenceRequest) Reset ¶ added in v0.9.0
func (x *VerifiableReferenceRequest) Reset()
func (*VerifiableReferenceRequest) String ¶ added in v0.9.0
func (x *VerifiableReferenceRequest) String() string
type VerifiableSQLEntry ¶ added in v1.0.0
type VerifiableSQLEntry struct { SqlEntry *SQLEntry `protobuf:"bytes,1,opt,name=sqlEntry,proto3" json:"sqlEntry,omitempty"` VerifiableTx *VerifiableTx `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"` InclusionProof *InclusionProof `protobuf:"bytes,3,opt,name=inclusionProof,proto3" json:"inclusionProof,omitempty"` DatabaseId uint32 `protobuf:"varint,4,opt,name=DatabaseId,proto3" json:"DatabaseId,omitempty"` TableId uint32 `protobuf:"varint,5,opt,name=TableId,proto3" json:"TableId,omitempty"` PKIDs []uint32 `protobuf:"varint,16,rep,packed,name=PKIDs,proto3" json:"PKIDs,omitempty"` ColNamesById map[uint32]string `` /* 166-byte string literal not displayed */ ColIdsByName map[string]uint32 `` /* 166-byte string literal not displayed */ ColTypesById map[uint32]string `` /* 167-byte string literal not displayed */ ColLenById map[uint32]int32 `` /* 164-byte string literal not displayed */ // contains filtered or unexported fields }
func (*VerifiableSQLEntry) Descriptor
deprecated
added in
v1.0.0
func (*VerifiableSQLEntry) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableSQLEntry.ProtoReflect.Descriptor instead.
func (*VerifiableSQLEntry) GetColIdsByName ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetColIdsByName() map[string]uint32
func (*VerifiableSQLEntry) GetColLenById ¶ added in v1.1.0
func (x *VerifiableSQLEntry) GetColLenById() map[uint32]int32
func (*VerifiableSQLEntry) GetColNamesById ¶ added in v1.0.5
func (x *VerifiableSQLEntry) GetColNamesById() map[uint32]string
func (*VerifiableSQLEntry) GetColTypesById ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetColTypesById() map[uint32]string
func (*VerifiableSQLEntry) GetDatabaseId ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetDatabaseId() uint32
func (*VerifiableSQLEntry) GetInclusionProof ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetInclusionProof() *InclusionProof
func (*VerifiableSQLEntry) GetPKIDs ¶ added in v1.1.0
func (x *VerifiableSQLEntry) GetPKIDs() []uint32
func (*VerifiableSQLEntry) GetSqlEntry ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetSqlEntry() *SQLEntry
func (*VerifiableSQLEntry) GetTableId ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetTableId() uint32
func (*VerifiableSQLEntry) GetVerifiableTx ¶ added in v1.0.0
func (x *VerifiableSQLEntry) GetVerifiableTx() *VerifiableTx
func (*VerifiableSQLEntry) ProtoMessage ¶ added in v1.0.0
func (*VerifiableSQLEntry) ProtoMessage()
func (*VerifiableSQLEntry) ProtoReflect ¶ added in v1.0.0
func (x *VerifiableSQLEntry) ProtoReflect() protoreflect.Message
func (*VerifiableSQLEntry) Reset ¶ added in v1.0.0
func (x *VerifiableSQLEntry) Reset()
func (*VerifiableSQLEntry) String ¶ added in v1.0.0
func (x *VerifiableSQLEntry) String() string
type VerifiableSQLGetRequest ¶ added in v1.0.0
type VerifiableSQLGetRequest struct { SqlGetRequest *SQLGetRequest `protobuf:"bytes,1,opt,name=sqlGetRequest,proto3" json:"sqlGetRequest,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` // contains filtered or unexported fields }
func (*VerifiableSQLGetRequest) Descriptor
deprecated
added in
v1.0.0
func (*VerifiableSQLGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableSQLGetRequest.ProtoReflect.Descriptor instead.
func (*VerifiableSQLGetRequest) GetProveSinceTx ¶ added in v1.0.0
func (x *VerifiableSQLGetRequest) GetProveSinceTx() uint64
func (*VerifiableSQLGetRequest) GetSqlGetRequest ¶ added in v1.0.0
func (x *VerifiableSQLGetRequest) GetSqlGetRequest() *SQLGetRequest
func (*VerifiableSQLGetRequest) ProtoMessage ¶ added in v1.0.0
func (*VerifiableSQLGetRequest) ProtoMessage()
func (*VerifiableSQLGetRequest) ProtoReflect ¶ added in v1.0.0
func (x *VerifiableSQLGetRequest) ProtoReflect() protoreflect.Message
func (*VerifiableSQLGetRequest) Reset ¶ added in v1.0.0
func (x *VerifiableSQLGetRequest) Reset()
func (*VerifiableSQLGetRequest) String ¶ added in v1.0.0
func (x *VerifiableSQLGetRequest) String() string
type VerifiableSetRequest ¶ added in v0.9.0
type VerifiableSetRequest struct { SetRequest *SetRequest `protobuf:"bytes,1,opt,name=setRequest,proto3" json:"setRequest,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` // contains filtered or unexported fields }
func (*VerifiableSetRequest) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableSetRequest.ProtoReflect.Descriptor instead.
func (*VerifiableSetRequest) GetProveSinceTx ¶ added in v0.9.0
func (x *VerifiableSetRequest) GetProveSinceTx() uint64
func (*VerifiableSetRequest) GetSetRequest ¶ added in v0.9.0
func (x *VerifiableSetRequest) GetSetRequest() *SetRequest
func (*VerifiableSetRequest) ProtoMessage ¶ added in v0.9.0
func (*VerifiableSetRequest) ProtoMessage()
func (*VerifiableSetRequest) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableSetRequest) ProtoReflect() protoreflect.Message
func (*VerifiableSetRequest) Reset ¶ added in v0.9.0
func (x *VerifiableSetRequest) Reset()
func (*VerifiableSetRequest) String ¶ added in v0.9.0
func (x *VerifiableSetRequest) String() string
type VerifiableTx ¶ added in v0.9.0
type VerifiableTx struct { Tx *Tx `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"` DualProof *DualProof `protobuf:"bytes,2,opt,name=dualProof,proto3" json:"dualProof,omitempty"` Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*VerifiableTx) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableTx) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableTx.ProtoReflect.Descriptor instead.
func (*VerifiableTx) GetDualProof ¶ added in v0.9.0
func (x *VerifiableTx) GetDualProof() *DualProof
func (*VerifiableTx) GetSignature ¶ added in v0.9.0
func (x *VerifiableTx) GetSignature() *Signature
func (*VerifiableTx) GetTx ¶ added in v0.9.0
func (x *VerifiableTx) GetTx() *Tx
func (*VerifiableTx) ProtoMessage ¶ added in v0.9.0
func (*VerifiableTx) ProtoMessage()
func (*VerifiableTx) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableTx) ProtoReflect() protoreflect.Message
func (*VerifiableTx) Reset ¶ added in v0.9.0
func (x *VerifiableTx) Reset()
func (*VerifiableTx) String ¶ added in v0.9.0
func (x *VerifiableTx) String() string
type VerifiableTxRequest ¶ added in v0.9.0
type VerifiableTxRequest struct { Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` EntriesSpec *EntriesSpec `protobuf:"bytes,3,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"` SinceTx uint64 `protobuf:"varint,4,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,5,opt,name=noWait,proto3" json:"noWait,omitempty"` KeepReferencesUnresolved bool `protobuf:"varint,6,opt,name=keepReferencesUnresolved,proto3" json:"keepReferencesUnresolved,omitempty"` // contains filtered or unexported fields }
func (*VerifiableTxRequest) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableTxRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableTxRequest.ProtoReflect.Descriptor instead.
func (*VerifiableTxRequest) GetEntriesSpec ¶ added in v1.2.3
func (x *VerifiableTxRequest) GetEntriesSpec() *EntriesSpec
func (*VerifiableTxRequest) GetKeepReferencesUnresolved ¶ added in v1.2.4
func (x *VerifiableTxRequest) GetKeepReferencesUnresolved() bool
func (*VerifiableTxRequest) GetNoWait ¶ added in v1.2.3
func (x *VerifiableTxRequest) GetNoWait() bool
func (*VerifiableTxRequest) GetProveSinceTx ¶ added in v0.9.0
func (x *VerifiableTxRequest) GetProveSinceTx() uint64
func (*VerifiableTxRequest) GetSinceTx ¶ added in v1.2.3
func (x *VerifiableTxRequest) GetSinceTx() uint64
func (*VerifiableTxRequest) GetTx ¶ added in v0.9.0
func (x *VerifiableTxRequest) GetTx() uint64
func (*VerifiableTxRequest) ProtoMessage ¶ added in v0.9.0
func (*VerifiableTxRequest) ProtoMessage()
func (*VerifiableTxRequest) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableTxRequest) ProtoReflect() protoreflect.Message
func (*VerifiableTxRequest) Reset ¶ added in v0.9.0
func (x *VerifiableTxRequest) Reset()
func (*VerifiableTxRequest) String ¶ added in v0.9.0
func (x *VerifiableTxRequest) String() string
type VerifiableZAddRequest ¶ added in v0.9.0
type VerifiableZAddRequest struct { ZAddRequest *ZAddRequest `protobuf:"bytes,1,opt,name=zAddRequest,proto3" json:"zAddRequest,omitempty"` ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"` // contains filtered or unexported fields }
func (*VerifiableZAddRequest) Descriptor
deprecated
added in
v0.9.0
func (*VerifiableZAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableZAddRequest.ProtoReflect.Descriptor instead.
func (*VerifiableZAddRequest) GetProveSinceTx ¶ added in v0.9.0
func (x *VerifiableZAddRequest) GetProveSinceTx() uint64
func (*VerifiableZAddRequest) GetZAddRequest ¶ added in v0.9.0
func (x *VerifiableZAddRequest) GetZAddRequest() *ZAddRequest
func (*VerifiableZAddRequest) ProtoMessage ¶ added in v0.9.0
func (*VerifiableZAddRequest) ProtoMessage()
func (*VerifiableZAddRequest) ProtoReflect ¶ added in v0.9.0
func (x *VerifiableZAddRequest) ProtoReflect() protoreflect.Message
func (*VerifiableZAddRequest) Reset ¶ added in v0.9.0
func (x *VerifiableZAddRequest) Reset()
func (*VerifiableZAddRequest) String ¶ added in v0.9.0
func (x *VerifiableZAddRequest) String() string
type ZAddRequest ¶ added in v0.9.0
type ZAddRequest struct { Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"` Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"` Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` AtTx uint64 `protobuf:"varint,4,opt,name=atTx,proto3" json:"atTx,omitempty"` BoundRef bool `protobuf:"varint,5,opt,name=boundRef,proto3" json:"boundRef,omitempty"` NoWait bool `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*ZAddRequest) Descriptor
deprecated
added in
v0.9.0
func (*ZAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use ZAddRequest.ProtoReflect.Descriptor instead.
func (*ZAddRequest) GetAtTx ¶ added in v0.9.0
func (x *ZAddRequest) GetAtTx() uint64
func (*ZAddRequest) GetBoundRef ¶ added in v0.9.1
func (x *ZAddRequest) GetBoundRef() bool
func (*ZAddRequest) GetKey ¶ added in v0.9.0
func (x *ZAddRequest) GetKey() []byte
func (*ZAddRequest) GetNoWait ¶ added in v0.9.2
func (x *ZAddRequest) GetNoWait() bool
func (*ZAddRequest) GetScore ¶ added in v0.9.0
func (x *ZAddRequest) GetScore() float64
func (*ZAddRequest) GetSet ¶ added in v0.9.0
func (x *ZAddRequest) GetSet() []byte
func (*ZAddRequest) ProtoMessage ¶ added in v0.9.0
func (*ZAddRequest) ProtoMessage()
func (*ZAddRequest) ProtoReflect ¶ added in v0.9.0
func (x *ZAddRequest) ProtoReflect() protoreflect.Message
func (*ZAddRequest) Reset ¶ added in v0.9.0
func (x *ZAddRequest) Reset()
func (*ZAddRequest) String ¶ added in v0.9.0
func (x *ZAddRequest) String() string
type ZEntries ¶ added in v0.9.0
type ZEntries struct { Entries []*ZEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*ZEntries) Descriptor
deprecated
added in
v0.9.0
func (*ZEntries) GetEntries ¶ added in v0.9.0
func (*ZEntries) ProtoMessage ¶ added in v0.9.0
func (*ZEntries) ProtoMessage()
func (*ZEntries) ProtoReflect ¶ added in v0.9.0
func (x *ZEntries) ProtoReflect() protoreflect.Message
type ZEntry ¶ added in v0.9.0
type ZEntry struct { Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Entry *Entry `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"` Score float64 `protobuf:"fixed64,4,opt,name=score,proto3" json:"score,omitempty"` AtTx uint64 `protobuf:"varint,5,opt,name=atTx,proto3" json:"atTx,omitempty"` // contains filtered or unexported fields }
func (*ZEntry) Descriptor
deprecated
added in
v0.9.0
func (*ZEntry) ProtoMessage ¶ added in v0.9.0
func (*ZEntry) ProtoMessage()
func (*ZEntry) ProtoReflect ¶ added in v0.9.0
func (x *ZEntry) ProtoReflect() protoreflect.Message
type ZScanRequest ¶ added in v0.9.0
type ZScanRequest struct { Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"` SeekKey []byte `protobuf:"bytes,2,opt,name=seekKey,proto3" json:"seekKey,omitempty"` SeekScore float64 `protobuf:"fixed64,3,opt,name=seekScore,proto3" json:"seekScore,omitempty"` SeekAtTx uint64 `protobuf:"varint,4,opt,name=seekAtTx,proto3" json:"seekAtTx,omitempty"` InclusiveSeek bool `protobuf:"varint,5,opt,name=inclusiveSeek,proto3" json:"inclusiveSeek,omitempty"` Limit uint64 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` Desc bool `protobuf:"varint,7,opt,name=desc,proto3" json:"desc,omitempty"` MinScore *Score `protobuf:"bytes,8,opt,name=minScore,proto3" json:"minScore,omitempty"` MaxScore *Score `protobuf:"bytes,9,opt,name=maxScore,proto3" json:"maxScore,omitempty"` SinceTx uint64 `protobuf:"varint,10,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"` NoWait bool `protobuf:"varint,11,opt,name=noWait,proto3" json:"noWait,omitempty"` // contains filtered or unexported fields }
func (*ZScanRequest) Descriptor
deprecated
added in
v0.9.0
func (*ZScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ZScanRequest.ProtoReflect.Descriptor instead.
func (*ZScanRequest) GetDesc ¶ added in v0.9.0
func (x *ZScanRequest) GetDesc() bool
func (*ZScanRequest) GetInclusiveSeek ¶ added in v0.9.0
func (x *ZScanRequest) GetInclusiveSeek() bool
func (*ZScanRequest) GetLimit ¶ added in v0.9.0
func (x *ZScanRequest) GetLimit() uint64
func (*ZScanRequest) GetMaxScore ¶ added in v0.9.0
func (x *ZScanRequest) GetMaxScore() *Score
func (*ZScanRequest) GetMinScore ¶ added in v0.9.0
func (x *ZScanRequest) GetMinScore() *Score
func (*ZScanRequest) GetNoWait ¶ added in v0.9.0
func (x *ZScanRequest) GetNoWait() bool
func (*ZScanRequest) GetSeekAtTx ¶ added in v0.9.0
func (x *ZScanRequest) GetSeekAtTx() uint64
func (*ZScanRequest) GetSeekKey ¶ added in v0.9.0
func (x *ZScanRequest) GetSeekKey() []byte
func (*ZScanRequest) GetSeekScore ¶ added in v0.9.0
func (x *ZScanRequest) GetSeekScore() float64
func (*ZScanRequest) GetSet ¶ added in v0.9.0
func (x *ZScanRequest) GetSet() []byte
func (*ZScanRequest) GetSinceTx ¶ added in v0.9.0
func (x *ZScanRequest) GetSinceTx() uint64
func (*ZScanRequest) ProtoMessage ¶ added in v0.9.0
func (*ZScanRequest) ProtoMessage()
func (*ZScanRequest) ProtoReflect ¶ added in v0.9.0
func (x *ZScanRequest) ProtoReflect() protoreflect.Message
func (*ZScanRequest) Reset ¶ added in v0.9.0
func (x *ZScanRequest) Reset()
func (*ZScanRequest) String ¶ added in v0.9.0
func (x *ZScanRequest) String() string