Versions in this module Expand all Collapse all v1 v1.0.0 Apr 11, 2023 Changes in this version + const DEFAULT_CONN_TIMEOUT + const ErrorCollectionNotFound + const ErrorEmptyRow + const ErrorIndexAlreadyExist + const ErrorIndexComposedTTL + const ErrorIndexEmpty + const ErrorMultipleDBM + const ErrorMultipleQueryForSingleRow + const ErrorReconnecting + const ErrorRowOptDiffLenght + const ErrorRowQueryDiffLenght + const ErrorSessionClosed + type ClientOpts struct + ConnectionString string + ConnectionTimeout int + SSLAllowInvalidHostnames bool + SSLCAFile string + SSLInsecureSkipVerify bool + SSLPEMKeyfile string + SessionConsistency string + Type string + UseSSL bool + func (opts *ClientOpts) GetTLSConfig() (*tls.Config, error) + type DBObject interface + DBID func() ObjectID + SetDBID func(id ObjectID) + type DBTable interface + TableName func() string + type ObjectID interface + Hex func() string + MarshalJSON func() ([]byte, error) + MarshalText func() ([]byte, error) + String func() string + Timestamp func() time.Time + UnmarshalJSON func([]byte) error + UnmarshalText func([]byte) error + type PersistentStorage interface + Aggregate func(ctx context.Context, row id.DBObject, query []dbm.DBM) ([]dbm.DBM, error) + BulkUpdate func(context.Context, []id.DBObject, ...dbm.DBM) error + CleanIndexes func(ctx context.Context, row id.DBObject) error + Count func(ctx context.Context, row id.DBObject, filter ...dbm.DBM) (count int, error error) + CreateIndex func(ctx context.Context, row id.DBObject, index index.Index) error + DBTableStats func(ctx context.Context, row id.DBObject) (dbm.DBM, error) + Delete func(context.Context, id.DBObject, ...dbm.DBM) error + Drop func(context.Context, id.DBObject) error + DropDatabase func(ctx context.Context) error + DropTable func(ctx context.Context, name string) (int, error) + GetDatabaseInfo func(ctx context.Context) (utils.Info, error) + GetIndexes func(ctx context.Context, row id.DBObject) ([]index.Index, error) + GetTables func(ctx context.Context) ([]string, error) + HasTable func(context.Context, string) (bool, error) + Insert func(context.Context, ...id.DBObject) error + Migrate func(context.Context, []id.DBObject, ...dbm.DBM) error + Ping func(context.Context) error + Query func(context.Context, id.DBObject, interface{}, dbm.DBM) error + Update func(context.Context, id.DBObject, ...dbm.DBM) error + UpdateAll func(ctx context.Context, row id.DBObject, query, update dbm.DBM) error + Upsert func(ctx context.Context, row id.DBObject, query, update dbm.DBM) error + type StorageLifecycle interface + Close func() error + Connect func(*ClientOpts) error + DBType func() utils.DBType
Go to main page