Create aws log group and stream when not existing, and add flag for r…

…egion

cmd/main.go

@@ -12,6 +12,8 @@ var unitFileName = flag.String("unit", "", "(required) systemd unit name")
 var logGroup = flag.String("log-group", "", "(required) cloudwatch log group name")
 var logStream = flag.String("log-stream", "", "cloudwatch log stream name, defaults to hostname")
 
+var awsRegion = flag.String("aws-region", "us-west-2", "aws region name")
+
 var logBufferLimit = flag.Int("log-buffer", 10, "log buffer max limit before forward to CloudWatch")
 var timeoutSeconds = flag.Int("buffer-time", 5, "log buffer max time in seconds to foward to cloudwatch regardless of buffer size")
 var help = flag.Bool("h", false, "print help")
@@ -38,6 +40,7 @@ func main() {
 		LogGroupName:  *logGroup,
 		LogStreamName: *logStream,
 		Unit:          *unitFileName,
+		Region:        *awsRegion,
 	}
 	jw := journalwatch.New(c)
 

journalwatch/journalwatch.go

@@ -67,6 +67,14 @@ func (jw *JournalWatch) Start() error {
 
 	jw.cw = cloudwatchlogs.New(sess)
 
+	jw.cw.CreateLogGroup(&cloudwatchlogs.CreateLogGroupInput{
+		LogGroupName: &jw.config.LogGroupName,
+	})
+	jw.cw.CreateLogStream(&cloudwatchlogs.CreateLogStreamInput{
+		LogGroupName:  &jw.config.LogGroupName,
+		LogStreamName: &jw.config.LogStreamName,
+	})
+
 	logChan := make(chan *cloudwatchlogs.InputLogEvent)
 	defer close(logChan)