noSql

package

v0.0.6 Latest Latest Go to latest Published: May 22, 2024 License: BSD-2-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/devpro_studio/Paranoia

Documentation ¶

Index ¶

type ASRow
- func (t *ASRow) Scan(dest any) error
type ASRows
type Aerospike
type MongoDB
type MongoRow
- func (t *MongoRow) Scan(dest any) error
type MongoRows

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ASRow ¶ added in v0.0.6

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

func (*ASRow) Scan ¶ added in v0.0.6

func (t *ASRow) Scan(dest any) error

type ASRows ¶ added in v0.0.6

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

func (*ASRows) Close ¶ added in v0.0.6

func (t *ASRows) Close() error

func (*ASRows) Next ¶ added in v0.0.6

func (t *ASRows) Next() bool

func (*ASRows) Scan ¶ added in v0.0.6

func (t *ASRows) Scan(dest any) error

type Aerospike ¶

type Aerospike struct {
	Name  string
	Hosts string
	User  string
	Pass  string
	// contains filtered or unexported fields
}

func (*Aerospike) Batch ¶

func (t *Aerospike) Batch(ctx context.Context, key interface{}, query interface{}, typeOp string, args ...interface{}) (int64, error)

func (*Aerospike) Count ¶

func (t *Aerospike) Count(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

func (*Aerospike) Delete ¶

func (t *Aerospike) Delete(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

func (*Aerospike) Exec ¶

func (t *Aerospike) Exec(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRows, error)

func (*Aerospike) Exists ¶

func (t *Aerospike) Exists(ctx context.Context, key interface{}, query interface{}, args ...interface{}) bool

func (*Aerospike) Find ¶

func (t *Aerospike) Find(ctx context.Context, _ interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRows, error)

func (*Aerospike) FindOne ¶

func (t *Aerospike) FindOne(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRow, error)

func (*Aerospike) GetDb ¶

func (t *Aerospike) GetDb() interface{}

func (*Aerospike) Init ¶

func (t *Aerospike) Init(app interfaces.IService) error

func (*Aerospike) Insert ¶

func (t *Aerospike) Insert(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interface{}, error)

func (*Aerospike) Stop ¶

func (t *Aerospike) Stop() error

func (*Aerospike) String ¶

func (t *Aerospike) String() string

func (*Aerospike) Update ¶

func (t *Aerospike) Update(ctx context.Context, key interface{}, query interface{}, args ...interface{}) error

type MongoDB ¶

type MongoDB struct {
	Name     string
	Database string
	Options  *options.ClientOptions
	// contains filtered or unexported fields
}

func (*MongoDB) Batch ¶

func (t *MongoDB) Batch(ctx context.Context, key interface{}, query interface{}, typeOp string, args ...interface{}) (int64, error)

Batch

key - collection name

query []mongo.WriteModel

typeOp in [bulk]

func (*MongoDB) Count ¶

func (t *MongoDB) Count(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

func (*MongoDB) Delete ¶

func (t *MongoDB) Delete(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

func (*MongoDB) Exec ¶

func (t *MongoDB) Exec(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRows, error)

func (*MongoDB) Exists ¶

func (t *MongoDB) Exists(ctx context.Context, key interface{}, query interface{}, args ...interface{}) bool

func (*MongoDB) Find ¶

func (t *MongoDB) Find(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRows, error)

func (*MongoDB) FindOne ¶

func (t *MongoDB) FindOne(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interfaces.NoSQLRow, error)

func (*MongoDB) GetDb ¶

func (t *MongoDB) GetDb() interface{}

func (*MongoDB) Init ¶

func (t *MongoDB) Init(app interfaces.IService) error

func (*MongoDB) Insert ¶

func (t *MongoDB) Insert(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interface{}, error)

func (*MongoDB) Stop ¶

func (t *MongoDB) Stop() error

func (*MongoDB) String ¶

func (t *MongoDB) String() string

func (*MongoDB) Update ¶

func (t *MongoDB) Update(ctx context.Context, key interface{}, query interface{}, args ...interface{}) error

type MongoRow ¶ added in v0.0.6

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

func (*MongoRow) Scan ¶ added in v0.0.6

func (t *MongoRow) Scan(dest any) error

type MongoRows ¶ added in v0.0.6

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

func (*MongoRows) Close ¶ added in v0.0.6

func (t *MongoRows) Close() error

func (*MongoRows) Next ¶ added in v0.0.6

func (t *MongoRows) Next() bool

func (*MongoRows) Scan ¶ added in v0.0.6

func (t *MongoRows) Scan(dest any) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL