feat(config): add poke strategy

Author: ngoc-minh-do

README.md

@@ -75,6 +75,17 @@ You can load a JSON configuration such as:
 }
 ```
 
+Or use the poke strategy to start instances without waiting:
+
+```json
+{ 
+    "sablier_url": "sablier:10000", 
+    "group": "my-group", 
+    "session_duration": "1m", 
+    "poke": {}
+}
+```
+
 ## Examples
 
 ### Apache APISIX

main.go

@@ -91,6 +91,9 @@ type BlockingConfiguration struct {
 	Timeout string `json:"timeout"`
 }
 
+type PokeConfiguration struct {
+}
+
 type Config struct {
 	// SablierURL in the format of hostname:port. The scheme is excluded
 	SablierURL string `json:"sablier_url"`
@@ -105,6 +108,7 @@ type Config struct {
 	SessionDuration string                 `json:"session_duration"`
 	Dynamic         *DynamicConfiguration  `json:"dynamic"`
 	Blocking        *BlockingConfiguration `json:"blocking"`
+	Poke            *PokeConfiguration     `json:"poke"`
 }
 
 func (c Config) GetPath() string {
@@ -133,6 +137,8 @@ func (c Config) GetPath() string {
 		return c.getDynamicQuery(path)
 	} else if c.Blocking != nil {
 		return c.getBlockingQuery(path)
+	} else if c.Poke != nil {
+		return c.getPokeQuery(path)
 	}
 	return "no strategy configured"
 }
@@ -183,6 +189,12 @@ func (c Config) getBlockingQuery(path url.URL) string {
 	return path.String()
 }
 
+func (c Config) getPokeQuery(path url.URL) string {
+	path.Path = "/api/strategies/poke"
+
+	return path.String()
+}
+
 func parsePluginConfiguration(data []byte) (pluginConfiguration, error) {
 	pluginConf := newPluginConfiguration()
 	if len(data) == 0 {
@@ -196,11 +208,20 @@ func parsePluginConfiguration(data []byte) (pluginConfiguration, error) {
 		return pluginConf, err
 	}
 
-	if c.Blocking == nil && c.Dynamic == nil {
-		return pluginConf, fmt.Errorf("you must specify one strategy (dynamic or blocking)")
+	strategyCount := 0
+	if c.Blocking != nil {
+		strategyCount++
 	}
-
-	if c.Blocking != nil && c.Dynamic != nil {
+	if c.Dynamic != nil {
+		strategyCount++
+	}
+	if c.Poke != nil {
+		strategyCount++
+	}
+	if strategyCount == 0 {
+		return pluginConf, fmt.Errorf("you must specify one strategy (dynamic, blocking or poke)")
+	}
+	if strategyCount > 1 {
 		return pluginConf, fmt.Errorf("you must specify only one strategy")
 	}
 

main_test.go

@@ -9,6 +9,27 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
+func TestUnmarshalPoke(t *testing.T) {
+	data := `{
+		"sablier_url": "sablier",
+		"group": "demo",
+		"session_duration": "30s",
+		"poke": {}
+	}`
+
+	config, err := parsePluginConfiguration([]byte(data))
+	if err != nil {
+		t.Error(err)
+	}
+
+	expected := "/api/strategies/poke?group=demo&session_duration=30s"
+	if config.path != expected {
+		t.Errorf("path = %v, want %v", config.path, expected)
+	}
+
+	t.Log("path:", config.path)
+}
+
 func TestUnmarshal(t *testing.T) {
 	data := `{
 		"sablier_url": "sablier",