Documentation
¶
Overview ¶
Package postgres contains repository implementations using Postgres as the underlying database.
Index ¶
- func Connect(cfg Config) (*sqlx.DB, error)
- func NewJSONRepository(db dbutil.Database) readers.JSONMessageRepository
- func NewSenMLRepository(db dbutil.Database) readers.SenMLMessageRepository
- type AggStrategy
- type AvgStrategy
- type Config
- type CountStrategy
- type MaxStrategy
- type MinStrategy
- type QueryParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
Connect creates a connection to the PostgreSQL instance and applies any unapplied database migrations. A non-nil error is returned to indicate failure.
func NewJSONRepository ¶ added in v0.30.1
func NewJSONRepository(db dbutil.Database) readers.JSONMessageRepository
func NewSenMLRepository ¶ added in v0.30.1
func NewSenMLRepository(db dbutil.Database) readers.SenMLMessageRepository
Types ¶
type AggStrategy ¶ added in v0.29.1
type AggStrategy interface {
// Function that builds the query for aggregation.
BuildQuery(qp QueryParams) string
// Function that returns selected strings.
GetSelectedFields(qp QueryParams) string
//Function containing aggregation expression.
GetAggregateExpression(qp QueryParams) string
}
type AvgStrategy ¶ added in v0.29.1
type AvgStrategy struct{}
func (AvgStrategy) BuildQuery ¶ added in v0.29.1
func (avgStrt AvgStrategy) BuildQuery(qp QueryParams) string
func (AvgStrategy) GetAggregateExpression ¶ added in v0.29.1
func (avgStrt AvgStrategy) GetAggregateExpression(qp QueryParams) string
func (AvgStrategy) GetSelectedFields ¶ added in v0.29.1
func (avgStrt AvgStrategy) GetSelectedFields(qp QueryParams) string
type Config ¶
type Config struct {
Host string
Port string
User string
Pass string
Name string
SSLMode string
SSLCert string
SSLKey string
SSLRootCert string
}
Config defines the options that are used when connecting to a PostgreSQL instance
type CountStrategy ¶ added in v0.29.1
type CountStrategy struct{}
func (CountStrategy) BuildQuery ¶ added in v0.29.1
func (countStrt CountStrategy) BuildQuery(qp QueryParams) string
func (CountStrategy) GetAggregateExpression ¶ added in v0.29.1
func (countStrt CountStrategy) GetAggregateExpression(qp QueryParams) string
func (CountStrategy) GetSelectedFields ¶ added in v0.29.1
func (countStrt CountStrategy) GetSelectedFields(qp QueryParams) string
type MaxStrategy ¶ added in v0.29.1
type MaxStrategy struct{}
func (MaxStrategy) BuildQuery ¶ added in v0.29.1
func (maxStrt MaxStrategy) BuildQuery(qp QueryParams) string
func (MaxStrategy) GetAggregateExpression ¶ added in v0.29.1
func (maxStrt MaxStrategy) GetAggregateExpression(qp QueryParams) string
func (MaxStrategy) GetSelectedFields ¶ added in v0.29.1
func (maxStrt MaxStrategy) GetSelectedFields(qp QueryParams) string
type MinStrategy ¶ added in v0.29.1
type MinStrategy struct{}
func (MinStrategy) BuildQuery ¶ added in v0.29.1
func (minStrt MinStrategy) BuildQuery(qp QueryParams) string
func (MinStrategy) GetAggregateExpression ¶ added in v0.29.1
func (minStrt MinStrategy) GetAggregateExpression(qp QueryParams) string
func (MinStrategy) GetSelectedFields ¶ added in v0.29.1
func (minStrt MinStrategy) GetSelectedFields(qp QueryParams) string
Click to show internal directories.
Click to hide internal directories.