@@ -10,6 +10,10 @@ import (
10
10
"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"
11
11
)
12
12
13
+ const (
14
+ EVENTS = "events"
15
+ )
16
+
13
17
type DynamoDBLayer struct {
14
18
service * dynamodb.DynamoDB
15
19
}
@@ -38,7 +42,7 @@ func (dynamoLayer *DynamoDBLayer) AddEvent(event persistence.Event) ([]byte, err
38
42
return nil , err
39
43
}
40
44
_ , err = dynamoLayer .service .PutItem (& dynamodb.PutItemInput {
41
- TableName : aws .String ("events" ),
45
+ TableName : aws .String (EVENTS ),
42
46
Item : av ,
43
47
})
44
48
if err != nil {
@@ -55,7 +59,7 @@ func (dynamoLayer *DynamoDBLayer) FindEvent(id []byte) (persistence.Event, error
55
59
B : id ,
56
60
},
57
61
},
58
- TableName : aws .String ("events" ),
62
+ TableName : aws .String (EVENTS ),
59
63
}
60
64
//Get the item via the GetItem method
61
65
result , err := dynamoLayer .service .GetItem (input )
@@ -78,7 +82,7 @@ func (dynamoLayer *DynamoDBLayer) FindEventByName(name string) (persistence.Even
78
82
},
79
83
},
80
84
IndexName : aws .String ("EventName-index" ),
81
- TableName : aws .String ("events" ),
85
+ TableName : aws .String (EVENTS ),
82
86
}
83
87
// Execute the query
84
88
result , err := dynamoLayer .service .Query (input )
@@ -98,7 +102,7 @@ func (dynamoLayer *DynamoDBLayer) FindEventByName(name string) (persistence.Even
98
102
func (dynamoLayer * DynamoDBLayer ) FindAllAvailableEvents () ([]persistence.Event , error ) {
99
103
// Create the ScanInput object with the table name
100
104
input := & dynamodb.ScanInput {
101
- TableName : aws .String ("events" ),
105
+ TableName : aws .String (EVENTS ),
102
106
}
103
107
// Perform the scan operation
104
108
result , err := dynamoLayer .service .Scan (input )
0 commit comments