pb

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// SensorAnalyticsServiceGetReadingStatsProcedure is the fully-qualified name of the
	// SensorAnalyticsService's GetReadingStats RPC.
	SensorAnalyticsServiceGetReadingStatsProcedure = "/entlite.SensorAnalyticsService/GetReadingStats"
	// SensorAnalyticsServiceListWithLatestReadingProcedure is the fully-qualified name of the
	// SensorAnalyticsService's ListWithLatestReading RPC.
	SensorAnalyticsServiceListWithLatestReadingProcedure = "/entlite.SensorAnalyticsService/ListWithLatestReading"
	// SensorAnalyticsServicePruneReadingsProcedure is the fully-qualified name of the
	// SensorAnalyticsService's PruneReadings RPC.
	SensorAnalyticsServicePruneReadingsProcedure = "/entlite.SensorAnalyticsService/PruneReadings"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ReadingServiceName is the fully-qualified name of the ReadingService service.
	ReadingServiceName = "entlite.ReadingService"
	// SensorServiceName is the fully-qualified name of the SensorService service.
	SensorServiceName = "entlite.SensorService"
)
View Source 
const (
	// ReadingServiceCreateProcedure is the fully-qualified name of the ReadingService's Create RPC.
	ReadingServiceCreateProcedure = "/entlite.ReadingService/Create"
	// ReadingServiceGetByIDProcedure is the fully-qualified name of the ReadingService's GetByID RPC.
	ReadingServiceGetByIDProcedure = "/entlite.ReadingService/GetByID"
	// ReadingServiceDeleteProcedure is the fully-qualified name of the ReadingService's Delete RPC.
	ReadingServiceDeleteProcedure = "/entlite.ReadingService/Delete"
	// ReadingServiceListBySensorIdProcedure is the fully-qualified name of the ReadingService's
	// ListBySensorId RPC.
	ReadingServiceListBySensorIdProcedure = "/entlite.ReadingService/ListBySensorId"
	// ReadingServiceFilterBySensorIdRecordedAtFlaggedProcedure is the fully-qualified name of the
	// ReadingService's FilterBySensorIdRecordedAtFlagged RPC.
	ReadingServiceFilterBySensorIdRecordedAtFlaggedProcedure = "/entlite.ReadingService/FilterBySensorIdRecordedAtFlagged"
	// SensorServiceCreateProcedure is the fully-qualified name of the SensorService's Create RPC.
	SensorServiceCreateProcedure = "/entlite.SensorService/Create"
	// SensorServiceGetByIDProcedure is the fully-qualified name of the SensorService's GetByID RPC.
	SensorServiceGetByIDProcedure = "/entlite.SensorService/GetByID"
	// SensorServiceUpdateProcedure is the fully-qualified name of the SensorService's Update RPC.
	SensorServiceUpdateProcedure = "/entlite.SensorService/Update"
	// SensorServiceDeleteProcedure is the fully-qualified name of the SensorService's Delete RPC.
	SensorServiceDeleteProcedure = "/entlite.SensorService/Delete"
	// SensorServiceGetByCodeProcedure is the fully-qualified name of the SensorService's GetByCode RPC.
	SensorServiceGetByCodeProcedure = "/entlite.SensorService/GetByCode"
	// SensorServiceFilterByLabelKindActiveProcedure is the fully-qualified name of the SensorService's
	// FilterByLabelKindActive RPC.
	SensorServiceFilterByLabelKindActiveProcedure = "/entlite.SensorService/FilterByLabelKindActive"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// SensorAnalyticsServiceName is the fully-qualified name of the SensorAnalyticsService service.
	SensorAnalyticsServiceName = "entlite.SensorAnalyticsService"
)

Variables

View Source 
var File_custom_proto protoreflect.FileDescriptor
View Source 
var File_schema_proto protoreflect.FileDescriptor

Functions

func NewReadingServiceHandler 

