fbs

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EnumNamesCallableWdgConfig = map[CallableWdgConfig]string{
	CallableWdgConfigWDG_HW_TASK: "WDG_HW_TASK",
	CallableWdgConfigWDG_HW:      "WDG_HW",
	CallableWdgConfigWDG_NONE:    "WDG_NONE",
	CallableWdgConfigWDG_DEFAULT: "WDG_DEFAULT",
}
View Source 
var EnumNamesCurrentErrorReaction = map[CurrentErrorReaction]string{
	CurrentErrorReactionSTOP:     "STOP",
	CurrentErrorReactionCONTINUE: "CONTINUE",
}
View Source 
var EnumNamesCurrentState = map[CurrentState]string{
	CurrentStateRUN:    "RUN",
	CurrentStateCONFIG: "CONFIG",
	CurrentStateINIT:   "INIT",
	CurrentStateEXIT:   "EXIT",
}
View Source 
var EnumNamesCurrentTrigger = map[CurrentTrigger]string{
	CurrentTriggerTIMER:     "TIMER",
	CurrentTriggerINTERRUPT: "INTERRUPT",
}
View Source 
var EnumNamesTimer = map[Timer]string{
	TimerALL:          "ALL",
	TimerTOTAL:        "TOTAL",
	TimerTASK:         "TASK",
	TimerOTHER:        "OTHER",
	TimerEQUIDISTANCE: "EQUIDISTANCE",
	TimerDEVIATION:    "DEVIATION",
	TimerREMAINING:    "REMAINING",
}
View Source 
var EnumValuesCallableWdgConfig = map[string]CallableWdgConfig{
	"WDG_HW_TASK": CallableWdgConfigWDG_HW_TASK,
	"WDG_HW":      CallableWdgConfigWDG_HW,
	"WDG_NONE":    CallableWdgConfigWDG_NONE,
	"WDG_DEFAULT": CallableWdgConfigWDG_DEFAULT,
}
View Source 
var EnumValuesCurrentErrorReaction = map[string]CurrentErrorReaction{
	"STOP":     CurrentErrorReactionSTOP,
	"CONTINUE": CurrentErrorReactionCONTINUE,
}
View Source 
var EnumValuesCurrentState = map[string]CurrentState{
	"RUN":    CurrentStateRUN,
	"CONFIG": CurrentStateCONFIG,
	"INIT":   CurrentStateINIT,
	"EXIT":   CurrentStateEXIT,
}
View Source 
var EnumValuesCurrentTrigger = map[string]CurrentTrigger{
	"TIMER":     CurrentTriggerTIMER,
	"INTERRUPT": CurrentTriggerINTERRUPT,
}
View Source 
var EnumValuesTimer = map[string]Timer{
	"ALL":          TimerALL,
	"TOTAL":        TimerTOTAL,
	"TASK":         TimerTASK,
	"OTHER":        TimerOTHER,
	"EQUIDISTANCE": TimerEQUIDISTANCE,
	"DEVIATION":    TimerDEVIATION,
	"REMAINING":    TimerREMAINING,
}

Functions

func AdminAddControlDebug 

func AdminAddControlDebug(builder *flatbuffers.Builder, controlDebug flatbuffers.UOffsetT)

func AdminAddControlDebugType 

func AdminAddControlDebugType(builder *flatbuffers.Builder, controlDebugType common__scheduler__controls__fbs.Controls)

func AdminAddCpuInfo 

func AdminAddCpuInfo(builder *flatbuffers.Builder, cpuInfo flatbuffers.UOffsetT)

func AdminAddStartupErrorReaction 

func AdminAddStartupErrorReaction(builder *flatbuffers.Builder, startupErrorReaction CurrentErrorReaction)

func AdminAddStartupState 

func AdminAddStartupState(builder *flatbuffers.Builder, startupState CurrentState)

func AdminAddStartupTimeout 

func AdminAddStartupTimeout(builder *flatbuffers.Builder, startupTimeout uint32)

func AdminAddTriggerSource 

func AdminAddTriggerSource(builder *flatbuffers.Builder, triggerSource CurrentTrigger)

func AdminEnd 

func AdminEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func AdminStart 

func AdminStart(builder *flatbuffers.Builder)

func CallableAddAlias added in v1.1.0 

func CallableAddAlias(builder *flatbuffers.Builder, alias flatbuffers.UOffsetT)

func CallableAddArguments 

func CallableAddArguments(builder *flatbuffers.Builder, arguments flatbuffers.UOffsetT)

func CallableAddId 

func CallableAddId(builder *flatbuffers.Builder, id flatbuffers.UOffsetT)

func CallableAddIndex 

func CallableAddIndex(builder *flatbuffers.Builder, index uint32)

func CallableAddName 

func CallableAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func CallableAddSync added in v1.1.0 

func CallableAddSync(builder *flatbuffers.Builder, sync flatbuffers.UOffsetT)

func CallableAddWatchdog added in v1.1.0 

func CallableAddWatchdog(builder *flatbuffers.Builder, watchdog CallableWdgConfig)

func CallableConfigurationAddAlias added in v1.1.0 

func CallableConfigurationAddAlias(builder *flatbuffers.Builder, alias flatbuffers.UOffsetT)

func CallableConfigurationAddArguments added in v1.1.0 

func CallableConfigurationAddArguments(builder *flatbuffers.Builder, arguments flatbuffers.UOffsetT)

func CallableConfigurationAddSync added in v1.1.0 

func CallableConfigurationAddSync(builder *flatbuffers.Builder, sync flatbuffers.UOffsetT)

func CallableConfigurationAddTask added in v1.1.0 

func CallableConfigurationAddTask(builder *flatbuffers.Builder, task flatbuffers.UOffsetT)

func CallableConfigurationAddWatchdog added in v1.1.0 

func CallableConfigurationAddWatchdog(builder *flatbuffers.Builder, watchdog CallableWdgConfig)

func CallableConfigurationEnd added in v1.1.0 

func CallableConfigurationEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func CallableConfigurationStart added in v1.1.0 

func CallableConfigurationStart(builder *flatbuffers.Builder)

/ Task specifications to defined callable environment

func CallableConfigurationStartArgumentsVector added in v1.1.0 

func CallableConfigurationStartArgumentsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CallableConfigurationsAddConfigurations added in v1.1.0 

func CallableConfigurationsAddConfigurations(builder *flatbuffers.Builder, configurations flatbuffers.UOffsetT)

func CallableConfigurationsEnd added in v1.1.0 

func CallableConfigurationsEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func CallableConfigurationsStart added in v1.1.0 

func CallableConfigurationsStart(builder *flatbuffers.Builder)

/ Callable configurations of a callable factory

func CallableConfigurationsStartConfigurationsVector added in v1.1.0 

func CallableConfigurationsStartConfigurationsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CallableEnd 

func CallableEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func CallableStart 

func CallableStart(builder *flatbuffers.Builder)

func CallableStartArgumentsVector 

func CallableStartArgumentsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CpuInfoAddCpuCoreAutomation 

func CpuInfoAddCpuCoreAutomation(builder *flatbuffers.Builder, cpuCoreAutomation uint32)

func CpuInfoAddCpuCoreHwWdg 

func CpuInfoAddCpuCoreHwWdg(builder *flatbuffers.Builder, cpuCoreHwWdg uint32)

func CpuInfoAddCpuCoreNonRealtimeDefault 

func CpuInfoAddCpuCoreNonRealtimeDefault(builder *flatbuffers.Builder, cpuCoreNonRealtimeDefault int32)

func CpuInfoAddCpuCoreNonRealtimeMax 

func CpuInfoAddCpuCoreNonRealtimeMax(builder *flatbuffers.Builder, cpuCoreNonRealtimeMax int32)

func CpuInfoAddCpuCoreNonRealtimeMin 

func CpuInfoAddCpuCoreNonRealtimeMin(builder *flatbuffers.Builder, cpuCoreNonRealtimeMin int32)

func CpuInfoAddCpuCorePtpTimer 

func CpuInfoAddCpuCorePtpTimer(builder *flatbuffers.Builder, cpuCorePtpTimer uint32)

func CpuInfoAddCpuCoreRealtimeDefault 

func CpuInfoAddCpuCoreRealtimeDefault(builder *flatbuffers.Builder, cpuCoreRealtimeDefault int32)

