schema

package
v1.9.0-RC1 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2023 License: Apache-2.0 Imports: 33 Imported by: 43

Documentation

Overview

Package schema is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEmptySet                         = status.New(codes.InvalidArgument, "empty set").Err()
	ErrDuplicatedKeysNotSupported       = status.New(codes.InvalidArgument, "duplicated keys are not supported in single batch transaction").Err()
	ErrDuplicatedZAddNotSupported       = status.New(codes.InvalidArgument, "duplicated index inside zAdd insertions are not supported in single batch transaction").Err()
	ErrDuplicatedReferencesNotSupported = status.New(codes.InvalidArgument, "duplicated references insertions are not supported in single batch transaction").Err()
)
View Source 
var (
	EntryTypeAction_name = map[int32]string{
		0: "EXCLUDE",
		1: "ONLY_DIGEST",
		2: "RAW_VALUE",
		3: "RESOLVE",
	}
	EntryTypeAction_value = map[string]int32{
		"EXCLUDE":     0,
		"ONLY_DIGEST": 1,
		"RAW_VALUE":   2,
		"RESOLVE":     3,
	}
)

Enum value maps for EntryTypeAction.

View Source 
var (
	PermissionAction_name = map[int32]string{
		0: "GRANT",
		1: "REVOKE",
	}
	PermissionAction_value = map[string]int32{
		"GRANT":  0,
		"REVOKE": 1,
	}
)

Enum value maps for PermissionAction.

View Source 
var (
	TxMode_name = map[int32]string{
		0: "ReadOnly",
		1: "WriteOnly",
		2: "ReadWrite",
	}
	TxMode_value = map[string]int32{
		"ReadOnly":  0,
		"WriteOnly": 1,
		"ReadWrite": 2,
	}
)

Enum value maps for TxMode.

View Source 
var File_schema_proto protoreflect.FileDescriptor
View Source 
var ImmuService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "immudb.schema.ImmuService",
	HandlerType: (*ImmuServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListUsers",
			Handler:    _ImmuService_ListUsers_Handler,
		},
		{
			MethodName: "CreateUser",
			Handler:    _ImmuService_CreateUser_Handler,
		},
		{
			MethodName: "ChangePassword",
			Handler:    _ImmuService_ChangePassword_Handler,
		},
		{
			MethodName: "ChangePermission",
			Handler:    _ImmuService_ChangePermission_Handler,
		},
		{
			MethodName: "SetActiveUser",
			Handler:    _ImmuService_SetActiveUser_Handler,
		},
		{
			MethodName: "UpdateAuthConfig",
			Handler:    _ImmuService_UpdateAuthConfig_Handler,
		},
		{
			MethodName: "UpdateMTLSConfig",
			Handler:    _ImmuService_UpdateMTLSConfig_Handler,
		},
		{
			MethodName: "OpenSession",
			Handler:    _ImmuService_OpenSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _ImmuService_CloseSession_Handler,
		},
		{
			MethodName: "KeepAlive",
			Handler:    _ImmuService_KeepAlive_Handler,
		},
		{
			MethodName: "NewTx",
			Handler:    _ImmuService_NewTx_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _ImmuService_Commit_Handler,
		},
		{
			MethodName: "Rollback",
			Handler:    _ImmuService_Rollback_Handler,
		},
		{
			MethodName: "TxSQLExec",
			Handler:    _ImmuService_TxSQLExec_Handler,
		},
		{
			MethodName: "TxSQLQuery",
			Handler:    _ImmuService_TxSQLQuery_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _ImmuService_Login_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _ImmuService_Logout_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _ImmuService_Set_Handler,
		},
		{
			MethodName: "VerifiableSet",
			Handler:    _ImmuService_VerifiableSet_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ImmuService_Get_Handler,
		},
		{
			MethodName: "VerifiableGet",
			Handler:    _ImmuService_VerifiableGet_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ImmuService_Delete_Handler,
		},
		{
			MethodName: "GetAll",
			Handler:    _ImmuService_GetAll_Handler,
		},
		{
			MethodName: "ExecAll",
			Handler:    _ImmuService_ExecAll_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _ImmuService_Scan_Handler,
		},
		{
			MethodName: "Count",
			Handler:    _ImmuService_Count_Handler,
		},
		{
			MethodName: "CountAll",
			Handler:    _ImmuService_CountAll_Handler,
		},
		{
			MethodName: "TxById",
			Handler:    _ImmuService_TxById_Handler,
		},
		{
			MethodName: "VerifiableTxById",
			Handler:    _ImmuService_VerifiableTxById_Handler,
		},
		{
			MethodName: "TxScan",
			Handler:    _ImmuService_TxScan_Handler,
		},
		{
			MethodName: "History",
			Handler:    _ImmuService_History_Handler,
		},
		{
			MethodName: "ServerInfo",
			Handler:    _ImmuService_ServerInfo_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _ImmuService_Health_Handler,
		},
		{
			MethodName: "DatabaseHealth",
			Handler:    _ImmuService_DatabaseHealth_Handler,
		},
		{
			MethodName: "CurrentState",
			Handler:    _ImmuService_CurrentState_Handler,
		},
		{
			MethodName: "SetReference",
			Handler:    _ImmuService_SetReference_Handler,
		},
		{
			MethodName: "VerifiableSetReference",
			Handler:    _ImmuService_VerifiableSetReference_Handler,
		},
		{
			MethodName: "ZAdd",
			Handler:    _ImmuService_ZAdd_Handler,
		},
		{
			MethodName: "VerifiableZAdd",
			Handler:    _ImmuService_VerifiableZAdd_Handler,
		},
		{
			MethodName: "ZScan",
			Handler:    _ImmuService_ZScan_Handler,
		},
		{
			MethodName: "CreateDatabase",
			Handler:    _ImmuService_CreateDatabase_Handler,
		},
		{
			MethodName: "CreateDatabaseWith",
			Handler:    _ImmuService_CreateDatabaseWith_Handler,
		},
		{
			MethodName: "CreateDatabaseV2",
			Handler:    _ImmuService_CreateDatabaseV2_Handler,
		},
		{
			MethodName: "LoadDatabase",
			Handler:    _ImmuService_LoadDatabase_Handler,
		},
		{
			MethodName: "UnloadDatabase",
			Handler:    _ImmuService_UnloadDatabase_Handler,
		},
		{
			MethodName: "DeleteDatabase",
			Handler:    _ImmuService_DeleteDatabase_Handler,
		},
		{
			MethodName: "DatabaseList",
			Handler:    _ImmuService_DatabaseList_Handler,
		},
		{
			MethodName: "DatabaseListV2",
			Handler:    _ImmuService_DatabaseListV2_Handler,
		},
		{
			MethodName: "UseDatabase",
			Handler:    _ImmuService_UseDatabase_Handler,
		},
		{
			MethodName: "UpdateDatabase",
			Handler:    _ImmuService_UpdateDatabase_Handler,
		},
		{
			MethodName: "UpdateDatabaseV2",
			Handler:    _ImmuService_UpdateDatabaseV2_Handler,
		},
		{
			MethodName: "GetDatabaseSettings",
			Handler:    _ImmuService_GetDatabaseSettings_Handler,
		},
		{
			MethodName: "GetDatabaseSettingsV2",
			Handler:    _ImmuService_GetDatabaseSettingsV2_Handler,
		},
		{
			MethodName: "FlushIndex",
			Handler:    _ImmuService_FlushIndex_Handler,
		},
		{
			MethodName: "CompactIndex",
			Handler:    _ImmuService_CompactIndex_Handler,
		},
		{
			MethodName: "SQLExec",
			Handler:    _ImmuService_SQLExec_Handler,
		},
		{
			MethodName: "SQLQuery",
			Handler:    _ImmuService_SQLQuery_Handler,
		},
		{
			MethodName: "ListTables",
			Handler:    _ImmuService_ListTables_Handler,
		},
		{
			MethodName: "DescribeTable",
			Handler:    _ImmuService_DescribeTable_Handler,
		},
		{
			MethodName: "VerifiableSQLGet",
			Handler:    _ImmuService_VerifiableSQLGet_Handler,
		},
		{
			MethodName: "TruncateDatabase",
			Handler:    _ImmuService_TruncateDatabase_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "streamGet",
			Handler:       _ImmuService_StreamGet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "streamSet",
			Handler:       _ImmuService_StreamSet_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "streamVerifiableGet",
			Handler:       _ImmuService_StreamVerifiableGet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "streamVerifiableSet",
			Handler:       _ImmuService_StreamVerifiableSet_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "streamScan",
			Handler:       _ImmuService_StreamScan_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "streamZScan",
			Handler:       _ImmuService_StreamZScan_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "streamHistory",
			Handler:       _ImmuService_StreamHistory_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "streamExecAll",
			Handler:       _ImmuService_StreamExecAll_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "exportTx",
			Handler:       _ImmuService_ExportTx_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "replicateTx",
			Handler:       _ImmuService_ReplicateTx_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "streamExportTx",
			Handler:       _ImmuService_StreamExportTx_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "schema.proto",
}

ImmuService_ServiceDesc is the grpc.ServiceDesc for ImmuService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func DigestFromProto added in v1.2.0 

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

func DigestsFromProto added in v1.2.0 

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

func DigestsToProto added in v1.2.0 

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

func DualProofFromProto added in v1.2.0 

func DualProofFromProto(dproof *DualProof) *store.DualProof

func DualProofV2FromProto added in v1.5.0 

func DualProofV2FromProto(dproof *DualProofV2) *store.DualProofV2

func FillMissingLinearAdvanceProof added in v1.4.1 

func FillMissingLinearAdvanceProof(
	ctx context.Context,
	proof *store.DualProof,
	sourceTxID uint64,
	targetTxID uint64,
	imc ImmuServiceClient,
) error

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 LinearAdvanceProofFromProto added in v1.4.1 

func LinearAdvanceProofFromProto(laproof *LinearAdvanceProof) *store.LinearAdvanceProof

func LinearProofFromProto added in v1.2.0 

func LinearProofFromProto(lproof *LinearProof) *store.LinearProof

func Pattern_ImmuService_History_0 

func Pattern_ImmuService_History_0() runtime.Pattern

Pattern_ImmuService_History_0 exposes the runtime Pattern need to overwrite history autogenerated request

func Pattern_ImmuService_Set_0 

func Pattern_ImmuService_Set_0() runtime.Pattern

Pattern_ImmuService_Set_0 exposes the runtime Pattern need to overwrite set autogenerated request

func Pattern_ImmuService_UseDatabase_0 added in v0.7.0 

func Pattern_ImmuService_UseDatabase_0() runtime.Pattern

Pattern_ImmuService_UseDatabase_0 exposes the runtime Pattern need to overwrite UseDatabase autogenerated request

func Pattern_ImmuService_VerifiableGet_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableGet_0() runtime.Pattern

Pattern_ImmuService_VerifiableGet_0 exposes the runtime Pattern need to overwrite VerifiableGet autogenerated request

func Pattern_ImmuService_VerifiableSetReference_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableSetReference_0() runtime.Pattern

Pattern_ImmuService_VerifiableSetReference_0 exposes the runtime Pattern need to overwrite VerifiableSetReference autogenerated request

func Pattern_ImmuService_VerifiableSet_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableSet_0() runtime.Pattern

Pattern_ImmuService_VerifiableSet_0 exposes the runtime Pattern need to overwrite VerifiableSet autogenerated request

func Pattern_ImmuService_VerifiableTxById_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableTxById_0() runtime.Pattern

Pattern_ImmuService_VerifiableTxById_0 exposes the runtime Pattern need to overwrite VerifiableTxById autogenerated request

func Pattern_ImmuService_VerifiableZAdd_0 added in v1.0.0 

func Pattern_ImmuService_VerifiableZAdd_0() runtime.Pattern

Pattern_ImmuService_VerifiableZAdd_0 exposes the runtime Pattern need to overwrite VerifiableZAdd autogenerated request

func RawValue added in v1.0.0 

func RawValue(v *SQLValue) interface{}

func RegisterImmuServiceHandler 

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

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

func RegisterImmuServiceHandlerClient 

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

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

func RegisterImmuServiceHandlerFromEndpoint 

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

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

func RegisterImmuServiceHandlerServer 

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

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

func RegisterImmuServiceServer 

func RegisterImmuServiceServer(s grpc.ServiceRegistrar, srv ImmuServiceServer)

func RenderValue added in v1.0.0 

func RenderValue(op isSQLValue_Value) string

func RenderValueAsByte added in v1.0.0 

func RenderValueAsByte(op isSQLValue_Value) []byte

func TxFromProto added in v1.2.0 

func TxFromProto(stx *Tx) *store.Tx

func TxHeaderFromProto added in v1.2.0 

func TxHeaderFromProto(hdr *TxHeader) *store.TxHeader

func TxMetadataFromProto added in v1.2.0 

func TxMetadataFromProto(md *TxMetadata) *store.TxMetadata

Types

type AHTNullableSettings added in v1.3.2 

type AHTNullableSettings struct {

	// Number of new leaves in the tree between synchronous flush to disk
	SyncThreshold *NullableUint32 `protobuf:"bytes,1,opt,name=syncThreshold,proto3" json:"syncThreshold,omitempty"`
	// Size of the in-memory write buffer
	WriteBufferSize *NullableUint32 `protobuf:"bytes,2,opt,name=writeBufferSize,proto3" json:"writeBufferSize,omitempty"`
	// contains filtered or unexported fields
}

func (*AHTNullableSettings) Descriptor deprecated added in v1.3.2 

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

Deprecated: Use AHTNullableSettings.ProtoReflect.Descriptor instead.

func (*AHTNullableSettings) GetSyncThreshold added in v1.3.2 

func (x *AHTNullableSettings) GetSyncThreshold() *NullableUint32

func (*AHTNullableSettings) GetWriteBufferSize added in v1.3.2 

func (x *AHTNullableSettings) GetWriteBufferSize() *NullableUint32

func (*AHTNullableSettings) ProtoMessage added in v1.3.2 

