server

func (s *AnalyticsServer) GetReadingStats(
	ctx context.Context,
	req *connect.Request[pb.GetSensorReadingStatsRequest],
) (*connect.Response[pb.SensorReadingStats], error)

func (s *AnalyticsServer) ListWithLatestReading(
	ctx context.Context,
	req *connect.Request[pb.ListSensorsWithLatestReadingRequest],
) (*connect.Response[pb.ListSensorsWithLatestReadingResponse], error)

func (s *AnalyticsServer) PruneReadings(
	ctx context.Context,
	req *connect.Request[pb.PruneReadingsRequest],
) (*connect.Response[pb.PruneReadingsResponse], error)

func (s *ReadingServer) Create(
	ctx context.Context,
	req *connect.Request[pb.CreateReadingRequest],
) (*connect.Response[pb.Reading], error)

func (s *ReadingServer) Delete(
	ctx context.Context,
	req *connect.Request[pb.DeleteReadingRequest],
) (*connect.Response[emptypb.Empty], error)

func (s *ReadingServer) FilterBySensorIdRecordedAtFlagged(
	ctx context.Context,
	req *connect.Request[pb.ListReadingFilterBySensorIdRecordedAtFlaggedRequest],
) (*connect.Response[pb.ListReadingFilterBySensorIdRecordedAtFlaggedResponse], error)

func (s *ReadingServer) GetByID(
	ctx context.Context,
	req *connect.Request[pb.GetReadingByIDRequest],
) (*connect.Response[pb.Reading], error)

func (s *ReadingServer) ListBySensorId(
	ctx context.Context,
	req *connect.Request[pb.ListReadingBySensorIdRequest],
) (*connect.Response[pb.ListReadingBySensorIdResponse], error)

func (s *SensorServer) Create(
	ctx context.Context,
	req *connect.Request[pb.CreateSensorRequest],
) (*connect.Response[pb.Sensor], error)

func (s *SensorServer) Delete(
	ctx context.Context,
	req *connect.Request[pb.DeleteSensorRequest],
) (*connect.Response[emptypb.Empty], error)

func (s *SensorServer) FilterByLabelKindActive(
	ctx context.Context,
	req *connect.Request[pb.ListSensorFilterByLabelKindActiveRequest],
) (*connect.Response[pb.ListSensorFilterByLabelKindActiveResponse], error)

func (s *SensorServer) GetByCode(
	ctx context.Context,
	req *connect.Request[pb.GetSensorByCodeRequest],
) (*connect.Response[pb.Sensor], error)

func (s *SensorServer) GetByID(
	ctx context.Context,
	req *connect.Request[pb.GetSensorByIDRequest],
) (*connect.Response[pb.Sensor], error)

func (s *SensorServer) Update(
	ctx context.Context,
	req *connect.Request[pb.UpdateSensorRequest],
) (*connect.Response[pb.Sensor], error)