feast-dev
diff --git a/‎go/feast/connector.go‎
Lines changed: 1 addition & 14 deletions b/‎go/feast/connector.go‎
Lines changed: 1 addition & 14 deletions
diff --git a/‎go/feast/featureservice.go‎
Lines changed: 37 additions & 0 deletions b/‎go/feast/featureservice.go‎
Lines changed: 37 additions & 0 deletions
@@ -3,23 +3,18 @@ package feast
 import (
 	"errors"
 	"fmt"
-	// "io/ioutil"
-	// "log"
 	"os"
 	"os/exec"
 	"github.com/hashicorp/go-plugin"
 	"github.com/hashicorp/go-hclog"
-	"path/filepath"
-	"runtime"
-	// "time"
-	// "github.com/feast-dev/feast/go/protos/feast/third_party/grpc/connector"
 )
 
 func getOnlineStore(config *RepoConfig) (OnlineStore, error) {
 	onlineStoreType, ok := getOnlineStoreType(config.OnlineStore)
 	if !ok {
 		return nil, errors.New(fmt.Sprintf("could not get online store type from online store config: %+v", config.OnlineStore))
 	}
+	fmt.Println(onlineStoreType)
 	if onlineStoreType == "redis" {
 		onlineStore, err := NewRedisOnlineStore(config.Project, config.OnlineStore)
 		return onlineStore, err
@@ -35,14 +30,7 @@ func connectorClient(KV_PLUGIN string) (OnlineStore, error) {
 	// log.SetOutput(ioutil.Discard)
 
 	// We're a host. Start by launching the plugin process.
-	_, filename, _, ok := runtime.Caller(0)
-	if !ok {
-		panic("couldn't find file path of the connector file")
-	}
 	cmd := exec.Command("sh", "-c", KV_PLUGIN )
-	cmd.Env = os.Environ()
-	connectorPythonPath := filepath.Join(filename, "..", "..", "test_repo/connector_python")
-    cmd.Env = append(cmd.Env, fmt.Sprintf("PYTHONPATH=%s:$PYTHONPATH", connectorPythonPath))
 
 	logger := hclog.New(&hclog.LoggerOptions{
 		Name:   "plugin",
@@ -84,5 +72,4 @@ func connectorClient(KV_PLUGIN string) (OnlineStore, error) {
 		}
 		return onlineStore, nil
 	}
-	// return raw, nil
 }
@@ -0,0 +1,37 @@
+package feast
+
+import (
+	"errors"
+	"github.com/feast-dev/feast/go/protos/feast/core"
+	"github.com/feast-dev/feast/go/protos/feast/serving"
+	"github.com/feast-dev/feast/go/protos/feast/types"
+	"github.com/golang/protobuf/proto"
+	durationpb "google.golang.org/protobuf/types/known/durationpb"
+	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
+	"io/ioutil"
+	"strings"
+	// "sort"
+	"fmt"
+)
+
+// Wrapper around core.FeatureView to add projection
+type FeatureService struct {
+	name string
+	project string
+	createdTimestamp *timestamppb.Timestamp
+	lastUpdatedTimestamp *timestamppb.Timestamp
+	projections []*FeatureViewProjection
+}
+
+func NewFeatureServiceFromProto(proto *core.FeatureService) *FeatureService {
+	projections := make([]*FeatureViewProjection, len(proto.GetFeatures()))
+	for index, projection := range proto.GetFeatures() {
+		projections[index] = &FeatureViewProjection{proto: projection}
+	}
+	return 	&FeatureService	{	name: proto.GetSpec().GetName(),
+								project: proto.GetSpec().GetName(),
+								createdTimestamp: proto.GetMeta().GetCreatedTimestamp(),
+								lastUpdatedTimestamp: proto.GetMeta().GetLastUpdatedTimestamp(),
+								projections: projections,
+							}
+}