iotgrpcapi

package

Go to main page

Versions in this module

v1

deprecated

v1.4.4

Sep 3, 2018

v1.4.1

Aug 31, 2018

v1.4.0

Aug 29, 2018

v1.3.2

Aug 28, 2018

v1.3.1

Aug 23, 2018

Changes in this version

type TaskDescription

+ LongId uint64

+ func (m *TaskDescription) GetLongId() uint64

v1.3.0

Aug 23, 2018

Changes in this version

+ type GetTaskByLongIdInput struct

+ TaskId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskByLongIdInput) Descriptor() ([]byte, []int)

+ func (*GetTaskByLongIdInput) ProtoMessage()

+ func (dst *GetTaskByLongIdInput) XXX_Merge(src proto.Message)

+ func (m *GetTaskByLongIdInput) GetTaskId() uint64

+ func (m *GetTaskByLongIdInput) Reset()

+ func (m *GetTaskByLongIdInput) String() string

+ func (m *GetTaskByLongIdInput) XXX_DiscardUnknown()

+ func (m *GetTaskByLongIdInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskByLongIdInput) XXX_Size() int

+ func (m *GetTaskByLongIdInput) XXX_Unmarshal(b []byte) error

+ type GetTaskByLongIdOutput struct

+ Task *TaskDescription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskByLongIdOutput) Descriptor() ([]byte, []int)

+ func (*GetTaskByLongIdOutput) ProtoMessage()

+ func (dst *GetTaskByLongIdOutput) XXX_Merge(src proto.Message)

+ func (m *GetTaskByLongIdOutput) GetTask() *TaskDescription

+ func (m *GetTaskByLongIdOutput) Reset()

+ func (m *GetTaskByLongIdOutput) String() string

+ func (m *GetTaskByLongIdOutput) XXX_DiscardUnknown()

+ func (m *GetTaskByLongIdOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskByLongIdOutput) XXX_Size() int

+ func (m *GetTaskByLongIdOutput) XXX_Unmarshal(b []byte) error

+ type GetTaskByUUIDInput struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskByUUIDInput) Descriptor() ([]byte, []int)

+ func (*GetTaskByUUIDInput) ProtoMessage()

+ func (dst *GetTaskByUUIDInput) XXX_Merge(src proto.Message)

+ func (m *GetTaskByUUIDInput) GetTaskId() string

+ func (m *GetTaskByUUIDInput) Reset()

+ func (m *GetTaskByUUIDInput) String() string

+ func (m *GetTaskByUUIDInput) XXX_DiscardUnknown()

+ func (m *GetTaskByUUIDInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskByUUIDInput) XXX_Size() int

+ func (m *GetTaskByUUIDInput) XXX_Unmarshal(b []byte) error

+ type GetTaskByUUIDOutput struct

+ Task *TaskDescription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskByUUIDOutput) Descriptor() ([]byte, []int)

+ func (*GetTaskByUUIDOutput) ProtoMessage()

+ func (dst *GetTaskByUUIDOutput) XXX_Merge(src proto.Message)

+ func (m *GetTaskByUUIDOutput) GetTask() *TaskDescription

+ func (m *GetTaskByUUIDOutput) Reset()

+ func (m *GetTaskByUUIDOutput) String() string

+ func (m *GetTaskByUUIDOutput) XXX_DiscardUnknown()

+ func (m *GetTaskByUUIDOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskByUUIDOutput) XXX_Size() int

+ func (m *GetTaskByUUIDOutput) XXX_Unmarshal(b []byte) error

type IoTClient

+ GetTaskByLongId func(ctx context.Context, in *GetTaskByLongIdInput, opts ...grpc.CallOption) (*GetTaskByLongIdOutput, error)

+ GetTaskByUUID func(ctx context.Context, in *GetTaskByUUIDInput, opts ...grpc.CallOption) (*GetTaskByUUIDOutput, error)

type IoTServer

+ GetTaskByLongId func(context.Context, *GetTaskByLongIdInput) (*GetTaskByLongIdOutput, error)

+ GetTaskByUUID func(context.Context, *GetTaskByUUIDInput) (*GetTaskByUUIDOutput, error)

v1.2.0

Aug 23, 2018

Changes in this version

+ type GetTasksByStatusInput struct

+ HierarchyId string

+ Status TaskStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTasksByStatusInput) Descriptor() ([]byte, []int)

+ func (*GetTasksByStatusInput) ProtoMessage()

+ func (dst *GetTasksByStatusInput) XXX_Merge(src proto.Message)

+ func (m *GetTasksByStatusInput) GetHierarchyId() string

+ func (m *GetTasksByStatusInput) GetStatus() TaskStatus

