Github/temporal
1
0
Fork 0
mirror of https://github.com/temporalio/temporal.git synced 2026-08-30 18:41:49 -07:00
Code Issues Packages Projects Releases Wiki Activity

Update Go SDK to v1.26.0-rc.2 (#5396)

Browse Source 
## What changed?
Update Go SDK to v1.26.0-rc.2

## Why?
Use a tagged Go SDK for the server release

---------

Co-authored-by: Roey Berman <roey@temporal.io>
This commit is contained in:
Quinn Klassen
2024-02-21 12:54:18 -08:00
committed by GitHub
parent 3532e3551b
commit 0d6536f547
15 changed files with 366 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
client/frontend/client_gen.go
View File

@@ -313,6 +313,16 @@ func (c *clientImpl) PollActivityTaskQueue(
return c.client.PollActivityTaskQueue(ctx, request, opts...)
}
func (c *clientImpl) PollNexusTaskQueue(
ctx context.Context,
request *workflowservice.PollNexusTaskQueueRequest,
opts ...grpc.CallOption,
) (*workflowservice.PollNexusTaskQueueResponse, error) {
ctx, cancel := c.createContext(ctx)
defer cancel()
return c.client.PollNexusTaskQueue(ctx, request, opts...)
}
func (c *clientImpl) PollWorkflowExecutionUpdate(
ctx context.Context,
request *workflowservice.PollWorkflowExecutionUpdateRequest,
@@ -463,6 +473,26 @@ func (c *clientImpl) RespondActivityTaskFailedById(
return c.client.RespondActivityTaskFailedById(ctx, request, opts...)
}
func (c *clientImpl) RespondNexusTaskCompleted(
ctx context.Context,
request *workflowservice.RespondNexusTaskCompletedRequest,
opts ...grpc.CallOption,
) (*workflowservice.RespondNexusTaskCompletedResponse, error) {
ctx, cancel := c.createContext(ctx)
defer cancel()
return c.client.RespondNexusTaskCompleted(ctx, request, opts...)
}
func (c *clientImpl) RespondNexusTaskFailed(
ctx context.Context,
request *workflowservice.RespondNexusTaskFailedRequest,
opts ...grpc.CallOption,
) (*workflowservice.RespondNexusTaskFailedResponse, error) {
ctx, cancel := c.createContext(ctx)
defer cancel()
return c.client.RespondNexusTaskFailed(ctx, request, opts...)
}
func (c *clientImpl) RespondQueryTaskCompleted(
ctx context.Context,
request *workflowservice.RespondQueryTaskCompletedRequest,

42
client/frontend/metric_client_gen.go
View File

@@ -425,6 +425,20 @@ func (c *metricClient) PollActivityTaskQueue(
return c.client.PollActivityTaskQueue(ctx, request, opts...)
}
func (c *metricClient) PollNexusTaskQueue(
ctx context.Context,
request *workflowservice.PollNexusTaskQueueRequest,
opts ...grpc.CallOption,
) (_ *workflowservice.PollNexusTaskQueueResponse, retError error) {
metricsHandler, startTime := c.startMetricsRecording(ctx, "FrontendClientPollNexusTaskQueue")
defer func() {
c.finishMetricsRecording(metricsHandler, startTime, retError)
}()
return c.client.PollNexusTaskQueue(ctx, request, opts...)
}
func (c *metricClient) PollWorkflowExecutionUpdate(
ctx context.Context,
request *workflowservice.PollWorkflowExecutionUpdateRequest,
@@ -635,6 +649,34 @@ func (c *metricClient) RespondActivityTaskFailedById(
return c.client.RespondActivityTaskFailedById(ctx, request, opts...)
}
func (c *metricClient) RespondNexusTaskCompleted(
ctx context.Context,
request *workflowservice.RespondNexusTaskCompletedRequest,
opts ...grpc.CallOption,
) (_ *workflowservice.RespondNexusTaskCompletedResponse, retError error) {
metricsHandler, startTime := c.startMetricsRecording(ctx, "FrontendClientRespondNexusTaskCompleted")
defer func() {
c.finishMetricsRecording(metricsHandler, startTime, retError)
}()
return c.client.RespondNexusTaskCompleted(ctx, request, opts...)
}
func (c *metricClient) RespondNexusTaskFailed(
ctx context.Context,
request *workflowservice.RespondNexusTaskFailedRequest,
opts ...grpc.CallOption,
) (_ *workflowservice.RespondNexusTaskFailedResponse, retError error) {
metricsHandler, startTime := c.startMetricsRecording(ctx, "FrontendClientRespondNexusTaskFailed")
defer func() {
c.finishMetricsRecording(metricsHandler, startTime, retError)
}()
return c.client.RespondNexusTaskFailed(ctx, request, opts...)
}
func (c *metricClient) RespondQueryTaskCompleted(
ctx context.Context,
request *workflowservice.RespondQueryTaskCompletedRequest,

45
client/frontend/retryable_client_gen.go
View File

@@ -455,6 +455,21 @@ func (c *retryableClient) PollActivityTaskQueue(
return resp, err
}
func (c *retryableClient) PollNexusTaskQueue(
ctx context.Context,
request *workflowservice.PollNexusTaskQueueRequest,
opts ...grpc.CallOption,
) (*workflowservice.PollNexusTaskQueueResponse, error) {
var resp *workflowservice.PollNexusTaskQueueResponse
op := func(ctx context.Context) error {
var err error
resp, err = c.client.PollNexusTaskQueue(ctx, request, opts...)
return err
}
err := backoff.ThrottleRetryContext(ctx, op, c.policy, c.isRetryable)
return resp, err
}
func (c *retryableClient) PollWorkflowExecutionUpdate(
ctx context.Context,
request *workflowservice.PollWorkflowExecutionUpdateRequest,
@@ -680,6 +695,36 @@ func (c *retryableClient) RespondActivityTaskFailedById(
return resp, err
}
func (c *retryableClient) RespondNexusTaskCompleted(
ctx context.Context,
request *workflowservice.RespondNexusTaskCompletedRequest,
opts ...grpc.CallOption,
) (*workflowservice.RespondNexusTaskCompletedResponse, error) {
var resp *workflowservice.RespondNexusTaskCompletedResponse
op := func(ctx context.Context) error {
var err error
resp, err = c.client.RespondNexusTaskCompleted(ctx, request, opts...)
return err
}
err := backoff.ThrottleRetryContext(ctx, op, c.policy, c.isRetryable)
return resp, err
}
func (c *retryableClient) RespondNexusTaskFailed(
ctx context.Context,
request *workflowservice.RespondNexusTaskFailedRequest,
opts ...grpc.CallOption,
) (*workflowservice.RespondNexusTaskFailedResponse, error) {
var resp *workflowservice.RespondNexusTaskFailedResponse
op := func(ctx context.Context) error {
var err error
resp, err = c.client.RespondNexusTaskFailed(ctx, request, opts...)
return err
}
err := backoff.ThrottleRetryContext(ctx, op, c.policy, c.isRetryable)
return resp, err
}
func (c *retryableClient) RespondQueryTaskCompleted(
ctx context.Context,
request *workflowservice.RespondQueryTaskCompletedRequest,

5
client/history/historytest/clienttest.go
View File

@@ -37,6 +37,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.opentelemetry.io/otel/trace"
"go.opentelemetry.io/otel/trace/embedded"
commonspb "go.temporal.io/server/api/common/v1"
"go.temporal.io/server/api/historyservice/v1"
"go.temporal.io/server/client/history"
@@ -52,7 +53,9 @@ import (
)
// fakeTracerProvider is needed to construct a [historyserver.Handler] object.
type fakeTracerProvider struct{}
type fakeTracerProvider struct {
embedded.TracerProvider
}
func (f fakeTracerProvider) Tracer(string, ...trace.TracerOption) trace.Tracer {
return nil

21
common/api/metadata.go
View File

@@ -129,15 +129,22 @@ var (
"StopBatchOperation": MethodMetadata{Scope: ScopeNamespace, Access: AccessWrite},
"DescribeBatchOperation": MethodMetadata{Scope: ScopeNamespace, Access: AccessReadOnly},
"ListBatchOperations": MethodMetadata{Scope: ScopeNamespace, Access: AccessReadOnly},
"PollNexusTaskQueue": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"RespondNexusTaskCompleted": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"RespondNexusTaskFailed": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
}
operatorServiceMetadata = map[string]MethodMetadata{
"AddSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"RemoveSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"ListSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessReadOnly},
"DeleteNamespace": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"AddOrUpdateRemoteCluster": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"RemoveRemoteCluster": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"ListClusters": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"AddSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"RemoveSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"ListSearchAttributes": MethodMetadata{Scope: ScopeNamespace, Access: AccessReadOnly},
"DeleteNamespace": MethodMetadata{Scope: ScopeNamespace, Access: AccessAdmin},
"AddOrUpdateRemoteCluster": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"RemoveRemoteCluster": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"ListClusters": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"CreateOrUpdateNexusIncomingService": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"DeleteNexusIncomingService": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"GetNexusIncomingService": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
"ListNexusIncomingServices": MethodMetadata{Scope: ScopeCluster, Access: AccessAdmin},
}
)

7
develop/buildkite/third_party_deps.txt
View File

@@ -8,7 +8,7 @@ cloud.google.com/go/internal/version
cloud.google.com/go/storage
cloud.google.com/go/storage/internal
cloud.google.com/go/storage/internal/apiv2
cloud.google.com/go/storage/internal/apiv2/stubs
cloud.google.com/go/storage/internal/apiv2/storagepb
github.com/apache/thrift/lib/go/thrift
github.com/aws/aws-sdk-go/aws
github.com/aws/aws-sdk-go/aws/arn
@@ -78,6 +78,7 @@ github.com/emirpasic/gods/trees/redblacktree
github.com/emirpasic/gods/utils
github.com/facebookgo/clock
github.com/fatih/color
github.com/felixge/httpsnoop
github.com/go-logr/logr
github.com/go-logr/logr/funcr
github.com/go-logr/stdr
@@ -265,6 +266,8 @@ go.opencensus.io/trace/propagation
go.opencensus.io/trace/tracestate
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc/internal
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp/internal/semconvutil
go.opentelemetry.io/otel
go.opentelemetry.io/otel/attribute
go.opentelemetry.io/otel/baggage
@@ -307,6 +310,8 @@ go.opentelemetry.io/otel/semconv/v1.10.0
go.opentelemetry.io/otel/semconv/v1.17.0
go.opentelemetry.io/otel/semconv/v1.21.0
go.opentelemetry.io/otel/trace
go.opentelemetry.io/otel/trace/embedded
go.opentelemetry.io/otel/trace/noop
go.opentelemetry.io/proto/otlp/collector/metrics/v1
go.opentelemetry.io/proto/otlp/collector/trace/v1
go.opentelemetry.io/proto/otlp/common/v1

40
go.mod
View File

@@ -3,7 +3,7 @@ module go.temporal.io/server
go 1.21
require (
cloud.google.com/go/storage v1.30.1
cloud.google.com/go/storage v1.36.0
github.com/aws/aws-sdk-go v1.44.289
github.com/blang/semver/v4 v4.0.0
github.com/cactus/go-statsd-client/v5 v5.0.0
@@ -16,7 +16,7 @@ require (
github.com/golang-jwt/jwt/v4 v4.5.0
github.com/golang/mock v1.7.0-rc.1
github.com/google/go-cmp v0.6.0
github.com/google/uuid v1.4.0
github.com/google/uuid v1.5.0
github.com/iancoleman/strcase v0.3.0
github.com/jmoiron/sqlx v1.3.4
github.com/lib/pq v1.10.9
@@ -33,16 +33,16 @@ require (
github.com/uber-go/tally/v4 v4.1.7
github.com/urfave/cli v1.22.14
github.com/urfave/cli/v2 v2.4.0
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.45.0
go.opentelemetry.io/otel v1.19.0
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.46.1
go.opentelemetry.io/otel v1.21.0
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.42.0
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.19.0
go.opentelemetry.io/otel/exporters/prometheus v0.42.0
go.opentelemetry.io/otel/metric v1.19.0
go.opentelemetry.io/otel/sdk v1.19.0
go.opentelemetry.io/otel/metric v1.21.0
go.opentelemetry.io/otel/sdk v1.21.0
go.opentelemetry.io/otel/sdk/metric v1.19.0
go.temporal.io/api v1.26.1-0.20240116230500-406a5810b501
go.temporal.io/sdk v1.25.2-0.20240123002209-94a5f5f81f98
go.temporal.io/api v1.27.0
go.temporal.io/sdk v1.26.0-rc.2
go.temporal.io/version v0.3.0
go.uber.org/atomic v1.11.0
go.uber.org/automaxprocs v1.5.2
@@ -50,11 +50,11 @@ require (
go.uber.org/multierr v1.11.0
go.uber.org/zap v1.26.0
golang.org/x/exp v0.0.0-20231127185646-65229373498e
golang.org/x/oauth2 v0.15.0
golang.org/x/oauth2 v0.16.0
golang.org/x/sync v0.5.0
golang.org/x/time v0.3.0
google.golang.org/api v0.149.0
google.golang.org/grpc v1.60.1
golang.org/x/time v0.5.0
google.golang.org/api v0.155.0
google.golang.org/grpc v1.61.0
google.golang.org/grpc/examples v0.0.0-20230623203957-0b3a81eabc28
gopkg.in/square/go-jose.v2 v2.6.0
gopkg.in/validator.v2 v2.0.1
@@ -63,13 +63,15 @@ require (
)
require (
github.com/felixge/httpsnoop v1.0.4 // indirect
github.com/gogo/protobuf v1.3.2 // indirect
github.com/jackc/pgpassfile v1.0.0 // indirect
github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 // indirect
)
require (
cloud.google.com/go v0.111.0 // indirect
cloud.google.com/go v0.112.0 // indirect
cloud.google.com/go/compute v1.23.3 // indirect
cloud.google.com/go/compute/metadata v0.2.3 // indirect
cloud.google.com/go/iam v1.1.5 // indirect
@@ -84,7 +86,7 @@ require (
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/dustin/go-humanize v1.0.1 // indirect
github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a // indirect
github.com/go-logr/logr v1.2.4 // indirect
github.com/go-logr/logr v1.3.0 // indirect
github.com/go-logr/stdr v1.2.2 // indirect
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
github.com/golang/protobuf v1.5.3 // indirect
@@ -93,7 +95,7 @@ require (
github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect
github.com/googleapis/gax-go/v2 v2.12.0 // indirect
github.com/grpc-ecosystem/go-grpc-middleware v1.4.0 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1
github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed // indirect
github.com/jackc/pgx/v5 v5.4.3
github.com/jmespath/go-jmespath v0.4.0 // indirect
@@ -123,7 +125,7 @@ require (
go.opencensus.io v0.24.0 // indirect
go.opentelemetry.io/otel/exporters/otlp/otlpmetric v0.42.0 // indirect
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.19.0 // indirect
go.opentelemetry.io/otel/trace v1.19.0
go.opentelemetry.io/otel/trace v1.21.0
go.opentelemetry.io/proto/otlp v1.0.0 // indirect
go.uber.org/dig v1.17.0 // indirect
golang.org/x/crypto v0.18.0 // indirect
@@ -133,9 +135,9 @@ require (
golang.org/x/text v0.14.0 // indirect
golang.org/x/tools v0.16.0 // indirect
google.golang.org/appengine v1.6.8 // indirect
google.golang.org/genproto v0.0.0-20240116215550-a9fa1716bcac // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac // indirect
google.golang.org/genproto v0.0.0-20240125205218-1f4bbc51befe // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe // indirect
google.golang.org/protobuf v1.32.0
gopkg.in/inf.v0 v0.9.1 // indirect
lukechampine.com/uint128 v1.3.0 // indirect

84
go.sum
View File

@@ -1,15 +1,15 @@
cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go v0.111.0 h1:YHLKNupSD1KqjDbQ3+LVdQ81h/UJbJyZG203cEfnQgM=
cloud.google.com/go v0.111.0/go.mod h1:0mibmpKP1TyOOFYQY5izo0LnT+ecvOQ0Sg3OdmMiNRU=
cloud.google.com/go v0.112.0 h1:tpFCD7hpHFlQ8yPwT3x+QeXqc2T6+n6T+hmABHfDUSM=
cloud.google.com/go v0.112.0/go.mod h1:3jEEVwZ/MHU4djK5t5RHuKOA/GbLddgTdVubX1qnPD4=
cloud.google.com/go/compute v1.23.3 h1:6sVlXXBmbd7jNX0Ipq0trII3e4n1/MsADLK6a+aiVlk=
cloud.google.com/go/compute v1.23.3/go.mod h1:VCgBUoMnIVIR0CscqQiPJLAG25E3ZRZMzcFZeQ+h8CI=
cloud.google.com/go/compute/metadata v0.2.3 h1:mg4jlk7mCAj6xXp9UJ4fjI9VUI5rubuGBW5aJ7UnBMY=
cloud.google.com/go/compute/metadata v0.2.3/go.mod h1:VAV5nSsACxMJvgaAuX6Pk2AawlZn8kiOGuCv6gTkwuA=
cloud.google.com/go/iam v1.1.5 h1:1jTsCu4bcsNsE4iiqNT5SHwrDRCfRmIaaaVFhRveTJI=
cloud.google.com/go/iam v1.1.5/go.mod h1:rB6P/Ic3mykPbFio+vo7403drjlgvoWfYpJhMXEbzv8=
cloud.google.com/go/storage v1.30.1 h1:uOdMxAs8HExqBlnLtnQyP0YkvbiDpdGShGKtx6U/oNM=
cloud.google.com/go/storage v1.30.1/go.mod h1:NfxhC0UJE1aXSx7CIIbCf7y9HKT7BiccwkR7+P7gN8E=
cloud.google.com/go/storage v1.36.0 h1:P0mOkAcaJxhCTvAkMhxMfrTKiNcub4YmmPBtlhAyTr8=
cloud.google.com/go/storage v1.36.0/go.mod h1:M6M/3V/D3KpzMTJyPOR/HU6n2Si5QdaXYEsng2xgOs8=
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
@@ -57,8 +57,8 @@ github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4 h1:/inchEIKaYC1Akx+H+gqO04wryn5h75LSazbRlnya1k=
github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
github.com/cncf/xds/go v0.0.0-20231109132714-523115ebc101 h1:7To3pQ+pZo0i3dsWEbinPNFs5gPSBOsJtx3wTT94VBY=
github.com/cncf/xds/go v0.0.0-20231109132714-523115ebc101/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
github.com/cpuguy83/go-md2man/v2 v2.0.1/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
github.com/cpuguy83/go-md2man/v2 v2.0.2 h1:p1EgwI/C7NhT0JmVkwCD2ZBK8j4aeHQX2pMHHBfMQ6w=
github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
@@ -84,6 +84,8 @@ github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a h1:yDWHCSQ40h88yi
github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a/go.mod h1:7Ga40egUymuWXxAe151lTNnCv97MddSOVsjpPPkityA=
github.com/fatih/color v1.15.0 h1:kOqh6YHBtK8aywxGerMG2Eq3H6Qgoqeo13Bk2Mv/nBs=
github.com/fatih/color v1.15.0/go.mod h1:0h5ZqXfHYED7Bhv2ZJamyIOUej9KtShiJESRwBDUSsw=
github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
github.com/fogleman/gg v1.2.1-0.20190220221249-0403632d5b90/go.mod h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=
github.com/fortytw2/leaktest v1.3.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g=
@@ -97,8 +99,8 @@ github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9
github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
github.com/go-logfmt/logfmt v0.5.0/go.mod h1:wCYkCAKZfumFQihp8CzCvQ3paCTfi41vtzG1KdI/P7A=
github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.2.4 h1:g01GSCwiDw2xSZfjJ2/T9M+S6pFdcNtFYsp+Y43HYDQ=
github.com/go-logr/logr v1.2.4/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.3.0 h1:2y3SDp0ZXuc6/cjLSZ+Q3ir+QB9T/iG5yYRXqsagWSY=
github.com/go-logr/logr v1.3.0/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
github.com/go-sql-driver/mysql v1.5.0 h1:ozyZYNQW3x3HtqT1jira07DN2PArx2v7/mN66gGcHOs=
@@ -159,16 +161,16 @@ github.com/google/s2a-go v0.1.7 h1:60BLSyTrOV4/haCDW4zb1guZItoSq8foHCXrAnjBo/o=
github.com/google/s2a-go v0.1.7/go.mod h1:50CgR4k1jNlWBu4UfS4AcfhVe1r6pdZPygJ3R8F0Qdw=
github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/google/uuid v1.4.0 h1:MtMxsa51/r9yyhkyLsVeVt0B+BGQZzpQiTQ4eHZ8bc4=
github.com/google/uuid v1.4.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU=
github.com/google/uuid v1.5.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/googleapis/enterprise-certificate-proxy v0.3.2 h1:Vie5ybvEvT75RniqhfFxPRy3Bf7vr3h0cechB90XaQs=
github.com/googleapis/enterprise-certificate-proxy v0.3.2/go.mod h1:VLSiSSBs/ksPL8kq3OBOQ6WRI2QnaFynd1DCjZ62+V0=
github.com/googleapis/gax-go/v2 v2.12.0 h1:A+gCJKdRfqXkr+BIRGtZLibNXf0m1f9E4HG56etFpas=
github.com/googleapis/gax-go/v2 v2.12.0/go.mod h1:y+aIqrI5eb1YGMVJfuV3185Ts/D7qKpsEkdD5+I6QGU=
github.com/grpc-ecosystem/go-grpc-middleware v1.4.0 h1:UH//fgunKIs4JdUbpDl1VZCDaL56wXCB/5+wF6uHfaI=
github.com/grpc-ecosystem/go-grpc-middleware v1.4.0/go.mod h1:g5qyo/la0ALbONm6Vbp88Yd8NsDy6rZz+RcrMPxvld8=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 h1:Wqo399gCIufwto+VfwCSvsnfGpF/w5E9CNxSwbpD6No=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0/go.mod h1:qmOFXW2epJhM0qSnUUYpldc7gVz2KMQwJ/QYCDIa7XU=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1 h1:/c3QmbOGMGTOumP2iT/rCwB7b0QDGLKzqOmktBjT+Is=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1/go.mod h1:5SN9VR2LTsRFsrEC6FHgRbTWrTHu6tqPeKxEQv15giM=
github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed h1:5upAirOpQc1Q53c0bnx2ufif5kANL7bfZWcc6VJWJd8=
github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed/go.mod h1:tMWxXQ9wFIaZeTI9F+hmhFiGpFmhOHzyShyFUhRm0H4=
github.com/iancoleman/strcase v0.3.0 h1:nTXanmYxhfFAMjZL34Ov6gkzEsSJZ5DbhxWjvSASxEI=
@@ -352,10 +354,12 @@ github.com/yuin/goldmark v1.4.1/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1
github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
go.opencensus.io v0.24.0 h1:y73uSU6J157QMP2kn2r30vwW1A2W2WFwSCGnAVxeaD0=
go.opencensus.io v0.24.0/go.mod h1:vNK8G9p7aAivkbmorf4v+7Hgx+Zs0yY+0fOtgBfjQKo=
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.45.0 h1:RsQi0qJ2imFfCvZabqzM9cNXBG8k6gXMv1A0cXRmH6A=
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.45.0/go.mod h1:vsh3ySueQCiKPxFLvjWC4Z135gIa34TQ/NSqkDTZYUM=
go.opentelemetry.io/otel v1.19.0 h1:MuS/TNf4/j4IXsZuJegVzI1cwut7Qc00344rgH7p8bs=
go.opentelemetry.io/otel v1.19.0/go.mod h1:i0QyjOq3UPoTzff0PJB2N66fb4S0+rSbSB15/oyH9fY=
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.46.1 h1:SpGay3w+nEwMpfVnbqOLH5gY52/foP8RE8UzTZ1pdSE=
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.46.1/go.mod h1:4UoMYEZOC0yN/sPGH76KPkkU7zgiEWYWL9vwmbnTJPE=
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 h1:aFJWCqJMNjENlcleuuOkGAPH82y0yULBScfXcIEdS24=
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1/go.mod h1:sEGXWArGqc3tVa+ekntsN65DmVbVeW+7lTKTjZF3/Fo=
go.opentelemetry.io/otel v1.21.0 h1:hzLeKBZEL7Okw2mGzZ0cc4k/A7Fta0uoPgaJCr8fsFc=
go.opentelemetry.io/otel v1.21.0/go.mod h1:QZzNPQPm1zLX4gZK4cMi+71eaorMSGT3A4znnUvNNEo=
go.opentelemetry.io/otel/exporters/otlp/otlpmetric v0.42.0 h1:ZtfnDL+tUrs1F0Pzfwbg2d59Gru9NCH3bgSHBM6LDwU=
go.opentelemetry.io/otel/exporters/otlp/otlpmetric v0.42.0/go.mod h1:hG4Fj/y8TR/tlEDREo8tWstl9fO9gcFkn4xrx0Io8xU=
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.42.0 h1:NmnYCiR0qNufkldjVvyQfZTHSdzeHoZ41zggMsdMcLM=
@@ -366,20 +370,20 @@ go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.19.0 h1:3d+S2
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.19.0/go.mod h1:0+KuTDyKL4gjKCF75pHOX4wuzYDUZYfAQdSu43o+Z2I=
go.opentelemetry.io/otel/exporters/prometheus v0.42.0 h1:jwV9iQdvp38fxXi8ZC+lNpxjK16MRcZlpDYvbuO1FiA=
go.opentelemetry.io/otel/exporters/prometheus v0.42.0/go.mod h1:f3bYiqNqhoPxkvI2LrXqQVC546K7BuRDL/kKuxkujhA=
go.opentelemetry.io/otel/metric v1.19.0 h1:aTzpGtV0ar9wlV4Sna9sdJyII5jTVJEvKETPiOKwvpE=
go.opentelemetry.io/otel/metric v1.19.0/go.mod h1:L5rUsV9kM1IxCj1MmSdS+JQAcVm319EUrDVLrt7jqt8=
go.opentelemetry.io/otel/sdk v1.19.0 h1:6USY6zH+L8uMH8L3t1enZPR3WFEmSTADlqldyHtJi3o=
go.opentelemetry.io/otel/sdk v1.19.0/go.mod h1:NedEbbS4w3C6zElbLdPJKOpJQOrGUJ+GfzpjUvI0v1A=
go.opentelemetry.io/otel/metric v1.21.0 h1:tlYWfeo+Bocx5kLEloTjbcDwBuELRrIFxwdQ36PlJu4=
go.opentelemetry.io/otel/metric v1.21.0/go.mod h1:o1p3CA8nNHW8j5yuQLdc1eeqEaPfzug24uvsyIEJRWM=
go.opentelemetry.io/otel/sdk v1.21.0 h1:FTt8qirL1EysG6sTQRZ5TokkU8d0ugCj8htOgThZXQ8=
go.opentelemetry.io/otel/sdk v1.21.0/go.mod h1:Nna6Yv7PWTdgJHVRD9hIYywQBRx7pbox6nwBnZIxl/E=
go.opentelemetry.io/otel/sdk/metric v1.19.0 h1:EJoTO5qysMsYCa+w4UghwFV/ptQgqSL/8Ni+hx+8i1k=
go.opentelemetry.io/otel/sdk/metric v1.19.0/go.mod h1:XjG0jQyFJrv2PbMvwND7LwCEhsJzCzV5210euduKcKY=
go.opentelemetry.io/otel/trace v1.19.0 h1:DFVQmlVbfVeOuBRrwdtaehRrWiL1JoVs9CPIQ1Dzxpg=
go.opentelemetry.io/otel/trace v1.19.0/go.mod h1:mfaSyvGyEJEI0nyV2I4qhNQnbBOUUmYZpYojqMnX2vo=
go.opentelemetry.io/otel/trace v1.21.0 h1:WD9i5gzvoUPuXIXH24ZNBudiarZDKuekPqi/E8fpfLc=
go.opentelemetry.io/otel/trace v1.21.0/go.mod h1:LGbsEB0f9LGjN+OZaQQ26sohbOmiMR+BaslueVtS/qQ=
go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lIVU/I=
go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM=
go.temporal.io/api v1.26.1-0.20240116230500-406a5810b501 h1:/Tgw/kjlhLmfaVeVu9JWpILEyEFXEXEl0qCmLuOB7uI=
go.temporal.io/api v1.26.1-0.20240116230500-406a5810b501/go.mod h1:ccaGRzYOx2iUq2e7zx0BEm0t2V3rmcliFalMCixn1/4=
go.temporal.io/sdk v1.25.2-0.20240123002209-94a5f5f81f98 h1:G7hB8PbjugdVgrOzKU9IKPDXs4KuWKpdIyAmaAlyJMk=
go.temporal.io/sdk v1.25.2-0.20240123002209-94a5f5f81f98/go.mod h1:6gMeKgOjvhE4AGnW4ukPfbOIj7rEK4En6Mk7iBrSQ34=
go.temporal.io/api v1.27.0 h1:M7a7p3A/gIKEMAYVBQD+/2hfzh/hC0410393TwD20Ko=
go.temporal.io/api v1.27.0/go.mod h1:iASB2zPPR+FtFKn5w7/hF7AG2dkvkW7TTMAqL06tz0g=
go.temporal.io/sdk v1.26.0-rc.2 h1:0NX4wR2qwD6xCv+JNhZdViamsITMYWzZkUqBJEIVHBw=
go.temporal.io/sdk v1.26.0-rc.2/go.mod h1:HDr8fIWJ/HF8dJwTPgOayI8PYB5WoVIxUMjzE78M2ng=
go.temporal.io/version v0.3.0 h1:dMrei9l9NyHt8nG6EB8vAwDLLTwx2SvRyucCSumAiig=
go.temporal.io/version v0.3.0/go.mod h1:UA9S8/1LaKYae6TyD9NaPMJTZb911JcbqghI2CBSP78=
go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
@@ -461,8 +465,8 @@ golang.org/x/net v0.20.0 h1:aCL9BSgETF1k+blQaYUBx9hJ9LOGP3gAVemcZlf1Kpo=
golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/oauth2 v0.15.0 h1:s8pnnxNVzjWyrvYdFUQq5llS1PX2zhPXmccZv99h7uQ=
golang.org/x/oauth2 v0.15.0/go.mod h1:q48ptWNTY5XWf+JNten23lcvHpLJ0ZSxF5ttTHKVCAM=
golang.org/x/oauth2 v0.16.0 h1:aDkGMBSYxElaoP81NpoUoz2oo2R2wHdZpGToUxfyQrQ=
golang.org/x/oauth2 v0.16.0/go.mod h1:hqZ+0LWXsiVoZpeld6jVt06P3adbS2Uu911W1SsJv2o=
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -522,8 +526,8 @@ golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
golang.org/x/time v0.3.0 h1:rg5rLMjNzMS1RkNLzCG38eapWhnYLFYXDXj2gOlr8j4=
golang.org/x/time v0.3.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk=
golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
golang.org/x/tools v0.0.0-20180525024113-a5b4c53f6e8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
@@ -554,8 +558,8 @@ gonum.org/v1/gonum v0.0.0-20180816165407-929014505bf4/go.mod h1:Y+Yx5eoAFn32cQvJ
gonum.org/v1/gonum v0.8.2/go.mod h1:oe/vMfY3deqTw+1EZJhuvEW2iwGF1bW9wwu7XCu0+v0=
gonum.org/v1/netlib v0.0.0-20190313105609-8cb42192e0e0/go.mod h1:wa6Ws7BG/ESfp6dHfk7C6KdzKA7wR7u/rKwOGE66zvw=
gonum.org/v1/plot v0.0.0-20190515093506-e2840ee46a6b/go.mod h1:Wt8AAjI+ypCyYX3nZBvf6cAIx93T+c/OS2HFAYskSZc=
google.golang.org/api v0.149.0 h1:b2CqT6kG+zqJIVKRQ3ELJVLN1PwHZ6DJ3dW8yl82rgY=
google.golang.org/api v0.149.0/go.mod h1:Mwn1B7JTXrzXtnvmzQE2BD6bYZQ8DShKZDZbeN9I7qI=
google.golang.org/api v0.155.0 h1:vBmGhCYs0djJttDNynWo44zosHlPvHmA0XiN2zP2DtA=
google.golang.org/api v0.155.0/go.mod h1:GI5qK5f40kCpHfPn6+YzGAByIKWv8ujFnmoWm7Igduk=
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/appengine v1.6.8 h1:IhEN5q69dyKagZPYMSdIjS2HqprW324FRQZJcGqPAsM=
@@ -564,20 +568,20 @@ google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoA
google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
google.golang.org/genproto v0.0.0-20200423170343-7949de9c1215/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
google.golang.org/genproto v0.0.0-20240116215550-a9fa1716bcac h1:ZL/Teoy/ZGnzyrqK/Optxxp2pmVh+fmJ97slxSRyzUg=
google.golang.org/genproto v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:+Rvu7ElI+aLzyDQhpHMFMMltsD6m7nqpuWDd2CwJw3k=
google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac h1:OZkkudMUu9LVQMCoRUbI/1p5VCo9BOrlvkqMvWtqa6s=
google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:B5xPO//w8qmBDjGReYLpR6UJPnkldGkCSMoH/2vxJeg=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac h1:nUQEQmH/csSvFECKYRv6HWEyypysidKl2I6Qpsglq/0=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:daQN87bsDqDoe316QbbvX60nMoJQa4r6Ds0ZuoAe5yA=
google.golang.org/genproto v0.0.0-20240125205218-1f4bbc51befe h1:USL2DhxfgRchafRvt/wYyyQNzwgL7ZiURcozOE/Pkvo=
google.golang.org/genproto v0.0.0-20240125205218-1f4bbc51befe/go.mod h1:cc8bqMqtv9gMOr0zHg2Vzff5ULhhL2IXP4sbcn32Dro=
google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe h1:0poefMBYvYbs7g5UkjS6HcxBPaTRAmznle9jnxYoAI8=
google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe/go.mod h1:4jWUdICTdgc3Ibxmr8nAJiiLHwQBY0UI0XZcEMaFKaA=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe h1:bQnxqljG/wqi4NTXu2+DJ3n7APcEA882QZ1JvhQAq9o=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe/go.mod h1:PAREbraiVEVGVdTZsVWjSbbTtSyGbAgIIvni8a8CD5s=
google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
google.golang.org/grpc v1.29.1/go.mod h1:itym6AZVZYACWQqET3MqgPpjcuV5QH3BxFS3IjizoKk=
google.golang.org/grpc v1.33.2/go.mod h1:JMHMWHQWaTccqQQlmk3MJZS+GWXOdAesneDmEnv2fbc=
google.golang.org/grpc v1.60.1 h1:26+wFr+cNqSGFcOXcabYC0lUVJVRa2Sb2ortSK7VrEU=
google.golang.org/grpc v1.60.1/go.mod h1:OlCHIeLYqSSsLi6i49B5QGdzaMZK9+M7LXN2FKz4eGM=
google.golang.org/grpc v1.61.0 h1:TOvOcuXn30kRao+gfcvsebNEa5iZIiLkisYEkf7R7o0=
google.golang.org/grpc v1.61.0/go.mod h1:VUbo7IFqmF1QtCAstipjG0GIoq49KvMe9+h1jFLBNJs=
google.golang.org/grpc/examples v0.0.0-20230623203957-0b3a81eabc28 h1:soFSbKG2H9FiKip4adXyJL8FEsA+wcFvu1YYMDcKKWY=
google.golang.org/grpc/examples v0.0.0-20230623203957-0b3a81eabc28/go.mod h1:CjEn68pJy4gCZyxDUQ9HNT0mQwZtbmMMHh5UrDl3Ozc=
google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=

5
service/frontend/configs/quotas.go
View File

@@ -140,6 +140,11 @@ var (
"ListBatchOperations": 1,
"StartBatchOperation": 1,
"StopBatchOperation": 1,
// TODO: added temporarily here; need to be check when implemented if it's the right place and priority
"PollNexusTaskQueue": 1,
"RespondNexusTaskCompleted": 1,
"RespondNexusTaskFailed": 1,
}
OtherAPIPrioritiesOrdered = []int{0, 1}

4
service/frontend/configs/quotas_test.go
View File

@@ -234,6 +234,10 @@ func (s *quotasSuite) TestOtherAPIs() {
"ListBatchOperations": {},
"StartBatchOperation": {},
"StopBatchOperation": {},
"PollNexusTaskQueue": {},
"RespondNexusTaskCompleted": {},
"RespondNexusTaskFailed": {},
}
var service workflowservice.WorkflowServiceServer

105
service/frontend/interface_mock.go
View File

@@ -494,6 +494,21 @@ func (mr *MockHandlerMockRecorder) PollActivityTaskQueue(arg0, arg1 interface{})
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollActivityTaskQueue", reflect.TypeOf((*MockHandler)(nil).PollActivityTaskQueue), arg0, arg1)
}
// PollNexusTaskQueue mocks base method.
func (m *MockHandler) PollNexusTaskQueue(arg0 context.Context, arg1 *v10.PollNexusTaskQueueRequest) (*v10.PollNexusTaskQueueResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "PollNexusTaskQueue", arg0, arg1)
ret0, _ := ret[0].(*v10.PollNexusTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (mr *MockHandlerMockRecorder) PollNexusTaskQueue(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollNexusTaskQueue", reflect.TypeOf((*MockHandler)(nil).PollNexusTaskQueue), arg0, arg1)
}
// PollWorkflowExecutionUpdate mocks base method.
func (m *MockHandler) PollWorkflowExecutionUpdate(arg0 context.Context, arg1 *v10.PollWorkflowExecutionUpdateRequest) (*v10.PollWorkflowExecutionUpdateResponse, error) {
m.ctrl.T.Helper()
@@ -719,6 +734,36 @@ func (mr *MockHandlerMockRecorder) RespondActivityTaskFailedById(arg0, arg1 inte
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskFailedById", reflect.TypeOf((*MockHandler)(nil).RespondActivityTaskFailedById), arg0, arg1)
}
// RespondNexusTaskCompleted mocks base method.
func (m *MockHandler) RespondNexusTaskCompleted(arg0 context.Context, arg1 *v10.RespondNexusTaskCompletedRequest) (*v10.RespondNexusTaskCompletedResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "RespondNexusTaskCompleted", arg0, arg1)
ret0, _ := ret[0].(*v10.RespondNexusTaskCompletedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (mr *MockHandlerMockRecorder) RespondNexusTaskCompleted(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondNexusTaskCompleted", reflect.TypeOf((*MockHandler)(nil).RespondNexusTaskCompleted), arg0, arg1)
}
// RespondNexusTaskFailed mocks base method.
func (m *MockHandler) RespondNexusTaskFailed(arg0 context.Context, arg1 *v10.RespondNexusTaskFailedRequest) (*v10.RespondNexusTaskFailedResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "RespondNexusTaskFailed", arg0, arg1)
ret0, _ := ret[0].(*v10.RespondNexusTaskFailedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (mr *MockHandlerMockRecorder) RespondNexusTaskFailed(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondNexusTaskFailed", reflect.TypeOf((*MockHandler)(nil).RespondNexusTaskFailed), arg0, arg1)
}
// RespondQueryTaskCompleted mocks base method.
func (m *MockHandler) RespondQueryTaskCompleted(arg0 context.Context, arg1 *v10.RespondQueryTaskCompletedRequest) (*v10.RespondQueryTaskCompletedResponse, error) {
m.ctrl.T.Helper()
@@ -1018,6 +1063,21 @@ func (mr *MockOperatorHandlerMockRecorder) AddSearchAttributes(arg0, arg1 interf
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddSearchAttributes", reflect.TypeOf((*MockOperatorHandler)(nil).AddSearchAttributes), arg0, arg1)
}
// CreateOrUpdateNexusIncomingService mocks base method.
func (m *MockOperatorHandler) CreateOrUpdateNexusIncomingService(arg0 context.Context, arg1 *v1.CreateOrUpdateNexusIncomingServiceRequest) (*v1.CreateOrUpdateNexusIncomingServiceResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "CreateOrUpdateNexusIncomingService", arg0, arg1)
ret0, _ := ret[0].(*v1.CreateOrUpdateNexusIncomingServiceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// CreateOrUpdateNexusIncomingService indicates an expected call of CreateOrUpdateNexusIncomingService.
func (mr *MockOperatorHandlerMockRecorder) CreateOrUpdateNexusIncomingService(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateOrUpdateNexusIncomingService", reflect.TypeOf((*MockOperatorHandler)(nil).CreateOrUpdateNexusIncomingService), arg0, arg1)
}
// DeleteNamespace mocks base method.
func (m *MockOperatorHandler) DeleteNamespace(arg0 context.Context, arg1 *v1.DeleteNamespaceRequest) (*v1.DeleteNamespaceResponse, error) {
m.ctrl.T.Helper()
@@ -1033,6 +1093,36 @@ func (mr *MockOperatorHandlerMockRecorder) DeleteNamespace(arg0, arg1 interface{
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteNamespace", reflect.TypeOf((*MockOperatorHandler)(nil).DeleteNamespace), arg0, arg1)
}
// DeleteNexusIncomingService mocks base method.
func (m *MockOperatorHandler) DeleteNexusIncomingService(arg0 context.Context, arg1 *v1.DeleteNexusIncomingServiceRequest) (*v1.DeleteNexusIncomingServiceResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeleteNexusIncomingService", arg0, arg1)
ret0, _ := ret[0].(*v1.DeleteNexusIncomingServiceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeleteNexusIncomingService indicates an expected call of DeleteNexusIncomingService.
func (mr *MockOperatorHandlerMockRecorder) DeleteNexusIncomingService(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteNexusIncomingService", reflect.TypeOf((*MockOperatorHandler)(nil).DeleteNexusIncomingService), arg0, arg1)
}
// GetNexusIncomingService mocks base method.
func (m *MockOperatorHandler) GetNexusIncomingService(arg0 context.Context, arg1 *v1.GetNexusIncomingServiceRequest) (*v1.GetNexusIncomingServiceResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetNexusIncomingService", arg0, arg1)
ret0, _ := ret[0].(*v1.GetNexusIncomingServiceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetNexusIncomingService indicates an expected call of GetNexusIncomingService.
func (mr *MockOperatorHandlerMockRecorder) GetNexusIncomingService(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetNexusIncomingService", reflect.TypeOf((*MockOperatorHandler)(nil).GetNexusIncomingService), arg0, arg1)
}
// ListClusters mocks base method.
func (m *MockOperatorHandler) ListClusters(arg0 context.Context, arg1 *v1.ListClustersRequest) (*v1.ListClustersResponse, error) {
m.ctrl.T.Helper()
@@ -1048,6 +1138,21 @@ func (mr *MockOperatorHandlerMockRecorder) ListClusters(arg0, arg1 interface{})
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListClusters", reflect.TypeOf((*MockOperatorHandler)(nil).ListClusters), arg0, arg1)
}
// ListNexusIncomingServices mocks base method.
func (m *MockOperatorHandler) ListNexusIncomingServices(arg0 context.Context, arg1 *v1.ListNexusIncomingServicesRequest) (*v1.ListNexusIncomingServicesResponse, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "ListNexusIncomingServices", arg0, arg1)
ret0, _ := ret[0].(*v1.ListNexusIncomingServicesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListNexusIncomingServices indicates an expected call of ListNexusIncomingServices.
func (mr *MockOperatorHandlerMockRecorder) ListNexusIncomingServices(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListNexusIncomingServices", reflect.TypeOf((*MockOperatorHandler)(nil).ListNexusIncomingServices), arg0, arg1)
}
// ListSearchAttributes mocks base method.
func (m *MockOperatorHandler) ListSearchAttributes(arg0 context.Context, arg1 *v1.ListSearchAttributesRequest) (*v1.ListSearchAttributesResponse, error) {
m.ctrl.T.Helper()

21
service/frontend/operator_handler.go
View File

@@ -30,8 +30,10 @@ import (
"sync/atomic"
"golang.org/x/exp/maps"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/health"
healthpb "google.golang.org/grpc/health/grpc_health_v1"
"google.golang.org/grpc/status"
commonpb "go.temporal.io/api/common/v1"
enumspb "go.temporal.io/api/enums/v1"
@@ -821,3 +823,22 @@ func (h *OperatorHandlerImpl) validateRemoteClusterMetadata(metadata *adminservi
}
return nil
}
func (h *OperatorHandlerImpl) CreateOrUpdateNexusIncomingService(context.Context, *operatorservice.CreateOrUpdateNexusIncomingServiceRequest) (*operatorservice.CreateOrUpdateNexusIncomingServiceResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateOrUpdateNexusIncomingService not implemented")
}
// DeleteNexusIncomingService implements OperatorHandler.
func (*OperatorHandlerImpl) DeleteNexusIncomingService(context.Context, *operatorservice.DeleteNexusIncomingServiceRequest) (*operatorservice.DeleteNexusIncomingServiceResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteNexusIncomingService not implemented")
}
// GetNexusIncomingService implements OperatorHandler.
func (*OperatorHandlerImpl) GetNexusIncomingService(context.Context, *operatorservice.GetNexusIncomingServiceRequest) (*operatorservice.GetNexusIncomingServiceResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetNexusIncomingService not implemented")
}
// ListNexusIncomingServices implements OperatorHandler.
func (*OperatorHandlerImpl) ListNexusIncomingServices(context.Context, *operatorservice.ListNexusIncomingServicesRequest) (*operatorservice.ListNexusIncomingServicesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListNexusIncomingServices not implemented")
}

4
service/frontend/redirection_interceptor.go
View File

@@ -118,6 +118,10 @@ var (
"StopBatchOperation": func() any { return &workflowservice.StopBatchOperationResponse{} },
"DescribeBatchOperation": func() any { return &workflowservice.DescribeBatchOperationResponse{} },
"ListBatchOperations": func() any { return &workflowservice.ListBatchOperationsResponse{} },
"PollNexusTaskQueue": func() any { return &workflowservice.PollNexusTaskQueueResponse{} },
"RespondNexusTaskCompleted": func() any { return &workflowservice.RespondNexusTaskCompletedResponse{} },
"RespondNexusTaskFailed": func() any { return &workflowservice.RespondNexusTaskFailedResponse{} },
}
)

4
service/frontend/redirection_interceptor_test.go
View File

@@ -178,6 +178,10 @@ func (s *redirectionInterceptorSuite) TestGlobalAPI() {
"StopBatchOperation": {},
"DescribeBatchOperation": {},
"ListBatchOperations": {},
"PollNexusTaskQueue": {},
"RespondNexusTaskCompleted": {},
"RespondNexusTaskFailed": {},
}, apis)
}

17
service/frontend/workflow_handler.go
View File

@@ -47,8 +47,10 @@ import (
updatepb "go.temporal.io/api/update/v1"
workflowpb "go.temporal.io/api/workflow/v1"
"go.temporal.io/api/workflowservice/v1"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/health"
healthpb "google.golang.org/grpc/health/grpc_health_v1"
"google.golang.org/grpc/status"
"google.golang.org/protobuf/types/known/durationpb"
"google.golang.org/protobuf/types/known/timestamppb"
@@ -4268,3 +4270,18 @@ func (wh *WorkflowHandler) unaliasCreateScheduleRequestSearchAttributes(request
return newRequest, nil
}
// PollNexusTaskQueue implements Handler.
func (*WorkflowHandler) PollNexusTaskQueue(context.Context, *workflowservice.PollNexusTaskQueueRequest) (*workflowservice.PollNexusTaskQueueResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PollNexusTaskQueue not implemented")
}
// RespondNexusTaskCompleted implements Handler.
func (*WorkflowHandler) RespondNexusTaskCompleted(context.Context, *workflowservice.RespondNexusTaskCompletedRequest) (*workflowservice.RespondNexusTaskCompletedResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RespondNexusTaskCompleted not implemented")
}
// RespondNexusTaskFailed implements Handler.
func (*WorkflowHandler) RespondNexusTaskFailed(context.Context, *workflowservice.RespondNexusTaskFailedRequest) (*workflowservice.RespondNexusTaskFailedResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RespondNexusTaskFailed not implemented")
}