pull/2411/head
devinyan 9 years ago
parent 2bde5a0e75
commit 9f4299e57a

@ -126,8 +126,9 @@ func (r *ReleaseModuleServiceServer) UpgradeRelease(ctx context.Context, in *rud
return &rudderAPI.UpgradeReleaseResponse{}, err return &rudderAPI.UpgradeReleaseResponse{}, err
} }
func (r *ReleaseModuleServiceServer) ReleaseStatus(ctx context.Context, in *rudderAPI.ReleaseStatusRequest, filter kube.FilterStruct) (*rudderAPI.ReleaseStatusResponse, error) { func (r *ReleaseModuleServiceServer) ReleaseStatus(ctx context.Context, in *rudderAPI.ReleaseStatusRequest) (*rudderAPI.ReleaseStatusResponse, error) {
grpclog.Print("status") grpclog.Print("status")
var filter kube.FilterStruct = kube.FilterStruct{Kind:"",Instance:""}
resp, err := kubeClient.Get(in.Release.Namespace, bytes.NewBufferString(in.Release.Manifest),filter) resp, err := kubeClient.Get(in.Release.Namespace, bytes.NewBufferString(in.Release.Manifest),filter)
in.Release.Info.Status.Resources = resp in.Release.Info.Status.Resources = resp

@ -23,7 +23,7 @@ import (
"google.golang.org/grpc" "google.golang.org/grpc"
rudderAPI "k8s.io/helm/pkg/proto/hapi/rudder" rudderAPI "k8s.io/helm/pkg/proto/hapi/rudder"
"k8s.io/helm/pkg/kube"
) )
// GrpcPort specifies port on which rudder will spawn a server // GrpcPort specifies port on which rudder will spawn a server
@ -69,14 +69,14 @@ func RollbackRelease(req *rudderAPI.RollbackReleaseRequest) (*rudderAPI.Rollback
} }
// ReleaseStatus calls Rudder ReleaseStatus method which should perform update // ReleaseStatus calls Rudder ReleaseStatus method which should perform update
func ReleaseStatus(req *rudderAPI.ReleaseStatusRequest, filter kube.FilterStruct) (*rudderAPI.ReleaseStatusResponse, error) { func ReleaseStatus(req *rudderAPI.ReleaseStatusRequest) (*rudderAPI.ReleaseStatusResponse, error) {
conn, err := grpc.Dial(grpcAddr, grpc.WithInsecure()) conn, err := grpc.Dial(grpcAddr, grpc.WithInsecure())
if err != nil { if err != nil {
return nil, err return nil, err
} }
defer conn.Close() defer conn.Close()
client := rudderAPI.NewReleaseModuleServiceClient(conn) client := rudderAPI.NewReleaseModuleServiceClient(conn)
return client.ReleaseStatus(context.Background(), req,filter) return client.ReleaseStatus(context.Background(), req)
} }
// DeleteRelease calls Rudder DeleteRelease method which should uninstall provided release // DeleteRelease calls Rudder DeleteRelease method which should uninstall provided release

@ -120,9 +120,9 @@ func (m *RemoteReleaseModule) Rollback(current, target *release.Release, req *se
} }
// Status returns status retrieved from rudder.ReleaseStatus // Status returns status retrieved from rudder.ReleaseStatus
func (m *RemoteReleaseModule) Status(r *release.Release, req *services.GetReleaseStatusRequest, env *environment.Environment, filter kube.FilterStruct) (string, error) { func (m *RemoteReleaseModule) Status(r *release.Release, req *services.GetReleaseStatusRequest, env *environment.Environment) (string, error) {
statusRequest := &rudderAPI.ReleaseStatusRequest{Release: r} statusRequest := &rudderAPI.ReleaseStatusRequest{Release: r}
resp, err := rudder.ReleaseStatus(statusRequest,filter) resp, err := rudder.ReleaseStatus(statusRequest)
return resp.Info.Status.Resources, err return resp.Info.Status.Resources, err
} }

Loading…
Cancel
Save