func NewReadingServiceHandler(svc ReadingServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewReadingServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewSensorAnalyticsServiceHandler 

func NewSensorAnalyticsServiceHandler(svc SensorAnalyticsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewSensorAnalyticsServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewSensorServiceHandler 

func NewSensorServiceHandler(svc SensorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewSensorServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type CreateReadingRequest 

type CreateReadingRequest struct {

	// References sensor.ID
	SensorId int32   `protobuf:"varint,2,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	Value    float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// Signal quality 0-100
	Quality int32 `protobuf:"varint,4,opt,name=quality,proto3" json:"quality,omitempty"`
	// Marked as anomalous by ingestion
	Flagged *bool `protobuf:"varint,5,opt,name=flagged,proto3,oneof" json:"flagged,omitempty"`
	// Device measurement time (client-supplied)
	RecordedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=recorded_at,json=recordedAt,proto3" json:"recorded_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReadingRequest) Descriptor deprecated 

func (*CreateReadingRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateReadingRequest.ProtoReflect.Descriptor instead.

func (*CreateReadingRequest) GetFlagged 

func (x *CreateReadingRequest) GetFlagged() bool

func (*CreateReadingRequest) GetQuality 

func (x *CreateReadingRequest) GetQuality() int32

func (*CreateReadingRequest) GetRecordedAt 

func (x *CreateReadingRequest) GetRecordedAt() *timestamppb.Timestamp

func (*CreateReadingRequest) GetSensorId 

func (x *CreateReadingRequest) GetSensorId() int32

func (*CreateReadingRequest) GetValue 

func (x *CreateReadingRequest) GetValue() float64

func (*CreateReadingRequest) ProtoMessage 

func (*CreateReadingRequest) ProtoMessage()

func (*CreateReadingRequest) ProtoReflect 

func (x *CreateReadingRequest) ProtoReflect() protoreflect.Message

func (*CreateReadingRequest) Reset 

func (x *CreateReadingRequest) Reset()

func (*CreateReadingRequest) String 

func (x *CreateReadingRequest) String() string

func (*CreateReadingRequest) Validate 

func (r *CreateReadingRequest) Validate() error

type CreateSensorRequest 

type CreateSensorRequest struct {

	// External hardware identifier, e.g. TEMP-A1
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// Human friendly name
	Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	// temperature | humidity | pressure | motion
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// Measurement unit, e.g. celsius
	Unit     string  `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
	Location *string `protobuf:"bytes,6,opt,name=location,proto3,oneof" json:"location,omitempty"`
	Active   *bool   `protobuf:"varint,7,opt,name=active,proto3,oneof" json:"active,omitempty"`
	Firmware *string `protobuf:"bytes,8,opt,name=firmware,proto3,oneof" json:"firmware,omitempty"`
	// Sampling interval in milliseconds
	SampleRateMs *int32 `protobuf:"varint,9,opt,name=sample_rate_ms,json=sampleRateMs,proto3,oneof" json:"sample_rate_ms,omitempty"`
	// When the device was physically installed (client-supplied)
	InstalledAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=installed_at,json=installedAt,proto3" json:"installed_at,omitempty"`
	// Most recent reading value, joined in at the API layer - not stored
	LatestValue *float64 `protobuf:"fixed64,13,opt,name=latest_value,json=latestValue,proto3,oneof" json:"latest_value,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSensorRequest) Descriptor deprecated 

func (*CreateSensorRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateSensorRequest.ProtoReflect.Descriptor instead.

func (*CreateSensorRequest) GetActive 

func (x *CreateSensorRequest) GetActive() bool

func (*CreateSensorRequest) GetCode 

func (x *CreateSensorRequest) GetCode() string

func (*CreateSensorRequest) GetFirmware 

func (x *CreateSensorRequest) GetFirmware() string

func (*CreateSensorRequest) GetInstalledAt 

func (x *CreateSensorRequest) GetInstalledAt() *timestamppb.Timestamp

func (*CreateSensorRequest) GetKind 

func (x *CreateSensorRequest) GetKind() string

func (*CreateSensorRequest) GetLabel 

func (x *CreateSensorRequest) GetLabel() string

func (*CreateSensorRequest) GetLatestValue 

func (x *CreateSensorRequest) GetLatestValue() float64

func (*CreateSensorRequest) GetLocation 

func (x *CreateSensorRequest) GetLocation() string

func (*CreateSensorRequest) GetSampleRateMs 

func (x *CreateSensorRequest) GetSampleRateMs() int32

func (*CreateSensorRequest) GetUnit 

func (x *CreateSensorRequest) GetUnit() string

func (*CreateSensorRequest) ProtoMessage 

func (*CreateSensorRequest) ProtoMessage()

func (*CreateSensorRequest) ProtoReflect 

func (x *CreateSensorRequest) ProtoReflect() protoreflect.Message

func (*CreateSensorRequest) Reset 

func (x *CreateSensorRequest) Reset()

func (*CreateSensorRequest) String 

func (x *CreateSensorRequest) String() string

func (*CreateSensorRequest) Validate 

func (r *CreateSensorRequest) Validate() error

type DeleteReadingRequest 

type DeleteReadingRequest struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteReadingRequest) Descriptor deprecated 

func (*DeleteReadingRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteReadingRequest.ProtoReflect.Descriptor instead.

func (*DeleteReadingRequest) GetID 

func (x *DeleteReadingRequest) GetID() int64

func (*DeleteReadingRequest) ProtoMessage 

func (*DeleteReadingRequest) ProtoMessage()

func (*DeleteReadingRequest) ProtoReflect 

func (x *DeleteReadingRequest) ProtoReflect() protoreflect.Message

func (*DeleteReadingRequest) Reset 

func (x *DeleteReadingRequest) Reset()

func (*DeleteReadingRequest) String 

func (x *DeleteReadingRequest) String() string

type DeleteSensorRequest 

type DeleteSensorRequest struct {
	ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSensorRequest) Descriptor deprecated 

func (*DeleteSensorRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSensorRequest.ProtoReflect.Descriptor instead.

func (*DeleteSensorRequest) GetID 

func (x *DeleteSensorRequest) GetID() int32

func (*DeleteSensorRequest) ProtoMessage 

func (*DeleteSensorRequest) ProtoMessage()

func (*DeleteSensorRequest) ProtoReflect 

func (x *DeleteSensorRequest) ProtoReflect() protoreflect.Message

func (*DeleteSensorRequest) Reset 

func (x *DeleteSensorRequest) Reset()

func (*DeleteSensorRequest) String 

func (x *DeleteSensorRequest) String() string

type GetReadingByIDRequest 

type GetReadingByIDRequest struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReadingByIDRequest) Descriptor deprecated 

func (*GetReadingByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetReadingByIDRequest.ProtoReflect.Descriptor instead.

func (*GetReadingByIDRequest) GetID 

func (x *GetReadingByIDRequest) GetID() int64

func (*GetReadingByIDRequest) ProtoMessage 

func (*GetReadingByIDRequest) ProtoMessage()

func (*GetReadingByIDRequest) ProtoReflect 

func (x *GetReadingByIDRequest) ProtoReflect() protoreflect.Message

func (*GetReadingByIDRequest) Reset 

func (x *GetReadingByIDRequest) Reset()

func (*GetReadingByIDRequest) String 

func (x *GetReadingByIDRequest) String() string

type GetSensorByCodeRequest 

type GetSensorByCodeRequest struct {
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSensorByCodeRequest) Descriptor deprecated 

func (*GetSensorByCodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSensorByCodeRequest.ProtoReflect.Descriptor instead.

func (*GetSensorByCodeRequest) GetCode 

func (x *GetSensorByCodeRequest) GetCode() string

func (*GetSensorByCodeRequest) ProtoMessage 

func (*GetSensorByCodeRequest) ProtoMessage()

func (*GetSensorByCodeRequest) ProtoReflect 

func (x *GetSensorByCodeRequest) ProtoReflect() protoreflect.Message

func (*GetSensorByCodeRequest) Reset 

func (x *GetSensorByCodeRequest) Reset()

func (*GetSensorByCodeRequest) String 

func (x *GetSensorByCodeRequest) String() string

type GetSensorByIDRequest 

type GetSensorByIDRequest struct {
	ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSensorByIDRequest) Descriptor deprecated 

func (*GetSensorByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSensorByIDRequest.ProtoReflect.Descriptor instead.

func (*GetSensorByIDRequest) GetID 

func (x *GetSensorByIDRequest) GetID() int32

func (*GetSensorByIDRequest) ProtoMessage 

func (*GetSensorByIDRequest) ProtoMessage()

func (*GetSensorByIDRequest) ProtoReflect 

func (x *GetSensorByIDRequest) ProtoReflect() protoreflect.Message

func (*GetSensorByIDRequest) Reset 

func (x *GetSensorByIDRequest) Reset()

func (*GetSensorByIDRequest) String 

func (x *GetSensorByIDRequest) String() string

type GetSensorReadingStatsRequest 

type GetSensorReadingStatsRequest struct {
	SensorId int32                  `protobuf:"varint,1,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	FromTs   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from_ts,json=fromTs,proto3" json:"from_ts,omitempty"`
	ToTs     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to_ts,json=toTs,proto3" json:"to_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSensorReadingStatsRequest) Descriptor deprecated 

func (*GetSensorReadingStatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSensorReadingStatsRequest.ProtoReflect.Descriptor instead.

func (*GetSensorReadingStatsRequest) GetFromTs 

func (x *GetSensorReadingStatsRequest) GetFromTs() *timestamppb.Timestamp

func (*GetSensorReadingStatsRequest) GetSensorId 

func (x *GetSensorReadingStatsRequest) GetSensorId() int32

func (*GetSensorReadingStatsRequest) GetToTs 

func (x *GetSensorReadingStatsRequest) GetToTs() *timestamppb.Timestamp

func (*GetSensorReadingStatsRequest) ProtoMessage 

func (*GetSensorReadingStatsRequest) ProtoMessage()

func (*GetSensorReadingStatsRequest) ProtoReflect 

func (x *GetSensorReadingStatsRequest) ProtoReflect() protoreflect.Message

func (*GetSensorReadingStatsRequest) Reset 

func (x *GetSensorReadingStatsRequest) Reset()

func (*GetSensorReadingStatsRequest) String 

func (x *GetSensorReadingStatsRequest) String() string

type ListReadingBySensorIdRequest 

type ListReadingBySensorIdRequest struct {
	Limit    int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset   int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SensorId int32 `protobuf:"varint,3,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReadingBySensorIdRequest) Descriptor deprecated 

func (*ListReadingBySensorIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListReadingBySensorIdRequest.ProtoReflect.Descriptor instead.

func (*ListReadingBySensorIdRequest) GetLimit 

func (x *ListReadingBySensorIdRequest) GetLimit() int32

func (*ListReadingBySensorIdRequest) GetOffset 

func (x *ListReadingBySensorIdRequest) GetOffset() int32

func (*ListReadingBySensorIdRequest) GetSensorId 

func (x *ListReadingBySensorIdRequest) GetSensorId() int32

func (*ListReadingBySensorIdRequest) ProtoMessage 

func (*ListReadingBySensorIdRequest) ProtoMessage()

func (*ListReadingBySensorIdRequest) ProtoReflect 

func (x *ListReadingBySensorIdRequest) ProtoReflect() protoreflect.Message

func (*ListReadingBySensorIdRequest) Reset 

func (x *ListReadingBySensorIdRequest) Reset()

func (*ListReadingBySensorIdRequest) String 

func (x *ListReadingBySensorIdRequest) String() string

type ListReadingBySensorIdResponse 

type ListReadingBySensorIdResponse struct {
	Readings []*Reading `protobuf:"bytes,1,rep,name=readings,proto3" json:"readings,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReadingBySensorIdResponse) Descriptor deprecated 

func (*ListReadingBySensorIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListReadingBySensorIdResponse.ProtoReflect.Descriptor instead.

func (*ListReadingBySensorIdResponse) GetReadings 

func (x *ListReadingBySensorIdResponse) GetReadings() []*Reading

func (*ListReadingBySensorIdResponse) ProtoMessage 

func (*ListReadingBySensorIdResponse) ProtoMessage()

func (*ListReadingBySensorIdResponse) ProtoReflect 

func (x *ListReadingBySensorIdResponse) ProtoReflect() protoreflect.Message

func (*ListReadingBySensorIdResponse) Reset 

func (x *ListReadingBySensorIdResponse) Reset()

func (*ListReadingBySensorIdResponse) String 

func (x *ListReadingBySensorIdResponse) String() string

type ListReadingFilterBySensorIdRecordedAtFlaggedRequest 

type ListReadingFilterBySensorIdRecordedAtFlaggedRequest struct {
	Limit         int32                  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset        int32                  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SensorId      int32                  `protobuf:"varint,3,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	MinRecordedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=min_recorded_at,json=minRecordedAt,proto3" json:"min_recorded_at,omitempty"`
	MaxRecordedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=max_recorded_at,json=maxRecordedAt,proto3" json:"max_recorded_at,omitempty"`
	Flagged       bool                   `protobuf:"varint,6,opt,name=flagged,proto3" json:"flagged,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) Descriptor deprecated 

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListReadingFilterBySensorIdRecordedAtFlaggedRequest.ProtoReflect.Descriptor instead.

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetFlagged 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetFlagged() bool

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetLimit 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetLimit() int32

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMaxRecordedAt 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMaxRecordedAt() *timestamppb.Timestamp

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMinRecordedAt 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMinRecordedAt() *timestamppb.Timestamp

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetOffset 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetOffset() int32

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetSensorId 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) GetSensorId() int32

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoMessage 

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoMessage()

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoReflect 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoReflect() protoreflect.Message

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) Reset 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) Reset()

func (*ListReadingFilterBySensorIdRecordedAtFlaggedRequest) String 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedRequest) String() string

type ListReadingFilterBySensorIdRecordedAtFlaggedResponse 

type ListReadingFilterBySensorIdRecordedAtFlaggedResponse struct {
	Readings []*Reading `protobuf:"bytes,1,rep,name=readings,proto3" json:"readings,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) Descriptor deprecated 

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListReadingFilterBySensorIdRecordedAtFlaggedResponse.ProtoReflect.Descriptor instead.

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) GetReadings 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedResponse) GetReadings() []*Reading

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoMessage 

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoMessage()

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoReflect 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoReflect() protoreflect.Message

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) Reset 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedResponse) Reset()

func (*ListReadingFilterBySensorIdRecordedAtFlaggedResponse) String 

func (x *ListReadingFilterBySensorIdRecordedAtFlaggedResponse) String() string

type ListSensorFilterByLabelKindActiveRequest 

type ListSensorFilterByLabelKindActiveRequest struct {
	Limit  int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Label  string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	Kind   string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	Active *bool  `protobuf:"varint,5,opt,name=active,proto3,oneof" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorFilterByLabelKindActiveRequest) Descriptor deprecated 

func (*ListSensorFilterByLabelKindActiveRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSensorFilterByLabelKindActiveRequest.ProtoReflect.Descriptor instead.

func (*ListSensorFilterByLabelKindActiveRequest) GetActive 

func (x *ListSensorFilterByLabelKindActiveRequest) GetActive() bool

func (*ListSensorFilterByLabelKindActiveRequest) GetKind 

func (x *ListSensorFilterByLabelKindActiveRequest) GetKind() string

func (*ListSensorFilterByLabelKindActiveRequest) GetLabel 

func (x *ListSensorFilterByLabelKindActiveRequest) GetLabel() string

func (*ListSensorFilterByLabelKindActiveRequest) GetLimit 

func (x *ListSensorFilterByLabelKindActiveRequest) GetLimit() int32

func (*ListSensorFilterByLabelKindActiveRequest) GetOffset 

func (x *ListSensorFilterByLabelKindActiveRequest) GetOffset() int32

func (*ListSensorFilterByLabelKindActiveRequest) ProtoMessage 

func (*ListSensorFilterByLabelKindActiveRequest) ProtoMessage()

func (*ListSensorFilterByLabelKindActiveRequest) ProtoReflect 

func (x *ListSensorFilterByLabelKindActiveRequest) ProtoReflect() protoreflect.Message

func (*ListSensorFilterByLabelKindActiveRequest) Reset 

func (x *ListSensorFilterByLabelKindActiveRequest) Reset()

func (*ListSensorFilterByLabelKindActiveRequest) String 

func (x *ListSensorFilterByLabelKindActiveRequest) String() string

type ListSensorFilterByLabelKindActiveResponse 

type ListSensorFilterByLabelKindActiveResponse struct {
	Sensors []*Sensor `protobuf:"bytes,1,rep,name=sensors,proto3" json:"sensors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorFilterByLabelKindActiveResponse) Descriptor deprecated 

func (*ListSensorFilterByLabelKindActiveResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSensorFilterByLabelKindActiveResponse.ProtoReflect.Descriptor instead.

func (*ListSensorFilterByLabelKindActiveResponse) GetSensors 

func (x *ListSensorFilterByLabelKindActiveResponse) GetSensors() []*Sensor

func (*ListSensorFilterByLabelKindActiveResponse) ProtoMessage 

func (*ListSensorFilterByLabelKindActiveResponse) ProtoMessage()

func (*ListSensorFilterByLabelKindActiveResponse) ProtoReflect 

func (x *ListSensorFilterByLabelKindActiveResponse) ProtoReflect() protoreflect.Message

func (*ListSensorFilterByLabelKindActiveResponse) Reset 

func (x *ListSensorFilterByLabelKindActiveResponse) Reset()

func (*ListSensorFilterByLabelKindActiveResponse) String 

func (x *ListSensorFilterByLabelKindActiveResponse) String() string

type ListSensorsWithLatestReadingRequest 

type ListSensorsWithLatestReadingRequest struct {
	Limit  int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorsWithLatestReadingRequest) Descriptor deprecated 

func (*ListSensorsWithLatestReadingRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSensorsWithLatestReadingRequest.ProtoReflect.Descriptor instead.

func (*ListSensorsWithLatestReadingRequest) GetLimit 

func (x *ListSensorsWithLatestReadingRequest) GetLimit() int32

func (*ListSensorsWithLatestReadingRequest) GetOffset 

func (x *ListSensorsWithLatestReadingRequest) GetOffset() int32

func (*ListSensorsWithLatestReadingRequest) ProtoMessage 

func (*ListSensorsWithLatestReadingRequest) ProtoMessage()

func (*ListSensorsWithLatestReadingRequest) ProtoReflect 

func (x *ListSensorsWithLatestReadingRequest) ProtoReflect() protoreflect.Message

func (*ListSensorsWithLatestReadingRequest) Reset 

func (x *ListSensorsWithLatestReadingRequest) Reset()

func (*ListSensorsWithLatestReadingRequest) String 

func (x *ListSensorsWithLatestReadingRequest) String() string

type ListSensorsWithLatestReadingResponse 

type ListSensorsWithLatestReadingResponse struct {
	Items []*SensorWithLatestReading `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorsWithLatestReadingResponse) Descriptor deprecated 

func (*ListSensorsWithLatestReadingResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSensorsWithLatestReadingResponse.ProtoReflect.Descriptor instead.

func (*ListSensorsWithLatestReadingResponse) GetItems 

func (x *ListSensorsWithLatestReadingResponse) GetItems() []*SensorWithLatestReading

func (*ListSensorsWithLatestReadingResponse) ProtoMessage 

func (*ListSensorsWithLatestReadingResponse) ProtoMessage()

func (*ListSensorsWithLatestReadingResponse) ProtoReflect 

func (x *ListSensorsWithLatestReadingResponse) ProtoReflect() protoreflect.Message

func (*ListSensorsWithLatestReadingResponse) Reset 

func (x *ListSensorsWithLatestReadingResponse) Reset()

func (*ListSensorsWithLatestReadingResponse) String 

func (x *ListSensorsWithLatestReadingResponse) String() string

type PruneReadingsRequest 

type PruneReadingsRequest struct {
	Cutoff *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneReadingsRequest) Descriptor deprecated 

func (*PruneReadingsRequest) Descriptor() ([]byte, []int)

Deprecated: Use PruneReadingsRequest.ProtoReflect.Descriptor instead.

func (*PruneReadingsRequest) GetCutoff 

func (x *PruneReadingsRequest) GetCutoff() *timestamppb.Timestamp

func (*PruneReadingsRequest) ProtoMessage 

func (*PruneReadingsRequest) ProtoMessage()

func (*PruneReadingsRequest) ProtoReflect 

func (x *PruneReadingsRequest) ProtoReflect() protoreflect.Message

func (*PruneReadingsRequest) Reset 

func (x *PruneReadingsRequest) Reset()

func (*PruneReadingsRequest) String 

func (x *PruneReadingsRequest) String() string

type PruneReadingsResponse 

type PruneReadingsResponse struct {
	Deleted int64 `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneReadingsResponse) Descriptor deprecated 

func (*PruneReadingsResponse) Descriptor() ([]byte, []int)

Deprecated: Use PruneReadingsResponse.ProtoReflect.Descriptor instead.

func (*PruneReadingsResponse) GetDeleted 

func (x *PruneReadingsResponse) GetDeleted() int64

func (*PruneReadingsResponse) ProtoMessage 

func (*PruneReadingsResponse) ProtoMessage()

func (*PruneReadingsResponse) ProtoReflect 

func (x *PruneReadingsResponse) ProtoReflect() protoreflect.Message

func (*PruneReadingsResponse) Reset 

func (x *PruneReadingsResponse) Reset()

func (*PruneReadingsResponse) String 

func (x *PruneReadingsResponse) String() string

type Reading 

type Reading struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// References sensor.ID
	SensorId int32   `protobuf:"varint,2,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	Value    float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// Signal quality 0-100
	Quality int32 `protobuf:"varint,4,opt,name=quality,proto3" json:"quality,omitempty"`
	// Marked as anomalous by ingestion
	Flagged bool `protobuf:"varint,5,opt,name=flagged,proto3" json:"flagged,omitempty"`
	// Device measurement time (client-supplied)
	RecordedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=recorded_at,json=recordedAt,proto3" json:"recorded_at,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

Reading is a single measurement captured by a Sensor.

func (*Reading) Descriptor deprecated 

func (*Reading) Descriptor() ([]byte, []int)

Deprecated: Use Reading.ProtoReflect.Descriptor instead.

func (*Reading) GetCreatedAt 

func (x *Reading) GetCreatedAt() *timestamppb.Timestamp

func (*Reading) GetFlagged 

func (x *Reading) GetFlagged() bool

func (*Reading) GetID 

func (x *Reading) GetID() int64

func (*Reading) GetQuality 

func (x *Reading) GetQuality() int32

func (*Reading) GetRecordedAt 

func (x *Reading) GetRecordedAt() *timestamppb.Timestamp

func (*Reading) GetSensorId 

func (x *Reading) GetSensorId() int32

func (*Reading) GetValue 

func (x *Reading) GetValue() float64

func (*Reading) ProtoMessage 

func (*Reading) ProtoMessage()

func (*Reading) ProtoReflect 

func (x *Reading) ProtoReflect() protoreflect.Message

func (*Reading) Reset 

func (x *Reading) Reset()

func (*Reading) String 

func (x *Reading) String() string

type ReadingServiceClient 

type ReadingServiceClient interface {
	Create(context.Context, *connect.Request[CreateReadingRequest]) (*connect.Response[Reading], error)
	GetByID(context.Context, *connect.Request[GetReadingByIDRequest]) (*connect.Response[Reading], error)
	Delete(context.Context, *connect.Request[DeleteReadingRequest]) (*connect.Response[emptypb.Empty], error)
	ListBySensorId(context.Context, *connect.Request[ListReadingBySensorIdRequest]) (*connect.Response[ListReadingBySensorIdResponse], error)
	FilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListReadingFilterBySensorIdRecordedAtFlaggedResponse], error)
}

ReadingServiceClient is a client for the entlite.ReadingService service.

func NewReadingServiceClient 

func NewReadingServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ReadingServiceClient

NewReadingServiceClient constructs a client for the entlite.ReadingService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ReadingServiceHandler 

type ReadingServiceHandler interface {
	Create(context.Context, *connect.Request[CreateReadingRequest]) (*connect.Response[Reading], error)
	GetByID(context.Context, *connect.Request[GetReadingByIDRequest]) (*connect.Response[Reading], error)
	Delete(context.Context, *connect.Request[DeleteReadingRequest]) (*connect.Response[emptypb.Empty], error)
	ListBySensorId(context.Context, *connect.Request[ListReadingBySensorIdRequest]) (*connect.Response[ListReadingBySensorIdResponse], error)
	FilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListReadingFilterBySensorIdRecordedAtFlaggedResponse], error)
}

ReadingServiceHandler is an implementation of the entlite.ReadingService service.

type Sensor 

type Sensor struct {
	ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// External hardware identifier, e.g. TEMP-A1
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// Human friendly name
	Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	// temperature | humidity | pressure | motion
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// Measurement unit, e.g. celsius
	Unit     string  `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
	Location *string `protobuf:"bytes,6,opt,name=location,proto3,oneof" json:"location,omitempty"`
	Active   bool    `protobuf:"varint,7,opt,name=active,proto3" json:"active,omitempty"`
	Firmware string  `protobuf:"bytes,8,opt,name=firmware,proto3" json:"firmware,omitempty"`
	// Sampling interval in milliseconds
	SampleRateMs int32 `protobuf:"varint,9,opt,name=sample_rate_ms,json=sampleRateMs,proto3" json:"sample_rate_ms,omitempty"`
	// When the device was physically installed (client-supplied)
	InstalledAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=installed_at,json=installedAt,proto3" json:"installed_at,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Most recent reading value, joined in at the API layer - not stored
	LatestValue *float64 `protobuf:"fixed64,13,opt,name=latest_value,json=latestValue,proto3,oneof" json:"latest_value,omitempty"`
	// contains filtered or unexported fields
}

Sensor is a physical device deployed in the field that emits Readings.

func (*Sensor) Descriptor deprecated 

func (*Sensor) Descriptor() ([]byte, []int)

Deprecated: Use Sensor.ProtoReflect.Descriptor instead.

func (*Sensor) GetActive 

func (x *Sensor) GetActive() bool

func (*Sensor) GetCode 

func (x *Sensor) GetCode() string

func (*Sensor) GetCreatedAt 

func (x *Sensor) GetCreatedAt() *timestamppb.Timestamp

func (*Sensor) GetFirmware 

func (x *Sensor) GetFirmware() string

func (*Sensor) GetID 

func (x *Sensor) GetID() int32

func (*Sensor) GetInstalledAt 

func (x *Sensor) GetInstalledAt() *timestamppb.Timestamp

func (*Sensor) GetKind 

func (x *Sensor) GetKind() string

func (*Sensor) GetLabel 

func (x *Sensor) GetLabel() string

func (*Sensor) GetLatestValue 

func (x *Sensor) GetLatestValue() float64

func (*Sensor) GetLocation 

func (x *Sensor) GetLocation() string

func (*Sensor) GetSampleRateMs 

func (x *Sensor) GetSampleRateMs() int32

func (*Sensor) GetUnit 

func (x *Sensor) GetUnit() string

func (*Sensor) GetUpdatedAt 

func (x *Sensor) GetUpdatedAt() *timestamppb.Timestamp

func (*Sensor) ProtoMessage 

func (*Sensor) ProtoMessage()

func (*Sensor) ProtoReflect 

func (x *Sensor) ProtoReflect() protoreflect.Message

func (*Sensor) Reset 

func (x *Sensor) Reset()

func (*Sensor) String 

func (x *Sensor) String() string

type SensorAnalyticsServiceClient 

type SensorAnalyticsServiceClient interface {
	GetReadingStats(context.Context, *connect.Request[GetSensorReadingStatsRequest]) (*connect.Response[SensorReadingStats], error)
	ListWithLatestReading(context.Context, *connect.Request[ListSensorsWithLatestReadingRequest]) (*connect.Response[ListSensorsWithLatestReadingResponse], error)
	PruneReadings(context.Context, *connect.Request[PruneReadingsRequest]) (*connect.Response[PruneReadingsResponse], error)
}

SensorAnalyticsServiceClient is a client for the entlite.SensorAnalyticsService service.

func NewSensorAnalyticsServiceClient 

func NewSensorAnalyticsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SensorAnalyticsServiceClient

NewSensorAnalyticsServiceClient constructs a client for the entlite.SensorAnalyticsService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type SensorAnalyticsServiceHandler 

type SensorAnalyticsServiceHandler interface {
	GetReadingStats(context.Context, *connect.Request[GetSensorReadingStatsRequest]) (*connect.Response[SensorReadingStats], error)
	ListWithLatestReading(context.Context, *connect.Request[ListSensorsWithLatestReadingRequest]) (*connect.Response[ListSensorsWithLatestReadingResponse], error)
	PruneReadings(context.Context, *connect.Request[PruneReadingsRequest]) (*connect.Response[PruneReadingsResponse], error)
}

SensorAnalyticsServiceHandler is an implementation of the entlite.SensorAnalyticsService service.

type SensorReadingStats 

type SensorReadingStats struct {
	ReadingCount int64   `protobuf:"varint,1,opt,name=reading_count,json=readingCount,proto3" json:"reading_count,omitempty"`
	AvgValue     float64 `protobuf:"fixed64,2,opt,name=avg_value,json=avgValue,proto3" json:"avg_value,omitempty"`
	MinValue     float64 `protobuf:"fixed64,3,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
	MaxValue     float64 `protobuf:"fixed64,4,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
	// contains filtered or unexported fields
}

func (*SensorReadingStats) Descriptor deprecated 

func (*SensorReadingStats) Descriptor() ([]byte, []int)

Deprecated: Use SensorReadingStats.ProtoReflect.Descriptor instead.

func (*SensorReadingStats) GetAvgValue 

func (x *SensorReadingStats) GetAvgValue() float64

func (*SensorReadingStats) GetMaxValue 

func (x *SensorReadingStats) GetMaxValue() float64

func (*SensorReadingStats) GetMinValue 

func (x *SensorReadingStats) GetMinValue() float64

func (*SensorReadingStats) GetReadingCount 

func (x *SensorReadingStats) GetReadingCount() int64

func (*SensorReadingStats) ProtoMessage 

func (*SensorReadingStats) ProtoMessage()

func (*SensorReadingStats) ProtoReflect 

func (x *SensorReadingStats) ProtoReflect() protoreflect.Message

func (*SensorReadingStats) Reset 

func (x *SensorReadingStats) Reset()

func (*SensorReadingStats) String 

func (x *SensorReadingStats) String() string

type SensorServiceClient 

type SensorServiceClient interface {
	Create(context.Context, *connect.Request[CreateSensorRequest]) (*connect.Response[Sensor], error)
	GetByID(context.Context, *connect.Request[GetSensorByIDRequest]) (*connect.Response[Sensor], error)
	Update(context.Context, *connect.Request[UpdateSensorRequest]) (*connect.Response[Sensor], error)
	Delete(context.Context, *connect.Request[DeleteSensorRequest]) (*connect.Response[emptypb.Empty], error)
	// Look up a sensor by its hardware code
	GetByCode(context.Context, *connect.Request[GetSensorByCodeRequest]) (*connect.Response[Sensor], error)
	FilterByLabelKindActive(context.Context, *connect.Request[ListSensorFilterByLabelKindActiveRequest]) (*connect.Response[ListSensorFilterByLabelKindActiveResponse], error)
}

SensorServiceClient is a client for the entlite.SensorService service.

func NewSensorServiceClient 

func NewSensorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SensorServiceClient

NewSensorServiceClient constructs a client for the entlite.SensorService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type SensorServiceHandler 

type SensorServiceHandler interface {
	Create(context.Context, *connect.Request[CreateSensorRequest]) (*connect.Response[Sensor], error)
	GetByID(context.Context, *connect.Request[GetSensorByIDRequest]) (*connect.Response[Sensor], error)
	Update(context.Context, *connect.Request[UpdateSensorRequest]) (*connect.Response[Sensor], error)
	Delete(context.Context, *connect.Request[DeleteSensorRequest]) (*connect.Response[emptypb.Empty], error)
	// Look up a sensor by its hardware code
	GetByCode(context.Context, *connect.Request[GetSensorByCodeRequest]) (*connect.Response[Sensor], error)
	FilterByLabelKindActive(context.Context, *connect.Request[ListSensorFilterByLabelKindActiveRequest]) (*connect.Response[ListSensorFilterByLabelKindActiveResponse], error)
}

SensorServiceHandler is an implementation of the entlite.SensorService service.

type SensorWithLatestReading 

type SensorWithLatestReading struct {

	// the generated message from schema.proto
	Sensor           *Sensor                `protobuf:"bytes,1,opt,name=sensor,proto3" json:"sensor,omitempty"`
	LatestValue      *float64               `protobuf:"fixed64,2,opt,name=latest_value,json=latestValue,proto3,oneof" json:"latest_value,omitempty"`
	LatestRecordedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=latest_recorded_at,json=latestRecordedAt,proto3,oneof" json:"latest_recorded_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SensorWithLatestReading) Descriptor deprecated 

func (*SensorWithLatestReading) Descriptor() ([]byte, []int)

Deprecated: Use SensorWithLatestReading.ProtoReflect.Descriptor instead.

func (*SensorWithLatestReading) GetLatestRecordedAt 

func (x *SensorWithLatestReading) GetLatestRecordedAt() *timestamppb.Timestamp

func (*SensorWithLatestReading) GetLatestValue 

func (x *SensorWithLatestReading) GetLatestValue() float64

func (*SensorWithLatestReading) GetSensor 

func (x *SensorWithLatestReading) GetSensor() *Sensor

func (*SensorWithLatestReading) ProtoMessage 

func (*SensorWithLatestReading) ProtoMessage()

func (*SensorWithLatestReading) ProtoReflect 

func (x *SensorWithLatestReading) ProtoReflect() protoreflect.Message

func (*SensorWithLatestReading) Reset 

func (x *SensorWithLatestReading) Reset()

func (*SensorWithLatestReading) String 

func (x *SensorWithLatestReading) String() string

type UnimplementedReadingServiceHandler 

type UnimplementedReadingServiceHandler struct{}

UnimplementedReadingServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedReadingServiceHandler) Create 

func (UnimplementedReadingServiceHandler) Create(context.Context, *connect.Request[CreateReadingRequest]) (*connect.Response[Reading], error)

func (UnimplementedReadingServiceHandler) Delete 

func (UnimplementedReadingServiceHandler) Delete(context.Context, *connect.Request[DeleteReadingRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedReadingServiceHandler) FilterBySensorIdRecordedAtFlagged 

func (UnimplementedReadingServiceHandler) FilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListReadingFilterBySensorIdRecordedAtFlaggedResponse], error)

func (UnimplementedReadingServiceHandler) GetByID 

func (UnimplementedReadingServiceHandler) GetByID(context.Context, *connect.Request[GetReadingByIDRequest]) (*connect.Response[Reading], error)

func (UnimplementedReadingServiceHandler) ListBySensorId 

func (UnimplementedReadingServiceHandler) ListBySensorId(context.Context, *connect.Request[ListReadingBySensorIdRequest]) (*connect.Response[ListReadingBySensorIdResponse], error)

type UnimplementedSensorAnalyticsServiceHandler 

type UnimplementedSensorAnalyticsServiceHandler struct{}

UnimplementedSensorAnalyticsServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSensorAnalyticsServiceHandler) GetReadingStats 

func (UnimplementedSensorAnalyticsServiceHandler) GetReadingStats(context.Context, *connect.Request[GetSensorReadingStatsRequest]) (*connect.Response[SensorReadingStats], error)

func (UnimplementedSensorAnalyticsServiceHandler) ListWithLatestReading 

func (UnimplementedSensorAnalyticsServiceHandler) ListWithLatestReading(context.Context, *connect.Request[ListSensorsWithLatestReadingRequest]) (*connect.Response[ListSensorsWithLatestReadingResponse], error)

func (UnimplementedSensorAnalyticsServiceHandler) PruneReadings 

func (UnimplementedSensorAnalyticsServiceHandler) PruneReadings(context.Context, *connect.Request[PruneReadingsRequest]) (*connect.Response[PruneReadingsResponse], error)

type UnimplementedSensorServiceHandler 

type UnimplementedSensorServiceHandler struct{}

UnimplementedSensorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSensorServiceHandler) Create 

