Add consistent locking around mock EC2 tags

cloudmock/aws/mockec2/tags.go

@@ -76,6 +76,10 @@ func (m *MockEC2) addTags(resourceId string, tags ...*ec2.Tag) {
 	} else {
 		klog.Fatalf("Unknown resource-type in create tags: %v", resourceId)
 	}
+
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
 	for _, tag := range tags {
 		t := &ec2.TagDescription{
 			Key:          tag.Key,
@@ -96,6 +100,9 @@ func (m *MockEC2) DescribeTagsWithContext(aws.Context, *ec2.DescribeTagsInput, .
 }
 
 func (m *MockEC2) hasTag(resourceType string, resourceId string, filter *ec2.Filter) bool {
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
 	name := *filter.Name
 	if strings.HasPrefix(name, "tag:") {
 		tagKey := name[4:]
@@ -138,6 +145,9 @@ func (m *MockEC2) hasTag(resourceType string, resourceId string, filter *ec2.Fil
 }
 
 func (m *MockEC2) getTags(resourceType string, resourceId string) []*ec2.Tag {
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
 	var tags []*ec2.Tag
 	for _, tag := range m.Tags {
 		if *tag.ResourceId != resourceId {