+ func (m *GetTasksByStatusInput) Reset()

+ func (m *GetTasksByStatusInput) String() string

+ func (m *GetTasksByStatusInput) XXX_DiscardUnknown()

+ func (m *GetTasksByStatusInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTasksByStatusInput) XXX_Size() int

+ func (m *GetTasksByStatusInput) XXX_Unmarshal(b []byte) error

+ type GetTasksByStatusOutput struct

+ TaskList []*TaskDescription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTasksByStatusOutput) Descriptor() ([]byte, []int)

+ func (*GetTasksByStatusOutput) ProtoMessage()

+ func (dst *GetTasksByStatusOutput) XXX_Merge(src proto.Message)

+ func (m *GetTasksByStatusOutput) GetTaskList() []*TaskDescription

+ func (m *GetTasksByStatusOutput) Reset()

+ func (m *GetTasksByStatusOutput) String() string

+ func (m *GetTasksByStatusOutput) XXX_DiscardUnknown()

+ func (m *GetTasksByStatusOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTasksByStatusOutput) XXX_Size() int

+ func (m *GetTasksByStatusOutput) XXX_Unmarshal(b []byte) error

type IoTClient

+ GetTasksByStatus func(ctx context.Context, in *GetTasksByStatusInput, opts ...grpc.CallOption) (*GetTasksByStatusOutput, error)

type IoTServer

+ GetTasksByStatus func(context.Context, *GetTasksByStatusInput) (*GetTasksByStatusOutput, error)

v1.1.3

Aug 20, 2018

v1.1.2

Aug 17, 2018

v1.1.1

Aug 15, 2018

v1.1.0

Aug 15, 2018

v1.0.4

Aug 15, 2018

Changes in this version

+ var MediaType_name = map[int32]string

+ var MediaType_value = map[string]int32

+ type GetMediaInput struct

+ MediaId string

+ NodeId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetMediaInput) Descriptor() ([]byte, []int)

+ func (*GetMediaInput) ProtoMessage()

+ func (dst *GetMediaInput) XXX_Merge(src proto.Message)

+ func (m *GetMediaInput) GetMediaId() string

+ func (m *GetMediaInput) GetNodeId() string

+ func (m *GetMediaInput) Reset()

+ func (m *GetMediaInput) String() string

+ func (m *GetMediaInput) XXX_DiscardUnknown()

+ func (m *GetMediaInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMediaInput) XXX_Size() int

+ func (m *GetMediaInput) XXX_Unmarshal(b []byte) error

+ type GetMediaOutput struct

+ Media *Media

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetMediaOutput) Descriptor() ([]byte, []int)

+ func (*GetMediaOutput) ProtoMessage()

+ func (dst *GetMediaOutput) XXX_Merge(src proto.Message)

+ func (m *GetMediaOutput) GetMedia() *Media

+ func (m *GetMediaOutput) Reset()

+ func (m *GetMediaOutput) String() string

+ func (m *GetMediaOutput) XXX_DiscardUnknown()

+ func (m *GetMediaOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMediaOutput) XXX_Size() int

+ func (m *GetMediaOutput) XXX_Unmarshal(b []byte) error

type IoTClient

+ GetMedia func(ctx context.Context, in *GetMediaInput, opts ...grpc.CallOption) (*GetMediaOutput, error)

type IoTServer

+ GetMedia func(context.Context, *GetMediaInput) (*GetMediaOutput, error)

+ type Media struct

+ Id string

+ Media []byte

+ Type MediaType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Media) Descriptor() ([]byte, []int)

+ func (*Media) ProtoMessage()

+ func (dst *Media) XXX_Merge(src proto.Message)

+ func (m *Media) GetId() string

+ func (m *Media) GetMedia() []byte

+ func (m *Media) GetType() MediaType

+ func (m *Media) Reset()

+ func (m *Media) String() string

+ func (m *Media) XXX_DiscardUnknown()

+ func (m *Media) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Media) XXX_Size() int

+ func (m *Media) XXX_Unmarshal(b []byte) error

+ type MediaType int32

+ const MediaType_AUDIO_WAV

+ const MediaType_IMAGE_JPEG

+ const MediaType_IMAGE_PNG

+ const MediaType_UNKNOWN

+ func (MediaType) EnumDescriptor() ([]byte, []int)

+ func (x MediaType) String() string

type NodeData

+ MediaV2 *Media

+ func (m *NodeData) GetMediaV2() *Media

type NodeDataContentType

+ const NodeDataContentType_MEDIA_V2

v1.0.3

Aug 11, 2018

v1.0.2

Aug 8, 2018

v1.0.1

