Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: support SNCloud Connection & Compute Workspace & Compute FlinkDeployment #278

Merged
merged 19 commits into from
Jan 26, 2025
Prev Previous commit
Next Next commit
goimport
freeznet committed Jan 24, 2025

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
commit 786a58c235516d03f01c3f581e73ee7966ee0191
5 changes: 4 additions & 1 deletion api/v1alpha1/common.go
Original file line number Diff line number Diff line change
@@ -15,9 +15,12 @@
package v1alpha1

import (
corev1 "k8s.io/api/core/v1"
"reflect"

corev1 "k8s.io/api/core/v1"

"k8s.io/apimachinery/pkg/api/meta"
metav1 "k8s.io/

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / Build

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (true)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / lint

string literal not terminated (typecheck)

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated

Check failure on line 23 in api/v1alpha1/common.go

GitHub Actions / E2e tests for Operators (false)

string literal not terminated
"k8s.io/apimachinery/pkg/api/meta"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

2 changes: 1 addition & 1 deletion api/v1alpha1/zz_generated.deepcopy.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions controllers/apiserverconnection_controller.go
Original file line number Diff line number Diff line change
@@ -18,6 +18,7 @@ import (
"context"
"encoding/json"
"fmt"

resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
corev1 "k8s.io/api/core/v1"
apierrors "k8s.io/apimachinery/pkg/api/errors"
3 changes: 2 additions & 1 deletion controllers/connection_manager.go
Original file line number Diff line number Diff line change
@@ -17,9 +17,10 @@ package controllers
import (
"context"
"fmt"
"sync"

resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
controllers2 "github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud"
"sync"

"sigs.k8s.io/controller-runtime/pkg/client"
)
1 change: 1 addition & 0 deletions controllers/connection_ref_mapper.go
Original file line number Diff line number Diff line change
@@ -16,6 +16,7 @@

import (
"context"

corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/types"
"sigs.k8s.io/controller-runtime/pkg/client"
@@ -64,7 +65,7 @@

func getConnectionRef(object client.Object) *corev1.LocalObjectReference {
switch v := object.(type) {
case *pulsarv1alpha1.PulsarTenant:

Check failure on line 68 in controllers/connection_ref_mapper.go

GitHub Actions / lint

previous case (typecheck)
return &v.Spec.ConnectionRef
case *pulsarv1alpha1.PulsarNamespace:
return &v.Spec.ConnectionRef
5 changes: 3 additions & 2 deletions controllers/flinkdeployment_controller.go
Original file line number Diff line number Diff line change
@@ -18,11 +18,12 @@ import (
"context"
"encoding/json"
"fmt"
resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
controllers2 "github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud"
"sync"
"time"

resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
controllers2 "github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud"

apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
5 changes: 3 additions & 2 deletions controllers/workspace_controller.go
Original file line number Diff line number Diff line change
@@ -17,11 +17,12 @@ package controllers
import (
"context"
"fmt"
resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
controllers2 "github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud"
"sync"
"time"

resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
controllers2 "github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud"

apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
1 change: 1 addition & 0 deletions pkg/streamnativecloud/status_helper.go
Original file line number Diff line number Diff line change
@@ -16,6 +16,7 @@ package controllers

import (
"bytes"

resourcev1alpha1 "github.com/streamnative/pulsar-resources-operator/api/v1alpha1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
Loading