Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterWaterQualityServiceServer(s grpc.ServiceRegistrar, srv WaterQualityServiceServer)
- type GeoPoint
- type GuessLevelResp
- type PredictAndGuessReq
- func (*PredictAndGuessReq) Descriptor() ([]byte, []int)deprecated
- func (x *PredictAndGuessReq) GetHorizon() int64
- func (x *PredictAndGuessReq) GetLookBack() int64
- func (x *PredictAndGuessReq) GetQualities() []*Quality
- func (*PredictAndGuessReq) ProtoMessage()
- func (x *PredictAndGuessReq) ProtoReflect() protoreflect.Message
- func (x *PredictAndGuessReq) Reset()
- func (x *PredictAndGuessReq) String() string
- type PredictAndGuessResp
- func (*PredictAndGuessResp) Descriptor() ([]byte, []int)deprecated
- func (x *PredictAndGuessResp) GetLevels() []int64
- func (x *PredictAndGuessResp) GetQualities() []*Quality
- func (*PredictAndGuessResp) ProtoMessage()
- func (x *PredictAndGuessResp) ProtoReflect() protoreflect.Message
- func (x *PredictAndGuessResp) Reset()
- func (x *PredictAndGuessResp) String() string
- type PredictReq
- func (*PredictReq) Descriptor() ([]byte, []int)deprecated
- func (x *PredictReq) GetHorizon() int64
- func (x *PredictReq) GetLookBack() int64
- func (x *PredictReq) GetQualities() []*Quality
- func (*PredictReq) ProtoMessage()
- func (x *PredictReq) ProtoReflect() protoreflect.Message
- func (x *PredictReq) Reset()
- func (x *PredictReq) String() string
- type PredictResp
- type Quality
- func (*Quality) Descriptor() ([]byte, []int)deprecated
- func (x *Quality) GetGeoPoint() *GeoPoint
- func (x *Quality) GetOxygen() float32
- func (x *Quality) GetPh() float32
- func (x *Quality) GetTds() float32
- func (x *Quality) GetTemperature() float32
- func (x *Quality) GetTimestamp() int64
- func (x *Quality) GetTsw() float32
- func (*Quality) ProtoMessage()
- func (x *Quality) ProtoReflect() protoreflect.Message
- func (x *Quality) Reset()
- func (x *Quality) String() string
- type UnimplementedWaterQualityServiceServer
- func (UnimplementedWaterQualityServiceServer) GuessLevel(context.Context, *Quality) (*GuessLevelResp, error)
- func (UnimplementedWaterQualityServiceServer) Predict(context.Context, *PredictReq) (*PredictResp, error)
- func (UnimplementedWaterQualityServiceServer) PredictAndGuess(context.Context, *PredictAndGuessReq) (*PredictAndGuessResp, error)
- type UnsafeWaterQualityServiceServer
- type WaterQualityServiceClient
- type WaterQualityServiceServer
Constants ¶
const ( WaterQualityService_Predict_FullMethodName = "/api.waterquality.WaterQualityService/Predict" WaterQualityService_GuessLevel_FullMethodName = "/api.waterquality.WaterQualityService/GuessLevel" WaterQualityService_PredictAndGuess_FullMethodName = "/api.waterquality.WaterQualityService/PredictAndGuess" )
Variables ¶
var File_waterquality_waterquality_proto protoreflect.FileDescriptor
var WaterQualityService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.waterquality.WaterQualityService", HandlerType: (*WaterQualityServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Predict", Handler: _WaterQualityService_Predict_Handler, }, { MethodName: "GuessLevel", Handler: _WaterQualityService_GuessLevel_Handler, }, { MethodName: "PredictAndGuess", Handler: _WaterQualityService_PredictAndGuess_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "waterquality/waterquality.proto", }
WaterQualityService_ServiceDesc is the grpc.ServiceDesc for WaterQualityService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterWaterQualityServiceServer ¶
func RegisterWaterQualityServiceServer(s grpc.ServiceRegistrar, srv WaterQualityServiceServer)
Types ¶
type GeoPoint ¶
type GeoPoint struct { Lat float64 `protobuf:"fixed64,1,opt,name=lat,proto3" json:"lat"` // @gotags: json:"lat" Lon float64 `protobuf:"fixed64,2,opt,name=lon,proto3" json:"lon"` // @gotags: json:"lon" // contains filtered or unexported fields }
func (*GeoPoint) Descriptor
deprecated
func (*GeoPoint) ProtoMessage ¶
func (*GeoPoint) ProtoMessage()
func (*GeoPoint) ProtoReflect ¶
func (x *GeoPoint) ProtoReflect() protoreflect.Message
type GuessLevelResp ¶
type GuessLevelResp struct { Level int64 `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"` // contains filtered or unexported fields }
func (*GuessLevelResp) Descriptor
deprecated
func (*GuessLevelResp) Descriptor() ([]byte, []int)
Deprecated: Use GuessLevelResp.ProtoReflect.Descriptor instead.
func (*GuessLevelResp) GetLevel ¶
func (x *GuessLevelResp) GetLevel() int64
func (*GuessLevelResp) ProtoMessage ¶
func (*GuessLevelResp) ProtoMessage()
func (*GuessLevelResp) ProtoReflect ¶
func (x *GuessLevelResp) ProtoReflect() protoreflect.Message
func (*GuessLevelResp) Reset ¶
func (x *GuessLevelResp) Reset()
func (*GuessLevelResp) String ¶
func (x *GuessLevelResp) String() string
type PredictAndGuessReq ¶
type PredictAndGuessReq struct { Qualities []*Quality `protobuf:"bytes,1,rep,name=qualities,proto3" json:"qualities,omitempty"` LookBack int64 `protobuf:"varint,2,opt,name=look_back,json=lookBack,proto3" json:"look_back,omitempty"` Horizon int64 `protobuf:"varint,3,opt,name=horizon,proto3" json:"horizon,omitempty"` // contains filtered or unexported fields }
func (*PredictAndGuessReq) Descriptor
deprecated
func (*PredictAndGuessReq) Descriptor() ([]byte, []int)
Deprecated: Use PredictAndGuessReq.ProtoReflect.Descriptor instead.
func (*PredictAndGuessReq) GetHorizon ¶
func (x *PredictAndGuessReq) GetHorizon() int64
func (*PredictAndGuessReq) GetLookBack ¶
func (x *PredictAndGuessReq) GetLookBack() int64
func (*PredictAndGuessReq) GetQualities ¶
func (x *PredictAndGuessReq) GetQualities() []*Quality
func (*PredictAndGuessReq) ProtoMessage ¶
func (*PredictAndGuessReq) ProtoMessage()
func (*PredictAndGuessReq) ProtoReflect ¶
func (x *PredictAndGuessReq) ProtoReflect() protoreflect.Message
func (*PredictAndGuessReq) Reset ¶
func (x *PredictAndGuessReq) Reset()
func (*PredictAndGuessReq) String ¶
func (x *PredictAndGuessReq) String() string
type PredictAndGuessResp ¶
type PredictAndGuessResp struct { Qualities []*Quality `protobuf:"bytes,1,rep,name=qualities,proto3" json:"qualities,omitempty"` Levels []int64 `protobuf:"varint,2,rep,packed,name=levels,proto3" json:"levels,omitempty"` // contains filtered or unexported fields }
func (*PredictAndGuessResp) Descriptor
deprecated
func (*PredictAndGuessResp) Descriptor() ([]byte, []int)
Deprecated: Use PredictAndGuessResp.ProtoReflect.Descriptor instead.
func (*PredictAndGuessResp) GetLevels ¶ added in v0.4.3
func (x *PredictAndGuessResp) GetLevels() []int64
func (*PredictAndGuessResp) GetQualities ¶
func (x *PredictAndGuessResp) GetQualities() []*Quality
func (*PredictAndGuessResp) ProtoMessage ¶
func (*PredictAndGuessResp) ProtoMessage()
func (*PredictAndGuessResp) ProtoReflect ¶
func (x *PredictAndGuessResp) ProtoReflect() protoreflect.Message
func (*PredictAndGuessResp) Reset ¶
func (x *PredictAndGuessResp) Reset()
func (*PredictAndGuessResp) String ¶
func (x *PredictAndGuessResp) String() string
type PredictReq ¶
type PredictReq struct { Qualities []*Quality `protobuf:"bytes,1,rep,name=qualities,proto3" json:"qualities,omitempty"` LookBack int64 `protobuf:"varint,2,opt,name=look_back,json=lookBack,proto3" json:"look_back,omitempty"` Horizon int64 `protobuf:"varint,3,opt,name=horizon,proto3" json:"horizon,omitempty"` // contains filtered or unexported fields }
func (*PredictReq) Descriptor
deprecated
func (*PredictReq) Descriptor() ([]byte, []int)
Deprecated: Use PredictReq.ProtoReflect.Descriptor instead.
func (*PredictReq) GetHorizon ¶
func (x *PredictReq) GetHorizon() int64
func (*PredictReq) GetLookBack ¶
func (x *PredictReq) GetLookBack() int64
func (*PredictReq) GetQualities ¶
func (x *PredictReq) GetQualities() []*Quality
func (*PredictReq) ProtoMessage ¶
func (*PredictReq) ProtoMessage()
func (*PredictReq) ProtoReflect ¶
func (x *PredictReq) ProtoReflect() protoreflect.Message
func (*PredictReq) Reset ¶
func (x *PredictReq) Reset()
func (*PredictReq) String ¶
func (x *PredictReq) String() string
type PredictResp ¶
type PredictResp struct { Qualities []*Quality `protobuf:"bytes,1,rep,name=qualities,proto3" json:"qualities,omitempty"` // contains filtered or unexported fields }
func (*PredictResp) Descriptor
deprecated
func (*PredictResp) Descriptor() ([]byte, []int)
Deprecated: Use PredictResp.ProtoReflect.Descriptor instead.
func (*PredictResp) GetQualities ¶
func (x *PredictResp) GetQualities() []*Quality
func (*PredictResp) ProtoMessage ¶
func (*PredictResp) ProtoMessage()
func (*PredictResp) ProtoReflect ¶
func (x *PredictResp) ProtoReflect() protoreflect.Message
func (*PredictResp) Reset ¶
func (x *PredictResp) Reset()
func (*PredictResp) String ¶
func (x *PredictResp) String() string
type Quality ¶
type Quality struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp"` // @gotags: json:"timestamp" GeoPoint *GeoPoint `protobuf:"bytes,2,opt,name=geo_point,json=geoPoint,proto3" json:"geoPoint"` // @gotags: json:"geoPoint" Temperature float32 `protobuf:"fixed32,3,opt,name=temperature,proto3" json:"temperature"` // @gotags: json:"temperature" Ph float32 `protobuf:"fixed32,4,opt,name=ph,proto3" json:"ph"` // @gotags: json:"ph" Tsw float32 `protobuf:"fixed32,5,opt,name=tsw,proto3" json:"tsw"` // @gotags: json:"tsw" Tds float32 `protobuf:"fixed32,6,opt,name=tds,proto3" json:"tds"` // @gotags: json:"tds" Oxygen float32 `protobuf:"fixed32,7,opt,name=oxygen,proto3" json:"oxygen"` // @gotags: json:"oxygen" // contains filtered or unexported fields }
func (*Quality) Descriptor
deprecated
func (*Quality) GetGeoPoint ¶
func (*Quality) GetTemperature ¶
func (*Quality) GetTimestamp ¶
func (*Quality) ProtoMessage ¶
func (*Quality) ProtoMessage()
func (*Quality) ProtoReflect ¶
func (x *Quality) ProtoReflect() protoreflect.Message
type UnimplementedWaterQualityServiceServer ¶
type UnimplementedWaterQualityServiceServer struct{}
UnimplementedWaterQualityServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedWaterQualityServiceServer) GuessLevel ¶
func (UnimplementedWaterQualityServiceServer) GuessLevel(context.Context, *Quality) (*GuessLevelResp, error)
func (UnimplementedWaterQualityServiceServer) Predict ¶
func (UnimplementedWaterQualityServiceServer) Predict(context.Context, *PredictReq) (*PredictResp, error)
func (UnimplementedWaterQualityServiceServer) PredictAndGuess ¶
func (UnimplementedWaterQualityServiceServer) PredictAndGuess(context.Context, *PredictAndGuessReq) (*PredictAndGuessResp, error)
type UnsafeWaterQualityServiceServer ¶
type UnsafeWaterQualityServiceServer interface {
// contains filtered or unexported methods
}
UnsafeWaterQualityServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WaterQualityServiceServer will result in compilation errors.
type WaterQualityServiceClient ¶
type WaterQualityServiceClient interface { Predict(ctx context.Context, in *PredictReq, opts ...grpc.CallOption) (*PredictResp, error) GuessLevel(ctx context.Context, in *Quality, opts ...grpc.CallOption) (*GuessLevelResp, error) PredictAndGuess(ctx context.Context, in *PredictAndGuessReq, opts ...grpc.CallOption) (*PredictAndGuessResp, error) }
WaterQualityServiceClient is the client API for WaterQualityService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWaterQualityServiceClient ¶
func NewWaterQualityServiceClient(cc grpc.ClientConnInterface) WaterQualityServiceClient
type WaterQualityServiceServer ¶
type WaterQualityServiceServer interface { Predict(context.Context, *PredictReq) (*PredictResp, error) GuessLevel(context.Context, *Quality) (*GuessLevelResp, error) PredictAndGuess(context.Context, *PredictAndGuessReq) (*PredictAndGuessResp, error) // contains filtered or unexported methods }
WaterQualityServiceServer is the server API for WaterQualityService service. All implementations must embed UnimplementedWaterQualityServiceServer for forward compatibility.