Documentation
¶
Index ¶
- func ErrInvalidSequenceNumber(seq int32) error
- func RunMigrations(ctx context.Context, connParams ConfigProvider, fs embed.FS, stopAfter int32, ...) (fault error)
- type AddFlagParams
- type Client
- type Config
- type ConfigProvider
- type DBMigrator
- type DBTX
- type Environment
- type FeatureFlag
- type FeatureFlagValue
- type FlagType
- type GetEnvFlagValueByFlagIdAndEnvironmentNameParams
- type GetEnvFlagValueByFlagIdAndEnvironmentNameRow
- type GetEnvFlagValueByFlagIdAndEnvironmentRow
- type GetEnvFlagValueByFlagIdRow
- type GetFlagsByEnvironmentNameRow
- type GetFlagsRow
- type Info
- type MigrationFS
- type MigrationInfo
- type NullFlagType
- type PageFlagsParams
- type PageFlagsRow
- type Querier
- type Queries
- func (q *Queries) AddFlag(ctx context.Context, arg AddFlagParams) (FeatureFlag, error)
- func (q *Queries) GetEnvFlagValueByFlagId(ctx context.Context, flagID int64) (GetEnvFlagValueByFlagIdRow, error)
- func (q *Queries) GetEnvFlagValueByFlagIdAndEnvironment(ctx context.Context, flagID int64, environment string) (result GetEnvFlagValueByFlagIdAndEnvironmentRow, fault error)
- func (q *Queries) GetEnvFlagValueByFlagIdAndEnvironmentName(ctx context.Context, arg GetEnvFlagValueByFlagIdAndEnvironmentNameParams) (GetEnvFlagValueByFlagIdAndEnvironmentNameRow, error)
- func (q *Queries) GetFlags(ctx context.Context) ([]GetFlagsRow, error)
- func (q *Queries) GetFlagsByEnvironmentName(ctx context.Context, environmentName string) ([]GetFlagsByEnvironmentNameRow, error)
- func (q *Queries) ListEnvironments(ctx context.Context) ([]string, error)
- func (q *Queries) PageFlags(ctx context.Context, arg PageFlagsParams) ([]PageFlagsRow, error)
- func (q *Queries) SetEnvFlagToDefault(ctx context.Context, arg SetEnvFlagToDefaultParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Secret
- type SetEnvFlagToDefaultParams
- type Stage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunMigrations ¶
Types ¶
type AddFlagParams ¶
type Client ¶
type Client struct {
Queries *Queries
Pool *pgxpool.Pool
// contains filtered or unexported fields
}
func (*Client) GetQueries ¶
type Config ¶
type Config struct {
Host string `env:"POSTGRES_HOST" envDefault:"localhost"`
Port string `env:"POSTGRES_PORT" envDefault:"5433"`
Database string `env:"POSTGRES_DATABASE" envDefault:"vexil"` // Database name
Username string `env:"POSTGRES_USER" envDefault:"vexil"` // Username
Password Secret `env:"POSTGRES_PASSWORD" envDefault:"vexil"` // Password
}
func LoadConfig ¶
func (Config) GetDatabase ¶
func (Config) GetRedactedURI ¶
type ConfigProvider ¶
type DBMigrator ¶
type DBMigrator struct {
// contains filtered or unexported fields
}
func NewMigrator ¶
func NewMigrator(ctx context.Context, connParams ConfigProvider, fs embed.FS) (migrator DBMigrator, fault error)
func (*DBMigrator) Migrate ¶
func (m *DBMigrator) Migrate() (fault error)
func (*DBMigrator) MigrateTo ¶
func (m *DBMigrator) MigrateTo(sequence int32) (fault error)
type Environment ¶
type Environment struct {
ID int64
Name string
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
}
type FeatureFlag ¶
type FeatureFlag struct {
ID int64
Name string
DefaultValue string
ValueType FlagType
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
}
type FeatureFlagValue ¶
type FeatureFlagValue struct {
FeatureFlagID int64
EnvironmentID int64
Value string
UpdatedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
}
type GetFlagsByEnvironmentNameRow ¶
type GetFlagsByEnvironmentNameRow struct {
FeatureFlag FeatureFlag
Environment Environment
FeatureFlagValue FeatureFlagValue
}
type GetFlagsRow ¶
type GetFlagsRow struct {
FeatureFlag FeatureFlag
Environment Environment
FeatureFlagValue FeatureFlagValue
}
type Info ¶
type Info struct {
Hostname string
Port string
Database string
Migrations MigrationInfo
}
type MigrationFS ¶
type MigrationInfo ¶
type NullFlagType ¶
func (*NullFlagType) Scan ¶
func (ns *NullFlagType) Scan(value interface{}) error
Scan implements the Scanner interface.
type PageFlagsRow ¶
type PageFlagsRow struct {
FeatureFlag FeatureFlag
Environment Environment
FeatureFlagValue FeatureFlagValue
}
type Querier ¶
type Querier interface {
AddFlag(ctx context.Context, arg AddFlagParams) (FeatureFlag, error)
GetEnvFlagValueByFlagId(ctx context.Context, flagID int64) (GetEnvFlagValueByFlagIdRow, error)
GetEnvFlagValueByFlagIdAndEnvironmentName(ctx context.Context, arg GetEnvFlagValueByFlagIdAndEnvironmentNameParams) (GetEnvFlagValueByFlagIdAndEnvironmentNameRow, error)
GetFlags(ctx context.Context) ([]GetFlagsRow, error)
GetFlagsByEnvironmentName(ctx context.Context, environmentName string) ([]GetFlagsByEnvironmentNameRow, error)
ListEnvironments(ctx context.Context) ([]string, error)
PageFlags(ctx context.Context, arg PageFlagsParams) ([]PageFlagsRow, error)
SetEnvFlagToDefault(ctx context.Context, arg SetEnvFlagToDefaultParams) error
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AddFlag ¶
func (q *Queries) AddFlag(ctx context.Context, arg AddFlagParams) (FeatureFlag, error)
func (*Queries) GetEnvFlagValueByFlagId ¶
func (*Queries) GetEnvFlagValueByFlagIdAndEnvironment ¶
func (*Queries) GetEnvFlagValueByFlagIdAndEnvironmentName ¶
func (q *Queries) GetEnvFlagValueByFlagIdAndEnvironmentName(ctx context.Context, arg GetEnvFlagValueByFlagIdAndEnvironmentNameParams) (GetEnvFlagValueByFlagIdAndEnvironmentNameRow, error)
func (*Queries) GetFlagsByEnvironmentName ¶
func (*Queries) ListEnvironments ¶
func (*Queries) PageFlags ¶
func (q *Queries) PageFlags(ctx context.Context, arg PageFlagsParams) ([]PageFlagsRow, error)
func (*Queries) SetEnvFlagToDefault ¶
func (q *Queries) SetEnvFlagToDefault(ctx context.Context, arg SetEnvFlagToDefaultParams) error
Click to show internal directories.
Click to hide internal directories.