Skip to content

Commit

Permalink
compose: support blkio_config
Browse files Browse the repository at this point in the history
Signed-off-by: Akihiro Suda <[email protected]>
  • Loading branch information
AkihiroSuda committed Nov 12, 2021
1 parent d51a10c commit 3ab0ffd
Showing 1 changed file with 13 additions and 0 deletions.
13 changes: 13 additions & 0 deletions pkg/composer/serviceparser/serviceparser.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ func warnUnknownFields(svc compose.ServiceConfig) {
if unknown := reflectutil.UnknownNonEmptyFields(&svc,
"Name",
"Build",
"BlkioConfig",
"CapAdd",
"CapDrop",
"CPUS",
Expand Down Expand Up @@ -81,6 +82,14 @@ func warnUnknownFields(svc compose.ServiceConfig) {
logrus.Warnf("Ignoring: service %s: %+v", svc.Name, unknown)
}

if svc.BlkioConfig != nil {
if unknown := reflectutil.UnknownNonEmptyFields(svc.BlkioConfig,
"Weight",
); len(unknown) > 0 {
logrus.Warnf("Ignoring: service %s: blkio_config: %+v", svc.Name, unknown)
}
}

for depName, dep := range svc.DependsOn {
if unknown := reflectutil.UnknownNonEmptyFields(&dep,
"Condition",
Expand Down Expand Up @@ -418,6 +427,10 @@ func newContainer(project *compose.Project, parsed *Service, i int) (*Container,
"--pull=never", // because image will be ensured before running replicas with `nerdctl run`.
}

if svc.BlkioConfig != nil && svc.BlkioConfig.Weight != 0 {
c.RunArgs = append(c.RunArgs, fmt.Sprintf("--blkio-weight=%d", svc.BlkioConfig.Weight))
}

for _, v := range svc.CapAdd {
c.RunArgs = append(c.RunArgs, fmt.Sprintf("--cap-add=%s", v))
}
Expand Down

0 comments on commit 3ab0ffd

Please sign in to comment.