Documentation
¶
Index ¶
- func RegisterAccountServer(s *grpc.Server, srv AccountServer)
- func RegisterThingServer(s *grpc.Server, srv ThingServer)
- type AccountClient
- type AccountServer
- type LoginRequest
- func (*LoginRequest) Descriptor() ([]byte, []int)
- func (m *LoginRequest) GetEmail() string
- func (m *LoginRequest) GetPassword() string
- func (*LoginRequest) ProtoMessage()
- func (m *LoginRequest) Reset()
- func (m *LoginRequest) String() string
- func (m *LoginRequest) XXX_DiscardUnknown()
- func (m *LoginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoginRequest) XXX_Merge(src proto.Message)
- func (m *LoginRequest) XXX_Size() int
- func (m *LoginRequest) XXX_Unmarshal(b []byte) error
- type LoginResponse
- func (*LoginResponse) Descriptor() ([]byte, []int)
- func (m *LoginResponse) GetStatus() bool
- func (m *LoginResponse) GetToken() string
- func (*LoginResponse) ProtoMessage()
- func (m *LoginResponse) Reset()
- func (m *LoginResponse) String() string
- func (m *LoginResponse) XXX_DiscardUnknown()
- func (m *LoginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoginResponse) XXX_Merge(src proto.Message)
- func (m *LoginResponse) XXX_Size() int
- func (m *LoginResponse) XXX_Unmarshal(b []byte) error
- type RefreshAccessTokenRequest
- func (*RefreshAccessTokenRequest) Descriptor() ([]byte, []int)
- func (m *RefreshAccessTokenRequest) GetToken() string
- func (*RefreshAccessTokenRequest) ProtoMessage()
- func (m *RefreshAccessTokenRequest) Reset()
- func (m *RefreshAccessTokenRequest) String() string
- func (m *RefreshAccessTokenRequest) XXX_DiscardUnknown()
- func (m *RefreshAccessTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RefreshAccessTokenRequest) XXX_Merge(src proto.Message)
- func (m *RefreshAccessTokenRequest) XXX_Size() int
- func (m *RefreshAccessTokenRequest) XXX_Unmarshal(b []byte) error
- type RefreshAccessTokenResponse
- func (*RefreshAccessTokenResponse) Descriptor() ([]byte, []int)
- func (m *RefreshAccessTokenResponse) GetExpiresAt() *timestamp.Timestamp
- func (m *RefreshAccessTokenResponse) GetStatus() bool
- func (m *RefreshAccessTokenResponse) GetThingId() int64
- func (m *RefreshAccessTokenResponse) GetUserId() int64
- func (*RefreshAccessTokenResponse) ProtoMessage()
- func (m *RefreshAccessTokenResponse) Reset()
- func (m *RefreshAccessTokenResponse) String() string
- func (m *RefreshAccessTokenResponse) XXX_DiscardUnknown()
- func (m *RefreshAccessTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RefreshAccessTokenResponse) XXX_Merge(src proto.Message)
- func (m *RefreshAccessTokenResponse) XXX_Size() int
- func (m *RefreshAccessTokenResponse) XXX_Unmarshal(b []byte) error
- 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 ThingClient
- type ThingServer
- type UnimplementedAccountServer
- func (*UnimplementedAccountServer) Login(ctx context.Context, req *LoginRequest) (*LoginResponse, error)
- func (*UnimplementedAccountServer) RefreshAccessToken(ctx context.Context, req *RefreshAccessTokenRequest) (*RefreshAccessTokenResponse, error)
- func (*UnimplementedAccountServer) VerifyAccessToken(ctx context.Context, req *VerifyAccessTokenRequest) (*VerifyAccessTokenResponse, error)
- type UnimplementedThingServer
- func (*UnimplementedThingServer) SetSensor(ctx context.Context, req *SetSensorRequest) (*SetSensorResponse, error)
- func (*UnimplementedThingServer) SetThing(ctx context.Context, req *SetThingRequest) (*SetThingResponse, error)
- func (*UnimplementedThingServer) SetTimeSeriesData(ctx context.Context, req *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error)
- type VerifyAccessTokenRequest
- func (*VerifyAccessTokenRequest) Descriptor() ([]byte, []int)
- func (m *VerifyAccessTokenRequest) GetToken() string
- func (*VerifyAccessTokenRequest) ProtoMessage()
- func (m *VerifyAccessTokenRequest) Reset()
- func (m *VerifyAccessTokenRequest) String() string
- func (m *VerifyAccessTokenRequest) XXX_DiscardUnknown()
- func (m *VerifyAccessTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VerifyAccessTokenRequest) XXX_Merge(src proto.Message)
- func (m *VerifyAccessTokenRequest) XXX_Size() int
- func (m *VerifyAccessTokenRequest) XXX_Unmarshal(b []byte) error
- type VerifyAccessTokenResponse
- func (*VerifyAccessTokenResponse) Descriptor() ([]byte, []int)
- func (m *VerifyAccessTokenResponse) GetExpiresAt() *timestamp.Timestamp
- func (m *VerifyAccessTokenResponse) GetStatus() bool
- func (m *VerifyAccessTokenResponse) GetThingId() int64
- func (m *VerifyAccessTokenResponse) GetUserId() int64
- func (*VerifyAccessTokenResponse) ProtoMessage()
- func (m *VerifyAccessTokenResponse) Reset()
- func (m *VerifyAccessTokenResponse) String() string
- func (m *VerifyAccessTokenResponse) XXX_DiscardUnknown()
- func (m *VerifyAccessTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VerifyAccessTokenResponse) XXX_Merge(src proto.Message)
- func (m *VerifyAccessTokenResponse) XXX_Size() int
- func (m *VerifyAccessTokenResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAccountServer ¶
func RegisterAccountServer(s *grpc.Server, srv AccountServer)
func RegisterThingServer ¶
func RegisterThingServer(s *grpc.Server, srv ThingServer)
Types ¶
type AccountClient ¶
type AccountClient interface { Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error) VerifyAccessToken(ctx context.Context, in *VerifyAccessTokenRequest, opts ...grpc.CallOption) (*VerifyAccessTokenResponse, error) RefreshAccessToken(ctx context.Context, in *RefreshAccessTokenRequest, opts ...grpc.CallOption) (*RefreshAccessTokenResponse, error) }
AccountClient is the client API for Account service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAccountClient ¶
func NewAccountClient(cc *grpc.ClientConn) AccountClient
type AccountServer ¶
type AccountServer interface { Login(context.Context, *LoginRequest) (*LoginResponse, error) VerifyAccessToken(context.Context, *VerifyAccessTokenRequest) (*VerifyAccessTokenResponse, error) RefreshAccessToken(context.Context, *RefreshAccessTokenRequest) (*RefreshAccessTokenResponse, error) }
AccountServer is the server API for Account service.
type LoginRequest ¶
type LoginRequest struct { Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoginRequest) Descriptor ¶
func (*LoginRequest) Descriptor() ([]byte, []int)
func (*LoginRequest) GetEmail ¶
func (m *LoginRequest) GetEmail() string
func (*LoginRequest) GetPassword ¶
func (m *LoginRequest) GetPassword() string
func (*LoginRequest) ProtoMessage ¶
func (*LoginRequest) ProtoMessage()
func (*LoginRequest) Reset ¶
func (m *LoginRequest) Reset()
func (*LoginRequest) String ¶
func (m *LoginRequest) String() string
func (*LoginRequest) XXX_DiscardUnknown ¶
func (m *LoginRequest) XXX_DiscardUnknown()
func (*LoginRequest) XXX_Marshal ¶
func (m *LoginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoginRequest) XXX_Merge ¶
func (m *LoginRequest) XXX_Merge(src proto.Message)
func (*LoginRequest) XXX_Size ¶
func (m *LoginRequest) XXX_Size() int
func (*LoginRequest) XXX_Unmarshal ¶
func (m *LoginRequest) XXX_Unmarshal(b []byte) error
type LoginResponse ¶
type LoginResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoginResponse) Descriptor ¶
func (*LoginResponse) Descriptor() ([]byte, []int)
func (*LoginResponse) GetStatus ¶
func (m *LoginResponse) GetStatus() bool
func (*LoginResponse) GetToken ¶
func (m *LoginResponse) GetToken() string
func (*LoginResponse) ProtoMessage ¶
func (*LoginResponse) ProtoMessage()
func (*LoginResponse) Reset ¶
func (m *LoginResponse) Reset()
func (*LoginResponse) String ¶
func (m *LoginResponse) String() string
func (*LoginResponse) XXX_DiscardUnknown ¶
func (m *LoginResponse) XXX_DiscardUnknown()
func (*LoginResponse) XXX_Marshal ¶
func (m *LoginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoginResponse) XXX_Merge ¶
func (m *LoginResponse) XXX_Merge(src proto.Message)
func (*LoginResponse) XXX_Size ¶
func (m *LoginResponse) XXX_Size() int
func (*LoginResponse) XXX_Unmarshal ¶
func (m *LoginResponse) XXX_Unmarshal(b []byte) error
type RefreshAccessTokenRequest ¶
type RefreshAccessTokenRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RefreshAccessTokenRequest) Descriptor ¶
func (*RefreshAccessTokenRequest) Descriptor() ([]byte, []int)
func (*RefreshAccessTokenRequest) GetToken ¶
func (m *RefreshAccessTokenRequest) GetToken() string
func (*RefreshAccessTokenRequest) ProtoMessage ¶
func (*RefreshAccessTokenRequest) ProtoMessage()
func (*RefreshAccessTokenRequest) Reset ¶
func (m *RefreshAccessTokenRequest) Reset()
func (*RefreshAccessTokenRequest) String ¶
func (m *RefreshAccessTokenRequest) String() string
func (*RefreshAccessTokenRequest) XXX_DiscardUnknown ¶
func (m *RefreshAccessTokenRequest) XXX_DiscardUnknown()
func (*RefreshAccessTokenRequest) XXX_Marshal ¶
func (m *RefreshAccessTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RefreshAccessTokenRequest) XXX_Merge ¶
func (m *RefreshAccessTokenRequest) XXX_Merge(src proto.Message)
func (*RefreshAccessTokenRequest) XXX_Size ¶
func (m *RefreshAccessTokenRequest) XXX_Size() int
func (*RefreshAccessTokenRequest) XXX_Unmarshal ¶
func (m *RefreshAccessTokenRequest) XXX_Unmarshal(b []byte) error
type RefreshAccessTokenResponse ¶
type RefreshAccessTokenResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` ThingId int64 `protobuf:"varint,3,opt,name=thing_id,json=thingId,proto3" json:"thing_id,omitempty"` ExpiresAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RefreshAccessTokenResponse) Descriptor ¶
func (*RefreshAccessTokenResponse) Descriptor() ([]byte, []int)
func (*RefreshAccessTokenResponse) GetExpiresAt ¶
func (m *RefreshAccessTokenResponse) GetExpiresAt() *timestamp.Timestamp
func (*RefreshAccessTokenResponse) GetStatus ¶
func (m *RefreshAccessTokenResponse) GetStatus() bool
func (*RefreshAccessTokenResponse) GetThingId ¶
func (m *RefreshAccessTokenResponse) GetThingId() int64
func (*RefreshAccessTokenResponse) GetUserId ¶
func (m *RefreshAccessTokenResponse) GetUserId() int64
func (*RefreshAccessTokenResponse) ProtoMessage ¶
func (*RefreshAccessTokenResponse) ProtoMessage()
func (*RefreshAccessTokenResponse) Reset ¶
func (m *RefreshAccessTokenResponse) Reset()
func (*RefreshAccessTokenResponse) String ¶
func (m *RefreshAccessTokenResponse) String() string
func (*RefreshAccessTokenResponse) XXX_DiscardUnknown ¶
func (m *RefreshAccessTokenResponse) XXX_DiscardUnknown()
func (*RefreshAccessTokenResponse) XXX_Marshal ¶
func (m *RefreshAccessTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RefreshAccessTokenResponse) XXX_Merge ¶
func (m *RefreshAccessTokenResponse) XXX_Merge(src proto.Message)
func (*RefreshAccessTokenResponse) XXX_Size ¶
func (m *RefreshAccessTokenResponse) XXX_Size() int
func (*RefreshAccessTokenResponse) XXX_Unmarshal ¶
func (m *RefreshAccessTokenResponse) XXX_Unmarshal(b []byte) error
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 ThingClient ¶
type ThingClient 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) }
ThingClient is the client API for Thing service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewThingClient ¶
func NewThingClient(cc *grpc.ClientConn) ThingClient
type ThingServer ¶
type ThingServer interface { SetTimeSeriesData(context.Context, *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error) SetSensor(context.Context, *SetSensorRequest) (*SetSensorResponse, error) SetThing(context.Context, *SetThingRequest) (*SetThingResponse, error) }
ThingServer is the server API for Thing service.
type UnimplementedAccountServer ¶
type UnimplementedAccountServer struct { }
UnimplementedAccountServer can be embedded to have forward compatible implementations.
func (*UnimplementedAccountServer) Login ¶
func (*UnimplementedAccountServer) Login(ctx context.Context, req *LoginRequest) (*LoginResponse, error)
func (*UnimplementedAccountServer) RefreshAccessToken ¶
func (*UnimplementedAccountServer) RefreshAccessToken(ctx context.Context, req *RefreshAccessTokenRequest) (*RefreshAccessTokenResponse, error)
func (*UnimplementedAccountServer) VerifyAccessToken ¶
func (*UnimplementedAccountServer) VerifyAccessToken(ctx context.Context, req *VerifyAccessTokenRequest) (*VerifyAccessTokenResponse, error)
type UnimplementedThingServer ¶
type UnimplementedThingServer struct { }
UnimplementedThingServer can be embedded to have forward compatible implementations.
func (*UnimplementedThingServer) SetSensor ¶
func (*UnimplementedThingServer) SetSensor(ctx context.Context, req *SetSensorRequest) (*SetSensorResponse, error)
func (*UnimplementedThingServer) SetThing ¶
func (*UnimplementedThingServer) SetThing(ctx context.Context, req *SetThingRequest) (*SetThingResponse, error)
func (*UnimplementedThingServer) SetTimeSeriesData ¶
func (*UnimplementedThingServer) SetTimeSeriesData(ctx context.Context, req *SetTimeSeriesDataRequest) (*SetTimeSeriesDataResponse, error)
type VerifyAccessTokenRequest ¶
type VerifyAccessTokenRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VerifyAccessTokenRequest) Descriptor ¶
func (*VerifyAccessTokenRequest) Descriptor() ([]byte, []int)
func (*VerifyAccessTokenRequest) GetToken ¶
func (m *VerifyAccessTokenRequest) GetToken() string
func (*VerifyAccessTokenRequest) ProtoMessage ¶
func (*VerifyAccessTokenRequest) ProtoMessage()
func (*VerifyAccessTokenRequest) Reset ¶
func (m *VerifyAccessTokenRequest) Reset()
func (*VerifyAccessTokenRequest) String ¶
func (m *VerifyAccessTokenRequest) String() string
func (*VerifyAccessTokenRequest) XXX_DiscardUnknown ¶
func (m *VerifyAccessTokenRequest) XXX_DiscardUnknown()
func (*VerifyAccessTokenRequest) XXX_Marshal ¶
func (m *VerifyAccessTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VerifyAccessTokenRequest) XXX_Merge ¶
func (m *VerifyAccessTokenRequest) XXX_Merge(src proto.Message)
func (*VerifyAccessTokenRequest) XXX_Size ¶
func (m *VerifyAccessTokenRequest) XXX_Size() int
func (*VerifyAccessTokenRequest) XXX_Unmarshal ¶
func (m *VerifyAccessTokenRequest) XXX_Unmarshal(b []byte) error
type VerifyAccessTokenResponse ¶
type VerifyAccessTokenResponse struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` ThingId int64 `protobuf:"varint,3,opt,name=thing_id,json=thingId,proto3" json:"thing_id,omitempty"` ExpiresAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VerifyAccessTokenResponse) Descriptor ¶
func (*VerifyAccessTokenResponse) Descriptor() ([]byte, []int)
func (*VerifyAccessTokenResponse) GetExpiresAt ¶
func (m *VerifyAccessTokenResponse) GetExpiresAt() *timestamp.Timestamp
func (*VerifyAccessTokenResponse) GetStatus ¶
func (m *VerifyAccessTokenResponse) GetStatus() bool
func (*VerifyAccessTokenResponse) GetThingId ¶
func (m *VerifyAccessTokenResponse) GetThingId() int64
func (*VerifyAccessTokenResponse) GetUserId ¶
func (m *VerifyAccessTokenResponse) GetUserId() int64
func (*VerifyAccessTokenResponse) ProtoMessage ¶
func (*VerifyAccessTokenResponse) ProtoMessage()
func (*VerifyAccessTokenResponse) Reset ¶
func (m *VerifyAccessTokenResponse) Reset()
func (*VerifyAccessTokenResponse) String ¶
func (m *VerifyAccessTokenResponse) String() string
func (*VerifyAccessTokenResponse) XXX_DiscardUnknown ¶
func (m *VerifyAccessTokenResponse) XXX_DiscardUnknown()
func (*VerifyAccessTokenResponse) XXX_Marshal ¶
func (m *VerifyAccessTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VerifyAccessTokenResponse) XXX_Merge ¶
func (m *VerifyAccessTokenResponse) XXX_Merge(src proto.Message)
func (*VerifyAccessTokenResponse) XXX_Size ¶
func (m *VerifyAccessTokenResponse) XXX_Size() int
func (*VerifyAccessTokenResponse) XXX_Unmarshal ¶
func (m *VerifyAccessTokenResponse) XXX_Unmarshal(b []byte) error