deviced

package
v1.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2019 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConnectMessageKind_name = map[int32]string{
	0: "CONNECT_MESSAGE_KIND_UNKNOWN",
	1: "CONNECT_MESSAGE_KIND_SYSTEM",
	2: "CONNECT_MESSAGE_KIND_USER",
}
View Source 
var ConnectMessageKind_value = map[string]int32{
	"CONNECT_MESSAGE_KIND_UNKNOWN": 0,
	"CONNECT_MESSAGE_KIND_SYSTEM":  1,
	"CONNECT_MESSAGE_KIND_USER":    2,
}

Functions

func RegisterDevicedServiceServer 

func RegisterDevicedServiceServer(s *grpc.Server, srv DevicedServiceServer)

Types

type ConnectMessageKind 

type ConnectMessageKind int32
const (
	ConnectMessageKind_CONNECT_MESSAGE_KIND_UNKNOWN ConnectMessageKind = 0
	ConnectMessageKind_CONNECT_MESSAGE_KIND_SYSTEM  ConnectMessageKind = 1
	ConnectMessageKind_CONNECT_MESSAGE_KIND_USER    ConnectMessageKind = 2
)

func (ConnectMessageKind) EnumDescriptor 

func (ConnectMessageKind) EnumDescriptor() ([]byte, []int)

func (ConnectMessageKind) String 

func (x ConnectMessageKind) String() string

type ConnectRequest 

type ConnectRequest struct {
	SessionId *wrappers.Int64Value `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Kind      ConnectMessageKind   `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.service.deviced.ConnectMessageKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*ConnectRequest_UnaryCall
	//	*ConnectRequest_StreamCall
	Union                isConnectRequest_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ConnectRequest) Descriptor 

func (*ConnectRequest) Descriptor() ([]byte, []int)

func (*ConnectRequest) GetKind 

func (m *ConnectRequest) GetKind() ConnectMessageKind

func (*ConnectRequest) GetSessionId 

func (m *ConnectRequest) GetSessionId() *wrappers.Int64Value

func (*ConnectRequest) GetStreamCall 

func (m *ConnectRequest) GetStreamCall() *OpStreamCallValue

func (*ConnectRequest) GetUnaryCall 

func (m *ConnectRequest) GetUnaryCall() *OpUnaryCallValue

func (*ConnectRequest) GetUnion 

func (m *ConnectRequest) GetUnion() isConnectRequest_Union

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Validate 

func (this *ConnectRequest) Validate() error

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

func (m *ConnectRequest) XXX_Merge(src proto.Message)

func (*ConnectRequest) XXX_OneofWrappers added in v1.0.0 

func (*ConnectRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

func (m *ConnectRequest) XXX_Unmarshal(b []byte) error

type ConnectRequest_StreamCall 

type ConnectRequest_StreamCall struct {
	StreamCall *OpStreamCallValue `protobuf:"bytes,4,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type ConnectRequest_UnaryCall 

type ConnectRequest_UnaryCall struct {
	UnaryCall *OpUnaryCallValue `protobuf:"bytes,3,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

type ConnectResponse 

type ConnectResponse struct {
	SessionId int64              `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Kind      ConnectMessageKind `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.service.deviced.ConnectMessageKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*ConnectResponse_UnaryCall
	//	*ConnectResponse_StreamCall
	//	*ConnectResponse_Err
	Union                isConnectResponse_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConnectResponse) Descriptor 

func (*ConnectResponse) Descriptor() ([]byte, []int)

func (*ConnectResponse) GetErr 

func (m *ConnectResponse) GetErr() *ErrorValue

func (*ConnectResponse) GetKind 

func (m *ConnectResponse) GetKind() ConnectMessageKind

func (*ConnectResponse) GetSessionId 

func (m *ConnectResponse) GetSessionId() int64

func (*ConnectResponse) GetStreamCall 

func (m *ConnectResponse) GetStreamCall() *StreamCallValue

func (*ConnectResponse) GetUnaryCall 

func (m *ConnectResponse) GetUnaryCall() *UnaryCallValue

func (*ConnectResponse) GetUnion 

func (m *ConnectResponse) GetUnion() isConnectResponse_Union

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (m *ConnectResponse) String() string

func (*ConnectResponse) Validate 

func (this *ConnectResponse) Validate() error

func (*ConnectResponse) XXX_DiscardUnknown 

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal 

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

func (*ConnectResponse) XXX_Merge 

func (m *ConnectResponse) XXX_Merge(src proto.Message)

func (*ConnectResponse) XXX_OneofWrappers added in v1.0.0 

func (*ConnectResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectResponse) XXX_Size 

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal 

func (m *ConnectResponse) XXX_Unmarshal(b []byte) error

type ConnectResponse_Err 

type ConnectResponse_Err struct {
	Err *ErrorValue `protobuf:"bytes,9,opt,name=err,proto3,oneof"`
}

type ConnectResponse_StreamCall 

type ConnectResponse_StreamCall struct {
	StreamCall *StreamCallValue `protobuf:"bytes,4,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type ConnectResponse_UnaryCall 

type ConnectResponse_UnaryCall struct {
	UnaryCall *UnaryCallValue `protobuf:"bytes,3,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

type CreateDeviceRequest 

type CreateDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateDeviceRequest) Descriptor 

func (*CreateDeviceRequest) Descriptor() ([]byte, []int)

func (*CreateDeviceRequest) GetDevice 

func (m *CreateDeviceRequest) GetDevice() *OpDevice

func (*CreateDeviceRequest) ProtoMessage 

func (*CreateDeviceRequest) ProtoMessage()

func (*CreateDeviceRequest) Reset 

func (m *CreateDeviceRequest) Reset()

func (*CreateDeviceRequest) String 

func (m *CreateDeviceRequest) String() string

func (*CreateDeviceRequest) Validate 

func (this *CreateDeviceRequest) Validate() error

func (*CreateDeviceRequest) XXX_DiscardUnknown 

func (m *CreateDeviceRequest) XXX_DiscardUnknown()

func (*CreateDeviceRequest) XXX_Marshal 

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

func (*CreateDeviceRequest) XXX_Merge 

func (m *CreateDeviceRequest) XXX_Merge(src proto.Message)

func (*CreateDeviceRequest) XXX_Size 

func (m *CreateDeviceRequest) XXX_Size() int

func (*CreateDeviceRequest) XXX_Unmarshal 

func (m *CreateDeviceRequest) XXX_Unmarshal(b []byte) error

type CreateDeviceResponse 

type CreateDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDeviceResponse) Descriptor 

func (*CreateDeviceResponse) Descriptor() ([]byte, []int)

func (*CreateDeviceResponse) GetDevice 

func (m *CreateDeviceResponse) GetDevice() *Device

func (*CreateDeviceResponse) ProtoMessage 

func (*CreateDeviceResponse) ProtoMessage()

func (*CreateDeviceResponse) Reset 

func (m *CreateDeviceResponse) Reset()

func (*CreateDeviceResponse) String 

func (m *CreateDeviceResponse) String() string

func (*CreateDeviceResponse) Validate 

func (this *CreateDeviceResponse) Validate() error

func (*CreateDeviceResponse) XXX_DiscardUnknown 

func (m *CreateDeviceResponse) XXX_DiscardUnknown()

func (*CreateDeviceResponse) XXX_Marshal 

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

func (*CreateDeviceResponse) XXX_Merge 

func (m *CreateDeviceResponse) XXX_Merge(src proto.Message)

func (*CreateDeviceResponse) XXX_Size 

func (m *CreateDeviceResponse) XXX_Size() int

func (*CreateDeviceResponse) XXX_Unmarshal 

func (m *CreateDeviceResponse) XXX_Unmarshal(b []byte) error

type DeleteDeviceRequest 

type DeleteDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteDeviceRequest) Descriptor 

func (*DeleteDeviceRequest) Descriptor() ([]byte, []int)

func (*DeleteDeviceRequest) GetDevice 

func (m *DeleteDeviceRequest) GetDevice() *OpDevice

func (*DeleteDeviceRequest) ProtoMessage 

func (*DeleteDeviceRequest) ProtoMessage()

func (*DeleteDeviceRequest) Reset 

func (m *DeleteDeviceRequest) Reset()

func (*DeleteDeviceRequest) String 

func (m *DeleteDeviceRequest) String() string

func (*DeleteDeviceRequest) Validate 

func (this *DeleteDeviceRequest) Validate() error

func (*DeleteDeviceRequest) XXX_DiscardUnknown 

func (m *DeleteDeviceRequest) XXX_DiscardUnknown()

func (*DeleteDeviceRequest) XXX_Marshal 

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

func (*DeleteDeviceRequest) XXX_Merge 

func (m *DeleteDeviceRequest) XXX_Merge(src proto.Message)

func (*DeleteDeviceRequest) XXX_Size 

func (m *DeleteDeviceRequest) XXX_Size() int

func (*DeleteDeviceRequest) XXX_Unmarshal 

func (m *DeleteDeviceRequest) XXX_Unmarshal(b []byte) error

type Device 

type Device struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind                 kind.DeviceKind      `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.constant.kind.DeviceKind" json:"kind,omitempty"`
	State                state.DeviceState    `protobuf:"varint,3,opt,name=state,proto3,enum=ai.metathings.constant.state.DeviceState" json:"state,omitempty"`
	Name                 string               `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string               `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`
	Modules              []*Module            `protobuf:"bytes,6,rep,name=modules,proto3" json:"modules,omitempty"`
	HeartbeatAt          *timestamp.Timestamp `protobuf:"bytes,7,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	Flows                []*Flow              `protobuf:"bytes,8,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Device) Descriptor 

func (*Device) Descriptor() ([]byte, []int)

func (*Device) GetAlias 

func (m *Device) GetAlias() string

func (*Device) GetFlows 

func (m *Device) GetFlows() []*Flow

func (*Device) GetHeartbeatAt 

func (m *Device) GetHeartbeatAt() *timestamp.Timestamp

func (*Device) GetId 

func (m *Device) GetId() string

func (*Device) GetKind 

func (m *Device) GetKind() kind.DeviceKind

func (*Device) GetModules 

func (m *Device) GetModules() []*Module

func (*Device) GetName 

func (m *Device) GetName() string

func (*Device) GetState 

func (m *Device) GetState() state.DeviceState

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) Validate 

func (this *Device) Validate() error

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

