util

Documentation

Index

• Constants
• func AddFixedTailConfig(input map[string]interface{})
• func GetClusterNameFromEc2Tagger() string
• func GetECSClusterName(sectionKey string, input map[string]interface{}) string
• func GetEKSClusterName(sectionKey string, input map[string]interface{}) string
• func GetFileStateFolder() (fileStateFolder string)
• func ValidateLogRetentionSettings(logConfigs []interface{}, currPath string) []interface{}

Constants

const (
	Data_Format_Key     = "data_format"
	Data_Format_Value   = "value"
	Data_Type_Key       = "data_type"
	Data_Type_Value     = "string"
	Name_Override_Key   = "name_override"
	Name_Override_Value = "raw_log_line"
)

const (
	EKSClusterNameTagKeyPrefix = "kubernetes.io/cluster/"
)

const File_State_Folder_Linux = "/opt/aws/amazon-cloudwatch-agent/logs/state"

Functions

func AddFixedTailConfig

func AddFixedTailConfig(input map[string]interface{})

func GetClusterNameFromEc2Tagger

func GetClusterNameFromEc2Tagger() string

func GetECSClusterName

func GetECSClusterName(sectionKey string, input map[string]interface{}) string

func GetEKSClusterName

func GetEKSClusterName(sectionKey string, input map[string]interface{}) string

For ASG case, the ec2 tag may be not ready as soon as the node is started up. In this case, the translator will fail and then the pod will restart.

func GetFileStateFolder

func GetFileStateFolder() (fileStateFolder string)

func ValidateLogRetentionSettings

func ValidateLogRetentionSettings(logConfigs []interface{}, currPath string) []interface{}