smartxworks/kopilot

Function main has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func main() {
    connectURL := ""
    flag.StringVar(&connectURL, "connect", connectURL, "connect URL of kopilot-hub")
    apiserverAddr := "kubernetes.default"
    flag.StringVar(&apiserverAddr, "apiserver", apiserverAddr, "kube-apiserver address")

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *FakeClusters) Create(ctx context.Context, cluster *v1alpha1.Cluster, opts v1.CreateOptions) (result *v1alpha1.Cluster, err error) {
    obj, err := c.Fake.
        Invokes(testing.NewCreateAction(clustersResource, c.ns, cluster), &v1alpha1.Cluster{})
 
    if obj == nil {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *FakeClusters) Update(ctx context.Context, cluster *v1alpha1.Cluster, opts v1.UpdateOptions) (result *v1alpha1.Cluster, err error) {
    obj, err := c.Fake.
        Invokes(testing.NewUpdateAction(clustersResource, c.ns, cluster), &v1alpha1.Cluster{})
 
    if obj == nil {

• Read up
  Read up

Method clusters.Patch has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (c *clusters) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1alpha1.Cluster, err error) {

Method FakeClusters.Patch has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (c *FakeClusters) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1alpha1.Cluster, err error) {

Method Manager.TryNextPeer has 6 return statements (exceeds 4 allowed).

Open

func (m *Manager) TryNextPeer(w http.ResponseWriter, r *http.Request, e error, key types.NamespacedName, nextPeer func() string) {
    peer := nextPeer()
    if peer == "" {
        w.WriteHeader(http.StatusBadGateway)
        return

Function NewProxyHandler has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewProxyHandler(client clientset.Interface, sessionManager SessionManager, peerManager PeerManager, key types.NamespacedName, subpath string) http.Handler {

Function NewFilteredClusterInformer has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewFilteredClusterInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {

Method Manager.TryNextPeer has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (m *Manager) TryNextPeer(w http.ResponseWriter, r *http.Request, e error, key types.NamespacedName, nextPeer func() string) {