Aug 8, 2018

v1.0.0

Aug 8, 2018

Changes in this version

+ var NodeDataContentType_name = map[int32]string

+ var NodeDataContentType_value = map[string]int32

+ var TaskStatus_name = map[int32]string

+ var TaskStatus_value = map[string]int32

+ func RegisterIoTServer(s *grpc.Server, srv IoTServer)

+ type Coordinate struct

+ X float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ Y float64

+ func (*Coordinate) Descriptor() ([]byte, []int)

+ func (*Coordinate) ProtoMessage()

+ func (dst *Coordinate) XXX_Merge(src proto.Message)

+ func (m *Coordinate) GetX() float64

+ func (m *Coordinate) GetY() float64

+ func (m *Coordinate) Reset()

+ func (m *Coordinate) String() string

+ func (m *Coordinate) XXX_DiscardUnknown()

+ func (m *Coordinate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Coordinate) XXX_Size() int

+ func (m *Coordinate) XXX_Unmarshal(b []byte) error

+ type DataPoint struct

+ Coordinate *Coordinate

+ XUnit string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ YUnit string

+ func (*DataPoint) Descriptor() ([]byte, []int)

+ func (*DataPoint) ProtoMessage()

+ func (dst *DataPoint) XXX_Merge(src proto.Message)

+ func (m *DataPoint) GetCoordinate() *Coordinate

+ func (m *DataPoint) GetXUnit() string

+ func (m *DataPoint) GetYUnit() string

+ func (m *DataPoint) Reset()

+ func (m *DataPoint) String() string

+ func (m *DataPoint) XXX_DiscardUnknown()

+ func (m *DataPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataPoint) XXX_Size() int

+ func (m *DataPoint) XXX_Unmarshal(b []byte) error

+ type FunctionalLocationIds struct

+ IdArr []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FunctionalLocationIds) Descriptor() ([]byte, []int)

+ func (*FunctionalLocationIds) ProtoMessage()

+ func (dst *FunctionalLocationIds) XXX_Merge(src proto.Message)

+ func (m *FunctionalLocationIds) GetIdArr() []string

+ func (m *FunctionalLocationIds) Reset()

+ func (m *FunctionalLocationIds) String() string

+ func (m *FunctionalLocationIds) XXX_DiscardUnknown()

+ func (m *FunctionalLocationIds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FunctionalLocationIds) XXX_Size() int

+ func (m *FunctionalLocationIds) XXX_Unmarshal(b []byte) error

+ type GetLatestNodeDataInput struct

+ ContentType NodeDataContentType

+ NodeId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetLatestNodeDataInput) Descriptor() ([]byte, []int)

+ func (*GetLatestNodeDataInput) ProtoMessage()

+ func (dst *GetLatestNodeDataInput) XXX_Merge(src proto.Message)

+ func (m *GetLatestNodeDataInput) GetContentType() NodeDataContentType

+ func (m *GetLatestNodeDataInput) GetNodeId() string

+ func (m *GetLatestNodeDataInput) Reset()

+ func (m *GetLatestNodeDataInput) String() string

+ func (m *GetLatestNodeDataInput) XXX_DiscardUnknown()

+ func (m *GetLatestNodeDataInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetLatestNodeDataInput) XXX_Size() int

+ func (m *GetLatestNodeDataInput) XXX_Unmarshal(b []byte) error

+ type GetLatestNodeDataOutput struct

+ NodeData *NodeData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetLatestNodeDataOutput) Descriptor() ([]byte, []int)

+ func (*GetLatestNodeDataOutput) ProtoMessage()

+ func (dst *GetLatestNodeDataOutput) XXX_Merge(src proto.Message)

+ func (m *GetLatestNodeDataOutput) GetNodeData() *NodeData

+ func (m *GetLatestNodeDataOutput) Reset()

+ func (m *GetLatestNodeDataOutput) String() string

+ func (m *GetLatestNodeDataOutput) XXX_DiscardUnknown()

+ func (m *GetLatestNodeDataOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetLatestNodeDataOutput) XXX_Size() int

+ func (m *GetLatestNodeDataOutput) XXX_Unmarshal(b []byte) error

+ type GetNodeDataInput struct

+ ContentType NodeDataContentType

+ NodeId string

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNodeDataInput) Descriptor() ([]byte, []int)

+ func (*GetNodeDataInput) ProtoMessage()

+ func (dst *GetNodeDataInput) XXX_Merge(src proto.Message)

+ func (m *GetNodeDataInput) GetContentType() NodeDataContentType

+ func (m *GetNodeDataInput) GetNodeId() string

+ func (m *GetNodeDataInput) GetTimestamp() int64

