server

Jun 20, 2023

Changes in this version

+ var ErrTruncatorDoesNotExist = errors.New("truncator does not exist")

+ var ErrTruncatorNotInProgress = errors.New("truncation is not in progress")

+ var ErrTruncatorNotNeeded = errors.New("truncator is not needed")

type ImmuServer

+ func (s *ImmuServer) AuditDocument(ctx context.Context, req *protomodel.AuditDocumentRequest) (*protomodel.AuditDocumentResponse, error)

+ func (s *ImmuServer) CountDocuments(ctx context.Context, req *protomodel.CountDocumentsRequest) (*protomodel.CountDocumentsResponse, error)

+ func (s *ImmuServer) CreateCollection(ctx context.Context, req *protomodel.CreateCollectionRequest) (*protomodel.CreateCollectionResponse, error)

+ func (s *ImmuServer) CreateIndex(ctx context.Context, req *protomodel.CreateIndexRequest) (*protomodel.CreateIndexResponse, error)

+ func (s *ImmuServer) DeleteCollection(ctx context.Context, req *protomodel.DeleteCollectionRequest) (*protomodel.DeleteCollectionResponse, error)

+ func (s *ImmuServer) DeleteDocuments(ctx context.Context, req *protomodel.DeleteDocumentsRequest) (*protomodel.DeleteDocumentsResponse, error)

+ func (s *ImmuServer) DeleteIndex(ctx context.Context, req *protomodel.DeleteIndexRequest) (*protomodel.DeleteIndexResponse, error)

+ func (s *ImmuServer) GetCollection(ctx context.Context, req *protomodel.GetCollectionRequest) (*protomodel.GetCollectionResponse, error)

+ func (s *ImmuServer) GetCollections(ctx context.Context, req *protomodel.GetCollectionsRequest) (*protomodel.GetCollectionsResponse, error)

+ func (s *ImmuServer) InsertDocuments(ctx context.Context, req *protomodel.InsertDocumentsRequest) (*protomodel.InsertDocumentsResponse, error)

+ func (s *ImmuServer) ProofDocument(ctx context.Context, req *protomodel.ProofDocumentRequest) (*protomodel.ProofDocumentResponse, error)

+ func (s *ImmuServer) ReplaceDocuments(ctx context.Context, req *protomodel.ReplaceDocumentsRequest) (*protomodel.ReplaceDocumentsResponse, error)

+ func (s *ImmuServer) SearchDocuments(ctx context.Context, req *protomodel.SearchDocumentsRequest) (*protomodel.SearchDocumentsResponse, error)

+ func (s *ImmuServer) StreamExportTx(stream schema.ImmuService_StreamExportTxServer) error

+ func (s *ImmuServer) TruncateDatabase(ctx context.Context, req *schema.TruncateDatabaseRequest) (res *schema.TruncateDatabaseResponse, err error)

+ func (s *ImmuServer) UpdateCollection(ctx context.Context, req *protomodel.UpdateCollectionRequest) (*protomodel.UpdateCollectionResponse, error)

type Options

+ GRPCReflectionServerEnabled bool

+ func (o *Options) WithGRPCReflectionServerEnabled(enabled bool) *Options

type ReplicationOptions

+ SkipIntegrityCheck bool

+ WaitForIndexing bool

+ func DefaultReplicationOptions() *ReplicationOptions

+ func (opts *ReplicationOptions) WithSkipIntegrityCheck(skipIntegrityCheck bool) *ReplicationOptions

+ func (opts *ReplicationOptions) WithWaitForIndexing(waitForIndexingç bool) *ReplicationOptions

Nov 21, 2022

Changes in this version

+ var ErrCantUpdateAdminPassword = errors.New("can not update sysadmin password")

type Options

+ ForceAdminPassword bool

+ func (o *Options) WithForceAdminPassword(forceAdminPassword bool) *Options

type ReplicationOptions

+ PrimaryHost string

+ PrimaryPassword string

+ PrimaryPort int

+ PrimaryUsername string

