pb

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 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 = "/proto.SensorAnalyticsService/GetReadingStats"
	// SensorAnalyticsServiceListWithLatestReadingProcedure is the fully-qualified name of the
	// SensorAnalyticsService's ListWithLatestReading RPC.
	SensorAnalyticsServiceListWithLatestReadingProcedure = "/proto.SensorAnalyticsService/ListWithLatestReading"
	// SensorAnalyticsServicePruneReadingsProcedure is the fully-qualified name of the
	// SensorAnalyticsService's PruneReadings RPC.
	SensorAnalyticsServicePruneReadingsProcedure = "/proto.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 (
	// SensorServiceName is the fully-qualified name of the SensorService service.
	SensorServiceName = "proto.SensorService"
	// SensorReadingServiceName is the fully-qualified name of the SensorReadingService service.
	SensorReadingServiceName = "proto.SensorReadingService"
)
View Source 
const (
	// SensorServiceCreateSensorProcedure is the fully-qualified name of the SensorService's
	// CreateSensor RPC.
	SensorServiceCreateSensorProcedure = "/proto.SensorService/CreateSensor"
	// SensorServiceGetSensorByIdProcedure is the fully-qualified name of the SensorService's
	// GetSensorById RPC.
	SensorServiceGetSensorByIdProcedure = "/proto.SensorService/GetSensorById"
	// SensorServiceUpdateSensorProcedure is the fully-qualified name of the SensorService's
	// UpdateSensor RPC.
	SensorServiceUpdateSensorProcedure = "/proto.SensorService/UpdateSensor"
	// SensorServiceDeleteSensorProcedure is the fully-qualified name of the SensorService's
	// DeleteSensor RPC.
	SensorServiceDeleteSensorProcedure = "/proto.SensorService/DeleteSensor"
	// SensorServiceGetSensorByCodeProcedure is the fully-qualified name of the SensorService's
	// GetSensorByCode RPC.
	SensorServiceGetSensorByCodeProcedure = "/proto.SensorService/GetSensorByCode"
	// SensorServiceListSensorFilterByLabelKindActiveProcedure is the fully-qualified name of the
	// SensorService's ListSensorFilterByLabelKindActive RPC.
	SensorServiceListSensorFilterByLabelKindActiveProcedure = "/proto.SensorService/ListSensorFilterByLabelKindActive"
	// SensorReadingServiceCreateSensorReadingProcedure is the fully-qualified name of the
	// SensorReadingService's CreateSensorReading RPC.
	SensorReadingServiceCreateSensorReadingProcedure = "/proto.SensorReadingService/CreateSensorReading"
	// SensorReadingServiceGetSensorReadingByIdProcedure is the fully-qualified name of the
	// SensorReadingService's GetSensorReadingById RPC.
	SensorReadingServiceGetSensorReadingByIdProcedure = "/proto.SensorReadingService/GetSensorReadingById"
	// SensorReadingServiceDeleteSensorReadingProcedure is the fully-qualified name of the
	// SensorReadingService's DeleteSensorReading RPC.
	SensorReadingServiceDeleteSensorReadingProcedure = "/proto.SensorReadingService/DeleteSensorReading"
	// SensorReadingServiceListSensorReadingBySensorIdProcedure is the fully-qualified name of the
	// SensorReadingService's ListSensorReadingBySensorId RPC.
	SensorReadingServiceListSensorReadingBySensorIdProcedure = "/proto.SensorReadingService/ListSensorReadingBySensorId"
	// SensorReadingServiceListSensorReadingFilterBySensorIdRecordedAtFlaggedProcedure is the
	// fully-qualified name of the SensorReadingService's
	// ListSensorReadingFilterBySensorIdRecordedAtFlagged RPC.
	SensorReadingServiceListSensorReadingFilterBySensorIdRecordedAtFlaggedProcedure = "/proto.SensorReadingService/ListSensorReadingFilterBySensorIdRecordedAtFlagged"
)

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 = "proto.SensorAnalyticsService"
)