+ func (m *GetNodeDataInput) Reset()

+ func (m *GetNodeDataInput) String() string

+ func (m *GetNodeDataInput) XXX_DiscardUnknown()

+ func (m *GetNodeDataInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetNodeDataInput) XXX_Size() int

+ func (m *GetNodeDataInput) XXX_Unmarshal(b []byte) error

+ type GetNodeDataOutput struct

+ NodeDataList []*NodeData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNodeDataOutput) Descriptor() ([]byte, []int)

+ func (*GetNodeDataOutput) ProtoMessage()

+ func (dst *GetNodeDataOutput) XXX_Merge(src proto.Message)

+ func (m *GetNodeDataOutput) GetNodeDataList() []*NodeData

+ func (m *GetNodeDataOutput) Reset()

+ func (m *GetNodeDataOutput) String() string

+ func (m *GetNodeDataOutput) XXX_DiscardUnknown()

+ func (m *GetNodeDataOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetNodeDataOutput) XXX_Size() int

+ func (m *GetNodeDataOutput) XXX_Unmarshal(b []byte) error

+ type GetNodeDataStreamInput struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNodeDataStreamInput) Descriptor() ([]byte, []int)

+ func (*GetNodeDataStreamInput) ProtoMessage()

+ func (dst *GetNodeDataStreamInput) XXX_Merge(src proto.Message)

+ func (m *GetNodeDataStreamInput) Reset()

+ func (m *GetNodeDataStreamInput) String() string

+ func (m *GetNodeDataStreamInput) XXX_DiscardUnknown()

+ func (m *GetNodeDataStreamInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetNodeDataStreamInput) XXX_Size() int

+ func (m *GetNodeDataStreamInput) XXX_Unmarshal(b []byte) error

+ type GetNodeDataStreamOutput struct

+ NodeData *NodeData

+ NodeId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNodeDataStreamOutput) Descriptor() ([]byte, []int)

+ func (*GetNodeDataStreamOutput) ProtoMessage()

+ func (dst *GetNodeDataStreamOutput) XXX_Merge(src proto.Message)

+ func (m *GetNodeDataStreamOutput) GetNodeData() *NodeData

+ func (m *GetNodeDataStreamOutput) GetNodeId() string

+ func (m *GetNodeDataStreamOutput) Reset()

+ func (m *GetNodeDataStreamOutput) String() string

+ func (m *GetNodeDataStreamOutput) XXX_DiscardUnknown()

+ func (m *GetNodeDataStreamOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetNodeDataStreamOutput) XXX_Size() int

+ func (m *GetNodeDataStreamOutput) XXX_Unmarshal(b []byte) error

+ type GetTaskStreamInput struct

+ HierarchyId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskStreamInput) Descriptor() ([]byte, []int)

+ func (*GetTaskStreamInput) ProtoMessage()

+ func (dst *GetTaskStreamInput) XXX_Merge(src proto.Message)

+ func (m *GetTaskStreamInput) GetHierarchyId() string

+ func (m *GetTaskStreamInput) Reset()

+ func (m *GetTaskStreamInput) String() string

+ func (m *GetTaskStreamInput) XXX_DiscardUnknown()

+ func (m *GetTaskStreamInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskStreamInput) XXX_Size() int

+ func (m *GetTaskStreamInput) XXX_Unmarshal(b []byte) error

+ type GetTaskStreamOutput struct

+ Task *TaskDescription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskStreamOutput) Descriptor() ([]byte, []int)

+ func (*GetTaskStreamOutput) ProtoMessage()

+ func (dst *GetTaskStreamOutput) XXX_Merge(src proto.Message)

+ func (m *GetTaskStreamOutput) GetTask() *TaskDescription

+ func (m *GetTaskStreamOutput) Reset()

+ func (m *GetTaskStreamOutput) String() string

+ func (m *GetTaskStreamOutput) XXX_DiscardUnknown()

+ func (m *GetTaskStreamOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTaskStreamOutput) XXX_Size() int

+ func (m *GetTaskStreamOutput) XXX_Unmarshal(b []byte) error

+ type IngestNodeDataInput struct

+ NodeData *NodeData

+ NodeId string

+ Origin *Origin

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IngestNodeDataInput) Descriptor() ([]byte, []int)

+ func (*IngestNodeDataInput) ProtoMessage()

+ func (dst *IngestNodeDataInput) XXX_Merge(src proto.Message)

+ func (m *IngestNodeDataInput) GetNodeData() *NodeData

+ func (m *IngestNodeDataInput) GetNodeId() string

+ func (m *IngestNodeDataInput) GetOrigin() *Origin

+ func (m *IngestNodeDataInput) Reset()