func CpuInfoAddCpuCoreRealtimeMax 

func CpuInfoAddCpuCoreRealtimeMax(builder *flatbuffers.Builder, cpuCoreRealtimeMax int32)

func CpuInfoAddCpuCoreRealtimeMin 

func CpuInfoAddCpuCoreRealtimeMin(builder *flatbuffers.Builder, cpuCoreRealtimeMin int32)

func CpuInfoAddCpuCoreScheduler 

func CpuInfoAddCpuCoreScheduler(builder *flatbuffers.Builder, cpuCoreScheduler uint32)

func CpuInfoAddCpuCoresActive 

func CpuInfoAddCpuCoresActive(builder *flatbuffers.Builder, cpuCoresActive flatbuffers.UOffsetT)

func CpuInfoAddCpuCoresNonRealtime 

func CpuInfoAddCpuCoresNonRealtime(builder *flatbuffers.Builder, cpuCoresNonRealtime flatbuffers.UOffsetT)

func CpuInfoAddCpuCoresRealtime 

func CpuInfoAddCpuCoresRealtime(builder *flatbuffers.Builder, cpuCoresRealtime flatbuffers.UOffsetT)

func CpuInfoAddCpuCoresTotal 

func CpuInfoAddCpuCoresTotal(builder *flatbuffers.Builder, cpuCoresTotal flatbuffers.UOffsetT)

func CpuInfoAddVariationId 

func CpuInfoAddVariationId(builder *flatbuffers.Builder, variationId flatbuffers.UOffsetT)

func CpuInfoEnd 

func CpuInfoEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func CpuInfoStart 

func CpuInfoStart(builder *flatbuffers.Builder)

func CpuInfoStartCpuCoresActiveVector 

func CpuInfoStartCpuCoresActiveVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CpuInfoStartCpuCoresNonRealtimeVector 

func CpuInfoStartCpuCoresNonRealtimeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CpuInfoStartCpuCoresRealtimeVector 

func CpuInfoStartCpuCoresRealtimeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func CpuInfoStartCpuCoresTotalVector 

func CpuInfoStartCpuCoresTotalVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func DataRtAddCounter 

func DataRtAddCounter(builder *flatbuffers.Builder, counter uint64)

func DataRtAddStartTime 

func DataRtAddStartTime(builder *flatbuffers.Builder, startTime uint64)

func DataRtEnd 

func DataRtEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DataRtStart 

func DataRtStart(builder *flatbuffers.Builder)

func DurationAddActive 

func DurationAddActive(builder *flatbuffers.Builder, active bool)

func DurationAddAverage 

func DurationAddAverage(builder *flatbuffers.Builder, average uint64)

func DurationAddMaximum 

func DurationAddMaximum(builder *flatbuffers.Builder, maximum uint64)

func DurationAddMinimum 

func DurationAddMinimum(builder *flatbuffers.Builder, minimum uint64)

func DurationEnd 

func DurationEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DurationRtAddCounter 

func DurationRtAddCounter(builder *flatbuffers.Builder, counter uint64)

func DurationRtAddDeviation 

func DurationRtAddDeviation(builder *flatbuffers.Builder, deviation uint64)

func DurationRtAddEquidistance 

func DurationRtAddEquidistance(builder *flatbuffers.Builder, equidistance uint64)

func DurationRtAddOther 

func DurationRtAddOther(builder *flatbuffers.Builder, other uint64)

func DurationRtAddRemaining added in v1.1.0 

func DurationRtAddRemaining(builder *flatbuffers.Builder, remaining uint64)

func DurationRtAddSamplerate 

func DurationRtAddSamplerate(builder *flatbuffers.Builder, samplerate uint64)

func DurationRtAddTask 

func DurationRtAddTask(builder *flatbuffers.Builder, task uint64)

func DurationRtAddTotal 

func DurationRtAddTotal(builder *flatbuffers.Builder, total uint64)

func DurationRtEnd 

func DurationRtEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DurationRtStart 

func DurationRtStart(builder *flatbuffers.Builder)

func DurationStart 

func DurationStart(builder *flatbuffers.Builder)

func DurationTimerAddTimer 

func DurationTimerAddTimer(builder *flatbuffers.Builder, timer Timer)

func DurationTimerEnd 

func DurationTimerEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DurationTimerStart 

func DurationTimerStart(builder *flatbuffers.Builder)

func HistogramAddScale 

func HistogramAddScale(builder *flatbuffers.Builder, scale uint64)

func HistogramAddValues 

func HistogramAddValues(builder *flatbuffers.Builder, values flatbuffers.UOffsetT)

func HistogramEnd 

func HistogramEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func HistogramStart 

func HistogramStart(builder *flatbuffers.Builder)

func HistogramStartValuesVector 

func HistogramStartValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ProgramAddCallables 

func ProgramAddCallables(builder *flatbuffers.Builder, callables flatbuffers.UOffsetT)

func ProgramAddTask 

func ProgramAddTask(builder *flatbuffers.Builder, task flatbuffers.UOffsetT)

func ProgramAddWatchdog 

func ProgramAddWatchdog(builder *flatbuffers.Builder, watchdog flatbuffers.UOffsetT)

func ProgramEnd 

func ProgramEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ProgramStart 

func ProgramStart(builder *flatbuffers.Builder)

func ProgramStartCallablesVector 

func ProgramStartCallablesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ProgramsAddPrograms 

func ProgramsAddPrograms(builder *flatbuffers.Builder, programs flatbuffers.UOffsetT)

func ProgramsEnd 

func ProgramsEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ProgramsStart 

func ProgramsStart(builder *flatbuffers.Builder)

func ProgramsStartProgramsVector 

func ProgramsStartProgramsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func StartupErrorReactionAddErrorReaction 

func StartupErrorReactionAddErrorReaction(builder *flatbuffers.Builder, errorReaction CurrentErrorReaction)

func StartupErrorReactionEnd 

func StartupErrorReactionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func StartupErrorReactionStart 

func StartupErrorReactionStart(builder *flatbuffers.Builder)

func StateAddState 

func StateAddState(builder *flatbuffers.Builder, state CurrentState)

func StateEnd 

func StateEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func StateStart 

func StateStart(builder *flatbuffers.Builder)

func SyncPointsAddAfter added in v1.1.0 

func SyncPointsAddAfter(builder *flatbuffers.Builder, after flatbuffers.UOffsetT)

func SyncPointsAddBefore added in v1.1.0 

func SyncPointsAddBefore(builder *flatbuffers.Builder, before flatbuffers.UOffsetT)

func SyncPointsEnd added in v1.1.0 

func SyncPointsEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func SyncPointsStart added in v1.1.0 

func SyncPointsStart(builder *flatbuffers.Builder)

/ User defined synchronization points, execute callable in order before these points, any alphanumeric character

func SyncPointsStartAfterVector added in v1.1.0 

func SyncPointsStartAfterVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func SyncPointsStartBeforeVector added in v1.1.0 

func SyncPointsStartBeforeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func TaskAddAffinity 

func TaskAddAffinity(builder *flatbuffers.Builder, affinity uint32)

func TaskAddCycletime 

func TaskAddCycletime(builder *flatbuffers.Builder, cycletime uint32)

func TaskAddEvent 

func TaskAddEvent(builder *flatbuffers.Builder, event flatbuffers.UOffsetT)

func TaskAddName 

func TaskAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func TaskAddPriority 

func TaskAddPriority(builder *flatbuffers.Builder, priority uint32)

func TaskAddStacksize 

func TaskAddStacksize(builder *flatbuffers.Builder, stacksize uint32)

func TaskEnd 

func TaskEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func TaskSpecsAddName added in v1.1.0 

func TaskSpecsAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func TaskSpecsAddPriority added in v1.1.0 

func TaskSpecsAddPriority(builder *flatbuffers.Builder, priority flatbuffers.UOffsetT)

func TaskSpecsAddType added in v1.1.0 

func TaskSpecsAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)

func TaskSpecsEnd added in v1.1.0 

func TaskSpecsEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func TaskSpecsStart added in v1.1.0 

func TaskSpecsStart(builder *flatbuffers.Builder)

