fmt code

apis/v1alpha1/groupversion_info.go

@@ -15,8 +15,8 @@ limitations under the License.
 */
 
 // Package v1alpha1 contains API Schema definitions for the game.kruise.io v1alpha1 API group
-//+kubebuilder:object:generate=true
-//+groupName=game.kruise.io
+// +kubebuilder:object:generate=true
+// +groupName=game.kruise.io
 package v1alpha1
 
 import (

pkg/client/clientset/versioned/fake/register.go

@@ -36,14 +36,14 @@ var localSchemeBuilder = runtime.SchemeBuilder{
 // AddToScheme adds all types of this clientset into the given scheme. This allows composition
 // of clientsets, like in:
 //
-//   import (
-//     "k8s.io/client-go/kubernetes"
-//     clientsetscheme "k8s.io/client-go/kubernetes/scheme"
-//     aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme"
-//   )
+//	import (
+//	  "k8s.io/client-go/kubernetes"
+//	  clientsetscheme "k8s.io/client-go/kubernetes/scheme"
+//	  aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme"
+//	)
 //
-//   kclientset, _ := kubernetes.NewForConfig(c)
-//   _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme)
+//	kclientset, _ := kubernetes.NewForConfig(c)
+//	_ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme)
 //
 // After this, RawExtensions in Kubernetes types will serialize kube-aggregator types
 // correctly.

pkg/client/clientset/versioned/scheme/register.go

@@ -36,14 +36,14 @@ var localSchemeBuilder = runtime.SchemeBuilder{
 // AddToScheme adds all types of this clientset into the given scheme. This allows composition
 // of clientsets, like in:
 //
-//   import (
-//     "k8s.io/client-go/kubernetes"
-//     clientsetscheme "k8s.io/client-go/kubernetes/scheme"
-//     aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme"
-//   )
+//	import (
+//	  "k8s.io/client-go/kubernetes"
+//	  clientsetscheme "k8s.io/client-go/kubernetes/scheme"
+//	  aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme"
+//	)
 //
-//   kclientset, _ := kubernetes.NewForConfig(c)
-//   _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme)
+//	kclientset, _ := kubernetes.NewForConfig(c)
+//	_ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme)
 //
 // After this, RawExtensions in Kubernetes types will serialize kube-aggregator types
 // correctly.

pkg/externalscaler/externalscaler.go

@@ -17,23 +17,23 @@ func (e *ExternalScaler) mustEmbedUnimplementedExternalScalerServer() {
 }
 
 func (e *ExternalScaler) IsActive(ctx context.Context, scaledObjectRef *ScaledObjectRef) (*IsActiveResponse, error) {
-        name := scaledObjectRef.GetName()
-        ns := scaledObjectRef.GetNamespace()
-        gss := &gamekruiseiov1alpha1.GameServerSet{}
-        err := e.client.Get(ctx, types.NamespacedName{Namespace: ns, Name: name}, gss)
-        if err != nil {
-                klog.Error(err)
-                return nil, err
-        }
-        currentReplicas := gss.Status.CurrentReplicas
-        numWaitToBeDeleted := gss.Status.WaitToBeDeletedReplicas
-        if numWaitToBeDeleted == nil {
-                return nil, fmt.Errorf("GameServerSet %s/%s has not inited", ns, name)
-        }
-        desireReplicas := currentReplicas - *numWaitToBeDeleted
-        return &IsActiveResponse{
-                Result: desireReplicas > 0,
-        }, nil
+	name := scaledObjectRef.GetName()
+	ns := scaledObjectRef.GetNamespace()
+	gss := &gamekruiseiov1alpha1.GameServerSet{}
+	err := e.client.Get(ctx, types.NamespacedName{Namespace: ns, Name: name}, gss)
+	if err != nil {
+		klog.Error(err)
+		return nil, err
+	}
+	currentReplicas := gss.Status.CurrentReplicas
+	numWaitToBeDeleted := gss.Status.WaitToBeDeletedReplicas
+	if numWaitToBeDeleted == nil {
+		return nil, fmt.Errorf("GameServerSet %s/%s has not inited", ns, name)
+	}
+	desireReplicas := currentReplicas - *numWaitToBeDeleted
+	return &IsActiveResponse{
+		Result: desireReplicas > 0,
+	}, nil
 }
 
 func (e *ExternalScaler) StreamIsActive(scaledObject *ScaledObjectRef, epsServer ExternalScaler_StreamIsActiveServer) error {

pkg/webhook/util/writer/atomic/atomic_writer.go

@@ -42,9 +42,9 @@ const (
 //
 // Note:
 //
-// 1. Writer reserves the set of pathnames starting with `..`.
-// 2. Writer offers no concurrency guarantees and must be synchronized
-//    by the caller.
+//  1. Writer reserves the set of pathnames starting with `..`.
+//  2. Writer offers no concurrency guarantees and must be synchronized
+//     by the caller.
 //
 // The visible files in this volume are symlinks to files in the writer's data
 // directory.  Actual files are stored in a hidden timestamped directory which
@@ -86,33 +86,37 @@ const (
 //
 // The Write algorithm is:
 //
-//  1.  The payload is validated; if the payload is invalid, the function returns
-//  2.  The current timestamped directory is detected by reading the data directory
-//      symlink
-//  3.  The old version of the volume is walked to determine whether any
-//      portion of the payload was deleted and is still present on disk.
-//  4.  The data in the current timestamped directory is compared to the projected
-//      data to determine if an update is required.
-//  5.  A new timestamped dir is created
-//  6.  The payload is written to the new timestamped directory
-//  7.  Symlinks and directory for new user-visible files are created (if needed).
+//  1. The payload is validated; if the payload is invalid, the function returns
+//     2.  The current timestamped directory is detected by reading the data directory
+//     symlink
 //
-//      For example, consider the files:
-//        <target-dir>/podName
-//        <target-dir>/user/labels
-//        <target-dir>/k8s/annotations
+//  3. The old version of the volume is walked to determine whether any
+//     portion of the payload was deleted and is still present on disk.
 //
-//      The user visible files are symbolic links into the internal data directory:
-//        <target-dir>/podName         -> ..data/podName
-//        <target-dir>/usr -> ..data/usr
-//        <target-dir>/k8s -> ..data/k8s
+//  4. The data in the current timestamped directory is compared to the projected
+//     data to determine if an update is required.
+//     5.  A new timestamped dir is created
+//
+//  6. The payload is written to the new timestamped directory
+//     7.  Symlinks and directory for new user-visible files are created (if needed).
+//
+//     For example, consider the files:
+//     <target-dir>/podName
+//     <target-dir>/user/labels
+//     <target-dir>/k8s/annotations
+//
+//     The user visible files are symbolic links into the internal data directory:
+//     <target-dir>/podName         -> ..data/podName
+//     <target-dir>/usr -> ..data/usr
+//     <target-dir>/k8s -> ..data/k8s
+//
+//     The data directory itself is a link to a timestamped directory with
+//     the real data:
+//     <target-dir>/..data          -> ..2016_02_01_15_04_05.12345678/
+//     8.  A symlink to the new timestamped directory ..data_tmp is created that will
+//     become the new data directory
+//     9.  The new data directory symlink is renamed to the data directory; rename is atomic
 //
-//      The data directory itself is a link to a timestamped directory with
-//      the real data:
-//        <target-dir>/..data          -> ..2016_02_01_15_04_05.12345678/
-//  8.  A symlink to the new timestamped directory ..data_tmp is created that will
-//      become the new data directory
-//  9.  The new data directory symlink is renamed to the data directory; rename is atomic
 // 10.  Old paths are removed from the user-visible portion of the target directory
 // 11.  The previous timestamped directory is removed, if it exists
 func (w *Writer) Write(payload map[string]FileProjection) error {