move exec method from separate file to the utils;
move regexps to the utils
This commit is contained in:
		
							parent
							
								
									e0dacd0ca9
								
							
						
					
					
						commit
						7abba86274
					
				|  | @ -7,7 +7,6 @@ import ( | ||||||
| 	"encoding/json" | 	"encoding/json" | ||||||
| 	"fmt" | 	"fmt" | ||||||
| 	"reflect" | 	"reflect" | ||||||
| 	"regexp" |  | ||||||
| 	"sync" | 	"sync" | ||||||
| 
 | 
 | ||||||
| 	"github.com/Sirupsen/logrus" | 	"github.com/Sirupsen/logrus" | ||||||
|  | @ -29,11 +28,6 @@ import ( | ||||||
| 	"github.com/zalando-incubator/postgres-operator/pkg/util/volumes" | 	"github.com/zalando-incubator/postgres-operator/pkg/util/volumes" | ||||||
| ) | ) | ||||||
| 
 | 
 | ||||||
| var ( |  | ||||||
| 	alphaNumericRegexp = regexp.MustCompile("^[a-zA-Z][a-zA-Z0-9]*$") |  | ||||||
| 	userRegexp         = regexp.MustCompile(`^[a-z0-9]([-_a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-_a-z0-9]*[a-z0-9])?)*$`) |  | ||||||
| ) |  | ||||||
| 
 |  | ||||||
| // Config contains operator-wide clients and configuration used from a cluster. TODO: remove struct duplication.
 | // Config contains operator-wide clients and configuration used from a cluster. TODO: remove struct duplication.
 | ||||||