+ func (m *IngestNodeDataInput) String() string

+ func (m *IngestNodeDataInput) XXX_DiscardUnknown()

+ func (m *IngestNodeDataInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IngestNodeDataInput) XXX_Size() int

+ func (m *IngestNodeDataInput) XXX_Unmarshal(b []byte) error

+ type IngestNodeDataOutput struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IngestNodeDataOutput) Descriptor() ([]byte, []int)

+ func (*IngestNodeDataOutput) ProtoMessage()

+ func (dst *IngestNodeDataOutput) XXX_Merge(src proto.Message)

+ func (m *IngestNodeDataOutput) Reset()

+ func (m *IngestNodeDataOutput) String() string

+ func (m *IngestNodeDataOutput) XXX_DiscardUnknown()

+ func (m *IngestNodeDataOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IngestNodeDataOutput) XXX_Size() int

+ func (m *IngestNodeDataOutput) XXX_Unmarshal(b []byte) error

+ type IngestNodeDataStreamInput struct

+ NodeDataList []*NodeData

+ NodeId string

+ Origin *Origin

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IngestNodeDataStreamInput) Descriptor() ([]byte, []int)

+ func (*IngestNodeDataStreamInput) ProtoMessage()

+ func (dst *IngestNodeDataStreamInput) XXX_Merge(src proto.Message)

+ func (m *IngestNodeDataStreamInput) GetNodeDataList() []*NodeData

+ func (m *IngestNodeDataStreamInput) GetNodeId() string

+ func (m *IngestNodeDataStreamInput) GetOrigin() *Origin

+ func (m *IngestNodeDataStreamInput) Reset()

+ func (m *IngestNodeDataStreamInput) String() string

+ func (m *IngestNodeDataStreamInput) XXX_DiscardUnknown()

+ func (m *IngestNodeDataStreamInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IngestNodeDataStreamInput) XXX_Size() int

+ func (m *IngestNodeDataStreamInput) XXX_Unmarshal(b []byte) error

+ type IngestNodeDataStreamOutput struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IngestNodeDataStreamOutput) Descriptor() ([]byte, []int)

+ func (*IngestNodeDataStreamOutput) ProtoMessage()

+ func (dst *IngestNodeDataStreamOutput) XXX_Merge(src proto.Message)

+ func (m *IngestNodeDataStreamOutput) Reset()

+ func (m *IngestNodeDataStreamOutput) String() string

+ func (m *IngestNodeDataStreamOutput) XXX_DiscardUnknown()

+ func (m *IngestNodeDataStreamOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IngestNodeDataStreamOutput) XXX_Size() int

+ func (m *IngestNodeDataStreamOutput) XXX_Unmarshal(b []byte) error

+ type InitialTaskDescription struct

+ DueDateTimestamp int64

+ ExternalTaskId string

+ FunctionalLocationIds *FunctionalLocationIds

+ HierarchyId string

+ Status TaskStatus

+ TaskName string

+ UserId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InitialTaskDescription) Descriptor() ([]byte, []int)

+ func (*InitialTaskDescription) ProtoMessage()

+ func (dst *InitialTaskDescription) XXX_Merge(src proto.Message)

+ func (m *InitialTaskDescription) GetDueDateTimestamp() int64

+ func (m *InitialTaskDescription) GetExternalTaskId() string

+ func (m *InitialTaskDescription) GetFunctionalLocationIds() *FunctionalLocationIds

+ func (m *InitialTaskDescription) GetHierarchyId() string

+ func (m *InitialTaskDescription) GetStatus() TaskStatus

+ func (m *InitialTaskDescription) GetTaskName() string

+ func (m *InitialTaskDescription) GetUserId() string

+ func (m *InitialTaskDescription) Reset()

+ func (m *InitialTaskDescription) String() string

+ func (m *InitialTaskDescription) XXX_DiscardUnknown()

+ func (m *InitialTaskDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InitialTaskDescription) XXX_Size() int

+ func (m *InitialTaskDescription) XXX_Unmarshal(b []byte) error

+ type IoTClient interface

+ CreateTask func(ctx context.Context, in *InitialTaskDescription, opts ...grpc.CallOption) (*PrimitiveString, error)

+ DeepPing func(ctx context.Context, in *PrimitiveVoid, opts ...grpc.CallOption) (*PrimitiveString, error)

+ DeleteTask func(ctx context.Context, in *TaskUser, opts ...grpc.CallOption) (*PrimitiveVoid, error)

+ GetAllTasks func(ctx context.Context, in *PrimitiveString, opts ...grpc.CallOption) (*TaskDescriptions, error)