+ func (opts *ReplicationOptions) WithPrimaryHost(primaryHost string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithPrimaryPassword(primaryPassword string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithPrimaryPort(primaryPort int) *ReplicationOptions

+ func (opts *ReplicationOptions) WithPrimaryUsername(primaryUsername string) *ReplicationOptions

Nov 16, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Oct 12, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type ImmuServer

+ func (s *ImmuServer) WithDbList(dbList database.DatabaseList) ImmuServerIf

type ImmuServerIf

+ WithDbList func(dbList database.DatabaseList) ImmuServerIf

type ReplicationOptions

+ AllowTxDiscarding bool

+ IsReplica bool

+ PrefetchTxBufferSize int

+ ReplicationCommitConcurrency int

+ SyncAcks int

+ SyncReplication bool

+ func (opts *ReplicationOptions) WithAllowTxDiscarding(allowTxDiscarding bool) *ReplicationOptions

+ func (opts *ReplicationOptions) WithIsReplica(isReplica bool) *ReplicationOptions

+ func (opts *ReplicationOptions) WithPrefetchTxBufferSize(prefetchTxBufferSize int) *ReplicationOptions

+ func (opts *ReplicationOptions) WithReplicationCommitConcurrency(replicationCommitConcurrency int) *ReplicationOptions

+ func (opts *ReplicationOptions) WithSyncAcks(syncAcks int) *ReplicationOptions

+ func (opts *ReplicationOptions) WithSyncReplication(syncReplication bool) *ReplicationOptions

type VersionResponse

+ FIPS bool

Oct 10, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Oct 4, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Aug 25, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type ImmuServer

+ func (s *ImmuServer) ServerInfo(ctx context.Context, req *schema.ServerInfoRequest) (*schema.ServerInfoResponse, error)

+ type Milliseconds int64

type Options

+ LogFormat string

+ PProf bool

+ func (o *Options) IsFileLogger() bool

+ func (o *Options) IsJSONLogger() bool

+ func (o *Options) WithLogFormat(logFormat string) *Options

+ func (o *Options) WithPProf(pprof bool) *Options

Aug 24, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Jun 30, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type MetricsCollection

+ RemoteStorageKind *prometheus.GaugeVec

type Options

+ MetricsServerPort int

+ func (o *Options) WithMetricsServerPort(port int) *Options

Jun 30, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

May 23, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

May 20, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Apr 28, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Apr 27, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Apr 14, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrDatabaseAlreadyLoaded = errors.New("database already loaded")

+ var ErrReplicatorNotNeeded = errors.New("replicator is not needed")

type ImmuServer

+ func (s *ImmuServer) CreateDatabaseV2(ctx context.Context, req *schema.CreateDatabaseRequest) (res *schema.CreateDatabaseResponse, err error)

+ func (s *ImmuServer) DatabaseHealth(ctx context.Context, _ *empty.Empty) (*schema.DatabaseHealthResponse, error)

+ func (s *ImmuServer) DatabaseListV2(ctx context.Context, req *schema.DatabaseListRequestV2) (*schema.DatabaseListResponseV2, error)

+ func (s *ImmuServer) DeleteDatabase(ctx context.Context, req *schema.DeleteDatabaseRequest) (res *schema.DeleteDatabaseResponse, err error)

+ func (s *ImmuServer) FlushIndex(ctx context.Context, req *schema.FlushIndexRequest) (*schema.FlushIndexResponse, error)

+ func (s *ImmuServer) GetDatabaseSettings(ctx context.Context, _ *empty.Empty) (*schema.DatabaseSettings, error)

+ func (s *ImmuServer) GetDatabaseSettingsV2(ctx context.Context, _ *schema.DatabaseSettingsRequest) (*schema.DatabaseSettingsResponse, error)

+ func (s *ImmuServer) LoadDatabase(ctx context.Context, req *schema.LoadDatabaseRequest) (res *schema.LoadDatabaseResponse, err error)

+ func (s *ImmuServer) UnloadDatabase(ctx context.Context, req *schema.UnloadDatabaseRequest) (res *schema.UnloadDatabaseResponse, err error)

+ func (s *ImmuServer) UpdateDatabaseV2(ctx context.Context, req *schema.UpdateDatabaseRequest) (res *schema.UpdateDatabaseResponse, err error)

Apr 13, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Jan 18, 2022 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type RemoteStorageOptions

+ S3Location string

+ func (opts *RemoteStorageOptions) WithS3Location(s3Location string) *RemoteStorageOptions

Dec 14, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrTxReadConflict = errors.New(store.ErrTxReadConflict.Error()).WithCode(errors.CodInFailedSqlTransaction)

Dec 10, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrNoSessionIDPresent = errors.New("no sessionID provided")

+ var ErrOngoingReadWriteTx = sessions.ErrOngoingReadWriteTx

+ var ErrReadWriteTxNotOngoing = errors.New("read write transaction not ongoing")

+ var ErrSessionAlreadyPresent = errors.New("session already present").WithCode(errors.CodInternalError)

+ var ErrSessionNotFound = errors.New("session not found").WithCode(errors.CodSqlserverRejectedEstablishmentOfSqlSession)

+ var ErrTxNotProperlyClosed = errors.New("tx not properly closed")

type ImmuServer

+ SessManager sessions.Manager

+ func (s *ImmuServer) CloseSession(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) Commit(ctx context.Context, _ *empty.Empty) (*schema.CommittedSQLTx, error)

+ func (s *ImmuServer) Delete(ctx context.Context, req *schema.DeleteKeysRequest) (*schema.TxHeader, error)

+ func (s *ImmuServer) KeepALiveSessionStreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func (s *ImmuServer) KeepAlive(ctx context.Context, e *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) KeepAliveSessionInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ func (s *ImmuServer) NewTx(ctx context.Context, request *schema.NewTxRequest) (*schema.NewTxResponse, error)

+ func (s *ImmuServer) OpenSession(ctx context.Context, r *schema.OpenSessionRequest) (*schema.OpenSessionResponse, error)

+ func (s *ImmuServer) Rollback(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) SessionAuthInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ func (s *ImmuServer) TxSQLExec(ctx context.Context, request *schema.SQLExecRequest) (*empty.Empty, error)

+ func (s *ImmuServer) TxSQLQuery(ctx context.Context, request *schema.SQLQueryRequest) (*schema.SQLQueryResult, error)

type Options

+ SessionsOptions *sessions.Options

+ func (o *Options) WithSessionOptions(options *sessions.Options) *Options

Dec 7, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Sep 21, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const DefaultDBName

+ const DefaultMaxValueLen

+ const DefaultStoreFileSize

+ const SystemDBName

+ var ErrReplicationInProgress = errors.New("replication already in progress")

+ var ErrReplicationNotInProgress = errors.New("replication is not in progress")

type ImmuServer

+ Listener net.Listener

type Options

+ ReplicationOptions *ReplicationOptions

+ func (o *Options) GetDefaultDBName() string

+ func (o *Options) GetSynced() bool

+ func (o *Options) GetSystemAdminDBName() string

+ func (o *Options) WithReplicationOptions(replicationOptions *ReplicationOptions) *Options

+ func (o *Options) WithSynced(synced bool) *Options

+ func (opts *Options) DefaultStoreOptions() *store.Options

+ type ReplicationOptions struct

+ FollowerPassword string

+ FollowerUsername string

+ MasterAddress string

+ MasterDatabase string

+ MasterPort int

+ func (opts *ReplicationOptions) WithFollowerPassword(followerPassword string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithFollowerUsername(followerUsername string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithMasterAddress(masterAddress string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithMasterDatabase(masterDatabase string) *ReplicationOptions

+ func (opts *ReplicationOptions) WithMasterPort(masterPort int) *ReplicationOptions

Aug 2, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const KeyPrefixDBSettings

+ var ErrAuthDisabled = "server is running with authentication disabled, please enable authentication to login"

+ var ErrAuthMustBeDisabled = status.Error(codes.InvalidArgument, ...)

+ var ErrAuthMustBeEnabled = status.Error(codes.InvalidArgument, "authentication must be on")

+ var ErrInvalidUsernameOrPassword = "invalid user name or password"

+ var ErrNotAllowedInMaintenanceMode = status.Error(codes.InvalidArgument, "operation not allowed in maintenance mode")

+ var ErrNotLoggedIn = errors.New("not logged in")

+ var ErrNotSupported = errors.New("operation not supported")

+ var ErrPermissionDenied = errors.New("permission denied")

+ var ErrRemoteStorageDoesNotMatch = errors.New("remote storage does not match local files")

+ var ErrReservedDatabase = errors.New("database is reserved")

+ var ErrUserNotActive = "user is not active"

+ func ImmudbHealthHandlerFunc() http.HandlerFunc

+ func ImmudbVersionHandlerFunc(w http.ResponseWriter, r *http.Request)

type ImmuServer

+ func (s *ImmuServer) CompactIndex(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) CreateDatabaseWith(ctx context.Context, req *schema.DatabaseSettings) (*empty.Empty, error)

+ func (s *ImmuServer) ExportTx(req *schema.TxRequest, txsServer schema.ImmuService_ExportTxServer) error

+ func (s *ImmuServer) ReplicateTx(replicateTxServer schema.ImmuService_ReplicateTxServer) error

+ func (s *ImmuServer) UpdateDatabase(ctx context.Context, req *schema.DatabaseSettings) (*empty.Empty, error)

type Options

+ RemoteStorageOptions *RemoteStorageOptions

+ func (o *Options) WithRemoteStorageOptions(remoteStorageOptions *RemoteStorageOptions) *Options

+ type RemoteStorageOptions struct

+ S3AccessKeyID string

+ S3BucketName string

+ S3Endpoint string

+ S3PathPrefix string

+ S3SecretKey string

+ S3Storage bool

+ func DefaultRemoteStorageOptions() *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3AccessKeyID(s3AccessKeyID string) *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3BucketName(s3BucketName string) *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3Endpoint(s3Endpoint string) *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3PathPrefix(s3PathPrefix string) *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3SecretKey(s3SecretKey string) *RemoteStorageOptions

+ func (opts *RemoteStorageOptions) WithS3Storage(S3Storage bool) *RemoteStorageOptions

+ type VersionResponse struct

+ BuildTime string

+ BuiltBy string

+ Component string

+ Static bool

+ Version string

+ var Version VersionResponse

Jun 7, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

May 20, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ func StartWebServer(addr string, tlsConfig *tls.Config, s schema.ImmuServiceServer, ...) (*http.Server, error)

type ImmuServer

+ PgsqlSrv pgsqlsrv.Server

+ func (s *ImmuServer) DescribeTable(ctx context.Context, req *schema.Table) (*schema.SQLQueryResult, error)

+ func (s *ImmuServer) ListTables(ctx context.Context, _ *empty.Empty) (*schema.SQLQueryResult, error)

+ func (s *ImmuServer) SQLExec(ctx context.Context, req *schema.SQLExecRequest) (*schema.SQLExecResult, error)

+ func (s *ImmuServer) SQLQuery(ctx context.Context, req *schema.SQLQueryRequest) (*schema.SQLQueryResult, error)

+ func (s *ImmuServer) UseSnapshot(ctx context.Context, req *schema.UseSnapshotRequest) (*empty.Empty, error)

+ func (s *ImmuServer) VerifiableSQLGet(ctx context.Context, req *schema.VerifiableSQLGetRequest) (*schema.VerifiableSQLEntry, error)

+ func (s *ImmuServer) WithPgsqlServer(psrv pgsqlsrv.Server) ImmuServerIf

type ImmuServerIf

+ WithPgsqlServer func(psrv pgsqlsrv.Server) ImmuServerIf

type MetricsCollection

+ DBEntriesGauges *prometheus.GaugeVec

+ DBSizeGauges *prometheus.GaugeVec

+ func (mc *MetricsCollection) UpdateDBMetrics()

+ func (mc *MetricsCollection) WithComputeDBEntries(f func() map[string]float64)

+ func (mc *MetricsCollection) WithComputeDBSizes(f func() map[string]float64)

type Options

+ PgsqlServer bool

+ PgsqlServerPort int

+ TLSConfig *tls.Config

+ TokenExpiryTimeMin int

+ WebServer bool

+ WebServerPort int

+ func (o *Options) WebBind() string

+ func (o *Options) WithPgsqlServer(enable bool) *Options

+ func (o *Options) WithPgsqlServerPort(port int) *Options

+ func (o *Options) WithTLS(tls *tls.Config) *Options

+ func (o *Options) WithTokenExpiryTime(tokenExpiryTimeMin int) *Options

+ func (o *Options) WithWebServer(webServer bool) *Options

+ func (o *Options) WithWebServerPort(port int) *Options

Apr 8, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrIllegalState = status.Error(codes.InvalidArgument, database.ErrIllegalState.Error())

+ func ErrorMapper(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ func ErrorMapperStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

type ImmuServer

+ StreamServiceFactory stream.ServiceFactory

+ func (s *ImmuServer) StreamExecAll(str schema.ImmuService_StreamExecAllServer) error

+ func (s *ImmuServer) StreamGet(kr *schema.KeyRequest, str schema.ImmuService_StreamGetServer) error

+ func (s *ImmuServer) StreamHistory(request *schema.HistoryRequest, server schema.ImmuService_StreamHistoryServer) error

+ func (s *ImmuServer) StreamScan(req *schema.ScanRequest, str schema.ImmuService_StreamScanServer) error

+ func (s *ImmuServer) StreamSet(str schema.ImmuService_StreamSetServer) error

+ func (s *ImmuServer) StreamVerifiableGet(req *schema.VerifiableGetRequest, ...) error

+ func (s *ImmuServer) StreamVerifiableSet(str schema.ImmuService_StreamVerifiableSetServer) error

+ func (s *ImmuServer) StreamZScan(request *schema.ZScanRequest, server schema.ImmuService_StreamZScanServer) error

+ func (s *ImmuServer) WithStreamServiceFactory(ssf stream.ServiceFactory) ImmuServerIf

type ImmuServerIf

+ WithStreamServiceFactory func(ssf stream.ServiceFactory) ImmuServerIf

type Options

+ StreamChunkSize int

+ func (o *Options) WithStreamChunkSize(streamChunkSize int) *Options

Feb 8, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrIllegalArguments = fmt.Errorf("Illegal arguments")

+ func DefaultStoreOptions() *store.Options

type ImmuServer

+ UUID xid.ID

+ func (s *ImmuServer) CleanIndex(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) TxScan(ctx context.Context, req *schema.TxScanRequest) (*schema.TxList, error)

type Options

+ StoreOptions *store.Options

+ func (o *Options) WithStoreOptions(storeOpts *store.Options) *Options

Jan 7, 2021 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const KeyPrefixUser

+ func NewStateSigner(signer signer.Signer) *stateSigner

+ func NewUUIDContext(id xid.ID) uuidContext

type ImmuServer

+ StateSigner StateSigner

+ func (s *ImmuServer) CurrentState(ctx context.Context, e *empty.Empty) (*schema.ImmutableState, error)

+ func (s *ImmuServer) ExecAll(ctx context.Context, req *schema.ExecAllRequest) (*schema.TxMetadata, error)

+ func (s *ImmuServer) GetAll(ctx context.Context, req *schema.KeyListRequest) (*schema.Entries, error)

+ func (s *ImmuServer) Initialize() error

+ func (s *ImmuServer) SetReference(ctx context.Context, req *schema.ReferenceRequest) (*schema.TxMetadata, error)

+ func (s *ImmuServer) TxById(ctx context.Context, req *schema.TxRequest) (*schema.Tx, error)

+ func (s *ImmuServer) VerifiableGet(ctx context.Context, req *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error)

+ func (s *ImmuServer) VerifiableSet(ctx context.Context, req *schema.VerifiableSetRequest) (*schema.VerifiableTx, error)

+ func (s *ImmuServer) VerifiableSetReference(ctx context.Context, req *schema.VerifiableReferenceRequest) (*schema.VerifiableTx, error)

+ func (s *ImmuServer) VerifiableTxById(ctx context.Context, req *schema.VerifiableTxRequest) (*schema.VerifiableTx, error)

+ func (s *ImmuServer) VerifiableZAdd(ctx context.Context, req *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error)

+ func (s *ImmuServer) WithStateSigner(stateSigner StateSigner) ImmuServerIf

type ImmuServerIf

+ Initialize func() error

+ WithStateSigner func(stateSigner StateSigner) ImmuServerIf

type MetricsCollection

+ DBSizeFunc prometheus.CounterFunc

+ func (mc *MetricsCollection) WithDBSizeFunc(f func() float64)

+ type StateSigner interface

+ Sign func(state *schema.ImmutableState) error

type UUIDContext

+ UUIDContextSetter func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ UUIDStreamContextSetter func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

Dec 29, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Dec 22, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Dec 8, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ var ErrEmptyAdminPassword = fmt.Errorf("Admin password cannot be empty")

type Db

+ func (d *Db) CountAll() *schema.ItemsCount

+ func (d *Db) ExecAllOps(operations *schema.Ops) (*schema.Index, error)

+ func (d *Db) GetReference(refOpts *schema.Key) (index *schema.Item, err error)

type ImmuServer

+ func (s *ImmuServer) CountAll(ctx context.Context, e *empty.Empty) (*schema.ItemsCount, error)

+ func (s *ImmuServer) ExecAllOps(ctx context.Context, operations *schema.Ops) (*schema.Index, error)

+ func (s *ImmuServer) GetReference(ctx context.Context, refOpts *schema.Key) (index *schema.Item, err error)

type Options

+ MaxRecvMsgSize int

+ func (o Options) WithMaxRecvMsgSize(maxRecvMsgSize int) Options

Sep 15, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ func NewRootSigner(signer signer.Signer) *rootSigner

type ImmuServer

+ RootSigner RootSigner

+ func (s *ImmuServer) WithRootSigner(rootSigner RootSigner) ImmuServerIf

type ImmuServerIf

+ WithRootSigner func(rootSigner RootSigner) ImmuServerIf

type Options

+ SigningKey string

+ func (o Options) WithSigningKey(signingKey string) Options

+ type RootSigner interface

+ Sign func(root *schema.Root) (*schema.Root, error)

Aug 17, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Aug 10, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const DefaultDbIndex

+ const DefaultdbName

+ const SystemdbName

+ func IsAllowedDbName(dbName string) error

+ type CCOptions struct

+ type DatabaseList interface

+ Append func(database *Db)

+ GetByIndex func(index int64) *Db

+ Length func() int

+ func NewDatabaseList() DatabaseList

+ type Db struct

+ Logger logger.Logger

+ Store *store.Store

+ func NewDb(op *DbOptions, log logger.Logger) (*Db, error)

+ func OpenDb(op *DbOptions, log logger.Logger) (*Db, error)

+ func (d *Db) ByIndex(index *schema.Index) (*schema.Item, error)

+ func (d *Db) ByIndexSV(index *schema.Index) (*schema.StructuredItem, error)

+ func (d *Db) BySafeIndex(sio *schema.SafeIndexOptions) (*schema.SafeItem, error)

+ func (d *Db) Consistency(index *schema.Index) (*schema.ConsistencyProof, error)

+ func (d *Db) Count(prefix *schema.KeyPrefix) (*schema.ItemsCount, error)

+ func (d *Db) CurrentRoot(e *empty.Empty) (*schema.Root, error)

+ func (d *Db) Dump(in *empty.Empty, stream schema.ImmuService_DumpServer) error

+ func (d *Db) Get(k *schema.Key) (*schema.Item, error)

+ func (d *Db) GetBatch(kl *schema.KeyList) (*schema.ItemList, error)

+ func (d *Db) GetBatchSV(kl *schema.KeyList) (*schema.StructuredItemList, error)

+ func (d *Db) GetSV(k *schema.Key) (*schema.StructuredItem, error)

+ func (d *Db) Health(*empty.Empty) (*schema.HealthResponse, error)

+ func (d *Db) History(key *schema.Key) (*schema.ItemList, error)

+ func (d *Db) HistorySV(key *schema.Key) (*schema.StructuredItemList, error)

+ func (d *Db) IScan(opts *schema.IScanOptions) (*schema.Page, error)

+ func (d *Db) IScanSV(opts *schema.IScanOptions) (*schema.SPage, error)

+ func (d *Db) Inclusion(index *schema.Index) (*schema.InclusionProof, error)

+ func (d *Db) PrintTree() *schema.Tree

+ func (d *Db) Reference(refOpts *schema.ReferenceOptions) (index *schema.Index, err error)

+ func (d *Db) SafeGet(opts *schema.SafeGetOptions) (*schema.SafeItem, error)

+ func (d *Db) SafeGetSV(opts *schema.SafeGetOptions) (*schema.SafeStructuredItem, error)

+ func (d *Db) SafeReference(safeRefOpts *schema.SafeReferenceOptions) (proof *schema.Proof, err error)

+ func (d *Db) SafeSet(opts *schema.SafeSetOptions) (*schema.Proof, error)

+ func (d *Db) SafeSetSV(sopts *schema.SafeSetSVOptions) (*schema.Proof, error)

+ func (d *Db) SafeZAdd(opts *schema.SafeZAddOptions) (*schema.Proof, error)

+ func (d *Db) Scan(opts *schema.ScanOptions) (*schema.ItemList, error)

+ func (d *Db) ScanSV(opts *schema.ScanOptions) (*schema.StructuredItemList, error)

+ func (d *Db) Set(kv *schema.KeyValue) (*schema.Index, error)

+ func (d *Db) SetBatch(kvl *schema.KVList) (*schema.Index, error)

+ func (d *Db) SetBatchSV(skvl *schema.SKVList) (*schema.Index, error)

+ func (d *Db) SetSV(skv *schema.StructuredKeyValue) (*schema.Index, error)

+ func (d *Db) ZAdd(opts *schema.ZAddOptions) (*schema.Index, error)

+ func (d *Db) ZScan(opts *schema.ZScanOptions) (*schema.ItemList, error)

+ func (d *Db) ZScanSV(opts *schema.ZScanOptions) (*schema.StructuredItemList, error)

+ type DbOptions struct

+ func DefaultOption() *DbOptions

+ func (o *DbOptions) GetCorruptionChecker() bool

+ func (o *DbOptions) GetDbName() string

+ func (o *DbOptions) GetDbRootPath() string

+ func (o *DbOptions) GetInMemoryStore() bool

+ func (o *DbOptions) WithCorruptionChecker(cc bool) *DbOptions

+ func (o *DbOptions) WithDbName(dbName string) *DbOptions

+ func (o *DbOptions) WithDbRootPath(Path string) *DbOptions

+ func (o *DbOptions) WithInMemoryStore(inmemory bool) *DbOptions

type ImmuServer

+ OS immuos.OS

+ func (s *ImmuServer) ChangePermission(ctx context.Context, r *schema.ChangePermissionRequest) (*empty.Empty, error)

+ func (s *ImmuServer) CloseDatabases() error

+ func (s *ImmuServer) CreateDatabase(ctx context.Context, newdb *schema.Database) (*empty.Empty, error)

+ func (s *ImmuServer) DatabaseList(ctx context.Context, req *empty.Empty) (*schema.DatabaseListResponse, error)

+ func (s *ImmuServer) SetActiveUser(ctx context.Context, r *schema.SetActiveUserRequest) (*empty.Empty, error)

+ func (s *ImmuServer) UseDatabase(ctx context.Context, db *schema.Database) (*schema.UseDatabaseReply, error)

+ type ImmuServerIf interface

+ Start func() error

+ Stop func() error

+ WithLogger func(logger.Logger) ImmuServerIf

+ WithOptions func(options Options) ImmuServerIf

type Options

+ func (o Options) GetAuth() bool

+ func (o Options) GetDefaultDbName() string

+ func (o Options) GetInMemoryStore() bool

+ func (o Options) GetMaintenance() bool

+ func (o Options) GetSystemAdminDbName() string

+ func (o Options) WithInMemoryStore(inmemory bool) Options

+ func (o Options) WithListener(lis net.Listener) Options

+ func (o Options) WithMaintenance(m bool) Options

type PIDFile

+ OS immuos.OS

+ type RandomGenerator interface

Jun 16, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type Options

+ AdminPassword string

+ DevMode bool

+ func (o Options) WithAdminPassword(adminPassword string) Options

+ func (o Options) WithDevMode(devMode bool) Options

Jun 9, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

type CorruptionChecker

+ Wait func()

type ImmuServer

+ func (s *ImmuServer) Logout(ctx context.Context, r *empty.Empty) (*empty.Empty, error)

+ func (s *ImmuServer) PrintTree(context.Context, *empty.Empty) (*schema.Tree, error)

May 28, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const ErrConsistencyFail

+ const IDENTIFIER_FNAME

+ const SERVER_UUID_HEADER

+ var ErrUserDeactivated = errors.New("user is deactivated")

+ var Metrics = MetricsCollection

+ func NewUuidContext(id xid.ID) uuidContext

+ func StartMetrics(addr string, l logger.Logger, recordsCounter func() float64, ...) *http.Server

+ type CorruptionChecker interface

+ GetStatus func(context.Context) bool

+ Start func(context.Context) (err error)

+ Stop func(context.Context)

+ func NewCorruptionChecker(s *store.Store, l logger.Logger, stopImmudb func() error) CorruptionChecker

+ type ImmuServer struct

+ Cc CorruptionChecker

+ GrpcServer *grpc.Server

+ Logger logger.Logger

+ Options Options

+ Pid PIDFile

+ Store *store.Store

+ SysStore *store.Store

+ func DefaultServer() *ImmuServer

+ func (s *ImmuServer) ByIndex(ctx context.Context, index *schema.Index) (*schema.Item, error)

+ func (s *ImmuServer) ByIndexSV(ctx context.Context, index *schema.Index) (*schema.StructuredItem, error)

+ func (s *ImmuServer) BySafeIndex(ctx context.Context, sio *schema.SafeIndexOptions) (*schema.SafeItem, error)

+ func (s *ImmuServer) ChangePassword(ctx context.Context, r *schema.ChangePasswordRequest) (*empty.Empty, error)

+ func (s *ImmuServer) Consistency(ctx context.Context, index *schema.Index) (*schema.ConsistencyProof, error)

+ func (s *ImmuServer) Count(ctx context.Context, prefix *schema.KeyPrefix) (*schema.ItemsCount, error)

+ func (s *ImmuServer) CreateAdminUser(ctx context.Context) (string, string, error)

+ func (s *ImmuServer) CreateUser(ctx context.Context, r *schema.CreateUserRequest) (*schema.UserResponse, error)

+ func (s *ImmuServer) CurrentRoot(ctx context.Context, e *empty.Empty) (*schema.Root, error)

+ func (s *ImmuServer) DeactivateUser(ctx context.Context, r *schema.UserRequest) (*empty.Empty, error)

+ func (s *ImmuServer) Dump(in *empty.Empty, stream schema.ImmuService_DumpServer) error

+ func (s *ImmuServer) Get(ctx context.Context, k *schema.Key) (*schema.Item, error)

+ func (s *ImmuServer) GetBatch(ctx context.Context, kl *schema.KeyList) (*schema.ItemList, error)

+ func (s *ImmuServer) GetBatchSV(ctx context.Context, kl *schema.KeyList) (*schema.StructuredItemList, error)

+ func (s *ImmuServer) GetSV(ctx context.Context, k *schema.Key) (*schema.StructuredItem, error)

+ func (s *ImmuServer) GetUser(ctx context.Context, r *schema.UserRequest) (*schema.UserResponse, error)

+ func (s *ImmuServer) Health(context.Context, *empty.Empty) (*schema.HealthResponse, error)

+ func (s *ImmuServer) History(ctx context.Context, key *schema.Key) (*schema.ItemList, error)

+ func (s *ImmuServer) HistorySV(ctx context.Context, key *schema.Key) (*schema.StructuredItemList, error)

+ func (s *ImmuServer) IScan(ctx context.Context, opts *schema.IScanOptions) (*schema.Page, error)

+ func (s *ImmuServer) IScanSV(ctx context.Context, opts *schema.IScanOptions) (*schema.SPage, error)

+ func (s *ImmuServer) Inclusion(ctx context.Context, index *schema.Index) (*schema.InclusionProof, error)

+ func (s *ImmuServer) ListUsers(ctx context.Context, req *empty.Empty) (*schema.UserList, error)

+ func (s *ImmuServer) Login(ctx context.Context, r *schema.LoginRequest) (*schema.LoginResponse, error)

+ func (s *ImmuServer) Reference(ctx context.Context, refOpts *schema.ReferenceOptions) (index *schema.Index, err error)

+ func (s *ImmuServer) SafeGet(ctx context.Context, opts *schema.SafeGetOptions) (*schema.SafeItem, error)

+ func (s *ImmuServer) SafeGetSV(ctx context.Context, opts *schema.SafeGetOptions) (*schema.SafeStructuredItem, error)

+ func (s *ImmuServer) SafeReference(ctx context.Context, safeRefOpts *schema.SafeReferenceOptions) (proof *schema.Proof, err error)

+ func (s *ImmuServer) SafeSet(ctx context.Context, opts *schema.SafeSetOptions) (*schema.Proof, error)

+ func (s *ImmuServer) SafeSetSV(ctx context.Context, sopts *schema.SafeSetSVOptions) (*schema.Proof, error)

+ func (s *ImmuServer) SafeZAdd(ctx context.Context, opts *schema.SafeZAddOptions) (*schema.Proof, error)

+ func (s *ImmuServer) Scan(ctx context.Context, opts *schema.ScanOptions) (*schema.ItemList, error)

+ func (s *ImmuServer) ScanSV(ctx context.Context, opts *schema.ScanOptions) (*schema.StructuredItemList, error)

+ func (s *ImmuServer) Set(ctx context.Context, kv *schema.KeyValue) (*schema.Index, error)

+ func (s *ImmuServer) SetBatch(ctx context.Context, kvl *schema.KVList) (*schema.Index, error)

+ func (s *ImmuServer) SetBatchSV(ctx context.Context, skvl *schema.SKVList) (*schema.Index, error)

+ func (s *ImmuServer) SetPermission(ctx context.Context, r *schema.Item) (*empty.Empty, error)

+ func (s *ImmuServer) SetSV(ctx context.Context, skv *schema.StructuredKeyValue) (*schema.Index, error)

+ func (s *ImmuServer) Start() error

+ func (s *ImmuServer) Stop() error

+ func (s *ImmuServer) UpdateAuthConfig(ctx context.Context, req *schema.AuthConfig) (*empty.Empty, error)

+ func (s *ImmuServer) UpdateMTLSConfig(ctx context.Context, req *schema.MTLSConfig) (*empty.Empty, error)

+ func (s *ImmuServer) WithCC(cc CorruptionChecker) *ImmuServer

+ func (s *ImmuServer) WithLogger(logger logger.Logger) *ImmuServer

+ func (s *ImmuServer) WithOptions(options Options) *ImmuServer

+ func (s *ImmuServer) WithStore(st *store.Store) *ImmuServer

+ func (s *ImmuServer) ZAdd(ctx context.Context, opts *schema.ZAddOptions) (*schema.Index, error)

+ func (s *ImmuServer) ZScan(ctx context.Context, opts *schema.ZScanOptions) (*schema.ItemList, error)

+ func (s *ImmuServer) ZScanSV(ctx context.Context, opts *schema.ZScanOptions) (*schema.StructuredItemList, error)

+ type MTLsOptions struct

+ Certificate string

+ ClientCAs string

+ Pkey string

+ func DefaultMTLsOptions() MTLsOptions

+ func (o MTLsOptions) WithCertificate(Certificate string) MTLsOptions

+ func (o MTLsOptions) WithClientCAs(ClientCAs string) MTLsOptions

+ func (o MTLsOptions) WithPkey(Pkey string) MTLsOptions

+ type MetricsCollection struct

+ LastMessageAtPerClientGauges *prometheus.GaugeVec

+ RPCsPerClientCounters *prometheus.CounterVec

+ RecordsCounter prometheus.CounterFunc

+ UptimeCounter prometheus.CounterFunc

+ func (mc *MetricsCollection) UpdateClientMetrics(ctx context.Context)

+ func (mc *MetricsCollection) WithRecordsCounter(f func() float64)

+ func (mc *MetricsCollection) WithUptimeCounter(f func() float64)

+ type Options struct

+ Address string

+ Auth bool

+ Config string

+ CorruptionCheck bool

+ DbName string

+ Detached bool

+ Dir string

+ Logfile string

+ MTLs bool

+ MTLsOptions MTLsOptions

+ MetricsPort int

+ MetricsServer bool

+ Network string

+ NoHistograms bool

+ Pidfile string

+ Port int

+ SysDbName string

+ func DefaultOptions() Options

+ func (o Options) Bind() string

+ func (o Options) MetricsBind() string

+ func (o Options) String() string

+ func (o Options) WithAddress(address string) Options

+ func (o Options) WithAuth(authEnabled bool) Options

+ func (o Options) WithConfig(config string) Options

+ func (o Options) WithCorruptionCheck(corruptionCheck bool) Options

+ func (o Options) WithDbName(dbName string) Options

+ func (o Options) WithDetached(detached bool) Options

+ func (o Options) WithDir(dir string) Options

+ func (o Options) WithLogfile(logfile string) Options

+ func (o Options) WithMTLs(MTLs bool) Options

+ func (o Options) WithMTLsOptions(MTLsOptions MTLsOptions) Options

+ func (o Options) WithMetricsServer(metricsServer bool) Options

+ func (o Options) WithNetwork(network string) Options

+ func (o Options) WithNoHistograms(noHistograms bool) Options

+ func (o Options) WithPidfile(pidfile string) Options

+ func (o Options) WithPort(port int) Options

+ func (o Options) WithSysDbName(sysDbName string) Options

+ type PIDFile struct

+ func NewPid(path string) (PIDFile, error)

+ func (file PIDFile) Remove() error

+ type Service struct

+ func (s Service) Run()

+ func (s Service) Start()

+ func (s Service) Stop()

+ type UUIDContext interface

+ UuidContextSetter func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ UuidStreamContextSetter func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ type WrappedServerStream struct

+ func (w *WrappedServerStream) RecvMsg(m interface{}) error

+ func (w *WrappedServerStream) SendMsg(m interface{}) error

May 19, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

May 11, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Feb 6, 2020 GO-2022-1117 +1 more

  GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

  GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb