(ctx context.Context, container containerd.Container)
| 184 | } |
| 185 | |
| 186 | func getLogPath(ctx context.Context, container containerd.Container) (string, error) { |
| 187 | extensions, err := container.Extensions(ctx) |
| 188 | if err != nil { |
| 189 | return "", fmt.Errorf("get extensions for container %s,failed: %#v", container.ID(), err) |
| 190 | } |
| 191 | metaData := extensions[k8slabels.ContainerMetadataExtension] |
| 192 | var meta cri.ContainerMetadata |
| 193 | if metaData != nil { |
| 194 | err = meta.UnmarshalJSON(metaData.GetValue()) |
| 195 | if err != nil { |
| 196 | return "", fmt.Errorf("unmarshal extensions for container %s,failed: %#v", container.ID(), err) |
| 197 | } |
| 198 | } |
| 199 | |
| 200 | return meta.LogPath, nil |
| 201 | } |
| 202 | |
| 203 | func getContainerEnvs(ctx context.Context, container containerd.Container) (map[string]string, error) { |
| 204 | envMap := make(map[string]string) |
no test coverage detected
searching dependent graphs…