mirror of https://github.com/docker/cli.git
commit
fe93451cf7
|
@ -215,7 +215,7 @@ func execCreateWithID(_ string, _ types.ExecConfig) (types.IDResponse, error) {
|
||||||
|
|
||||||
func TestGetExecExitStatus(t *testing.T) {
|
func TestGetExecExitStatus(t *testing.T) {
|
||||||
execID := "the exec id"
|
execID := "the exec id"
|
||||||
expecatedErr := errors.New("unexpected error")
|
expectedErr := errors.New("unexpected error")
|
||||||
|
|
||||||
testcases := []struct {
|
testcases := []struct {
|
||||||
inspectError error
|
inspectError error
|
||||||
|
@ -227,8 +227,8 @@ func TestGetExecExitStatus(t *testing.T) {
|
||||||
exitCode: 0,
|
exitCode: 0,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
inspectError: expecatedErr,
|
inspectError: expectedErr,
|
||||||
expectedError: expecatedErr,
|
expectedError: expectedErr,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
exitCode: 15,
|
exitCode: 15,
|
||||||
|
|
|
@ -1278,7 +1278,7 @@ func TestUpdateCredSpec(t *testing.T) {
|
||||||
spec: &swarm.ContainerSpec{},
|
spec: &swarm.ContainerSpec{},
|
||||||
expected: nil,
|
expected: nil,
|
||||||
}, {
|
}, {
|
||||||
name: "add a config credenital spec",
|
name: "add a config credential spec",
|
||||||
flagVal: "config://someConfigName",
|
flagVal: "config://someConfigName",
|
||||||
spec: &swarm.ContainerSpec{
|
spec: &swarm.ContainerSpec{
|
||||||
Configs: []*swarm.ConfigReference{
|
Configs: []*swarm.ConfigReference{
|
||||||
|
|
|
@ -27,13 +27,13 @@ type podListWatch interface {
|
||||||
Watch(opts metav1.ListOptions) (watch.Interface, error)
|
Watch(opts metav1.ListOptions) (watch.Interface, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
// DeployWatcher watches a stack deployement
|
// DeployWatcher watches a stack deployment
|
||||||
type deployWatcher struct {
|
type deployWatcher struct {
|
||||||
pods podListWatch
|
pods podListWatch
|
||||||
stacks stackListWatch
|
stacks stackListWatch
|
||||||
}
|
}
|
||||||
|
|
||||||
// Watch watches a stuck deployement and return a chan that will holds the state of the stack
|
// Watch watches a stuck deployment and return a chan that will holds the state of the stack
|
||||||
func (w *deployWatcher) Watch(name string, serviceNames []string, statusUpdates chan serviceStatus) error {
|
func (w *deployWatcher) Watch(name string, serviceNames []string, statusUpdates chan serviceStatus) error {
|
||||||
errC := make(chan error, 1)
|
errC := make(chan error, 1)
|
||||||
defer close(errC)
|
defer close(errC)
|
||||||
|
|
Loading…
Reference in New Issue