postgres

Documentation

Overview

Package postgres provides an implementation of diag.Repository using PostgreSQL for underlying database storage.

Index

• type Client
  • func New(dsn string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) FindAllDiagnosisKeys(ctx context.Context) ([]byte, error)
  • func (c *Client) LastModified(ctx context.Context) (time.Time, error)
  • func (c *Client) Ping() error
  • func (c *Client) StoreDiagnosisKeys(ctx context.Context, diagKeys []diag.DiagnosisKey, uploadedAt time.Time) error

Types

type Client

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

Client implements diag.Repository.

func New

func New(dsn string) (*Client, error)

New returns a new Client.

func (*Client) Close

func (c *Client) Close() error

Close uses the underlying database client to close all connections.

func (*Client) FindAllDiagnosisKeys

func (c *Client) FindAllDiagnosisKeys(ctx context.Context) ([]byte, error)

FindAllDiagnosisKeys finds all the Diagnosis Keys and returns them in their binary representation in a buffer.

func (*Client) LastModified

func (c *Client) LastModified(ctx context.Context) (time.Time, error)

LastModified returns the timestamp of the latest uploaded Diagnosis Key.

func (*Client) Ping

func (c *Client) Ping() error

Ping uses the underlying database client to for check connectivity.

func (*Client) StoreDiagnosisKeys

func (c *Client) StoreDiagnosisKeys(ctx context.Context, diagKeys []diag.DiagnosisKey, uploadedAt time.Time) error

StoreDiagnosisKeys persists an array of diagnosis keys in the database.