d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Add LogType and Metadata for Log Analytics

Browse Source
This commit is contained in:
robbiezhang
2018-09-04 04:43:57 +00:00
committed by Robbie Zhang
parent b41c1fee1a
commit 844d8a71d0
2 changed files with 39 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
providers/azure/aci.go
View File

@@ -220,6 +220,16 @@ func NewACIProvider(config string, rm *manager.ResourceManager, nodeName, operat
}
}
if clusterResourceID := os.Getenv("CLUSTER_RESOURCE_ID"); clusterResourceID != "" {
if p.diagnostics != nil && p.diagnostics.LogAnalytics != nil {
p.diagnostics.LogAnalytics.LogType = aci.LogAnlyticsLogTypeContainerInsights
p.diagnostics.LogAnalytics.Metadata = map[string]string{
aci.LogAnalyticsMetadataKeyClusterResourceID: clusterResourceID,
aci.LogAnalyticsMetadataKeyNodeName: nodeName,
}
}
}
if rg := os.Getenv("ACI_RESOURCE_GROUP"); rg != "" {
p.resourceGroup = rg
}
@@ -654,6 +664,15 @@ func formDNSSearchFitsLimits(searches []string) string {
return strings.Join(searches, " ")
}
func (p *ACIProvider) getDiagnostics(pod *v1.Pod) *aci.ContainerGroupDiagnostics {
if p.diagnostics != nil && p.diagnostics.LogAnalytics != nil && p.diagnostics.LogAnalytics.LogType == aci.LogAnlyticsLogTypeContainerInsights {
d := *p.diagnostics
d.LogAnalytics.Metadata[aci.LogAnalyticsMetadataKeyPodUUID] = string(pod.ObjectMeta.UID)
return &d
}
return p.diagnostics
}
func containerGroupName(pod *v1.Pod) string {
return fmt.Sprintf("%s-%s", pod.Namespace, pod.Name)
}