Documentation ¶
Index ¶
- func RegisterTemperatureServiceServer(s *grpc.Server, srv TemperatureServiceServer)
- type Broker
- type Server
- type TemperatureResponse
- func (*TemperatureResponse) Descriptor() ([]byte, []int)
- func (m *TemperatureResponse) GetTemperature() float64
- func (*TemperatureResponse) ProtoMessage()
- func (m *TemperatureResponse) Reset()
- func (m *TemperatureResponse) String() string
- func (m *TemperatureResponse) XXX_DiscardUnknown()
- func (m *TemperatureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemperatureResponse) XXX_Merge(src proto.Message)
- func (m *TemperatureResponse) XXX_Size() int
- func (m *TemperatureResponse) XXX_Unmarshal(b []byte) error
- type TemperatureServiceClient
- type TemperatureServiceServer
- type TemperatureService_GetTemperatureClient
- type TemperatureService_GetTemperatureServer
- type UnimplementedTemperatureServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTemperatureServiceServer ¶
func RegisterTemperatureServiceServer(s *grpc.Server, srv TemperatureServiceServer)
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
func (*Broker) Unsubscribe ¶
func (b *Broker) Unsubscribe(msgCh chan interface{})
type Server ¶
type Server struct {
Broker *Broker
}
func (*Server) GetTemperature ¶
func (s *Server) GetTemperature(e *empty.Empty, stream TemperatureService_GetTemperatureServer) error
type TemperatureResponse ¶
type TemperatureResponse struct { Temperature float64 `protobuf:"fixed64,1,opt,name=temperature,proto3" json:"temperature,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TemperatureResponse) Descriptor ¶
func (*TemperatureResponse) Descriptor() ([]byte, []int)
func (*TemperatureResponse) GetTemperature ¶
func (m *TemperatureResponse) GetTemperature() float64
func (*TemperatureResponse) ProtoMessage ¶
func (*TemperatureResponse) ProtoMessage()
func (*TemperatureResponse) Reset ¶
func (m *TemperatureResponse) Reset()
func (*TemperatureResponse) String ¶
func (m *TemperatureResponse) String() string
func (*TemperatureResponse) XXX_DiscardUnknown ¶
func (m *TemperatureResponse) XXX_DiscardUnknown()
func (*TemperatureResponse) XXX_Marshal ¶
func (m *TemperatureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemperatureResponse) XXX_Merge ¶
func (m *TemperatureResponse) XXX_Merge(src proto.Message)
func (*TemperatureResponse) XXX_Size ¶
func (m *TemperatureResponse) XXX_Size() int
func (*TemperatureResponse) XXX_Unmarshal ¶
func (m *TemperatureResponse) XXX_Unmarshal(b []byte) error
type TemperatureServiceClient ¶
type TemperatureServiceClient interface {
GetTemperature(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (TemperatureService_GetTemperatureClient, error)
}
TemperatureServiceClient is the client API for TemperatureService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTemperatureServiceClient ¶
func NewTemperatureServiceClient(cc *grpc.ClientConn) TemperatureServiceClient
type TemperatureServiceServer ¶
type TemperatureServiceServer interface {
GetTemperature(*empty.Empty, TemperatureService_GetTemperatureServer) error
}
TemperatureServiceServer is the server API for TemperatureService service.
type TemperatureService_GetTemperatureClient ¶
type TemperatureService_GetTemperatureClient interface { Recv() (*TemperatureResponse, error) grpc.ClientStream }
type TemperatureService_GetTemperatureServer ¶
type TemperatureService_GetTemperatureServer interface { Send(*TemperatureResponse) error grpc.ServerStream }
type UnimplementedTemperatureServiceServer ¶
type UnimplementedTemperatureServiceServer struct { }
UnimplementedTemperatureServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTemperatureServiceServer) GetTemperature ¶
func (*UnimplementedTemperatureServiceServer) GetTemperature(req *empty.Empty, srv TemperatureService_GetTemperatureServer) error
Click to show internal directories.
Click to hide internal directories.