func (m *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

func (m *Device) XXX_Unmarshal(b []byte) error

type DevicedServiceClient 

type DevicedServiceClient interface {
	CreateDevice(ctx context.Context, in *CreateDeviceRequest, opts ...grpc.CallOption) (*CreateDeviceResponse, error)
	DeleteDevice(ctx context.Context, in *DeleteDeviceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PatchDevice(ctx context.Context, in *PatchDeviceRequest, opts ...grpc.CallOption) (*PatchDeviceResponse, error)
	GetDevice(ctx context.Context, in *GetDeviceRequest, opts ...grpc.CallOption) (*GetDeviceResponse, error)
	ListDevices(ctx context.Context, in *ListDevicesRequest, opts ...grpc.CallOption) (*ListDevicesResponse, error)
	GetDeviceByModule(ctx context.Context, in *GetDeviceByModuleRequest, opts ...grpc.CallOption) (*GetDeviceByModuleResponse, error)
	// Calling
	UnaryCall(ctx context.Context, in *UnaryCallRequest, opts ...grpc.CallOption) (*UnaryCallResponse, error)
	StreamCall(ctx context.Context, opts ...grpc.CallOption) (DevicedService_StreamCallClient, error)
	// Flow
	PullFrameFromFlow(ctx context.Context, in *PullFrameFromFlowRequest, opts ...grpc.CallOption) (DevicedService_PullFrameFromFlowClient, error)
	PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (DevicedService_PushFrameToFlowClient, error)
	QueryFramesFromFlow(ctx context.Context, in *QueryFramesFromFlowRequest, opts ...grpc.CallOption) (*QueryFramesFromFlowResponse, error)
	// Simple Storage
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RemoveObject(ctx context.Context, in *RemoveObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RenameObject(ctx context.Context, in *RenameObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (*GetObjectResponse, error)
	GetObjectContent(ctx context.Context, in *GetObjectContentRequest, opts ...grpc.CallOption) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(ctx context.Context, in *GetObjectStreamingContentRequest, opts ...grpc.CallOption) (DevicedService_GetObjectStreamingContentClient, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
	// internal device only
	ShowDevice(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShowDeviceResponse, error)
	Connect(ctx context.Context, opts ...grpc.CallOption) (DevicedService_ConnectClient, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DevicedServiceClient is the client API for DevicedService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDevicedServiceClient 

func NewDevicedServiceClient(cc *grpc.ClientConn) DevicedServiceClient

type DevicedServiceServer 

type DevicedServiceServer interface {
	CreateDevice(context.Context, *CreateDeviceRequest) (*CreateDeviceResponse, error)
	DeleteDevice(context.Context, *DeleteDeviceRequest) (*empty.Empty, error)
	PatchDevice(context.Context, *PatchDeviceRequest) (*PatchDeviceResponse, error)
	GetDevice(context.Context, *GetDeviceRequest) (*GetDeviceResponse, error)
	ListDevices(context.Context, *ListDevicesRequest) (*ListDevicesResponse, error)
	GetDeviceByModule(context.Context, *GetDeviceByModuleRequest) (*GetDeviceByModuleResponse, error)
	// Calling
	UnaryCall(context.Context, *UnaryCallRequest) (*UnaryCallResponse, error)
	StreamCall(DevicedService_StreamCallServer) error
	// Flow
	PullFrameFromFlow(*PullFrameFromFlowRequest, DevicedService_PullFrameFromFlowServer) error
	PushFrameToFlow(DevicedService_PushFrameToFlowServer) error
	QueryFramesFromFlow(context.Context, *QueryFramesFromFlowRequest) (*QueryFramesFromFlowResponse, error)
	// Simple Storage
	PutObject(context.Context, *PutObjectRequest) (*empty.Empty, error)
	RemoveObject(context.Context, *RemoveObjectRequest) (*empty.Empty, error)
	RenameObject(context.Context, *RenameObjectRequest) (*empty.Empty, error)
	GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)
	GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(*GetObjectStreamingContentRequest, DevicedService_GetObjectStreamingContentServer) error
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	// internal device only
	ShowDevice(context.Context, *empty.Empty) (*ShowDeviceResponse, error)
	Connect(DevicedService_ConnectServer) error
	Heartbeat(context.Context, *HeartbeatRequest) (*empty.Empty, error)
}

DevicedServiceServer is the server API for DevicedService service.

type DevicedService_ConnectClient 

type DevicedService_ConnectClient interface {
	Send(*ConnectResponse) error
	Recv() (*ConnectRequest, error)
	grpc.ClientStream
}

type DevicedService_ConnectServer 

type DevicedService_ConnectServer interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResponse, error)
	grpc.ServerStream
}

type DevicedService_GetObjectStreamingContentClient 

type DevicedService_GetObjectStreamingContentClient interface {
	Recv() (*GetObjectStreamingContentResponse, error)
	grpc.ClientStream
}

type DevicedService_GetObjectStreamingContentServer 

type DevicedService_GetObjectStreamingContentServer interface {
	Send(*GetObjectStreamingContentResponse) error
	grpc.ServerStream
}

type DevicedService_PullFrameFromFlowClient 

type DevicedService_PullFrameFromFlowClient interface {
	Recv() (*PullFrameFromFlowResponse, error)
	grpc.ClientStream
}

type DevicedService_PullFrameFromFlowServer 

type DevicedService_PullFrameFromFlowServer interface {
	Send(*PullFrameFromFlowResponse) error
	grpc.ServerStream
}

type DevicedService_PushFrameToFlowClient 

type DevicedService_PushFrameToFlowClient interface {
	Send(*PushFrameToFlowRequest) error
	Recv() (*PushFrameToFlowResponse, error)
	grpc.ClientStream
}

type DevicedService_PushFrameToFlowServer 

type DevicedService_PushFrameToFlowServer interface {
	Send(*PushFrameToFlowResponse) error
	Recv() (*PushFrameToFlowRequest, error)
	grpc.ServerStream
}

type DevicedService_StreamCallClient 

type DevicedService_StreamCallClient interface {
	Send(*StreamCallRequest) error
	Recv() (*StreamCallResponse, error)
	grpc.ClientStream
}

type DevicedService_StreamCallServer 

type DevicedService_StreamCallServer interface {
	Send(*StreamCallResponse) error
	Recv() (*StreamCallRequest, error)
	grpc.ServerStream
}

type ErrorValue 

type ErrorValue struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Code                 uint32   `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorValue) Descriptor 

func (*ErrorValue) Descriptor() ([]byte, []int)

func (*ErrorValue) GetCode 

func (m *ErrorValue) GetCode() uint32

func (*ErrorValue) GetComponent 

func (m *ErrorValue) GetComponent() string

func (*ErrorValue) GetMessage 

func (m *ErrorValue) GetMessage() string

func (*ErrorValue) GetMethod 

func (m *ErrorValue) GetMethod() string

func (*ErrorValue) GetName 

func (m *ErrorValue) GetName() string

func (*ErrorValue) ProtoMessage 

func (*ErrorValue) ProtoMessage()

func (*ErrorValue) Reset 

func (m *ErrorValue) Reset()

func (*ErrorValue) String 

func (m *ErrorValue) String() string

func (*ErrorValue) Validate 

func (this *ErrorValue) Validate() error

func (*ErrorValue) XXX_DiscardUnknown 

func (m *ErrorValue) XXX_DiscardUnknown()

func (*ErrorValue) XXX_Marshal 

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

func (*ErrorValue) XXX_Merge 

func (m *ErrorValue) XXX_Merge(src proto.Message)

func (*ErrorValue) XXX_Size 

func (m *ErrorValue) XXX_Size() int

func (*ErrorValue) XXX_Unmarshal 

func (m *ErrorValue) XXX_Unmarshal(b []byte) error

type Flow 

type Flow struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeviceId             string   `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string   `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Flow) Descriptor 

func (*Flow) Descriptor() ([]byte, []int)

func (*Flow) GetAlias 

func (m *Flow) GetAlias() string

func (*Flow) GetDeviceId 

func (m *Flow) GetDeviceId() string

func (*Flow) GetId 

func (m *Flow) GetId() string

func (*Flow) GetName 

func (m *Flow) GetName() string

func (*Flow) ProtoMessage 

func (*Flow) ProtoMessage()

func (*Flow) Reset 

func (m *Flow) Reset()

func (*Flow) String 

func (m *Flow) String() string

func (*Flow) Validate 

func (this *Flow) Validate() error

func (*Flow) XXX_DiscardUnknown 

func (m *Flow) XXX_DiscardUnknown()

func (*Flow) XXX_Marshal 

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

func (*Flow) XXX_Merge 

func (m *Flow) XXX_Merge(src proto.Message)

func (*Flow) XXX_Size 

func (m *Flow) XXX_Size() int

func (*Flow) XXX_Unmarshal 

func (m *Flow) XXX_Unmarshal(b []byte) error

type Frame 

type Frame struct {
	Ts                   *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Frame) Descriptor 

func (*Frame) Descriptor() ([]byte, []int)

func (*Frame) GetData 

func (m *Frame) GetData() *_struct.Struct

func (*Frame) GetTs 

func (m *Frame) GetTs() *timestamp.Timestamp

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) Reset 

func (m *Frame) Reset()

func (*Frame) String 

func (m *Frame) String() string

func (*Frame) Validate 

func (this *Frame) Validate() error

func (*Frame) XXX_DiscardUnknown 

func (m *Frame) XXX_DiscardUnknown()

func (*Frame) XXX_Marshal 

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

func (*Frame) XXX_Merge 

func (m *Frame) XXX_Merge(src proto.Message)

func (*Frame) XXX_Size 

func (m *Frame) XXX_Size() int

func (*Frame) XXX_Unmarshal 

func (m *Frame) XXX_Unmarshal(b []byte) error

type GetDeviceByModuleRequest added in v0.100.0 

type GetDeviceByModuleRequest struct {
	Module               *OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDeviceByModuleRequest) Descriptor added in v0.100.0 

func (*GetDeviceByModuleRequest) Descriptor() ([]byte, []int)

func (*GetDeviceByModuleRequest) GetModule added in v0.100.0 

func (m *GetDeviceByModuleRequest) GetModule() *OpModule

func (*GetDeviceByModuleRequest) ProtoMessage added in v0.100.0 

func (*GetDeviceByModuleRequest) ProtoMessage()

func (*GetDeviceByModuleRequest) Reset added in v0.100.0 

func (m *GetDeviceByModuleRequest) Reset()

func (*GetDeviceByModuleRequest) String added in v0.100.0 

func (m *GetDeviceByModuleRequest) String() string

func (*GetDeviceByModuleRequest) Validate added in v0.100.0 

func (this *GetDeviceByModuleRequest) Validate() error

func (*GetDeviceByModuleRequest) XXX_DiscardUnknown added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_DiscardUnknown()

func (*GetDeviceByModuleRequest) XXX_Marshal added in v0.100.0 

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

func (*GetDeviceByModuleRequest) XXX_Merge added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_Merge(src proto.Message)

func (*GetDeviceByModuleRequest) XXX_Size added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_Size() int

func (*GetDeviceByModuleRequest) XXX_Unmarshal added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_Unmarshal(b []byte) error

type GetDeviceByModuleResponse added in v0.100.0 

type GetDeviceByModuleResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDeviceByModuleResponse) Descriptor added in v0.100.0 

func (*GetDeviceByModuleResponse) Descriptor() ([]byte, []int)

func (*GetDeviceByModuleResponse) GetDevice added in v0.100.0 

func (m *GetDeviceByModuleResponse) GetDevice() *Device

func (*GetDeviceByModuleResponse) ProtoMessage added in v0.100.0 

func (*GetDeviceByModuleResponse) ProtoMessage()

func (*GetDeviceByModuleResponse) Reset added in v0.100.0 

func (m *GetDeviceByModuleResponse) Reset()

func (*GetDeviceByModuleResponse) String added in v0.100.0 

func (m *GetDeviceByModuleResponse) String() string

func (*GetDeviceByModuleResponse) Validate added in v0.100.0 

func (this *GetDeviceByModuleResponse) Validate() error

func (*GetDeviceByModuleResponse) XXX_DiscardUnknown added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_DiscardUnknown()

func (*GetDeviceByModuleResponse) XXX_Marshal added in v0.100.0 

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

func (*GetDeviceByModuleResponse) XXX_Merge added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_Merge(src proto.Message)

func (*GetDeviceByModuleResponse) XXX_Size added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_Size() int

func (*GetDeviceByModuleResponse) XXX_Unmarshal added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_Unmarshal(b []byte) error

type GetDeviceRequest 

type GetDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDeviceRequest) Descriptor 

func (*GetDeviceRequest) Descriptor() ([]byte, []int)

func (*GetDeviceRequest) GetDevice 

func (m *GetDeviceRequest) GetDevice() *OpDevice

func (*GetDeviceRequest) ProtoMessage 

func (*GetDeviceRequest) ProtoMessage()

func (*GetDeviceRequest) Reset 

func (m *GetDeviceRequest) Reset()

func (*GetDeviceRequest) String 

func (m *GetDeviceRequest) String() string

func (*GetDeviceRequest) Validate 

func (this *GetDeviceRequest) Validate() error

func (*GetDeviceRequest) XXX_DiscardUnknown 

func (m *GetDeviceRequest) XXX_DiscardUnknown()

func (*GetDeviceRequest) XXX_Marshal 

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

func (*GetDeviceRequest) XXX_Merge 

func (m *GetDeviceRequest) XXX_Merge(src proto.Message)

func (*GetDeviceRequest) XXX_Size 

func (m *GetDeviceRequest) XXX_Size() int

func (*GetDeviceRequest) XXX_Unmarshal 

func (m *GetDeviceRequest) XXX_Unmarshal(b []byte) error

type GetDeviceResponse 

type GetDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDeviceResponse) Descriptor 

func (*GetDeviceResponse) Descriptor() ([]byte, []int)

func (*GetDeviceResponse) GetDevice 

func (m *GetDeviceResponse) GetDevice() *Device

func (*GetDeviceResponse) ProtoMessage 

func (*GetDeviceResponse) ProtoMessage()

func (*GetDeviceResponse) Reset 

func (m *GetDeviceResponse) Reset()

func (*GetDeviceResponse) String 

func (m *GetDeviceResponse) String() string

func (*GetDeviceResponse) Validate 

func (this *GetDeviceResponse) Validate() error

func (*GetDeviceResponse) XXX_DiscardUnknown 

func (m *GetDeviceResponse) XXX_DiscardUnknown()

func (*GetDeviceResponse) XXX_Marshal 

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

func (*GetDeviceResponse) XXX_Merge 

func (m *GetDeviceResponse) XXX_Merge(src proto.Message)

func (*GetDeviceResponse) XXX_Size 

func (m *GetDeviceResponse) XXX_Size() int

func (*GetDeviceResponse) XXX_Unmarshal 

func (m *GetDeviceResponse) XXX_Unmarshal(b []byte) error

type GetObjectContentRequest 

type GetObjectContentRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectContentRequest) Descriptor 

func (*GetObjectContentRequest) Descriptor() ([]byte, []int)

func (*GetObjectContentRequest) GetObject 

func (m *GetObjectContentRequest) GetObject() *OpObject

func (*GetObjectContentRequest) ProtoMessage 

func (*GetObjectContentRequest) ProtoMessage()

func (*GetObjectContentRequest) Reset 

func (m *GetObjectContentRequest) Reset()

func (*GetObjectContentRequest) String 

func (m *GetObjectContentRequest) String() string

func (*GetObjectContentRequest) Validate 

func (this *GetObjectContentRequest) Validate() error

func (*GetObjectContentRequest) XXX_DiscardUnknown 

func (m *GetObjectContentRequest) XXX_DiscardUnknown()

func (*GetObjectContentRequest) XXX_Marshal 

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

func (*GetObjectContentRequest) XXX_Merge 

func (m *GetObjectContentRequest) XXX_Merge(src proto.Message)

func (*GetObjectContentRequest) XXX_Size 

func (m *GetObjectContentRequest) XXX_Size() int

func (*GetObjectContentRequest) XXX_Unmarshal 

func (m *GetObjectContentRequest) XXX_Unmarshal(b []byte) error

type GetObjectContentResponse 

type GetObjectContentResponse struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectContentResponse) Descriptor 

func (*GetObjectContentResponse) Descriptor() ([]byte, []int)

func (*GetObjectContentResponse) GetContent 

func (m *GetObjectContentResponse) GetContent() []byte

func (*GetObjectContentResponse) ProtoMessage 

func (*GetObjectContentResponse) ProtoMessage()

func (*GetObjectContentResponse) Reset 

func (m *GetObjectContentResponse) Reset()

func (*GetObjectContentResponse) String 

func (m *GetObjectContentResponse) String() string

func (*GetObjectContentResponse) Validate 

func (this *GetObjectContentResponse) Validate() error

func (*GetObjectContentResponse) XXX_DiscardUnknown 

func (m *GetObjectContentResponse) XXX_DiscardUnknown()

func (*GetObjectContentResponse) XXX_Marshal 

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

func (*GetObjectContentResponse) XXX_Merge 

func (m *GetObjectContentResponse) XXX_Merge(src proto.Message)

func (*GetObjectContentResponse) XXX_Size 

func (m *GetObjectContentResponse) XXX_Size() int

func (*GetObjectContentResponse) XXX_Unmarshal 

func (m *GetObjectContentResponse) XXX_Unmarshal(b []byte) error

type GetObjectRequest 

type GetObjectRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectRequest) Descriptor 

func (*GetObjectRequest) Descriptor() ([]byte, []int)

func (*GetObjectRequest) GetObject 

func (m *GetObjectRequest) GetObject() *OpObject

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) Reset 

func (m *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (m *GetObjectRequest) String() string

func (*GetObjectRequest) Validate 

func (this *GetObjectRequest) Validate() error

func (*GetObjectRequest) XXX_DiscardUnknown 

func (m *GetObjectRequest) XXX_DiscardUnknown()

func (*GetObjectRequest) XXX_Marshal 

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

func (*GetObjectRequest) XXX_Merge 

func (m *GetObjectRequest) XXX_Merge(src proto.Message)

func (*GetObjectRequest) XXX_Size 

func (m *GetObjectRequest) XXX_Size() int

func (*GetObjectRequest) XXX_Unmarshal 

func (m *GetObjectRequest) XXX_Unmarshal(b []byte) error

type GetObjectResponse 

type GetObjectResponse struct {
	Object               *Object  `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectResponse) Descriptor 

func (*GetObjectResponse) Descriptor() ([]byte, []int)

func (*GetObjectResponse) GetObject 

func (m *GetObjectResponse) GetObject() *Object

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) Reset 

func (m *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (m *GetObjectResponse) String() string

func (*GetObjectResponse) Validate 

func (this *GetObjectResponse) Validate() error

func (*GetObjectResponse) XXX_DiscardUnknown 

func (m *GetObjectResponse) XXX_DiscardUnknown()

func (*GetObjectResponse) XXX_Marshal 

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

func (*GetObjectResponse) XXX_Merge 

func (m *GetObjectResponse) XXX_Merge(src proto.Message)

func (*GetObjectResponse) XXX_Size 

func (m *GetObjectResponse) XXX_Size() int

func (*GetObjectResponse) XXX_Unmarshal 

func (m *GetObjectResponse) XXX_Unmarshal(b []byte) error

type GetObjectStreamingContentRequest 

type GetObjectStreamingContentRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectStreamingContentRequest) Descriptor 

func (*GetObjectStreamingContentRequest) Descriptor() ([]byte, []int)

func (*GetObjectStreamingContentRequest) GetObject 

func (m *GetObjectStreamingContentRequest) GetObject() *OpObject

func (*GetObjectStreamingContentRequest) ProtoMessage 

func (*GetObjectStreamingContentRequest) ProtoMessage()

func (*GetObjectStreamingContentRequest) Reset 

func (m *GetObjectStreamingContentRequest) Reset()

func (*GetObjectStreamingContentRequest) String 

func (m *GetObjectStreamingContentRequest) String() string

func (*GetObjectStreamingContentRequest) Validate 

func (this *GetObjectStreamingContentRequest) Validate() error

func (*GetObjectStreamingContentRequest) XXX_DiscardUnknown 

func (m *GetObjectStreamingContentRequest) XXX_DiscardUnknown()

func (*GetObjectStreamingContentRequest) XXX_Marshal 

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

func (*GetObjectStreamingContentRequest) XXX_Merge 

func (m *GetObjectStreamingContentRequest) XXX_Merge(src proto.Message)

func (*GetObjectStreamingContentRequest) XXX_Size 

func (m *GetObjectStreamingContentRequest) XXX_Size() int

func (*GetObjectStreamingContentRequest) XXX_Unmarshal 

func (m *GetObjectStreamingContentRequest) XXX_Unmarshal(b []byte) error

type GetObjectStreamingContentResponse 

type GetObjectStreamingContentResponse struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectStreamingContentResponse) Descriptor 

func (*GetObjectStreamingContentResponse) Descriptor() ([]byte, []int)

func (*GetObjectStreamingContentResponse) GetContent 

func (m *GetObjectStreamingContentResponse) GetContent() []byte

func (*GetObjectStreamingContentResponse) ProtoMessage 

func (*GetObjectStreamingContentResponse) ProtoMessage()

func (*GetObjectStreamingContentResponse) Reset 

func (m *GetObjectStreamingContentResponse) Reset()

func (*GetObjectStreamingContentResponse) String 

func (m *GetObjectStreamingContentResponse) String() string

func (*GetObjectStreamingContentResponse) Validate 

func (this *GetObjectStreamingContentResponse) Validate() error

func (*GetObjectStreamingContentResponse) XXX_DiscardUnknown 

func (m *GetObjectStreamingContentResponse) XXX_DiscardUnknown()

func (*GetObjectStreamingContentResponse) XXX_Marshal 

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

func (*GetObjectStreamingContentResponse) XXX_Merge 

func (m *GetObjectStreamingContentResponse) XXX_Merge(src proto.Message)

func (*GetObjectStreamingContentResponse) XXX_Size 

func (m *GetObjectStreamingContentResponse) XXX_Size() int

func (*GetObjectStreamingContentResponse) XXX_Unmarshal 

func (m *GetObjectStreamingContentResponse) XXX_Unmarshal(b []byte) error

type HeartbeatRequest 

type HeartbeatRequest struct {
	Device               *OpDevice            `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	StartupSession       *wrappers.Int32Value `protobuf:"bytes,2,opt,name=startup_session,json=startupSession,proto3" json:"startup_session,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

func (*HeartbeatRequest) Descriptor() ([]byte, []int)

func (*HeartbeatRequest) GetDevice 

func (m *HeartbeatRequest) GetDevice() *OpDevice

func (*HeartbeatRequest) GetStartupSession 

func (m *HeartbeatRequest) GetStartupSession() *wrappers.Int32Value

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

func (*HeartbeatRequest) Validate 

func (this *HeartbeatRequest) Validate() error

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

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

func (*HeartbeatRequest) XXX_Merge 

func (m *HeartbeatRequest) XXX_Merge(src proto.Message)

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error

type ListDevicesRequest 

type ListDevicesRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListDevicesRequest) Descriptor 

func (*ListDevicesRequest) Descriptor() ([]byte, []int)

func (*ListDevicesRequest) GetDevice 

func (m *ListDevicesRequest) GetDevice() *OpDevice

func (*ListDevicesRequest) ProtoMessage 

func (*ListDevicesRequest) ProtoMessage()

func (*ListDevicesRequest) Reset 

func (m *ListDevicesRequest) Reset()

func (*ListDevicesRequest) String 

func (m *ListDevicesRequest) String() string

func (*ListDevicesRequest) Validate 

func (this *ListDevicesRequest) Validate() error

func (*ListDevicesRequest) XXX_DiscardUnknown 

func (m *ListDevicesRequest) XXX_DiscardUnknown()

func (*ListDevicesRequest) XXX_Marshal 

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

func (*ListDevicesRequest) XXX_Merge 

func (m *ListDevicesRequest) XXX_Merge(src proto.Message)

func (*ListDevicesRequest) XXX_Size 

func (m *ListDevicesRequest) XXX_Size() int

func (*ListDevicesRequest) XXX_Unmarshal 

func (m *ListDevicesRequest) XXX_Unmarshal(b []byte) error

type ListDevicesResponse 

type ListDevicesResponse struct {
	Devices              []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListDevicesResponse) Descriptor 

func (*ListDevicesResponse) Descriptor() ([]byte, []int)

func (*ListDevicesResponse) GetDevices 

func (m *ListDevicesResponse) GetDevices() []*Device

func (*ListDevicesResponse) ProtoMessage 

func (*ListDevicesResponse) ProtoMessage()

func (*ListDevicesResponse) Reset 

func (m *ListDevicesResponse) Reset()

func (*ListDevicesResponse) String 

func (m *ListDevicesResponse) String() string

func (*ListDevicesResponse) Validate 

func (this *ListDevicesResponse) Validate() error

func (*ListDevicesResponse) XXX_DiscardUnknown 

func (m *ListDevicesResponse) XXX_DiscardUnknown()

func (*ListDevicesResponse) XXX_Marshal 

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

func (*ListDevicesResponse) XXX_Merge 

func (m *ListDevicesResponse) XXX_Merge(src proto.Message)

func (*ListDevicesResponse) XXX_Size 

func (m *ListDevicesResponse) XXX_Size() int

func (*ListDevicesResponse) XXX_Unmarshal 

func (m *ListDevicesResponse) XXX_Unmarshal(b []byte) error

type ListObjectsRequest 

type ListObjectsRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListObjectsRequest) Descriptor 

