// Listen announces on the network address
listener, err = net.Listen("tcp", ":"+strconv.Itoa(s.port))
if err != nil {
- s.logger.Fatalf("failed to listen on port: %s. Err: %s", s.port, err)
- return err
+ s.logger.Fatalf("failed to listen on specified port")
}
- s.logger.Infof("Server started listening on port ", s.port)
+ s.logger.Infof("Server started listening on specified port")
// Secure connection if asked
if s.certificate != "" && s.key != "" {
grpcCreds, err = credentials.NewServerTLSFromFile(
s.certificate, s.key)
if err != nil {
- s.logger.Fatalf("failed to create tls grpc server using cert %s and key: %s. Err: %s", s.certificate, s.key, err)
+ s.logger.Fatalf("failed to create tls grpc server using given cert and key")
}
grpcOpts = append(grpcOpts, grpc.Creds(grpcCreds))
}
// Input validation
if (req.GetHostIp() == "") || (req.GetWorkloadId() == "") {
- return nil, s.logError(status.Errorf(codes.InvalidArgument, "Nil input HostIp: %s or workloadId: %s. " +
- "Err: %s", req.GetHostIp(), req.GetWorkloadId(), err))
+ return nil, s.logError(status.Errorf(codes.InvalidArgument, "HostIP & WorkloadId can't be null", err))
}
// Create HELM Client
hc, err := NewHelmClient(req.GetHostIp(), s.logger)
if os.IsNotExist(err) {
- return nil, s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig for HostIp can't be found: %s. " +
- "Err: %s", req.GetHostIp(), err))
+ return nil, s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig corresponding to given Edge can't be found. " +
+ "Err: %s", err))
}
// Query Chart
func (s *ServerGRPC) Terminate(ctx context.Context, req *lcmservice.TerminateRequest) (resp *lcmservice.TerminateResponse, err error) {
// Input validation
if (req.GetHostIp() == "") || (req.GetWorkloadId() == "") {
- return nil, s.logError(status.Errorf(codes.InvalidArgument, "Nil input HostIp: %s or workloadId: %s. " +
- "Err: %s", req.GetHostIp(), req.GetWorkloadId(), err))
+ return nil, s.logError(status.Errorf(codes.InvalidArgument, "HostIP & WorkloadId can't be null", err))
}
// Create HELM client
hc, err := NewHelmClient(req.GetHostIp(), s.logger)
if os.IsNotExist(err) {
- return nil, s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig for HostIp can't be found: %s. " +
- "Err: %s", req.GetHostIp(), err))
+ return nil, s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig corresponding to given Edge can't be found. " +
+ "Err: %s", err))
}
// Uninstall chart
}
hostIP := req.GetHostIp()
- s.logger.Info("Recieved instantiate request for host ", hostIP)
+ s.logger.Info("Recieved instantiate request")
// Host validation
if (hostIP == "") {
- return s.logError(status.Errorf(codes.InvalidArgument, "Nil input for HostIp: %s Err: %s", req.GetHostIp(), err))
+ return s.logError(status.Errorf(codes.InvalidArgument, "HostIP & WorkloadId can't be null", err))
}
// Receive package
return err
}
- s.logger.Info("Waiting to receive more data")
+ s.logger.Debug("Waiting to receive more data")
req, err := stream.Recv()
if err == io.EOF {
- s.logger.Info("No more data")
+ s.logger.Debug("No more data")
break
}
if err != nil {
// Create HELM client
hc, err := NewHelmClient(req.GetHostIp(), s.logger)
if os.IsNotExist(err) {
- return s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig for HostIp can't be found: %s. " +
- "Err: %s", req.GetHostIp(), err))
+ return s.logError(status.Errorf(codes.InvalidArgument, "Kubeconfig corresponding to edge can't be found. " +
+ "Err: %s", err))
}
relName, err := hc.installChart(helmPkg)
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package plugin
import (
// Install a given helm chart
func (hc *HelmClient) installChart(helmPkg bytes.Buffer) (string, error) {
- hc.logger.Info("Inside helm client")
+ hc.logger.Debug("Inside helm client")
// Create temporary file to hold helm chart
file, err := os.Create(chartPath + "temp.tar.gz")
actionConfig := new(action.Configuration)
if err := actionConfig.Init(kube.GetConfig(hc.kubeconfig, "", releaseNamespace), releaseNamespace,
os.Getenv("HELM_DRIVER"), func(format string, v ...interface{}) {
- fmt.Sprintf(format, v)
+ fmt.Sprintf(format, v)
}); err != nil {
hc.logger.Errorf("Unable to initialize action config Err: %s", err)
return "", err
- }
+ }
// Prepare chart install action and install chart
installer := action.NewInstall(actionConfig)
actionConfig := new(action.Configuration)
if err := actionConfig.Init(kube.GetConfig(hc.kubeconfig, "", releaseNamespace), releaseNamespace,
os.Getenv("HELM_DRIVER"), func(format string, v ...interface{}) {
- fmt.Sprintf(format, v)
+ fmt.Sprintf(format, v)
}); err != nil {
hc.logger.Errorf("Unable to initialize action config Err: %s", err)
return err
- }
+ }
ui := action.NewUninstall(actionConfig)
res, err := ui.Run(relName);
actionConfig := new(action.Configuration)
if err := actionConfig.Init(kube.GetConfig(hc.kubeconfig, "", releaseNamespace), releaseNamespace,
os.Getenv("HELM_DRIVER"), func(format string, v ...interface{}) {
- fmt.Sprintf(format, v)
- }); err != nil {
+ fmt.Sprintf(format, v)
+ }); err != nil {
hc.logger.Errorf("Unable to initialize action config Err: %s", err)
return "", err
}
return false, err
}
return !info.IsDir(), nil
-}
-
+}
\ No newline at end of file