sensor

Documentation

Index

• type SensorRepository
  • func NewSensorRepository(s *store.Store, mappers SensorRepositoryMappers) *SensorRepository
  • func (r *SensorRepository) Create(ctx context.Context, ...) (*entities.Sensor, error)
  • func (r *SensorRepository) Delete(ctx context.Context, id string) error
  • func (r *SensorRepository) GetAll(ctx context.Context, query entities.Query) ([]*entities.Sensor, int64, error)
  • func (r *SensorRepository) GetAllDataByID(ctx context.Context, id string) ([]*entities.SensorData, error)
  • func (r *SensorRepository) GetByID(ctx context.Context, id string) (*entities.Sensor, error)
  • func (r *SensorRepository) GetCount(ctx context.Context, query entities.Query) (int64, 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, ...) (*entities.Sensor, error)
• type SensorRepositoryMappers
  • func NewSensorRepositoryMappers(sMapper mapper.InternalSensorRepoMapper) SensorRepositoryMappers

Types

type SensorRepository

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

func NewSensorRepository

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

func (*SensorRepository) Create

func (r *SensorRepository) Create(ctx context.Context, createFn func(*entities.Sensor, storage.SensorRepository) (bool, error)) (*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, query entities.Query) ([]*entities.Sensor, int64, error)

func (*SensorRepository) GetAllDataByID

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

func (*SensorRepository) GetByID

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

func (*SensorRepository) GetCount

func (r *SensorRepository) GetCount(ctx context.Context, query entities.Query) (int64, 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, updateFn func(*entities.Sensor, storage.SensorRepository) (bool, error)) (*entities.Sensor, error)

type SensorRepositoryMappers

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

func NewSensorRepositoryMappers

func NewSensorRepositoryMappers(sMapper mapper.InternalSensorRepoMapper) SensorRepositoryMappers