Skip to content

Commit

Permalink
Change repo path
Browse files Browse the repository at this point in the history
Signed-off-by: Lazar Cvetković <[email protected]>
  • Loading branch information
cvetkovic committed Sep 8, 2023
1 parent 8a37e1d commit 1708569
Show file tree
Hide file tree
Showing 25 changed files with 48 additions and 48 deletions.
2 changes: 1 addition & 1 deletion .github/configs/linkcheck.json
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
"pattern": "^http://127.0.0.1:*"
}
{
"pattern": "^https://github.com/eth-easl/loader/*"
"pattern": "^https://github.com/vhive-serverless/loader/*"
}
],
"replacementPatterns": [
Expand Down
8 changes: 4 additions & 4 deletions cmd/loader.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,10 @@ import (
"os"
"time"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/config"
"github.com/eth-easl/loader/pkg/driver"
"github.com/eth-easl/loader/pkg/trace"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/config"
"github.com/vhive-serverless/loader/pkg/driver"
"github.com/vhive-serverless/loader/pkg/trace"

log "github.com/sirupsen/logrus"

Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/eth-easl/loader
module github.com/vhive-serverless/loader

go 1.19

Expand Down
2 changes: 1 addition & 1 deletion pkg/driver/deployment.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ import (
"regexp"
"strconv"

"github.com/eth-easl/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/common"

log "github.com/sirupsen/logrus"
)
Expand Down
2 changes: 1 addition & 1 deletion pkg/driver/deployment_openwhisk.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ import (
"os/exec"
"strings"

"github.com/eth-easl/loader/pkg/common"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
)

func DeployFunctionsOpenWhisk(functions []*common.Function) {
Expand Down
8 changes: 4 additions & 4 deletions pkg/driver/grpc_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,17 +29,17 @@ import (
"strings"
"time"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/config"
"github.com/eth-easl/loader/pkg/workload/proto"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/config"
"github.com/vhive-serverless/loader/pkg/workload/proto"

log "github.com/sirupsen/logrus"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"

"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"

mc "github.com/eth-easl/loader/pkg/metric"
mc "github.com/vhive-serverless/loader/pkg/metric"
)

func Invoke(function *common.Function, runtimeSpec *common.RuntimeSpecification, cfg *config.LoaderConfiguration) (bool, *mc.ExecutionRecord) {
Expand Down
6 changes: 3 additions & 3 deletions pkg/driver/grpc_client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,10 @@ import (
"testing"
"time"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/config"
"github.com/eth-easl/loader/pkg/workload/standard"
"github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/config"
"github.com/vhive-serverless/loader/pkg/workload/standard"
)

func createFakeLoaderConfiguration() *config.LoaderConfiguration {
Expand Down
6 changes: 3 additions & 3 deletions pkg/driver/http_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,10 +34,10 @@ import (
"sync"
"time"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/config"
mc "github.com/eth-easl/loader/pkg/metric"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/config"
mc "github.com/vhive-serverless/loader/pkg/metric"
)

type ActivationMetadata struct {
Expand Down
10 changes: 5 additions & 5 deletions pkg/driver/trace_driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,13 +36,13 @@ import (

"strconv"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/config"
"github.com/eth-easl/loader/pkg/generator"
mc "github.com/eth-easl/loader/pkg/metric"
"github.com/eth-easl/loader/pkg/trace"
"github.com/gocarina/gocsv"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/config"
"github.com/vhive-serverless/loader/pkg/generator"
mc "github.com/vhive-serverless/loader/pkg/metric"
"github.com/vhive-serverless/loader/pkg/trace"
)

type DriverConfiguration struct {
Expand Down
6 changes: 3 additions & 3 deletions pkg/driver/trace_driver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@ import (
"testing"
"time"

"github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/metric"
"github.com/eth-easl/loader/pkg/workload/standard"
"github.com/gocarina/gocsv"
"github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/metric"
"github.com/vhive-serverless/loader/pkg/workload/standard"
)

func createTestDriver() *Driver {
Expand Down
2 changes: 1 addition & 1 deletion pkg/generator/specification.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ package generator
import (
"math/rand"

"github.com/eth-easl/loader/pkg/common"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
)

type SpecificationGenerator struct {
Expand Down
2 changes: 1 addition & 1 deletion pkg/generator/specification_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@ import (
"sync"
"testing"

"github.com/eth-easl/loader/pkg/common"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
)

var testFunction = common.Function{
Expand Down
2 changes: 1 addition & 1 deletion pkg/trace/parser.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ package trace
import (
"encoding/csv"
"fmt"
"github.com/eth-easl/loader/pkg/common"
"github.com/gocarina/gocsv"
"github.com/vhive-serverless/loader/pkg/common"
"io"
"math/rand"
"os"
Expand Down
2 changes: 1 addition & 1 deletion pkg/trace/profiler.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@
package trace

import (
"github.com/eth-easl/loader/pkg/common"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/common"
"math"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/trace/profiler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
package trace

import (
"github.com/eth-easl/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/common"
"testing"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/workload/proto/faas.proto
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
*/
syntax = "proto3";

option go_package = "github.com/eth-easl/loader/workload/proto";
option go_package = "github.com/vhive-serverless/loader/workload/proto";

package faas;

Expand Down
4 changes: 2 additions & 2 deletions pkg/workload/proto/faas_pb2.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,9 @@
name='server/faas.proto',
package='faas',
syntax='proto3',
serialized_options=b'Z!github.com/eth-easl/loader/server',
serialized_options=b'Z!github.com/vhive-serverless/loader/server',
create_key=_descriptor._internal_create_key,
serialized_pb=b'\n\x11server/faas.proto\x12\x04\x66\x61\x61s\"T\n\x0b\x46\x61\x61sRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\x19\n\x11runtimeInMilliSec\x18\x02 \x01(\r\x12\x19\n\x11memoryInMebiBytes\x18\x03 \x01(\r\"Q\n\tFaasReply\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\x1a\n\x12\x64urationInMicroSec\x18\x02 \x01(\r\x12\x17\n\x0fmemoryUsageInKb\x18\x03 \x01(\r2;\n\x08\x45xecutor\x12/\n\x07\x45xecute\x12\x11.faas.FaasRequest\x1a\x0f.faas.FaasReply\"\x00\x42#Z!github.com/eth-easl/loader/serverb\x06proto3'
serialized_pb=b'\n\x11server/faas.proto\x12\x04\x66\x61\x61s\"T\n\x0b\x46\x61\x61sRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\x19\n\x11runtimeInMilliSec\x18\x02 \x01(\r\x12\x19\n\x11memoryInMebiBytes\x18\x03 \x01(\r\"Q\n\tFaasReply\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\x1a\n\x12\x64urationInMicroSec\x18\x02 \x01(\r\x12\x17\n\x0fmemoryUsageInKb\x18\x03 \x01(\r2;\n\x08\x45xecutor\x12/\n\x07\x45xecute\x12\x11.faas.FaasRequest\x1a\x0f.faas.FaasReply\"\x00\x42#Z!github.com/vhive-serverless/loader/serverb\x06proto3'
)


Expand Down
4 changes: 2 additions & 2 deletions pkg/workload/standard/workload.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,9 @@ import (
"context"
"fmt"
tracing "github.com/ease-lab/vhive/utils/tracing/go"
util "github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/workload/proto"
log "github.com/sirupsen/logrus"
util "github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/workload/proto"
"google.golang.org/grpc"
"google.golang.org/grpc/reflection"
"net"
Expand Down
4 changes: 2 additions & 2 deletions server/timed/timed.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ import (
"context"
"errors"
"fmt"
util "github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/workload/proto"
util "github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/workload/proto"
"net"
"os"
"strconv"
Expand Down
2 changes: 1 addition & 1 deletion server/trace-func-go/trace_func.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ package main

import (
"flag"
"github.com/eth-easl/loader/pkg/workload/standard"
log "github.com/sirupsen/logrus"
"github.com/vhive-serverless/loader/pkg/workload/standard"
"os"
"strconv"
)
Expand Down
2 changes: 1 addition & 1 deletion server/trace-func-py/faas.proto
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
*/
syntax = "proto3";

option go_package = "github.com/eth-easl/loader/pkg/faas";
option go_package = "github.com/vhive-serverless/loader/pkg/faas";

package faasfunction;

Expand Down
4 changes: 2 additions & 2 deletions server/trace-func-py/faas_pb2.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,9 @@
name='faas.proto',
package='faasfunction',
syntax='proto3',
serialized_options=b'Z\'github.com/eth-easl/loader/pkg/faas',
serialized_options=b'Z\'github.com/vhive-serverless/loader/pkg/faas',
create_key=_descriptor._internal_create_key,
serialized_pb=b'\n\nfaas.proto\x12\x0c\x66\x61\x61sfunction\"=\n\x0b\x46\x61\x61sRequest\x12\r\n\x05input\x18\x01 \x01(\t\x12\x0f\n\x07runtime\x18\x02 \x01(\r\x12\x0e\n\x06memory\x18\x03 \x01(\r\".\n\tFaasReply\x12\x10\n\x08response\x18\x01 \x01(\t\x12\x0f\n\x07latency\x18\x02 \x01(\x03\x32K\n\x08\x45xecutor\x12?\n\x07\x45xecute\x12\x19.faasfunction.FaasRequest\x1a\x17.faasfunction.FaasReply\"\x00\x42)Z\'github.com/eth-easl/loader/pkg/faasb\x06proto3'
serialized_pb=b'\n\nfaas.proto\x12\x0c\x66\x61\x61sfunction\"=\n\x0b\x46\x61\x61sRequest\x12\r\n\x05input\x18\x01 \x01(\t\x12\x0f\n\x07runtime\x18\x02 \x01(\r\x12\x0e\n\x06memory\x18\x03 \x01(\r\".\n\tFaasReply\x12\x10\n\x08response\x18\x01 \x01(\t\x12\x0f\n\x07latency\x18\x02 \x01(\x03\x32K\n\x08\x45xecutor\x12?\n\x07\x45xecute\x12\x19.faasfunction.FaasRequest\x1a\x17.faasfunction.FaasReply\"\x00\x42)Z\'github.com/vhive-serverless/loader/pkg/faasb\x06proto3'
)


Expand Down
4 changes: 2 additions & 2 deletions server/wimpy/wimpy.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ import (
"context"
"errors"
"fmt"
util "github.com/eth-easl/loader/pkg/common"
"github.com/eth-easl/loader/pkg/workload/proto"
util "github.com/vhive-serverless/loader/pkg/common"
"github.com/vhive-serverless/loader/pkg/workload/proto"
"net"
"time"

Expand Down
6 changes: 3 additions & 3 deletions tools/driver/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -46,9 +46,9 @@ is then the duration of the measurement phase + the duration of the warmup phase
"outputDir": The local output directory on the machine running the experiment driver, this is where experiment results
will be saved.
"YAMLSelector": Which yaml specification to use, supported values are
"[wimpy](https://github.com/eth-easl/loader/blob/main/workloads/container/wimpy.yaml)",
"[container](https://github.com/eth-easl/loader/blob/main/workloads/container/trace_func_go.yaml)" and
"[firecracker](https://github.com/eth-easl/loader/blob/main/workloads/firecracker/trace_func_go.yaml)".
"[wimpy](https://github.com/vhive-serverless/loader/blob/main/workloads/container/wimpy.yaml)",
"[container](https://github.com/vhive-serverless/loader/blob/main/workloads/container/trace_func_go.yaml)" and
"[firecracker](https://github.com/vhive-serverless/loader/blob/main/workloads/firecracker/trace_func_go.yaml)".
"IATDistribution": The IAT distribution that the loader will use when sending invocations to the worker node(s).
Supported values are "exponential", "uniform" and "equidistant".
"loaderOutputPath": The output path for the experiment results on the loader node.
Expand Down
2 changes: 1 addition & 1 deletion tools/trace_synthesizer/synthesizer.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ def generate(args):
lenHashes = 64
sampleCount = 1
# needs to be > 0 to work with loader implementation on loader_unit_tests branch
# see https://github.com/eth-easl/loader/blob/acdcde214d7a08d3603011ec5c9d28885ab3e986/pkg/generator/specification.go#L189
# see https://github.com/vhive-serverless/loader/blob/acdcde214d7a08d3603011ec5c9d28885ab3e986/pkg/generator/specification.go#L189
for i in range(functions):
hashFunction.append(hash_generator(lenHashes))
hashOwner.append(hash_generator(lenHashes))
Expand Down

0 comments on commit 1708569

Please sign in to comment.