Reserve proto definition and generated code

pkg/sdkserver/localsdk.go

@@ -216,6 +216,12 @@ func (l *LocalSDKServer) WatchGameServer(_ *sdk.Empty, stream sdk.SDK_WatchGameS
 	return nil
 }
 
+// Reserve moves this GameServer to the Reserved state for the Duration specified
+func (l *LocalSDKServer) Reserve(_ context.Context, d *sdk.Duration) (*sdk.Empty, error) {
+	logrus.WithField("duration", d).Info("Reserve request has been received!")
+	return &sdk.Empty{}, nil
+}
+
 // Close tears down all the things
 func (l *LocalSDKServer) Close() {
 	l.updateObservers.Range(func(observer, _ interface{}) bool {

pkg/sdkserver/sdkserver.go

@@ -465,6 +465,12 @@ func (s *SDKServer) WatchGameServer(_ *sdk.Empty, stream sdk.SDK_WatchGameServer
 	return nil
 }
 
+// Reserve moves this GameServer to the Reserved state for the Duration specified
+// TODO: implement this functionality
+func (s *SDKServer) Reserve(_ context.Context, d *sdk.Duration) (*sdk.Empty, error) {
+	return &sdk.Empty{}, errors.New("not implemented")
+}
+
 // sendGameServerUpdate sends a watch game server event
 func (s *SDKServer) sendGameServerUpdate(gs *stablev1alpha1.GameServer) {
 	s.logger.Info("Sending GameServer Event to connectedStreams")

sdk.proto

@@ -79,6 +79,14 @@ service SDK {
 			body: "*"
 		};
     }
+
+    // Marks the GameServer as the Reserved state for Duration
+    rpc Reserve(Duration) returns (Empty) {
+        option (google.api.http) = {
+            post: "/reserve"
+            body: "*"
+        };
+    }
 }
 
 // I am Empty
@@ -91,6 +99,11 @@ message KeyValue {
     string value = 2;
 }
 
+// time duration, in seconds
+message Duration {
+    int64 seconds = 1;
+}
+
 // A GameServer Custom Resource Definition object
 // We will only export those resources that make the most
 // sense. Can always expand to more as needed.

sdk.swagger.json

@@ -167,6 +167,33 @@
         ]
       }
     },
+    "/reserve": {
+      "post": {
+        "summary": "Marks the GameServer as the Reserved state for Duration",
+        "operationId": "Reserve",
+        "responses": {
+          "200": {
+            "description": "",
+            "schema": {
+              "$ref": "#/definitions/sdkEmpty"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "body",
+            "in": "body",
+            "required": true,
+            "schema": {
+              "$ref": "#/definitions/sdkDuration"
+            }
+          }
+        ],
+        "tags": [
+          "SDK"
+        ]
+      }
+    },
     "/shutdown": {
       "post": {
         "summary": "Call when the GameServer is shutting down",
@@ -315,6 +342,16 @@
         }
       }
     },
+    "sdkDuration": {
+      "type": "object",
+      "properties": {
+        "seconds": {
+          "type": "string",
+          "format": "int64"
+        }
+      },
+      "title": "time duration, in seconds"
+    },
     "sdkEmpty": {
       "type": "object",
       "title": "I am Empty"