func (*AHTNullableSettings) ProtoMessage()

func (*AHTNullableSettings) ProtoReflect added in v1.3.2 

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

func (*AHTNullableSettings) Reset added in v1.3.2 

func (x *AHTNullableSettings) Reset()

func (*AHTNullableSettings) String added in v1.3.2 

func (x *AHTNullableSettings) String() string

type AuthConfig 

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

DEPRECATED

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 {

	// Username
	User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Old password
	OldPassword []byte `protobuf:"bytes,2,opt,name=oldPassword,proto3" json:"oldPassword,omitempty"`
	// New password
	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 to perform
	Action PermissionAction `protobuf:"varint,1,opt,name=action,proto3,enum=immudb.schema.PermissionAction" json:"action,omitempty"`
	// Name of the user to update
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Name of the database
	Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// Permission to grant / revoke: 1 - read only, 2 - read/write, 254 - admin
	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"`
	Metadata map[string][]byte `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetContent added in v0.9.2 

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

func (*Chunk) GetMetadata added in v1.5.0 

func (x *Chunk) GetMetadata() map[string][]byte

func (*Chunk) ProtoMessage added in v0.9.2 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect added in v0.9.2 

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

func (*Chunk) Reset added in v0.9.2 

func (x *Chunk) Reset()

func (*Chunk) String added in v0.9.2 

func (x *Chunk) String() string

type Column added in v1.0.0 

type Column struct {

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

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

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetName added in v1.0.0 

func (x *Column) GetName() string

func (*Column) GetType added in v1.0.0 

func (x *Column) GetType() string

func (*Column) ProtoMessage added in v1.0.0 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect added in v1.0.0 

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

func (*Column) Reset added in v1.0.0 

func (x *Column) Reset()

func (*Column) String added in v1.0.0 

func (x *Column) String() string

type CommittedSQLTx added in v1.2.0 

type CommittedSQLTx struct {

	// Transaction header
	Header *TxHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Number of updated rows
	UpdatedRows uint32 `protobuf:"varint,2,opt,name=updatedRows,proto3" json:"updatedRows,omitempty"`
	// The value of last inserted auto_increment primary key (mapped by table name)
	LastInsertedPKs map[string]*SQLValue `` /* 171-byte string literal not displayed */
	// The value of first inserted auto_increment primary key (mapped by table name)
	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 {

	// Database name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Database settings
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// If set to true, do not fail if the database already exists
	IfNotExists bool `protobuf:"varint,3,opt,name=ifNotExists,proto3" json:"ifNotExists,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.

func (*CreateDatabaseRequest) GetIfNotExists added in v1.3.0 

func (x *CreateDatabaseRequest) GetIfNotExists() bool

func (*CreateDatabaseRequest) GetName added in v1.2.3 

func (x *CreateDatabaseRequest) GetName() string

func (*CreateDatabaseRequest) GetSettings added in v1.2.3 

func (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 {

	// Database name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Current database settings
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// Set to true if given database already existed
	AlreadyExisted bool `protobuf:"varint,3,opt,name=alreadyExisted,proto3" json:"alreadyExisted,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CreateDatabaseResponse.ProtoReflect.Descriptor instead.

func (*CreateDatabaseResponse) GetAlreadyExisted added in v1.3.0 

func (x *CreateDatabaseResponse) GetAlreadyExisted() bool

func (*CreateDatabaseResponse) GetName added in v1.2.3 

func (x *CreateDatabaseResponse) GetName() string

func (*CreateDatabaseResponse) GetSettings added in v1.2.3 

func (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 {

	// Username
	User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Login password
	Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// Permission, 1 - read permission, 2 - read+write permission, 254 - admin
	Permission uint32 `protobuf:"varint,3,opt,name=permission,proto3" json:"permission,omitempty"`
	// Database name
	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 {

	// Name of the database
	DatabaseName string `protobuf:"bytes,1,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetDatabaseName added in v1.0.0 

func (x *Database) GetDatabaseName() string

func (*Database) ProtoMessage added in v0.7.0 

func (*Database) ProtoMessage()

func (*Database) ProtoReflect added in v0.9.0 

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

func (*Database) Reset added in v0.7.0 

func (x *Database) Reset()

func (*Database) String added in v0.7.0 

func (x *Database) String() string

type DatabaseHealthResponse added in v1.2.3 

type DatabaseHealthResponse struct {

	// Number of requests currently being executed
	PendingRequests uint32 `protobuf:"varint,1,opt,name=pendingRequests,proto3" json:"pendingRequests,omitempty"`
	// Timestamp at which the last request was completed
	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 {

	// Database list
	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 {

	// Database list with current database settings
	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 {

	// Replication settings
	ReplicationSettings *ReplicationNullableSettings `protobuf:"bytes,2,opt,name=replicationSettings,proto3" json:"replicationSettings,omitempty"`
	// Max filesize on disk
	FileSize *NullableUint32 `protobuf:"bytes,8,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	// Maximum length of keys
	MaxKeyLen *NullableUint32 `protobuf:"bytes,9,opt,name=maxKeyLen,proto3" json:"maxKeyLen,omitempty"`
	// Maximum length of values
	MaxValueLen *NullableUint32 `protobuf:"bytes,10,opt,name=maxValueLen,proto3" json:"maxValueLen,omitempty"`
	// Maximum number of entries in a single transaction
	MaxTxEntries *NullableUint32 `protobuf:"bytes,11,opt,name=maxTxEntries,proto3" json:"maxTxEntries,omitempty"`
	// If set to true, do not include commit timestamp in transaction headers
	ExcludeCommitTime *NullableBool `protobuf:"bytes,12,opt,name=excludeCommitTime,proto3" json:"excludeCommitTime,omitempty"`
	// Maximum number of simultaneous commits prepared for write
	MaxConcurrency *NullableUint32 `protobuf:"bytes,13,opt,name=maxConcurrency,proto3" json:"maxConcurrency,omitempty"`
	// Maximum number of simultaneous IO writes
	MaxIOConcurrency *NullableUint32 `protobuf:"bytes,14,opt,name=maxIOConcurrency,proto3" json:"maxIOConcurrency,omitempty"`
	// Size of the LRU cache for transaction logs
	TxLogCacheSize *NullableUint32 `protobuf:"bytes,15,opt,name=txLogCacheSize,proto3" json:"txLogCacheSize,omitempty"`
	// Maximum number of simultaneous value files opened
	VLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,16,opt,name=vLogMaxOpenedFiles,proto3" json:"vLogMaxOpenedFiles,omitempty"`
	// Maximum number of simultaneous transaction log files opened
	TxLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,17,opt,name=txLogMaxOpenedFiles,proto3" json:"txLogMaxOpenedFiles,omitempty"`
	// Maximum number of simultaneous commit log files opened
	CommitLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,18,opt,name=commitLogMaxOpenedFiles,proto3" json:"commitLogMaxOpenedFiles,omitempty"`
	// Index settings
	IndexSettings *IndexNullableSettings `protobuf:"bytes,19,opt,name=indexSettings,proto3" json:"indexSettings,omitempty"`
	// Version of transaction header to use (limits available features)
	WriteTxHeaderVersion *NullableUint32 `protobuf:"bytes,20,opt,name=writeTxHeaderVersion,proto3" json:"writeTxHeaderVersion,omitempty"`
	// If set to true, automatically load the database when starting immudb (true by default)
	Autoload *NullableBool `protobuf:"bytes,21,opt,name=autoload,proto3" json:"autoload,omitempty"`
	// Size of the pool of read buffers
	ReadTxPoolSize *NullableUint32 `protobuf:"bytes,22,opt,name=readTxPoolSize,proto3" json:"readTxPoolSize,omitempty"`
	// Fsync frequency during commit process
	SyncFrequency *NullableMilliseconds `protobuf:"bytes,23,opt,name=syncFrequency,proto3" json:"syncFrequency,omitempty"`
	// Size of the in-memory buffer for write operations
	WriteBufferSize *NullableUint32 `protobuf:"bytes,24,opt,name=writeBufferSize,proto3" json:"writeBufferSize,omitempty"`
	// Settings of Appendable Hash Tree
	AhtSettings *AHTNullableSettings `protobuf:"bytes,25,opt,name=ahtSettings,proto3" json:"ahtSettings,omitempty"`
	// Maximum number of pre-committed transactions
	MaxActiveTransactions *NullableUint32 `protobuf:"bytes,26,opt,name=maxActiveTransactions,proto3" json:"maxActiveTransactions,omitempty"`
	// Limit the number of read entries per transaction
	MvccReadSetLimit *NullableUint32 `protobuf:"bytes,27,opt,name=mvccReadSetLimit,proto3" json:"mvccReadSetLimit,omitempty"`
	// Size of the LRU cache for value logs
	VLogCacheSize *NullableUint32 `protobuf:"bytes,28,opt,name=vLogCacheSize,proto3" json:"vLogCacheSize,omitempty"`
	// Truncation settings
	TruncationSettings *TruncationNullableSettings `protobuf:"bytes,29,opt,name=truncationSettings,proto3" json:"truncationSettings,omitempty"`
	// If set to true, values are stored together with the transaction header (true by default)
	EmbeddedValues *NullableBool `protobuf:"bytes,30,opt,name=embeddedValues,proto3" json:"embeddedValues,omitempty"`
	// Enable file preallocation
	PreallocFiles *NullableBool `protobuf:"bytes,31,opt,name=preallocFiles,proto3" json:"preallocFiles,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) GetAhtSettings added in v1.3.2 

func (x *DatabaseNullableSettings) GetAhtSettings() *AHTNullableSettings

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) GetEmbeddedValues added in v1.5.0 

func (x *DatabaseNullableSettings) GetEmbeddedValues() *NullableBool

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) GetMaxActiveTransactions added in v1.5.0 

func (x *DatabaseNullableSettings) GetMaxActiveTransactions() *NullableUint32

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) GetMvccReadSetLimit added in v1.5.0 

func (x *DatabaseNullableSettings) GetMvccReadSetLimit() *NullableUint32

func (*DatabaseNullableSettings) GetPreallocFiles added in v1.5.0 

func (x *DatabaseNullableSettings) GetPreallocFiles() *NullableBool

func (*DatabaseNullableSettings) GetReadTxPoolSize added in v1.3.2 

func (x *DatabaseNullableSettings) GetReadTxPoolSize() *NullableUint32

func (*DatabaseNullableSettings) GetReplicationSettings added in v1.2.3 

func (x *DatabaseNullableSettings) GetReplicationSettings() *ReplicationNullableSettings

func (*DatabaseNullableSettings) GetSyncFrequency added in v1.3.2 

func (x *DatabaseNullableSettings) GetSyncFrequency() *NullableMilliseconds

func (*DatabaseNullableSettings) GetTruncationSettings added in v1.5.0 

func (x *DatabaseNullableSettings) GetTruncationSettings() *TruncationNullableSettings

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) GetVLogCacheSize added in v1.5.0 

func (x *DatabaseNullableSettings) GetVLogCacheSize() *NullableUint32

func (*DatabaseNullableSettings) GetVLogMaxOpenedFiles added in v1.2.3 

func (x *DatabaseNullableSettings) GetVLogMaxOpenedFiles() *NullableUint32

func (*DatabaseNullableSettings) GetWriteBufferSize added in v1.3.2 

func (x *DatabaseNullableSettings) GetWriteBufferSize() *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 {

	// Name of the database
	DatabaseName string `protobuf:"bytes,1,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	// If set to true, this database is replicating another database
	Replica bool `protobuf:"varint,2,opt,name=replica,proto3" json:"replica,omitempty"`
	// Name of the database to replicate
	PrimaryDatabase string `protobuf:"bytes,3,opt,name=primaryDatabase,proto3" json:"primaryDatabase,omitempty"`
	// Hostname of the immudb instance with database to replicate
	PrimaryHost string `protobuf:"bytes,4,opt,name=primaryHost,proto3" json:"primaryHost,omitempty"`
	// Port of the immudb instance with database to replicate
	PrimaryPort uint32 `protobuf:"varint,5,opt,name=primaryPort,proto3" json:"primaryPort,omitempty"`
	// Username of the user with read access of the database to replicate
	PrimaryUsername string `protobuf:"bytes,6,opt,name=primaryUsername,proto3" json:"primaryUsername,omitempty"`
	// Password of the user with read access of the database to replicate
	PrimaryPassword string `protobuf:"bytes,7,opt,name=primaryPassword,proto3" json:"primaryPassword,omitempty"`
	// Size of files stored on disk
	FileSize uint32 `protobuf:"varint,8,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	// Maximum length of keys
	MaxKeyLen uint32 `protobuf:"varint,9,opt,name=maxKeyLen,proto3" json:"maxKeyLen,omitempty"`
	// Maximum length of values
	MaxValueLen uint32 `protobuf:"varint,10,opt,name=maxValueLen,proto3" json:"maxValueLen,omitempty"`
	// Maximum number of entries in a single transaction
	MaxTxEntries uint32 `protobuf:"varint,11,opt,name=maxTxEntries,proto3" json:"maxTxEntries,omitempty"`
	// If set to true, do not include commit timestamp in transaction headers
	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) 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) GetPrimaryDatabase added in v1.4.1 

func (x *DatabaseSettings) GetPrimaryDatabase() string

func (*DatabaseSettings) GetPrimaryHost added in v1.4.1 

func (x *DatabaseSettings) GetPrimaryHost() string

func (*DatabaseSettings) GetPrimaryPassword added in v1.4.1 

func (x *DatabaseSettings) GetPrimaryPassword() string

func (*DatabaseSettings) GetPrimaryPort added in v1.4.1 

func (x *DatabaseSettings) GetPrimaryPort() uint32

func (*DatabaseSettings) GetPrimaryUsername added in v1.4.1 

func (x *DatabaseSettings) GetPrimaryUsername() string

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 name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Database settings
	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 {

	// Database name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Current database settings
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// If true, this database is currently loaded into memory
	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 trace when the error was noticed
	Stack string `protobuf:"bytes,1,opt,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DebugInfo.ProtoReflect.Descriptor instead.

func (*DebugInfo) GetStack added in v1.0.5 

func (x *DebugInfo) GetStack() string

func (*DebugInfo) ProtoMessage added in v1.0.5 

func (*DebugInfo) ProtoMessage()

func (*DebugInfo) ProtoReflect added in v1.0.5 

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

func (*DebugInfo) Reset added in v1.0.5 

func (x *DebugInfo) Reset()

func (*DebugInfo) String added in v1.0.5 

func (x *DebugInfo) String() string

type DeleteDatabaseRequest added in v1.2.3 

type DeleteDatabaseRequest struct {

	// Database name
	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 name
	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 {

	// List of keys to delete logically
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// If 0, wait for index to be up-to-date,
	// If > 0, wait for at least sinceTx transaction to be indexed
	SinceTx uint64 `protobuf:"varint,2,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// If set to true, do not wait for the indexer to index this operation
	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 {

	// Header of the source (earlier) transaction
	SourceTxHeader *TxHeader `protobuf:"bytes,1,opt,name=sourceTxHeader,proto3" json:"sourceTxHeader,omitempty"`
	// Header of the target (latter) transaction
	TargetTxHeader *TxHeader `protobuf:"bytes,2,opt,name=targetTxHeader,proto3" json:"targetTxHeader,omitempty"`
	// Inclusion proof of the source transaction hash in the main Merkle Tree
	InclusionProof [][]byte `protobuf:"bytes,3,rep,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	// Consistency proof between Merkle Trees in the source and target transactions
	ConsistencyProof [][]byte `protobuf:"bytes,4,rep,name=consistencyProof,proto3" json:"consistencyProof,omitempty"`
	// Accumulative hash (Alh) of the last transaction that's part of the target Merkle Tree
	TargetBlTxAlh []byte `protobuf:"bytes,5,opt,name=targetBlTxAlh,proto3" json:"targetBlTxAlh,omitempty"`
	// Inclusion proof of the targetBlTxAlh in the target Merkle Tree
	LastInclusionProof [][]byte `protobuf:"bytes,6,rep,name=lastInclusionProof,proto3" json:"lastInclusionProof,omitempty"`
	// Linear proof starting from targetBlTxAlh to the final state value
	LinearProof *LinearProof `protobuf:"bytes,7,opt,name=linearProof,proto3" json:"linearProof,omitempty"`
	// Proof of consistency between some part of older linear chain and newer Merkle Tree
	LinearAdvanceProof *LinearAdvanceProof `protobuf:"bytes,8,opt,name=LinearAdvanceProof,proto3" json:"LinearAdvanceProof,omitempty"`
	// contains filtered or unexported fields
}

DualProof contains inclusion and consistency proofs for dual Merkle-Tree + Linear proofs

func DualProofToProto added in v1.2.0 

func DualProofToProto(dualProof *store.DualProof) *DualProof

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

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

Deprecated: Use DualProof.ProtoReflect.Descriptor instead.

func (*DualProof) GetConsistencyProof added in v0.9.0 

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

func (*DualProof) GetInclusionProof added in v0.9.0 

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

func (*DualProof) GetLastInclusionProof added in v0.9.0 

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

func (*DualProof) GetLinearAdvanceProof added in v1.4.1 

func (x *DualProof) GetLinearAdvanceProof() *LinearAdvanceProof

func (*DualProof) GetLinearProof added in v0.9.0 

func (x *DualProof) GetLinearProof() *LinearProof

func (*DualProof) GetSourceTxHeader added in v1.2.0 

func (x *DualProof) GetSourceTxHeader() *TxHeader

func (*DualProof) GetTargetBlTxAlh added in v0.9.0 

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

func (*DualProof) GetTargetTxHeader added in v1.2.0 

func (x *DualProof) GetTargetTxHeader() *TxHeader

func (*DualProof) ProtoMessage added in v0.9.0 

func (*DualProof) ProtoMessage()

func (*DualProof) ProtoReflect added in v0.9.0 

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

func (*DualProof) Reset added in v0.9.0 

func (x *DualProof) Reset()

func (*DualProof) String added in v0.9.0 

func (x *DualProof) String() string

type DualProofV2 added in v1.5.0 

type DualProofV2 struct {

	// Header of the source (earlier) transaction
	SourceTxHeader *TxHeader `protobuf:"bytes,1,opt,name=sourceTxHeader,proto3" json:"sourceTxHeader,omitempty"`
	// Header of the target (latter) transaction
	TargetTxHeader *TxHeader `protobuf:"bytes,2,opt,name=targetTxHeader,proto3" json:"targetTxHeader,omitempty"`
	// Inclusion proof of the source transaction hash in the main Merkle Tree
	InclusionProof [][]byte `protobuf:"bytes,3,rep,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	// Consistency proof between Merkle Trees in the source and target transactions
	ConsistencyProof [][]byte `protobuf:"bytes,4,rep,name=consistencyProof,proto3" json:"consistencyProof,omitempty"`
	// contains filtered or unexported fields
}

DualProofV2 contains inclusion and consistency proofs

func DualProofV2ToProto added in v1.5.0 

func DualProofV2ToProto(dualProof *store.DualProofV2) *DualProofV2

func (*DualProofV2) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use DualProofV2.ProtoReflect.Descriptor instead.

func (*DualProofV2) GetConsistencyProof added in v1.5.0 

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

func (*DualProofV2) GetInclusionProof added in v1.5.0 

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

func (*DualProofV2) GetSourceTxHeader added in v1.5.0 

func (x *DualProofV2) GetSourceTxHeader() *TxHeader

func (*DualProofV2) GetTargetTxHeader added in v1.5.0 

func (x *DualProofV2) GetTargetTxHeader() *TxHeader

func (*DualProofV2) ProtoMessage added in v1.5.0 

func (*DualProofV2) ProtoMessage()

func (*DualProofV2) ProtoReflect added in v1.5.0 

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

func (*DualProofV2) Reset added in v1.5.0 

func (x *DualProofV2) Reset()

func (*DualProofV2) String added in v1.5.0 

func (x *DualProofV2) String() string

type Entries added in v0.9.0 

type Entries struct {

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

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

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

Deprecated: Use Entries.ProtoReflect.Descriptor instead.

func (*Entries) GetEntries added in v0.9.0 

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

func (*Entries) ProtoMessage added in v0.9.0 

func (*Entries) ProtoMessage()

func (*Entries) ProtoReflect added in v0.9.0 

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

func (*Entries) Reset added in v0.9.0 

func (x *Entries) Reset()

func (*Entries) String added in v0.9.0 

func (x *Entries) String() string

type EntriesSpec added in v1.2.3 

type EntriesSpec struct {

	// Specification for parsing KV entries
	KvEntriesSpec *EntryTypeSpec `protobuf:"bytes,1,opt,name=kvEntriesSpec,proto3" json:"kvEntriesSpec,omitempty"`
	// Specification for parsing sorted set entries
	ZEntriesSpec *EntryTypeSpec `protobuf:"bytes,2,opt,name=zEntriesSpec,proto3" json:"zEntriesSpec,omitempty"`
	// Specification for parsing SQL entries
	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 {

	// Transaction id at which the target value was set (i.e. not the reference transaction id)
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Key of the target value (i.e. not the reference entry)
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Value
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// If the request was for a reference, this field will keep information about the reference entry
	ReferencedBy *Reference `protobuf:"bytes,4,opt,name=referencedBy,proto3" json:"referencedBy,omitempty"`
	// Metadata of the target entry (i.e. not the reference entry)
	Metadata *KVMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// If set to true, this entry has expired and the value is not retrieved
	Expired bool `protobuf:"varint,6,opt,name=expired,proto3" json:"expired,omitempty"`
	// Key's revision, in case of GetAt it will be 0
	Revision uint64 `protobuf:"varint,7,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetExpired added in v1.2.0 

func (x *Entry) GetExpired() bool

func (*Entry) GetKey added in v0.9.0 

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

func (*Entry) GetMetadata added in v1.2.0 

func (x *Entry) GetMetadata() *KVMetadata

func (*Entry) GetReferencedBy added in v0.9.0 

func (x *Entry) GetReferencedBy() *Reference

func (*Entry) GetRevision added in v1.3.0 

func (x *Entry) GetRevision() uint64

func (*Entry) GetTx added in v0.9.0 

func (x *Entry) GetTx() uint64

func (*Entry) GetValue added in v0.9.0 

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

func (*Entry) ProtoMessage added in v0.9.0 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect added in v0.9.0 

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

func (*Entry) Reset added in v0.9.0 

func (x *Entry) Reset()

func (*Entry) String added in v0.9.0 

func (x *Entry) String() string

type EntryCount added in v0.9.0 

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

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

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

Deprecated: Use EntryCount.ProtoReflect.Descriptor instead.

func (*EntryCount) GetCount added in v0.9.0 

func (x *EntryCount) GetCount() uint64

func (*EntryCount) ProtoMessage added in v0.9.0 

func (*EntryCount) ProtoMessage()

func (*EntryCount) ProtoReflect added in v0.9.0 

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

func (*EntryCount) Reset added in v0.9.0 

func (x *EntryCount) Reset()

func (*EntryCount) String added in v0.9.0 

func (x *EntryCount) String() string

type EntryTypeAction added in v1.2.3 

type EntryTypeAction int32
const (
	// Exclude entries from the result
	EntryTypeAction_EXCLUDE EntryTypeAction = 0
	// Provide keys in raw (unparsed) form and only the digest of the value
	EntryTypeAction_ONLY_DIGEST EntryTypeAction = 1
	// Provide keys and values in raw form
	EntryTypeAction_RAW_VALUE EntryTypeAction = 2
	// Provide parsed keys and values and resolve values if needed
	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 to perform on entries
	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 {

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

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

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

Deprecated: Use ErrorInfo.ProtoReflect.Descriptor instead.

func (*ErrorInfo) GetCause added in v1.0.5 

func (x *ErrorInfo) GetCause() string

func (*ErrorInfo) GetCode added in v1.0.5 

func (x *ErrorInfo) GetCode() string

func (*ErrorInfo) ProtoMessage added in v1.0.5 

func (*ErrorInfo) ProtoMessage()

func (*ErrorInfo) ProtoReflect added in v1.0.5 

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

func (*ErrorInfo) Reset added in v1.0.5 

func (x *ErrorInfo) Reset()

func (*ErrorInfo) String added in v1.0.5 

func (x *ErrorInfo) String() string

type ExecAllRequest added in v0.9.0 

type ExecAllRequest struct {

	// List of operations to perform
	Operations []*Op `protobuf:"bytes,1,rep,name=Operations,proto3" json:"Operations,omitempty"`
	// If set to true, do not wait for indexing to process this transaction
	NoWait bool `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// Preconditions to check
	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 {

	// Entry expiration time (unix timestamp in seconds)
	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 {

	// Id of transaction to export
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// If set to true, non-committed transactions can be exported
	AllowPreCommitted bool `protobuf:"varint,2,opt,name=allowPreCommitted,proto3" json:"allowPreCommitted,omitempty"`
	// Used on synchronous replication to notify the primary about replica state
	ReplicaState *ReplicaState `protobuf:"bytes,3,opt,name=replicaState,proto3" json:"replicaState,omitempty"`
	// If set to true, integrity checks are skipped when reading data
	SkipIntegrityCheck bool `protobuf:"varint,4,opt,name=skipIntegrityCheck,proto3" json:"skipIntegrityCheck,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) GetAllowPreCommitted added in v1.4.0 

func (x *ExportTxRequest) GetAllowPreCommitted() bool

func (*ExportTxRequest) GetReplicaState added in v1.4.1 

func (x *ExportTxRequest) GetReplicaState() *ReplicaState

func (*ExportTxRequest) GetSkipIntegrityCheck added in v1.5.0 

func (x *ExportTxRequest) GetSkipIntegrityCheck() bool

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 {

	// Percentage of nodes file to cleanup during flush
	CleanupPercentage float32 `protobuf:"fixed32,1,opt,name=cleanupPercentage,proto3" json:"cleanupPercentage,omitempty"`
	// If true, do a full disk sync after the flush
	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 name
	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 {

	// If true, server considers itself to be healthy
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// The version of the server instance
	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 {

	// Name of the key to query for the history
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Specify the initial entry to be returned by excluding the initial set of
	// entries
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Maximum number of entries to return
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// If true, search in descending order
	Desc bool `protobuf:"varint,4,opt,name=desc,proto3" json:"desc,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require
	// entries up to sinceTx to be indexed
	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 *emptypb.Empty, opts ...grpc.CallOption) (*UserList, error)
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ChangePassword(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ChangePermission(ctx context.Context, in *ChangePermissionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetActiveUser(ctx context.Context, in *SetActiveUserRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	UpdateAuthConfig(ctx context.Context, in *AuthConfig, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	UpdateMTLSConfig(ctx context.Context, in *MTLSConfig, opts ...grpc.CallOption) (*emptypb.Empty, error)
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	KeepAlive(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NewTx(ctx context.Context, in *NewTxRequest, opts ...grpc.CallOption) (*NewTxResponse, error)
	Commit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CommittedSQLTx, error)
	Rollback(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TxSQLExec(ctx context.Context, in *SQLExecRequest, opts ...grpc.CallOption) (*emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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 *emptypb.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)
	// ServerInfo returns information about the server instance.
	// ServerInfoRequest is defined for future extensions.
	ServerInfo(ctx context.Context, in *ServerInfoRequest, opts ...grpc.CallOption) (*ServerInfoResponse, error)
	// DEPRECATED: Use ServerInfo
	Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
	DatabaseHealth(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DatabaseHealthResponse, error)
	CurrentState(ctx context.Context, in *emptypb.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) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabaseWith(ctx context.Context, in *DatabaseSettings, opts ...grpc.CallOption) (*emptypb.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 *emptypb.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) (*emptypb.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 *emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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)
	StreamExportTx(ctx context.Context, opts ...grpc.CallOption) (ImmuService_StreamExportTxClient, 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 *emptypb.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)
	TruncateDatabase(ctx context.Context, in *TruncateDatabaseRequest, opts ...grpc.CallOption) (*TruncateDatabaseResponse, error)
}

ImmuServiceClient is the client API for ImmuService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewImmuServiceClient 

func NewImmuServiceClient(cc grpc.ClientConnInterface) ImmuServiceClient

type ImmuServiceServer 

type ImmuServiceServer interface {
	ListUsers(context.Context, *emptypb.Empty) (*UserList, error)
	CreateUser(context.Context, *CreateUserRequest) (*emptypb.Empty, error)
	ChangePassword(context.Context, *ChangePasswordRequest) (*emptypb.Empty, error)
	ChangePermission(context.Context, *ChangePermissionRequest) (*emptypb.Empty, error)
	SetActiveUser(context.Context, *SetActiveUserRequest) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	UpdateAuthConfig(context.Context, *AuthConfig) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	UpdateMTLSConfig(context.Context, *MTLSConfig) (*emptypb.Empty, error)
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	KeepAlive(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	NewTx(context.Context, *NewTxRequest) (*NewTxResponse, error)
	Commit(context.Context, *emptypb.Empty) (*CommittedSQLTx, error)
	Rollback(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	TxSQLExec(context.Context, *SQLExecRequest) (*emptypb.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, *emptypb.Empty) (*emptypb.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, *emptypb.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)
	// ServerInfo returns information about the server instance.
	// ServerInfoRequest is defined for future extensions.
	ServerInfo(context.Context, *ServerInfoRequest) (*ServerInfoResponse, error)
	// DEPRECATED: Use ServerInfo
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	DatabaseHealth(context.Context, *emptypb.Empty) (*DatabaseHealthResponse, error)
	CurrentState(context.Context, *emptypb.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) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use CreateDatabaseV2
	CreateDatabaseWith(context.Context, *DatabaseSettings) (*emptypb.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, *emptypb.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) (*emptypb.Empty, error)
	UpdateDatabaseV2(context.Context, *UpdateDatabaseRequest) (*UpdateDatabaseResponse, error)
	// Deprecated: Do not use.
	// DEPRECATED: Use GetDatabaseSettingsV2
	GetDatabaseSettings(context.Context, *emptypb.Empty) (*DatabaseSettings, error)
	GetDatabaseSettingsV2(context.Context, *DatabaseSettingsRequest) (*DatabaseSettingsResponse, error)
	FlushIndex(context.Context, *FlushIndexRequest) (*FlushIndexResponse, error)
	CompactIndex(context.Context, *emptypb.Empty) (*emptypb.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
	StreamExportTx(ImmuService_StreamExportTxServer) error
	SQLExec(context.Context, *SQLExecRequest) (*SQLExecResult, error)
	SQLQuery(context.Context, *SQLQueryRequest) (*SQLQueryResult, error)
	ListTables(context.Context, *emptypb.Empty) (*SQLQueryResult, error)
	DescribeTable(context.Context, *Table) (*SQLQueryResult, error)
	VerifiableSQLGet(context.Context, *VerifiableSQLGetRequest) (*VerifiableSQLEntry, error)
	TruncateDatabase(context.Context, *TruncateDatabaseRequest) (*TruncateDatabaseResponse, error)
}

ImmuServiceServer is the server API for ImmuService service. All implementations should embed UnimplementedImmuServiceServer for forward compatibility

type ImmuService_ExportTxClient added in v1.0.5 

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

type ImmuService_ExportTxServer added in v1.0.5 

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

type ImmuService_ReplicateTxClient added in v1.0.5 

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

type ImmuService_ReplicateTxServer added in v1.0.5 

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

type ImmuService_StreamExecAllClient added in v0.9.2 

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

type ImmuService_StreamExecAllServer added in v0.9.2 

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

type ImmuService_StreamExportTxClient added in v1.5.0 

type ImmuService_StreamExportTxClient interface {
	Send(*ExportTxRequest) error
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type ImmuService_StreamExportTxServer added in v1.5.0 

type ImmuService_StreamExportTxServer interface {
	Send(*Chunk) error
	Recv() (*ExportTxRequest, error)
	grpc.ServerStream
}

type ImmuService_StreamGetClient added in v0.9.2 

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

type ImmuService_StreamGetServer added in v0.9.2 

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

type ImmuService_StreamHistoryClient added in v0.9.2 

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

type ImmuService_StreamHistoryServer added in v0.9.2 

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

type ImmuService_StreamScanClient added in v0.9.2 

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

type ImmuService_StreamScanServer added in v0.9.2 

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

type ImmuService_StreamSetClient added in v0.9.2 

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

type ImmuService_StreamSetServer added in v0.9.2 

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

type ImmuService_StreamVerifiableGetClient added in v0.9.2 

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

type ImmuService_StreamVerifiableGetServer added in v0.9.2 

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

type ImmuService_StreamVerifiableSetClient added in v0.9.2 

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

type ImmuService_StreamVerifiableSetServer added in v0.9.2 

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

type ImmuService_StreamZScanClient added in v0.9.2 

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

type ImmuService_StreamZScanServer added in v0.9.2 

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

type ImmutableState added in v0.9.0 

type ImmutableState struct {

	// The db name
	Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	// Id of the most recent transaction
	TxId uint64 `protobuf:"varint,2,opt,name=txId,proto3" json:"txId,omitempty"`
	// State of the most recent transaction
	TxHash []byte `protobuf:"bytes,3,opt,name=txHash,proto3" json:"txHash,omitempty"`
	// Signature of the hash
	Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// Id of the most recent precommitted transaction
	PrecommittedTxId uint64 `protobuf:"varint,5,opt,name=precommittedTxId,proto3" json:"precommittedTxId,omitempty"`
	// State of the most recent precommitted transaction
	PrecommittedTxHash []byte `protobuf:"bytes,6,opt,name=precommittedTxHash,proto3" json:"precommittedTxHash,omitempty"`
	// contains filtered or unexported fields
}

func (*ImmutableState) CheckSignature added in v0.9.0 

func (state *ImmutableState) CheckSignature(key *ecdsa.PublicKey) 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) GetPrecommittedTxHash added in v1.4.0 

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

func (*ImmutableState) GetPrecommittedTxId added in v1.4.0 

func (x *ImmutableState) GetPrecommittedTxId() uint64

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 {

	// Index of the leaf for which the proof is generated
	Leaf int32 `protobuf:"varint,1,opt,name=leaf,proto3" json:"leaf,omitempty"`
	// Width of the tree at the leaf level
	Width int32 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	// Proof terms (selected hashes from the tree)
	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 {

	// Number of new index entries between disk flushes
	FlushThreshold *NullableUint32 `protobuf:"bytes,1,opt,name=flushThreshold,proto3" json:"flushThreshold,omitempty"`
	// Number of new index entries between disk flushes with file sync
	SyncThreshold *NullableUint32 `protobuf:"bytes,2,opt,name=syncThreshold,proto3" json:"syncThreshold,omitempty"`
	// Size of the Btree node LRU cache
	CacheSize *NullableUint32 `protobuf:"bytes,3,opt,name=cacheSize,proto3" json:"cacheSize,omitempty"`
	// Max size of a single Btree node in bytes
	MaxNodeSize *NullableUint32 `protobuf:"bytes,4,opt,name=maxNodeSize,proto3" json:"maxNodeSize,omitempty"`
	// Maximum number of active btree snapshots
	MaxActiveSnapshots *NullableUint32 `protobuf:"bytes,5,opt,name=maxActiveSnapshots,proto3" json:"maxActiveSnapshots,omitempty"`
	// Time in milliseconds between the most recent DB snapshot is automatically renewed
	RenewSnapRootAfter *NullableUint64 `protobuf:"bytes,6,opt,name=renewSnapRootAfter,proto3" json:"renewSnapRootAfter,omitempty"`
	// Minimum number of updates entries in the btree to allow for full compaction
	CompactionThld *NullableUint32 `protobuf:"bytes,7,opt,name=compactionThld,proto3" json:"compactionThld,omitempty"`
	// Additional delay added during indexing when full compaction is in progress
	DelayDuringCompaction *NullableUint32 `protobuf:"bytes,8,opt,name=delayDuringCompaction,proto3" json:"delayDuringCompaction,omitempty"`
	// Maximum number of simultaneously opened nodes files
	NodesLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,9,opt,name=nodesLogMaxOpenedFiles,proto3" json:"nodesLogMaxOpenedFiles,omitempty"`
	// Maximum number of simultaneously opened node history files
	HistoryLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,10,opt,name=historyLogMaxOpenedFiles,proto3" json:"historyLogMaxOpenedFiles,omitempty"`
	// Maximum number of simultaneously opened commit log files
	CommitLogMaxOpenedFiles *NullableUint32 `protobuf:"bytes,11,opt,name=commitLogMaxOpenedFiles,proto3" json:"commitLogMaxOpenedFiles,omitempty"`
	// Size of the in-memory flush buffer (in bytes)
	FlushBufferSize *NullableUint32 `protobuf:"bytes,12,opt,name=flushBufferSize,proto3" json:"flushBufferSize,omitempty"`
	// Percentage of node files cleaned up during each flush
	CleanupPercentage *NullableFloat `protobuf:"bytes,13,opt,name=cleanupPercentage,proto3" json:"cleanupPercentage,omitempty"`
	// Maximum number of transactions indexed together
	MaxBulkSize *NullableUint32 `protobuf:"bytes,14,opt,name=maxBulkSize,proto3" json:"maxBulkSize,omitempty"`
	// Maximum time waiting for more transactions to be committed and included into the same bulk
	BulkPreparationTimeout *NullableMilliseconds `protobuf:"bytes,15,opt,name=bulkPreparationTimeout,proto3" json:"bulkPreparationTimeout,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) GetBulkPreparationTimeout added in v1.5.0 

func (x *IndexNullableSettings) GetBulkPreparationTimeout() *NullableMilliseconds

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) GetMaxBulkSize added in v1.5.0 

func (x *IndexNullableSettings) GetMaxBulkSize() *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 {

	// True if this entry denotes a logical deletion
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// Entry expiration information
	Expiration *Expiration `protobuf:"bytes,2,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// If set to true, this entry will not be indexed and will only be accessed through GetAt calls
	NonIndexable bool `protobuf:"varint,3,opt,name=nonIndexable,proto3" json:"nonIndexable,omitempty"`
	// contains filtered or unexported fields
}

func KVMetadataToProto added in v1.2.0 

func KVMetadataToProto(md *store.KVMetadata) *KVMetadata

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

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

Deprecated: Use KVMetadata.ProtoReflect.Descriptor instead.

func (*KVMetadata) GetDeleted added in v1.2.0 

func (x *KVMetadata) GetDeleted() bool

func (*KVMetadata) GetExpiration added in v1.2.0 

func (x *KVMetadata) GetExpiration() *Expiration

func (*KVMetadata) GetNonIndexable added in v1.2.3 

func (x *KVMetadata) GetNonIndexable() bool

func (*KVMetadata) ProtoMessage added in v1.2.0 

func (*KVMetadata) ProtoMessage()

func (*KVMetadata) ProtoReflect added in v1.2.0 

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

func (*KVMetadata) Reset added in v1.2.0 

func (x *KVMetadata) Reset()

func (*KVMetadata) String added in v1.2.0 

func (x *KVMetadata) String() string

type Key 

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

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetKey 

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

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect added in v0.9.0 

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

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) String 

func (x *Key) String() string

type KeyListRequest added in v0.9.0 

type KeyListRequest struct {

	// List of keys to query for
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// If 0, wait for index to be up-to-date,
	// If > 0, wait for at least sinceTx transaction to be indexed
	SinceTx uint64 `protobuf:"varint,2,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use KeyListRequest.ProtoReflect.Descriptor instead.

func (*KeyListRequest) GetKeys added in v0.9.0 

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

func (*KeyListRequest) GetSinceTx added in v0.9.0 

func (x *KeyListRequest) GetSinceTx() uint64

func (*KeyListRequest) ProtoMessage added in v0.9.0 

func (*KeyListRequest) ProtoMessage()

func (*KeyListRequest) ProtoReflect added in v0.9.0 

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

func (*KeyListRequest) Reset added in v0.9.0 

func (x *KeyListRequest) Reset()

func (*KeyListRequest) String added in v0.9.0 

func (x *KeyListRequest) String() string

type KeyPrefix 

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

func (*KeyPrefix) Descriptor deprecated 

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

Deprecated: Use KeyPrefix.ProtoReflect.Descriptor instead.

func (*KeyPrefix) GetPrefix 

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

func (*KeyPrefix) ProtoMessage 

func (*KeyPrefix) ProtoMessage()

func (*KeyPrefix) ProtoReflect added in v0.9.0 

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

func (*KeyPrefix) Reset 

func (x *KeyPrefix) Reset()

func (*KeyPrefix) String 

func (x *KeyPrefix) String() string

type KeyRequest added in v0.9.0 

type KeyRequest struct {

	// Key to query for
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// If > 0, query for the value exactly at given transaction
	AtTx uint64 `protobuf:"varint,2,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// If 0 (and noWait=false), wait for the index to be up-to-date,
	// If > 0 (and noWait=false), wait for at lest the sinceTx transaction to be indexed
	SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// If set to true - do not wait for any indexing update considering only the currently indexed state
	NoWait bool `protobuf:"varint,4,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// If > 0, get the nth version of the value, 1 being the first version, 2 being the second and so on
	// If < 0, get the historical nth value of the key, -1 being the previous version, -2 being the one before and so on
	AtRevision int64 `protobuf:"varint,5,opt,name=atRevision,proto3" json:"atRevision,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetAtRevision added in v1.3.0 

func (x *KeyRequest) GetAtRevision() int64

func (*KeyRequest) GetAtTx added in v0.9.1 

func (x *KeyRequest) GetAtTx() uint64

func (*KeyRequest) GetKey added in v0.9.0 

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

func (*KeyRequest) GetNoWait added in v1.2.3 

func (x *KeyRequest) GetNoWait() bool

func (*KeyRequest) GetSinceTx added in v0.9.0 

func (x *KeyRequest) GetSinceTx() uint64

func (*KeyRequest) ProtoMessage added in v0.9.0 

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect added in v0.9.0 

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

func (*KeyRequest) Reset added in v0.9.0 

func (x *KeyRequest) Reset()

func (*KeyRequest) String added in v0.9.0 

func (x *KeyRequest) String() string

type KeyValue 

type KeyValue struct {
	Key      []byte      `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte      `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Metadata *KVMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

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

func (*KeyValue) GetMetadata added in v1.2.0 

func (x *KeyValue) GetMetadata() *KVMetadata

func (*KeyValue) GetValue 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect added in v0.9.0 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type LinearAdvanceProof added in v1.4.1 

type LinearAdvanceProof struct {

	// terms for the linear chain
	LinearProofTerms [][]byte `protobuf:"bytes,1,rep,name=linearProofTerms,proto3" json:"linearProofTerms,omitempty"`
	// inclusion proofs for steps on the linear chain
	InclusionProofs []*InclusionProof `protobuf:"bytes,2,rep,name=inclusionProofs,proto3" json:"inclusionProofs,omitempty"`
	// contains filtered or unexported fields
}

LinearAdvanceProof contains the proof of consistency between the consumed part of the older linear chain and the new Merkle Tree

func LinearAdvanceProofToProto added in v1.4.1 

func LinearAdvanceProofToProto(proof *store.LinearAdvanceProof) *LinearAdvanceProof

func (*LinearAdvanceProof) Descriptor deprecated added in v1.4.1 

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

Deprecated: Use LinearAdvanceProof.ProtoReflect.Descriptor instead.

func (*LinearAdvanceProof) GetInclusionProofs added in v1.4.1 

func (x *LinearAdvanceProof) GetInclusionProofs() []*InclusionProof

func (*LinearAdvanceProof) GetLinearProofTerms added in v1.4.1 

func (x *LinearAdvanceProof) GetLinearProofTerms() [][]byte

func (*LinearAdvanceProof) ProtoMessage added in v1.4.1 

func (*LinearAdvanceProof) ProtoMessage()

func (*LinearAdvanceProof) ProtoReflect added in v1.4.1 

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

func (*LinearAdvanceProof) Reset added in v1.4.1 

func (x *LinearAdvanceProof) Reset()

func (*LinearAdvanceProof) String added in v1.4.1 

func (x *LinearAdvanceProof) String() string

type LinearProof added in v0.9.0 

type LinearProof struct {

	// Starting transaction of the proof
	SourceTxId uint64 `protobuf:"varint,1,opt,name=sourceTxId,proto3" json:"sourceTxId,omitempty"`
	// End transaction of the proof
	TargetTxId uint64 `protobuf:"varint,2,opt,name=TargetTxId,proto3" json:"TargetTxId,omitempty"`
	// List of terms (inner hashes of transaction entries)
	Terms [][]byte `protobuf:"bytes,3,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

LinearProof contains the linear part of the proof (outside the main Merkle Tree)

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 name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // may add settings
	// 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 {

	// Username
	User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// User's password
	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 {

	// Deprecated: use session-based authentication
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Optional: additional warning message sent to the user (e.g. request to change the password)
	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
}

DEPRECATED

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 {

	// Parameter name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Parameter value
	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 {

	// Transaction mode
	Mode TxMode `protobuf:"varint,1,opt,name=mode,proto3,enum=immudb.schema.TxMode" json:"mode,omitempty"`
	// An existing snapshot may be reused as long as it includes the specified transaction
	// If not specified it will include up to the latest precommitted transaction
	SnapshotMustIncludeTxID *NullableUint64 `protobuf:"bytes,2,opt,name=snapshotMustIncludeTxID,proto3" json:"snapshotMustIncludeTxID,omitempty"`
	// An existing snapshot may be reused as long as it is not older than the specified timeframe
	SnapshotRenewalPeriod *NullableMilliseconds `protobuf:"bytes,3,opt,name=snapshotRenewalPeriod,proto3" json:"snapshotRenewalPeriod,omitempty"`
	// Indexing may not be up to date when doing MVCC
	UnsafeMVCC bool `protobuf:"varint,4,opt,name=unsafeMVCC,proto3" json:"unsafeMVCC,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) GetSnapshotMustIncludeTxID added in v1.5.0 

func (x *NewTxRequest) GetSnapshotMustIncludeTxID() *NullableUint64

func (*NewTxRequest) GetSnapshotRenewalPeriod added in v1.5.0 

func (x *NewTxRequest) GetSnapshotRenewalPeriod() *NullableMilliseconds

func (*NewTxRequest) GetUnsafeMVCC added in v1.5.0 

func (x *NewTxRequest) GetUnsafeMVCC() bool

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 {

	// Internal transaction ID
	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 NullableMilliseconds added in v1.3.2 

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

func (*NullableMilliseconds) Descriptor deprecated added in v1.3.2 

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

Deprecated: Use NullableMilliseconds.ProtoReflect.Descriptor instead.

func (*NullableMilliseconds) GetValue added in v1.3.2 

func (x *NullableMilliseconds) GetValue() int64

func (*NullableMilliseconds) ProtoMessage added in v1.3.2 

func (*NullableMilliseconds) ProtoMessage()

func (*NullableMilliseconds) ProtoReflect added in v1.3.2 

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

func (*NullableMilliseconds) Reset added in v1.3.2 

func (x *NullableMilliseconds) Reset()

func (*NullableMilliseconds) String added in v1.3.2 

func (x *NullableMilliseconds) 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) Descriptor() ([]byte, []int)

Deprecated: Use Op.ProtoReflect.Descriptor instead.

func (*Op) GetKv added in v0.9.0 

func (x *Op) GetKv() *KeyValue

func (*Op) GetOperation added in v0.8.1 

func (m *Op) GetOperation() isOp_Operation

func (*Op) GetRef added in v0.9.0 

func (x *Op) GetRef() *ReferenceRequest

func (*Op) GetZAdd added in v0.9.0 

func (x *Op) GetZAdd() *ZAddRequest

func (*Op) ProtoMessage added in v0.8.1 

func (*Op) ProtoMessage()

func (*Op) ProtoReflect added in v0.9.0 

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

func (*Op) Reset added in v0.8.1 

func (x *Op) Reset()

func (*Op) String added in v0.8.1 

func (x *Op) String() string

type Op_Kv added in v0.9.0 

type Op_Kv struct {
	// Modify / add simple KV value
	Kv *KeyValue `protobuf:"bytes,1,opt,name=kv,proto3,oneof"`
}

type Op_Ref added in v0.9.0 

type Op_Ref struct {
	// Modify / add reference
	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 {
	// Modify / add sorted set entry
	ZAdd *ZAddRequest `protobuf:"bytes,2,opt,name=zAdd,proto3,oneof"`
}

type OpenSessionRequest added in v1.2.0 

type OpenSessionRequest struct {

	// Username
	Username []byte `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Password
	Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// Database name
	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 {

	// Id of the new session
	SessionID string `protobuf:"bytes,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	// UUID of the server
	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 name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Permission, 1 - read permission, 2 - read+write permission, 254 - admin, 255 - sysadmin
	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 (
	// Grant permission
	PermissionAction_GRANT PermissionAction = 0
	// Revoke permission
	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 to check
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Only succeed if given key exists

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 to check
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Only succeed if given key does not exists

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 to check
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// transaction id to check against
	TxID uint64 `protobuf:"varint,2,opt,name=txID,proto3" json:"txID,omitempty"`
	// contains filtered or unexported fields
}

Only succeed if given key was not modified after given transaction

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 {

	// Transaction if when the reference key was set
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Reference key
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// At which transaction the key is bound, 0 if reference is not bound and should read the most recent reference
	AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// Metadata of the reference entry
	Metadata *KVMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Revision of the reference entry
	Revision uint64 `protobuf:"varint,5,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Reference.ProtoReflect.Descriptor instead.

func (*Reference) GetAtTx added in v0.9.0 

func (x *Reference) GetAtTx() uint64

func (*Reference) GetKey added in v0.9.0 

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

func (*Reference) GetMetadata added in v1.2.0 

func (x *Reference) GetMetadata() *KVMetadata

func (*Reference) GetRevision added in v1.3.0 

func (x *Reference) GetRevision() uint64

func (*Reference) GetTx added in v0.9.0 

func (x *Reference) GetTx() uint64

func (*Reference) ProtoMessage added in v0.9.0 

func (*Reference) ProtoMessage()

func (*Reference) ProtoReflect added in v0.9.0 

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

func (*Reference) Reset added in v0.9.0 

func (x *Reference) Reset()

func (*Reference) String added in v0.9.0 

func (x *Reference) String() string

type ReferenceRequest added in v0.9.0 

type ReferenceRequest struct {

	// Key for the reference
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Key to be referenced
	ReferencedKey []byte `protobuf:"bytes,2,opt,name=referencedKey,proto3" json:"referencedKey,omitempty"`
	// If boundRef == true, id of transaction to bind with the reference
	AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// If true, bind the reference to particular transaction,
	// if false, use the most recent value of the key
	BoundRef bool `protobuf:"varint,4,opt,name=boundRef,proto3" json:"boundRef,omitempty"`
	// If true, do not wait for the indexer to index this write operation
	NoWait bool `protobuf:"varint,5,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// Preconditions to be met to perform the write
	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 ReplicaState added in v1.4.1 

type ReplicaState struct {
	UUID             string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	CommittedTxID    uint64 `protobuf:"varint,2,opt,name=committedTxID,proto3" json:"committedTxID,omitempty"`
	CommittedAlh     []byte `protobuf:"bytes,3,opt,name=committedAlh,proto3" json:"committedAlh,omitempty"`
	PrecommittedTxID uint64 `protobuf:"varint,4,opt,name=precommittedTxID,proto3" json:"precommittedTxID,omitempty"`
	PrecommittedAlh  []byte `protobuf:"bytes,5,opt,name=precommittedAlh,proto3" json:"precommittedAlh,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaState) Descriptor deprecated added in v1.4.1 

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

Deprecated: Use ReplicaState.ProtoReflect.Descriptor instead.

func (*ReplicaState) GetCommittedAlh added in v1.4.1 

func (x *ReplicaState) GetCommittedAlh() []byte

func (*ReplicaState) GetCommittedTxID added in v1.4.1 

func (x *ReplicaState) GetCommittedTxID() uint64

func (*ReplicaState) GetPrecommittedAlh added in v1.4.1 

func (x *ReplicaState) GetPrecommittedAlh() []byte

func (*ReplicaState) GetPrecommittedTxID added in v1.4.1 

func (x *ReplicaState) GetPrecommittedTxID() uint64

func (*ReplicaState) GetUUID added in v1.4.1 

func (x *ReplicaState) GetUUID() string

func (*ReplicaState) ProtoMessage added in v1.4.1 

func (*ReplicaState) ProtoMessage()

func (*ReplicaState) ProtoReflect added in v1.4.1 

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

func (*ReplicaState) Reset added in v1.4.1 

func (x *ReplicaState) Reset()

func (*ReplicaState) String added in v1.4.1 

func (x *ReplicaState) String() string

type ReplicationNullableSettings added in v1.2.3 

type ReplicationNullableSettings struct {

	// If set to true, this database is replicating another database
	Replica *NullableBool `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// Name of the database to replicate
	PrimaryDatabase *NullableString `protobuf:"bytes,2,opt,name=primaryDatabase,proto3" json:"primaryDatabase,omitempty"`
	// Hostname of the immudb instance with database to replicate
	PrimaryHost *NullableString `protobuf:"bytes,3,opt,name=primaryHost,proto3" json:"primaryHost,omitempty"`
	// Port of the immudb instance with database to replicate
	PrimaryPort *NullableUint32 `protobuf:"bytes,4,opt,name=primaryPort,proto3" json:"primaryPort,omitempty"`
	// Username of the user with read access of the database to replicate
	PrimaryUsername *NullableString `protobuf:"bytes,5,opt,name=primaryUsername,proto3" json:"primaryUsername,omitempty"`
	// Password of the user with read access of the database to replicate
	PrimaryPassword *NullableString `protobuf:"bytes,6,opt,name=primaryPassword,proto3" json:"primaryPassword,omitempty"`
	// Enable synchronous replication
	SyncReplication *NullableBool `protobuf:"bytes,7,opt,name=syncReplication,proto3" json:"syncReplication,omitempty"`
	// Number of confirmations from synchronous replicas required to commit a transaction
	SyncAcks *NullableUint32 `protobuf:"bytes,8,opt,name=syncAcks,proto3" json:"syncAcks,omitempty"`
	// Maximum number of prefetched transactions
	PrefetchTxBufferSize *NullableUint32 `protobuf:"bytes,9,opt,name=prefetchTxBufferSize,proto3" json:"prefetchTxBufferSize,omitempty"`
	// Number of concurrent replications
	ReplicationCommitConcurrency *NullableUint32 `protobuf:"bytes,10,opt,name=replicationCommitConcurrency,proto3" json:"replicationCommitConcurrency,omitempty"`
	// Allow precommitted transactions to be discarded if the replica diverges from the primary
	AllowTxDiscarding *NullableBool `protobuf:"bytes,11,opt,name=allowTxDiscarding,proto3" json:"allowTxDiscarding,omitempty"`
	// Disable integrity check when reading data during replication
	SkipIntegrityCheck *NullableBool `protobuf:"bytes,12,opt,name=skipIntegrityCheck,proto3" json:"skipIntegrityCheck,omitempty"`
	// Wait for indexing to be up to date during replication
	WaitForIndexing *NullableBool `protobuf:"bytes,13,opt,name=waitForIndexing,proto3" json:"waitForIndexing,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) GetAllowTxDiscarding added in v1.4.0 

func (x *ReplicationNullableSettings) GetAllowTxDiscarding() *NullableBool

func (*ReplicationNullableSettings) GetPrefetchTxBufferSize added in v1.4.0 

func (x *ReplicationNullableSettings) GetPrefetchTxBufferSize() *NullableUint32

func (*ReplicationNullableSettings) GetPrimaryDatabase added in v1.4.1 

func (x *ReplicationNullableSettings) GetPrimaryDatabase() *NullableString

func (*ReplicationNullableSettings) GetPrimaryHost added in v1.4.1 

func (x *ReplicationNullableSettings) GetPrimaryHost() *NullableString

func (*ReplicationNullableSettings) GetPrimaryPassword added in v1.4.1 

func (x *ReplicationNullableSettings) GetPrimaryPassword() *NullableString

func (*ReplicationNullableSettings) GetPrimaryPort added in v1.4.1 

func (x *ReplicationNullableSettings) GetPrimaryPort() *NullableUint32

func (*ReplicationNullableSettings) GetPrimaryUsername added in v1.4.1 

func (x *ReplicationNullableSettings) GetPrimaryUsername() *NullableString

func (*ReplicationNullableSettings) GetReplica added in v1.2.3 

func (x *ReplicationNullableSettings) GetReplica() *NullableBool

func (*ReplicationNullableSettings) GetReplicationCommitConcurrency added in v1.4.0 

func (x *ReplicationNullableSettings) GetReplicationCommitConcurrency() *NullableUint32

func (*ReplicationNullableSettings) GetSkipIntegrityCheck added in v1.5.0 

func (x *ReplicationNullableSettings) GetSkipIntegrityCheck() *NullableBool

func (*ReplicationNullableSettings) GetSyncAcks added in v1.4.0 

func (x *ReplicationNullableSettings) GetSyncAcks() *NullableUint32

func (*ReplicationNullableSettings) GetSyncReplication added in v1.4.0 

func (x *ReplicationNullableSettings) GetSyncReplication() *NullableBool

func (*ReplicationNullableSettings) GetWaitForIndexing added in v1.5.0 

func (x *ReplicationNullableSettings) GetWaitForIndexing() *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 {

	// Number of milliseconds after which the request can be retried
	RetryDelay int32 `protobuf:"varint,1,opt,name=retry_delay,json=retryDelay,proto3" json:"retry_delay,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use RetryInfo.ProtoReflect.Descriptor instead.

func (*RetryInfo) GetRetryDelay added in v1.0.5 

func (x *RetryInfo) GetRetryDelay() int32

func (*RetryInfo) ProtoMessage added in v1.0.5 

func (*RetryInfo) ProtoMessage()

func (*RetryInfo) ProtoReflect added in v1.0.5 

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

func (*RetryInfo) Reset added in v1.0.5 

func (x *RetryInfo) Reset()

func (*RetryInfo) String added in v1.0.5 

func (x *RetryInfo) String() string

type Row added in v1.0.0 

type Row struct {

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

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

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetColumns added in v1.0.0 

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

func (*Row) GetValues added in v1.0.0 

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

func (*Row) ProtoMessage added in v1.0.0 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect added in v1.0.0 

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

func (*Row) Reset added in v1.0.0 

func (x *Row) Reset()

func (*Row) String added in v1.0.0 

func (x *Row) String() string

type SQLEntry added in v1.0.0 

type SQLEntry struct {

	// Id of the transaction when the row was added / modified
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Raw key of the row
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Raw value of the row
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Metadata of the raw value
	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) Descriptor() ([]byte, []int)

Deprecated: Use SQLEntry.ProtoReflect.Descriptor instead.

func (*SQLEntry) GetKey added in v1.0.0 

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

func (*SQLEntry) GetMetadata added in v1.2.0 

func (x *SQLEntry) GetMetadata() *KVMetadata

func (*SQLEntry) GetTx added in v1.0.0 

func (x *SQLEntry) GetTx() uint64

func (*SQLEntry) GetValue added in v1.0.0 

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

func (*SQLEntry) ProtoMessage added in v1.0.0 

func (*SQLEntry) ProtoMessage()

func (*SQLEntry) ProtoReflect added in v1.0.0 

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

func (*SQLEntry) Reset added in v1.0.0 

func (x *SQLEntry) Reset()

func (*SQLEntry) String added in v1.0.0 

func (x *SQLEntry) String() string

type SQLExecRequest added in v1.0.0 

type SQLExecRequest struct {

	// SQL query
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Named query parameters
	Params []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// If true, do not wait for the indexer to index written changes
	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 {

	// List of committed transactions as a result of the exec operation
	Txs []*CommittedSQLTx `protobuf:"bytes,5,rep,name=txs,proto3" json:"txs,omitempty"`
	// If true, there's an ongoing transaction after exec completes
	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 name
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Values of the primary key
	PkValues []*SQLValue `protobuf:"bytes,2,rep,name=pkValues,proto3" json:"pkValues,omitempty"`
	// Id of the transaction at which the row was added / modified
	AtTx uint64 `protobuf:"varint,3,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require entries up to sinceTx to be indexed
	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 query
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Named query parameters
	Params []*NamedParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// If true, reuse previously opened snapshot
	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 {

	// Result columns description
	Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// Result rows
	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
	//	*SQLValue_F
	Value isSQLValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use SQLValue.ProtoReflect.Descriptor instead.

func (*SQLValue) GetB added in v1.0.0 

func (x *SQLValue) GetB() bool

func (*SQLValue) GetBs added in v1.0.0 

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

func (*SQLValue) GetF added in v1.5.0 

func (x *SQLValue) GetF() float64

func (*SQLValue) GetN added in v1.0.0 

func (x *SQLValue) GetN() int64

func (*SQLValue) GetNull added in v1.0.0 

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

func (*SQLValue) GetS added in v1.0.0 

func (x *SQLValue) GetS() string

func (*SQLValue) GetTs added in v1.2.0 

func (x *SQLValue) GetTs() int64

func (*SQLValue) GetValue added in v1.0.0 

func (m *SQLValue) GetValue() isSQLValue_Value

func (*SQLValue) ProtoMessage added in v1.0.0 

func (*SQLValue) ProtoMessage()

func (*SQLValue) ProtoReflect added in v1.0.0 

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

func (*SQLValue) Reset added in v1.0.0 

func (x *SQLValue) Reset()

func (*SQLValue) String added in v1.0.0 

func (x *SQLValue) String() string

type SQLValue_B added in v1.0.0 

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

func (*SQLValue_B) Equal added in v1.0.0 

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

type SQLValue_Bs added in v1.0.0 

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

func (*SQLValue_Bs) Equal added in v1.0.0 

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

type SQLValue_F added in v1.5.0 

type SQLValue_F struct {
	F float64 `protobuf:"fixed64,7,opt,name=f,proto3,oneof"`
}

func (*SQLValue_F) Equal added in v1.5.0 

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

type SQLValue_N added in v1.0.0 

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

func (*SQLValue_N) Equal added in v1.0.0 

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

type SQLValue_Null added in v1.0.0 

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

func (*SQLValue_Null) Equal added in v1.0.0 

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

type SQLValue_S added in v1.0.0 

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

func (*SQLValue_S) Equal added in v1.0.0 

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

type SQLValue_Ts added in v1.2.0 

type SQLValue_Ts struct {
	Ts int64 `protobuf:"varint,6,opt,name=ts,proto3,oneof"`
}

func (*SQLValue_Ts) Equal added in v1.2.0 

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

type ScanRequest added in v0.9.0 

type ScanRequest struct {

	// If not empty, continue scan at (when inclusiveSeek == true)
	// or after (when inclusiveSeek == false) that key
	SeekKey []byte `protobuf:"bytes,1,opt,name=seekKey,proto3" json:"seekKey,omitempty"`
	// stop at (when inclusiveEnd == true)
	// or before (when inclusiveEnd == false) that key
	EndKey []byte `protobuf:"bytes,7,opt,name=endKey,proto3" json:"endKey,omitempty"`
	// search for entries with this prefix only
	Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// If set to true, sort items in descending order
	Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// maximum number of entries to get, if not specified, the default value is used
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// If non-zero, only require transactions up to this transaction to be
	// indexed, newer transaction may still be pending
	SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// Deprecated: If set to true, do not wait for indexing to be done before finishing this call
	NoWait bool `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// If set to true, results will include seekKey
	InclusiveSeek bool `protobuf:"varint,8,opt,name=inclusiveSeek,proto3" json:"inclusiveSeek,omitempty"`
	// If set to true, results will include endKey if needed
	InclusiveEnd bool `protobuf:"varint,9,opt,name=inclusiveEnd,proto3" json:"inclusiveEnd,omitempty"`
	// Specify the initial entry to be returned by excluding the initial set of entries
	Offset uint64 `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,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) GetEndKey added in v1.3.0 

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

func (*ScanRequest) GetInclusiveEnd added in v1.3.0 

func (x *ScanRequest) GetInclusiveEnd() bool

func (*ScanRequest) GetInclusiveSeek added in v1.3.0 

func (x *ScanRequest) GetInclusiveSeek() 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) GetOffset added in v1.3.1 

func (x *ScanRequest) GetOffset() uint64

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 {

	// Entry's score value
	Score float64 `protobuf:"fixed64,1,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Score.ProtoReflect.Descriptor instead.

func (*Score) GetScore added in v0.8.1 

func (x *Score) GetScore() float64

func (*Score) ProtoMessage added in v0.8.1 

func (*Score) ProtoMessage()

func (*Score) ProtoReflect added in v0.9.0 

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

func (*Score) Reset added in v0.8.1 

func (x *Score) Reset()

func (*Score) String added in v0.8.1 

func (x *Score) String() string

type ServerInfoRequest added in v1.3.2 

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

ServerInfoRequest exists to provide extensibility for rpc ServerInfo.

func (*ServerInfoRequest) Descriptor deprecated added in v1.3.2 

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

Deprecated: Use ServerInfoRequest.ProtoReflect.Descriptor instead.

func (*ServerInfoRequest) ProtoMessage added in v1.3.2 

func (*ServerInfoRequest) ProtoMessage()

func (*ServerInfoRequest) ProtoReflect added in v1.3.2 

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

func (*ServerInfoRequest) Reset added in v1.3.2 

func (x *ServerInfoRequest) Reset()

func (*ServerInfoRequest) String added in v1.3.2 

func (x *ServerInfoRequest) String() string

type ServerInfoResponse added in v1.3.2 

type ServerInfoResponse struct {

	// The version of the server instance.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

ServerInfoResponse contains information about the server instance.

func (*ServerInfoResponse) Descriptor deprecated added in v1.3.2 

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

Deprecated: Use ServerInfoResponse.ProtoReflect.Descriptor instead.

func (*ServerInfoResponse) GetVersion added in v1.3.2 

func (x *ServerInfoResponse) GetVersion() string

func (*ServerInfoResponse) ProtoMessage added in v1.3.2 

func (*ServerInfoResponse) ProtoMessage()

func (*ServerInfoResponse) ProtoReflect added in v1.3.2 

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

func (*ServerInfoResponse) Reset added in v1.3.2 

func (x *ServerInfoResponse) Reset()

func (*ServerInfoResponse) String added in v1.3.2 

func (x *ServerInfoResponse) String() string

type SetActiveUserRequest added in v0.7.0 

type SetActiveUserRequest struct {

	// If true, the user is active
	Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	// Name of the user to activate / deactivate
	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 {

	// List of KV entries to set
	KVs []*KeyValue `protobuf:"bytes,1,rep,name=KVs,proto3" json:"KVs,omitempty"`
	// If set to true, do not wait for indexer to index ne entries
	NoWait bool `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// Preconditions to be met to perform the write
	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) Descriptor() ([]byte, []int)

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetPublicKey added in v0.8.0 

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

func (*Signature) GetSignature added in v0.8.0 

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

func (*Signature) ProtoMessage added in v0.8.0 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect added in v0.9.0 

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

func (*Signature) Reset added in v0.8.0 

func (x *Signature) Reset()

func (*Signature) String added in v0.8.0 

func (x *Signature) String() string

type SqlValue added in v1.0.0 

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

type Table added in v1.0.0 

type Table struct {

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

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

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetTableName added in v1.0.0 

func (x *Table) GetTableName() string

func (*Table) ProtoMessage added in v1.0.0 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect added in v1.0.0 

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

func (*Table) Reset added in v1.0.0 

func (x *Table) Reset()

func (*Table) String added in v1.0.0 

func (x *Table) String() string

type TruncateDatabaseRequest added in v1.5.0 

type TruncateDatabaseRequest struct {

	// Database name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Retention Period of data
	RetentionPeriod int64 `protobuf:"varint,2,opt,name=retentionPeriod,proto3" json:"retentionPeriod,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateDatabaseRequest) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use TruncateDatabaseRequest.ProtoReflect.Descriptor instead.

func (*TruncateDatabaseRequest) GetDatabase added in v1.5.0 

func (x *TruncateDatabaseRequest) GetDatabase() string

func (*TruncateDatabaseRequest) GetRetentionPeriod added in v1.5.0 

func (x *TruncateDatabaseRequest) GetRetentionPeriod() int64

func (*TruncateDatabaseRequest) ProtoMessage added in v1.5.0 

func (*TruncateDatabaseRequest) ProtoMessage()

func (*TruncateDatabaseRequest) ProtoReflect added in v1.5.0 

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

func (*TruncateDatabaseRequest) Reset added in v1.5.0 

func (x *TruncateDatabaseRequest) Reset()

func (*TruncateDatabaseRequest) String added in v1.5.0 

func (x *TruncateDatabaseRequest) String() string

type TruncateDatabaseResponse added in v1.5.0 

type TruncateDatabaseResponse struct {

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

func (*TruncateDatabaseResponse) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use TruncateDatabaseResponse.ProtoReflect.Descriptor instead.

func (*TruncateDatabaseResponse) GetDatabase added in v1.5.0 

func (x *TruncateDatabaseResponse) GetDatabase() string

func (*TruncateDatabaseResponse) ProtoMessage added in v1.5.0 

func (*TruncateDatabaseResponse) ProtoMessage()

func (*TruncateDatabaseResponse) ProtoReflect added in v1.5.0 

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

func (*TruncateDatabaseResponse) Reset added in v1.5.0 

func (x *TruncateDatabaseResponse) Reset()

func (*TruncateDatabaseResponse) String added in v1.5.0 

func (x *TruncateDatabaseResponse) String() string

type TruncationNullableSettings added in v1.5.0 

type TruncationNullableSettings struct {

	// Retention Period for data in the database
	RetentionPeriod *NullableMilliseconds `protobuf:"bytes,1,opt,name=retentionPeriod,proto3" json:"retentionPeriod,omitempty"`
	// Truncation Frequency for the database
	TruncationFrequency *NullableMilliseconds `protobuf:"bytes,2,opt,name=truncationFrequency,proto3" json:"truncationFrequency,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncationNullableSettings) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use TruncationNullableSettings.ProtoReflect.Descriptor instead.

func (*TruncationNullableSettings) GetRetentionPeriod added in v1.5.0 

func (x *TruncationNullableSettings) GetRetentionPeriod() *NullableMilliseconds

func (*TruncationNullableSettings) GetTruncationFrequency added in v1.5.0 

func (x *TruncationNullableSettings) GetTruncationFrequency() *NullableMilliseconds

func (*TruncationNullableSettings) ProtoMessage added in v1.5.0 

func (*TruncationNullableSettings) ProtoMessage()

func (*TruncationNullableSettings) ProtoReflect added in v1.5.0 

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

func (*TruncationNullableSettings) Reset added in v1.5.0 

func (x *TruncationNullableSettings) Reset()

func (*TruncationNullableSettings) String added in v1.5.0 

func (x *TruncationNullableSettings) String() string

type Tx added in v0.9.0 

type Tx struct {

	// Transaction header
	Header *TxHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Raw entry values
	Entries []*TxEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// KV entries in the transaction (parsed)
	KvEntries []*Entry `protobuf:"bytes,3,rep,name=kvEntries,proto3" json:"kvEntries,omitempty"`
	// Sorted Set entries in the transaction (parsed)
	ZEntries []*ZEntry `protobuf:"bytes,4,rep,name=zEntries,proto3" json:"zEntries,omitempty"`
	// contains filtered or unexported fields
}

func TxToProto added in v1.2.0 

func TxToProto(tx *store.Tx) *Tx

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

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

Deprecated: Use Tx.ProtoReflect.Descriptor instead.

func (*Tx) GetEntries added in v0.9.0 

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

func (*Tx) GetHeader added in v1.2.0 

func (x *Tx) GetHeader() *TxHeader

func (*Tx) GetKvEntries added in v1.2.3 

func (x *Tx) GetKvEntries() []*Entry

func (*Tx) GetZEntries added in v1.2.3 

func (x *Tx) GetZEntries() []*ZEntry

func (*Tx) ProtoMessage added in v0.9.0 

func (*Tx) ProtoMessage()

func (*Tx) ProtoReflect added in v0.9.0 

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

func (*Tx) Reset added in v0.9.0 

func (x *Tx) Reset()

func (*Tx) String added in v0.9.0 

func (x *Tx) String() string

type TxEntry added in v0.9.0 

type TxEntry struct {

	// Raw key value (contains 1-byte prefix for kind of the key)
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value hash
	HValue []byte `protobuf:"bytes,2,opt,name=hValue,proto3" json:"hValue,omitempty"`
	// Value length
	VLen int32 `protobuf:"varint,3,opt,name=vLen,proto3" json:"vLen,omitempty"`
	// Entry metadata
	Metadata *KVMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// value, must be ignored when len(value) == 0 and vLen > 0.
	// Otherwise sha256(value) must be equal to hValue.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func TxEntryToProto added in v1.2.3 

func TxEntryToProto(e *store.TxEntry) *TxEntry

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

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

Deprecated: Use TxEntry.ProtoReflect.Descriptor instead.

func (*TxEntry) GetHValue added in v0.9.0 

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

func (*TxEntry) GetKey added in v0.9.0 

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

func (*TxEntry) GetMetadata added in v1.2.0 

func (x *TxEntry) GetMetadata() *KVMetadata

func (*TxEntry) GetVLen added in v0.9.0 

func (x *TxEntry) GetVLen() int32

func (*TxEntry) GetValue added in v1.2.3 

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

func (*TxEntry) ProtoMessage added in v0.9.0 

func (*TxEntry) ProtoMessage()

func (*TxEntry) ProtoReflect added in v0.9.0 

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

func (*TxEntry) Reset added in v0.9.0 

func (x *TxEntry) Reset()

func (*TxEntry) String added in v0.9.0 

func (x *TxEntry) String() string

type TxHeader added in v1.2.0 

type TxHeader struct {

	// Transaction ID
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// State value (Accumulative Hash - Alh) of the previous transaction
	PrevAlh []byte `protobuf:"bytes,2,opt,name=prevAlh,proto3" json:"prevAlh,omitempty"`
	// Unix timestamp of the transaction (in seconds)
	Ts int64 `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	// Number of entries in a transaction
	Nentries int32 `protobuf:"varint,4,opt,name=nentries,proto3" json:"nentries,omitempty"`
	// Entries Hash - cumulative hash of all entries in the transaction
	EH []byte `protobuf:"bytes,5,opt,name=eH,proto3" json:"eH,omitempty"`
	// Binary linking tree transaction ID
	// (ID of last transaction already in the main Merkle Tree)
	BlTxId uint64 `protobuf:"varint,6,opt,name=blTxId,proto3" json:"blTxId,omitempty"`
	// Binary linking tree root (Root hash of the Merkle Tree)
	BlRoot []byte `protobuf:"bytes,7,opt,name=blRoot,proto3" json:"blRoot,omitempty"`
	// Header version
	Version int32 `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"`
	// Transaction metadata
	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 TxHeaderToProto(hdr *store.TxHeader) *TxHeader

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

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

Deprecated: Use TxHeader.ProtoReflect.Descriptor instead.

func (*TxHeader) GetBlRoot added in v1.2.0 

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

func (*TxHeader) GetBlTxId added in v1.2.0 

func (x *TxHeader) GetBlTxId() uint64

func (*TxHeader) GetEH added in v1.2.0 

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

func (*TxHeader) GetId added in v1.2.0 

func (x *TxHeader) GetId() uint64

func (*TxHeader) GetMetadata added in v1.2.0 

func (x *TxHeader) GetMetadata() *TxMetadata

func (*TxHeader) GetNentries added in v1.2.0 

func (x *TxHeader) GetNentries() int32

func (*TxHeader) GetPrevAlh added in v1.2.0 

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

func (*TxHeader) GetTs added in v1.2.0 

func (x *TxHeader) GetTs() int64

func (*TxHeader) GetVersion added in v1.2.0 

func (x *TxHeader) GetVersion() int32

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

func (*TxHeader) Reset added in v1.2.0 

func (x *TxHeader) Reset()

func (*TxHeader) String added in v1.2.0 

func (x *TxHeader) String() string

type TxList added in v0.9.1 

type TxList struct {

	// List of transactions
	Txs []*Tx `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use TxList.ProtoReflect.Descriptor instead.

func (*TxList) GetTxs added in v0.9.1 

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

func (*TxList) ProtoMessage added in v0.9.1 

func (*TxList) ProtoMessage()

func (*TxList) ProtoReflect added in v0.9.1 

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

func (*TxList) Reset added in v0.9.1 

func (x *TxList) Reset()

func (*TxList) String added in v0.9.1 

func (x *TxList) String() string

type TxMetadata added in v0.9.0 

type TxMetadata struct {

	// Entry expiration information
	TruncatedTxID uint64 `protobuf:"varint,1,opt,name=truncatedTxID,proto3" json:"truncatedTxID,omitempty"`
	// Extra data
	Extra []byte `protobuf:"bytes,2,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

TxMetadata contains metadata set to whole transaction

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) GetExtra 

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

func (*TxMetadata) GetTruncatedTxID added in v1.5.0 

func (x *TxMetadata) GetTruncatedTxID() uint64

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
const (
	// Read-only transaction
	TxMode_ReadOnly TxMode = 0
	// Write-only transaction
	TxMode_WriteOnly TxMode = 1
	// Read-write transaction
	TxMode_ReadWrite TxMode = 2
)

func (TxMode) Descriptor added in v1.2.0 

func (TxMode) Descriptor() protoreflect.EnumDescriptor

func (TxMode) Enum added in v1.2.0 

func (x TxMode) Enum() *TxMode

func (TxMode) EnumDescriptor deprecated added in v1.2.0 

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

Deprecated: Use TxMode.Descriptor instead.

func (TxMode) Number added in v1.2.0 

func (x TxMode) Number() protoreflect.EnumNumber

func (TxMode) String added in v1.2.0 

func (x TxMode) String() string

func (TxMode) Type added in v1.2.0 

func (TxMode) Type() protoreflect.EnumType

type TxRequest added in v0.9.0 

type TxRequest struct {

	// Transaction id to query for
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Specification for parsing entries, if empty, entries are returned in raw form
	EntriesSpec *EntriesSpec `protobuf:"bytes,2,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require
	// entries up to sinceTx to be indexed, will affect resolving references
	SinceTx uint64 `protobuf:"varint,3,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// Deprecated: If set to true, do not wait for the indexer to be up to date
	NoWait bool `protobuf:"varint,4,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// If set to true, do not resolve references (avoid looking up final values if not needed)
	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) Descriptor() ([]byte, []int)

Deprecated: Use TxRequest.ProtoReflect.Descriptor instead.

func (*TxRequest) GetEntriesSpec added in v1.2.3 

func (x *TxRequest) GetEntriesSpec() *EntriesSpec

func (*TxRequest) GetKeepReferencesUnresolved added in v1.2.4 

func (x *TxRequest) GetKeepReferencesUnresolved() bool

func (*TxRequest) GetNoWait added in v1.2.3 

func (x *TxRequest) GetNoWait() bool

func (*TxRequest) GetSinceTx added in v1.2.3 

func (x *TxRequest) GetSinceTx() uint64

func (*TxRequest) GetTx added in v0.9.0 

func (x *TxRequest) GetTx() uint64

func (*TxRequest) ProtoMessage added in v0.9.0 

func (*TxRequest) ProtoMessage()

func (*TxRequest) ProtoReflect added in v0.9.0 

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

func (*TxRequest) Reset added in v0.9.0 

func (x *TxRequest) Reset()

func (*TxRequest) String added in v0.9.0 

func (x *TxRequest) String() string

type TxScanRequest added in v0.9.1 

type TxScanRequest struct {

	// ID of the transaction where scanning should start
	InitialTx uint64 `protobuf:"varint,1,opt,name=initialTx,proto3" json:"initialTx,omitempty"`
	// Maximum number of transactions to scan, when not specified the default limit is used
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// If set to true, scan transactions in descending order
	Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// Specification of how to parse entries
	EntriesSpec *EntriesSpec `protobuf:"bytes,4,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require
	// entries up to sinceTx to be indexed, will affect resolving references
	SinceTx uint64 `protobuf:"varint,5,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// Deprecated: If set to true, do not wait for the indexer to be up to date
	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 should be embedded to have forward compatible implementations.

func (UnimplementedImmuServiceServer) ChangePassword 

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

func (UnimplementedImmuServiceServer) ChangePermission added in v0.7.0 

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

func (UnimplementedImmuServiceServer) CloseSession added in v1.2.0 

func (UnimplementedImmuServiceServer) CloseSession(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedImmuServiceServer) Commit added in v1.2.0 

func (UnimplementedImmuServiceServer) Commit(context.Context, *emptypb.Empty) (*CommittedSQLTx, error)

func (UnimplementedImmuServiceServer) CompactIndex added in v1.0.5 

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

func (UnimplementedImmuServiceServer) Count 

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

func (UnimplementedImmuServiceServer) CountAll added in v0.8.1 

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

func (UnimplementedImmuServiceServer) CreateDatabase added in v0.7.0 

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

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) (*emptypb.Empty, error)

func (UnimplementedImmuServiceServer) CreateUser 

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

func (UnimplementedImmuServiceServer) CurrentState added in v0.9.0 

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

func (UnimplementedImmuServiceServer) DatabaseHealth added in v1.2.3 

func (UnimplementedImmuServiceServer) DatabaseHealth(context.Context, *emptypb.Empty) (*DatabaseHealthResponse, error)

func (UnimplementedImmuServiceServer) DatabaseList added in v0.7.0 

func (UnimplementedImmuServiceServer) DatabaseList(context.Context, *emptypb.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, *emptypb.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, *emptypb.Empty) (*HealthResponse, error)

func (UnimplementedImmuServiceServer) History 

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

func (UnimplementedImmuServiceServer) KeepAlive added in v1.2.0 

func (UnimplementedImmuServiceServer) KeepAlive(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedImmuServiceServer) ListTables added in v1.0.0 

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

func (UnimplementedImmuServiceServer) ListUsers 

func (UnimplementedImmuServiceServer) ListUsers(context.Context, *emptypb.Empty) (*UserList, 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) Logout added in v0.6.1 

func (UnimplementedImmuServiceServer) Logout(context.Context, *emptypb.Empty) (*emptypb.Empty, 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) Rollback added in v1.2.0 

func (UnimplementedImmuServiceServer) Rollback(context.Context, *emptypb.Empty) (*emptypb.Empty, 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) ServerInfo added in v1.3.2 

func (UnimplementedImmuServiceServer) ServerInfo(context.Context, *ServerInfoRequest) (*ServerInfoResponse, 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) (*emptypb.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) StreamExportTx added in v1.5.0 

func (UnimplementedImmuServiceServer) StreamExportTx(ImmuService_StreamExportTxServer) 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) TruncateDatabase added in v1.5.0 

func (UnimplementedImmuServiceServer) TruncateDatabase(context.Context, *TruncateDatabaseRequest) (*TruncateDatabaseResponse, error)

func (UnimplementedImmuServiceServer) TxById added in v0.9.0 

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

func (UnimplementedImmuServiceServer) TxSQLExec added in v1.2.0 

func (UnimplementedImmuServiceServer) TxSQLExec(context.Context, *SQLExecRequest) (*emptypb.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) (*emptypb.Empty, error)

func (UnimplementedImmuServiceServer) UpdateDatabase added in v1.0.5 

func (UnimplementedImmuServiceServer) UpdateDatabase(context.Context, *DatabaseSettings) (*emptypb.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) (*emptypb.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 name
	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 name
	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 UnsafeImmuServiceServer added in v1.3.2 

type UnsafeImmuServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeImmuServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ImmuServiceServer will result in compilation errors.

type UpdateDatabaseRequest added in v1.2.3 

type UpdateDatabaseRequest struct {

	// Database name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Updated settings
	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 name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Current database settings
	Settings *DatabaseNullableSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

Reserved to reply with more advanced response later

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 {

	// Deprecated: database access token
	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 {

	// Username
	User []byte `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// List of permissions for the user
	Permissions []*Permission `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"`
	// Name of the creator user
	Createdby string `protobuf:"bytes,4,opt,name=createdby,proto3" json:"createdby,omitempty"`
	// Time when the user was created
	Createdat string `protobuf:"bytes,5,opt,name=createdat,proto3" json:"createdat,omitempty"`
	// Flag indicating whether the user is active or not
	Active bool `protobuf:"varint,6,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetActive added in v0.7.0 

func (x *User) GetActive() bool

func (*User) GetCreatedat added in v0.7.0 

func (x *User) GetCreatedat() string

func (*User) GetCreatedby added in v0.7.0 

func (x *User) GetCreatedby() string

func (*User) GetPermissions 

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

func (*User) GetUser 

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

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v0.9.0 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type UserList 

type UserList struct {

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

func (*UserList) Descriptor deprecated 

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

Deprecated: Use UserList.ProtoReflect.Descriptor instead.

func (*UserList) GetUsers 

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

func (*UserList) ProtoMessage 

func (*UserList) ProtoMessage()

func (*UserList) ProtoReflect added in v0.9.0 

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

func (*UserList) Reset 

func (x *UserList) Reset()

func (*UserList) String 

func (x *UserList) String() string

type UserRequest 

type UserRequest struct {

	// Username
	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 to verify
	Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// Transaction to verify
	VerifiableTx *VerifiableTx `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"`
	// Proof for inclusion of the entry within the transaction
	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 {

	// Key to read
	KeyRequest *KeyRequest `protobuf:"bytes,1,opt,name=keyRequest,proto3" json:"keyRequest,omitempty"`
	// When generating the proof, generate consistency proof with state from this transaction
	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 {

	// Reference data
	ReferenceRequest *ReferenceRequest `protobuf:"bytes,1,opt,name=referenceRequest,proto3" json:"referenceRequest,omitempty"`
	// When generating the proof, generate consistency proof with state from this
	// transaction
	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 {

	// Raw row entry data
	SqlEntry *SQLEntry `protobuf:"bytes,1,opt,name=sqlEntry,proto3" json:"sqlEntry,omitempty"`
	// Verifiable transaction of the row
	VerifiableTx *VerifiableTx `protobuf:"bytes,2,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"`
	// Inclusion proof of the row in the transaction
	InclusionProof *InclusionProof `protobuf:"bytes,3,opt,name=inclusionProof,proto3" json:"inclusionProof,omitempty"`
	// Internal ID of the database (used to validate raw entry values)
	DatabaseId uint32 `protobuf:"varint,4,opt,name=DatabaseId,proto3" json:"DatabaseId,omitempty"`
	// Internal ID of the table (used to validate raw entry values)
	TableId uint32 `protobuf:"varint,5,opt,name=TableId,proto3" json:"TableId,omitempty"`
	// Internal IDs of columns for the primary key (used to validate raw entry values)
	PKIDs []uint32 `protobuf:"varint,16,rep,packed,name=PKIDs,proto3" json:"PKIDs,omitempty"`
	// Mapping of used column IDs to their names
	ColNamesById map[uint32]string `` /* 166-byte string literal not displayed */
	// Mapping of column names to their IDS
	ColIdsByName map[string]uint32 `` /* 166-byte string literal not displayed */
	// Mapping of column IDs to their types
	ColTypesById map[uint32]string `` /* 167-byte string literal not displayed */
	// Mapping of column IDs to their length constraints
	ColLenById map[uint32]int32 `` /* 164-byte string literal not displayed */
	// Variable is used to assign unique ids to new columns as they are created
	MaxColId uint32 `protobuf:"varint,12,opt,name=MaxColId,proto3" json:"MaxColId,omitempty"`
	// 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) GetMaxColId 

func (x *VerifiableSQLEntry) GetMaxColId() uint32

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 {

	// Data of row to query
	SqlGetRequest *SQLGetRequest `protobuf:"bytes,1,opt,name=sqlGetRequest,proto3" json:"sqlGetRequest,omitempty"`
	// When generating the proof, generate consistency proof with state from this transaction
	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 {

	// Keys to set
	SetRequest *SetRequest `protobuf:"bytes,1,opt,name=setRequest,proto3" json:"setRequest,omitempty"`
	// When generating the proof, generate consistency proof with state from this transaction
	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 {

	// Transaction to verify
	Tx *Tx `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Proof for the transaction
	DualProof *DualProof `protobuf:"bytes,2,opt,name=dualProof,proto3" json:"dualProof,omitempty"`
	// Signature for the new state value
	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 {

	// Transaction ID
	Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// When generating the proof, generate consistency proof with state from this
	// transaction
	ProveSinceTx uint64 `protobuf:"varint,2,opt,name=proveSinceTx,proto3" json:"proveSinceTx,omitempty"`
	// Specification of how to parse entries
	EntriesSpec *EntriesSpec `protobuf:"bytes,3,opt,name=entriesSpec,proto3" json:"entriesSpec,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require
	// entries up to sinceTx to be indexed, will affect resolving references
	SinceTx uint64 `protobuf:"varint,4,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// Deprecated: If set to true, do not wait for the indexer to be up to date
	NoWait bool `protobuf:"varint,5,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// If set to true, do not resolve references (avoid looking up final values if not needed)
	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 VerifiableTxV2 added in v1.5.0 

type VerifiableTxV2 struct {

	// Transaction to verify
	Tx *Tx `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Proof for the transaction
	DualProof *DualProofV2 `protobuf:"bytes,2,opt,name=dualProof,proto3" json:"dualProof,omitempty"`
	// Signature for the new state value
	Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifiableTxV2) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use VerifiableTxV2.ProtoReflect.Descriptor instead.

func (*VerifiableTxV2) GetDualProof added in v1.5.0 

func (x *VerifiableTxV2) GetDualProof() *DualProofV2

func (*VerifiableTxV2) GetSignature added in v1.5.0 

func (x *VerifiableTxV2) GetSignature() *Signature

func (*VerifiableTxV2) GetTx added in v1.5.0 

func (x *VerifiableTxV2) GetTx() *Tx

func (*VerifiableTxV2) ProtoMessage added in v1.5.0 

func (*VerifiableTxV2) ProtoMessage()

func (*VerifiableTxV2) ProtoReflect added in v1.5.0 

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

func (*VerifiableTxV2) Reset added in v1.5.0 

func (x *VerifiableTxV2) Reset()

func (*VerifiableTxV2) String added in v1.5.0 

func (x *VerifiableTxV2) String() string

type VerifiableZAddRequest added in v0.9.0 

type VerifiableZAddRequest struct {

	// Data for new sorted set entry
	ZAddRequest *ZAddRequest `protobuf:"bytes,1,opt,name=zAddRequest,proto3" json:"zAddRequest,omitempty"`
	// When generating the proof, generate consistency proof with state from this transaction
	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 {

	// Name of the sorted set
	Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	// Score of the new entry
	Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	// Referenced key
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// If boundRef == true, id of the transaction to bind with the reference
	AtTx uint64 `protobuf:"varint,4,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// If true, bind the reference to particular transaction, if false, use the
	// most recent value of the key
	BoundRef bool `protobuf:"varint,5,opt,name=boundRef,proto3" json:"boundRef,omitempty"`
	// If true, do not wait for the indexer to index this write operation
	NoWait bool `protobuf:"varint,6,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ZAddRequest.ProtoReflect.Descriptor instead.

func (*ZAddRequest) GetAtTx added in v0.9.0 

func (x *ZAddRequest) GetAtTx() uint64

func (*ZAddRequest) GetBoundRef added in v0.9.1 

func (x *ZAddRequest) GetBoundRef() bool

func (*ZAddRequest) GetKey added in v0.9.0 

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

func (*ZAddRequest) GetNoWait added in v0.9.2 

func (x *ZAddRequest) GetNoWait() bool

func (*ZAddRequest) GetScore added in v0.9.0 

func (x *ZAddRequest) GetScore() float64

func (*ZAddRequest) GetSet added in v0.9.0 

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

func (*ZAddRequest) ProtoMessage added in v0.9.0 

func (*ZAddRequest) ProtoMessage()

func (*ZAddRequest) ProtoReflect added in v0.9.0 

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

func (*ZAddRequest) Reset added in v0.9.0 

func (x *ZAddRequest) Reset()

func (*ZAddRequest) String added in v0.9.0 

func (x *ZAddRequest) String() string

type ZEntries added in v0.9.0 

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

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

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

Deprecated: Use ZEntries.ProtoReflect.Descriptor instead.

func (*ZEntries) GetEntries added in v0.9.0 

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

func (*ZEntries) ProtoMessage added in v0.9.0 

func (*ZEntries) ProtoMessage()

func (*ZEntries) ProtoReflect added in v0.9.0 

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

func (*ZEntries) Reset added in v0.9.0 

func (x *ZEntries) Reset()

func (*ZEntries) String added in v0.9.0 

func (x *ZEntries) String() string

type ZEntry added in v0.9.0 

type ZEntry struct {

	// Name of the sorted set
	Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	// Referenced key
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Referenced entry
	Entry *Entry `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	// Sorted set element's score
	Score float64 `protobuf:"fixed64,4,opt,name=score,proto3" json:"score,omitempty"`
	// At which transaction the key is bound,
	// 0 if reference is not bound and should read the most recent reference
	AtTx uint64 `protobuf:"varint,5,opt,name=atTx,proto3" json:"atTx,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ZEntry.ProtoReflect.Descriptor instead.

func (*ZEntry) GetAtTx added in v0.9.0 

func (x *ZEntry) GetAtTx() uint64

func (*ZEntry) GetEntry added in v0.9.0 

func (x *ZEntry) GetEntry() *Entry

func (*ZEntry) GetKey added in v0.9.0 

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

func (*ZEntry) GetScore added in v0.9.0 

func (x *ZEntry) GetScore() float64

func (*ZEntry) GetSet added in v0.9.0 

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

func (*ZEntry) ProtoMessage added in v0.9.0 

func (*ZEntry) ProtoMessage()

func (*ZEntry) ProtoReflect added in v0.9.0 

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

func (*ZEntry) Reset added in v0.9.0 

func (x *ZEntry) Reset()

func (*ZEntry) String added in v0.9.0 

func (x *ZEntry) String() string

type ZScanRequest added in v0.9.0 

type ZScanRequest struct {

	// Name of the sorted set
	Set []byte `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	// Key to continue the search at
	SeekKey []byte `protobuf:"bytes,2,opt,name=seekKey,proto3" json:"seekKey,omitempty"`
	// Score of the entry to continue the search at
	SeekScore float64 `protobuf:"fixed64,3,opt,name=seekScore,proto3" json:"seekScore,omitempty"`
	// AtTx of the entry to continue the search at
	SeekAtTx uint64 `protobuf:"varint,4,opt,name=seekAtTx,proto3" json:"seekAtTx,omitempty"`
	// If true, include the entry given with the `seekXXX` attributes, if false,
	// skip the entry and start after that one
	InclusiveSeek bool `protobuf:"varint,5,opt,name=inclusiveSeek,proto3" json:"inclusiveSeek,omitempty"`
	// Maximum number of entries to return, if 0, the default limit will be used
	Limit uint64 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// If true, scan entries in descending order
	Desc bool `protobuf:"varint,7,opt,name=desc,proto3" json:"desc,omitempty"`
	// Minimum score of entries to scan
	MinScore *Score `protobuf:"bytes,8,opt,name=minScore,proto3" json:"minScore,omitempty"`
	// Maximum score of entries to scan
	MaxScore *Score `protobuf:"bytes,9,opt,name=maxScore,proto3" json:"maxScore,omitempty"`
	// If > 0, do not wait for the indexer to index all entries, only require
	// entries up to sinceTx to be indexed
	SinceTx uint64 `protobuf:"varint,10,opt,name=sinceTx,proto3" json:"sinceTx,omitempty"`
	// Deprecated: If set to true, do not wait for the indexer to be up to date
	NoWait bool `protobuf:"varint,11,opt,name=noWait,proto3" json:"noWait,omitempty"`
	// Specify the index of initial entry to be returned by excluding the initial
	// set of entries (alternative to seekXXX attributes)
	Offset uint64 `protobuf:"varint,12,opt,name=offset,proto3" json:"offset,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) GetOffset added in v1.3.1 

func (x *ZScanRequest) GetOffset() uint64

func (*ZScanRequest) GetSeekAtTx added in v0.9.0 

func (x *ZScanRequest) GetSeekAtTx() uint64

func (*ZScanRequest) GetSeekKey added in v0.9.0 

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

func (*ZScanRequest) GetSeekScore added in v0.9.0 

func (x *ZScanRequest) GetSeekScore() float64

func (*ZScanRequest) GetSet added in v0.9.0 

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

func (*ZScanRequest) GetSinceTx added in v0.9.0 

func (x *ZScanRequest) GetSinceTx() uint64

func (*ZScanRequest) ProtoMessage added in v0.9.0 

func (*ZScanRequest) ProtoMessage()

func (*ZScanRequest) ProtoReflect added in v0.9.0 

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

func (*ZScanRequest) Reset added in v0.9.0 

func (x *ZScanRequest) Reset()

func (*ZScanRequest) String added in v0.9.0 

func (x *ZScanRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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