sensor

Documentation

Index

• func NewSensorRepository(s *store.Store, mappers SensorRepositoryMappers) storage.SensorRepository
• func WithLatestData(data *entities.SensorData) entities.EntityFunc[entities.Sensor]
• func WithLatitude(lat float64) entities.EntityFunc[entities.Sensor]
• func WithLongitude(long float64) entities.EntityFunc[entities.Sensor]
• func WithSensorID(sensorID string) entities.EntityFunc[entities.Sensor]
• func WithStatus(status entities.SensorStatus) entities.EntityFunc[entities.Sensor]
• type SensorRepository
  • func (r *SensorRepository) Create(ctx context.Context, sFn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)
  • func (r *SensorRepository) Delete(ctx context.Context, id string) error
  • func (r *SensorRepository) GetAll(ctx context.Context) ([]*entities.Sensor, error)
  • func (r *SensorRepository) GetByID(ctx context.Context, id string) (*entities.Sensor, error)
  • func (r *SensorRepository) GetLatestSensorDataBySensorID(ctx context.Context, id string) (*entities.SensorData, error)
  • func (r *SensorRepository) InsertSensorData(ctx context.Context, latestData *entities.SensorData, id string) error
  • func (r *SensorRepository) Update(ctx context.Context, id string, sFn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)
• type SensorRepositoryMappers
  • func NewSensorRepositoryMappers(sMapper mapper.InternalSensorRepoMapper) SensorRepositoryMappers

Functions

func NewSensorRepository

func NewSensorRepository(s *store.Store, mappers SensorRepositoryMappers) storage.SensorRepository

func WithLatestData

func WithLatestData(data *entities.SensorData) entities.EntityFunc[entities.Sensor]

func WithLatitude

func WithLatitude(lat float64) entities.EntityFunc[entities.Sensor]

func WithLongitude

func WithLongitude(long float64) entities.EntityFunc[entities.Sensor]

func WithSensorID

func WithSensorID(sensorID string) entities.EntityFunc[entities.Sensor]

func WithStatus

func WithStatus(status entities.SensorStatus) entities.EntityFunc[entities.Sensor]

Types

type SensorRepository

type SensorRepository struct {
	SensorRepositoryMappers
	// contains filtered or unexported fields
}

func (*SensorRepository) Create

func (r *SensorRepository) Create(ctx context.Context, sFn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)

func (*SensorRepository) Delete

func (r *SensorRepository) Delete(ctx context.Context, id string) error

func (*SensorRepository) GetAll

func (r *SensorRepository) GetAll(ctx context.Context) ([]*entities.Sensor, error)

func (*SensorRepository) GetByID

func (r *SensorRepository) GetByID(ctx context.Context, id string) (*entities.Sensor, error)

func (*SensorRepository) GetLatestSensorDataBySensorID

func (r *SensorRepository) GetLatestSensorDataBySensorID(ctx context.Context, id string) (*entities.SensorData, error)

func (*SensorRepository) InsertSensorData

func (r *SensorRepository) InsertSensorData(ctx context.Context, latestData *entities.SensorData, id string) error

func (*SensorRepository) Update

func (r *SensorRepository) Update(ctx context.Context, id string, sFn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)

type SensorRepositoryMappers

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

func NewSensorRepositoryMappers

func NewSensorRepositoryMappers(sMapper mapper.InternalSensorRepoMapper) SensorRepositoryMappers