リトライ間隔を指定できるようにする

config.go

@@ -27,6 +27,9 @@ const (
 
 	// 100ms
 	DefaultTimeToWaitForOpusPacketMs = 100
+
+	// リトライ間隔 100ms
+	DefaultRetryIntervalMs = 100
 )
 
 type Config struct {
@@ -46,7 +49,8 @@ type Config struct {
 	HTTP2MaxReadFrameSize     uint32 `ini:"http2_max_read_frame_size"`
 	HTTP2IdleTimeout          uint32 `ini:"http2_idle_timeout"`
 
-	MaxRetry int `ini:"max_retry"`
+	MaxRetry        int `ini:"max_retry"`
+	RetryIntervalMs int `ini:"retry_interval_ms"`
 
 	ExporterHTTPS      bool   `ini:"exporter_https"`
 	ExporterListenAddr string `ini:"exporter_listen_addr"`
@@ -159,6 +163,10 @@ func setDefaultsConfig(config *Config) {
 	if config.TimeToWaitForOpusPacketMs == 0 {
 		config.TimeToWaitForOpusPacketMs = DefaultTimeToWaitForOpusPacketMs
 	}
+
+	if config.RetryIntervalMs == 0 {
+		config.RetryIntervalMs = DefaultRetryIntervalMs
+	}
 }
 
 func validateConfig(config *Config) error {
@@ -209,4 +217,5 @@ func ShowConfig(config *Config) {
 	zlog.Info().Int("exporter_listen_port", config.ExporterListenPort).Msg("CONF")
 
 	zlog.Info().Int("max_retry", config.MaxRetry).Msg("CONF")
+	zlog.Info().Int("retry_interval_ms", config.RetryIntervalMs).Msg("CONF")
 }

config_example.ini

@@ -46,6 +46,8 @@ dump_file = ./dump.jsonl
 
 # サーバからの切断時またはハンドラー個別で指定した条件でのリトライ回数を指定します
 max_retry = 0
+# リトライ間隔（ミリ秒）です
+retry_interval_ms = 100
 
 # aws の場合は IsPartial が false, gcp の場合は IsFinal が true の場合の最終的な結果のみを返す指定
 final_result_only = true

handler.go

@@ -154,6 +154,9 @@ func (s *Server) createSpeechHandler(serviceType string, onResultFunc func(conte
 								Int("retry_count", retryCount).
 								Send()
 
+							// 連続のリトライを避けるために少し待つ
+							time.Sleep(time.Duration(s.config.RetryIntervalMs) * time.Millisecond)
+
 							// リトライ対象のエラーのため、クライアントとの接続は切らずにリトライする
 							continue
 						}
@@ -194,6 +197,9 @@ func (s *Server) createSpeechHandler(serviceType string, onResultFunc func(conte
 								Str("connection_id", h.SoraConnectionID).
 								Int("retry_count", retryCount).
 								Send()
+
+							// TODO: 必要な場合は連続のリトライを避けるために少し待つ処理を追加する
+
 							break
 						} else {
 							// サーバから切断されたが再接続させない設定の場合