Documentation ¶
Index ¶
- func RegisterMikaponicsThingServer(s *grpc.Server, srv MikaponicsThingServer)
- type MikaponicsThingClient
- type MikaponicsThingServer
- type SetSensorRequest
- func (*SetSensorRequest) Descriptor() ([]byte, []int)
- func (m *SetSensorRequest) GetTenantId() int64
- func (m *SetSensorRequest) GetThingId() int64
- func (m *SetSensorRequest) GetTypeId() int32
- func (*SetSensorRequest) ProtoMessage()
- func (m *SetSensorRequest) Reset()
- func (m *SetSensorRequest) String() string
- func (m *SetSensorRequest) XXX_DiscardUnknown()
- func (m *SetSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetSensorRequest) XXX_Merge(src proto.Message)
- func (m *SetSensorRequest) XXX_Size() int
- func (m *SetSensorRequest) XXX_Unmarshal(b []byte) error
- type SetSensorResponse
- func (*SetSensorResponse) Descriptor() ([]byte, []int)
- func (m *SetSensorResponse) GetMessage() string
- func (m *SetSensorResponse) GetStatus() bool
- func (*SetSensorResponse) ProtoMessage()
- func (m *SetSensorResponse) Reset()
- func (m *SetSensorResponse) String() string
- func (m *SetSensorResponse) XXX_DiscardUnknown()
- func (m *SetSensorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetSensorResponse) XXX_Merge(src proto.Message)
- func (m *SetSensorResponse) XXX_Size() int
- func (m *SetSensorResponse) XXX_Unmarshal(b []byte) error
- type SetThingRequest
- func (*SetThingRequest) Descriptor() ([]byte, []int)
- func (m *SetThingRequest) GetName() string
- func (m *SetThingRequest) GetTenantId() int64
- func (m *SetThingRequest) GetUserId() int64
- func (*SetThingRequest) ProtoMessage()
- func (m *SetThingRequest) Reset()
- func (m *SetThingRequest) String() string
- func (m *SetThingRequest) XXX_DiscardUnknown()
- func (m *SetThingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetThingRequest) XXX_Merge(src proto.Message)
- func (m *SetThingRequest) XXX_Size() int
- func (m *SetThingRequest) XXX_Unmarshal(b []byte) error
- type SetThingResponse
- func (*SetThingResponse) Descriptor() ([]byte, []int)
- func (m *SetThingResponse) GetMessage() string
- func (m *SetThingResponse) GetStatus() bool
- func (*SetThingResponse) ProtoMessage()
- func (m *SetThingResponse) Reset()
- func (m *SetThingResponse) String() string
- func (m *SetThingResponse) XXX_DiscardUnknown()
- func (m *SetThingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetThingResponse) XXX_Merge(src proto.Message)
- func (m *SetThingResponse) XXX_Size() int
- func (m *SetThingResponse) XXX_Unmarshal(b []byte) error
- type SetTimeSeriesDataRequest
- func (*SetTimeSeriesDataRequest) Descriptor() ([]byte, []int)
- func (m *SetTimeSeriesDataRequest) GetData() []*SetTimeSeriesDatumRequest
- func (*SetTimeSeriesDataRequest) ProtoMessage()
- func (m *SetTimeSeriesDataRequest) Reset()
- func (m *SetTimeSeriesDataRequest) String() string
- func (m *SetTimeSeriesDataRequest) XXX_DiscardUnknown()
- func (m *SetTimeSeriesDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetTimeSeriesDataRequest) XXX_Merge(src proto.Message)
- func (m *SetTimeSeriesDataRequest) XXX_Size() int
- func (m *SetTimeSeriesDataRequest) XXX_Unmarshal(b []byte) error
- type SetTimeSeriesDataResponse
- func (*SetTimeSeriesDataResponse) Descriptor() ([]byte, []int)
- func (m *SetTimeSeriesDataResponse) GetMessage() string
- func (m *SetTimeSeriesDataResponse) GetStatus() bool
- func (*SetTimeSeriesDataResponse) ProtoMessage()
- func (m *SetTimeSeriesDataResponse) Reset()
- func (m *SetTimeSeriesDataResponse) String() string
- func (m *SetTimeSeriesDataResponse) XXX_DiscardUnknown()
- func (m *SetTimeSeriesDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetTimeSeriesDataResponse) XXX_Merge(src proto.Message)
- func (m *SetTimeSeriesDataResponse) XXX_Size() int
- func (m *SetTimeSeriesDataResponse) XXX_Unmarshal(b []byte) error
- type SetTimeSeriesDatumRequest
- func (*SetTimeSeriesDatumRequest) Descriptor() ([]byte, []int)
- func (m *SetTimeSeriesDatumRequest) GetSensorId() int64
- func (m *SetTimeSeriesDatumRequest) GetTenantId() int64
- func (m *SetTimeSeriesDatumRequest) GetTimestamp() *timestamp.Timestamp
- func (m *SetTimeSeriesDatumRequest) GetValue() float64
- func (*SetTimeSeriesDatumRequest) ProtoMessage()
- func (m *SetTimeSeriesDatumRequest) Reset()
- func (m *SetTimeSeriesDatumRequest) String() string
- func (m *SetTimeSeriesDatumRequest) XXX_DiscardUnknown()
- func (m *SetTimeSeriesDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetTimeSeriesDatumRequest) XXX_Merge(src proto.Message)
- func (m *SetTimeSeriesDatumRequest) XXX_Size() int
- func (m *SetTimeSeriesDatumRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedMikaponicsThingServer
- func (*UnimplementedMikaponicsThingServer) SetSensor(ctx context.Context, req *SetSensorRequest) (*SetSensorResponse, error)
- func (*UnimplementedMikaponicsThingServer) SetThing(ctx context.Context, req *SetThingRequest) (*SetThingResponse, error)
- func (*UnimplementedMikaponicsThingServer) SetTimeSeriesData(ctx context.Context, req *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMikaponicsThingServer ¶
func RegisterMikaponicsThingServer(s *grpc.Server, srv MikaponicsThingServer)
Types ¶
type MikaponicsThingClient ¶
type MikaponicsThingClient interface { SetTimeSeriesData(ctx context.Context, in *SetTimeSeriesDataRequest, opts ...grpc.CallOption) (*SetTimeSeriesDataResponse, error) SetSensor(ctx context.Context, in *SetSensorRequest, opts ...grpc.CallOption) (*SetSensorResponse, error) SetThing(ctx context.Context, in *SetThingRequest, opts ...grpc.CallOption) (*SetThingResponse, error) }
MikaponicsThingClient is the client API for MikaponicsThing service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMikaponicsThingClient ¶
func NewMikaponicsThingClient(cc *grpc.ClientConn) MikaponicsThingClient
type MikaponicsThingServer ¶
type MikaponicsThingServer interface { SetTimeSeriesData(context.Context, *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error) SetSensor(context.Context, *SetSensorRequest) (*SetSensorResponse, error) SetThing(context.Context, *SetThingRequest) (*SetThingResponse, error) }
MikaponicsThingServer is the server API for MikaponicsThing service.
type SetSensorRequest ¶
type SetSensorRequest struct { TenantId int64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` ThingId int64 `protobuf:"varint,2,opt,name=thing_id,json=thingId,proto3" json:"thing_id,omitempty"` TypeId int32 `protobuf:"varint,3,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetSensorRequest) Descriptor ¶
func (*SetSensorRequest) Descriptor() ([]byte, []int)
func (*SetSensorRequest) GetTenantId ¶
func (m *SetSensorRequest) GetTenantId() int64
func (*SetSensorRequest) GetThingId ¶
func (m *SetSensorRequest) GetThingId() int64
func (*SetSensorRequest) GetTypeId ¶
func (m *SetSensorRequest) GetTypeId() int32
func (*SetSensorRequest) ProtoMessage ¶
func (*SetSensorRequest) ProtoMessage()
func (*SetSensorRequest) Reset ¶
func (m *SetSensorRequest) Reset()
func (*SetSensorRequest) String ¶
func (m *SetSensorRequest) String() string
func (*SetSensorRequest) XXX_DiscardUnknown ¶
func (m *SetSensorRequest) XXX_DiscardUnknown()
func (*SetSensorRequest) XXX_Marshal ¶
func (m *SetSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetSensorRequest) XXX_Merge ¶
func (m *SetSensorRequest) XXX_Merge(src proto.Message)
func (*SetSensorRequest) XXX_Size ¶
func (m *SetSensorRequest) XXX_Size() int
func (*SetSensorRequest) XXX_Unmarshal ¶
func (m *SetSensorRequest) XXX_Unmarshal(b []byte) error
type SetSensorResponse ¶
type SetSensorResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetSensorResponse) Descriptor ¶
func (*SetSensorResponse) Descriptor() ([]byte, []int)
func (*SetSensorResponse) GetMessage ¶
func (m *SetSensorResponse) GetMessage() string
func (*SetSensorResponse) GetStatus ¶
func (m *SetSensorResponse) GetStatus() bool
func (*SetSensorResponse) ProtoMessage ¶
func (*SetSensorResponse) ProtoMessage()
func (*SetSensorResponse) Reset ¶
func (m *SetSensorResponse) Reset()
func (*SetSensorResponse) String ¶
func (m *SetSensorResponse) String() string
func (*SetSensorResponse) XXX_DiscardUnknown ¶
func (m *SetSensorResponse) XXX_DiscardUnknown()
func (*SetSensorResponse) XXX_Marshal ¶
func (m *SetSensorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetSensorResponse) XXX_Merge ¶
func (m *SetSensorResponse) XXX_Merge(src proto.Message)
func (*SetSensorResponse) XXX_Size ¶
func (m *SetSensorResponse) XXX_Size() int
func (*SetSensorResponse) XXX_Unmarshal ¶
func (m *SetSensorResponse) XXX_Unmarshal(b []byte) error
type SetThingRequest ¶
type SetThingRequest struct { TenantId int64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetThingRequest) Descriptor ¶
func (*SetThingRequest) Descriptor() ([]byte, []int)
func (*SetThingRequest) GetName ¶
func (m *SetThingRequest) GetName() string
func (*SetThingRequest) GetTenantId ¶
func (m *SetThingRequest) GetTenantId() int64
func (*SetThingRequest) GetUserId ¶
func (m *SetThingRequest) GetUserId() int64
func (*SetThingRequest) ProtoMessage ¶
func (*SetThingRequest) ProtoMessage()
func (*SetThingRequest) Reset ¶
func (m *SetThingRequest) Reset()
func (*SetThingRequest) String ¶
func (m *SetThingRequest) String() string
func (*SetThingRequest) XXX_DiscardUnknown ¶
func (m *SetThingRequest) XXX_DiscardUnknown()
func (*SetThingRequest) XXX_Marshal ¶
func (m *SetThingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetThingRequest) XXX_Merge ¶
func (m *SetThingRequest) XXX_Merge(src proto.Message)
func (*SetThingRequest) XXX_Size ¶
func (m *SetThingRequest) XXX_Size() int
func (*SetThingRequest) XXX_Unmarshal ¶
func (m *SetThingRequest) XXX_Unmarshal(b []byte) error
type SetThingResponse ¶
type SetThingResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetThingResponse) Descriptor ¶
func (*SetThingResponse) Descriptor() ([]byte, []int)
func (*SetThingResponse) GetMessage ¶
func (m *SetThingResponse) GetMessage() string
func (*SetThingResponse) GetStatus ¶
func (m *SetThingResponse) GetStatus() bool
func (*SetThingResponse) ProtoMessage ¶
func (*SetThingResponse) ProtoMessage()
func (*SetThingResponse) Reset ¶
func (m *SetThingResponse) Reset()
func (*SetThingResponse) String ¶
func (m *SetThingResponse) String() string
func (*SetThingResponse) XXX_DiscardUnknown ¶
func (m *SetThingResponse) XXX_DiscardUnknown()
func (*SetThingResponse) XXX_Marshal ¶
func (m *SetThingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetThingResponse) XXX_Merge ¶
func (m *SetThingResponse) XXX_Merge(src proto.Message)
func (*SetThingResponse) XXX_Size ¶
func (m *SetThingResponse) XXX_Size() int
func (*SetThingResponse) XXX_Unmarshal ¶
func (m *SetThingResponse) XXX_Unmarshal(b []byte) error
type SetTimeSeriesDataRequest ¶
type SetTimeSeriesDataRequest struct { Data []*SetTimeSeriesDatumRequest `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetTimeSeriesDataRequest) Descriptor ¶
func (*SetTimeSeriesDataRequest) Descriptor() ([]byte, []int)
func (*SetTimeSeriesDataRequest) GetData ¶
func (m *SetTimeSeriesDataRequest) GetData() []*SetTimeSeriesDatumRequest
func (*SetTimeSeriesDataRequest) ProtoMessage ¶
func (*SetTimeSeriesDataRequest) ProtoMessage()
func (*SetTimeSeriesDataRequest) Reset ¶
func (m *SetTimeSeriesDataRequest) Reset()
func (*SetTimeSeriesDataRequest) String ¶
func (m *SetTimeSeriesDataRequest) String() string
func (*SetTimeSeriesDataRequest) XXX_DiscardUnknown ¶
func (m *SetTimeSeriesDataRequest) XXX_DiscardUnknown()
func (*SetTimeSeriesDataRequest) XXX_Marshal ¶
func (m *SetTimeSeriesDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetTimeSeriesDataRequest) XXX_Merge ¶
func (m *SetTimeSeriesDataRequest) XXX_Merge(src proto.Message)
func (*SetTimeSeriesDataRequest) XXX_Size ¶
func (m *SetTimeSeriesDataRequest) XXX_Size() int
func (*SetTimeSeriesDataRequest) XXX_Unmarshal ¶
func (m *SetTimeSeriesDataRequest) XXX_Unmarshal(b []byte) error
type SetTimeSeriesDataResponse ¶
type SetTimeSeriesDataResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetTimeSeriesDataResponse) Descriptor ¶
func (*SetTimeSeriesDataResponse) Descriptor() ([]byte, []int)
func (*SetTimeSeriesDataResponse) GetMessage ¶
func (m *SetTimeSeriesDataResponse) GetMessage() string
func (*SetTimeSeriesDataResponse) GetStatus ¶
func (m *SetTimeSeriesDataResponse) GetStatus() bool
func (*SetTimeSeriesDataResponse) ProtoMessage ¶
func (*SetTimeSeriesDataResponse) ProtoMessage()
func (*SetTimeSeriesDataResponse) Reset ¶
func (m *SetTimeSeriesDataResponse) Reset()
func (*SetTimeSeriesDataResponse) String ¶
func (m *SetTimeSeriesDataResponse) String() string
func (*SetTimeSeriesDataResponse) XXX_DiscardUnknown ¶
func (m *SetTimeSeriesDataResponse) XXX_DiscardUnknown()
func (*SetTimeSeriesDataResponse) XXX_Marshal ¶
func (m *SetTimeSeriesDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetTimeSeriesDataResponse) XXX_Merge ¶
func (m *SetTimeSeriesDataResponse) XXX_Merge(src proto.Message)
func (*SetTimeSeriesDataResponse) XXX_Size ¶
func (m *SetTimeSeriesDataResponse) XXX_Size() int
func (*SetTimeSeriesDataResponse) XXX_Unmarshal ¶
func (m *SetTimeSeriesDataResponse) XXX_Unmarshal(b []byte) error
type SetTimeSeriesDatumRequest ¶
type SetTimeSeriesDatumRequest struct { TenantId int64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` SensorId int64 `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"` Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetTimeSeriesDatumRequest) Descriptor ¶
func (*SetTimeSeriesDatumRequest) Descriptor() ([]byte, []int)
func (*SetTimeSeriesDatumRequest) GetSensorId ¶
func (m *SetTimeSeriesDatumRequest) GetSensorId() int64
func (*SetTimeSeriesDatumRequest) GetTenantId ¶
func (m *SetTimeSeriesDatumRequest) GetTenantId() int64
func (*SetTimeSeriesDatumRequest) GetTimestamp ¶
func (m *SetTimeSeriesDatumRequest) GetTimestamp() *timestamp.Timestamp
func (*SetTimeSeriesDatumRequest) GetValue ¶
func (m *SetTimeSeriesDatumRequest) GetValue() float64
func (*SetTimeSeriesDatumRequest) ProtoMessage ¶
func (*SetTimeSeriesDatumRequest) ProtoMessage()
func (*SetTimeSeriesDatumRequest) Reset ¶
func (m *SetTimeSeriesDatumRequest) Reset()
func (*SetTimeSeriesDatumRequest) String ¶
func (m *SetTimeSeriesDatumRequest) String() string
func (*SetTimeSeriesDatumRequest) XXX_DiscardUnknown ¶
func (m *SetTimeSeriesDatumRequest) XXX_DiscardUnknown()
func (*SetTimeSeriesDatumRequest) XXX_Marshal ¶
func (m *SetTimeSeriesDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetTimeSeriesDatumRequest) XXX_Merge ¶
func (m *SetTimeSeriesDatumRequest) XXX_Merge(src proto.Message)
func (*SetTimeSeriesDatumRequest) XXX_Size ¶
func (m *SetTimeSeriesDatumRequest) XXX_Size() int
func (*SetTimeSeriesDatumRequest) XXX_Unmarshal ¶
func (m *SetTimeSeriesDatumRequest) XXX_Unmarshal(b []byte) error
type UnimplementedMikaponicsThingServer ¶
type UnimplementedMikaponicsThingServer struct { }
UnimplementedMikaponicsThingServer can be embedded to have forward compatible implementations.
func (*UnimplementedMikaponicsThingServer) SetSensor ¶
func (*UnimplementedMikaponicsThingServer) SetSensor(ctx context.Context, req *SetSensorRequest) (*SetSensorResponse, error)
func (*UnimplementedMikaponicsThingServer) SetThing ¶
func (*UnimplementedMikaponicsThingServer) SetThing(ctx context.Context, req *SetThingRequest) (*SetThingResponse, error)
func (*UnimplementedMikaponicsThingServer) SetTimeSeriesData ¶
func (*UnimplementedMikaponicsThingServer) SetTimeSeriesData(ctx context.Context, req *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error)
Click to show internal directories.
Click to hide internal directories.