postgres

Documentation

Overview

Package postgres provides the PostgresSQL storage implementation.

Index

• type Account
• type GooseLogger
  • func (l *GooseLogger) Fatalf(format string, v ...any)
  • func (l *GooseLogger) Printf(format string, v ...any)
• type PostgresCentralStorage
  • func (s PostgresCentralStorage) GetAAPCentralStorage() (azstorage.AAPCentralStorage, error)
• type PostgresCentralStorageAAP
  • func (s PostgresCentralStorageAAP) CreateAccount(email string) (*azmodels.Account, error)
  • func (s PostgresCentralStorageAAP) DeleteAccount(accountID int64) (*azmodels.Account, error)
  • func (s PostgresCentralStorageAAP) GetAllAccounts() ([]azmodels.Account, error)
• type PostgresConnection
  • func (c *PostgresConnection) Connect(logger *zap.Logger, ctx context.Context) (*gorm.DB, error)
  • func (c *PostgresConnection) Disconnect(logger *zap.Logger, ctx context.Context) error
  • func (c *PostgresConnection) GetStorage() azstorage.StorageKind
• type PostgresConnectionConfig
  • func (c *PostgresConnectionConfig) AddFlags(flagSet *flag.FlagSet) error
  • func (c *PostgresConnectionConfig) GetConnectionString() (string, error)
  • func (c *PostgresConnectionConfig) GetDatabase() string
  • func (c *PostgresConnectionConfig) GetHost() string
  • func (c *PostgresConnectionConfig) GetPassword() string
  • func (c *PostgresConnectionConfig) GetPort() int
  • func (c *PostgresConnectionConfig) GetSSLMode() string
  • func (c *PostgresConnectionConfig) GetStorage() azstorage.StorageKind
  • func (c *PostgresConnectionConfig) GetUsername() string
  • func (c *PostgresConnectionConfig) InitFromViper(v *viper.Viper) error
• type PostgresStorageFactory
  • func NewPostgresStorageFactory(storageFctyCfg *PostgresStorageFactoryConfig) (*PostgresStorageFactory, error)
  • func (f *PostgresStorageFactory) CreateCentralStorage(storageContext *azstorage.StorageContext) (azstorage.CentralStorage, error)
  • func (f *PostgresStorageFactory) CreateProximityStorage(storageContext *azstorage.StorageContext) (azstorage.ProximityStorage, error)
• type PostgresStorageFactoryConfig
  • func NewPostgresStorageFactoryConfig() (*PostgresStorageFactoryConfig, error)
  • func (c *PostgresStorageFactoryConfig) AddFlags(flagSet *flag.FlagSet) error
  • func (c *PostgresStorageFactoryConfig) InitFromViper(v *viper.Viper) error
• type PostgresStorageProvisioner
  • func NewPostgresStorageProvisioner() (*PostgresStorageProvisioner, error)
  • func (p *PostgresStorageProvisioner) AddFlags(flagSet *flag.FlagSet) error
  • func (p *PostgresStorageProvisioner) Down() error
  • func (p *PostgresStorageProvisioner) InitFromViper(v *viper.Viper) error
  • func (p *PostgresStorageProvisioner) Up() error

Types

type Account

type Account struct {
	AccountID int64     `gorm:"primaryKey"`
	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP"`
	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP"`
	Status    int16     `gorm:"default:1"`
	Email     string    `gorm:"unique"`
}

Account is the model for the account table.

type GooseLogger

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

GooseLogger is a logger for goose.

func (*GooseLogger) Fatalf

func (l *GooseLogger) Fatalf(format string, v ...any)

Fatalf logs a fatal error.

func (*GooseLogger) Printf

func (l *GooseLogger) Printf(format string, v ...any)

Printf logs a message.

type PostgresCentralStorage

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

PostgresCentralStorage implements the postgres central storage.

func (PostgresCentralStorage) GetAAPCentralStorage

func (s PostgresCentralStorage) GetAAPCentralStorage() (azstorage.AAPCentralStorage, error)

GetAAPCentralStorage returns the AAP central storage.

type PostgresCentralStorageAAP

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

PostgresCentralStorageAAP implements the postgres central storage.

func (PostgresCentralStorageAAP) CreateAccount

func (s PostgresCentralStorageAAP) CreateAccount(email string) (*azmodels.Account, error)

CreateAccount creates a new account.

func (PostgresCentralStorageAAP) DeleteAccount

func (s PostgresCentralStorageAAP) DeleteAccount(accountID int64) (*azmodels.Account, error)

DeleteAccount deletes an account.

func (PostgresCentralStorageAAP) GetAllAccounts

func (s PostgresCentralStorageAAP) GetAllAccounts() ([]azmodels.Account, error)

GetAllAccounts returns all accounts.

