in pkg/ebpf/events/events.go [81:108]
func setupCW(logger logr.Logger) error {
awsCloudConfig := aws.CloudConfig{}
fs := pflag.NewFlagSet("", pflag.ExitOnError)
awsCloudConfig.BindFlags(fs)
cloud, err := aws.NewCloud(awsCloudConfig)
if err != nil {
logger.Error(err, "unable to initialize AWS cloud session for Cloudwatch logs")
return err
}
cwl = cloud.CloudWatchLogs()
clusterName := cloud.ClusterName()
customlogGroupName := EKS_CW_PATH + clusterName + "/cluster"
if clusterName == utils.DEFAULT_CLUSTER_NAME {
customlogGroupName = NON_EKS_CW_PATH + clusterName + "/cluster"
}
logger.Info("Setup CW", "Setting loggroup Name", customlogGroupName)
err = ensureLogGroupExists(customlogGroupName)
if err != nil {
logger.Error(err, "unable to validate log group presence. Please check IAM permissions")
return err
}
logGroupName = customlogGroupName
return nil
}