Documentation
¶
Index ¶
- type AnalyticsServer
- func (s *AnalyticsServer) GetReadingStats(ctx context.Context, req *connect.Request[pb.GetSensorReadingStatsRequest]) (*connect.Response[pb.SensorReadingStats], error)
- func (s *AnalyticsServer) ListWithLatestReading(ctx context.Context, ...) (*connect.Response[pb.ListSensorsWithLatestReadingResponse], error)
- func (s *AnalyticsServer) PruneReadings(ctx context.Context, req *connect.Request[pb.PruneReadingsRequest]) (*connect.Response[pb.PruneReadingsResponse], error)
- type ReadingServer
- 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, ...) (*connect.Response[pb.ListReadingFilterBySensorIdRecordedAtFlaggedResponse], ...)
- 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 *ReadingServer) Update(ctx context.Context, req *connect.Request[pb.UpdateReadingRequest]) (*connect.Response[pb.Reading], error)
- type SensorServer
- 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, ...) (*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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AnalyticsServer ¶
type AnalyticsServer struct {
// contains filtered or unexported fields
}
--- Sensor analytics: hand-written custom.sql + custom.proto ---------------
func NewSensorAnalyticsServiceServer ¶
func NewSensorAnalyticsServiceServer(db *sql.DB) *AnalyticsServer
func (*AnalyticsServer) GetReadingStats ¶
func (s *AnalyticsServer) GetReadingStats( ctx context.Context, req *connect.Request[pb.GetSensorReadingStatsRequest], ) (*connect.Response[pb.SensorReadingStats], error)
func (*AnalyticsServer) ListWithLatestReading ¶
func (s *AnalyticsServer) ListWithLatestReading( ctx context.Context, req *connect.Request[pb.ListSensorsWithLatestReadingRequest], ) (*connect.Response[pb.ListSensorsWithLatestReadingResponse], error)
func (*AnalyticsServer) PruneReadings ¶
func (s *AnalyticsServer) PruneReadings( ctx context.Context, req *connect.Request[pb.PruneReadingsRequest], ) (*connect.Response[pb.PruneReadingsResponse], error)
type ReadingServer ¶
type ReadingServer struct {
// contains filtered or unexported fields
}
--- Reading: generated CRUD ------------------------------------------------
func NewReadingServiceServer ¶
func NewReadingServiceServer(db *sql.DB) *ReadingServer
func (*ReadingServer) FilterBySensorIdRecordedAtFlagged ¶
func (s *ReadingServer) FilterBySensorIdRecordedAtFlagged( ctx context.Context, req *connect.Request[pb.ListReadingFilterBySensorIdRecordedAtFlaggedRequest], ) (*connect.Response[pb.ListReadingFilterBySensorIdRecordedAtFlaggedResponse], error)
func (*ReadingServer) ListBySensorId ¶
func (s *ReadingServer) ListBySensorId( ctx context.Context, req *connect.Request[pb.ListReadingBySensorIdRequest], ) (*connect.Response[pb.ListReadingBySensorIdResponse], error)
type SensorServer ¶
type SensorServer struct {
// contains filtered or unexported fields
}
--- Sensor: generated CRUD -------------------------------------------------
func NewSensorServiceServer ¶
func NewSensorServiceServer(db *sql.DB) *SensorServer
func (*SensorServer) FilterByLabelKindActive ¶
func (s *SensorServer) FilterByLabelKindActive( ctx context.Context, req *connect.Request[pb.ListSensorFilterByLabelKindActiveRequest], ) (*connect.Response[pb.ListSensorFilterByLabelKindActiveResponse], error)
Click to show internal directories.
Click to hide internal directories.