diff --git a/benchmark/bench_test.go b/benchmark/bench_test.go index ade2ea41..6bbd1742 100644 --- a/benchmark/bench_test.go +++ b/benchmark/bench_test.go @@ -20,12 +20,12 @@ import ( "context" "github.com/apache/pulsar-client-go/pulsaradmin" "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/fs" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/perf" - "github.com/functionstream/functionstream/restclient" - "github.com/functionstream/functionstream/server" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/fs" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/perf" + "github.com/functionstream/function-stream/restclient" + "github.com/functionstream/function-stream/server" "math/rand" "os" "runtime/pprof" diff --git a/cmd/client/cmd.go b/cmd/client/cmd.go index 9e954d47..bce9a708 100644 --- a/cmd/client/cmd.go +++ b/cmd/client/cmd.go @@ -17,12 +17,12 @@ package client import ( - c "github.com/functionstream/functionstream/cmd/client/common" - "github.com/functionstream/functionstream/cmd/client/consume" - "github.com/functionstream/functionstream/cmd/client/create" - del "github.com/functionstream/functionstream/cmd/client/delete" - "github.com/functionstream/functionstream/cmd/client/list" - "github.com/functionstream/functionstream/cmd/client/produce" + c "github.com/functionstream/function-stream/cmd/client/common" + "github.com/functionstream/function-stream/cmd/client/consume" + "github.com/functionstream/function-stream/cmd/client/create" + del "github.com/functionstream/function-stream/cmd/client/delete" + "github.com/functionstream/function-stream/cmd/client/list" + "github.com/functionstream/function-stream/cmd/client/produce" "github.com/spf13/cobra" ) diff --git a/cmd/client/consume/cmd.go b/cmd/client/consume/cmd.go index 28d06c20..1971e605 100644 --- a/cmd/client/consume/cmd.go +++ b/cmd/client/consume/cmd.go @@ -19,8 +19,8 @@ package consume import ( "context" "fmt" - "github.com/functionstream/functionstream/cmd/client/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/cmd/client/common" + "github.com/functionstream/function-stream/restclient" "github.com/spf13/cobra" "os" ) diff --git a/cmd/client/create/cmd.go b/cmd/client/create/cmd.go index 69b692ae..82b78010 100644 --- a/cmd/client/create/cmd.go +++ b/cmd/client/create/cmd.go @@ -19,9 +19,9 @@ package create import ( "context" "fmt" - "github.com/functionstream/functionstream/cmd/client/common" - fs_cmmon "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/cmd/client/common" + fs_cmmon "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/restclient" "github.com/spf13/cobra" "io" "os" diff --git a/cmd/client/delete/cmd.go b/cmd/client/delete/cmd.go index ffdb71d0..18bf3a36 100644 --- a/cmd/client/delete/cmd.go +++ b/cmd/client/delete/cmd.go @@ -19,8 +19,8 @@ package del import ( "context" "fmt" - "github.com/functionstream/functionstream/cmd/client/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/cmd/client/common" + "github.com/functionstream/function-stream/restclient" "github.com/spf13/cobra" "os" ) diff --git a/cmd/client/list/cmd.go b/cmd/client/list/cmd.go index 0148f183..3c7a30d0 100644 --- a/cmd/client/list/cmd.go +++ b/cmd/client/list/cmd.go @@ -19,8 +19,8 @@ package list import ( "context" "fmt" - "github.com/functionstream/functionstream/cmd/client/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/cmd/client/common" + "github.com/functionstream/function-stream/restclient" "github.com/spf13/cobra" "os" ) diff --git a/cmd/client/produce/cmd.go b/cmd/client/produce/cmd.go index 79d1e962..a3f495ee 100644 --- a/cmd/client/produce/cmd.go +++ b/cmd/client/produce/cmd.go @@ -19,8 +19,8 @@ package produce import ( "context" "fmt" - "github.com/functionstream/functionstream/cmd/client/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/cmd/client/common" + "github.com/functionstream/function-stream/restclient" "github.com/spf13/cobra" "os" ) diff --git a/cmd/main.go b/cmd/main.go index bb8b1dc7..2485e6a6 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -18,10 +18,10 @@ package main import ( "fmt" - "github.com/functionstream/functionstream/cmd/client" - "github.com/functionstream/functionstream/cmd/perf" - "github.com/functionstream/functionstream/cmd/server" - "github.com/functionstream/functionstream/cmd/standalone" + "github.com/functionstream/function-stream/cmd/client" + "github.com/functionstream/function-stream/cmd/perf" + "github.com/functionstream/function-stream/cmd/server" + "github.com/functionstream/function-stream/cmd/standalone" "github.com/spf13/cobra" "os" ) diff --git a/cmd/perf/cmd.go b/cmd/perf/cmd.go index 86cf2154..281dc1f2 100644 --- a/cmd/perf/cmd.go +++ b/cmd/perf/cmd.go @@ -18,8 +18,8 @@ package perf import ( "context" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/perf" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/perf" "github.com/spf13/cobra" "io" ) diff --git a/cmd/server/cmd.go b/cmd/server/cmd.go index 8e7f0f99..4507d76f 100644 --- a/cmd/server/cmd.go +++ b/cmd/server/cmd.go @@ -18,8 +18,8 @@ package server import ( "context" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/server" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/server" "github.com/spf13/cobra" "io" ) diff --git a/cmd/standalone/cmd.go b/cmd/standalone/cmd.go index 1127178a..d88eb206 100644 --- a/cmd/standalone/cmd.go +++ b/cmd/standalone/cmd.go @@ -18,8 +18,8 @@ package standalone import ( "context" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/server" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/server" "github.com/spf13/cobra" "io" ) diff --git a/common/model/function.go b/common/model/function.go index f6d1c2f2..279017e3 100644 --- a/common/model/function.go +++ b/common/model/function.go @@ -16,7 +16,7 @@ package model -import "github.com/functionstream/functionstream/fs/contube" +import "github.com/functionstream/function-stream/fs/contube" type TubeConfig struct { Config contube.ConfigMap `json:"config,omitempty" yaml:"config,omitempty"` diff --git a/common/model/function_serde_test.go b/common/model/function_serde_test.go index 94044aa2..63e7ae71 100644 --- a/common/model/function_serde_test.go +++ b/common/model/function_serde_test.go @@ -19,7 +19,7 @@ package model import ( "encoding/json" "fmt" - "github.com/functionstream/functionstream/common" + "github.com/functionstream/function-stream/common" "gopkg.in/yaml.v3" "reflect" "testing" diff --git a/fs/api/instance.go b/fs/api/instance.go index e2d6d544..3e54ca92 100644 --- a/fs/api/instance.go +++ b/fs/api/instance.go @@ -17,8 +17,8 @@ package api import ( - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs/contube" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs/contube" "golang.org/x/net/context" ) diff --git a/fs/api/runtime.go b/fs/api/runtime.go index 4cae72a2..55df3e8e 100644 --- a/fs/api/runtime.go +++ b/fs/api/runtime.go @@ -17,7 +17,7 @@ package api import ( - "github.com/functionstream/functionstream/fs/contube" + "github.com/functionstream/function-stream/fs/contube" ) type FunctionRuntime interface { diff --git a/fs/instance_impl.go b/fs/instance_impl.go index f71f4b84..46708e75 100644 --- a/fs/instance_impl.go +++ b/fs/instance_impl.go @@ -19,9 +19,9 @@ package fs import ( "context" "fmt" - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs/api" - "github.com/functionstream/functionstream/fs/contube" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs/api" + "github.com/functionstream/function-stream/fs/contube" "github.com/pkg/errors" "github.com/sirupsen/logrus" "log/slog" diff --git a/fs/manager.go b/fs/manager.go index de2475d3..f7dc9c46 100644 --- a/fs/manager.go +++ b/fs/manager.go @@ -18,11 +18,11 @@ package fs import ( "context" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs/api" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/fs/runtime/wazero" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs/api" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/fs/runtime/wazero" "github.com/pkg/errors" "log/slog" "math/rand" diff --git a/fs/runtime/grpc/grpc_func.go b/fs/runtime/grpc/grpc_func.go index fa01e71f..6cd89194 100644 --- a/fs/runtime/grpc/grpc_func.go +++ b/fs/runtime/grpc/grpc_func.go @@ -18,9 +18,9 @@ package grpc import ( "fmt" - "github.com/functionstream/functionstream/fs/api" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/fs/runtime/grpc/proto" + "github.com/functionstream/function-stream/fs/api" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/fs/runtime/grpc/proto" "golang.org/x/net/context" "google.golang.org/grpc" "google.golang.org/grpc/metadata" diff --git a/fs/runtime/grpc/grpc_func_test.go b/fs/runtime/grpc/grpc_func_test.go index 36c1ed92..c27b9f7c 100644 --- a/fs/runtime/grpc/grpc_func_test.go +++ b/fs/runtime/grpc/grpc_func_test.go @@ -18,11 +18,11 @@ package grpc import ( "context" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs" - "github.com/functionstream/functionstream/fs/api" - "github.com/functionstream/functionstream/fs/contube" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs" + "github.com/functionstream/function-stream/fs/api" + "github.com/functionstream/function-stream/fs/contube" "testing" "time" ) diff --git a/fs/runtime/grpc/mock_grpc_func_test.go b/fs/runtime/grpc/mock_grpc_func_test.go index d2dabd55..dfd4fa26 100644 --- a/fs/runtime/grpc/mock_grpc_func_test.go +++ b/fs/runtime/grpc/mock_grpc_func_test.go @@ -17,7 +17,7 @@ package grpc import ( - "github.com/functionstream/functionstream/fs/runtime/grpc/proto" + "github.com/functionstream/function-stream/fs/runtime/grpc/proto" "golang.org/x/net/context" "google.golang.org/grpc" "google.golang.org/grpc/codes" diff --git a/fs/runtime/wazero/wazero_runtime.go b/fs/runtime/wazero/wazero_runtime.go index f75ae617..81167cab 100644 --- a/fs/runtime/wazero/wazero_runtime.go +++ b/fs/runtime/wazero/wazero_runtime.go @@ -17,9 +17,9 @@ package wazero import ( - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/fs/api" - "github.com/functionstream/functionstream/fs/contube" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/fs/api" + "github.com/functionstream/function-stream/fs/contube" "github.com/pkg/errors" "github.com/tetratelabs/wazero" wazero_api "github.com/tetratelabs/wazero/api" diff --git a/go.mod b/go.mod index 8364986c..fbaf9996 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/functionstream/functionstream +module github.com/functionstream/function-stream go 1.21 diff --git a/perf/perf.go b/perf/perf.go index a0641ae3..5008fbe7 100644 --- a/perf/perf.go +++ b/perf/perf.go @@ -21,9 +21,9 @@ import ( "encoding/json" "fmt" "github.com/bmizerany/perks/quantile" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/restclient" "golang.org/x/time/rate" "log/slog" "math/rand" diff --git a/server/config_loader.go b/server/config_loader.go index 9f72a99d..4606defe 100644 --- a/server/config_loader.go +++ b/server/config_loader.go @@ -17,7 +17,7 @@ package server import ( - "github.com/functionstream/functionstream/common" + "github.com/functionstream/function-stream/common" "log/slog" "os" "sync" diff --git a/server/server.go b/server/server.go index e4faaba3..abfcc175 100644 --- a/server/server.go +++ b/server/server.go @@ -20,11 +20,11 @@ import ( "context" "encoding/json" "fmt" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/restclient" "github.com/gorilla/mux" "github.com/pkg/errors" "io" diff --git a/server/server_test.go b/server/server_test.go index defe27d4..e2e01a9a 100644 --- a/server/server_test.go +++ b/server/server_test.go @@ -19,10 +19,10 @@ package server import ( "context" "encoding/json" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/common/model" - "github.com/functionstream/functionstream/fs/contube" - "github.com/functionstream/functionstream/tests" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/common/model" + "github.com/functionstream/function-stream/fs/contube" + "github.com/functionstream/function-stream/tests" "math/rand" "strconv" "testing" diff --git a/tests/integration_test.go b/tests/integration_test.go index 4332782d..8c273fa8 100644 --- a/tests/integration_test.go +++ b/tests/integration_test.go @@ -20,8 +20,8 @@ import ( "context" "encoding/json" "github.com/apache/pulsar-client-go/pulsar" - "github.com/functionstream/functionstream/common" - "github.com/functionstream/functionstream/restclient" + "github.com/functionstream/function-stream/common" + "github.com/functionstream/function-stream/restclient" "io" "log/slog" "math/rand"