/ Description of required task properties, e.g. "cyclic/ms/10" to runs cyclic every 10 millisecond / The notation of the task properties depends on supported task types. / Notation of cyclic tasks, separated by '/' / event : Execution event of the task ["cyclic"] / cycle time unit : Supported units are millisecond ["ms"] and microsecond ["µs"] / digit : Any digit [0-9]+

func TaskStart 

func TaskStart(builder *flatbuffers.Builder)

func TriggerAddTrigger 

func TriggerAddTrigger(builder *flatbuffers.Builder, trigger CurrentTrigger)

func TriggerEnd 

func TriggerEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func TriggerStart 

func TriggerStart(builder *flatbuffers.Builder)

Types

type Admin 

type Admin struct {
	// contains filtered or unexported fields
}

func GetRootAsAdmin 

func GetRootAsAdmin(buf []byte, offset flatbuffers.UOffsetT) *Admin

func GetSizePrefixedRootAsAdmin 

func GetSizePrefixedRootAsAdmin(buf []byte, offset flatbuffers.UOffsetT) *Admin

func (*Admin) ControlDebug 

func (rcv *Admin) ControlDebug(obj *flatbuffers.Table) bool

func (*Admin) ControlDebugType 

func (rcv *Admin) ControlDebugType() common__scheduler__controls__fbs.Controls

func (*Admin) CpuInfo 

func (rcv *Admin) CpuInfo(obj *CpuInfo) *CpuInfo

func (*Admin) Init 

func (rcv *Admin) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Admin) MutateControlDebugType 

func (rcv *Admin) MutateControlDebugType(n common__scheduler__controls__fbs.Controls) bool

func (*Admin) MutateStartupErrorReaction 

func (rcv *Admin) MutateStartupErrorReaction(n CurrentErrorReaction) bool

func (*Admin) MutateStartupState 

func (rcv *Admin) MutateStartupState(n CurrentState) bool

func (*Admin) MutateStartupTimeout 

func (rcv *Admin) MutateStartupTimeout(n uint32) bool

func (*Admin) MutateTriggerSource 

func (rcv *Admin) MutateTriggerSource(n CurrentTrigger) bool

func (*Admin) StartupErrorReaction 

func (rcv *Admin) StartupErrorReaction() CurrentErrorReaction

func (*Admin) StartupState 

func (rcv *Admin) StartupState() CurrentState

func (*Admin) StartupTimeout 

func (rcv *Admin) StartupTimeout() uint32

func (*Admin) Table 

func (rcv *Admin) Table() flatbuffers.Table

func (*Admin) TriggerSource 

func (rcv *Admin) TriggerSource() CurrentTrigger

func (*Admin) UnPack added in v1.1.0 

func (rcv *Admin) UnPack() *AdminT

func (*Admin) UnPackTo added in v1.1.0 

func (rcv *Admin) UnPackTo(t *AdminT)

type AdminT added in v1.1.0 

type AdminT struct {
	StartupState         CurrentState
	StartupTimeout       uint32
	StartupErrorReaction CurrentErrorReaction
	TriggerSource        CurrentTrigger
	ControlDebug         *common__scheduler__controls__fbs.ControlsT
	CpuInfo              *CpuInfoT
}

func (*AdminT) Pack added in v1.1.0 

func (t *AdminT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Callable 

type Callable struct {
	// contains filtered or unexported fields
}

func GetRootAsCallable 

func GetRootAsCallable(buf []byte, offset flatbuffers.UOffsetT) *Callable

func GetSizePrefixedRootAsCallable 

func GetSizePrefixedRootAsCallable(buf []byte, offset flatbuffers.UOffsetT) *Callable

func (*Callable) Alias added in v1.1.0 

func (rcv *Callable) Alias() []byte

/ Callable ID, used as reference, which is assigned automatically by the Scheduler [0-9]+ / Alias of callable, human readable replacement of callable ID / The alias have match to the Data Layer compliance guide lines meaning any alphanumeric character are allowed [a-zA-Z_][a-zA-Z0-9-._]+

func (*Callable) Arguments 

func (rcv *Callable) Arguments(j int) []byte

/ List of arguments to create the callable, for further information see application description of the callable factory

func (*Callable) ArgumentsLength 

func (rcv *Callable) ArgumentsLength() int

func (*Callable) Id 

func (rcv *Callable) Id() []byte

/ List of arguments to create the callable, for further information see application description of the callable factory / Callable ID, used as reference, which is assigned automatically by the Scheduler [0-9]+

func (*Callable) Index 

func (rcv *Callable) Index() uint32

/ Name of callable factory provided by an installed app / Run index to specify the call sequence, alternatively to the use of synchronization points / Notes: / - The run index ranges from 1 (high) to maximum of data type (low) / - Using of run index cause disabling of synchronization points of this callable / - Using no synchronization points and run index value '0' cause that this callable run together with other, same configured callables, unordered at the end of the task

func (*Callable) Init 

func (rcv *Callable) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Callable) MutateIndex 

func (rcv *Callable) MutateIndex(n uint32) bool

/ Run index to specify the call sequence, alternatively to the use of synchronization points / Notes: / - The run index ranges from 1 (high) to maximum of data type (low) / - Using of run index cause disabling of synchronization points of this callable / - Using no synchronization points and run index value '0' cause that this callable run together with other, same configured callables, unordered at the end of the task

func (*Callable) MutateWatchdog added in v1.1.0 

func (rcv *Callable) MutateWatchdog(n CallableWdgConfig) bool

/ Requirement of the callable that a watchdog is present

func (*Callable) Name 

func (rcv *Callable) Name() []byte

/ Name of callable factory provided by an installed app

func (*Callable) Sync added in v1.1.0 

func (rcv *Callable) Sync(obj *SyncPoints) *SyncPoints

/ Alias of callable, human readable replacement of callable ID / The alias have match to the Data Layer compliance guide lines meaning any alphanumeric character are allowed [a-zA-Z_][a-zA-Z0-9-._]+ / Synchronization points to specify the call sequence, alternatively to the use of run index / Notes: / - Using of run index cause disabling of synchronization points of this callable / - Using no synchronization points and run index value '0' cause that this callable run together with other, same configured callables, unordered at the end of the task

func (*Callable) Table 

func (rcv *Callable) Table() flatbuffers.Table

func (*Callable) UnPack added in v1.1.0 

func (rcv *Callable) UnPack() *CallableT

func (*Callable) UnPackTo added in v1.1.0 

func (rcv *Callable) UnPackTo(t *CallableT)

func (*Callable) Watchdog added in v1.1.0 

func (rcv *Callable) Watchdog() CallableWdgConfig

/ Synchronization points to specify the call sequence, alternatively to the use of run index / Notes: / - Using of run index cause disabling of synchronization points of this callable / - Using no synchronization points and run index value '0' cause that this callable run together with other, same configured callables, unordered at the end of the task / Requirement of the callable that a watchdog is present

type CallableConfiguration added in v1.1.0 

type CallableConfiguration struct {
	// contains filtered or unexported fields
}

func GetRootAsCallableConfiguration added in v1.1.0 

func GetRootAsCallableConfiguration(buf []byte, offset flatbuffers.UOffsetT) *CallableConfiguration

func GetSizePrefixedRootAsCallableConfiguration added in v1.1.0 

func GetSizePrefixedRootAsCallableConfiguration(buf []byte, offset flatbuffers.UOffsetT) *CallableConfiguration

func (*CallableConfiguration) Alias added in v1.1.0 

func (rcv *CallableConfiguration) Alias() []byte

/ Alias of callable, human readable replacement of callable ID, any alphanumeric character [a-zA-Z_][a-zA-Z0-9-._]+

func (*CallableConfiguration) Arguments added in v1.1.0 

func (rcv *CallableConfiguration) Arguments(j int) []byte

/ Synchronization points to specify the call sequence / List of arguments to create the callable, for further information see application description of the callable factory

func (*CallableConfiguration) ArgumentsLength added in v1.1.0 

func (rcv *CallableConfiguration) ArgumentsLength() int

func (*CallableConfiguration) Init added in v1.1.0 

func (rcv *CallableConfiguration) Init(buf []byte, i flatbuffers.UOffsetT)

func (*CallableConfiguration) MutateWatchdog added in v1.1.0 