func (UnimplementedSensorServiceHandler) Create(context.Context, *connect.Request[CreateSensorRequest]) (*connect.Response[Sensor], error)

func (UnimplementedSensorServiceHandler) Delete 

func (UnimplementedSensorServiceHandler) Delete(context.Context, *connect.Request[DeleteSensorRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedSensorServiceHandler) FilterByLabelKindActive 

func (UnimplementedSensorServiceHandler) FilterByLabelKindActive(context.Context, *connect.Request[ListSensorFilterByLabelKindActiveRequest]) (*connect.Response[ListSensorFilterByLabelKindActiveResponse], error)

func (UnimplementedSensorServiceHandler) GetByCode 

func (UnimplementedSensorServiceHandler) GetByCode(context.Context, *connect.Request[GetSensorByCodeRequest]) (*connect.Response[Sensor], error)

func (UnimplementedSensorServiceHandler) GetByID 

func (UnimplementedSensorServiceHandler) GetByID(context.Context, *connect.Request[GetSensorByIDRequest]) (*connect.Response[Sensor], error)

func (UnimplementedSensorServiceHandler) Update 

func (UnimplementedSensorServiceHandler) Update(context.Context, *connect.Request[UpdateSensorRequest]) (*connect.Response[Sensor], error)

type UpdateSensorRequest 

type UpdateSensorRequest struct {
	ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// External hardware identifier, e.g. TEMP-A1
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// Human friendly name
	Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	// temperature | humidity | pressure | motion
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// Measurement unit, e.g. celsius
	Unit     string  `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
	Location *string `protobuf:"bytes,6,opt,name=location,proto3,oneof" json:"location,omitempty"`
	Active   *bool   `protobuf:"varint,7,opt,name=active,proto3,oneof" json:"active,omitempty"`
	Firmware *string `protobuf:"bytes,8,opt,name=firmware,proto3,oneof" json:"firmware,omitempty"`
	// Sampling interval in milliseconds
	SampleRateMs *int32 `protobuf:"varint,9,opt,name=sample_rate_ms,json=sampleRateMs,proto3,oneof" json:"sample_rate_ms,omitempty"`
	// Most recent reading value, joined in at the API layer - not stored
	LatestValue *float64 `protobuf:"fixed64,13,opt,name=latest_value,json=latestValue,proto3,oneof" json:"latest_value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSensorRequest) Descriptor deprecated 

func (*UpdateSensorRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSensorRequest.ProtoReflect.Descriptor instead.

func (*UpdateSensorRequest) GetActive 

func (x *UpdateSensorRequest) GetActive() bool

func (*UpdateSensorRequest) GetCode 

func (x *UpdateSensorRequest) GetCode() string

func (*UpdateSensorRequest) GetFirmware 

func (x *UpdateSensorRequest) GetFirmware() string

func (*UpdateSensorRequest) GetID 

func (x *UpdateSensorRequest) GetID() int32

func (*UpdateSensorRequest) GetKind 

func (x *UpdateSensorRequest) GetKind() string

func (*UpdateSensorRequest) GetLabel 

func (x *UpdateSensorRequest) GetLabel() string

func (*UpdateSensorRequest) GetLatestValue 

func (x *UpdateSensorRequest) GetLatestValue() float64

func (*UpdateSensorRequest) GetLocation 

func (x *UpdateSensorRequest) GetLocation() string

func (*UpdateSensorRequest) GetSampleRateMs 

func (x *UpdateSensorRequest) GetSampleRateMs() int32

func (*UpdateSensorRequest) GetUnit 

func (x *UpdateSensorRequest) GetUnit() string

func (*UpdateSensorRequest) ProtoMessage 

func (*UpdateSensorRequest) ProtoMessage()

func (*UpdateSensorRequest) ProtoReflect 

func (x *UpdateSensorRequest) ProtoReflect() protoreflect.Message

func (*UpdateSensorRequest) Reset 

func (x *UpdateSensorRequest) Reset()

func (*UpdateSensorRequest) String 

func (x *UpdateSensorRequest) String() string

func (*UpdateSensorRequest) Validate 

func (r *UpdateSensorRequest) Validate() error

type ValidateInterceptor 

type ValidateInterceptor struct{}

ValidateInterceptor calls the generated Validate() method on any request message that implements it

func NewValidateInterceptor 

func NewValidateInterceptor() *ValidateInterceptor

func (*ValidateInterceptor) WrapStreamingClient 

func (i *ValidateInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient implements connect.Interceptor.

func (*ValidateInterceptor) WrapStreamingHandler 

func (i *ValidateInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler implements connect.Interceptor.

func (*ValidateInterceptor) WrapUnary 

func (i *ValidateInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

WrapUnary implements connect.Interceptor.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.