type PostgresConnection

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

PostgresConnection holds the configuration for the server.

func (*PostgresConnection) Connect

func (c *PostgresConnection) Connect(logger *zap.Logger, ctx context.Context) (*gorm.DB, error)

Connect connects to postgres and return a client.

func (*PostgresConnection) Disconnect

func (c *PostgresConnection) Disconnect(logger *zap.Logger, ctx context.Context) error

Disconnect disconnects from postgres.

func (*PostgresConnection) GetStorage

func (c *PostgresConnection) GetStorage() azstorage.StorageKind

GetStorage returns the storage kind.

type PostgresConnectionConfig

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

PostgresConnectionConfig holds the configuration for the server.

func (*PostgresConnectionConfig) AddFlags

func (c *PostgresConnectionConfig) AddFlags(flagSet *flag.FlagSet) error

AddFlags adds flags.

func (*PostgresConnectionConfig) GetConnectionString

func (c *PostgresConnectionConfig) GetConnectionString() (string, error)

GetConnectionString returns the connection string.

func (*PostgresConnectionConfig) GetDatabase

func (c *PostgresConnectionConfig) GetDatabase() string

GetDatabase returns the database.

func (*PostgresConnectionConfig) GetHost

func (c *PostgresConnectionConfig) GetHost() string

GetHost returns the host.

func (*PostgresConnectionConfig) GetPassword

func (c *PostgresConnectionConfig) GetPassword() string

GetPassword returns the password.

func (*PostgresConnectionConfig) GetPort

func (c *PostgresConnectionConfig) GetPort() int

GetPort returns the port.

func (*PostgresConnectionConfig) GetSSLMode

func (c *PostgresConnectionConfig) GetSSLMode() string

GetSSLMode returns the ssl mode.

func (*PostgresConnectionConfig) GetStorage

func (c *PostgresConnectionConfig) GetStorage() azstorage.StorageKind

GetStorage returns the storage kind.

func (*PostgresConnectionConfig) GetUsername

func (c *PostgresConnectionConfig) GetUsername() string

GetUsername returns the username.

func (*PostgresConnectionConfig) InitFromViper

func (c *PostgresConnectionConfig) InitFromViper(v *viper.Viper) error

InitFromViper initializes the configuration from viper.

type PostgresStorageFactory

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

PostgresStorageFactory holds the configuration for the server factory.

func NewPostgresStorageFactory

func NewPostgresStorageFactory(storageFctyCfg *PostgresStorageFactoryConfig) (*PostgresStorageFactory, error)

NewPostgresStorageFactory creates a new server factory configuration.

func (*PostgresStorageFactory) CreateCentralStorage

func (f *PostgresStorageFactory) CreateCentralStorage(storageContext *azstorage.StorageContext) (azstorage.CentralStorage, error)

CreateCentralStorage returns the central storage.

func (*PostgresStorageFactory) CreateProximityStorage

func (f *PostgresStorageFactory) CreateProximityStorage(storageContext *azstorage.StorageContext) (azstorage.ProximityStorage, error)

CreateProximityStorage returns the proximity storage.

type PostgresStorageFactoryConfig

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

PostgresStorageFactoryConfig holds the configuration for the server factory.

func NewPostgresStorageFactoryConfig

func NewPostgresStorageFactoryConfig() (*PostgresStorageFactoryConfig, error)

NewPostgresStorageFactoryConfig creates a new server factory configuration.

func (*PostgresStorageFactoryConfig) AddFlags

func (c *PostgresStorageFactoryConfig) AddFlags(flagSet *flag.FlagSet) error

AddFlags adds flags.

func (*PostgresStorageFactoryConfig) InitFromViper

func (c *PostgresStorageFactoryConfig) InitFromViper(v *viper.Viper) error

InitFromViper initializes the configuration from viper.

type PostgresStorageProvisioner

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

PostgresStorageProvisioner is the storage provisioner for Postgres.

func NewPostgresStorageProvisioner

func NewPostgresStorageProvisioner() (*PostgresStorageProvisioner, error)

NewPostgresStorageProvisioner creates a new PostgresStorageProvisioner.

func (*PostgresStorageProvisioner) AddFlags

func (p *PostgresStorageProvisioner) AddFlags(flagSet *flag.FlagSet) error

AddFlags adds flags.

func (*PostgresStorageProvisioner) Down

func (p *PostgresStorageProvisioner) Down() error

Down deprovisions the database.

func (*PostgresStorageProvisioner) InitFromViper

func (p *PostgresStorageProvisioner) InitFromViper(v *viper.Viper) error

InitFromViper initializes the configuration from viper.

func (*PostgresStorageProvisioner) Up

func (p *PostgresStorageProvisioner) Up() error

Up provisions the database.