func (*ListObjectsRequest) Descriptor() ([]byte, []int)

func (*ListObjectsRequest) GetObject 

func (m *ListObjectsRequest) GetObject() *OpObject

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Validate 

func (this *ListObjectsRequest) Validate() error

func (*ListObjectsRequest) XXX_DiscardUnknown 

func (m *ListObjectsRequest) XXX_DiscardUnknown()

func (*ListObjectsRequest) XXX_Marshal 

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

func (*ListObjectsRequest) XXX_Merge 

func (m *ListObjectsRequest) XXX_Merge(src proto.Message)

func (*ListObjectsRequest) XXX_Size 

func (m *ListObjectsRequest) XXX_Size() int

func (*ListObjectsRequest) XXX_Unmarshal 

func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error

type ListObjectsResponse 

type ListObjectsResponse struct {
	Objects              []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListObjectsResponse) Descriptor 

func (*ListObjectsResponse) Descriptor() ([]byte, []int)

func (*ListObjectsResponse) GetObjects 

func (m *ListObjectsResponse) GetObjects() []*Object

func (*ListObjectsResponse) ProtoMessage 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) Reset 

func (m *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String 

func (m *ListObjectsResponse) String() string

func (*ListObjectsResponse) Validate 

func (this *ListObjectsResponse) Validate() error

func (*ListObjectsResponse) XXX_DiscardUnknown 

func (m *ListObjectsResponse) XXX_DiscardUnknown()

func (*ListObjectsResponse) XXX_Marshal 

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

func (*ListObjectsResponse) XXX_Merge 

func (m *ListObjectsResponse) XXX_Merge(src proto.Message)

func (*ListObjectsResponse) XXX_Size 

func (m *ListObjectsResponse) XXX_Size() int

func (*ListObjectsResponse) XXX_Unmarshal 

func (m *ListObjectsResponse) XXX_Unmarshal(b []byte) error

type Module 

type Module struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                state.ModuleState    `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.ModuleState" json:"state,omitempty"`
	DeviceId             string               `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Endpoint             string               `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Component            string               `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
	Name                 string               `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string               `protobuf:"bytes,7,opt,name=alias,proto3" json:"alias,omitempty"`
	HeartbeatAt          *timestamp.Timestamp `protobuf:"bytes,8,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Module) Descriptor 

func (*Module) Descriptor() ([]byte, []int)

func (*Module) GetAlias 

func (m *Module) GetAlias() string

func (*Module) GetComponent 

func (m *Module) GetComponent() string

func (*Module) GetDeviceId 

func (m *Module) GetDeviceId() string

func (*Module) GetEndpoint 

func (m *Module) GetEndpoint() string

func (*Module) GetHeartbeatAt 

func (m *Module) GetHeartbeatAt() *timestamp.Timestamp

func (*Module) GetId 

func (m *Module) GetId() string

func (*Module) GetName 

func (m *Module) GetName() string

func (*Module) GetState 

func (m *Module) GetState() state.ModuleState

func (*Module) ProtoMessage 

func (*Module) ProtoMessage()

func (*Module) Reset 

func (m *Module) Reset()

func (*Module) String 

func (m *Module) String() string

func (*Module) Validate 

func (this *Module) Validate() error

func (*Module) XXX_DiscardUnknown 

func (m *Module) XXX_DiscardUnknown()

func (*Module) XXX_Marshal 

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

func (*Module) XXX_Merge 

func (m *Module) XXX_Merge(src proto.Message)

func (*Module) XXX_Size 

func (m *Module) XXX_Size() int

func (*Module) XXX_Unmarshal 

func (m *Module) XXX_Unmarshal(b []byte) error

type Object 

type Object struct {
	Device               *Device              `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Prefix               string               `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Name                 string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Length               int64                `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	Etag                 string               `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Object) Descriptor 

func (*Object) Descriptor() ([]byte, []int)

func (*Object) GetDevice 

func (m *Object) GetDevice() *Device

func (*Object) GetEtag 

func (m *Object) GetEtag() string

func (*Object) GetLastModified 

func (m *Object) GetLastModified() *timestamp.Timestamp

func (*Object) GetLength 

func (m *Object) GetLength() int64

func (*Object) GetName 

func (m *Object) GetName() string

func (*Object) GetPrefix 

func (m *Object) GetPrefix() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) String 

func (m *Object) String() string

func (*Object) Validate 

func (this *Object) Validate() error

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

func (m *Object) XXX_Merge(src proto.Message)

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

func (m *Object) XXX_Unmarshal(b []byte) error

type OpDevice 

type OpDevice struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind                 kind.DeviceKind       `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.constant.kind.DeviceKind" json:"kind,omitempty"`
	State                state.DeviceState     `protobuf:"varint,3,opt,name=state,proto3,enum=ai.metathings.constant.state.DeviceState" json:"state,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`
	Modules              []*OpModule           `protobuf:"bytes,6,rep,name=modules,proto3" json:"modules,omitempty"`
	HeartbeatAt          *timestamp.Timestamp  `protobuf:"bytes,7,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	Flows                []*OpFlow             `protobuf:"bytes,8,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpDevice) Descriptor 

func (*OpDevice) Descriptor() ([]byte, []int)

func (*OpDevice) GetAlias 

func (m *OpDevice) GetAlias() *wrappers.StringValue

func (*OpDevice) GetFlows 

func (m *OpDevice) GetFlows() []*OpFlow

func (*OpDevice) GetHeartbeatAt 

func (m *OpDevice) GetHeartbeatAt() *timestamp.Timestamp

func (*OpDevice) GetId 

func (m *OpDevice) GetId() *wrappers.StringValue

func (*OpDevice) GetKind 

func (m *OpDevice) GetKind() kind.DeviceKind

func (*OpDevice) GetModules 

func (m *OpDevice) GetModules() []*OpModule

func (*OpDevice) GetName 

func (m *OpDevice) GetName() *wrappers.StringValue

func (*OpDevice) GetState 

func (m *OpDevice) GetState() state.DeviceState

func (*OpDevice) ProtoMessage 

func (*OpDevice) ProtoMessage()

func (*OpDevice) Reset 

func (m *OpDevice) Reset()

func (*OpDevice) String 

func (m *OpDevice) String() string

func (*OpDevice) Validate 

func (this *OpDevice) Validate() error

func (*OpDevice) XXX_DiscardUnknown 

func (m *OpDevice) XXX_DiscardUnknown()

func (*OpDevice) XXX_Marshal 

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

func (*OpDevice) XXX_Merge 

func (m *OpDevice) XXX_Merge(src proto.Message)

func (*OpDevice) XXX_Size 

func (m *OpDevice) XXX_Size() int

func (*OpDevice) XXX_Unmarshal 

func (m *OpDevice) XXX_Unmarshal(b []byte) error

type OpFlow 

type OpFlow struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeviceId             *wrappers.StringValue `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpFlow) Descriptor 

func (*OpFlow) Descriptor() ([]byte, []int)

func (*OpFlow) GetAlias 

func (m *OpFlow) GetAlias() *wrappers.StringValue

func (*OpFlow) GetDeviceId 

func (m *OpFlow) GetDeviceId() *wrappers.StringValue

func (*OpFlow) GetId 

func (m *OpFlow) GetId() *wrappers.StringValue

func (*OpFlow) GetName 

func (m *OpFlow) GetName() *wrappers.StringValue

func (*OpFlow) ProtoMessage 

func (*OpFlow) ProtoMessage()

func (*OpFlow) Reset 

func (m *OpFlow) Reset()

func (*OpFlow) String 

func (m *OpFlow) String() string

func (*OpFlow) Validate 

func (this *OpFlow) Validate() error

func (*OpFlow) XXX_DiscardUnknown 

func (m *OpFlow) XXX_DiscardUnknown()

func (*OpFlow) XXX_Marshal 

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

func (*OpFlow) XXX_Merge 

func (m *OpFlow) XXX_Merge(src proto.Message)

func (*OpFlow) XXX_Size 

func (m *OpFlow) XXX_Size() int

func (*OpFlow) XXX_Unmarshal 

func (m *OpFlow) XXX_Unmarshal(b []byte) error

type OpFrame 

type OpFrame struct {
	Ts                   *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OpFrame) Descriptor 

func (*OpFrame) Descriptor() ([]byte, []int)

func (*OpFrame) GetData 

func (m *OpFrame) GetData() *_struct.Struct

func (*OpFrame) GetTs 

func (m *OpFrame) GetTs() *timestamp.Timestamp

func (*OpFrame) ProtoMessage 

func (*OpFrame) ProtoMessage()

func (*OpFrame) Reset 

func (m *OpFrame) Reset()

func (*OpFrame) String 

func (m *OpFrame) String() string

func (*OpFrame) Validate 

func (this *OpFrame) Validate() error

func (*OpFrame) XXX_DiscardUnknown 

func (m *OpFrame) XXX_DiscardUnknown()

func (*OpFrame) XXX_Marshal 

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

func (*OpFrame) XXX_Merge 

func (m *OpFrame) XXX_Merge(src proto.Message)

func (*OpFrame) XXX_Size 

func (m *OpFrame) XXX_Size() int

func (*OpFrame) XXX_Unmarshal 

func (m *OpFrame) XXX_Unmarshal(b []byte) error

type OpModule 

type OpModule struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                state.ModuleState     `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.ModuleState" json:"state,omitempty"`
	DeviceId             *wrappers.StringValue `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Endpoint             *wrappers.StringValue `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,7,opt,name=alias,proto3" json:"alias,omitempty"`
	HeartbeatAt          *timestamp.Timestamp  `protobuf:"bytes,8,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpModule) Descriptor 

func (*OpModule) Descriptor() ([]byte, []int)

func (*OpModule) GetAlias 

func (m *OpModule) GetAlias() *wrappers.StringValue

func (*OpModule) GetComponent 

func (m *OpModule) GetComponent() *wrappers.StringValue

func (*OpModule) GetDeviceId 

func (m *OpModule) GetDeviceId() *wrappers.StringValue

func (*OpModule) GetEndpoint 

func (m *OpModule) GetEndpoint() *wrappers.StringValue

func (*OpModule) GetHeartbeatAt 

func (m *OpModule) GetHeartbeatAt() *timestamp.Timestamp

func (*OpModule) GetId 

func (m *OpModule) GetId() *wrappers.StringValue

func (*OpModule) GetName 

func (m *OpModule) GetName() *wrappers.StringValue

func (*OpModule) GetState 

func (m *OpModule) GetState() state.ModuleState

func (*OpModule) ProtoMessage 

func (*OpModule) ProtoMessage()

func (*OpModule) Reset 

func (m *OpModule) Reset()

func (*OpModule) String 

func (m *OpModule) String() string

func (*OpModule) Validate 

func (this *OpModule) Validate() error

func (*OpModule) XXX_DiscardUnknown 

func (m *OpModule) XXX_DiscardUnknown()

func (*OpModule) XXX_Marshal 

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

func (*OpModule) XXX_Merge 

func (m *OpModule) XXX_Merge(src proto.Message)

func (*OpModule) XXX_Size 

func (m *OpModule) XXX_Size() int

func (*OpModule) XXX_Unmarshal 

func (m *OpModule) XXX_Unmarshal(b []byte) error

type OpObject 

type OpObject struct {
	Device               *OpDevice             `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Prefix               *wrappers.StringValue `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Length               *wrappers.Int64Value  `protobuf:"bytes,4,opt,name=length,proto3" json:"length,omitempty"`
	Etag                 *wrappers.StringValue `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified         *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpObject) Descriptor 

func (*OpObject) Descriptor() ([]byte, []int)

func (*OpObject) GetDevice 

func (m *OpObject) GetDevice() *OpDevice

func (*OpObject) GetEtag 

func (m *OpObject) GetEtag() *wrappers.StringValue

func (*OpObject) GetLastModified added in v1.0.0 

func (m *OpObject) GetLastModified() *timestamp.Timestamp

func (*OpObject) GetLength 

func (m *OpObject) GetLength() *wrappers.Int64Value

func (*OpObject) GetName 

func (m *OpObject) GetName() *wrappers.StringValue

func (*OpObject) GetPrefix 

func (m *OpObject) GetPrefix() *wrappers.StringValue

func (*OpObject) ProtoMessage 

func (*OpObject) ProtoMessage()

func (*OpObject) Reset 

func (m *OpObject) Reset()

func (*OpObject) String 

func (m *OpObject) String() string

func (*OpObject) Validate 

func (this *OpObject) Validate() error

func (*OpObject) XXX_DiscardUnknown 

func (m *OpObject) XXX_DiscardUnknown()

func (*OpObject) XXX_Marshal 

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

func (*OpObject) XXX_Merge 

func (m *OpObject) XXX_Merge(src proto.Message)

func (*OpObject) XXX_Size 

func (m *OpObject) XXX_Size() int

func (*OpObject) XXX_Unmarshal 

func (m *OpObject) XXX_Unmarshal(b []byte) error

type OpStreamCallConfig 

type OpStreamCallConfig struct {
	Name                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpStreamCallConfig) Descriptor 

func (*OpStreamCallConfig) Descriptor() ([]byte, []int)

func (*OpStreamCallConfig) GetComponent 

func (m *OpStreamCallConfig) GetComponent() *wrappers.StringValue

func (*OpStreamCallConfig) GetMethod 

func (m *OpStreamCallConfig) GetMethod() *wrappers.StringValue

func (*OpStreamCallConfig) GetName 

func (m *OpStreamCallConfig) GetName() *wrappers.StringValue

func (*OpStreamCallConfig) ProtoMessage 

func (*OpStreamCallConfig) ProtoMessage()

func (*OpStreamCallConfig) Reset 

func (m *OpStreamCallConfig) Reset()

func (*OpStreamCallConfig) String 

func (m *OpStreamCallConfig) String() string

func (*OpStreamCallConfig) Validate 

func (this *OpStreamCallConfig) Validate() error

func (*OpStreamCallConfig) XXX_DiscardUnknown 

func (m *OpStreamCallConfig) XXX_DiscardUnknown()

func (*OpStreamCallConfig) XXX_Marshal 

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

func (*OpStreamCallConfig) XXX_Merge 

func (m *OpStreamCallConfig) XXX_Merge(src proto.Message)

func (*OpStreamCallConfig) XXX_Size 

func (m *OpStreamCallConfig) XXX_Size() int

func (*OpStreamCallConfig) XXX_Unmarshal 

func (m *OpStreamCallConfig) XXX_Unmarshal(b []byte) error

type OpStreamCallConfigAck 

type OpStreamCallConfigAck struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpStreamCallConfigAck) Descriptor 

func (*OpStreamCallConfigAck) Descriptor() ([]byte, []int)

func (*OpStreamCallConfigAck) ProtoMessage 

func (*OpStreamCallConfigAck) ProtoMessage()

func (*OpStreamCallConfigAck) Reset 

func (m *OpStreamCallConfigAck) Reset()

func (*OpStreamCallConfigAck) String 

func (m *OpStreamCallConfigAck) String() string

func (*OpStreamCallConfigAck) Validate 

func (this *OpStreamCallConfigAck) Validate() error

func (*OpStreamCallConfigAck) XXX_DiscardUnknown 

func (m *OpStreamCallConfigAck) XXX_DiscardUnknown()

func (*OpStreamCallConfigAck) XXX_Marshal 

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

func (*OpStreamCallConfigAck) XXX_Merge 

func (m *OpStreamCallConfigAck) XXX_Merge(src proto.Message)

func (*OpStreamCallConfigAck) XXX_Size 

func (m *OpStreamCallConfigAck) XXX_Size() int

func (*OpStreamCallConfigAck) XXX_Unmarshal 

func (m *OpStreamCallConfigAck) XXX_Unmarshal(b []byte) error

type OpStreamCallExit 

type OpStreamCallExit struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpStreamCallExit) Descriptor 

func (*OpStreamCallExit) Descriptor() ([]byte, []int)

func (*OpStreamCallExit) ProtoMessage 

func (*OpStreamCallExit) ProtoMessage()

func (*OpStreamCallExit) Reset 

func (m *OpStreamCallExit) Reset()

func (*OpStreamCallExit) String 

func (m *OpStreamCallExit) String() string

func (*OpStreamCallExit) Validate 

func (this *OpStreamCallExit) Validate() error

func (*OpStreamCallExit) XXX_DiscardUnknown 

func (m *OpStreamCallExit) XXX_DiscardUnknown()

func (*OpStreamCallExit) XXX_Marshal 

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

func (*OpStreamCallExit) XXX_Merge 

func (m *OpStreamCallExit) XXX_Merge(src proto.Message)

func (*OpStreamCallExit) XXX_Size 

func (m *OpStreamCallExit) XXX_Size() int

func (*OpStreamCallExit) XXX_Unmarshal 

func (m *OpStreamCallExit) XXX_Unmarshal(b []byte) error

type OpStreamCallValue 

type OpStreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*OpStreamCallValue_Value
	//	*OpStreamCallValue_Config
	//	*OpStreamCallValue_ConfigAck
	//	*OpStreamCallValue_Exit
	Union                isOpStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*OpStreamCallValue) Descriptor 

func (*OpStreamCallValue) Descriptor() ([]byte, []int)

func (*OpStreamCallValue) GetConfig 

func (m *OpStreamCallValue) GetConfig() *OpStreamCallConfig

func (*OpStreamCallValue) GetConfigAck 

func (m *OpStreamCallValue) GetConfigAck() *OpStreamCallConfigAck

func (*OpStreamCallValue) GetExit 

func (m *OpStreamCallValue) GetExit() *OpStreamCallExit

func (*OpStreamCallValue) GetUnion 

func (m *OpStreamCallValue) GetUnion() isOpStreamCallValue_Union

func (*OpStreamCallValue) GetValue 

func (m *OpStreamCallValue) GetValue() *any.Any

func (*OpStreamCallValue) ProtoMessage 

func (*OpStreamCallValue) ProtoMessage()

func (*OpStreamCallValue) Reset 

func (m *OpStreamCallValue) Reset()

func (*OpStreamCallValue) String 

func (m *OpStreamCallValue) String() string

func (*OpStreamCallValue) Validate 

func (this *OpStreamCallValue) Validate() error

func (*OpStreamCallValue) XXX_DiscardUnknown 

func (m *OpStreamCallValue) XXX_DiscardUnknown()

func (*OpStreamCallValue) XXX_Marshal 

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

func (*OpStreamCallValue) XXX_Merge 

func (m *OpStreamCallValue) XXX_Merge(src proto.Message)

func (*OpStreamCallValue) XXX_OneofWrappers added in v1.0.0 

func (*OpStreamCallValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OpStreamCallValue) XXX_Size 

func (m *OpStreamCallValue) XXX_Size() int

func (*OpStreamCallValue) XXX_Unmarshal 

func (m *OpStreamCallValue) XXX_Unmarshal(b []byte) error

type OpStreamCallValue_Config 

type OpStreamCallValue_Config struct {
	Config *OpStreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type OpStreamCallValue_ConfigAck 

type OpStreamCallValue_ConfigAck struct {
	ConfigAck *OpStreamCallConfigAck `protobuf:"bytes,3,opt,name=config_ack,json=configAck,proto3,oneof"`
}

type OpStreamCallValue_Exit 

type OpStreamCallValue_Exit struct {
	Exit *OpStreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type OpStreamCallValue_Value 

type OpStreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type OpUnaryCallValue 

type OpUnaryCallValue struct {
	Name                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any              `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpUnaryCallValue) Descriptor 

func (*OpUnaryCallValue) Descriptor() ([]byte, []int)

func (*OpUnaryCallValue) GetComponent 

func (m *OpUnaryCallValue) GetComponent() *wrappers.StringValue

func (*OpUnaryCallValue) GetMethod 

func (m *OpUnaryCallValue) GetMethod() *wrappers.StringValue

func (*OpUnaryCallValue) GetName 

func (m *OpUnaryCallValue) GetName() *wrappers.StringValue

func (*OpUnaryCallValue) GetValue 

func (m *OpUnaryCallValue) GetValue() *any.Any

func (*OpUnaryCallValue) ProtoMessage 

func (*OpUnaryCallValue) ProtoMessage()

func (*OpUnaryCallValue) Reset 

func (m *OpUnaryCallValue) Reset()

func (*OpUnaryCallValue) String 

func (m *OpUnaryCallValue) String() string

func (*OpUnaryCallValue) Validate 

func (this *OpUnaryCallValue) Validate() error

func (*OpUnaryCallValue) XXX_DiscardUnknown 

func (m *OpUnaryCallValue) XXX_DiscardUnknown()

func (*OpUnaryCallValue) XXX_Marshal 

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

func (*OpUnaryCallValue) XXX_Merge 

func (m *OpUnaryCallValue) XXX_Merge(src proto.Message)

func (*OpUnaryCallValue) XXX_Size 

func (m *OpUnaryCallValue) XXX_Size() int

func (*OpUnaryCallValue) XXX_Unmarshal 

func (m *OpUnaryCallValue) XXX_Unmarshal(b []byte) error

type PatchDeviceRequest 

type PatchDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PatchDeviceRequest) Descriptor 

func (*PatchDeviceRequest) Descriptor() ([]byte, []int)

func (*PatchDeviceRequest) GetDevice 

func (m *PatchDeviceRequest) GetDevice() *OpDevice

func (*PatchDeviceRequest) ProtoMessage 

func (*PatchDeviceRequest) ProtoMessage()

func (*PatchDeviceRequest) Reset 

func (m *PatchDeviceRequest) Reset()

func (*PatchDeviceRequest) String 

func (m *PatchDeviceRequest) String() string

func (*PatchDeviceRequest) Validate 

func (this *PatchDeviceRequest) Validate() error

func (*PatchDeviceRequest) XXX_DiscardUnknown 

func (m *PatchDeviceRequest) XXX_DiscardUnknown()

func (*PatchDeviceRequest) XXX_Marshal 

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

func (*PatchDeviceRequest) XXX_Merge 

func (m *PatchDeviceRequest) XXX_Merge(src proto.Message)

func (*PatchDeviceRequest) XXX_Size 

func (m *PatchDeviceRequest) XXX_Size() int

func (*PatchDeviceRequest) XXX_Unmarshal 

func (m *PatchDeviceRequest) XXX_Unmarshal(b []byte) error

type PatchDeviceResponse 

type PatchDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchDeviceResponse) Descriptor 

func (*PatchDeviceResponse) Descriptor() ([]byte, []int)

func (*PatchDeviceResponse) GetDevice 

func (m *PatchDeviceResponse) GetDevice() *Device

func (*PatchDeviceResponse) ProtoMessage 

func (*PatchDeviceResponse) ProtoMessage()

func (*PatchDeviceResponse) Reset 

func (m *PatchDeviceResponse) Reset()

func (*PatchDeviceResponse) String 

func (m *PatchDeviceResponse) String() string

func (*PatchDeviceResponse) Validate 

func (this *PatchDeviceResponse) Validate() error

func (*PatchDeviceResponse) XXX_DiscardUnknown 

func (m *PatchDeviceResponse) XXX_DiscardUnknown()

func (*PatchDeviceResponse) XXX_Marshal 

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

func (*PatchDeviceResponse) XXX_Merge 

func (m *PatchDeviceResponse) XXX_Merge(src proto.Message)

func (*PatchDeviceResponse) XXX_Size 

func (m *PatchDeviceResponse) XXX_Size() int

func (*PatchDeviceResponse) XXX_Unmarshal 

func (m *PatchDeviceResponse) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowRequest 

type PullFrameFromFlowRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PullFrameFromFlowRequest_Config_
	Request              isPullFrameFromFlowRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*PullFrameFromFlowRequest) Descriptor 

func (*PullFrameFromFlowRequest) Descriptor() ([]byte, []int)

func (*PullFrameFromFlowRequest) GetConfig 

func (m *PullFrameFromFlowRequest) GetConfig() *PullFrameFromFlowRequest_Config

func (*PullFrameFromFlowRequest) GetId 

func (m *PullFrameFromFlowRequest) GetId() *wrappers.StringValue

func (*PullFrameFromFlowRequest) GetRequest 

func (m *PullFrameFromFlowRequest) GetRequest() isPullFrameFromFlowRequest_Request

func (*PullFrameFromFlowRequest) ProtoMessage 

func (*PullFrameFromFlowRequest) ProtoMessage()

func (*PullFrameFromFlowRequest) Reset 

func (m *PullFrameFromFlowRequest) Reset()

func (*PullFrameFromFlowRequest) String 

func (m *PullFrameFromFlowRequest) String() string

func (*PullFrameFromFlowRequest) Validate 

func (this *PullFrameFromFlowRequest) Validate() error

func (*PullFrameFromFlowRequest) XXX_DiscardUnknown 

func (m *PullFrameFromFlowRequest) XXX_DiscardUnknown()

func (*PullFrameFromFlowRequest) XXX_Marshal 

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

func (*PullFrameFromFlowRequest) XXX_Merge 

func (m *PullFrameFromFlowRequest) XXX_Merge(src proto.Message)

func (*PullFrameFromFlowRequest) XXX_OneofWrappers added in v1.0.0 

func (*PullFrameFromFlowRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowRequest) XXX_Size 

func (m *PullFrameFromFlowRequest) XXX_Size() int

func (*PullFrameFromFlowRequest) XXX_Unmarshal 

func (m *PullFrameFromFlowRequest) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowRequest_Config 

type PullFrameFromFlowRequest_Config struct {
	Device               *OpDevice           `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	ConfigAck            *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PullFrameFromFlowRequest_Config) Descriptor 

func (*PullFrameFromFlowRequest_Config) Descriptor() ([]byte, []int)

func (*PullFrameFromFlowRequest_Config) GetConfigAck 

func (m *PullFrameFromFlowRequest_Config) GetConfigAck() *wrappers.BoolValue

func (*PullFrameFromFlowRequest_Config) GetDevice 

func (m *PullFrameFromFlowRequest_Config) GetDevice() *OpDevice

func (*PullFrameFromFlowRequest_Config) ProtoMessage 

func (*PullFrameFromFlowRequest_Config) ProtoMessage()

func (*PullFrameFromFlowRequest_Config) Reset 

func (m *PullFrameFromFlowRequest_Config) Reset()

func (*PullFrameFromFlowRequest_Config) String 

func (m *PullFrameFromFlowRequest_Config) String() string

func (*PullFrameFromFlowRequest_Config) Validate 

func (this *PullFrameFromFlowRequest_Config) Validate() error

func (*PullFrameFromFlowRequest_Config) XXX_DiscardUnknown 

func (m *PullFrameFromFlowRequest_Config) XXX_DiscardUnknown()

func (*PullFrameFromFlowRequest_Config) XXX_Marshal 

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

func (*PullFrameFromFlowRequest_Config) XXX_Merge 

func (m *PullFrameFromFlowRequest_Config) XXX_Merge(src proto.Message)

func (*PullFrameFromFlowRequest_Config) XXX_Size 

func (m *PullFrameFromFlowRequest_Config) XXX_Size() int

func (*PullFrameFromFlowRequest_Config) XXX_Unmarshal 

func (m *PullFrameFromFlowRequest_Config) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowRequest_Config_ 

type PullFrameFromFlowRequest_Config_ struct {
	Config *PullFrameFromFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PullFrameFromFlowResponse 

type PullFrameFromFlowResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PullFrameFromFlowResponse_Ack_
	//	*PullFrameFromFlowResponse_Pack_
	Response             isPullFrameFromFlowResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*PullFrameFromFlowResponse) Descriptor 

func (*PullFrameFromFlowResponse) Descriptor() ([]byte, []int)

func (*PullFrameFromFlowResponse) GetAck 

func (m *PullFrameFromFlowResponse) GetAck() *PullFrameFromFlowResponse_Ack

func (*PullFrameFromFlowResponse) GetId 

func (m *PullFrameFromFlowResponse) GetId() string

func (*PullFrameFromFlowResponse) GetPack 

func (m *PullFrameFromFlowResponse) GetPack() *PullFrameFromFlowResponse_Pack

func (*PullFrameFromFlowResponse) GetResponse 

func (m *PullFrameFromFlowResponse) GetResponse() isPullFrameFromFlowResponse_Response

func (*PullFrameFromFlowResponse) ProtoMessage 

func (*PullFrameFromFlowResponse) ProtoMessage()

func (*PullFrameFromFlowResponse) Reset 

func (m *PullFrameFromFlowResponse) Reset()

func (*PullFrameFromFlowResponse) String 

func (m *PullFrameFromFlowResponse) String() string

func (*PullFrameFromFlowResponse) Validate 

func (this *PullFrameFromFlowResponse) Validate() error

func (*PullFrameFromFlowResponse) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse) XXX_Marshal 

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

func (*PullFrameFromFlowResponse) XXX_Merge 

func (m *PullFrameFromFlowResponse) XXX_Merge(src proto.Message)

func (*PullFrameFromFlowResponse) XXX_OneofWrappers added in v1.0.0 

func (*PullFrameFromFlowResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowResponse) XXX_Size 

func (m *PullFrameFromFlowResponse) XXX_Size() int

func (*PullFrameFromFlowResponse) XXX_Unmarshal 

func (m *PullFrameFromFlowResponse) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowResponse_Ack 

type PullFrameFromFlowResponse_Ack struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullFrameFromFlowResponse_Ack) Descriptor 

