postgres

package

v0.24.0 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 26 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

github.com/solarisdb/solaris

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func MapError(err error) error
func MapPqError(err error) error
type Chunk
type Db
- func GetDb(ctx context.Context, dsName string) (*Db, error)
- func MustGetDb(ctx context.Context, dsName string) *Db
- func (s *Db) Init(ctx context.Context) error
- func (s *Db) Shutdown()
type DbConfig
- func (ds DbConfig) DataSourceFull() string
- func (ds DbConfig) DataSourceNoDb() string
type DbContainer
- func NewNilDbContainer(opts ...DbOption) (DbContainer, error)
- func NewPgDbContainer(ctx context.Context, image string, opts ...DbOption) (DbContainer, error)
type DbOption
type Log
type Storage
- func NewStorage(db *Db) *Storage
type Tags

Constants ¶

View Source

const (
	PqForeignKeyViolationError = pq.ErrorCode("23503")
	PqUniqueViolationError     = pq.ErrorCode("23505")
)

Variables ¶

This section is empty.

Functions ¶

func MapError ¶

func MapError(err error) error

func MapPqError ¶

func MapPqError(err error) error

Types ¶

type Chunk ¶

type Chunk struct {
	ID           string `db:"id"`
	LogID        string `db:"log_id"`
	Min          string `db:"min"`
	Max          string `db:"max"`
	RecordsCount int    `db:"records"`
}

type Db ¶

type Db struct {
	*sqlx.DB
	// contains filtered or unexported fields
}

Db exposes db operations

func GetDb ¶

func GetDb(ctx context.Context, dsName string) (*Db, error)

GetDb returns the Db object built for the given configuration

func MustGetDb ¶

func MustGetDb(ctx context.Context, dsName string) *Db

MustGetDb does the same as GetDb but panics in case of an error

func (*Db) Init ¶

func (s *Db) Init(ctx context.Context) error

Init implements linker.Initializer

func (*Db) Shutdown ¶

func (s *Db) Shutdown()

Shutdown implements linker.Shutdowner

type DbConfig ¶

type DbConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	DbName   string
	SslMode  string
}

func (DbConfig) DataSourceFull ¶

func (ds DbConfig) DataSourceFull() string

func (DbConfig) DataSourceNoDb ¶

func (ds DbConfig) DataSourceNoDb() string

type DbContainer ¶

type DbContainer interface {
	io.Closer
	DbConfig() DbConfig
}

func NewNilDbContainer ¶

func NewNilDbContainer(opts ...DbOption) (DbContainer, error)

func NewPgDbContainer ¶

func NewPgDbContainer(ctx context.Context, image string, opts ...DbOption) (DbContainer, error)

NewPgDbContainer runs pg database in a docker container.

type DbOption ¶

type DbOption func(cfg *DbConfig)

func WithDbName ¶

func WithDbName(dbName string) DbOption

func WithHost ¶

func WithHost(host string) DbOption

func WithPassword ¶

func WithPassword(password string) DbOption

func WithPort ¶

func WithPort(port string) DbOption

func WithSslMode ¶

func WithSslMode(sslMode string) DbOption

func WithUser ¶

func WithUser(user string) DbOption

type Log ¶

type Log struct {
	ID        string    `db:"id"`
	Tags      Tags      `db:"tags"`
	Records   int64     `db:"records"`
	Deleted   bool      `db:"deleted"`
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
}

type Storage ¶

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

Storage is the logs meta storage

func NewStorage ¶

func NewStorage(db *Db) *Storage

NewStorage creates new logs meta storage based on Postgres

func (*Storage) CreateLog ¶

func (s *Storage) CreateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

CreateLog implements storage.Logs

func (*Storage) DeleteLogs ¶

func (s *Storage) DeleteLogs(ctx context.Context, req storage.DeleteLogsRequest) (*solaris.DeleteLogsResult, error)

DeleteLogs implements storage.Logs

func (*Storage) GetChunks ¶

func (s *Storage) GetChunks(ctx context.Context, logID string) ([]logfs.ChunkInfo, error)

GetChunks implements logfs.LogsMetaStorage

func (*Storage) GetLastChunk ¶

func (s *Storage) GetLastChunk(ctx context.Context, logID string) (logfs.ChunkInfo, error)

GetLastChunk implements logfs.LogsMetaStorage

func (*Storage) GetLogByID ¶

func (s *Storage) GetLogByID(ctx context.Context, id string) (*solaris.Log, error)

GetLogByID implements storage.Logs

func (*Storage) QueryLogs ¶

func (s *Storage) QueryLogs(ctx context.Context, qr storage.QueryLogsRequest) (*solaris.QueryLogsResult, error)

QueryLogs implements storage.Logs

func (*Storage) UpdateLog ¶

func (s *Storage) UpdateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

UpdateLog implements storage.Logs

func (*Storage) UpsertChunkInfos ¶

func (s *Storage) UpsertChunkInfos(ctx context.Context, logID string, cis []logfs.ChunkInfo) error

UpsertChunkInfos implements logfs.LogsMetaStorage

type Tags ¶

type Tags map[string]string

func (Tags) JSON ¶

func (t Tags) JSON() string

func (*Tags) Scan ¶

func (t *Tags) Scan(value any) error

func (Tags) Value ¶

func (t Tags) Value() (value driver.Value, err error)

Source Files ¶

View all Source files

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