database

Documentation

Index

• type Database
  • func NewFromConfig(ctx context.Context, cfg *config.Config) (*Database, error)
  • func NewWithInsecureDefaults(ctx context.Context) (*Database, error)
  • func (db *Database) AddReport(ctx context.Context, report *proto.Report) error
  • func (db *Database) Close()
  • func (db *Database) CreateAuthorizationKey(ctx context.Context, request *proto.TokenRequest) ([]byte, error)
  • func (db *Database) GetDiagnosisKeys(ctx context.Context, request *proto.GetKeyRequest) (chan *proto.TimestampedTEK, chan error)
  • func (db *Database) RunAsTransaction(ctx context.Context, f func(txn pgx.Tx) error) error

Types

type Database

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

Database object providing pooled connections to the underlying postgres database

func NewFromConfig

func NewFromConfig(ctx context.Context, cfg *config.Config) (*Database, error)

Creates a new Database instance from the given configuration

func NewWithInsecureDefaults

func NewWithInsecureDefaults(ctx context.Context) (*Database, error)

Creates a new Database instance from the insecure defaults given in the docker compose file. Helpful for testing.

func (*Database) AddReport

func (db *Database) AddReport(ctx context.Context, report *proto.Report) error

func (*Database) Close

func (db *Database) Close()

func (*Database) CreateAuthorizationKey

func (db *Database) CreateAuthorizationKey(ctx context.Context, request *proto.TokenRequest) ([]byte, error)

Create a one-time use authorization key to be given to a patient.

func (*Database) GetDiagnosisKeys

func (db *Database) GetDiagnosisKeys(ctx context.Context, request *proto.GetKeyRequest) (chan *proto.TimestampedTEK, chan error)

func (*Database) RunAsTransaction

func (db *Database) RunAsTransaction(ctx context.Context, f func(txn pgx.Tx) error) error