+ GetLatestNodeData func(ctx context.Context, in *GetLatestNodeDataInput, opts ...grpc.CallOption) (*GetLatestNodeDataOutput, error)

+ GetNodeData func(ctx context.Context, in *GetNodeDataInput, opts ...grpc.CallOption) (*GetNodeDataOutput, error)

+ GetNodeDataStream func(ctx context.Context, in *GetNodeDataStreamInput, opts ...grpc.CallOption) (IoT_GetNodeDataStreamClient, error)

+ GetTaskStream func(ctx context.Context, in *GetTaskStreamInput, opts ...grpc.CallOption) (IoT_GetTaskStreamClient, error)

+ GetUncompletedTasks func(ctx context.Context, in *PrimitiveString, opts ...grpc.CallOption) (*TaskDescriptions, error)

+ GetUncompletedTasksByHierarchy func(ctx context.Context, in *PrimitiveString, opts ...grpc.CallOption) (*TaskDescriptions, error)

+ IngestNodeData func(ctx context.Context, in *IngestNodeDataInput, opts ...grpc.CallOption) (*IngestNodeDataOutput, error)

+ IngestNodeDataStream func(ctx context.Context, opts ...grpc.CallOption) (IoT_IngestNodeDataStreamClient, error)

+ SetTaskCompleted func(ctx context.Context, in *TaskUser, opts ...grpc.CallOption) (*PrimitiveVoid, error)

+ SetTaskStatus func(ctx context.Context, in *SetTaskStatusInput, opts ...grpc.CallOption) (*PrimitiveVoid, error)

+ func NewIoTClient(cc *grpc.ClientConn) IoTClient

+ type IoTServer interface

+ CreateTask func(context.Context, *InitialTaskDescription) (*PrimitiveString, error)

+ DeepPing func(context.Context, *PrimitiveVoid) (*PrimitiveString, error)

+ DeleteTask func(context.Context, *TaskUser) (*PrimitiveVoid, error)

+ GetAllTasks func(context.Context, *PrimitiveString) (*TaskDescriptions, error)

+ GetLatestNodeData func(context.Context, *GetLatestNodeDataInput) (*GetLatestNodeDataOutput, error)

+ GetNodeData func(context.Context, *GetNodeDataInput) (*GetNodeDataOutput, error)

+ GetNodeDataStream func(*GetNodeDataStreamInput, IoT_GetNodeDataStreamServer) error

+ GetTaskStream func(*GetTaskStreamInput, IoT_GetTaskStreamServer) error

+ GetUncompletedTasks func(context.Context, *PrimitiveString) (*TaskDescriptions, error)

+ GetUncompletedTasksByHierarchy func(context.Context, *PrimitiveString) (*TaskDescriptions, error)

+ IngestNodeData func(context.Context, *IngestNodeDataInput) (*IngestNodeDataOutput, error)

+ IngestNodeDataStream func(IoT_IngestNodeDataStreamServer) error

+ SetTaskCompleted func(context.Context, *TaskUser) (*PrimitiveVoid, error)

+ SetTaskStatus func(context.Context, *SetTaskStatusInput) (*PrimitiveVoid, error)

+ type IoT_GetNodeDataStreamClient interface

+ Recv func() (*GetNodeDataStreamOutput, error)

+ type IoT_GetNodeDataStreamServer interface

+ Send func(*GetNodeDataStreamOutput) error

+ type IoT_GetTaskStreamClient interface

+ Recv func() (*GetTaskStreamOutput, error)

+ type IoT_GetTaskStreamServer interface

+ Send func(*GetTaskStreamOutput) error

+ type IoT_IngestNodeDataStreamClient interface

+ CloseAndRecv func() (*IngestNodeDataStreamOutput, error)

+ Send func(*IngestNodeDataStreamInput) error

+ type IoT_IngestNodeDataStreamServer interface

+ Recv func() (*IngestNodeDataStreamInput, error)

+ SendAndClose func(*IngestNodeDataStreamOutput) error

+ type NodeData struct

+ ContentType NodeDataContentType

+ CreatedAt int64

+ DataPoint *DataPoint

+ Media []byte

+ Note string

+ QuestionAnswers []string

+ Spectrum *Spectrum

+ TimeSeries *TimeSeries

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeData) Descriptor() ([]byte, []int)

+ func (*NodeData) ProtoMessage()

+ func (dst *NodeData) XXX_Merge(src proto.Message)

+ func (m *NodeData) GetContentType() NodeDataContentType

+ func (m *NodeData) GetCreatedAt() int64

+ func (m *NodeData) GetDataPoint() *DataPoint

+ func (m *NodeData) GetMedia() []byte

