server

package

v0.0.5 Latest Latest Go to latest Published: Sep 7, 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 ReadingServer
- func NewReadingServiceServer(db *sql.DB) *ReadingServer
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 ReadingServer ¶

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

--- Reading: generated CRUD ------------------------------------------------

func NewReadingServiceServer ¶

func NewReadingServiceServer(db *sql.DB) *ReadingServer

func (*ReadingServer) CreateReading ¶ added in v0.0.5

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

func (*ReadingServer) DeleteReading ¶ added in v0.0.5

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

func (*ReadingServer) GetReadingByID ¶ added in v0.0.5

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

func (*ReadingServer) ListReadingBySensorId ¶ added in v0.0.5

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

func (*ReadingServer) ListReadingFilterBySensorIdRecordedAtFlagged ¶ added in v0.0.5

func (s *ReadingServer) ListReadingFilterBySensorIdRecordedAtFlagged(
	ctx context.Context,
	req *connect.Request[pb.ListReadingFilterBySensorIdRecordedAtFlaggedRequest],
) (*connect.Response[pb.ListReadingFilterBySensorIdRecordedAtFlaggedResponse], 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.5

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