Versions in this module Expand all Collapse all v5 v5.4.100 Mar 26, 2023 Changes in this version + var Aggregator_ServiceDesc = grpc.ServiceDesc + var File_aggregator_api_proto protoreflect.FileDescriptor + func RegisterAggregatorServer(s grpc.ServiceRegistrar, srv AggregatorServer) + type AggregatorClient interface + FeedSensorPacket func(ctx context.Context, in *SensorPacket, opts ...grpc.CallOption) (*FeedResponse, error) + func NewAggregatorClient(cc grpc.ClientConnInterface) AggregatorClient + type AggregatorServer interface + FeedSensorPacket func(context.Context, *SensorPacket) (*FeedResponse, error) + func NewAggregator(db *pgxpool.Pool, location *time.Location) (AggregatorServer, error) + type FeedResponse struct + Processed bool + func (*FeedResponse) Descriptor() ([]byte, []int) + func (*FeedResponse) ProtoMessage() + func (x *FeedResponse) GetProcessed() bool + func (x *FeedResponse) ProtoReflect() protoreflect.Message + func (x *FeedResponse) Reset() + func (x *FeedResponse) String() string + type GraphiteSender struct + func NewGraphiteSender(host string, port int, pathTemplate string) *GraphiteSender + func (g *GraphiteSender) Push(s sensorStat) bool + func (g *GraphiteSender) Run() + type MqttClient struct + func NewMqttClient(mqttHost string, mqttPort int) *MqttClient + func (cl *MqttClient) Push(s sensorStat) bool + func (cl *MqttClient) Run() + type SensorPacket struct + Id uint32 + Lqi uint32 + Raw []byte + Rssi float32 + Seq uint32 + func (*SensorPacket) Descriptor() ([]byte, []int) + func (*SensorPacket) ProtoMessage() + func (x *SensorPacket) GetId() uint32 + func (x *SensorPacket) GetLqi() uint32 + func (x *SensorPacket) GetRaw() []byte + func (x *SensorPacket) GetRssi() float32 + func (x *SensorPacket) GetSeq() uint32 + func (x *SensorPacket) ProtoReflect() protoreflect.Message + func (x *SensorPacket) Reset() + func (x *SensorPacket) String() string + type UnimplementedAggregatorServer struct + func (UnimplementedAggregatorServer) FeedSensorPacket(context.Context, *SensorPacket) (*FeedResponse, error) + type UnsafeAggregatorServer interface