sensor

Documentation

Index

• func NewSensorRepository(s *store.Store, mappers SensorRepositoryMappers) storage.SensorRepository
• func WithData(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) GetSensorByStatus(ctx context.Context, status *entities.SensorStatus) ([]*entities.Sensor, error)
  • func (r *SensorRepository) GetSensorDataByID(ctx context.Context, id string) ([]*entities.SensorData, error)
  • func (r *SensorRepository) GetStatusByID(ctx context.Context, id string) (*entities.SensorStatus, error)
  • func (r *SensorRepository) InsertSensorData(ctx context.Context, data []*entities.SensorData, id string) ([]*entities.SensorData, 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 WithData

func WithData(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) GetSensorByStatus

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

func (*SensorRepository) GetSensorDataByID

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

func (*SensorRepository) GetStatusByID

func (r *SensorRepository) GetStatusByID(ctx context.Context, id string) (*entities.SensorStatus, error)

func (*SensorRepository) InsertSensorData

func (r *SensorRepository) InsertSensorData(ctx context.Context, data []*entities.SensorData, id string) ([]*entities.SensorData, 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