Variables

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

Functions

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

func NewSensorReadingServiceHandler(svc SensorReadingServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewSensorReadingServiceHandler 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 CreateSensorReadingRequest added in v0.0.6 

type CreateSensorReadingRequest 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 (*CreateSensorReadingRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use CreateSensorReadingRequest.ProtoReflect.Descriptor instead.

func (*CreateSensorReadingRequest) GetFlagged added in v0.0.6 

func (x *CreateSensorReadingRequest) GetFlagged() bool

func (*CreateSensorReadingRequest) GetQuality added in v0.0.6 

func (x *CreateSensorReadingRequest) GetQuality() int32

func (*CreateSensorReadingRequest) GetRecordedAt added in v0.0.6 

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

func (*CreateSensorReadingRequest) GetSensorId added in v0.0.6 

func (x *CreateSensorReadingRequest) GetSensorId() int32

func (*CreateSensorReadingRequest) GetValue added in v0.0.6 

func (x *CreateSensorReadingRequest) GetValue() float64

func (*CreateSensorReadingRequest) ProtoMessage added in v0.0.6 

func (*CreateSensorReadingRequest) ProtoMessage()

func (*CreateSensorReadingRequest) ProtoReflect added in v0.0.6 

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

func (*CreateSensorReadingRequest) Reset added in v0.0.6 

func (x *CreateSensorReadingRequest) Reset()

func (*CreateSensorReadingRequest) String added in v0.0.6 

func (x *CreateSensorReadingRequest) String() string

func (*CreateSensorReadingRequest) Validate added in v0.0.6 

func (r *CreateSensorReadingRequest) 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 DeleteSensorReadingRequest added in v0.0.6 

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

func (*DeleteSensorReadingRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use DeleteSensorReadingRequest.ProtoReflect.Descriptor instead.

func (*DeleteSensorReadingRequest) GetId added in v0.0.6 

func (x *DeleteSensorReadingRequest) GetId() int64

func (*DeleteSensorReadingRequest) ProtoMessage added in v0.0.6 

func (*DeleteSensorReadingRequest) ProtoMessage()

func (*DeleteSensorReadingRequest) ProtoReflect added in v0.0.6 

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

func (*DeleteSensorReadingRequest) Reset added in v0.0.6 

func (x *DeleteSensorReadingRequest) Reset()

func (*DeleteSensorReadingRequest) String added in v0.0.6 

func (x *DeleteSensorReadingRequest) 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 added in v0.0.6 

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

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

func (*GetSensorByIdRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetSensorByIdRequest.ProtoReflect.Descriptor instead.

func (*GetSensorByIdRequest) GetId added in v0.0.6 

func (x *GetSensorByIdRequest) GetId() int32

func (*GetSensorByIdRequest) ProtoMessage added in v0.0.6 

func (*GetSensorByIdRequest) ProtoMessage()

func (*GetSensorByIdRequest) ProtoReflect added in v0.0.6 

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

func (*GetSensorByIdRequest) Reset added in v0.0.6 

func (x *GetSensorByIdRequest) Reset()

func (*GetSensorByIdRequest) String added in v0.0.6 

func (x *GetSensorByIdRequest) String() string

type GetSensorReadingByIdRequest added in v0.0.6 

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

func (*GetSensorReadingByIdRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetSensorReadingByIdRequest.ProtoReflect.Descriptor instead.

func (*GetSensorReadingByIdRequest) GetId added in v0.0.6 

func (x *GetSensorReadingByIdRequest) GetId() int64

func (*GetSensorReadingByIdRequest) ProtoMessage added in v0.0.6 

func (*GetSensorReadingByIdRequest) ProtoMessage()

func (*GetSensorReadingByIdRequest) ProtoReflect added in v0.0.6 

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

func (*GetSensorReadingByIdRequest) Reset added in v0.0.6 

func (x *GetSensorReadingByIdRequest) Reset()

func (*GetSensorReadingByIdRequest) String added in v0.0.6 

func (x *GetSensorReadingByIdRequest) 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 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 {
	Rows      []*Sensor `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	TotalSize int64     `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorFilterByLabelKindActiveResponse) Descriptor deprecated 

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

Deprecated: Use ListSensorFilterByLabelKindActiveResponse.ProtoReflect.Descriptor instead.

func (*ListSensorFilterByLabelKindActiveResponse) GetRows added in v0.0.5 

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

func (*ListSensorFilterByLabelKindActiveResponse) GetTotalSize added in v0.0.5 

func (x *ListSensorFilterByLabelKindActiveResponse) GetTotalSize() int64

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

type ListSensorReadingBySensorIdRequest 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 (*ListSensorReadingBySensorIdRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ListSensorReadingBySensorIdRequest.ProtoReflect.Descriptor instead.

func (*ListSensorReadingBySensorIdRequest) GetLimit added in v0.0.6 

func (x *ListSensorReadingBySensorIdRequest) GetLimit() int32

func (*ListSensorReadingBySensorIdRequest) GetOffset added in v0.0.6 

func (x *ListSensorReadingBySensorIdRequest) GetOffset() int32

func (*ListSensorReadingBySensorIdRequest) GetSensorId added in v0.0.6 

func (x *ListSensorReadingBySensorIdRequest) GetSensorId() int32

func (*ListSensorReadingBySensorIdRequest) ProtoMessage added in v0.0.6 

func (*ListSensorReadingBySensorIdRequest) ProtoMessage()

func (*ListSensorReadingBySensorIdRequest) ProtoReflect added in v0.0.6 

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

func (*ListSensorReadingBySensorIdRequest) Reset added in v0.0.6 

func (x *ListSensorReadingBySensorIdRequest) Reset()

func (*ListSensorReadingBySensorIdRequest) String added in v0.0.6 

func (x *ListSensorReadingBySensorIdRequest) String() string

type ListSensorReadingBySensorIdResponse added in v0.0.6 

type ListSensorReadingBySensorIdResponse struct {
	Rows []*SensorReading `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorReadingBySensorIdResponse) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ListSensorReadingBySensorIdResponse.ProtoReflect.Descriptor instead.

func (*ListSensorReadingBySensorIdResponse) GetRows added in v0.0.6 

func (x *ListSensorReadingBySensorIdResponse) GetRows() []*SensorReading

func (*ListSensorReadingBySensorIdResponse) ProtoMessage added in v0.0.6 

func (*ListSensorReadingBySensorIdResponse) ProtoMessage()

func (*ListSensorReadingBySensorIdResponse) ProtoReflect added in v0.0.6 

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

func (*ListSensorReadingBySensorIdResponse) Reset added in v0.0.6 

func (x *ListSensorReadingBySensorIdResponse) Reset()

func (*ListSensorReadingBySensorIdResponse) String added in v0.0.6 

func (x *ListSensorReadingBySensorIdResponse) String() string

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest added in v0.0.6 

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest 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 (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest.ProtoReflect.Descriptor instead.

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetFlagged added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetFlagged() bool

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetLimit added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetLimit() int32

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMaxRecordedAt added in v0.0.6 

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

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetMinRecordedAt added in v0.0.6 

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

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetOffset added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetOffset() int32

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetSensorId added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) GetSensorId() int32

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoMessage added in v0.0.6 

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoMessage()

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) ProtoReflect added in v0.0.6 

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

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) Reset added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) Reset()

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) String added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest) String() string

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse added in v0.0.6 

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse struct {
	Rows      []*SensorReading `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	TotalSize int64            `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse.ProtoReflect.Descriptor instead.

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) GetRows added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) GetRows() []*SensorReading

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) GetTotalSize added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) GetTotalSize() int64

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoMessage added in v0.0.6 

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoMessage()

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) ProtoReflect added in v0.0.6 

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

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) Reset added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) Reset()

func (*ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) String added in v0.0.6 

func (x *ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse) 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 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 SensorReadings.

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

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 proto.SensorAnalyticsService service.

func NewSensorAnalyticsServiceClient 

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

NewSensorAnalyticsServiceClient constructs a client for the proto.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 proto.SensorAnalyticsService service.

type SensorReading added in v0.0.6 

type SensorReading 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
}

SensorReading is a single measurement captured by a Sensor.

func (*SensorReading) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use SensorReading.ProtoReflect.Descriptor instead.

func (*SensorReading) GetCreatedAt added in v0.0.6 

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

func (*SensorReading) GetFlagged added in v0.0.6 

func (x *SensorReading) GetFlagged() bool

func (*SensorReading) GetId added in v0.0.6 

func (x *SensorReading) GetId() int64

func (*SensorReading) GetQuality added in v0.0.6 

func (x *SensorReading) GetQuality() int32

func (*SensorReading) GetRecordedAt added in v0.0.6 

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

func (*SensorReading) GetSensorId added in v0.0.6 

func (x *SensorReading) GetSensorId() int32

func (*SensorReading) GetValue added in v0.0.6 

func (x *SensorReading) GetValue() float64

func (*SensorReading) ProtoMessage added in v0.0.6 

func (*SensorReading) ProtoMessage()

func (*SensorReading) ProtoReflect added in v0.0.6 

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

func (*SensorReading) Reset added in v0.0.6 

func (x *SensorReading) Reset()

func (*SensorReading) String added in v0.0.6 

func (x *SensorReading) String() string

type SensorReadingServiceClient added in v0.0.6 

type SensorReadingServiceClient interface {
	CreateSensorReading(context.Context, *connect.Request[CreateSensorReadingRequest]) (*connect.Response[SensorReading], error)
	GetSensorReadingById(context.Context, *connect.Request[GetSensorReadingByIdRequest]) (*connect.Response[SensorReading], error)
	DeleteSensorReading(context.Context, *connect.Request[DeleteSensorReadingRequest]) (*connect.Response[emptypb.Empty], error)
	ListSensorReadingBySensorId(context.Context, *connect.Request[ListSensorReadingBySensorIdRequest]) (*connect.Response[ListSensorReadingBySensorIdResponse], error)
	ListSensorReadingFilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse], error)
}

SensorReadingServiceClient is a client for the proto.SensorReadingService service.

func NewSensorReadingServiceClient added in v0.0.6 

func NewSensorReadingServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SensorReadingServiceClient

NewSensorReadingServiceClient constructs a client for the proto.SensorReadingService 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 SensorReadingServiceHandler added in v0.0.6 

type SensorReadingServiceHandler interface {
	CreateSensorReading(context.Context, *connect.Request[CreateSensorReadingRequest]) (*connect.Response[SensorReading], error)
	GetSensorReadingById(context.Context, *connect.Request[GetSensorReadingByIdRequest]) (*connect.Response[SensorReading], error)
	DeleteSensorReading(context.Context, *connect.Request[DeleteSensorReadingRequest]) (*connect.Response[emptypb.Empty], error)
	ListSensorReadingBySensorId(context.Context, *connect.Request[ListSensorReadingBySensorIdRequest]) (*connect.Response[ListSensorReadingBySensorIdResponse], error)
	ListSensorReadingFilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse], error)
}

SensorReadingServiceHandler is an implementation of the proto.SensorReadingService 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 {
	CreateSensor(context.Context, *connect.Request[CreateSensorRequest]) (*connect.Response[Sensor], error)
	GetSensorById(context.Context, *connect.Request[GetSensorByIdRequest]) (*connect.Response[Sensor], error)
	UpdateSensor(context.Context, *connect.Request[UpdateSensorRequest]) (*connect.Response[Sensor], error)
	DeleteSensor(context.Context, *connect.Request[DeleteSensorRequest]) (*connect.Response[emptypb.Empty], error)
	// Look up a sensor by its hardware code
	GetSensorByCode(context.Context, *connect.Request[GetSensorByCodeRequest]) (*connect.Response[Sensor], error)
	ListSensorFilterByLabelKindActive(context.Context, *connect.Request[ListSensorFilterByLabelKindActiveRequest]) (*connect.Response[ListSensorFilterByLabelKindActiveResponse], error)
}

SensorServiceClient is a client for the proto.SensorService service.

func NewSensorServiceClient 

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

NewSensorServiceClient constructs a client for the proto.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 {
	CreateSensor(context.Context, *connect.Request[CreateSensorRequest]) (*connect.Response[Sensor], error)
	GetSensorById(context.Context, *connect.Request[GetSensorByIdRequest]) (*connect.Response[Sensor], error)
	UpdateSensor(context.Context, *connect.Request[UpdateSensorRequest]) (*connect.Response[Sensor], error)
	DeleteSensor(context.Context, *connect.Request[DeleteSensorRequest]) (*connect.Response[emptypb.Empty], error)
	// Look up a sensor by its hardware code
	GetSensorByCode(context.Context, *connect.Request[GetSensorByCodeRequest]) (*connect.Response[Sensor], error)
	ListSensorFilterByLabelKindActive(context.Context, *connect.Request[ListSensorFilterByLabelKindActiveRequest]) (*connect.Response[ListSensorFilterByLabelKindActiveResponse], error)
}

SensorServiceHandler is an implementation of the proto.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 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 UnimplementedSensorReadingServiceHandler added in v0.0.6 

type UnimplementedSensorReadingServiceHandler struct{}

UnimplementedSensorReadingServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSensorReadingServiceHandler) CreateSensorReading added in v0.0.6 

func (UnimplementedSensorReadingServiceHandler) CreateSensorReading(context.Context, *connect.Request[CreateSensorReadingRequest]) (*connect.Response[SensorReading], error)

func (UnimplementedSensorReadingServiceHandler) DeleteSensorReading added in v0.0.6 

func (UnimplementedSensorReadingServiceHandler) DeleteSensorReading(context.Context, *connect.Request[DeleteSensorReadingRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedSensorReadingServiceHandler) GetSensorReadingById added in v0.0.6 

func (UnimplementedSensorReadingServiceHandler) GetSensorReadingById(context.Context, *connect.Request[GetSensorReadingByIdRequest]) (*connect.Response[SensorReading], error)

func (UnimplementedSensorReadingServiceHandler) ListSensorReadingBySensorId added in v0.0.6 

func (UnimplementedSensorReadingServiceHandler) ListSensorReadingBySensorId(context.Context, *connect.Request[ListSensorReadingBySensorIdRequest]) (*connect.Response[ListSensorReadingBySensorIdResponse], error)

func (UnimplementedSensorReadingServiceHandler) ListSensorReadingFilterBySensorIdRecordedAtFlagged added in v0.0.6 

func (UnimplementedSensorReadingServiceHandler) ListSensorReadingFilterBySensorIdRecordedAtFlagged(context.Context, *connect.Request[ListSensorReadingFilterBySensorIdRecordedAtFlaggedRequest]) (*connect.Response[ListSensorReadingFilterBySensorIdRecordedAtFlaggedResponse], error)

type UnimplementedSensorServiceHandler 

type UnimplementedSensorServiceHandler struct{}

UnimplementedSensorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSensorServiceHandler) CreateSensor added in v0.0.5 

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

func (UnimplementedSensorServiceHandler) DeleteSensor added in v0.0.5 

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

func (UnimplementedSensorServiceHandler) GetSensorByCode added in v0.0.5 

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

func (UnimplementedSensorServiceHandler) GetSensorById added in v0.0.6 

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

func (UnimplementedSensorServiceHandler) ListSensorFilterByLabelKindActive added in v0.0.5 

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

func (UnimplementedSensorServiceHandler) UpdateSensor added in v0.0.5 

func (UnimplementedSensorServiceHandler) UpdateSensor(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 added in v0.0.6 

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.