in args.go [125:155]
func getAWSLogsArgs() (*awslogs.Args, error) {
group, err := getRequiredValue(awslogs.GroupKey)
if err != nil {
return nil, err
}
region, err := getRequiredValue(awslogs.RegionKey)
if err != nil {
return nil, err
}
stream, err := getRequiredValue(awslogs.StreamKey)
if err != nil {
return nil, err
}
credentialsEndpoint, err := getRequiredValue(awslogs.CredentialsEndpointKey)
if err != nil {
return nil, err
}
return &awslogs.Args{
Group: group,
Region: region,
Stream: stream,
CredentialsEndpoint: credentialsEndpoint,
CreateGroup: viper.GetString(awslogs.CreateGroupKey),
CreateStream: viper.GetString(awslogs.CreateStreamKey),
MultilinePattern: viper.GetString(awslogs.MultilinePatternKey),
DatetimeFormat: viper.GetString(awslogs.DatetimeFormatKey),
Endpoint: viper.GetString(awslogs.EndpointKey),
LogsFormatHeader: viper.GetString(awslogs.LogFormatKey),
}, nil
}