Merge pull request #417 from kube-tarian/plugin-app-model

adding new model plugin app config files

Makefile

@@ -11,9 +11,12 @@ gen-protoc:
 	mkdir -p capten/agent/internal/pb/captenpluginspb
 	mkdir -p server/pkg/pb/agentpb
 	mkdir -p server/pkg/pb/captenpluginspb
+	mkdir -p server/pkg/pb/pluginstorepb
 	mkdir -p capten/agent/internal/pb/captensdkpb
 	mkdir -p capten/common-pkg/vault-cred/vaultcredpb
 	mkdir -p capten/common-pkg/capten-sdk/captensdkpb
+	mkdir -p capten/common-pkg/vault-cred/vaultcredpb
+	mkdir -p capten/common-pkg/cluster-plugins/clusterpluginspb
 
 	cd proto && protoc --go_out=../server/pkg/pb/serverpb/ --go_opt=paths=source_relative \
     		--go-grpc_out=../server/pkg/pb/serverpb  --go-grpc_opt=paths=source_relative \
@@ -55,6 +58,14 @@ gen-protoc:
     		--go-grpc_out=../capten/common-pkg/vault-cred/vaultcredpb --go-grpc_opt=paths=source_relative \
     		./vault_cred.proto
 
+	cd proto && protoc --go_out=../server/pkg/pb/pluginstorepb --go_opt=paths=source_relative \
+    		--go-grpc_out=../server/pkg/pb/pluginstorepb --go-grpc_opt=paths=source_relative \
+    		./plugin_store.proto
+
+	cd proto && protoc --go_out=../capten/common-pkg/cluster-plugins/clusterpluginspb --go_opt=paths=source_relative \
+    		--go-grpc_out=../capten/common-pkg/cluster-plugins/clusterpluginspb --go-grpc_opt=paths=source_relative \
+    		./cluster_plugins.proto
+
 docker-build-server:
 	# The prefix for server to changed either as server or intelops-kad-server
 	docker build --platform=linux/amd64 -f dockerfiles/server/Dockerfile -t ${PREFIX}-${SERVER_APP_NAME}:${BUILD} .

capten/agent/internal/api/agent.go

@@ -11,6 +11,7 @@ import (
 	"github.com/kube-tarian/kad/capten/agent/internal/pb/captenpluginspb"
 	"github.com/kube-tarian/kad/capten/agent/internal/pb/captensdkpb"
 	"github.com/kube-tarian/kad/capten/agent/internal/temporalclient"
+	"github.com/kube-tarian/kad/capten/common-pkg/cluster-plugins/clusterpluginspb"
 )
 
 var _ agentpb.AgentServer = &Agent{}
@@ -19,6 +20,7 @@ type Agent struct {
 	agentpb.UnimplementedAgentServer
 	captenpluginspb.UnimplementedCaptenPluginsServer
 	captensdkpb.UnimplementedCaptenSdkServer
+	clusterpluginspb.UnimplementedClusterPluginsServer
 	tc       *temporalclient.Client
 	as       *captenstore.Store
 	log      logging.Logger

capten/agent/internal/api/cluster_plugin_apis.go

@@ -0,0 +1,25 @@
+package api
+
+import (
+	"context"
+
+	"github.com/kube-tarian/kad/capten/common-pkg/cluster-plugins/clusterpluginspb"
+)
+
+func (a *Agent) GetClusterPlugins(ctx context.Context, request *clusterpluginspb.GetClusterPluginsRequest) (
+	*clusterpluginspb.GetClusterPluginsResponse, error) {
+	return &clusterpluginspb.GetClusterPluginsResponse{
+		Status: clusterpluginspb.StatusCode_OK}, nil
+}
+
+func (a *Agent) DeployClusterPlugin(ctx context.Context, request *clusterpluginspb.DeployClusterPluginRequest) (
+	*clusterpluginspb.DeployClusterPluginResponse, error) {
+	return &clusterpluginspb.DeployClusterPluginResponse{
+		Status: clusterpluginspb.StatusCode_OK}, nil
+}
+
+func (a *Agent) UnDeployClusterPlugin(ctx context.Context, request *clusterpluginspb.UnDeployClusterPluginRequest) (
+	*clusterpluginspb.UnDeployClusterPluginResponse, error) {
+	return &clusterpluginspb.UnDeployClusterPluginResponse{
+		Status: clusterpluginspb.StatusCode_OK}, nil
+}