+ func (m *NodeData) GetNote() string

+ func (m *NodeData) GetQuestionAnswers() []string

+ func (m *NodeData) GetSpectrum() *Spectrum

+ func (m *NodeData) GetTimeSeries() *TimeSeries

+ func (m *NodeData) Reset()

+ func (m *NodeData) String() string

+ func (m *NodeData) XXX_DiscardUnknown()

+ func (m *NodeData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeData) XXX_Size() int

+ func (m *NodeData) XXX_Unmarshal(b []byte) error

+ type NodeDataContentType int32

+ const NodeDataContentType_DATA_POINT

+ const NodeDataContentType_DEFAULT

+ const NodeDataContentType_MEDIA

+ const NodeDataContentType_NOTE

+ const NodeDataContentType_QUESTION_ANSWERS

+ const NodeDataContentType_SPECTRUM

+ const NodeDataContentType_TIME_SERIES

+ func (NodeDataContentType) EnumDescriptor() ([]byte, []int)

+ func (x NodeDataContentType) String() string

+ type Origin struct

+ Id string

+ Provider string

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Origin) Descriptor() ([]byte, []int)

+ func (*Origin) ProtoMessage()

+ func (dst *Origin) XXX_Merge(src proto.Message)

+ func (m *Origin) GetId() string

+ func (m *Origin) GetProvider() string

+ func (m *Origin) GetType() string

+ func (m *Origin) Reset()

+ func (m *Origin) String() string

+ func (m *Origin) XXX_DiscardUnknown()

+ func (m *Origin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Origin) XXX_Size() int

+ func (m *Origin) XXX_Unmarshal(b []byte) error

+ type PrimitiveBool struct

+ Value bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrimitiveBool) Descriptor() ([]byte, []int)

+ func (*PrimitiveBool) ProtoMessage()

+ func (dst *PrimitiveBool) XXX_Merge(src proto.Message)

+ func (m *PrimitiveBool) GetValue() bool

+ func (m *PrimitiveBool) Reset()

+ func (m *PrimitiveBool) String() string

+ func (m *PrimitiveBool) XXX_DiscardUnknown()

+ func (m *PrimitiveBool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrimitiveBool) XXX_Size() int

+ func (m *PrimitiveBool) XXX_Unmarshal(b []byte) error

+ type PrimitiveString struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrimitiveString) Descriptor() ([]byte, []int)

+ func (*PrimitiveString) ProtoMessage()

+ func (dst *PrimitiveString) XXX_Merge(src proto.Message)

+ func (m *PrimitiveString) GetValue() string

+ func (m *PrimitiveString) Reset()

+ func (m *PrimitiveString) String() string

+ func (m *PrimitiveString) XXX_DiscardUnknown()

+ func (m *PrimitiveString) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrimitiveString) XXX_Size() int

+ func (m *PrimitiveString) XXX_Unmarshal(b []byte) error

+ type PrimitiveVoid struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrimitiveVoid) Descriptor() ([]byte, []int)

+ func (*PrimitiveVoid) ProtoMessage()

+ func (dst *PrimitiveVoid) XXX_Merge(src proto.Message)

+ func (m *PrimitiveVoid) Reset()

+ func (m *PrimitiveVoid) String() string

+ func (m *PrimitiveVoid) XXX_DiscardUnknown()

+ func (m *PrimitiveVoid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrimitiveVoid) XXX_Size() int

+ func (m *PrimitiveVoid) XXX_Unmarshal(b []byte) error

+ type SetTaskStatusInput struct

+ Status TaskStatus

+ TaskId string

+ UpdatedAt int64

+ UserId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetTaskStatusInput) Descriptor() ([]byte, []int)

+ func (*SetTaskStatusInput) ProtoMessage()

+ func (dst *SetTaskStatusInput) XXX_Merge(src proto.Message)

+ func (m *SetTaskStatusInput) GetStatus() TaskStatus

+ func (m *SetTaskStatusInput) GetTaskId() string

+ func (m *SetTaskStatusInput) GetUpdatedAt() int64

+ func (m *SetTaskStatusInput) GetUserId() string

+ func (m *SetTaskStatusInput) Reset()

+ func (m *SetTaskStatusInput) String() string

+ func (m *SetTaskStatusInput) XXX_DiscardUnknown()

+ func (m *SetTaskStatusInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetTaskStatusInput) XXX_Size() int

+ func (m *SetTaskStatusInput) XXX_Unmarshal(b []byte) error

+ type Spectrum struct

+ Coordinates []*Coordinate

+ SpeedRpm float64

+ WindowFunction string

+ XUnit string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ YUnit string

+ func (*Spectrum) Descriptor() ([]byte, []int)

