Documentation
¶
Index ¶
- func RegisterEspressoServer(s *grpc.Server, srv EspressoServer)
- type Configuration
- func (*Configuration) Descriptor() ([]byte, []int)
- func (m *Configuration) GetD() float32
- func (m *Configuration) GetI() float32
- func (m *Configuration) GetP() float32
- func (m *Configuration) GetSetAt() *timestamp.Timestamp
- func (m *Configuration) GetTemperature() float32
- func (*Configuration) ProtoMessage()
- func (m *Configuration) Reset()
- func (m *Configuration) String() string
- func (m *Configuration) XXX_DiscardUnknown()
- func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Configuration) XXX_Merge(src proto.Message)
- func (m *Configuration) XXX_Size() int
- func (m *Configuration) XXX_Unmarshal(b []byte) error
- type EspressoClient
- type EspressoServer
- type Espresso_BoilerTemperatureClient
- type Espresso_BoilerTemperatureServer
- type GetConfigurationRequest
- func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
- func (*GetConfigurationRequest) ProtoMessage()
- func (m *GetConfigurationRequest) Reset()
- func (m *GetConfigurationRequest) String() string
- func (m *GetConfigurationRequest) XXX_DiscardUnknown()
- func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
- func (m *GetConfigurationRequest) XXX_Size() int
- func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
- type TemperatureHistory
- func (*TemperatureHistory) Descriptor() ([]byte, []int)
- func (m *TemperatureHistory) GetSamples() []*TemperatureSample
- func (*TemperatureHistory) ProtoMessage()
- func (m *TemperatureHistory) Reset()
- func (m *TemperatureHistory) String() string
- func (m *TemperatureHistory) XXX_DiscardUnknown()
- func (m *TemperatureHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemperatureHistory) XXX_Merge(src proto.Message)
- func (m *TemperatureHistory) XXX_Size() int
- func (m *TemperatureHistory) XXX_Unmarshal(b []byte) error
- type TemperatureSample
- func (*TemperatureSample) Descriptor() ([]byte, []int)
- func (m *TemperatureSample) GetObservedAt() *timestamp.Timestamp
- func (m *TemperatureSample) GetValue() float32
- func (*TemperatureSample) ProtoMessage()
- func (m *TemperatureSample) Reset()
- func (m *TemperatureSample) String() string
- func (m *TemperatureSample) XXX_DiscardUnknown()
- func (m *TemperatureSample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemperatureSample) XXX_Merge(src proto.Message)
- func (m *TemperatureSample) XXX_Size() int
- func (m *TemperatureSample) XXX_Unmarshal(b []byte) error
- type TemperatureStreamRequest
- func (*TemperatureStreamRequest) Descriptor() ([]byte, []int)
- func (*TemperatureStreamRequest) ProtoMessage()
- func (m *TemperatureStreamRequest) Reset()
- func (m *TemperatureStreamRequest) String() string
- func (m *TemperatureStreamRequest) XXX_DiscardUnknown()
- func (m *TemperatureStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemperatureStreamRequest) XXX_Merge(src proto.Message)
- func (m *TemperatureStreamRequest) XXX_Size() int
- func (m *TemperatureStreamRequest) XXX_Unmarshal(b []byte) error
- type TemperatureStreamResponse
- func (*TemperatureStreamResponse) Descriptor() ([]byte, []int)
- func (m *TemperatureStreamResponse) GetData() isTemperatureStreamResponse_Data
- func (m *TemperatureStreamResponse) GetHistory() *TemperatureHistory
- func (m *TemperatureStreamResponse) GetSample() *TemperatureSample
- func (*TemperatureStreamResponse) ProtoMessage()
- func (m *TemperatureStreamResponse) Reset()
- func (m *TemperatureStreamResponse) String() string
- func (m *TemperatureStreamResponse) XXX_DiscardUnknown()
- func (m *TemperatureStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemperatureStreamResponse) XXX_Merge(src proto.Message)
- func (*TemperatureStreamResponse) XXX_OneofWrappers() []interface{}
- func (m *TemperatureStreamResponse) XXX_Size() int
- func (m *TemperatureStreamResponse) XXX_Unmarshal(b []byte) error
- type TemperatureStreamResponse_History
- type TemperatureStreamResponse_Sample
- type UnimplementedEspressoServer
- func (*UnimplementedEspressoServer) BoilerTemperature(req *TemperatureStreamRequest, srv Espresso_BoilerTemperatureServer) error
- func (*UnimplementedEspressoServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*Configuration, error)
- func (*UnimplementedEspressoServer) SetConfiguration(ctx context.Context, req *Configuration) (*Configuration, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterEspressoServer ¶
func RegisterEspressoServer(s *grpc.Server, srv EspressoServer)
Types ¶
type Configuration ¶
type Configuration struct { Temperature float32 `protobuf:"fixed32,1,opt,name=temperature,proto3" json:"temperature,omitempty"` P float32 `protobuf:"fixed32,2,opt,name=p,proto3" json:"p,omitempty"` I float32 `protobuf:"fixed32,3,opt,name=i,proto3" json:"i,omitempty"` D float32 `protobuf:"fixed32,4,opt,name=d,proto3" json:"d,omitempty"` SetAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=set_at,json=setAt,proto3" json:"set_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Configuration) Descriptor ¶
func (*Configuration) Descriptor() ([]byte, []int)
func (*Configuration) GetD ¶
func (m *Configuration) GetD() float32
func (*Configuration) GetI ¶
func (m *Configuration) GetI() float32
func (*Configuration) GetP ¶
func (m *Configuration) GetP() float32
func (*Configuration) GetSetAt ¶
func (m *Configuration) GetSetAt() *timestamp.Timestamp
func (*Configuration) GetTemperature ¶
func (m *Configuration) GetTemperature() float32
func (*Configuration) ProtoMessage ¶
func (*Configuration) ProtoMessage()
func (*Configuration) Reset ¶
func (m *Configuration) Reset()
func (*Configuration) String ¶
func (m *Configuration) String() string
func (*Configuration) XXX_DiscardUnknown ¶
func (m *Configuration) XXX_DiscardUnknown()
func (*Configuration) XXX_Marshal ¶
func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Configuration) XXX_Merge ¶
func (m *Configuration) XXX_Merge(src proto.Message)
func (*Configuration) XXX_Size ¶
func (m *Configuration) XXX_Size() int
func (*Configuration) XXX_Unmarshal ¶
func (m *Configuration) XXX_Unmarshal(b []byte) error
type EspressoClient ¶
type EspressoClient interface { BoilerTemperature(ctx context.Context, in *TemperatureStreamRequest, opts ...grpc.CallOption) (Espresso_BoilerTemperatureClient, error) GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*Configuration, error) SetConfiguration(ctx context.Context, in *Configuration, opts ...grpc.CallOption) (*Configuration, error) }
EspressoClient is the client API for Espresso service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEspressoClient ¶
func NewEspressoClient(cc grpc.ClientConnInterface) EspressoClient
type EspressoServer ¶
type EspressoServer interface { BoilerTemperature(*TemperatureStreamRequest, Espresso_BoilerTemperatureServer) error GetConfiguration(context.Context, *GetConfigurationRequest) (*Configuration, error) SetConfiguration(context.Context, *Configuration) (*Configuration, error) }
EspressoServer is the server API for Espresso service.
type Espresso_BoilerTemperatureClient ¶
type Espresso_BoilerTemperatureClient interface { Recv() (*TemperatureStreamResponse, error) grpc.ClientStream }
type Espresso_BoilerTemperatureServer ¶
type Espresso_BoilerTemperatureServer interface { Send(*TemperatureStreamResponse) error grpc.ServerStream }
type GetConfigurationRequest ¶
type GetConfigurationRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetConfigurationRequest) Descriptor ¶
func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
func (*GetConfigurationRequest) ProtoMessage ¶
func (*GetConfigurationRequest) ProtoMessage()
func (*GetConfigurationRequest) Reset ¶
func (m *GetConfigurationRequest) Reset()
func (*GetConfigurationRequest) String ¶
func (m *GetConfigurationRequest) String() string
func (*GetConfigurationRequest) XXX_DiscardUnknown ¶
func (m *GetConfigurationRequest) XXX_DiscardUnknown()
func (*GetConfigurationRequest) XXX_Marshal ¶
func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigurationRequest) XXX_Merge ¶
func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
func (*GetConfigurationRequest) XXX_Size ¶
func (m *GetConfigurationRequest) XXX_Size() int
func (*GetConfigurationRequest) XXX_Unmarshal ¶
func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
type TemperatureHistory ¶
type TemperatureHistory struct { Samples []*TemperatureSample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TemperatureHistory) Descriptor ¶
func (*TemperatureHistory) Descriptor() ([]byte, []int)
func (*TemperatureHistory) GetSamples ¶
func (m *TemperatureHistory) GetSamples() []*TemperatureSample
func (*TemperatureHistory) ProtoMessage ¶
func (*TemperatureHistory) ProtoMessage()
func (*TemperatureHistory) Reset ¶
func (m *TemperatureHistory) Reset()
func (*TemperatureHistory) String ¶
func (m *TemperatureHistory) String() string
func (*TemperatureHistory) XXX_DiscardUnknown ¶
func (m *TemperatureHistory) XXX_DiscardUnknown()
func (*TemperatureHistory) XXX_Marshal ¶
func (m *TemperatureHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemperatureHistory) XXX_Merge ¶
func (m *TemperatureHistory) XXX_Merge(src proto.Message)
func (*TemperatureHistory) XXX_Size ¶
func (m *TemperatureHistory) XXX_Size() int
func (*TemperatureHistory) XXX_Unmarshal ¶
func (m *TemperatureHistory) XXX_Unmarshal(b []byte) error
type TemperatureSample ¶
type TemperatureSample struct { Value float32 `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"` ObservedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=observed_at,json=observedAt,proto3" json:"observed_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TemperatureSample) Descriptor ¶
func (*TemperatureSample) Descriptor() ([]byte, []int)
func (*TemperatureSample) GetObservedAt ¶
func (m *TemperatureSample) GetObservedAt() *timestamp.Timestamp
func (*TemperatureSample) GetValue ¶
func (m *TemperatureSample) GetValue() float32
func (*TemperatureSample) ProtoMessage ¶
func (*TemperatureSample) ProtoMessage()
func (*TemperatureSample) Reset ¶
func (m *TemperatureSample) Reset()
func (*TemperatureSample) String ¶
func (m *TemperatureSample) String() string
func (*TemperatureSample) XXX_DiscardUnknown ¶
func (m *TemperatureSample) XXX_DiscardUnknown()
func (*TemperatureSample) XXX_Marshal ¶
func (m *TemperatureSample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemperatureSample) XXX_Merge ¶
func (m *TemperatureSample) XXX_Merge(src proto.Message)
func (*TemperatureSample) XXX_Size ¶
func (m *TemperatureSample) XXX_Size() int
func (*TemperatureSample) XXX_Unmarshal ¶
func (m *TemperatureSample) XXX_Unmarshal(b []byte) error
type TemperatureStreamRequest ¶
type TemperatureStreamRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TemperatureStreamRequest) Descriptor ¶
func (*TemperatureStreamRequest) Descriptor() ([]byte, []int)
func (*TemperatureStreamRequest) ProtoMessage ¶
func (*TemperatureStreamRequest) ProtoMessage()
func (*TemperatureStreamRequest) Reset ¶
func (m *TemperatureStreamRequest) Reset()
func (*TemperatureStreamRequest) String ¶
func (m *TemperatureStreamRequest) String() string
func (*TemperatureStreamRequest) XXX_DiscardUnknown ¶
func (m *TemperatureStreamRequest) XXX_DiscardUnknown()
func (*TemperatureStreamRequest) XXX_Marshal ¶
func (m *TemperatureStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemperatureStreamRequest) XXX_Merge ¶
func (m *TemperatureStreamRequest) XXX_Merge(src proto.Message)
func (*TemperatureStreamRequest) XXX_Size ¶
func (m *TemperatureStreamRequest) XXX_Size() int
func (*TemperatureStreamRequest) XXX_Unmarshal ¶
func (m *TemperatureStreamRequest) XXX_Unmarshal(b []byte) error
type TemperatureStreamResponse ¶
type TemperatureStreamResponse struct { // Types that are valid to be assigned to Data: // *TemperatureStreamResponse_History // *TemperatureStreamResponse_Sample Data isTemperatureStreamResponse_Data `protobuf_oneof:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TemperatureStreamResponse) Descriptor ¶
func (*TemperatureStreamResponse) Descriptor() ([]byte, []int)
func (*TemperatureStreamResponse) GetData ¶
func (m *TemperatureStreamResponse) GetData() isTemperatureStreamResponse_Data
func (*TemperatureStreamResponse) GetHistory ¶
func (m *TemperatureStreamResponse) GetHistory() *TemperatureHistory
func (*TemperatureStreamResponse) GetSample ¶
func (m *TemperatureStreamResponse) GetSample() *TemperatureSample
func (*TemperatureStreamResponse) ProtoMessage ¶
func (*TemperatureStreamResponse) ProtoMessage()
func (*TemperatureStreamResponse) Reset ¶
func (m *TemperatureStreamResponse) Reset()
func (*TemperatureStreamResponse) String ¶
func (m *TemperatureStreamResponse) String() string
func (*TemperatureStreamResponse) XXX_DiscardUnknown ¶
func (m *TemperatureStreamResponse) XXX_DiscardUnknown()
func (*TemperatureStreamResponse) XXX_Marshal ¶
func (m *TemperatureStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemperatureStreamResponse) XXX_Merge ¶
func (m *TemperatureStreamResponse) XXX_Merge(src proto.Message)
func (*TemperatureStreamResponse) XXX_OneofWrappers ¶
func (*TemperatureStreamResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*TemperatureStreamResponse) XXX_Size ¶
func (m *TemperatureStreamResponse) XXX_Size() int
func (*TemperatureStreamResponse) XXX_Unmarshal ¶
func (m *TemperatureStreamResponse) XXX_Unmarshal(b []byte) error
type TemperatureStreamResponse_History ¶
type TemperatureStreamResponse_History struct {
History *TemperatureHistory `protobuf:"bytes,1,opt,name=history,proto3,oneof"`
}
type TemperatureStreamResponse_Sample ¶
type TemperatureStreamResponse_Sample struct {
Sample *TemperatureSample `protobuf:"bytes,2,opt,name=sample,proto3,oneof"`
}
type UnimplementedEspressoServer ¶
type UnimplementedEspressoServer struct { }
UnimplementedEspressoServer can be embedded to have forward compatible implementations.
func (*UnimplementedEspressoServer) BoilerTemperature ¶
func (*UnimplementedEspressoServer) BoilerTemperature(req *TemperatureStreamRequest, srv Espresso_BoilerTemperatureServer) error
func (*UnimplementedEspressoServer) GetConfiguration ¶
func (*UnimplementedEspressoServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*Configuration, error)
func (*UnimplementedEspressoServer) SetConfiguration ¶
func (*UnimplementedEspressoServer) SetConfiguration(ctx context.Context, req *Configuration) (*Configuration, error)
Click to show internal directories.
Click to hide internal directories.