fbs

package
v2.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2024 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 

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 

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

func CallableAddWatchdog 

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

func CallableConfigurationAddAlias 

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

func CallableConfigurationAddArguments 

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

func CallableConfigurationAddSync 

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

func CallableConfigurationAddTask 

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

func CallableConfigurationAddWatchdog 

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

func CallableConfigurationEnd 

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

func CallableConfigurationStart 

func CallableConfigurationStart(builder *flatbuffers.Builder)

/ Task specifications to defined callable environment

func CallableConfigurationStartArgumentsVector 

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

func CallableConfigurationsAddConfigurations 

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

func CallableConfigurationsEnd 

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

func CallableConfigurationsStart 

func CallableConfigurationsStart(builder *flatbuffers.Builder)

/ Callable configurations of a callable factory

func CallableConfigurationsStartConfigurationsVector 

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 

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 

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

func SyncPointsAddBefore 

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

func SyncPointsEnd 

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

func SyncPointsStart 

func SyncPointsStart(builder *flatbuffers.Builder)

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

func SyncPointsStartAfterVector 

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

func SyncPointsStartBeforeVector 

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 TaskSpecsAddCpuIndex 

func TaskSpecsAddCpuIndex(builder *flatbuffers.Builder, cpuIndex flatbuffers.UOffsetT)

func TaskSpecsAddName 

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

func TaskSpecsAddPriority 

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

func TaskSpecsAddType 

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

func TaskSpecsEnd 

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

func TaskSpecsStart 

func TaskSpecsStart(builder *flatbuffers.Builder)

/ Preferred CPU index on which the task should run / Is composed of the preferred CPU type and an index. / The cpu type can be 'rt' for isolated cores or 'nrt' for non-isolated cores. / The index represents the element of a list sorted in ascending order. / If multiple CPU indices are desired they have been separated by ','. / If the desired cpu core is not available the CPU core with the highest index of that type is used. / If 'rt' type is desired and no real time core is available the non-real time core with the highest index is used. At least one 'nrt' core must be available. / When multiple CPU indices are set and no exact matching core is available the the CPU core with the highest index of that type is used. / Allowed values: / "rt" -> The real time core (isolated core) with the highest index is used. If a real time core is available. / "nrt" -> The non real time core with the highest index is used. / "rt/1" -> The real time core with index 1 is used if it is available. / "rt/5,rt/3,rt/0,nrt/5" -> Iterating over all elements and use first matching core.

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 

func (rcv *Admin) UnPack() *AdminT

func (*Admin) UnPackTo 

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

type AdminT 

type AdminT struct {
	StartupState         CurrentState                                `json:"startupState"`
	StartupTimeout       uint32                                      `json:"startupTimeout"`
	StartupErrorReaction CurrentErrorReaction                        `json:"startupErrorReaction"`
	TriggerSource        CurrentTrigger                              `json:"triggerSource"`
	ControlDebug         *common__scheduler__controls__fbs.ControlsT `json:"controlDebug"`
	CpuInfo              *CpuInfoT                                   `json:"cpuInfo"`
}

func (*AdminT) Pack 

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 

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 

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 

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 

func (rcv *Callable) UnPack() *CallableT

func (*Callable) UnPackTo 

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

func (*Callable) Watchdog 

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 

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

func GetRootAsCallableConfiguration 

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

func GetSizePrefixedRootAsCallableConfiguration 

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

func (*CallableConfiguration) Alias 

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 

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 

func (rcv *CallableConfiguration) ArgumentsLength() int

func (*CallableConfiguration) Init 

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

func (*CallableConfiguration) MutateWatchdog 

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

/ Requirement of the callable that a watchdog is present

func (*CallableConfiguration) Sync 

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 

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

func (*CallableConfiguration) Task 

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

/ Task specifications to defined callable environment

func (*CallableConfiguration) UnPack 

func (rcv *CallableConfiguration) UnPack() *CallableConfigurationT

func (*CallableConfiguration) UnPackTo 

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

func (*CallableConfiguration) Watchdog 

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 

type CallableConfigurationT struct {
	Alias     string            `json:"alias"`
	Sync      *SyncPointsT      `json:"sync"`
	Arguments []string          `json:"arguments"`
	Watchdog  CallableWdgConfig `json:"watchdog"`
	Task      *TaskSpecsT       `json:"task"`
}

/ Callable configurations of a callable factory

func (*CallableConfigurationT) Pack 

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

type CallableConfigurations 

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

func GetRootAsCallableConfigurations 

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

func GetSizePrefixedRootAsCallableConfigurations 

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