+ func (*Spectrum) ProtoMessage()

+ func (dst *Spectrum) XXX_Merge(src proto.Message)

+ func (m *Spectrum) GetCoordinates() []*Coordinate

+ func (m *Spectrum) GetSpeedRpm() float64

+ func (m *Spectrum) GetWindowFunction() string

+ func (m *Spectrum) GetXUnit() string

+ func (m *Spectrum) GetYUnit() string

+ func (m *Spectrum) Reset()

+ func (m *Spectrum) String() string

+ func (m *Spectrum) XXX_DiscardUnknown()

+ func (m *Spectrum) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Spectrum) XXX_Size() int

+ func (m *Spectrum) XXX_Unmarshal(b []byte) error

+ type TaskDescription struct

+ DueDateTimestamp int64

+ ExternalTaskId string

+ FunctionalLocationIds *FunctionalLocationIds

+ HierarchyId string

+ IsCompleted bool

+ Status TaskStatus

+ StatusUpdatedAt int64

+ TaskId string

+ TaskName string

+ UserId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskDescription) Descriptor() ([]byte, []int)

+ func (*TaskDescription) ProtoMessage()

+ func (dst *TaskDescription) XXX_Merge(src proto.Message)

+ func (m *TaskDescription) GetDueDateTimestamp() int64

+ func (m *TaskDescription) GetExternalTaskId() string

+ func (m *TaskDescription) GetFunctionalLocationIds() *FunctionalLocationIds

+ func (m *TaskDescription) GetHierarchyId() string

+ func (m *TaskDescription) GetIsCompleted() bool

+ func (m *TaskDescription) GetStatus() TaskStatus

+ func (m *TaskDescription) GetStatusUpdatedAt() int64

+ func (m *TaskDescription) GetTaskId() string

+ func (m *TaskDescription) GetTaskName() string

+ func (m *TaskDescription) GetUserId() string

+ func (m *TaskDescription) Reset()

+ func (m *TaskDescription) String() string

+ func (m *TaskDescription) XXX_DiscardUnknown()

+ func (m *TaskDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskDescription) XXX_Size() int

+ func (m *TaskDescription) XXX_Unmarshal(b []byte) error

+ type TaskDescriptions struct

+ TaskDescriptionArr []*TaskDescription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskDescriptions) Descriptor() ([]byte, []int)

+ func (*TaskDescriptions) ProtoMessage()

+ func (dst *TaskDescriptions) XXX_Merge(src proto.Message)

+ func (m *TaskDescriptions) GetTaskDescriptionArr() []*TaskDescription

+ func (m *TaskDescriptions) Reset()

+ func (m *TaskDescriptions) String() string

+ func (m *TaskDescriptions) XXX_DiscardUnknown()

+ func (m *TaskDescriptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskDescriptions) XXX_Size() int

+ func (m *TaskDescriptions) XXX_Unmarshal(b []byte) error

+ type TaskStatus int32

+ const TaskStatus_COMPLETED

+ const TaskStatus_IN_PROGRESS

+ const TaskStatus_NOT_SENT

+ const TaskStatus_RECEIVED

+ const TaskStatus_SENT

+ func (TaskStatus) EnumDescriptor() ([]byte, []int)

+ func (x TaskStatus) String() string

+ type TaskUser struct

+ TaskId string

+ UserId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskUser) Descriptor() ([]byte, []int)

+ func (*TaskUser) ProtoMessage()

+ func (dst *TaskUser) XXX_Merge(src proto.Message)

+ func (m *TaskUser) GetTaskId() string

+ func (m *TaskUser) GetUserId() string

+ func (m *TaskUser) Reset()

+ func (m *TaskUser) String() string

+ func (m *TaskUser) XXX_DiscardUnknown()

+ func (m *TaskUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskUser) XXX_Size() int

+ func (m *TaskUser) XXX_Unmarshal(b []byte) error

+ type TimeSeries struct

+ Coordinates []*Coordinate

+ XUnit string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ YUnit string

+ func (*TimeSeries) Descriptor() ([]byte, []int)

+ func (*TimeSeries) ProtoMessage()

+ func (dst *TimeSeries) XXX_Merge(src proto.Message)

+ func (m *TimeSeries) GetCoordinates() []*Coordinate

+ func (m *TimeSeries) GetXUnit() string

+ func (m *TimeSeries) GetYUnit() string

+ func (m *TimeSeries) Reset()

+ func (m *TimeSeries) String() string

+ func (m *TimeSeries) XXX_DiscardUnknown()

+ func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TimeSeries) XXX_Size() int

+ func (m *TimeSeries) XXX_Unmarshal(b []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL