package uiiit.rpc

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc ReceiveResponse (LambdaResponse, Void)

  edgeserver.proto:14

  receive a response to a previously issued lambda request

• rpc StreamUtil (Void, stream Utilization)

  edgecomputer.proto:8

  message Utilization

  edgecomputer.proto:11

  • map<string, float> values = 1

• rpc AnnounceComputer (ComputerInfo, Void)

  edgecontroller.proto:8

• rpc AnnounceRouter (RouterInfo, Void)

  edgecontroller.proto:9

  message RouterInfo

  edgecontroller.proto:24

  • string edgeServerEndpoint = 1

  • string forwardingTableEndpoint = 2

• rpc RemoveComputer (ComputerInfo, Void)

  edgecontroller.proto:10

• rpc Configure (EdgeRouterConf, Return)

  edgerouter.proto:8

  message EdgeRouterConf

  edgerouter.proto:13

  • EdgeRouterConf.Action action = 1

  • string lambda = 2

  • string destination = 3

  • float weight = 4

  • bool final = 5

  message Return

  edgerouter.proto:26

  • string msg = 2

• rpc GetNumTables (Void, NumTables)

  edgerouter.proto:10

  message NumTables

  edgerouter.proto:44

  • uint32 value = 1

• rpc GetTable (TableId, ForwardingTable)

  edgerouter.proto:9

  message TableId

  edgerouter.proto:40

  • uint32 value = 1

  message ForwardingTable

  edgerouter.proto:30

  • repeated ForwardingTable.Entry entries = 1

• rpc RunLambda (LambdaRequest, LambdaResponse)

  edgeserver.proto:9

  request the execution of a remote procedure on an edge computer

  message LambdaRequest

  edgeserver.proto:59

  • string name = 1

    name of the remote procedure to be executed

  • string input = 2

    function input, encoded as a string (may be empty)

  • bytes datain = 3

    function input, encoded as a binary object (may be empty)

  • bool dry = 4

    if true then instead of actually executing the function the edge server gives an estimate of the time required to run it in response

  • bool forward = 5

    if true this means that this request has been issued from a router or dispatcher and, hence, should not be forwarded further but rather addressed to a computer

  • uint32 hops = 6

    number of edge nodes traversed so far

  • map<string, State> states = 7

    map of application's states, accessed by their names key: name of the state value: state content

  • string callback = 8

    endpoint where to send the response for asynchronous invocations

  • repeated string chain = 9

    chain of functions to be executed (overrides name)

  • optional Dag dag = 10

    DAG of functions to be executed (overrides name)

  • map<string, FunctionList> dependencies = 11

    dependencies of functions upon the application's states key: name of the state value: list of functions that depend on this

  • uint32 nextFunctionIndex = 12

    index of the next function to execute in the chain/DAG

  • string uuid = 13

    unique identified of this request, needed only by DAGs

• rpc Del (State, StateResponse)

  edgeserver.proto:25

  delete a state, if available

• rpc Get (State, StateResponse)

  edgeserver.proto:19

  get a state, if available

• rpc Put (State, StateResponse)

  edgeserver.proto:22

  put a state, possibly overwriting existing content

Used as request type in: EdgeController.AnnounceComputer, EdgeController.RemoveComputer

• string edgeServerEndpoint = 1

• repeated ComputerInfo.Container containers = 2

Used in: ComputerInfo

• string name = 1

• string processor = 2

• string lambda = 3

• uint32 numWorkers = 4

Used in: LambdaRequest

• repeated IndexList successors = 1

  the i-th entry contains the list of successors of function with index i in the DAG there are N+1 function calls, where N is the size of successors

• repeated string names = 2

  the i-th entry contains the name of the function with index i the size of names is equal to the size of successors + 1 (to include also the last function, which has no successors)

Used in: EdgeRouterConf

• FLUSH = 0

  valid fields: none

• CHANGE = 1

  valid fields: all

• REMOVE = 2

  valid fields: lambda

Used in: ForwardingTable

• string lambda = 1

• string destination = 2

• float weight = 3

• bool final = 4

Used in: LambdaRequest

• repeated string functions = 1

Used in: Dag

• repeated uint64 functions = 1

Used as request type in: CallbackServer.ReceiveResponse

Used as response type in: EdgeServer.RunLambda

• string retcode = 1

  execution response: - OK: the function was executed with success - else: string encoding the type of error encountered should never be empty

• string output = 2

  execution output, encoded as a string (may be empty)

• string responder = 3

  identifier of the edge computer that carried out the procedure

• uint32 ptime = 4

  time required for the execution of the lambda on the computer, in ms (does not include queueing in the gRPC server)

• bytes dataout = 5

  execution output, encoded as a binary object (may be empty)

• uint32 load1 = 6

  utilization of the edge computer before the execution of this procedure, scaled in 0-100

• uint32 load10 = 7

  average utilization of the edge computer in the last 10 seconds, scaled in 0-100

• uint32 load30 = 8

  average utilization of the edge computer in the last 30 seconds, scaled in 0-100

• uint32 hops = 9

  number of edge nodes traversed so far

• map<string, State> states = 10

  map of application's states, accessed by their names

• bool asynchronous = 11

  if true then this response does not contain the output this is used with asynchronous function invocations

application's state

Used as request type in: StateServer.Del, StateServer.Get, StateServer.Put

Used as field type in: LambdaRequest, LambdaResponse, StateResponse

• string name = 1

  the name of the state on the server

• string location = 2

  the endpoint of the server that holds the state

• bytes content = 3

  the content of the state

Used as response type in: StateServer.Del, StateServer.Get, StateServer.Put

• string retcode = 1

  execution response: - OK: the function was executed with success - else: string encoding the type of error encountered should never be empty

• optional State state = 2

  the state (can be empty)

Used as request type in: EdgeComputer.StreamUtil, EdgeRouter.GetNumTables

Used as response type in: CallbackServer.ReceiveResponse, EdgeController.AnnounceComputer, EdgeController.AnnounceRouter, EdgeController.RemoveComputer

(message has no fields)