-
Notifications
You must be signed in to change notification settings - Fork 140
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
recorded password in the file /etc/redis_password
- Loading branch information
Showing
10 changed files
with
194 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -19,6 +19,7 @@ rules: | |
| - "" | ||
| resources: | ||
| - configmaps | ||
| - pods/exec | ||
| - secrets | ||
| - services | ||
| - events | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -19,6 +19,7 @@ rules: | |
| - "" | ||
| resources: | ||
| - configmaps | ||
| - pods/exec | ||
| - secrets | ||
| - services | ||
| - events | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,129 @@ | ||
| package exec | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "io" | ||
| "net/url" | ||
| "strings" | ||
|
|
||
| "github.com/go-logr/logr" | ||
| corev1 "k8s.io/api/core/v1" | ||
| "k8s.io/client-go/kubernetes/scheme" | ||
| "k8s.io/client-go/rest" | ||
| "k8s.io/client-go/tools/remotecommand" | ||
| ) | ||
|
|
||
| // IExec is an injectable interface for running remote exec commands. | ||
| type IExec interface { | ||
| // ExecCommandInPodSet exec cmd in pod set. | ||
| ExecCommandInPodSet(podSet []*corev1.Pod, cmd ...string) error | ||
| } | ||
|
|
||
| type remoteExec struct { | ||
| restGVKClient rest.Interface | ||
| logger logr.Logger | ||
| config *rest.Config | ||
| } | ||
|
|
||
| // NewRemoteExec returns a new IExec which will exec remote cmd. | ||
| func NewRemoteExec(restGVKClient rest.Interface, config *rest.Config, logger logr.Logger) IExec { | ||
| return &remoteExec{ | ||
| restGVKClient: restGVKClient, | ||
| logger: logger, | ||
| config: config, | ||
| } | ||
| } | ||
|
|
||
| // ExecOptions passed to ExecWithOptions. | ||
| type ExecOptions struct { | ||
| Command []string | ||
|
|
||
| Namespace string | ||
| PodName string | ||
| ContainerName string | ||
|
|
||
| Stdin io.Reader | ||
| CaptureStdout bool | ||
| CaptureStderr bool | ||
| // If false, whitespace in std{err,out} will be removed. | ||
| PreserveWhitespace bool | ||
| } | ||
|
|
||
| // ExecCommandInPodSet implements IExec interface. | ||
| func (e *remoteExec) ExecCommandInPodSet(podSet []*corev1.Pod, cmd ...string) error { | ||
| for _, pod := range podSet { | ||
| if _, err := e.ExecCommandInContainer(pod.Namespace, pod.Name, pod.Spec.Containers[0].Name, cmd...); err != nil { | ||
| return err | ||
| } | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| // ExecCommandInContainer executes a command in the specified container. | ||
| func (e *remoteExec) ExecCommandInContainer(namespace, podName, containerName string, cmd ...string) (string, error) { | ||
| stdout, stderr, err := e.ExecCommandInContainerWithFullOutput(namespace, podName, containerName, cmd...) | ||
| if stderr != "" { | ||
| e.logger.Info("ExecCommand", "command", cmd, "stderr", stderr) | ||
| } | ||
| return stdout, err | ||
| } | ||
|
|
||
| // ExecCommandInContainerWithFullOutput executes a command in the | ||
| // specified container and return stdout, stderr and error | ||
| func (e *remoteExec) ExecCommandInContainerWithFullOutput(namespace, podName, containerName string, cmd ...string) (string, string, error) { | ||
| return e.ExecWithOptions(ExecOptions{ | ||
| Command: cmd, | ||
| Namespace: namespace, | ||
| PodName: podName, | ||
| ContainerName: containerName, | ||
|
|
||
| Stdin: nil, | ||
| CaptureStdout: true, | ||
| CaptureStderr: true, | ||
| PreserveWhitespace: false, | ||
| }) | ||
| } | ||
|
|
||
| // ExecWithOptions executes a command in the specified container, | ||
| // returning stdout, stderr and error. `options` allowed for | ||
| // additional parameters to be passed. | ||
| func (e *remoteExec) ExecWithOptions(options ExecOptions) (string, string, error) { | ||
| const tty = false | ||
|
|
||
| req := e.restGVKClient.Post(). | ||
| Resource("pods"). | ||
| Name(options.PodName). | ||
| Namespace(options.Namespace). | ||
| SubResource("exec"). | ||
| Param("container", options.ContainerName) | ||
|
|
||
| req.VersionedParams(&corev1.PodExecOptions{ | ||
| Container: options.ContainerName, | ||
| Command: options.Command, | ||
| Stdin: options.Stdin != nil, | ||
| Stdout: options.CaptureStdout, | ||
| Stderr: options.CaptureStderr, | ||
| TTY: tty, | ||
| }, scheme.ParameterCodec) | ||
|
|
||
| var stdout, stderr bytes.Buffer | ||
| err := execute("POST", req.URL(), e.config, options.Stdin, &stdout, &stderr, tty) | ||
|
|
||
| if options.PreserveWhitespace { | ||
| return stdout.String(), stderr.String(), err | ||
| } | ||
| return strings.TrimSpace(stdout.String()), strings.TrimSpace(stderr.String()), err | ||
| } | ||
|
|
||
| func execute(method string, url *url.URL, config *rest.Config, stdin io.Reader, stdout, stderr io.Writer, tty bool) error { | ||
| exec, err := remotecommand.NewSPDYExecutor(config, method, url) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| return exec.Stream(remotecommand.StreamOptions{ | ||
| Stdin: stdin, | ||
| Stdout: stdout, | ||
| Stderr: stderr, | ||
| Tty: tty, | ||
| }) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters