Documentation
¶
Index ¶
- Variables
- type Command
- func (*Command) Descriptor() ([]byte, []int)deprecated
- func (x *Command) GetConfigurationControl() *ConfigurationControl
- func (x *Command) GetContext() *Context
- func (x *Command) GetFunctionControl() *FunctionControl
- func (x *Command) GetStreamControl() *StreamControl
- func (m *Command) GetType() isCommand_Type
- func (*Command) ProtoMessage()
- func (x *Command) ProtoReflect() protoreflect.Message
- func (x *Command) Reset()
- func (x *Command) String() string
- type Command_ConfigurationControl
- type Command_FunctionControl
- type Command_StreamControl
- type ConfigurationControl
- func (*ConfigurationControl) Descriptor() ([]byte, []int)deprecated
- func (m *ConfigurationControl) GetAction() isConfigurationControl_Action
- func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlDescribe() *anypb.Any
- func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlGet() *anypb.Any
- func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlSet() *anypb.Any
- func (*ConfigurationControl) ProtoMessage()
- func (x *ConfigurationControl) ProtoReflect() protoreflect.Message
- func (x *ConfigurationControl) Reset()
- func (x *ConfigurationControl) String() string
- type ConfigurationControlResponse
- func (*ConfigurationControlResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigurationControlResponse) GetFunctionSpecificConfigurationControlResponse() *anypb.Any
- func (*ConfigurationControlResponse) ProtoMessage()
- func (x *ConfigurationControlResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigurationControlResponse) Reset()
- func (x *ConfigurationControlResponse) String() string
- type ConfigurationControl_FunctionSpecificConfigurationControlDescribe
- type ConfigurationControl_FunctionSpecificConfigurationControlGet
- type ConfigurationControl_FunctionSpecificConfigurationControlSet
- type Context
- type Error
- type FunctionControl
- func (*FunctionControl) Descriptor() ([]byte, []int)deprecated
- func (m *FunctionControl) GetAction() isFunctionControl_Action
- func (x *FunctionControl) GetFunctionSpecificFunctionControlGet() *anypb.Any
- func (x *FunctionControl) GetFunctionSpecificFunctionControlSet() *anypb.Any
- func (*FunctionControl) ProtoMessage()
- func (x *FunctionControl) ProtoReflect() protoreflect.Message
- func (x *FunctionControl) Reset()
- func (x *FunctionControl) String() string
- type FunctionControlResponse
- func (*FunctionControlResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionControlResponse) GetFunctionSpecificFunctionControlResponse() *anypb.Any
- func (*FunctionControlResponse) ProtoMessage()
- func (x *FunctionControlResponse) ProtoReflect() protoreflect.Message
- func (x *FunctionControlResponse) Reset()
- func (x *FunctionControlResponse) String() string
- type FunctionControl_FunctionSpecificFunctionControlGet
- type FunctionControl_FunctionSpecificFunctionControlSet
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetConfigurationControl() *ConfigurationControlResponse
- func (x *Response) GetContext() *Context
- func (x *Response) GetError() *Error
- func (x *Response) GetFunctionControl() *FunctionControlResponse
- func (x *Response) GetStatus() Status
- func (x *Response) GetStream() *StreamData
- func (x *Response) GetStreamControl() *StreamControlResponse
- func (m *Response) GetType() isResponse_Type
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type Response_ConfigurationControl
- type Response_FunctionControl
- type Response_Stream
- type Response_StreamControl
- type Status
- type StreamControl
- func (*StreamControl) Descriptor() ([]byte, []int)deprecated
- func (m *StreamControl) GetAction() isStreamControl_Action
- func (x *StreamControl) GetStart() *StreamControlStart
- func (x *StreamControl) GetStop() *StreamControlStop
- func (*StreamControl) ProtoMessage()
- func (x *StreamControl) ProtoReflect() protoreflect.Message
- func (x *StreamControl) Reset()
- func (x *StreamControl) String() string
- type StreamControlResponse
- type StreamControlStart
- func (*StreamControlStart) Descriptor() ([]byte, []int)deprecated
- func (x *StreamControlStart) GetFunctionSpecificStreamControlStart() *anypb.Any
- func (*StreamControlStart) ProtoMessage()
- func (x *StreamControlStart) ProtoReflect() protoreflect.Message
- func (x *StreamControlStart) Reset()
- func (x *StreamControlStart) String() string
- type StreamControlStop
- type StreamControl_Start
- type StreamControl_Stop
- type StreamData
- func (*StreamData) Descriptor() ([]byte, []int)deprecated
- func (x *StreamData) GetDeliveryTimestampUs() uint64
- func (x *StreamData) GetFunctionSpecificStreamData() *anypb.Any
- func (x *StreamData) GetSequence() uint32
- func (*StreamData) ProtoMessage()
- func (x *StreamData) ProtoReflect() protoreflect.Message
- func (x *StreamData) Reset()
- func (x *StreamData) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Status_name = map[int32]string{ 0: "OK", 1: "ERROR", 2: "NOT_IMPLEMENTED", 3: "WRONG_CLIENT", } Status_value = map[string]int32{ "OK": 0, "ERROR": 1, "NOT_IMPLEMENTED": 2, "WRONG_CLIENT": 3, } )
Enum value maps for Status.
var File_io4edge_functionblock_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Command ¶
type Command struct {
Context *Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
// Types that are assignable to Type:
// *Command_ConfigurationControl
// *Command_FunctionControl
// *Command_StreamControl
Type isCommand_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
------- Commands ---------
func (*Command) Descriptor
deprecated
func (*Command) GetConfigurationControl ¶
func (x *Command) GetConfigurationControl() *ConfigurationControl
func (*Command) GetContext ¶
func (*Command) GetFunctionControl ¶
func (x *Command) GetFunctionControl() *FunctionControl
func (*Command) GetStreamControl ¶
func (x *Command) GetStreamControl() *StreamControl
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) ProtoReflect ¶
func (x *Command) ProtoReflect() protoreflect.Message
type Command_ConfigurationControl ¶
type Command_ConfigurationControl struct {
ConfigurationControl *ConfigurationControl `protobuf:"bytes,2,opt,name=configurationControl,proto3,oneof"`
}
type Command_FunctionControl ¶
type Command_FunctionControl struct {
FunctionControl *FunctionControl `protobuf:"bytes,3,opt,name=functionControl,proto3,oneof"`
}
type Command_StreamControl ¶
type Command_StreamControl struct {
StreamControl *StreamControl `protobuf:"bytes,4,opt,name=streamControl,proto3,oneof"`
}
type ConfigurationControl ¶
type ConfigurationControl struct {
// Types that are assignable to Action:
// *ConfigurationControl_FunctionSpecificConfigurationControlSet
// *ConfigurationControl_FunctionSpecificConfigurationControlGet
// *ConfigurationControl_FunctionSpecificConfigurationControlDescribe
Action isConfigurationControl_Action `protobuf_oneof:"action"`
// contains filtered or unexported fields
}
ConfigurationControl contains the function blocks high level configuration
func (*ConfigurationControl) Descriptor
deprecated
func (*ConfigurationControl) Descriptor() ([]byte, []int)
Deprecated: Use ConfigurationControl.ProtoReflect.Descriptor instead.
func (*ConfigurationControl) GetAction ¶
func (m *ConfigurationControl) GetAction() isConfigurationControl_Action
func (*ConfigurationControl) GetFunctionSpecificConfigurationControlDescribe ¶
func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlDescribe() *anypb.Any
func (*ConfigurationControl) GetFunctionSpecificConfigurationControlGet ¶
func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlGet() *anypb.Any
func (*ConfigurationControl) GetFunctionSpecificConfigurationControlSet ¶
func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlSet() *anypb.Any
func (*ConfigurationControl) ProtoMessage ¶
func (*ConfigurationControl) ProtoMessage()
func (*ConfigurationControl) ProtoReflect ¶
func (x *ConfigurationControl) ProtoReflect() protoreflect.Message
func (*ConfigurationControl) Reset ¶
func (x *ConfigurationControl) Reset()
func (*ConfigurationControl) String ¶
func (x *ConfigurationControl) String() string
type ConfigurationControlResponse ¶
type ConfigurationControlResponse struct {
FunctionSpecificConfigurationControlResponse *anypb.Any `` /* 142-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ConfigurationControlResponse) Descriptor
deprecated
func (*ConfigurationControlResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigurationControlResponse.ProtoReflect.Descriptor instead.
func (*ConfigurationControlResponse) GetFunctionSpecificConfigurationControlResponse ¶
func (x *ConfigurationControlResponse) GetFunctionSpecificConfigurationControlResponse() *anypb.Any
func (*ConfigurationControlResponse) ProtoMessage ¶
func (*ConfigurationControlResponse) ProtoMessage()
func (*ConfigurationControlResponse) ProtoReflect ¶
func (x *ConfigurationControlResponse) ProtoReflect() protoreflect.Message
func (*ConfigurationControlResponse) Reset ¶
func (x *ConfigurationControlResponse) Reset()
func (*ConfigurationControlResponse) String ¶
func (x *ConfigurationControlResponse) String() string
type Context ¶
type Context struct {
// A message identifying key for a command-response pairs, e.g. an UUID the
// clients sends on the request.
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
-------- Meta ------------
func (*Context) Descriptor
deprecated
func (*Context) ProtoMessage ¶
func (*Context) ProtoMessage()
func (*Context) ProtoReflect ¶
func (x *Context) ProtoReflect() protoreflect.Message
type Error ¶
type Error struct {
Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*Error) Descriptor
deprecated
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type FunctionControl ¶
type FunctionControl struct {
// Types that are assignable to Action:
// *FunctionControl_FunctionSpecificFunctionControlSet
// *FunctionControl_FunctionSpecificFunctionControlGet
Action isFunctionControl_Action `protobuf_oneof:"action"`
// contains filtered or unexported fields
}
FunctionControl specifies the direct function control for getting and setting values
func (*FunctionControl) Descriptor
deprecated
func (*FunctionControl) Descriptor() ([]byte, []int)
Deprecated: Use FunctionControl.ProtoReflect.Descriptor instead.
func (*FunctionControl) GetAction ¶
func (m *FunctionControl) GetAction() isFunctionControl_Action
func (*FunctionControl) GetFunctionSpecificFunctionControlGet ¶
func (x *FunctionControl) GetFunctionSpecificFunctionControlGet() *anypb.Any
func (*FunctionControl) GetFunctionSpecificFunctionControlSet ¶
func (x *FunctionControl) GetFunctionSpecificFunctionControlSet() *anypb.Any
func (*FunctionControl) ProtoMessage ¶
func (*FunctionControl) ProtoMessage()
func (*FunctionControl) ProtoReflect ¶
func (x *FunctionControl) ProtoReflect() protoreflect.Message
func (*FunctionControl) Reset ¶
func (x *FunctionControl) Reset()
func (*FunctionControl) String ¶
func (x *FunctionControl) String() string
type FunctionControlResponse ¶
type FunctionControlResponse struct {
FunctionSpecificFunctionControlResponse *anypb.Any `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FunctionControlResponse) Descriptor
deprecated
func (*FunctionControlResponse) Descriptor() ([]byte, []int)
Deprecated: Use FunctionControlResponse.ProtoReflect.Descriptor instead.
func (*FunctionControlResponse) GetFunctionSpecificFunctionControlResponse ¶
func (x *FunctionControlResponse) GetFunctionSpecificFunctionControlResponse() *anypb.Any
func (*FunctionControlResponse) ProtoMessage ¶
func (*FunctionControlResponse) ProtoMessage()
func (*FunctionControlResponse) ProtoReflect ¶
func (x *FunctionControlResponse) ProtoReflect() protoreflect.Message
func (*FunctionControlResponse) Reset ¶
func (x *FunctionControlResponse) Reset()
func (*FunctionControlResponse) String ¶
func (x *FunctionControlResponse) String() string
type Response ¶
type Response struct {
Context *Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=functionblock.Status" json:"status,omitempty"`
Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// Types that are assignable to Type:
// *Response_ConfigurationControl
// *Response_FunctionControl
// *Response_StreamControl
// *Response_Stream
Type isResponse_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*Response) Descriptor
deprecated
func (*Response) GetConfigurationControl ¶
func (x *Response) GetConfigurationControl() *ConfigurationControlResponse
func (*Response) GetContext ¶
func (*Response) GetFunctionControl ¶
func (x *Response) GetFunctionControl() *FunctionControlResponse
func (*Response) GetStream ¶
func (x *Response) GetStream() *StreamData
func (*Response) GetStreamControl ¶
func (x *Response) GetStreamControl() *StreamControlResponse
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_ConfigurationControl ¶
type Response_ConfigurationControl struct {
ConfigurationControl *ConfigurationControlResponse `protobuf:"bytes,4,opt,name=configurationControl,proto3,oneof"`
}
type Response_FunctionControl ¶
type Response_FunctionControl struct {
FunctionControl *FunctionControlResponse `protobuf:"bytes,5,opt,name=functionControl,proto3,oneof"`
}
type Response_Stream ¶
type Response_Stream struct {
Stream *StreamData `protobuf:"bytes,7,opt,name=stream,proto3,oneof"`
}
type Response_StreamControl ¶
type Response_StreamControl struct {
StreamControl *StreamControlResponse `protobuf:"bytes,6,opt,name=streamControl,proto3,oneof"`
}
type Status ¶
type Status int32
--------- Responses ------------
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type StreamControl ¶
type StreamControl struct {
// Types that are assignable to Action:
// *StreamControl_Start
// *StreamControl_Stop
Action isStreamControl_Action `protobuf_oneof:"action"`
// contains filtered or unexported fields
}
StreamControl specifies if the stream shall be started or stopped
func (*StreamControl) Descriptor
deprecated
func (*StreamControl) Descriptor() ([]byte, []int)
Deprecated: Use StreamControl.ProtoReflect.Descriptor instead.
func (*StreamControl) GetAction ¶
func (m *StreamControl) GetAction() isStreamControl_Action
func (*StreamControl) GetStart ¶
func (x *StreamControl) GetStart() *StreamControlStart
func (*StreamControl) GetStop ¶
func (x *StreamControl) GetStop() *StreamControlStop
func (*StreamControl) ProtoMessage ¶
func (*StreamControl) ProtoMessage()
func (*StreamControl) ProtoReflect ¶
func (x *StreamControl) ProtoReflect() protoreflect.Message
func (*StreamControl) Reset ¶
func (x *StreamControl) Reset()
func (*StreamControl) String ¶
func (x *StreamControl) String() string
type StreamControlResponse ¶
type StreamControlResponse struct {
// contains filtered or unexported fields
}
func (*StreamControlResponse) Descriptor
deprecated
func (*StreamControlResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamControlResponse.ProtoReflect.Descriptor instead.
func (*StreamControlResponse) ProtoMessage ¶
func (*StreamControlResponse) ProtoMessage()
func (*StreamControlResponse) ProtoReflect ¶
func (x *StreamControlResponse) ProtoReflect() protoreflect.Message
func (*StreamControlResponse) Reset ¶
func (x *StreamControlResponse) Reset()
func (*StreamControlResponse) String ¶
func (x *StreamControlResponse) String() string
type StreamControlStart ¶
type StreamControlStart struct {
FunctionSpecificStreamControlStart *anypb.Any `protobuf:"bytes,2,opt,name=functionSpecificStreamControlStart,proto3" json:"functionSpecificStreamControlStart,omitempty"`
// contains filtered or unexported fields
}
StreamControlStart specifies the start of a stream.
func (*StreamControlStart) Descriptor
deprecated
func (*StreamControlStart) Descriptor() ([]byte, []int)
Deprecated: Use StreamControlStart.ProtoReflect.Descriptor instead.
func (*StreamControlStart) GetFunctionSpecificStreamControlStart ¶
func (x *StreamControlStart) GetFunctionSpecificStreamControlStart() *anypb.Any
func (*StreamControlStart) ProtoMessage ¶
func (*StreamControlStart) ProtoMessage()
func (*StreamControlStart) ProtoReflect ¶
func (x *StreamControlStart) ProtoReflect() protoreflect.Message
func (*StreamControlStart) Reset ¶
func (x *StreamControlStart) Reset()
func (*StreamControlStart) String ¶
func (x *StreamControlStart) String() string
type StreamControlStop ¶
type StreamControlStop struct {
// contains filtered or unexported fields
}
StreamControlStart specifies the stop of a stream.
func (*StreamControlStop) Descriptor
deprecated
func (*StreamControlStop) Descriptor() ([]byte, []int)
Deprecated: Use StreamControlStop.ProtoReflect.Descriptor instead.
func (*StreamControlStop) ProtoMessage ¶
func (*StreamControlStop) ProtoMessage()
func (*StreamControlStop) ProtoReflect ¶
func (x *StreamControlStop) ProtoReflect() protoreflect.Message
func (*StreamControlStop) Reset ¶
func (x *StreamControlStop) Reset()
func (*StreamControlStop) String ¶
func (x *StreamControlStop) String() string
type StreamControl_Start ¶
type StreamControl_Start struct {
Start *StreamControlStart `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}
type StreamControl_Stop ¶
type StreamControl_Stop struct {
Stop *StreamControlStop `protobuf:"bytes,2,opt,name=stop,proto3,oneof"`
}
type StreamData ¶
type StreamData struct {
// timestamp when the message has been sent out
DeliveryTimestampUs uint64 `protobuf:"fixed64,1,opt,name=deliveryTimestampUs,proto3" json:"deliveryTimestampUs,omitempty"`
// sample series sequence number (counted from 0, rolls over)
Sequence uint32 `protobuf:"fixed32,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
// Function specific data type
FunctionSpecificStreamData *anypb.Any `protobuf:"bytes,10,opt,name=functionSpecificStreamData,proto3" json:"functionSpecificStreamData,omitempty"`
// contains filtered or unexported fields
}
func (*StreamData) Descriptor
deprecated
func (*StreamData) Descriptor() ([]byte, []int)
Deprecated: Use StreamData.ProtoReflect.Descriptor instead.
func (*StreamData) GetDeliveryTimestampUs ¶
func (x *StreamData) GetDeliveryTimestampUs() uint64
func (*StreamData) GetFunctionSpecificStreamData ¶
func (x *StreamData) GetFunctionSpecificStreamData() *anypb.Any
func (*StreamData) GetSequence ¶
func (x *StreamData) GetSequence() uint32
func (*StreamData) ProtoMessage ¶
func (*StreamData) ProtoMessage()
func (*StreamData) ProtoReflect ¶
func (x *StreamData) ProtoReflect() protoreflect.Message
func (*StreamData) Reset ¶
func (x *StreamData) Reset()
func (*StreamData) String ¶
func (x *StreamData) String() string