operparse

Documentation

Index

• Variables
• func ComputeArgs(arg_spec []string, obsv operation.Observation) []string
• func ConcatOperations(first *operation.Operations, second *operation.Operations) *rgerror.RGerror
• func ParseOperations(raw_data []byte, data *operation.Operations) *rgerror.RGerror
• func SelectAction(actn_name string, actns map[string]operation.Action) *operation.Action
• func SelectImplementActionByName(impl_name string, impls map[string]operation.Implement) *operation.Action
• func SelectImplementActionForCorrection(obsv operation.Observation, obsv_result operation.ObservationResult, ...) (string, *operation.Action)
• func SelectObservation(obsv_name string, obsvs map[string]operation.Observation) *operation.Observation
• func SelectObservationResult(obsv_name string, obsv_results map[string]operation.ObservationResult) *operation.ObservationResult

Variables

var RESERVED_INSTANCE_NAME string = "__obsv_instance__"

Functions

func ComputeArgs

func ComputeArgs(arg_spec []string, obsv operation.Observation) []string

Replaces a special string in a list of arguments (used for observations and reaction impls) with specific data from elsewhere

func ConcatOperations

func ConcatOperations(first *operation.Operations, second *operation.Operations) *rgerror.RGerror

Yeah this is big and ugly and could probably have helper functions, but I don't want to do that much interface magic and pass enough strings around to make the messages different and helpful.

func ParseOperations

func ParseOperations(raw_data []byte, data *operation.Operations) *rgerror.RGerror

Idempotent function for merging new data in to Operations struct. Can be used more than once to read data from multiple sources

func SelectAction

func SelectAction(actn_name string, actns map[string]operation.Action) *operation.Action

func SelectImplementActionByName

func SelectImplementActionByName(impl_name string, impls map[string]operation.Implement) *operation.Action

func SelectImplementActionForCorrection

func SelectImplementActionForCorrection(obsv operation.Observation, obsv_result operation.ObservationResult, impls map[string]operation.Implement) (string, *operation.Action)

func SelectObservation

func SelectObservation(obsv_name string, obsvs map[string]operation.Observation) *operation.Observation

func SelectObservationResult

func SelectObservationResult(obsv_name string, obsv_results map[string]operation.ObservationResult) *operation.ObservationResult