shared

Documentation

Index

• Constants
• Variables
• func CheckFileName(fileName, fileExtension string)
• func CompatibleComponents(componentTypeName1, componentTypeName2 string) bool
• func Contains(list []string, value string) bool
• func EnvironmentVariableValue(variable string) (value string)
• func EnvironmentVariableValueWithDefault(variable, defaultValue string) string
• func ErrorHandler(f string, msg string)
• func GetComponentTypeByNameFromRAM(componentName string) interface{}
• func GetFunction() string
• func GetTypeAndBehaviour(file string) (string, string, error)
• func IsExternal(action string) bool
• func IsInternal(action string) bool
• func LocalizeFDR() string
• func LocalizeGo() string
• func LocalizegMidArch() string
• func MyInvoke(compType interface{}, compId string, op string, msg *messages.SAMessage, ...)
• func MyTokenize(s string) []string
• func SaveFile(path, name, ext string, content []string)
• func SkipLine(line string) bool
• func StringComposition(e []string, sep string, hasSpace bool) string
• type AdaptationPlan
• type EvolutiveAnalysisResult
• type MonitoredEvolutiveData
• type UnitCommand

Constants

const ACTION_PREFIX = "->"

const ATTEMPTS_TO_OPEN_A_PLUGIN = 1000

const BEHAVIOUR_ID = "Behaviour"

const BEHAVIOUR_TAG = "// @Behaviour:"

const CALCULATOR_HOST = "localhost" //"server"   //

const CALCULATOR_PORT = "1314"

const CHOICE = "[]"

const CORINGA = "XXX"

const CSP_EXTENSION = "csp"

const DEADLOCK_PROPERTY = "assert " + CORINGA + " :[deadlock free]"

const DOT_EXTENSION = "dot"

const EVOLUTIVE_ADAPTATION string = "EVOLUTIVE"

const EVOLUTIVE_PROTOCOL_ADAPTATION string = "EVOLUTIVE_PROTOCOL"

const EXECUTE_FOREVER = true

const FDR_COMMAND = "refines"

const FIBONACCI_PORT = "1315"

const FIRST_MONITOR_TIME time.Duration = 10 * time.Second

Evolution

const INVP = "InvP"

Port names

const INVR = "InvR"

const LEFT_ARITY = 1

const MADL_COMMENT = "//"

MADL

const MADL_EXTENSION = "madl"

File extensions

const MAXIMUM_GRAPH_SIZE = 15

const MAX_LEFT_ARITY = 99

const MAX_NUMBER_OF_CONNECTIONS = 10

const MAX_NUMBER_OF_RECEIVED_MESSAGES = 300 // messages received and not processed by srh

const MAX_RIGHT_ARITY = 99

const MONITOR_TIME time.Duration = 100 * time.Millisecond

const NAMING_HOST = "localhost" // "namingserver" //

const NAMING_PORT = "1313"

Network setups

const NON_ADAPTIVE string = "NONE"

const NTOONE = "Ntoone"

const NTOONEREQREP = "Ntoonereqrep"

const NUM_MAX_MESSAGE_BYTES int = 1024

const NUM_MAX_NODES int = 50

const ONETON = "Oneton"

const ONETONREQREP = "Onetonreqrep"

const ONEWAY = "Oneway"

Connectors

const PREFIX_INTERNAL_ACTION = "I_"

Graphs

const QUEUEING_PORT = "1316"

const REPLACE_COMPONENT = "REPLACE_COMPONENT"

const REQUEST_REPLY = "Requestreply"

const RIGHT_ARITY = 2

const RUNTIME_BEHAVIOUR = "RUNTIME"

CSP

const SIZE_OF_MESSAGE_SIZE = 4

const TERP = "TerP"

const TERR = "TerR"

const TYPE_TAG = "// @Type:"

Variables

var AdaptId = -1

var Adaptability []string

var AdaptationTypes = map[string]string{
	"EVOLUTIVE":          "EVOLUTIVE",
	"EVOLUTIVE_PROTOCOL": "EVOLUTIVE_PROTOCOL",
	"NONE":               "NONE"}

var ArchitecturalComponentTypes = map[string]interface{}{}

