release: 0.11.3

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.11.2"
+  ".": "0.11.3"
 }

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 50
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-d3a597bbbb25c131e2c06eb9b47d70932d14a97a6f916677a195a128e196f4db.yml
-openapi_spec_hash: c967b384624017eed0abff1b53a74530
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-5ee2116982adf46664acf84b8ba4b56ba65780983506c63d9b005dab49def757.yml
+openapi_spec_hash: 42a3a519301d0e2bb2b5a71018915b55
 config_hash: 0d150b61cae2dc57d3648ceae7784966

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## 0.11.3 (2025-09-24)
+
+Full Changelog: [v0.11.2...v0.11.3](https://github.com/onkernel/kernel-go-sdk/compare/v0.11.2...v0.11.3)
+
+### Features
+
+* Per Invocation Logs ([f1241f2](https://github.com/onkernel/kernel-go-sdk/commit/f1241f2d66a097bfb11a2cbd9fda9495b54b0690))
+
 ## 0.11.2 (2025-09-24)
 
 Full Changelog: [v0.11.1...v0.11.2](https://github.com/onkernel/kernel-go-sdk/compare/v0.11.1...v0.11.2)

README.md

@@ -28,7 +28,7 @@ Or to pin the version:
 <!-- x-release-please-start-version -->
 
 ```sh
-go get -u 'github.com/onkernel/kernel-go-sdk@v0.11.2'
+go get -u 'github.com/onkernel/kernel-go-sdk@v0.11.3'
 ```
 
 <!-- x-release-please-end -->

api.md

@@ -50,7 +50,7 @@ Methods:
 - <code title="get /invocations/{id}">client.Invocations.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationService.Get">Get</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>) (<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationGetResponse">InvocationGetResponse</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
 - <code title="patch /invocations/{id}">client.Invocations.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationService.Update">Update</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>, body <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationUpdateParams">InvocationUpdateParams</a>) (<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationUpdateResponse">InvocationUpdateResponse</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
 - <code title="delete /invocations/{id}/browsers">client.Invocations.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationService.DeleteBrowsers">DeleteBrowsers</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>) <a href="https://pkg.go.dev/builtin#error">error</a></code>
-- <code title="get /invocations/{id}/events">client.Invocations.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationService.Follow">Follow</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>) (<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationFollowResponseUnion">InvocationFollowResponseUnion</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
+- <code title="get /invocations/{id}/events">client.Invocations.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationService.Follow">Follow</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>, query <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationFollowParams">InvocationFollowParams</a>) (<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#InvocationFollowResponseUnion">InvocationFollowResponseUnion</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
 
 # Browsers
 

internal/version.go

@@ -2,4 +2,4 @@
 
 package internal
 
-const PackageVersion = "0.11.2" // x-release-please-version
+const PackageVersion = "0.11.3" // x-release-please-version

invocation.go

@@ -8,10 +8,12 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"net/url"
 	"slices"
 	"time"
 
 	"github.com/onkernel/kernel-go-sdk/internal/apijson"
+	"github.com/onkernel/kernel-go-sdk/internal/apiquery"
 	"github.com/onkernel/kernel-go-sdk/internal/requestconfig"
 	"github.com/onkernel/kernel-go-sdk/option"
 	"github.com/onkernel/kernel-go-sdk/packages/param"
@@ -89,7 +91,7 @@ func (r *InvocationService) DeleteBrowsers(ctx context.Context, id string, opts
 // Establishes a Server-Sent Events (SSE) stream that delivers real-time logs and
 // status updates for an invocation. The stream terminates automatically once the
 // invocation reaches a terminal state.
-func (r *InvocationService) FollowStreaming(ctx context.Context, id string, opts ...option.RequestOption) (stream *ssestream.Stream[InvocationFollowResponseUnion]) {
+func (r *InvocationService) FollowStreaming(ctx context.Context, id string, query InvocationFollowParams, opts ...option.RequestOption) (stream *ssestream.Stream[InvocationFollowResponseUnion]) {
 	var (
 		raw *http.Response
 		err error
@@ -101,7 +103,7 @@ func (r *InvocationService) FollowStreaming(ctx context.Context, id string, opts
 		return
 	}
 	path := fmt.Sprintf("invocations/%s/events", id)
-	err = requestconfig.ExecuteNewRequest(ctx, http.MethodGet, path, nil, &raw, opts...)
+	err = requestconfig.ExecuteNewRequest(ctx, http.MethodGet, path, query, &raw, opts...)
 	return ssestream.NewStream[InvocationFollowResponseUnion](ssestream.NewDecoder(raw), err)
 }
 
@@ -460,3 +462,17 @@ const (
 	InvocationUpdateParamsStatusSucceeded InvocationUpdateParamsStatus = "succeeded"
 	InvocationUpdateParamsStatusFailed    InvocationUpdateParamsStatus = "failed"
 )
+
+type InvocationFollowParams struct {
+	// Show logs since the given time (RFC timestamps or durations like 5m).
+	Since param.Opt[string] `query:"since,omitzero" json:"-"`
+	paramObj
+}
+
+// URLQuery serializes [InvocationFollowParams]'s query parameters as `url.Values`.
+func (r InvocationFollowParams) URLQuery() (v url.Values, err error) {
+	return apiquery.MarshalWithSettings(r, apiquery.QuerySettings{
+		ArrayFormat:  apiquery.ArrayQueryFormatComma,
+		NestedFormat: apiquery.NestedQueryFormatBrackets,
+	})
+}