Function NewTemporalClient

flow/e2e/test_utils.go:618–648

(t *testing.T)

}

func NewTemporalClient(t *testing.T) client.Client {
	t.Helper()

	logger := slog.New(shared.NewSlogHandler(
		slog.NewJSONHandler(
			&testWriter{t},
			&slog.HandlerOptions{Level: slog.LevelWarn},
		),
	))

	var lastErr error
	deadline := time.Now().Add(time.Minute)
	for attempt := 1; ; attempt++ {
		tc, err := client.Dial(client.Options{
			HostPort: "localhost:7233",
			Logger:   logger,
		})
		if err == nil {
			return tc
		}
		lastErr = err
		if ctxErr := t.Context().Err(); ctxErr != nil {
			t.Fatalf("Failed to connect temporal client: %v", ctxErr)
		}
		if time.Now().After(deadline) {
			t.Fatalf("Failed to connect temporal client after %d attempts: %v", attempt, lastErr)
		}
		t.Logf("Temporal client dial attempt %d failed: %v", attempt, err)
		time.Sleep(time.Second)
	}
}

func NewApiClient() (protos.FlowServiceClient, error) {
	client, err := grpc.NewClient("0.0.0.0:8112", grpc.WithTransportCredentials(insecure.NewCredentials()))