Merge pull request #1744 from cloudwego/release-v0.13.0

chore: release v0.13.0

Author: DMwangnima

.codecov.yml

@@ -0,0 +1,2 @@
+ignore:
+  - "tool/**/*.go"

.github/workflows/pr-check.yml

@@ -14,7 +14,7 @@ jobs:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Check Spell
-        uses: crate-ci/typos@v1.13.14
+        uses: crate-ci/typos@master
 
   golangci-lint:
     runs-on: [ Linux, X64 ]

.github/workflows/tests.yml

@@ -10,15 +10,15 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.23"
+          go-version: "1.24"
           cache: false
       - name: Scenario Tests
         run: |
           cd ..
           rm -rf kitex-tests
-          git clone https://github.com/cloudwego/kitex-tests.git
-          cd kitex-tests
-          ./run.sh ${{github.workspace}}
+          git clone --depth=1 https://github.com/cloudwego/kitex-tests.git
+          cd kitex-tests 
+          KITEX_TOOL_USE_PROTOC=0 ./run.sh ${{github.workspace}}
           cd ${{github.workspace}}
       - name: Upload coverage to Codecov # coverage generated by run.sh
         uses: codecov/codecov-action@v5
@@ -33,7 +33,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.23"
+          go-version: "1.24"
       - name: Benchmark
         # we only use this CI to verify bench code works
         # setting benchtime=100ms is saving our time...
@@ -42,7 +42,7 @@ jobs:
   unit-test-x64:
     strategy:
       matrix:
-        go: [ "1.18", "1.19", "1.20", "1.21", "1.22", "1.23" ]
+        go: [ "1.19", "1.20", "1.21", "1.22", "1.23", "1.24" ]
     runs-on: [ Linux, X64 ]
     steps:
       - uses: actions/checkout@v4
@@ -57,7 +57,7 @@ jobs:
   unit-test-arm:
     strategy:
       matrix:
-        go: [ "1.18", "1.19", "1.20", "1.21", "1.22", "1.23" ]
+        go: [ "1.19", "1.20", "1.21", "1.22", "1.23", "1.24" ]
     runs-on: [ ARM64 ] # It's OK under Linux or macOS
     steps:
       - uses: actions/checkout@v4
@@ -76,7 +76,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.23"
+          go-version: "1.24"
       - name: Prepare
         run: |  
           go install github.com/cloudwego/thriftgo@main
@@ -105,7 +105,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.23"
+          go-version: "1.24"
           cache: false # don't use cache for self-hosted runners
       - name: Windows compatibility test
         run: go test -run=^$ ./...
@@ -118,7 +118,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.23"
+          go-version: "1.24"
           cache: false # don't use cache for self-hosted runners
       - name: Run coverage
         run: go test -race -coverprofile=coverage.out -covermode=atomic ./...

.typos.toml

@@ -0,0 +1,12 @@
+# Typo check: https://github.com/crate-ci/typos
+
+[files]
+extend-exclude = ["go.mod", "go.sum"]
+
+[default.extend-words]
+typ = "typ"   # type
+Descritor = "Descritor" # reflect pkg typo, exported func, let it go
+
+[default.extend-identifiers]
+GoAways = "GoAways" # GoAway frame plural noun
+henc = "henc" # hpack encoder

_typos.toml

@@ -47,6 +47,7 @@ type CallOptions struct {
 	RetryPolicy    retry.Policy
 	Fallback       *fallback.Policy
 	CompressorName string
+	StreamOptions  client.StreamOptions
 }
 
 func newOptions() interface{} {

client/callopt/options.go

@@ -17,6 +17,7 @@
 package streamcall
 
 import (
+	"strings"
 	"time"
 
 	"github.com/cloudwego/kitex/client/callopt"
@@ -45,3 +46,15 @@ func WithConnectTimeout(d time.Duration) Option {
 func WithTag(key, val string) Option {
 	return ConvertOptionFrom(callopt.WithTag(key, val))
 }
+
+// WithRecvTimeout add recv timeout for stream.Recv function.
+// NOTICE: ONLY effective for ttheader streaming protocol for now.
+func WithRecvTimeout(d time.Duration) Option {
+	return Option{f: func(o *callopt.CallOptions, di *strings.Builder) {
+		di.WriteString("WithRecvTimeout(")
+		di.WriteString(d.String())
+		di.WriteString(")")
+
+		o.StreamOptions.RecvTimeout = d
+	}}
+}

client/callopt/streamcall/call_options.go

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2025 CloudWeGo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package streamcall
+
+import (
+	"strings"
+	"testing"
+	"time"
+
+	"github.com/cloudwego/kitex/client/callopt"
+	"github.com/cloudwego/kitex/internal/test"
+)
+
+func TestWithRecvTimeout(t *testing.T) {
+	var sb strings.Builder
+	callOpts := callopt.CallOptions{}
+	testTimeout := 1 * time.Second
+	WithRecvTimeout(testTimeout).f(&callOpts, &sb)
+	test.Assert(t, callOpts.StreamOptions.RecvTimeout == testTimeout)
+	test.Assert(t, sb.String() == "WithRecvTimeout(1s)")
+}