store

Documentation

Index

• type Store
  • func NewStore(db *pgxpool.Pool, querier *sqlc.Queries) *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) MapClusterFields(ctx context.Context, tc *entities.TreeCluster) error
  • func (s *Store) MapError(err error, dbType any) 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.Queries
	// contains filtered or unexported fields
}

func NewStore

func NewStore(db *pgxpool.Pool, querier *sqlc.Queries) *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) 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) MapError

func (s *Store) MapError(err error, dbType any) error

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