store

Documentation

Index

• type Store
  • func NewStore(db *pgxpool.Pool, querier sqlc.Querier) *Store
  • func (s *Store) Close()
  • func (s *Store) DB() *pgxpool.Pool
  • func (s *Store) GetLatestSensorDataBySensorID(ctx context.Context, id string) (*entities.SensorData, error)
  • func (s *Store) HandleError(err error) error
  • func (s *Store) MapClusterFields(ctx context.Context, tc *entities.TreeCluster) error
  • func (s *Store) MapSensorFields(ctx context.Context, sn *entities.Sensor) error
  • func (s *Store) WithTx(ctx context.Context, fn func(*Store) error) error

Types

type Store

type Store struct {
	sqlc.Querier
	// contains filtered or unexported fields
}

func NewStore

func NewStore(db *pgxpool.Pool, querier sqlc.Querier) *Store

func (*Store) Close

func (s *Store) Close()

func (*Store) DB

func (s *Store) DB() *pgxpool.Pool

func (*Store) GetLatestSensorDataBySensorID

func (s *Store) GetLatestSensorDataBySensorID(ctx context.Context, id string) (*entities.SensorData, error)

This function provides the latest data from a specific sensor

func (*Store) HandleError

func (s *Store) HandleError(err error) error

TODO: Improve error handling

func (*Store) MapClusterFields

func (s *Store) MapClusterFields(ctx context.Context, tc *entities.TreeCluster) error

This function is required as soon as you want to add data to the tree cluster object from the database, e.g. the linked region or the linked trees. As this function is required in different repositories, it has been outsourced.

func (*Store) MapSensorFields

func (s *Store) MapSensorFields(ctx context.Context, sn *entities.Sensor) error

This function is required as soon as you want to add the data to the sensor object

func (*Store) WithTx

func (s *Store) WithTx(ctx context.Context, fn func(*Store) error) error