pg_grpc

Documentation

Index

• func InitializePostgresClient() (pb.PostgresClient, error)
• type Database
  • func NewDatabase(ctx context.Context, client pb.PostgresClient) Database
  • func (d Database) AllCols() isql.Database
  • func (d Database) Columns(s ...string) isql.Database
  • func (d Database) DeleteOne(filter ...interface{}) error
  • func (d Database) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (d Database) FindMany(documents interface{}, filter ...interface{}) error
  • func (d Database) FindOne(document interface{}, filter ...interface{}) (bool, error)
  • func (d Database) ID(id any) isql.Database
  • func (d Database) In(s string, a ...any) isql.Database
  • func (d Database) InsertMany(documents []interface{}) ([]int64, error)
  • func (d Database) InsertOne(document interface{}) (id int64, err error)
  • func (d Database) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (d Database) Sync(...any) error
  • func (d Database) Table(name string) isql.Database
  • func (d Database) UpdateOne(document interface{}) error
  • func (d Database) Where(s string, a ...any) isql.Database

Functions

func InitializePostgresClient

func InitializePostgresClient() (pb.PostgresClient, error)

Types

type Database

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

func NewDatabase

func NewDatabase(ctx context.Context, client pb.PostgresClient) Database

func (Database) AllCols

func (d Database) AllCols() isql.Database

func (Database) Columns

func (d Database) Columns(s ...string) isql.Database

func (Database) DeleteOne

func (d Database) DeleteOne(filter ...interface{}) error

func (Database) Exec

func (d Database) Exec(query string, args ...interface{}) (sql.Result, error)

func (Database) FindMany

func (d Database) FindMany(documents interface{}, filter ...interface{}) error

func (Database) FindOne

func (d Database) FindOne(document interface{}, filter ...interface{}) (bool, error)

func (Database) ID

func (d Database) ID(id any) isql.Database

func (Database) In

func (d Database) In(s string, a ...any) isql.Database

func (Database) InsertMany

func (d Database) InsertMany(documents []interface{}) ([]int64, error)

TODO: Implement in a more efficient way

func (Database) InsertOne

func (d Database) InsertOne(document interface{}) (id int64, err error)

func (Database) Query

func (d Database) Query(query string, args ...interface{}) (*sql.Rows, error)

func (Database) Sync

func (d Database) Sync(...any) error

func (Database) Table

func (d Database) Table(name string) isql.Database

func (Database) UpdateOne

func (d Database) UpdateOne(document interface{}) error

func (Database) Where

func (d Database) Where(s string, a ...any) isql.Database