func (rcv *CallableConfiguration) MutateWatchdog(n CallableWdgConfig) bool

/ Requirement of the callable that a watchdog is present

func (*CallableConfiguration) Sync added in v1.1.0 

func (rcv *CallableConfiguration) Sync(obj *SyncPoints) *SyncPoints

/ Alias of callable, human readable replacement of callable ID, any alphanumeric character [a-zA-Z_][a-zA-Z0-9-._]+ / Synchronization points to specify the call sequence

func (*CallableConfiguration) Table added in v1.1.0 

func (rcv *CallableConfiguration) Table() flatbuffers.Table

func (*CallableConfiguration) Task added in v1.1.0 

func (rcv *CallableConfiguration) Task(obj *TaskSpecs) *TaskSpecs

/ Task specifications to defined callable environment

func (*CallableConfiguration) UnPack added in v1.1.0 

func (rcv *CallableConfiguration) UnPack() *CallableConfigurationT

func (*CallableConfiguration) UnPackTo added in v1.1.0 

func (rcv *CallableConfiguration) UnPackTo(t *CallableConfigurationT)

func (*CallableConfiguration) Watchdog added in v1.1.0 

func (rcv *CallableConfiguration) Watchdog() CallableWdgConfig

/ List of arguments to create the callable, for further information see application description of the callable factory / Requirement of the callable that a watchdog is present

type CallableConfigurationT added in v1.1.0 

type CallableConfigurationT struct {
	Alias     string
	Sync      *SyncPointsT
	Arguments []string
	Watchdog  CallableWdgConfig
	Task      *TaskSpecsT
}

/ Callable configurations of a callable factory

func (*CallableConfigurationT) Pack added in v1.1.0 