func (*PullFrameFromFlowResponse_Ack) Descriptor() ([]byte, []int)

func (*PullFrameFromFlowResponse_Ack) ProtoMessage 

func (*PullFrameFromFlowResponse_Ack) ProtoMessage()

func (*PullFrameFromFlowResponse_Ack) Reset 

func (m *PullFrameFromFlowResponse_Ack) Reset()

func (*PullFrameFromFlowResponse_Ack) String 

func (m *PullFrameFromFlowResponse_Ack) String() string

func (*PullFrameFromFlowResponse_Ack) Validate 

func (this *PullFrameFromFlowResponse_Ack) Validate() error

func (*PullFrameFromFlowResponse_Ack) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse_Ack) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse_Ack) XXX_Marshal 

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

func (*PullFrameFromFlowResponse_Ack) XXX_Merge 

func (m *PullFrameFromFlowResponse_Ack) XXX_Merge(src proto.Message)

func (*PullFrameFromFlowResponse_Ack) XXX_Size 

func (m *PullFrameFromFlowResponse_Ack) XXX_Size() int

func (*PullFrameFromFlowResponse_Ack) XXX_Unmarshal 

func (m *PullFrameFromFlowResponse_Ack) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowResponse_Ack_ 

type PullFrameFromFlowResponse_Ack_ struct {
	Ack *PullFrameFromFlowResponse_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PullFrameFromFlowResponse_Pack 

type PullFrameFromFlowResponse_Pack struct {
	Flow                 *Flow    `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	Frames               []*Frame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullFrameFromFlowResponse_Pack) Descriptor 

func (*PullFrameFromFlowResponse_Pack) Descriptor() ([]byte, []int)

func (*PullFrameFromFlowResponse_Pack) GetFlow 

func (m *PullFrameFromFlowResponse_Pack) GetFlow() *Flow

func (*PullFrameFromFlowResponse_Pack) GetFrames 

func (m *PullFrameFromFlowResponse_Pack) GetFrames() []*Frame

func (*PullFrameFromFlowResponse_Pack) ProtoMessage 

func (*PullFrameFromFlowResponse_Pack) ProtoMessage()

func (*PullFrameFromFlowResponse_Pack) Reset 

func (m *PullFrameFromFlowResponse_Pack) Reset()

func (*PullFrameFromFlowResponse_Pack) String 

func (m *PullFrameFromFlowResponse_Pack) String() string

func (*PullFrameFromFlowResponse_Pack) Validate 

func (this *PullFrameFromFlowResponse_Pack) Validate() error

func (*PullFrameFromFlowResponse_Pack) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse_Pack) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse_Pack) XXX_Marshal 

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

func (*PullFrameFromFlowResponse_Pack) XXX_Merge 

func (m *PullFrameFromFlowResponse_Pack) XXX_Merge(src proto.Message)

func (*PullFrameFromFlowResponse_Pack) XXX_Size 

func (m *PullFrameFromFlowResponse_Pack) XXX_Size() int

func (*PullFrameFromFlowResponse_Pack) XXX_Unmarshal 

func (m *PullFrameFromFlowResponse_Pack) XXX_Unmarshal(b []byte) error

type PullFrameFromFlowResponse_Pack_ 

type PullFrameFromFlowResponse_Pack_ struct {
	Pack *PullFrameFromFlowResponse_Pack `protobuf:"bytes,3,opt,name=pack,proto3,oneof"`
}

type PushFrameToFlowRequest 

type PushFrameToFlowRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PushFrameToFlowRequest_Config_
	//	*PushFrameToFlowRequest_Frame
	Request              isPushFrameToFlowRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*PushFrameToFlowRequest) Descriptor 

func (*PushFrameToFlowRequest) Descriptor() ([]byte, []int)

func (*PushFrameToFlowRequest) GetConfig 

func (m *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config

func (*PushFrameToFlowRequest) GetFrame 

func (m *PushFrameToFlowRequest) GetFrame() *OpFrame

func (*PushFrameToFlowRequest) GetId 

func (m *PushFrameToFlowRequest) GetId() *wrappers.StringValue

func (*PushFrameToFlowRequest) GetRequest 

func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request

func (*PushFrameToFlowRequest) ProtoMessage 

func (*PushFrameToFlowRequest) ProtoMessage()

func (*PushFrameToFlowRequest) Reset 

func (m *PushFrameToFlowRequest) Reset()

func (*PushFrameToFlowRequest) String 

func (m *PushFrameToFlowRequest) String() string

func (*PushFrameToFlowRequest) Validate 

func (this *PushFrameToFlowRequest) Validate() error

func (*PushFrameToFlowRequest) XXX_DiscardUnknown 

func (m *PushFrameToFlowRequest) XXX_DiscardUnknown()

func (*PushFrameToFlowRequest) XXX_Marshal 

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

func (*PushFrameToFlowRequest) XXX_Merge 

func (m *PushFrameToFlowRequest) XXX_Merge(src proto.Message)

func (*PushFrameToFlowRequest) XXX_OneofWrappers added in v1.0.0 

func (*PushFrameToFlowRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PushFrameToFlowRequest) XXX_Size 

func (m *PushFrameToFlowRequest) XXX_Size() int

func (*PushFrameToFlowRequest) XXX_Unmarshal 

func (m *PushFrameToFlowRequest) XXX_Unmarshal(b []byte) error

type PushFrameToFlowRequest_Config 

type PushFrameToFlowRequest_Config struct {
	Device               *OpDevice           `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	ConfigAck            *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	PushAck              *wrappers.BoolValue `protobuf:"bytes,3,opt,name=push_ack,json=pushAck,proto3" json:"push_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PushFrameToFlowRequest_Config) Descriptor 

func (*PushFrameToFlowRequest_Config) Descriptor() ([]byte, []int)

func (*PushFrameToFlowRequest_Config) GetConfigAck 

func (m *PushFrameToFlowRequest_Config) GetConfigAck() *wrappers.BoolValue

func (*PushFrameToFlowRequest_Config) GetDevice 

func (m *PushFrameToFlowRequest_Config) GetDevice() *OpDevice

func (*PushFrameToFlowRequest_Config) GetPushAck 

func (m *PushFrameToFlowRequest_Config) GetPushAck() *wrappers.BoolValue

func (*PushFrameToFlowRequest_Config) ProtoMessage 

func (*PushFrameToFlowRequest_Config) ProtoMessage()

func (*PushFrameToFlowRequest_Config) Reset 

func (m *PushFrameToFlowRequest_Config) Reset()

func (*PushFrameToFlowRequest_Config) String 

func (m *PushFrameToFlowRequest_Config) String() string

func (*PushFrameToFlowRequest_Config) Validate 

func (this *PushFrameToFlowRequest_Config) Validate() error

func (*PushFrameToFlowRequest_Config) XXX_DiscardUnknown 

func (m *PushFrameToFlowRequest_Config) XXX_DiscardUnknown()

func (*PushFrameToFlowRequest_Config) XXX_Marshal 

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

func (*PushFrameToFlowRequest_Config) XXX_Merge 

func (m *PushFrameToFlowRequest_Config) XXX_Merge(src proto.Message)

func (*PushFrameToFlowRequest_Config) XXX_Size 

func (m *PushFrameToFlowRequest_Config) XXX_Size() int

func (*PushFrameToFlowRequest_Config) XXX_Unmarshal 

func (m *PushFrameToFlowRequest_Config) XXX_Unmarshal(b []byte) error

type PushFrameToFlowRequest_Config_ 

type PushFrameToFlowRequest_Config_ struct {
	Config *PushFrameToFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowRequest_Frame 

type PushFrameToFlowRequest_Frame struct {
	Frame *OpFrame `protobuf:"bytes,3,opt,name=frame,proto3,oneof"`
}

type PushFrameToFlowResponse 

type PushFrameToFlowResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PushFrameToFlowResponse_Ack_
	Response             isPushFrameToFlowResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*PushFrameToFlowResponse) Descriptor 

func (*PushFrameToFlowResponse) Descriptor() ([]byte, []int)

func (*PushFrameToFlowResponse) GetAck 

func (m *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack

func (*PushFrameToFlowResponse) GetId 

func (m *PushFrameToFlowResponse) GetId() string

func (*PushFrameToFlowResponse) GetResponse 

func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response

func (*PushFrameToFlowResponse) ProtoMessage 

func (*PushFrameToFlowResponse) ProtoMessage()

func (*PushFrameToFlowResponse) Reset 

func (m *PushFrameToFlowResponse) Reset()

func (*PushFrameToFlowResponse) String 

func (m *PushFrameToFlowResponse) String() string

func (*PushFrameToFlowResponse) Validate 

func (this *PushFrameToFlowResponse) Validate() error

func (*PushFrameToFlowResponse) XXX_DiscardUnknown 

func (m *PushFrameToFlowResponse) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse) XXX_Marshal 

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

func (*PushFrameToFlowResponse) XXX_Merge 

func (m *PushFrameToFlowResponse) XXX_Merge(src proto.Message)

func (*PushFrameToFlowResponse) XXX_OneofWrappers added in v1.0.0 

func (*PushFrameToFlowResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PushFrameToFlowResponse) XXX_Size 

func (m *PushFrameToFlowResponse) XXX_Size() int

func (*PushFrameToFlowResponse) XXX_Unmarshal 

func (m *PushFrameToFlowResponse) XXX_Unmarshal(b []byte) error

type PushFrameToFlowResponse_Ack 

type PushFrameToFlowResponse_Ack struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushFrameToFlowResponse_Ack) Descriptor 

func (*PushFrameToFlowResponse_Ack) Descriptor() ([]byte, []int)

func (*PushFrameToFlowResponse_Ack) ProtoMessage 

func (*PushFrameToFlowResponse_Ack) ProtoMessage()

func (*PushFrameToFlowResponse_Ack) Reset 

func (m *PushFrameToFlowResponse_Ack) Reset()

func (*PushFrameToFlowResponse_Ack) String 

func (m *PushFrameToFlowResponse_Ack) String() string

func (*PushFrameToFlowResponse_Ack) Validate 

func (this *PushFrameToFlowResponse_Ack) Validate() error

func (*PushFrameToFlowResponse_Ack) XXX_DiscardUnknown 

func (m *PushFrameToFlowResponse_Ack) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse_Ack) XXX_Marshal 

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

func (*PushFrameToFlowResponse_Ack) XXX_Merge 

func (m *PushFrameToFlowResponse_Ack) XXX_Merge(src proto.Message)

func (*PushFrameToFlowResponse_Ack) XXX_Size 

func (m *PushFrameToFlowResponse_Ack) XXX_Size() int

func (*PushFrameToFlowResponse_Ack) XXX_Unmarshal 

func (m *PushFrameToFlowResponse_Ack) XXX_Unmarshal(b []byte) error

type PushFrameToFlowResponse_Ack_ 

type PushFrameToFlowResponse_Ack_ struct {
	Ack *PushFrameToFlowResponse_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PutObjectRequest 

type PutObjectRequest struct {
	Object               *OpObject            `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Content              *wrappers.BytesValue `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PutObjectRequest) Descriptor 

func (*PutObjectRequest) Descriptor() ([]byte, []int)

func (*PutObjectRequest) GetContent 

func (m *PutObjectRequest) GetContent() *wrappers.BytesValue

func (*PutObjectRequest) GetObject 

func (m *PutObjectRequest) GetObject() *OpObject

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) String 

func (m *PutObjectRequest) String() string

func (*PutObjectRequest) Validate 

func (this *PutObjectRequest) Validate() error

func (*PutObjectRequest) XXX_DiscardUnknown 

func (m *PutObjectRequest) XXX_DiscardUnknown()

func (*PutObjectRequest) XXX_Marshal 

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

func (*PutObjectRequest) XXX_Merge 

func (m *PutObjectRequest) XXX_Merge(src proto.Message)

func (*PutObjectRequest) XXX_Size 

func (m *PutObjectRequest) XXX_Size() int

func (*PutObjectRequest) XXX_Unmarshal 

func (m *PutObjectRequest) XXX_Unmarshal(b []byte) error

type QueryFramesFromFlowRequest 

type QueryFramesFromFlowRequest struct {
	Device               *OpDevice            `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	From                 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*QueryFramesFromFlowRequest) Descriptor 

func (*QueryFramesFromFlowRequest) Descriptor() ([]byte, []int)

func (*QueryFramesFromFlowRequest) GetDevice 

func (m *QueryFramesFromFlowRequest) GetDevice() *OpDevice

func (*QueryFramesFromFlowRequest) GetFrom 

func (m *QueryFramesFromFlowRequest) GetFrom() *timestamp.Timestamp

func (*QueryFramesFromFlowRequest) GetTo 

func (m *QueryFramesFromFlowRequest) GetTo() *timestamp.Timestamp

func (*QueryFramesFromFlowRequest) ProtoMessage 

func (*QueryFramesFromFlowRequest) ProtoMessage()

func (*QueryFramesFromFlowRequest) Reset 

func (m *QueryFramesFromFlowRequest) Reset()

func (*QueryFramesFromFlowRequest) String 

func (m *QueryFramesFromFlowRequest) String() string

func (*QueryFramesFromFlowRequest) Validate 

func (this *QueryFramesFromFlowRequest) Validate() error

func (*QueryFramesFromFlowRequest) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowRequest) XXX_DiscardUnknown()

