Skip to content

Commit

Permalink
fix: select containers by labels
Browse files Browse the repository at this point in the history
Signed-off-by: tiny-x <[email protected]>
  • Loading branch information
tiny-x committed Jun 24, 2022
1 parent 351feed commit 684a953
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions exec/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,8 @@ func ConvertContainerOutputToResponse(output string, err error, defaultResponse

// GetContainer return container by container flag, such as container id or container name.
func GetContainer(ctx context.Context, client container.Container, uid string, containerId, containerName string, containerLabelSelector map[string]string) (container.ContainerInfo, *spec.Response) {
if containerId == "" && containerName == "" {
tips := fmt.Sprintf("%s or %s", ContainerIdFlag.Name, ContainerNameFlag.Name, ContainerLabelSelectorFlag.Name)
if containerId == "" && containerName == "" && len(containerLabelSelector) == 0 {
tips := fmt.Sprintf("%s or %s or %s", ContainerIdFlag.Name, ContainerNameFlag.Name, ContainerLabelSelectorFlag.Name)
log.Errorf(ctx, spec.ParameterLess.Sprintf(tips))
return container.ContainerInfo{}, spec.ResponseFailWithFlags(spec.ParameterLess, tips)
}
Expand Down
2 changes: 1 addition & 1 deletion exec/executor_common_linux.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ func (r *CommonExecutor) Exec(uid string, ctx context.Context, expModel *spec.Ex
}
containerId := expModel.ActionFlags[ContainerIdFlag.Name]
containerName := expModel.ActionFlags[ContainerNameFlag.Name]
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerNameFlag.Name])
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerLabelSelectorFlag.Name])
container, response := GetContainer(ctx, r.Client, uid, containerId, containerName, containerLabelSelector)
if !response.Success {
return response
Expand Down
2 changes: 1 addition & 1 deletion exec/executor_execin.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ func (r *RunCmdInContainerExecutorByCP) Exec(uid string, ctx context.Context, ex
}
containerId := expModel.ActionFlags[ContainerIdFlag.Name]
containerName := expModel.ActionFlags[ContainerNameFlag.Name]
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerNameFlag.Name])
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerLabelSelectorFlag.Name])
container, response := GetContainer(ctx, r.Client, uid, containerId, containerName, containerLabelSelector)
if !response.Success {
return response
Expand Down
2 changes: 1 addition & 1 deletion exec/executor_network.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ func (r *NetworkExecutor) Exec(uid string, ctx context.Context, expModel *spec.E
}
containerId := expModel.ActionFlags[ContainerIdFlag.Name]
containerName := expModel.ActionFlags[ContainerNameFlag.Name]
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerNameFlag.Name])
containerLabelSelector := parseContainerLabelSelector(expModel.ActionFlags[ContainerLabelSelectorFlag.Name])
container, response := GetContainer(ctx, r.Client, uid, containerId, containerName, containerLabelSelector)
if !response.Success {
return response
Expand Down

0 comments on commit 684a953

Please sign in to comment.