func (t *CallableConfigurationT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type CallableConfigurations added in v1.1.0 

type CallableConfigurations struct {
	// contains filtered or unexported fields
}

func GetRootAsCallableConfigurations added in v1.1.0 

func GetRootAsCallableConfigurations(buf []byte, offset flatbuffers.UOffsetT) *CallableConfigurations

func GetSizePrefixedRootAsCallableConfigurations added in v1.1.0 

func GetSizePrefixedRootAsCallableConfigurations(buf []byte, offset flatbuffers.UOffsetT) *CallableConfigurations

func (*CallableConfigurations) Configurations added in v1.1.0 

func (rcv *CallableConfigurations) Configurations(obj *CallableConfiguration, j int) bool

/ Callable configurations of a callable factory

func (*CallableConfigurations) ConfigurationsLength added in v1.1.0 

func (rcv *CallableConfigurations) ConfigurationsLength() int

func (*CallableConfigurations) Init added in v1.1.0 

func (rcv *CallableConfigurations) Init(buf []byte, i flatbuffers.UOffsetT)

func (*CallableConfigurations) Table added in v1.1.0 

func (rcv *CallableConfigurations) Table() flatbuffers.Table

func (*CallableConfigurations) UnPack added in v1.1.0 

func (rcv *CallableConfigurations) UnPack() *CallableConfigurationsT

func (*CallableConfigurations) UnPackTo added in v1.1.0 

func (rcv *CallableConfigurations) UnPackTo(t *CallableConfigurationsT)

type CallableConfigurationsT added in v1.1.0 

type CallableConfigurationsT struct {
	Configurations []*CallableConfigurationT
}

/ Callable configurations of a callable factory

func (*CallableConfigurationsT) Pack added in v1.1.0 

func (t *CallableConfigurationsT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type CallableT added in v1.1.0 

type CallableT struct {
	Name      string
	Index     uint32
	Arguments []string
	Id        string
	Alias     string
	Sync      *SyncPointsT
	Watchdog  CallableWdgConfig
}

/ Callable, executes a job defined by regarding app

func (*CallableT) Pack added in v1.1.0 

func (t *CallableT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type CallableWdgConfig added in v1.1.0 

type CallableWdgConfig int8

/ Requirement of the callable that a watchdog is present 

const (
	/// Task and hardware watchdog activated
	CallableWdgConfigWDG_HW_TASK CallableWdgConfig = 0
	/// Hardware watchdog activated; don't care about task watchdog
	CallableWdgConfigWDG_HW CallableWdgConfig = 1
	/// Neither task or hardware watchdog is needed
	CallableWdgConfigWDG_NONE CallableWdgConfig = 2
	/// Don't care about neither task or hardware watchdog, use of default value
	CallableWdgConfigWDG_DEFAULT CallableWdgConfig = 3
)

func (CallableWdgConfig) String added in v1.1.0 

func (v CallableWdgConfig) String() string

type CpuInfo 

type CpuInfo struct {
	// contains filtered or unexported fields
}

func GetRootAsCpuInfo 

func GetRootAsCpuInfo(buf []byte, offset flatbuffers.UOffsetT) *CpuInfo

func GetSizePrefixedRootAsCpuInfo 

func GetSizePrefixedRootAsCpuInfo(buf []byte, offset flatbuffers.UOffsetT) *CpuInfo

func (*CpuInfo) CpuCoreAutomation 

func (rcv *CpuInfo) CpuCoreAutomation() uint32

func (*CpuInfo) CpuCoreHwWdg 

func (rcv *CpuInfo) CpuCoreHwWdg() uint32

func (*CpuInfo) CpuCoreNonRealtimeDefault 

func (rcv *CpuInfo) CpuCoreNonRealtimeDefault() int32

func (*CpuInfo) CpuCoreNonRealtimeMax 

func (rcv *CpuInfo) CpuCoreNonRealtimeMax() int32

func (*CpuInfo) CpuCoreNonRealtimeMin 

func (rcv *CpuInfo) CpuCoreNonRealtimeMin() int32

func (*CpuInfo) CpuCorePtpTimer 

func (rcv *CpuInfo) CpuCorePtpTimer() uint32

func (*CpuInfo) CpuCoreRealtimeDefault 

func (rcv *CpuInfo) CpuCoreRealtimeDefault() int32

func (*CpuInfo) CpuCoreRealtimeMax 

func (rcv *CpuInfo) CpuCoreRealtimeMax() int32

func (*CpuInfo) CpuCoreRealtimeMin 

func (rcv *CpuInfo) CpuCoreRealtimeMin() int32

func (*CpuInfo) CpuCoreScheduler 

func (rcv *CpuInfo) CpuCoreScheduler() uint32

func (*CpuInfo) CpuCoresActive 

func (rcv *CpuInfo) CpuCoresActive(j int) uint32

func (*CpuInfo) CpuCoresActiveLength 

func (rcv *CpuInfo) CpuCoresActiveLength() int

func (*CpuInfo) CpuCoresNonRealtime 

func (rcv *CpuInfo) CpuCoresNonRealtime(j int) uint32

func (*CpuInfo) CpuCoresNonRealtimeLength 

func (rcv *CpuInfo) CpuCoresNonRealtimeLength() int

func (*CpuInfo) CpuCoresRealtime 

func (rcv *CpuInfo) CpuCoresRealtime(j int) uint32

func (*CpuInfo) CpuCoresRealtimeLength 

func (rcv *CpuInfo) CpuCoresRealtimeLength() int

func (*CpuInfo) CpuCoresTotal 

func (rcv *CpuInfo) CpuCoresTotal(j int) uint32

func (*CpuInfo) CpuCoresTotalLength 

func (rcv *CpuInfo) CpuCoresTotalLength() int

func (*CpuInfo) Init 

func (rcv *CpuInfo) Init(buf []byte, i flatbuffers.UOffsetT)

func (*CpuInfo) MutateCpuCoreAutomation 

func (rcv *CpuInfo) MutateCpuCoreAutomation(n uint32) bool

func (*CpuInfo) MutateCpuCoreHwWdg 

func (rcv *CpuInfo) MutateCpuCoreHwWdg(n uint32) bool

func (*CpuInfo) MutateCpuCoreNonRealtimeDefault 

func (rcv *CpuInfo) MutateCpuCoreNonRealtimeDefault(n int32) bool

func (*CpuInfo) MutateCpuCoreNonRealtimeMax 

func (rcv *CpuInfo) MutateCpuCoreNonRealtimeMax(n int32) bool

func (*CpuInfo) MutateCpuCoreNonRealtimeMin 

func (rcv *CpuInfo) MutateCpuCoreNonRealtimeMin(n int32) bool

func (*CpuInfo) MutateCpuCorePtpTimer 

func (rcv *CpuInfo) MutateCpuCorePtpTimer(n uint32) bool

func (*CpuInfo) MutateCpuCoreRealtimeDefault 

func (rcv *CpuInfo) MutateCpuCoreRealtimeDefault(n int32) bool

func (*CpuInfo) MutateCpuCoreRealtimeMax 

func (rcv *CpuInfo) MutateCpuCoreRealtimeMax(n int32) bool

func (*CpuInfo) MutateCpuCoreRealtimeMin 

func (rcv *CpuInfo) MutateCpuCoreRealtimeMin(n int32) bool

func (*CpuInfo) MutateCpuCoreScheduler 

func (rcv *CpuInfo) MutateCpuCoreScheduler(n uint32) bool

func (*CpuInfo) MutateCpuCoresActive 

func (rcv *CpuInfo) MutateCpuCoresActive(j int, n uint32) bool

func (*CpuInfo) MutateCpuCoresNonRealtime 

func (rcv *CpuInfo) MutateCpuCoresNonRealtime(j int, n uint32) bool

func (*CpuInfo) MutateCpuCoresRealtime 

func (rcv *CpuInfo) MutateCpuCoresRealtime(j int, n uint32) bool

func (*CpuInfo) MutateCpuCoresTotal 

func (rcv *CpuInfo) MutateCpuCoresTotal(j int, n uint32) bool

func (*CpuInfo) Table 

func (rcv *CpuInfo) Table() flatbuffers.Table

func (*CpuInfo) UnPack added in v1.1.0 

func (rcv *CpuInfo) UnPack() *CpuInfoT

func (*CpuInfo) UnPackTo added in v1.1.0 

func (rcv *CpuInfo) UnPackTo(t *CpuInfoT)

func (*CpuInfo) VariationId 

func (rcv *CpuInfo) VariationId() []byte

type CpuInfoT added in v1.1.0 

type CpuInfoT struct {
	CpuCoresTotal             []uint32
	CpuCoresActive            []uint32
	CpuCoresRealtime          []uint32
	CpuCoresNonRealtime       []uint32
	CpuCoreRealtimeMax        int32
	CpuCoreRealtimeMin        int32
	CpuCoreRealtimeDefault    int32
	CpuCoreNonRealtimeMax     int32
	CpuCoreNonRealtimeMin     int32
	CpuCoreNonRealtimeDefault int32
	VariationId               string
	CpuCoreHwWdg              uint32
	CpuCorePtpTimer           uint32
	CpuCoreScheduler          uint32
	CpuCoreAutomation         uint32
}

func (*CpuInfoT) Pack added in v1.1.0 

func (t *CpuInfoT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type CurrentErrorReaction 

type CurrentErrorReaction int8

/ Error reaction in case of not all configured components are available on startup 

const (
	/// The Scheduler aborts further startup
	CurrentErrorReactionSTOP CurrentErrorReaction = 0
	/// The Scheduler continues the startup without the missing components
	CurrentErrorReactionCONTINUE CurrentErrorReaction = 1
)

func (CurrentErrorReaction) String 

func (v CurrentErrorReaction) String() string

type CurrentState 

type CurrentState int8
const (
	CurrentStateRUN    CurrentState = 0
	CurrentStateCONFIG CurrentState = 1
	CurrentStateINIT   CurrentState = 2
	CurrentStateEXIT   CurrentState = 3
)

func (CurrentState) String 

func (v CurrentState) String() string

type CurrentTrigger 

type CurrentTrigger int8

/ Types of trigger sources of Scheduler 

const (
	/// Trigger of Scheduler is cause by a timer interrupt
	CurrentTriggerTIMER CurrentTrigger = 0
	/// Trigger of Scheduler is cause by a FPGA interrupt
	CurrentTriggerINTERRUPT CurrentTrigger = 1
)

func (CurrentTrigger) String 

func (v CurrentTrigger) String() string

type DataRt 

type DataRt struct {
	// contains filtered or unexported fields
}

func GetRootAsDataRt 

func GetRootAsDataRt(buf []byte, offset flatbuffers.UOffsetT) *DataRt

func GetSizePrefixedRootAsDataRt 

func GetSizePrefixedRootAsDataRt(buf []byte, offset flatbuffers.UOffsetT) *DataRt

func (*DataRt) Counter 

func (rcv *DataRt) Counter() uint64

/ Count of execution of the task

func (*DataRt) Init 

func (rcv *DataRt) Init(buf []byte, i flatbuffers.UOffsetT)

func (*DataRt) MutateCounter 

func (rcv *DataRt) MutateCounter(n uint64) bool

/ Count of execution of the task

func (*DataRt) MutateStartTime 

func (rcv *DataRt) MutateStartTime(n uint64) bool

/ Start time of the task in [µs]

func (*DataRt) StartTime 

func (rcv *DataRt) StartTime() uint64

/ Start time of the task in [µs]

func (*DataRt) Table 

func (rcv *DataRt) Table() flatbuffers.Table

func (*DataRt) UnPack added in v1.1.0 

func (rcv *DataRt) UnPack() *DataRtT

func (*DataRt) UnPackTo added in v1.1.0 

func (rcv *DataRt) UnPackTo(t *DataRtT)

type DataRtT added in v1.1.0 

type DataRtT struct {
	StartTime uint64
	Counter   uint64
}

/ Information about the current cycle of the task (related to real-time usage)

func (*DataRtT) Pack added in v1.1.0 

func (t *DataRtT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Duration 

type Duration struct {
	// contains filtered or unexported fields
}

func GetRootAsDuration 

func GetRootAsDuration(buf []byte, offset flatbuffers.UOffsetT) *Duration

func GetSizePrefixedRootAsDuration 

func GetSizePrefixedRootAsDuration(buf []byte, offset flatbuffers.UOffsetT) *Duration

func (*Duration) Active 

func (rcv *Duration) Active() bool

/ Indication whether the duration measurement of execution is active (true) or not (false)

func (*Duration) Average 

func (rcv *Duration) Average() uint64

/ Average of values of duration measurement in [µs]

func (*Duration) Init 

func (rcv *Duration) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Duration) Maximum 

func (rcv *Duration) Maximum() uint64

/ Maximum value of duration measurement in [µs]

func (*Duration) Minimum 

func (rcv *Duration) Minimum() uint64

/ Minimum value of duration measurement in [µs]

func (*Duration) MutateActive 

func (rcv *Duration) MutateActive(n bool) bool

/ Indication whether the duration measurement of execution is active (true) or not (false)

func (*Duration) MutateAverage 

func (rcv *Duration) MutateAverage(n uint64) bool

/ Average of values of duration measurement in [µs]

func (*Duration) MutateMaximum 

func (rcv *Duration) MutateMaximum(n uint64) bool

/ Maximum value of duration measurement in [µs]

func (*Duration) MutateMinimum 

func (rcv *Duration) MutateMinimum(n uint64) bool

/ Minimum value of duration measurement in [µs]

func (*Duration) Table 

func (rcv *Duration) Table() flatbuffers.Table

func (*Duration) UnPack added in v1.1.0 

func (rcv *Duration) UnPack() *DurationT

func (*Duration) UnPackTo added in v1.1.0 

func (rcv *Duration) UnPackTo(t *DurationT)

type DurationRt 

type DurationRt struct {
	// contains filtered or unexported fields
}

func GetRootAsDurationRt 

func GetRootAsDurationRt(buf []byte, offset flatbuffers.UOffsetT) *DurationRt

func GetSizePrefixedRootAsDurationRt 

func GetSizePrefixedRootAsDurationRt(buf []byte, offset flatbuffers.UOffsetT) *DurationRt

func (*DurationRt) Counter 

func (rcv *DurationRt) Counter() uint64

/ Count of execution of the task

func (*DurationRt) Deviation 

func (rcv *DurationRt) Deviation() uint64

/ Deviation of the task to the expected start time in [µs]

func (*DurationRt) Equidistance 

func (rcv *DurationRt) Equidistance() uint64

/ Equidistance of the task from one cycle to an other in [µs]

func (*DurationRt) Init 

func (rcv *DurationRt) Init(buf []byte, i flatbuffers.UOffsetT)

func (*DurationRt) MutateCounter 

func (rcv *DurationRt) MutateCounter(n uint64) bool

/ Count of execution of the task

func (*DurationRt) MutateDeviation 

func (rcv *DurationRt) MutateDeviation(n uint64) bool

/ Deviation of the task to the expected start time in [µs]

func (*DurationRt) MutateEquidistance 

func (rcv *DurationRt) MutateEquidistance(n uint64) bool

/ Equidistance of the task from one cycle to an other in [µs]

func (*DurationRt) MutateOther 

func (rcv *DurationRt) MutateOther(n uint64) bool

/ Duration of interruptions of the task by other tasks in [µs]

func (*DurationRt) MutateRemaining added in v1.1.0 

func (rcv *DurationRt) MutateRemaining(n uint64) bool

/ Remaining time from the end of the task to the begin of the next cycle of it in [µs]

func (*DurationRt) MutateSamplerate 

func (rcv *DurationRt) MutateSamplerate(n uint64) bool

/ Sample rate resp. cycle time of the task in [µs]

func (*DurationRt) MutateTask 

func (rcv *DurationRt) MutateTask(n uint64) bool

/ Task duration of the task without interruptions by other tasks in [µs]

func (*DurationRt) MutateTotal 

func (rcv *DurationRt) MutateTotal(n uint64) bool

/ Total duration of the task including interruptions by other tasks in [µs]

func (*DurationRt) Other 

func (rcv *DurationRt) Other() uint64

/ Duration of interruptions of the task by other tasks in [µs]

func (*DurationRt) Remaining added in v1.1.0 

func (rcv *DurationRt) Remaining() uint64

/ Remaining time from the end of the task to the begin of the next cycle of it in [µs]

func (*DurationRt) Samplerate 

func (rcv *DurationRt) Samplerate() uint64

/ Sample rate resp. cycle time of the task in [µs]

func (*DurationRt) Table 

func (rcv *DurationRt) Table() flatbuffers.Table

func (*DurationRt) Task 

func (rcv *DurationRt) Task() uint64

/ Task duration of the task without interruptions by other tasks in [µs]

func (*DurationRt) Total 

func (rcv *DurationRt) Total() uint64

/ Total duration of the task including interruptions by other tasks in [µs]

func (*DurationRt) UnPack added in v1.1.0 

func (rcv *DurationRt) UnPack() *DurationRtT

func (*DurationRt) UnPackTo added in v1.1.0 

func (rcv *DurationRt) UnPackTo(t *DurationRtT)

type DurationRtT added in v1.1.0 

type DurationRtT struct {
	Total        uint64
	Task         uint64
	Other        uint64
	Equidistance uint64
	Deviation    uint64
	Counter      uint64
	Samplerate   uint64
	Remaining    uint64
}

/ Duration measurement of execution of the task (related to real-time usage)

func (*DurationRtT) Pack added in v1.1.0 

func (t *DurationRtT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type DurationT added in v1.1.0 

type DurationT struct {
	Minimum uint64
	Maximum uint64
	Average uint64
	Active  bool
}

/ Duration measurement of execution of a task

func (*DurationT) Pack added in v1.1.0 

func (t *DurationT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type DurationTimer 

type DurationTimer struct {
	// contains filtered or unexported fields
}

func GetRootAsDurationTimer 

func GetRootAsDurationTimer(buf []byte, offset flatbuffers.UOffsetT) *DurationTimer

func GetSizePrefixedRootAsDurationTimer 

func GetSizePrefixedRootAsDurationTimer(buf []byte, offset flatbuffers.UOffsetT) *DurationTimer

func (*DurationTimer) Init 

func (rcv *DurationTimer) Init(buf []byte, i flatbuffers.UOffsetT)

func (*DurationTimer) MutateTimer 

func (rcv *DurationTimer) MutateTimer(n Timer) bool

/ Type selector of duration measurement

func (*DurationTimer) Table 

func (rcv *DurationTimer) Table() flatbuffers.Table

func (*DurationTimer) Timer 

func (rcv *DurationTimer) Timer() Timer

/ Type selector of duration measurement

func (*DurationTimer) UnPack added in v1.1.0 

func (rcv *DurationTimer) UnPack() *DurationTimerT

func (*DurationTimer) UnPackTo added in v1.1.0 

func (rcv *DurationTimer) UnPackTo(t *DurationTimerT)

type DurationTimerT added in v1.1.0 

type DurationTimerT struct {
	Timer Timer
}

/ Type selector of duration measurement

func (*DurationTimerT) Pack added in v1.1.0 

func (t *DurationTimerT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Histogram 

type Histogram struct {
	// contains filtered or unexported fields
}

func GetRootAsHistogram 

func GetRootAsHistogram(buf []byte, offset flatbuffers.UOffsetT) *Histogram

func GetSizePrefixedRootAsHistogram 

func GetSizePrefixedRootAsHistogram(buf []byte, offset flatbuffers.UOffsetT) *Histogram

func (*Histogram) Init 

func (rcv *Histogram) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Histogram) MutateScale 

func (rcv *Histogram) MutateScale(n uint64) bool

/ Scale of one element of timing histogram in [µs]

func (*Histogram) MutateValues 

func (rcv *Histogram) MutateValues(j int, n uint64) bool

/ Count of hits within the ranges of the scale elements of the timing values

func (*Histogram) Scale 

func (rcv *Histogram) Scale() uint64

/ Scale of one element of timing histogram in [µs]

func (*Histogram) Table 

func (rcv *Histogram) Table() flatbuffers.Table

func (*Histogram) UnPack added in v1.1.0 

func (rcv *Histogram) UnPack() *HistogramT

func (*Histogram) UnPackTo added in v1.1.0 

func (rcv *Histogram) UnPackTo(t *HistogramT)

func (*Histogram) Values 

func (rcv *Histogram) Values(j int) uint64

/ Count of hits within the ranges of the scale elements of the timing values

func (*Histogram) ValuesLength 

func (rcv *Histogram) ValuesLength() int

type HistogramT added in v1.1.0 

type HistogramT struct {
	Scale  uint64
	Values []uint64
}

/ Timing histogram

func (*HistogramT) Pack added in v1.1.0 

func (t *HistogramT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Program 

type Program struct {
	// contains filtered or unexported fields
}

func GetRootAsProgram 

func GetRootAsProgram(buf []byte, offset flatbuffers.UOffsetT) *Program

func GetSizePrefixedRootAsProgram 

func GetSizePrefixedRootAsProgram(buf []byte, offset flatbuffers.UOffsetT) *Program

func (*Program) Callables 

func (rcv *Program) Callables(obj *Callable, j int) bool

func (*Program) CallablesLength 

func (rcv *Program) CallablesLength() int

func (*Program) Init 

func (rcv *Program) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Program) Table 

func (rcv *Program) Table() flatbuffers.Table

func (*Program) Task 

func (rcv *Program) Task(obj *Task) *Task

func (*Program) UnPack added in v1.1.0 

func (rcv *Program) UnPack() *ProgramT

func (*Program) UnPackTo added in v1.1.0 

func (rcv *Program) UnPackTo(t *ProgramT)

func (*Program) Watchdog 

func (rcv *Program) Watchdog(obj *common__scheduler__watchdog__fbs.Watchdog) *common__scheduler__watchdog__fbs.Watchdog

type ProgramT added in v1.1.0 

type ProgramT struct {
	Task      *TaskT
	Callables []*CallableT
	Watchdog  *common__scheduler__watchdog__fbs.WatchdogT
}

func (*ProgramT) Pack added in v1.1.0 

func (t *ProgramT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Programs 

type Programs struct {
	// contains filtered or unexported fields
}

func GetRootAsPrograms 

func GetRootAsPrograms(buf []byte, offset flatbuffers.UOffsetT) *Programs

func GetSizePrefixedRootAsPrograms 

func GetSizePrefixedRootAsPrograms(buf []byte, offset flatbuffers.UOffsetT) *Programs

func (*Programs) Init 

func (rcv *Programs) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Programs) Programs 

func (rcv *Programs) Programs(obj *Program, j int) bool

func (*Programs) ProgramsLength 

func (rcv *Programs) ProgramsLength() int

func (*Programs) Table 

func (rcv *Programs) Table() flatbuffers.Table

func (*Programs) UnPack added in v1.1.0 

func (rcv *Programs) UnPack() *ProgramsT

func (*Programs) UnPackTo added in v1.1.0 

func (rcv *Programs) UnPackTo(t *ProgramsT)

type ProgramsT added in v1.1.0 

type ProgramsT struct {
	Programs []*ProgramT
}

func (*ProgramsT) Pack added in v1.1.0 

func (t *ProgramsT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type StartupErrorReaction 

type StartupErrorReaction struct {
	// contains filtered or unexported fields
}

func GetRootAsStartupErrorReaction 

func GetRootAsStartupErrorReaction(buf []byte, offset flatbuffers.UOffsetT) *StartupErrorReaction

func GetSizePrefixedRootAsStartupErrorReaction 

func GetSizePrefixedRootAsStartupErrorReaction(buf []byte, offset flatbuffers.UOffsetT) *StartupErrorReaction

func (*StartupErrorReaction) ErrorReaction 

func (rcv *StartupErrorReaction) ErrorReaction() CurrentErrorReaction

/ Error reaction in case of not all configured components are available on startup

func (*StartupErrorReaction) Init 

func (rcv *StartupErrorReaction) Init(buf []byte, i flatbuffers.UOffsetT)

func (*StartupErrorReaction) MutateErrorReaction 

func (rcv *StartupErrorReaction) MutateErrorReaction(n CurrentErrorReaction) bool

/ Error reaction in case of not all configured components are available on startup

func (*StartupErrorReaction) Table 

func (rcv *StartupErrorReaction) Table() flatbuffers.Table

func (*StartupErrorReaction) UnPack added in v1.1.0 

func (rcv *StartupErrorReaction) UnPack() *StartupErrorReactionT

func (*StartupErrorReaction) UnPackTo added in v1.1.0 

func (rcv *StartupErrorReaction) UnPackTo(t *StartupErrorReactionT)

type StartupErrorReactionT added in v1.1.0 

type StartupErrorReactionT struct {
	ErrorReaction CurrentErrorReaction
}

/ Error reaction in case of not all configured components are available on startup

func (*StartupErrorReactionT) Pack added in v1.1.0 

func (t *StartupErrorReactionT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type State 

type State struct {
	// contains filtered or unexported fields
}

func GetRootAsState 

func GetRootAsState(buf []byte, offset flatbuffers.UOffsetT) *State

func GetSizePrefixedRootAsState 

func GetSizePrefixedRootAsState(buf []byte, offset flatbuffers.UOffsetT) *State

func (*State) Init 

func (rcv *State) Init(buf []byte, i flatbuffers.UOffsetT)

func (*State) MutateState 

func (rcv *State) MutateState(n CurrentState) bool

func (*State) State 

func (rcv *State) State() CurrentState

func (*State) Table 

func (rcv *State) Table() flatbuffers.Table

func (*State) UnPack added in v1.1.0 

func (rcv *State) UnPack() *StateT

func (*State) UnPackTo added in v1.1.0 

func (rcv *State) UnPackTo(t *StateT)

type StateT added in v1.1.0 

type StateT struct {
	State CurrentState
}

func (*StateT) Pack added in v1.1.0 

func (t *StateT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type SyncPoints added in v1.1.0 

type SyncPoints struct {
	// contains filtered or unexported fields
}

func GetRootAsSyncPoints added in v1.1.0 

func GetRootAsSyncPoints(buf []byte, offset flatbuffers.UOffsetT) *SyncPoints

func GetSizePrefixedRootAsSyncPoints added in v1.1.0 

func GetSizePrefixedRootAsSyncPoints(buf []byte, offset flatbuffers.UOffsetT) *SyncPoints

func (*SyncPoints) After added in v1.1.0 

func (rcv *SyncPoints) After(j int) []byte

/ User defined synchronization points, execute callable in order after these points,

func (*SyncPoints) AfterLength added in v1.1.0 

func (rcv *SyncPoints) AfterLength() int

func (*SyncPoints) Before added in v1.1.0 

func (rcv *SyncPoints) Before(j int) []byte

/ User defined synchronization points, execute callable in order after these points, / User defined synchronization points, execute callable in order before these points, any alphanumeric character

func (*SyncPoints) BeforeLength added in v1.1.0 

func (rcv *SyncPoints) BeforeLength() int

func (*SyncPoints) Init added in v1.1.0 

func (rcv *SyncPoints) Init(buf []byte, i flatbuffers.UOffsetT)

func (*SyncPoints) Table added in v1.1.0 

func (rcv *SyncPoints) Table() flatbuffers.Table

func (*SyncPoints) UnPack added in v1.1.0 

func (rcv *SyncPoints) UnPack() *SyncPointsT

func (*SyncPoints) UnPackTo added in v1.1.0 

func (rcv *SyncPoints) UnPackTo(t *SyncPointsT)

type SyncPointsT added in v1.1.0 

type SyncPointsT struct {
	After  []string
	Before []string
}

/ Synchronization points to specify the call sequence, alternatively to the use of run index / Notes: / - The names of the synchronization points of a callables have to be unique / - The names of the synchronization points of a callables have match to the Data Layer compliance guide lines meaning any alphanumeric character are allowed [a-zA-Z_][a-zA-Z0-9-._]+ / - To ensure that other callable can run after or before this callable it's recommended to set at least one synchronization point in each list

func (*SyncPointsT) Pack added in v1.1.0 

func (t *SyncPointsT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Task 

type Task struct {
	// contains filtered or unexported fields
}

func GetRootAsTask 

func GetRootAsTask(buf []byte, offset flatbuffers.UOffsetT) *Task

func GetSizePrefixedRootAsTask 

func GetSizePrefixedRootAsTask(buf []byte, offset flatbuffers.UOffsetT) *Task

func (*Task) Affinity 

func (rcv *Task) Affinity() uint32

/ CPU core affinity of the task, defining on which CPU core it is executed, available cores see 'scheduler/admin/info/cpu-cores'

func (*Task) Cycletime 

func (rcv *Task) Cycletime() uint32

/ Execution event of the task ["cyclic"] / Cycle time of the task in [µs]

func (*Task) Event 

func (rcv *Task) Event() []byte

/ Execution event of the task ["cyclic"]

func (*Task) Init 

func (rcv *Task) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Task) MutateAffinity 

func (rcv *Task) MutateAffinity(n uint32) bool

/ CPU core affinity of the task, defining on which CPU core it is executed, available cores see 'scheduler/admin/info/cpu-cores'

func (*Task) MutateCycletime 

func (rcv *Task) MutateCycletime(n uint32) bool

/ Cycle time of the task in [µs]

func (*Task) MutatePriority 

func (rcv *Task) MutatePriority(n uint32) bool

/ Priority of the task / Priority ranges: / 0 .. 10 : reserved for the system / 11 .. 99 : available for real-time user tasks / 100 .. 139 : available for non real-time user tasks / Priority agreements: / 10 : reserved for Scheduler tick task 'schedMain' / 11 : highest prior real-time task, use of the policy FIFO policy / 23 : high prior real-time task, use of the policy FIFO policy / 29 : mid prior real-time task, use of the policy FIFO policy / 37 : low prior real-time task, use of the policy FIFO policy / 99 : lowest prior real-time task, use of the policy round-robin policy / 100 : highest prior non real-time task, use of the nice value of '-20' / 120 : common used non real-time task, use of the nice value of '0' / 139 : lowest prior non real-time task, use of the nice value of '19'

func (*Task) MutateStacksize 

func (rcv *Task) MutateStacksize(n uint32) bool

/ Stack size of the task in [byte]

func (*Task) Name 

func (rcv *Task) Name() []byte

/ Name of the task [unique] / Allowed characters: / Any alphanumeric character, beginning with a letter and a maximum length of 15 characters [a-zA-Z][a-zA-Z0-9]{1,15}

func (*Task) Priority 

func (rcv *Task) Priority() uint32

/ Name of the task [unique] / Allowed characters: / Any alphanumeric character, beginning with a letter and a maximum length of 15 characters [a-zA-Z][a-zA-Z0-9]{1,15} / Priority of the task / Priority ranges: / 0 .. 10 : reserved for the system / 11 .. 99 : available for real-time user tasks / 100 .. 139 : available for non real-time user tasks / Priority agreements: / 10 : reserved for Scheduler tick task 'schedMain' / 11 : highest prior real-time task, use of the policy FIFO policy / 23 : high prior real-time task, use of the policy FIFO policy / 29 : mid prior real-time task, use of the policy FIFO policy / 37 : low prior real-time task, use of the policy FIFO policy / 99 : lowest prior real-time task, use of the policy round-robin policy / 100 : highest prior non real-time task, use of the nice value of '-20' / 120 : common used non real-time task, use of the nice value of '0' / 139 : lowest prior non real-time task, use of the nice value of '19'

func (*Task) Stacksize 

func (rcv *Task) Stacksize() uint32

/ Stack size of the task in [byte]

func (*Task) Table 

func (rcv *Task) Table() flatbuffers.Table

func (*Task) UnPack added in v1.1.0 

func (rcv *Task) UnPack() *TaskT

func (*Task) UnPackTo added in v1.1.0 

func (rcv *Task) UnPackTo(t *TaskT)

type TaskSpecs added in v1.1.0 

type TaskSpecs struct {
	// contains filtered or unexported fields
}

func GetRootAsTaskSpecs added in v1.1.0 

func GetRootAsTaskSpecs(buf []byte, offset flatbuffers.UOffsetT) *TaskSpecs

func GetSizePrefixedRootAsTaskSpecs added in v1.1.0 

func GetSizePrefixedRootAsTaskSpecs(buf []byte, offset flatbuffers.UOffsetT) *TaskSpecs

func (*TaskSpecs) Init added in v1.1.0 

func (rcv *TaskSpecs) Init(buf []byte, i flatbuffers.UOffsetT)

func (*TaskSpecs) Name added in v1.1.0 

func (rcv *TaskSpecs) Name() []byte

/ Task name to link callables together within a task, e.g. "ctrlXAutomation" or "schedBackground" / Allowed characters: / Any alphanumeric character, beginning with a letter and a maximum length of 15 characters [a-zA-Z][a-zA-Z0-9]{1,15}

func (*TaskSpecs) Priority added in v1.1.0 

func (rcv *TaskSpecs) Priority() []byte

/ Task name to link callables together within a task, e.g. "ctrlXAutomation" or "schedBackground" / Allowed characters: / Any alphanumeric character, beginning with a letter and a maximum length of 15 characters [a-zA-Z][a-zA-Z0-9]{1,15} / Task priority as well defined digit or range, e.g. "29" or "mid" to runs with medium priority / Priority ranges: / 0 .. 10 : reserved for the system / 11 .. 99 : available for real-time user tasks / 100 .. 139 : available for non real-time user tasks / Priority agreements: / 10 : reserved for Scheduler tick task 'schedMain' / 11 : highest prior real-time task, use of the policy FIFO policy / 23 : high prior real-time task, use of the policy FIFO policy / 29 : mid prior real-time task, use of the policy FIFO policy / 37 : low prior real-time task, use of the policy FIFO policy / 99 : lowest prior real-time task, use of the policy round-robin policy / 100 : highest prior non real-time task, use of the nice value of '-20' / 120 : common used non real-time task, use of the nice value of '0' / 139 : lowest prior non real-time task, use of the nice value of '19' / high : see (23), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "high+1" results (24) / mid : see (29), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "mid-2" results (27) / low : see (37), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "low+3" results (40) / nrt : see (120), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "nrt-10" results a nice value of (-10)

func (*TaskSpecs) Table added in v1.1.0 

func (rcv *TaskSpecs) Table() flatbuffers.Table

func (*TaskSpecs) Type added in v1.1.0 

func (rcv *TaskSpecs) Type() []byte

/ Task priority as well defined digit or range, e.g. "29" or "mid" to runs with medium priority / Priority ranges: / 0 .. 10 : reserved for the system / 11 .. 99 : available for real-time user tasks / 100 .. 139 : available for non real-time user tasks / Priority agreements: / 10 : reserved for Scheduler tick task 'schedMain' / 11 : highest prior real-time task, use of the policy FIFO policy / 23 : high prior real-time task, use of the policy FIFO policy / 29 : mid prior real-time task, use of the policy FIFO policy / 37 : low prior real-time task, use of the policy FIFO policy / 99 : lowest prior real-time task, use of the policy round-robin policy / 100 : highest prior non real-time task, use of the nice value of '-20' / 120 : common used non real-time task, use of the nice value of '0' / 139 : lowest prior non real-time task, use of the nice value of '19' / high : see (23), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "high+1" results (24) / mid : see (29), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "mid-2" results (27) / low : see (37), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "low+3" results (40) / nrt : see (120), can be extended by operator '+' resp. '-' and in additional any digit offset, e.g. "nrt-10" results a nice value of (-10) / Description of required task properties, e.g. "cyclic/ms/10" to runs cyclic every 10 millisecond / The notation of the task properties depends on supported task types. / Notation of cyclic tasks, separated by '/' / event : Execution event of the task ["cyclic"] / cycle time unit : Supported units are millisecond ["ms"] and microsecond ["µs"] / digit : Any digit [0-9]+

func (*TaskSpecs) UnPack added in v1.1.0 

func (rcv *TaskSpecs) UnPack() *TaskSpecsT

func (*TaskSpecs) UnPackTo added in v1.1.0 

func (rcv *TaskSpecs) UnPackTo(t *TaskSpecsT)

type TaskSpecsT added in v1.1.0 

type TaskSpecsT struct {
	Name     string
	Priority string
	Type     string
}

/ Task specifications to defined callable environment

func (*TaskSpecsT) Pack added in v1.1.0 

func (t *TaskSpecsT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type TaskT added in v1.1.0 

type TaskT struct {
	Name      string
	Priority  uint32
	Affinity  uint32
	Stacksize uint32
	Event     string
	Cycletime uint32
}

/ Properties of a task

func (*TaskT) Pack added in v1.1.0 

func (t *TaskT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Timer 

type Timer int8

/ Types of duration measurements 

const (
	/// Start, stop or reset all available types of duration measurements
	TimerALL Timer = 0
	/// Start, stop or reset duration measurement of the task including interruptions by other tasks
	TimerTOTAL Timer = 1
	/// Start, stop or reset duration measurement of the task without interruptions by other tasks
	TimerTASK Timer = 2
	/// Start, stop or reset duration measurement of the interruptions of the task by other tasks
	TimerOTHER Timer = 3
	/// Start, stop or reset duration measurement of equidistance of the task from one cycle to an other
	TimerEQUIDISTANCE Timer = 4
	/// Start, stop or reset duration measurement of deviation of the task to the expected start time
	TimerDEVIATION Timer = 5
	/// Start, stop or reset duration measurement of remaining time from the end of the task to the begin of the next cycle of it
	TimerREMAINING Timer = 6
)

func (Timer) String 

func (v Timer) String() string

type Trigger 

type Trigger struct {
	// contains filtered or unexported fields
}

func GetRootAsTrigger 

func GetRootAsTrigger(buf []byte, offset flatbuffers.UOffsetT) *Trigger

func GetSizePrefixedRootAsTrigger 

func GetSizePrefixedRootAsTrigger(buf []byte, offset flatbuffers.UOffsetT) *Trigger

func (*Trigger) Init 

func (rcv *Trigger) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Trigger) MutateTrigger 

func (rcv *Trigger) MutateTrigger(n CurrentTrigger) bool

/ Type selector of trigger sources of Scheduler

func (*Trigger) Table 

func (rcv *Trigger) Table() flatbuffers.Table

func (*Trigger) Trigger 

func (rcv *Trigger) Trigger() CurrentTrigger

/ Type selector of trigger sources of Scheduler

func (*Trigger) UnPack added in v1.1.0 

func (rcv *Trigger) UnPack() *TriggerT

func (*Trigger) UnPackTo added in v1.1.0 

func (rcv *Trigger) UnPackTo(t *TriggerT)

type TriggerT added in v1.1.0 

type TriggerT struct {
	Trigger CurrentTrigger
}

/ Type selector of trigger sources of Scheduler

func (*TriggerT) Pack added in v1.1.0 

func (t *TriggerT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

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.