var CA_PATH = EnvironmentVariableValue("CA_PATH")

var CRT_PATH = EnvironmentVariableValue("CRT_PATH")

var DIR_ADAPTIVE_COMPONENTS = DIR_BASE + "/pkg/gmidarch/development/components/adaptive"

var DIR_APP_COMPONENTS = DIR_BASE + "/pkg/gmidarch/development/components/apps"

var DIR_BASE = LocalizegMidArch()

var DIR_BUSINESS_COMPONENTS = EnvironmentVariableValue("MIDARCH_BUSINESS_COMPONENTS_PATH")

var DIR_CSP = DIR_BASE + "/pkg/apps/artefacts/csp"

var DIR_DOT = DIR_BASE + "/pkg/gmidarch/development/repositories/dot"

var DIR_FDR = LocalizeFDR()

var DIR_GO = ""

Directories

var DIR_MADL = DIR_BASE + "/pkg/apps/artefacts/madls"

var DIR_MIDDLEWARE_COMPONENTS = DIR_BASE + "/pkg/gmidarch/development/components/middleware"

var DIR_PLUGINS = DIR_BASE + "/pkg/gmidarch/execution/repositories/plugins"

var DIR_PLUGINS_IMPORT = "github.com/gfads/midarch/pkg/gmidarch/development/repositories/plugins"

var DIR_PLUGINS_SOURCE = DIR_BASE + "/pkg/gmidarch/development/repositories/plugins"

var DIR_PROXIES_COMPONENTS = DIR_BASE + "/pkg/gmidarch/development/components/proxies"

var ExecuteForever = true

var INJECTION_TIME time.Duration

var KEY_PATH = EnvironmentVariableValue("KEY_PATH")

var LocalAddr = ""

var SetOfPorts = map[string]string{
	"NAMING_PORT":     NAMING_PORT,
	"CALCULATOR_PORT": CALCULATOR_PORT,
	"FIBONACCI_PORT":  FIBONACCI_PORT,
	"QUEUEING_PORT":   QUEUEING_PORT}

Functions

func CheckFileName

func CheckFileName(fileName, fileExtension string)

func CompatibleComponents

func CompatibleComponents(componentTypeName1, componentTypeName2 string) bool

func Contains

func Contains(list []string, value string) bool

func EnvironmentVariableValue

func EnvironmentVariableValue(variable string) (value string)

func EnvironmentVariableValueWithDefault

func EnvironmentVariableValueWithDefault(variable, defaultValue string) string

func ErrorHandler

func ErrorHandler(f string, msg string)

func GetComponentTypeByNameFromRAM

func GetComponentTypeByNameFromRAM(componentName string) interface{}

func GetFunction

func GetFunction() string

func GetTypeAndBehaviour

func GetTypeAndBehaviour(file string) (string, string, error)

func IsExternal

func IsExternal(action string) bool

func IsInternal

func IsInternal(action string) bool

func LocalizeFDR

func LocalizeFDR() string

func LocalizeGo

func LocalizeGo() string

func LocalizegMidArch

func LocalizegMidArch() string

func MyInvoke

func MyInvoke(compType interface{}, compId string, op string, msg *messages.SAMessage, info *interface{}, reset *bool)

Utility functions

func MyTokenize

func MyTokenize(s string) []string

func SaveFile

func SaveFile(path, name, ext string, content []string)

func SkipLine

func SkipLine(line string) bool

func StringComposition

func StringComposition(e []string, sep string, hasSpace bool) string

Types

type AdaptationPlan

type AdaptationPlan struct {
	Operations []string
	Params     map[string][]string
}

type EvolutiveAnalysisResult

type EvolutiveAnalysisResult struct {
	NeedAdaptation         bool
	MonitoredEvolutiveData MonitoredEvolutiveData
}

type MonitoredEvolutiveData

type MonitoredEvolutiveData []string // used in channel Monitor -> Analyser (Evolutive)

var ListOfComponentsToAdaptTo MonitoredEvolutiveData

type UnitCommand

type UnitCommand struct {
	Cmd      string
	Params   plugin.Plugin
	Type     interface{}
	Selector func(interface{}, []*interface{}, string, *messages.SAMessage, []*interface{}, *bool)
}