postgres

Documentation

Index

• func IsTemporaryConnectionError(err error) bool
• type PostgresStorage
  • func NewPostgresStorage(dataSourceName string, backoffInteraval []time.Duration) *PostgresStorage
  • func (storage *PostgresStorage) Add(ctx context.Context, metric metrics.Metrics) error
  • func (storage *PostgresStorage) Bootstrap(ctx context.Context) error
  • func (storage *PostgresStorage) BulkAdd(ctx context.Context, metricList []metrics.Metrics) error
  • func (storage *PostgresStorage) Close()
  • func (storage *PostgresStorage) Get(ctx context.Context, metric *metrics.Metrics) error
  • func (storage *PostgresStorage) List(ctx context.Context) (metricsList []metrics.Metrics, err error)
  • func (storage *PostgresStorage) Ping(ctx context.Context) bool

Functions

func IsTemporaryConnectionError

func IsTemporaryConnectionError(err error) bool

Types

type PostgresStorage

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

func NewPostgresStorage

func NewPostgresStorage(dataSourceName string, backoffInteraval []time.Duration) *PostgresStorage

func (*PostgresStorage) Add

func (storage *PostgresStorage) Add(ctx context.Context, metric metrics.Metrics) error

func (*PostgresStorage) Bootstrap

func (storage *PostgresStorage) Bootstrap(ctx context.Context) error

func (*PostgresStorage) BulkAdd

func (storage *PostgresStorage) BulkAdd(ctx context.Context, metricList []metrics.Metrics) error

func (*PostgresStorage) Close

func (storage *PostgresStorage) Close()

func (*PostgresStorage) Get

func (storage *PostgresStorage) Get(ctx context.Context, metric *metrics.Metrics) error

func (*PostgresStorage) List

func (storage *PostgresStorage) List(ctx context.Context) (metricsList []metrics.Metrics, err error)

func (*PostgresStorage) Ping

func (storage *PostgresStorage) Ping(ctx context.Context) bool