func (*QueryFramesFromFlowRequest) XXX_Marshal 

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

func (*QueryFramesFromFlowRequest) XXX_Merge 

func (m *QueryFramesFromFlowRequest) XXX_Merge(src proto.Message)

func (*QueryFramesFromFlowRequest) XXX_Size 

func (m *QueryFramesFromFlowRequest) XXX_Size() int

func (*QueryFramesFromFlowRequest) XXX_Unmarshal 

func (m *QueryFramesFromFlowRequest) XXX_Unmarshal(b []byte) error

type QueryFramesFromFlowResponse 

type QueryFramesFromFlowResponse struct {
	Packs                []*QueryFramesFromFlowResponse_Pack `protobuf:"bytes,1,rep,name=packs,proto3" json:"packs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*QueryFramesFromFlowResponse) Descriptor 

func (*QueryFramesFromFlowResponse) Descriptor() ([]byte, []int)

func (*QueryFramesFromFlowResponse) GetPacks 

func (m *QueryFramesFromFlowResponse) GetPacks() []*QueryFramesFromFlowResponse_Pack

func (*QueryFramesFromFlowResponse) ProtoMessage 

func (*QueryFramesFromFlowResponse) ProtoMessage()

func (*QueryFramesFromFlowResponse) Reset 

func (m *QueryFramesFromFlowResponse) Reset()

func (*QueryFramesFromFlowResponse) String 

func (m *QueryFramesFromFlowResponse) String() string

func (*QueryFramesFromFlowResponse) Validate 

func (this *QueryFramesFromFlowResponse) Validate() error

func (*QueryFramesFromFlowResponse) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowResponse) XXX_DiscardUnknown()

func (*QueryFramesFromFlowResponse) XXX_Marshal 

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

func (*QueryFramesFromFlowResponse) XXX_Merge 

func (m *QueryFramesFromFlowResponse) XXX_Merge(src proto.Message)

func (*QueryFramesFromFlowResponse) XXX_Size 

func (m *QueryFramesFromFlowResponse) XXX_Size() int

func (*QueryFramesFromFlowResponse) XXX_Unmarshal 

func (m *QueryFramesFromFlowResponse) XXX_Unmarshal(b []byte) error

type QueryFramesFromFlowResponse_Pack 

type QueryFramesFromFlowResponse_Pack struct {
	Flow                 *Flow    `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	Frames               []*Frame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFramesFromFlowResponse_Pack) Descriptor 

func (*QueryFramesFromFlowResponse_Pack) Descriptor() ([]byte, []int)

func (*QueryFramesFromFlowResponse_Pack) GetFlow 

func (m *QueryFramesFromFlowResponse_Pack) GetFlow() *Flow

func (*QueryFramesFromFlowResponse_Pack) GetFrames 

func (m *QueryFramesFromFlowResponse_Pack) GetFrames() []*Frame

func (*QueryFramesFromFlowResponse_Pack) ProtoMessage 

func (*QueryFramesFromFlowResponse_Pack) ProtoMessage()

func (*QueryFramesFromFlowResponse_Pack) Reset 

func (m *QueryFramesFromFlowResponse_Pack) Reset()

func (*QueryFramesFromFlowResponse_Pack) String 

func (m *QueryFramesFromFlowResponse_Pack) String() string

func (*QueryFramesFromFlowResponse_Pack) Validate 

func (this *QueryFramesFromFlowResponse_Pack) Validate() error

func (*QueryFramesFromFlowResponse_Pack) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowResponse_Pack) XXX_DiscardUnknown()

func (*QueryFramesFromFlowResponse_Pack) XXX_Marshal 

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

func (*QueryFramesFromFlowResponse_Pack) XXX_Merge 

func (m *QueryFramesFromFlowResponse_Pack) XXX_Merge(src proto.Message)

func (*QueryFramesFromFlowResponse_Pack) XXX_Size 

func (m *QueryFramesFromFlowResponse_Pack) XXX_Size() int

func (*QueryFramesFromFlowResponse_Pack) XXX_Unmarshal 

func (m *QueryFramesFromFlowResponse_Pack) XXX_Unmarshal(b []byte) error

type RemoveObjectRequest 

type RemoveObjectRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RemoveObjectRequest) Descriptor 

func (*RemoveObjectRequest) Descriptor() ([]byte, []int)

func (*RemoveObjectRequest) GetObject 

func (m *RemoveObjectRequest) GetObject() *OpObject

func (*RemoveObjectRequest) ProtoMessage 

func (*RemoveObjectRequest) ProtoMessage()

func (*RemoveObjectRequest) Reset 

func (m *RemoveObjectRequest) Reset()

func (*RemoveObjectRequest) String 

func (m *RemoveObjectRequest) String() string

func (*RemoveObjectRequest) Validate 

func (this *RemoveObjectRequest) Validate() error

func (*RemoveObjectRequest) XXX_DiscardUnknown 

func (m *RemoveObjectRequest) XXX_DiscardUnknown()

func (*RemoveObjectRequest) XXX_Marshal 

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

func (*RemoveObjectRequest) XXX_Merge 

func (m *RemoveObjectRequest) XXX_Merge(src proto.Message)

func (*RemoveObjectRequest) XXX_Size 

func (m *RemoveObjectRequest) XXX_Size() int

func (*RemoveObjectRequest) XXX_Unmarshal 

func (m *RemoveObjectRequest) XXX_Unmarshal(b []byte) error

type RenameObjectRequest 

type RenameObjectRequest struct {
	Source               *OpObject `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination          *OpObject `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RenameObjectRequest) Descriptor 

func (*RenameObjectRequest) Descriptor() ([]byte, []int)

func (*RenameObjectRequest) GetDestination 

func (m *RenameObjectRequest) GetDestination() *OpObject

func (*RenameObjectRequest) GetSource 

func (m *RenameObjectRequest) GetSource() *OpObject

func (*RenameObjectRequest) ProtoMessage 

func (*RenameObjectRequest) ProtoMessage()

func (*RenameObjectRequest) Reset 

func (m *RenameObjectRequest) Reset()

func (*RenameObjectRequest) String 

func (m *RenameObjectRequest) String() string

func (*RenameObjectRequest) Validate 

func (this *RenameObjectRequest) Validate() error

func (*RenameObjectRequest) XXX_DiscardUnknown 

func (m *RenameObjectRequest) XXX_DiscardUnknown()

func (*RenameObjectRequest) XXX_Marshal 

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

func (*RenameObjectRequest) XXX_Merge 

func (m *RenameObjectRequest) XXX_Merge(src proto.Message)

func (*RenameObjectRequest) XXX_Size 

func (m *RenameObjectRequest) XXX_Size() int

func (*RenameObjectRequest) XXX_Unmarshal 

func (m *RenameObjectRequest) XXX_Unmarshal(b []byte) error

type ShowDeviceResponse 

type ShowDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowDeviceResponse) Descriptor 

func (*ShowDeviceResponse) Descriptor() ([]byte, []int)

func (*ShowDeviceResponse) GetDevice 

func (m *ShowDeviceResponse) GetDevice() *Device

func (*ShowDeviceResponse) ProtoMessage 

func (*ShowDeviceResponse) ProtoMessage()

func (*ShowDeviceResponse) Reset 

func (m *ShowDeviceResponse) Reset()

func (*ShowDeviceResponse) String 

func (m *ShowDeviceResponse) String() string

func (*ShowDeviceResponse) Validate 

func (this *ShowDeviceResponse) Validate() error

func (*ShowDeviceResponse) XXX_DiscardUnknown 

func (m *ShowDeviceResponse) XXX_DiscardUnknown()

func (*ShowDeviceResponse) XXX_Marshal 

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

func (*ShowDeviceResponse) XXX_Merge 

func (m *ShowDeviceResponse) XXX_Merge(src proto.Message)

func (*ShowDeviceResponse) XXX_Size 

func (m *ShowDeviceResponse) XXX_Size() int

func (*ShowDeviceResponse) XXX_Unmarshal 

func (m *ShowDeviceResponse) XXX_Unmarshal(b []byte) error

type StreamCallConfig 

type StreamCallConfig struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallConfig) Descriptor 

func (*StreamCallConfig) Descriptor() ([]byte, []int)

func (*StreamCallConfig) GetComponent 

func (m *StreamCallConfig) GetComponent() string

func (*StreamCallConfig) GetMethod 

func (m *StreamCallConfig) GetMethod() string

func (*StreamCallConfig) GetName 

func (m *StreamCallConfig) GetName() string

func (*StreamCallConfig) ProtoMessage 

func (*StreamCallConfig) ProtoMessage()

func (*StreamCallConfig) Reset 

func (m *StreamCallConfig) Reset()

func (*StreamCallConfig) String 

func (m *StreamCallConfig) String() string

func (*StreamCallConfig) Validate 

func (this *StreamCallConfig) Validate() error

func (*StreamCallConfig) XXX_DiscardUnknown 

func (m *StreamCallConfig) XXX_DiscardUnknown()

func (*StreamCallConfig) XXX_Marshal 

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

func (*StreamCallConfig) XXX_Merge 

func (m *StreamCallConfig) XXX_Merge(src proto.Message)

func (*StreamCallConfig) XXX_Size 

func (m *StreamCallConfig) XXX_Size() int

func (*StreamCallConfig) XXX_Unmarshal 

func (m *StreamCallConfig) XXX_Unmarshal(b []byte) error

type StreamCallConfigAck 

type StreamCallConfigAck struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallConfigAck) Descriptor 

func (*StreamCallConfigAck) Descriptor() ([]byte, []int)

func (*StreamCallConfigAck) ProtoMessage 

func (*StreamCallConfigAck) ProtoMessage()

func (*StreamCallConfigAck) Reset 

func (m *StreamCallConfigAck) Reset()

func (*StreamCallConfigAck) String 

func (m *StreamCallConfigAck) String() string

func (*StreamCallConfigAck) Validate 

func (this *StreamCallConfigAck) Validate() error

func (*StreamCallConfigAck) XXX_DiscardUnknown 

func (m *StreamCallConfigAck) XXX_DiscardUnknown()

func (*StreamCallConfigAck) XXX_Marshal 

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

func (*StreamCallConfigAck) XXX_Merge 

func (m *StreamCallConfigAck) XXX_Merge(src proto.Message)

func (*StreamCallConfigAck) XXX_Size 

func (m *StreamCallConfigAck) XXX_Size() int

func (*StreamCallConfigAck) XXX_Unmarshal 

func (m *StreamCallConfigAck) XXX_Unmarshal(b []byte) error

type StreamCallExit 

type StreamCallExit struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallExit) Descriptor 

func (*StreamCallExit) Descriptor() ([]byte, []int)

func (*StreamCallExit) ProtoMessage 

func (*StreamCallExit) ProtoMessage()

func (*StreamCallExit) Reset 

func (m *StreamCallExit) Reset()

func (*StreamCallExit) String 

func (m *StreamCallExit) String() string

func (*StreamCallExit) Validate 

func (this *StreamCallExit) Validate() error

