Adding DynamoDB Resource For Creation

**Why:**

* allows you to create a dynamodb table via a CRD

**This change addresses the need by:**

* closes #6

Signed-off-by: Christopher Hein <[email protected]>

Author: christopherhein

examples/dynamodb.yaml

@@ -0,0 +1,14 @@
+apiVersion: operator.aws/v1alpha1
+kind: DynamoDB
+metadata:
+  name: dynamodb-table
+spec:
+  tableName: dynamodb-table
+  hashAttribute:
+    name: user_id
+    type: S
+  rangeAttribute:
+    name: created_at
+    type: S
+  readCapacityUnits: 5
+  writeCapacityUnits: 5

models/dynamodb.yaml

@@ -0,0 +1,95 @@
+apiVersion: operator.aws/v1alpha1
+kind: ModelDefinition
+metadata:
+  name: DynamoDBResource
+spec:
+  kind: DynamoDB
+  type: Spec # can be Spec or Data
+  queue: true
+  useCloudFormation: true
+  resource:
+    name: dynamodb
+    plural: dynamodbs
+    shortNames:
+    - name: ddb
+    - name: ddbs
+    - name: dynamo
+    - name: dynamotable
+    - name: dynamotables
+  body:
+    schema:
+      title: DynamoDB
+      type: object
+      properties:
+      - key: tableName
+        type: string
+        description: |
+          TableName is the name of the DynamoDB Table to be created.
+        structKey: TableName
+        templateKey: TableName
+      - key: rangeAttribute
+        type: object
+        description: |
+          RangeAttribute is the configuration for the range attribute.
+        structKey: RangeAttribute
+        templateKey: RangeAttribute
+        properties:
+        - key: Name
+          type: string
+          description: |
+            Name is the name of the range attribute on the table.
+          structKey: Name
+          templateKey: RangeAttributeName
+        - key: Type
+          type: string
+          description: |
+            Type is the kind of range attribute that should be used.
+          structKey: Type
+          templateKey: RangeAttributeType
+      - key: readCapacityUnits
+        type: int
+        description: |
+          ReadCapacityUnits specifies the read capacity of the table.
+        structKey: ReadCapacityUnits
+        templateKey: ReadCapacityUnits
+      - key: writeCapacityUnits
+        type: int
+        description: |
+          WriteCapacityUnits specifies the write capacity of the table.
+        structKey: WriteCapacityUnits
+        templateKey: WriteCapacityUnits
+      - key: hashAttribute
+        type: object
+        description: |
+          HashAttribute is the configuration for the hash attribute on the table.
+        structKey: HashAttribute
+        templateKey: HashAttribute
+        properties:
+        - key: Name
+          type: string
+          description: |
+            Name is the name of the hashing attribute on the table.
+          structKey: Name
+          templateKey: HashAttributeName
+        - key: Type
+          type: string
+          description: |
+            Type is the kind of hash attribute that should be used.
+          structKey: Type
+          templateKey: HashAttributeType
+  output:
+    schema:
+      type: object
+      properties:
+      - key: tableName
+        type: string
+        description: |
+          TableName is the output tablename incase it changed
+        structKey: TableName
+        templateKey: TableName
+      - key: tableARN
+        type: string
+        description: |
+          TableARN is the full Amazon ARN for the table created
+        structKey: TableARN
+        templateKey: TableArn

pkg/server/server.go

@@ -10,6 +10,7 @@ import (
 	awsclient "github.com/christopherhein/aws-operator/pkg/client/clientset/versioned/typed/operator.aws/v1alpha1"
 	"github.com/christopherhein/aws-operator/pkg/config"
 	"github.com/christopherhein/aws-operator/pkg/operator/cloudformationtemplate"
+	"github.com/christopherhein/aws-operator/pkg/operator/dynamodb"
 	"github.com/christopherhein/aws-operator/pkg/operator/s3bucket"
 	opkit "github.com/christopherhein/operator-kit"
 	"k8s.io/api/core/v1"
@@ -44,6 +45,7 @@ func (c *Server) Run(stopChan chan struct{}) {
 	resources := []opkit.CustomResource{
 		cloudformationtemplate.Resource,
 		s3bucket.Resource,
+		dynamodb.Resource,
 	}
 	err = opkit.CreateCustomResources(*context, resources)
 	if err != nil {
@@ -81,6 +83,9 @@ func (c *Server) Run(stopChan chan struct{}) {
 
 	s3controller := s3bucket.NewController(config, context, awsClientset)
 	s3controller.StartWatch(v1.NamespaceAll, stopChan)
+
+	ddbcontroller := dynamodb.NewController(config, context, awsClientset)
+	ddbcontroller.StartWatch(v1.NamespaceAll, stopChan)
 }
 
 func getClientConfig(kubeconfig string) (*rest.Config, error) {