func (*CallableConfigurations) Configurations 

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

/ Callable configurations of a callable factory

func (*CallableConfigurations) ConfigurationsLength 

func (rcv *CallableConfigurations) ConfigurationsLength() int

func (*CallableConfigurations) Init 

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

func (*CallableConfigurations) Table 

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

func (*CallableConfigurations) UnPack 

func (rcv *CallableConfigurations) UnPack() *CallableConfigurationsT

func (*CallableConfigurations) UnPackTo 

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

type CallableConfigurationsT 

type CallableConfigurationsT struct {
	Configurations []*CallableConfigurationT `json:"configurations"`
}

/ Callable configurations of a callable factory

func (*CallableConfigurationsT) Pack 

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

type CallableT 

type CallableT struct {
	Name      string            `json:"name"`
	Index     uint32            `json:"index"`
	Arguments []string          `json:"arguments"`
	Id        string            `json:"id"`
	Alias     string            `json:"alias"`
	Sync      *SyncPointsT      `json:"sync"`
	Watchdog  CallableWdgConfig `json:"watchdog"`
}

/ Callable, executes a job defined by regarding app

func (*CallableT) Pack 

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

type CallableWdgConfig 

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 

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 

func (rcv *CpuInfo) UnPack() *CpuInfoT

func (*CpuInfo) UnPackTo 

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

func (*CpuInfo) VariationId 

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

type CpuInfoT 

type CpuInfoT struct {
	CpuCoresTotal             []uint32 `json:"cpuCoresTotal"`
	CpuCoresActive            []uint32 `json:"cpuCoresActive"`
	CpuCoresRealtime          []uint32 `json:"cpuCoresRealtime"`
	CpuCoresNonRealtime       []uint32 `json:"cpuCoresNonRealtime"`
	CpuCoreRealtimeMax        int32    `json:"cpuCoreRealtimeMax"`
	CpuCoreRealtimeMin        int32    `json:"cpuCoreRealtimeMin"`
	CpuCoreRealtimeDefault    int32    `json:"cpuCoreRealtimeDefault"`
	CpuCoreNonRealtimeMax     int32    `json:"cpuCoreNonRealtimeMax"`
	CpuCoreNonRealtimeMin     int32    `json:"cpuCoreNonRealtimeMin"`
	CpuCoreNonRealtimeDefault int32    `json:"cpuCoreNonRealtimeDefault"`
	VariationId               string   `json:"variationId"`
	CpuCoreHwWdg              uint32   `json:"cpuCoreHwWdg"`
	CpuCorePtpTimer           uint32   `json:"cpuCorePtpTimer"`
	CpuCoreScheduler          uint32   `json:"cpuCoreScheduler"`
	CpuCoreAutomation         uint32   `json:"cpuCoreAutomation"`
}

func (*CpuInfoT) Pack 

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 

func (rcv *DataRt) UnPack() *DataRtT

func (*DataRt) UnPackTo 

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

type DataRtT 

type DataRtT struct {
	StartTime uint64 `json:"startTime"`
	Counter   uint64 `json:"counter"`
}

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

func (*DataRtT) Pack 

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 

func (rcv *Duration) UnPack() *DurationT

func (*Duration) UnPackTo 

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 

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 

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 

func (rcv *DurationRt) UnPack() *DurationRtT

func (*DurationRt) UnPackTo 

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

type DurationRtT 

type DurationRtT struct {
	Total        uint64 `json:"total"`
	Task         uint64 `json:"task"`
	Other        uint64 `json:"other"`
	Equidistance uint64 `json:"equidistance"`
	Deviation    uint64 `json:"deviation"`
	Counter      uint64 `json:"counter"`
	Samplerate   uint64 `json:"samplerate"`
	Remaining    uint64 `json:"remaining"`
}

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

func (*DurationRtT) Pack 

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

type DurationT 

type DurationT struct {
	Minimum uint64 `json:"minimum"`
	Maximum uint64 `json:"maximum"`
	Average uint64 `json:"average"`
	Active  bool   `json:"active"`
}

/ Duration measurement of execution of a task

func (*DurationT) Pack 

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 

func (rcv *DurationTimer) UnPack() *DurationTimerT

func (*DurationTimer) UnPackTo 

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

type DurationTimerT 

type DurationTimerT struct {
	Timer Timer `json:"timer"`
}

/ Type selector of duration measurement

func (*DurationTimerT) Pack 

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 

func (rcv *Histogram) UnPack() *HistogramT

func (*Histogram) UnPackTo 

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 

type HistogramT struct {
	Scale  uint64   `json:"scale"`
	Values []uint64 `json:"values"`
}

/ Timing histogram

func (*HistogramT) Pack 

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 

func (rcv *Program) UnPack() *ProgramT

func (*Program) UnPackTo 

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 

type ProgramT struct {
	Task      *TaskT                                      `json:"task"`
	Callables []*CallableT                                `json:"callables"`
	Watchdog  *common__scheduler__watchdog__fbs.WatchdogT `json:"watchdog"`
}

func (*ProgramT) Pack 

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 

func (rcv *Programs) UnPack() *ProgramsT

func (*Programs) UnPackTo 

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

type ProgramsT 

type ProgramsT struct {
	Programs []*ProgramT `json:"programs"`
}

func (*ProgramsT) Pack 

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 

func (rcv *StartupErrorReaction) UnPack() *StartupErrorReactionT

func (*StartupErrorReaction) UnPackTo 

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

type StartupErrorReactionT 

type StartupErrorReactionT struct {
	ErrorReaction CurrentErrorReaction `json:"errorReaction"`
}

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

func (*StartupErrorReactionT) Pack 

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 

func (rcv *State) UnPack() *StateT

func (*State) UnPackTo 

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

type StateT 

type StateT struct {
	State CurrentState `json:"state"`
}

func (*StateT) Pack 

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

type SyncPoints 

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

func GetRootAsSyncPoints 

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

func GetSizePrefixedRootAsSyncPoints 

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

func (*SyncPoints) After 

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

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

func (*SyncPoints) AfterLength 

func (rcv *SyncPoints) AfterLength() int

func (*SyncPoints) Before 

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 

func (rcv *SyncPoints) BeforeLength() int

func (*SyncPoints) Init 

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

func (*SyncPoints) Table 

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

func (*SyncPoints) UnPack 

func (rcv *SyncPoints) UnPack() *SyncPointsT

func (*SyncPoints) UnPackTo 

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

type SyncPointsT 

type SyncPointsT struct {
	After  []string `json:"after"`
	Before []string `json:"before"`
}

/ 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 

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 

func (rcv *Task) UnPack() *TaskT

func (*Task) UnPackTo 

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

type TaskSpecs 

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

func GetRootAsTaskSpecs 

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

func GetSizePrefixedRootAsTaskSpecs 

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

func (*TaskSpecs) CpuIndex 

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

/ 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]+ / Preferred CPU index on which the task should run / Is composed of the preferred CPU type and an index. / The cpu type can be 'rt' for isolated cores or 'nrt' for non-isolated cores. / The index represents the element of a list sorted in ascending order. / If multiple CPU indices are desired they have been separated by ','. / If the desired cpu core is not available the CPU core with the highest index of that type is used. / If 'rt' type is desired and no real time core is available the non-real time core with the highest index is used. At least one 'nrt' core must be available. / When multiple CPU indices are set and no exact matching core is available the the CPU core with the highest index of that type is used. / Allowed values: / "rt" -> The real time core (isolated core) with the highest index is used. If a real time core is available. / "nrt" -> The non real time core with the highest index is used. / "rt/1" -> The real time core with index 1 is used if it is available. / "rt/5,rt/3,rt/0,nrt/5" -> Iterating over all elements and use first matching core.

func (*TaskSpecs) Init 

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

func (*TaskSpecs) Name 

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 

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 

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

func (*TaskSpecs) Type 

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 

func (rcv *TaskSpecs) UnPack() *TaskSpecsT

func (*TaskSpecs) UnPackTo 

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

type TaskSpecsT 

type TaskSpecsT struct {
	Name     string `json:"name"`
	Priority string `json:"priority"`
	Type     string `json:"type"`
	CpuIndex string `json:"cpuIndex"`
}

/ Task specifications to defined callable environment

func (*TaskSpecsT) Pack 

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

type TaskT 

type TaskT struct {
	Name      string `json:"name"`
	Priority  uint32 `json:"priority"`
	Affinity  uint32 `json:"affinity"`
	Stacksize uint32 `json:"stacksize"`
	Event     string `json:"event"`
	Cycletime uint32 `json:"cycletime"`
}

/ Properties of a task

func (*TaskT) Pack 

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 

func (rcv *Trigger) UnPack() *TriggerT

func (*Trigger) UnPackTo 

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

type TriggerT 

type TriggerT struct {
	Trigger CurrentTrigger `json:"trigger"`
}

/ Type selector of trigger sources of Scheduler

func (*TriggerT) Pack 

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.