db

Documentation

Index

• Constants
• type ConfigLock
  • func (l *ConfigLock) IsActive() bool
• type Database
  • func NewDatabase(awsClient aws_client.AwsClient) (Database, error)
• type LocalLockDatabase
  • func (d *LocalLockDatabase) LockConfig(_ context.Context, userId string) (lock *ConfigLock, err error)
  • func (d *LocalLockDatabase) UnlockConfig(_ context.Context, lock *ConfigLock) error
• type LockDatabase
• type LockType
• type RemoteLockDatabase
  • func NewLockDatabase(dbConnection *sql.DB) (*RemoteLockDatabase, error)
  • func (d *RemoteLockDatabase) LockConfig(ctx context.Context, userId string) (lock *ConfigLock, err error)
  • func (d *RemoteLockDatabase) UnlockConfig(ctx context.Context, lock *ConfigLock) error

Constants

const (
	MainConfigLock = "main"
)

Types

type ConfigLock

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

func (*ConfigLock) IsActive

func (l *ConfigLock) IsActive() bool

type Database

type Database interface {
	LockDatabase
	GetUserId(ctx context.Context, apiKey string) (string, error)
	CreateUser(ctx context.Context, emailAddress string) (apiKey string, err error)
	StoreUserConfig(config *configpb.Config, lock *ConfigLock) error
	LoadUserConfig(userId string, lock *ConfigLock) (*configpb.Config, error)
	Close() error
}

func NewDatabase

func NewDatabase(awsClient aws_client.AwsClient) (Database, error)

type LocalLockDatabase

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

func (*LocalLockDatabase) LockConfig

func (d *LocalLockDatabase) LockConfig(_ context.Context, userId string) (lock *ConfigLock, err error)

func (*LocalLockDatabase) UnlockConfig

func (d *LocalLockDatabase) UnlockConfig(_ context.Context, lock *ConfigLock) error

type LockDatabase

type LockDatabase interface {
	LockConfig(ctx context.Context, userId string) (lock *ConfigLock, err error)
	UnlockConfig(ctx context.Context, lock *ConfigLock) error
}

type LockType

type LockType string

type RemoteLockDatabase

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

func NewLockDatabase

func NewLockDatabase(dbConnection *sql.DB) (*RemoteLockDatabase, error)

func (*RemoteLockDatabase) LockConfig

func (d *RemoteLockDatabase) LockConfig(ctx context.Context, userId string) (lock *ConfigLock, err error)

func (*RemoteLockDatabase) UnlockConfig

func (d *RemoteLockDatabase) UnlockConfig(ctx context.Context, lock *ConfigLock) error