memory

Documentation

Index

• type DB
  • func New(_, _ string) (*DB, error)
  • func (d *DB) Close() error
  • func (d *DB) DeactivateConfig(ctx context.Context, userID string) error
  • func (d *DB) GetAllConfigs(ctx context.Context) (map[string]userconfig.View, error)
  • func (d *DB) GetAllRulesConfigs(ctx context.Context) (map[string]userconfig.VersionedRulesConfig, error)
  • func (d *DB) GetConfig(ctx context.Context, userID string) (userconfig.View, error)
  • func (d *DB) GetConfigs(ctx context.Context, since userconfig.ID) (map[string]userconfig.View, error)
  • func (d *DB) GetRulesConfig(ctx context.Context, userID string) (userconfig.VersionedRulesConfig, error)
  • func (d *DB) GetRulesConfigs(ctx context.Context, since userconfig.ID) (map[string]userconfig.VersionedRulesConfig, error)
  • func (d *DB) RestoreConfig(ctx context.Context, userID string) error
  • func (d *DB) SetConfig(ctx context.Context, userID string, cfg userconfig.Config) error
  • func (d *DB) SetDeletedAtConfig(ctx context.Context, userID string, deletedAt time.Time) error
  • func (d *DB) SetRulesConfig(ctx context.Context, userID string, ...) (bool, error)

Types

type DB

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

DB is an in-memory database for testing, and local development

func New

func New(_, _ string) (*DB, error)

New creates a new in-memory database

func (*DB) Close

func (d *DB) Close() error

Close finishes using the db. Noop.

func (*DB) DeactivateConfig

func (d *DB) DeactivateConfig(ctx context.Context, userID string) error

DeactivateConfig deactivates configuration for a user by creating new configuration with DeletedAt set to now

func (*DB) GetAllConfigs

func (d *DB) GetAllConfigs(ctx context.Context) (map[string]userconfig.View, error)

GetAllConfigs gets all of the userconfig.

func (*DB) GetAllRulesConfigs

func (d *DB) GetAllRulesConfigs(ctx context.Context) (map[string]userconfig.VersionedRulesConfig, error)

GetAllRulesConfigs gets the rules configs for all users that have them.

func (*DB) GetConfig

func (d *DB) GetConfig(ctx context.Context, userID string) (userconfig.View, error)

GetConfig gets the user's configuration.

func (*DB) GetConfigs

func (d *DB) GetConfigs(ctx context.Context, since userconfig.ID) (map[string]userconfig.View, error)

GetConfigs gets all of the configs that have changed recently.

func (*DB) GetRulesConfig

func (d *DB) GetRulesConfig(ctx context.Context, userID string) (userconfig.VersionedRulesConfig, error)

GetRulesConfig gets the rules config for a user.

func (*DB) GetRulesConfigs

func (d *DB) GetRulesConfigs(ctx context.Context, since userconfig.ID) (map[string]userconfig.VersionedRulesConfig, error)

GetRulesConfigs gets the rules configs that have changed since the given config version.

func (*DB) RestoreConfig

func (d *DB) RestoreConfig(ctx context.Context, userID string) error

RestoreConfig restores deactivated configuration for a user by creating new configuration with empty DeletedAt

func (*DB) SetConfig

func (d *DB) SetConfig(ctx context.Context, userID string, cfg userconfig.Config) error

SetConfig sets configuration for a user.

func (*DB) SetDeletedAtConfig

func (d *DB) SetDeletedAtConfig(ctx context.Context, userID string, deletedAt time.Time) error

SetDeletedAtConfig sets a deletedAt for configuration by adding a single new row with deleted_at set the same as SetConfig is actually insert

func (*DB) SetRulesConfig

func (d *DB) SetRulesConfig(ctx context.Context, userID string, oldConfig, newConfig userconfig.RulesConfig) (bool, error)

SetRulesConfig sets the rules config for a user.