v1alpha1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "ERROR",
		2: "NOT_IMPLEMENTED",
	}
	Status_value = map[string]int32{
		"OK":              0,
		"ERROR":           1,
		"NOT_IMPLEMENTED": 2,
	}
)

Enum value maps for Status.

View Source 
var File_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) Descriptor() ([]byte, []int)

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetConfigurationControl 

func (x *Command) GetConfigurationControl() *ConfigurationControl

func (*Command) GetContext 

func (x *Command) GetContext() *Context

func (*Command) GetFunctionControl 

func (x *Command) GetFunctionControl() *FunctionControl

func (*Command) GetStreamControl 

func (x *Command) GetStreamControl() *StreamControl

func (*Command) GetType 

func (m *Command) GetType() isCommand_Type

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

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() *any.Any

func (*ConfigurationControl) GetFunctionSpecificConfigurationControlGet 

func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlGet() *any.Any

func (*ConfigurationControl) GetFunctionSpecificConfigurationControlSet 

func (x *ConfigurationControl) GetFunctionSpecificConfigurationControlSet() *any.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 *any.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() *any.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 ConfigurationControl_FunctionSpecificConfigurationControlDescribe 

type ConfigurationControl_FunctionSpecificConfigurationControlDescribe struct {
	// Describe hardware capabilities
	FunctionSpecificConfigurationControlDescribe *any.Any `protobuf:"bytes,30,opt,name=functionSpecificConfigurationControlDescribe,proto3,oneof"`
}

type ConfigurationControl_FunctionSpecificConfigurationControlGet 

type ConfigurationControl_FunctionSpecificConfigurationControlGet struct {
	// Getting the current configuration
	FunctionSpecificConfigurationControlGet *any.Any `protobuf:"bytes,20,opt,name=functionSpecificConfigurationControlGet,proto3,oneof"`
}

type ConfigurationControl_FunctionSpecificConfigurationControlSet 

type ConfigurationControl_FunctionSpecificConfigurationControlSet struct {
	// Setting a new configuration
	FunctionSpecificConfigurationControlSet *any.Any `protobuf:"bytes,10,opt,name=functionSpecificConfigurationControlSet,proto3,oneof"`
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetValue 

func (x *Context) GetValue() string

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

func (x *Context) ProtoReflect() protoreflect.Message

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) String 

func (x *Context) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetError 

func (x *Error) GetError() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

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() *any.Any

func (*FunctionControl) GetFunctionSpecificFunctionControlSet 

func (x *FunctionControl) GetFunctionSpecificFunctionControlSet() *any.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 *any.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() *any.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 FunctionControl_FunctionSpecificFunctionControlGet 

type FunctionControl_FunctionSpecificFunctionControlGet struct {
	FunctionSpecificFunctionControlGet *any.Any `protobuf:"bytes,2,opt,name=functionSpecificFunctionControlGet,proto3,oneof"`
}

type FunctionControl_FunctionSpecificFunctionControlSet 

type FunctionControl_FunctionSpecificFunctionControlSet struct {
	FunctionSpecificFunctionControlSet *any.Any `protobuf:"bytes,1,opt,name=functionSpecificFunctionControlSet,proto3,oneof"`
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetConfigurationControl 

func (x *Response) GetConfigurationControl() *ConfigurationControlResponse

func (*Response) GetContext 

func (x *Response) GetContext() *Context

func (*Response) GetError 

func (x *Response) GetError() *Error

func (*Response) GetFunctionControl 

func (x *Response) GetFunctionControl() *FunctionControlResponse

func (*Response) GetStatus 

func (x *Response) GetStatus() Status

func (*Response) GetStream 

func (x *Response) GetStream() *StreamData

func (*Response) GetStreamControl 

func (x *Response) GetStreamControl() *StreamControlResponse

func (*Response) GetType 

func (m *Response) GetType() isResponse_Type

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

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 ------------ 

const (
	Status_OK              Status = 0
	Status_ERROR           Status = 1
	Status_NOT_IMPLEMENTED Status = 2
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

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 {

	// streamContext is user defined and used to identify the stream for stopping later on.
	StreamContext                      *Context `protobuf:"bytes,1,opt,name=streamContext,proto3" json:"streamContext,omitempty"`
	FunctionSpecificStreamControlStart *any.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() *any.Any

func (*StreamControlStart) GetStreamContext 

func (x *StreamControlStart) GetStreamContext() *Context

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 {

	// streamContext is used to identify the stream to be stopped
	StreamContext *Context `protobuf:"bytes,1,opt,name=streamContext,proto3" json:"streamContext,omitempty"`
	// 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) GetStreamContext 

func (x *StreamControlStop) GetStreamContext() *Context

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 *any.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() *any.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

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.