parseKVStringsMapFromLogOpt parse log options KV entries and convert to Map
(logOpt []string, logDriver string)
| 689 | |
| 690 | // parseKVStringsMapFromLogOpt parse log options KV entries and convert to Map |
| 691 | func parseKVStringsMapFromLogOpt(logOpt []string, logDriver string) (map[string]string, error) { |
| 692 | logOptArray := strutil.DedupeStrSlice(logOpt) |
| 693 | logOptMap := strutil.ConvertKVStringsToMap(logOptArray) |
| 694 | if logDriver == "json-file" { |
| 695 | if _, ok := logOptMap[logging.MaxSize]; !ok { |
| 696 | delete(logOptMap, logging.MaxFile) |
| 697 | } |
| 698 | } |
| 699 | if err := logging.ValidateLogOpts(logDriver, logOptMap); err != nil { |
| 700 | return nil, err |
| 701 | } |
| 702 | return logOptMap, nil |
| 703 | } |
| 704 | |
| 705 | func withStop(stopSignal string, stopTimeout int, ensuredImage *imgutil.EnsuredImage) containerd.NewContainerOpts { |
| 706 | return func(ctx context.Context, _ *containerd.Client, c *containers.Container) error { |
no test coverage detected
searching dependent graphs…