func (*StreamCallExit) XXX_DiscardUnknown 

func (m *StreamCallExit) XXX_DiscardUnknown()

func (*StreamCallExit) XXX_Marshal 

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

func (*StreamCallExit) XXX_Merge 

func (m *StreamCallExit) XXX_Merge(src proto.Message)

func (*StreamCallExit) XXX_Size 

func (m *StreamCallExit) XXX_Size() int

func (*StreamCallExit) XXX_Unmarshal 

func (m *StreamCallExit) XXX_Unmarshal(b []byte) error

type StreamCallRequest 

type StreamCallRequest struct {
	Device               *OpDevice          `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *OpStreamCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*StreamCallRequest) Descriptor 

func (*StreamCallRequest) Descriptor() ([]byte, []int)

func (*StreamCallRequest) GetDevice 

func (m *StreamCallRequest) GetDevice() *OpDevice

func (*StreamCallRequest) GetValue 

func (m *StreamCallRequest) GetValue() *OpStreamCallValue

func (*StreamCallRequest) ProtoMessage 

func (*StreamCallRequest) ProtoMessage()

func (*StreamCallRequest) Reset 

func (m *StreamCallRequest) Reset()

func (*StreamCallRequest) String 

func (m *StreamCallRequest) String() string

func (*StreamCallRequest) Validate 

func (this *StreamCallRequest) Validate() error

func (*StreamCallRequest) XXX_DiscardUnknown 

func (m *StreamCallRequest) XXX_DiscardUnknown()

func (*StreamCallRequest) XXX_Marshal 

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

func (*StreamCallRequest) XXX_Merge 

func (m *StreamCallRequest) XXX_Merge(src proto.Message)

func (*StreamCallRequest) XXX_Size 

func (m *StreamCallRequest) XXX_Size() int

func (*StreamCallRequest) XXX_Unmarshal 

func (m *StreamCallRequest) XXX_Unmarshal(b []byte) error

type StreamCallResponse 

type StreamCallResponse struct {
	Device               *Device          `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *StreamCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*StreamCallResponse) Descriptor 

func (*StreamCallResponse) Descriptor() ([]byte, []int)

func (*StreamCallResponse) GetDevice 

func (m *StreamCallResponse) GetDevice() *Device

func (*StreamCallResponse) GetValue 

func (m *StreamCallResponse) GetValue() *StreamCallValue

func (*StreamCallResponse) ProtoMessage 

func (*StreamCallResponse) ProtoMessage()

func (*StreamCallResponse) Reset 

func (m *StreamCallResponse) Reset()

func (*StreamCallResponse) String 

func (m *StreamCallResponse) String() string

func (*StreamCallResponse) Validate 

func (this *StreamCallResponse) Validate() error

func (*StreamCallResponse) XXX_DiscardUnknown 

func (m *StreamCallResponse) XXX_DiscardUnknown()

func (*StreamCallResponse) XXX_Marshal 

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

func (*StreamCallResponse) XXX_Merge 

func (m *StreamCallResponse) XXX_Merge(src proto.Message)

func (*StreamCallResponse) XXX_Size 

func (m *StreamCallResponse) XXX_Size() int

func (*StreamCallResponse) XXX_Unmarshal 

func (m *StreamCallResponse) XXX_Unmarshal(b []byte) error

type StreamCallValue 

type StreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*StreamCallValue_Value
	//	*StreamCallValue_Config
	//	*StreamCallValue_ConfigAck
	//	*StreamCallValue_Exit
	Union                isStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StreamCallValue) Descriptor 

func (*StreamCallValue) Descriptor() ([]byte, []int)

func (*StreamCallValue) GetConfig 

func (m *StreamCallValue) GetConfig() *StreamCallConfig

func (*StreamCallValue) GetConfigAck 

func (m *StreamCallValue) GetConfigAck() *StreamCallConfigAck

func (*StreamCallValue) GetExit 

func (m *StreamCallValue) GetExit() *StreamCallExit

func (*StreamCallValue) GetUnion 

func (m *StreamCallValue) GetUnion() isStreamCallValue_Union

func (*StreamCallValue) GetValue 

func (m *StreamCallValue) GetValue() *any.Any

func (*StreamCallValue) ProtoMessage 

func (*StreamCallValue) ProtoMessage()

func (*StreamCallValue) Reset 

func (m *StreamCallValue) Reset()

func (*StreamCallValue) String 

func (m *StreamCallValue) String() string

func (*StreamCallValue) Validate 

func (this *StreamCallValue) Validate() error

func (*StreamCallValue) XXX_DiscardUnknown 

func (m *StreamCallValue) XXX_DiscardUnknown()

func (*StreamCallValue) XXX_Marshal 

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

func (*StreamCallValue) XXX_Merge 

func (m *StreamCallValue) XXX_Merge(src proto.Message)

func (*StreamCallValue) XXX_OneofWrappers added in v1.0.0 

func (*StreamCallValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallValue) XXX_Size 

func (m *StreamCallValue) XXX_Size() int

func (*StreamCallValue) XXX_Unmarshal 

func (m *StreamCallValue) XXX_Unmarshal(b []byte) error

type StreamCallValue_Config 

type StreamCallValue_Config struct {
	Config *StreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type StreamCallValue_ConfigAck 

type StreamCallValue_ConfigAck struct {
	ConfigAck *StreamCallConfigAck `protobuf:"bytes,3,opt,name=config_ack,json=configAck,proto3,oneof"`
}

type StreamCallValue_Exit 

type StreamCallValue_Exit struct {
	Exit *StreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type StreamCallValue_Value 

type StreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type UnaryCallRequest 

type UnaryCallRequest struct {
	Device               *OpDevice         `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *OpUnaryCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UnaryCallRequest) Descriptor 

func (*UnaryCallRequest) Descriptor() ([]byte, []int)

func (*UnaryCallRequest) GetDevice 

func (m *UnaryCallRequest) GetDevice() *OpDevice

func (*UnaryCallRequest) GetValue 

func (m *UnaryCallRequest) GetValue() *OpUnaryCallValue

func (*UnaryCallRequest) ProtoMessage 

func (*UnaryCallRequest) ProtoMessage()

func (*UnaryCallRequest) Reset 

func (m *UnaryCallRequest) Reset()

func (*UnaryCallRequest) String 

func (m *UnaryCallRequest) String() string

func (*UnaryCallRequest) Validate 

func (this *UnaryCallRequest) Validate() error

func (*UnaryCallRequest) XXX_DiscardUnknown 

func (m *UnaryCallRequest) XXX_DiscardUnknown()

func (*UnaryCallRequest) XXX_Marshal 

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

func (*UnaryCallRequest) XXX_Merge 

func (m *UnaryCallRequest) XXX_Merge(src proto.Message)

func (*UnaryCallRequest) XXX_Size 

func (m *UnaryCallRequest) XXX_Size() int

func (*UnaryCallRequest) XXX_Unmarshal 

func (m *UnaryCallRequest) XXX_Unmarshal(b []byte) error

type UnaryCallResponse 

type UnaryCallResponse struct {
	Device               *Device         `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *UnaryCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*UnaryCallResponse) Descriptor 

func (*UnaryCallResponse) Descriptor() ([]byte, []int)

func (*UnaryCallResponse) GetDevice 

func (m *UnaryCallResponse) GetDevice() *Device

func (*UnaryCallResponse) GetValue 

func (m *UnaryCallResponse) GetValue() *UnaryCallValue

func (*UnaryCallResponse) ProtoMessage 

func (*UnaryCallResponse) ProtoMessage()

func (*UnaryCallResponse) Reset 

func (m *UnaryCallResponse) Reset()

func (*UnaryCallResponse) String 

func (m *UnaryCallResponse) String() string

func (*UnaryCallResponse) Validate 

func (this *UnaryCallResponse) Validate() error

func (*UnaryCallResponse) XXX_DiscardUnknown 

func (m *UnaryCallResponse) XXX_DiscardUnknown()

func (*UnaryCallResponse) XXX_Marshal 

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

func (*UnaryCallResponse) XXX_Merge 

func (m *UnaryCallResponse) XXX_Merge(src proto.Message)

func (*UnaryCallResponse) XXX_Size 

func (m *UnaryCallResponse) XXX_Size() int

func (*UnaryCallResponse) XXX_Unmarshal 

func (m *UnaryCallResponse) XXX_Unmarshal(b []byte) error

type UnaryCallValue 

type UnaryCallValue struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnaryCallValue) Descriptor 

func (*UnaryCallValue) Descriptor() ([]byte, []int)

func (*UnaryCallValue) GetComponent 

func (m *UnaryCallValue) GetComponent() string

func (*UnaryCallValue) GetMethod 

func (m *UnaryCallValue) GetMethod() string

func (*UnaryCallValue) GetName 

func (m *UnaryCallValue) GetName() string

func (*UnaryCallValue) GetValue 

func (m *UnaryCallValue) GetValue() *any.Any

func (*UnaryCallValue) ProtoMessage 

func (*UnaryCallValue) ProtoMessage()

func (*UnaryCallValue) Reset 

func (m *UnaryCallValue) Reset()

func (*UnaryCallValue) String 

func (m *UnaryCallValue) String() string

func (*UnaryCallValue) Validate 

func (this *UnaryCallValue) Validate() error

func (*UnaryCallValue) XXX_DiscardUnknown 

func (m *UnaryCallValue) XXX_DiscardUnknown()

func (*UnaryCallValue) XXX_Marshal 

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

func (*UnaryCallValue) XXX_Merge 

func (m *UnaryCallValue) XXX_Merge(src proto.Message)

func (*UnaryCallValue) XXX_Size 

func (m *UnaryCallValue) XXX_Size() int

func (*UnaryCallValue) XXX_Unmarshal 

func (m *UnaryCallValue) XXX_Unmarshal(b []byte) error

type UnimplementedDevicedServiceServer added in v1.0.0 

type UnimplementedDevicedServiceServer struct {
}

UnimplementedDevicedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDevicedServiceServer) Connect added in v1.0.0 

func (*UnimplementedDevicedServiceServer) Connect(srv DevicedService_ConnectServer) error

func (*UnimplementedDevicedServiceServer) CreateDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) CreateDevice(ctx context.Context, req *CreateDeviceRequest) (*CreateDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) DeleteDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) DeleteDevice(ctx context.Context, req *DeleteDeviceRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) GetDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetDevice(ctx context.Context, req *GetDeviceRequest) (*GetDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) GetDeviceByModule added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetDeviceByModule(ctx context.Context, req *GetDeviceByModuleRequest) (*GetDeviceByModuleResponse, error)

func (*UnimplementedDevicedServiceServer) GetObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObject(ctx context.Context, req *GetObjectRequest) (*GetObjectResponse, error)

func (*UnimplementedDevicedServiceServer) GetObjectContent added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObjectContent(ctx context.Context, req *GetObjectContentRequest) (*GetObjectContentResponse, error)

func (*UnimplementedDevicedServiceServer) GetObjectStreamingContent added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObjectStreamingContent(req *GetObjectStreamingContentRequest, srv DevicedService_GetObjectStreamingContentServer) error

func (*UnimplementedDevicedServiceServer) Heartbeat added in v1.0.0 

func (*UnimplementedDevicedServiceServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) ListDevices added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ListDevices(ctx context.Context, req *ListDevicesRequest) (*ListDevicesResponse, error)

func (*UnimplementedDevicedServiceServer) ListObjects added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ListObjects(ctx context.Context, req *ListObjectsRequest) (*ListObjectsResponse, error)

func (*UnimplementedDevicedServiceServer) PatchDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PatchDevice(ctx context.Context, req *PatchDeviceRequest) (*PatchDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) PullFrameFromFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PullFrameFromFlow(req *PullFrameFromFlowRequest, srv DevicedService_PullFrameFromFlowServer) error

func (*UnimplementedDevicedServiceServer) PushFrameToFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PushFrameToFlow(srv DevicedService_PushFrameToFlowServer) error

func (*UnimplementedDevicedServiceServer) PutObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PutObject(ctx context.Context, req *PutObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) QueryFramesFromFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) QueryFramesFromFlow(ctx context.Context, req *QueryFramesFromFlowRequest) (*QueryFramesFromFlowResponse, error)

func (*UnimplementedDevicedServiceServer) RemoveObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) RemoveObject(ctx context.Context, req *RemoveObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) RenameObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) RenameObject(ctx context.Context, req *RenameObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) ShowDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ShowDevice(ctx context.Context, req *empty.Empty) (*ShowDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) StreamCall added in v1.0.0 

func (*UnimplementedDevicedServiceServer) StreamCall(srv DevicedService_StreamCallServer) error

func (*UnimplementedDevicedServiceServer) UnaryCall added in v1.0.0 

func (*UnimplementedDevicedServiceServer) UnaryCall(ctx context.Context, req *UnaryCallRequest) (*UnaryCallResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.