| type Config struct { | type Config struct { | ||||||
| 	KubeClient          *kubernetes.Clientset //TODO: move clients to the better place?
 | 	KubeClient          *kubernetes.Clientset //TODO: move clients to the better place?
 | ||||||
|  |  | ||||||
|  | @ -1,61 +0,0 @@ | ||||||
| package cluster |  | ||||||
| 
 |  | ||||||
| import ( |  | ||||||
| 	"bytes" |  | ||||||
| 	"fmt" |  | ||||||
| 
 |  | ||||||
| 	remotecommandconsts "k8s.io/apimachinery/pkg/util/remotecommand" |  | ||||||
| 	"k8s.io/client-go/pkg/api" |  | ||||||
| 	"k8s.io/kubernetes/pkg/client/unversioned/remotecommand" |  | ||||||
| 
 |  | ||||||
| 	"github.com/zalando-incubator/postgres-operator/pkg/spec" |  | ||||||
| ) |  | ||||||
| 
 |  | ||||||
| func (c *Cluster) ExecCommand(podName *spec.NamespacedName, command ...string) (string, error) { |  | ||||||
| 	var ( |  | ||||||
| 		execOut bytes.Buffer |  | ||||||
| 		execErr bytes.Buffer |  | ||||||
| 	) |  | ||||||
| 
 |  | ||||||
| 	pod, err := c.KubeClient.Pods(podName.Namespace).Get(podName.Name) |  | ||||||
| 	if err != nil { |  | ||||||
| 		return "", fmt.Errorf("could not get pod info: %v", err) |  | ||||||
| 	} |  | ||||||
| 
 |  | ||||||
| 	if len(pod.Spec.Containers) != 1 { |  | ||||||
| 		return "", fmt.Errorf("could not determine which container to use") |  | ||||||
| 	} |  | ||||||
| 
 |  | ||||||
| 	req := c.RestClient.Post(). |  | ||||||
| 		Resource("pods"). |  | ||||||
| 		Name(podName.Name). |  | ||||||
| 		Namespace(podName.Namespace). |  | ||||||
| 		SubResource("exec") |  | ||||||
| 	req.VersionedParams(&api.PodExecOptions{ |  | ||||||
| 		Container: pod.Spec.Containers[0].Name, |  | ||||||
| 		Command:   command, |  | ||||||
| 		Stdout:    true, |  | ||||||
| 		Stderr:    true, |  | ||||||
| 	}, api.ParameterCodec) |  | ||||||
| 
 |  | ||||||
| 	exec, err := remotecommand.NewExecutor(c.RestConfig, "POST", req.URL()) |  | ||||||
| 	if err != nil { |  | ||||||
| 		return "", fmt.Errorf("failed to init executor: %v", err) |  | ||||||
| 	} |  | ||||||
| 
 |  | ||||||
| 	err = exec.Stream(remotecommand.StreamOptions{ |  | ||||||
| 		SupportedProtocols: remotecommandconsts.SupportedStreamingProtocols, |  | ||||||
| 		Stdout:             &execOut, |  | ||||||
| 		Stderr:             &execErr, |  | ||||||
| 	}) |  | ||||||
| 
 |  | ||||||
| 	if err != nil { |  | ||||||
| 		return "", fmt.Errorf("could not execute: %v", err) |  | ||||||
| 	} |  | ||||||
| 
 |  | ||||||
| 	if execErr.Len() > 0 { |  | ||||||
| 		return "", fmt.Errorf("stderr: %v", execErr.String()) |  | ||||||
| 	} |  | ||||||
| 
 |  | ||||||
| 	return execOut.String(), nil |  | ||||||
| } |  | ||||||
|  | @ -1,14 +1,19 @@ | ||||||
| package cluster | package cluster | ||||||
| 
 | 
 | ||||||
| import ( | import ( | ||||||
|  | 	"bytes" | ||||||
| 	"encoding/json" | 	"encoding/json" | ||||||
| 	"fmt" | 	"fmt" | ||||||
| 	"strings" | 	"strings" | ||||||
|  | 	"regexp" | ||||||
| 	"time" | 	"time" | ||||||
| 
 | 
 | ||||||
| 	"k8s.io/client-go/pkg/api/v1" | 	"k8s.io/client-go/pkg/api/v1" | ||||||
| 	"k8s.io/client-go/pkg/apis/apps/v1beta1" | 	"k8s.io/client-go/pkg/apis/apps/v1beta1" | ||||||
| 	"k8s.io/client-go/pkg/labels" | 	"k8s.io/client-go/pkg/labels" | ||||||
|  | 	remotecommandconsts "k8s.io/apimachinery/pkg/util/remotecommand" | ||||||
|  | 	"k8s.io/client-go/pkg/api" | ||||||
|  | 	"k8s.io/kubernetes/pkg/client/unversioned/remotecommand" | ||||||
| 
 | 
 | ||||||
| 	"github.com/zalando-incubator/postgres-operator/pkg/spec" | 	"github.com/zalando-incubator/postgres-operator/pkg/spec" | ||||||
| 	"github.com/zalando-incubator/postgres-operator/pkg/util" | 	"github.com/zalando-incubator/postgres-operator/pkg/util" | ||||||
|  | @ -16,6 +21,11 @@ import ( | ||||||
| 	"github.com/zalando-incubator/postgres-operator/pkg/util/retryutil" | 	"github.com/zalando-incubator/postgres-operator/pkg/util/retryutil" | ||||||
| ) | ) | ||||||
| 
 | 
 | ||||||
|  | var ( | ||||||
|  | 	alphaNumericRegexp = regexp.MustCompile("^[a-zA-Z][a-zA-Z0-9]*$") | ||||||
|  | 	userRegexp         = regexp.MustCompile(`^[a-z0-9]([-_a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-_a-z0-9]*[a-z0-9])?)*$`) | ||||||
|  | ) | ||||||
|  | 
 | ||||||
| func isValidUsername(username string) bool { | func isValidUsername(username string) bool { | ||||||
| 	return userRegexp.MatchString(username) | 	return userRegexp.MatchString(username) | ||||||
| } | } | ||||||
|  | @ -302,3 +312,52 @@ func (c *Cluster) credentialSecretName(username string) string { | ||||||
| func (c *Cluster) podSpiloRole(pod *v1.Pod) string { | func (c *Cluster) podSpiloRole(pod *v1.Pod) string { | ||||||
| 	return pod.Labels[c.OpConfig.PodRoleLabel] | 	return pod.Labels[c.OpConfig.PodRoleLabel] | ||||||
| } | } | ||||||
|  | 
 | ||||||
|  | func (c *Cluster) ExecCommand(podName *spec.NamespacedName, command ...string) (string, error) { | ||||||
|  | 	var ( | ||||||
|  | 		execOut bytes.Buffer | ||||||
|  | 		execErr bytes.Buffer | ||||||
|  | 	) | ||||||
|  | 
 | ||||||
|  | 	pod, err := c.KubeClient.Pods(podName.Namespace).Get(podName.Name) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return "", fmt.Errorf("could not get pod info: %v", err) | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	if len(pod.Spec.Containers) != 1 { | ||||||
|  | 		return "", fmt.Errorf("could not determine which container to use") | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	req := c.RestClient.Post(). | ||||||
|  | 		Resource("pods"). | ||||||
|  | 		Name(podName.Name). | ||||||
|  | 		Namespace(podName.Namespace). | ||||||
|  | 		SubResource("exec") | ||||||
|  | 	req.VersionedParams(&api.PodExecOptions{ | ||||||
|  | 		Container: pod.Spec.Containers[0].Name, | ||||||
|  | 		Command:   command, | ||||||
|  | 		Stdout:    true, | ||||||
|  | 		Stderr:    true, | ||||||
|  | 	}, api.ParameterCodec) | ||||||
|  | 
 | ||||||
|  | 	exec, err := remotecommand.NewExecutor(c.RestConfig, "POST", req.URL()) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return "", fmt.Errorf("failed to init executor: %v", err) | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	err = exec.Stream(remotecommand.StreamOptions{ | ||||||
|  | 		SupportedProtocols: remotecommandconsts.SupportedStreamingProtocols, | ||||||
|  | 		Stdout:             &execOut, | ||||||
|  | 		Stderr:             &execErr, | ||||||
|  | 	}) | ||||||
|  | 
 | ||||||
|  | 	if err != nil { | ||||||
|  | 		return "", fmt.Errorf("could not execute: %v", err) | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	if execErr.Len() > 0 { | ||||||
|  | 		return "", fmt.Errorf("stderr: %v", execErr.String()) | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	return execOut.String(), nil | ||||||
|  | } | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue