server

package

v0.0.7 Latest Latest Go to latest Published: Sep 10, 2026 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/guntisdev/entlite

Links

Open Source Insights

Documentation ¶

Index ¶

type AnalyticsServer
- func NewSensorAnalyticsServiceServer(db *sql.DB) *AnalyticsServer
type SensorReadingServer
- func NewSensorReadingServiceServer(db *sql.DB) *SensorReadingServer
type SensorServer
- func NewSensorServiceServer(db *sql.DB) *SensorServer

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 SensorReadingServer ¶ added in v0.0.6

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

--- SensorReading: generated CRUD ------------------------------------------------

func NewSensorReadingServiceServer ¶ added in v0.0.6

func NewSensorReadingServiceServer(db *sql.DB) *SensorReadingServer

func (*SensorReadingServer) CreateSensorReading ¶ added in v0.0.6

func (s *SensorReadingServer) CreateSensorReading(
	ctx context.Context,
	req *connect.Request[pb.CreateSensorReadingRequest],
) (*connect.Response[pb.SensorReading], error)

func (*SensorReadingServer) DeleteSensorReading ¶ added in v0.0.6

func (s *SensorReadingServer) DeleteSensorReading(
	ctx context.Context,
	req *connect.Request[pb.DeleteSensorReadingRequest],
) (*connect.Response[emptypb.Empty], error)

func (*SensorReadingServer) GetSensorReadingById ¶ added in v0.0.6

func (s *SensorReadingServer) GetSensorReadingById(
	ctx context.Context,
	req *connect.Request[pb.GetSensorReadingByIdRequest],
) (*connect.Response[pb.SensorReading], error)

func (*SensorReadingServer) ListSensorReadingBySensorId ¶ added in v0.0.6

func (s *SensorReadingServer) ListSensorReadingBySensorId(
	ctx context.Context,
	req *connect.Request[pb.ListSensorReadingBySensorIdRequest],
) (*connect.Response[pb.ListSensorReadingBySensorIdResponse], error)

func (*SensorReadingServer) ListSensorReadingFilterBySensorIdRecordedAtFlagged ¶ added in v0.0.6

func (s *SensorReadingServer) ListSensorReadingFilterBySensorIdRecordedAtFlagged(
	ctx context.Context,
	req *connect.Request[pb.ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest],
) (*connect.Response[pb.ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse], error)

type SensorServer ¶

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

--- Sensor: generated CRUD -------------------------------------------------

func NewSensorServiceServer ¶

func NewSensorServiceServer(db *sql.DB) *SensorServer

func (*SensorServer) CreateSensor ¶ added in v0.0.5

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

func (*SensorServer) DeleteSensor ¶ added in v0.0.5

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

func (*SensorServer) GetSensorByCode ¶ added in v0.0.5

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

func (*SensorServer) GetSensorById ¶ added in v0.0.6

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

func (*SensorServer) ListSensorFilterByLabelKindActive ¶ added in v0.0.5

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

func (*SensorServer) UpdateSensor ¶ added in v0.0.5

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

Source Files ¶

View all Source files

server.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL