fix spelling errors (#48)

Signed-off-by: Qianbo Huai <[email protected]>
numaproj · Jun 6, 2022 · 9f9f5ba · 9f9f5ba
1 parent f423002
commit 9f9f5ba
Show file tree

Hide file tree

Showing 9 changed files with 16 additions and 16 deletions.
diff --git a/config/base/crds/numaflow.numaproj.io_interstepbufferservices.yaml b/config/base/crds/numaflow.numaproj.io_interstepbufferservices.yaml
@@ -1253,7 +1253,7 @@ spec:
                     type: object
                   encryption:
                     description: Whether encrypt the data at rest, defaults to false
-                      Enabling encryption might impact the performace, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest
+                      Enabling encryption might impact the performance, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest
                       for the detail Toggling the value will impact encypting/decrypting
                       existing messages.
                     type: boolean
@@ -2181,7 +2181,7 @@ spec:
                     type: array
                   tls:
                     description: Whether enable TLS, defaults to false Enabling TLS
-                      might impact the performace
+                      might impact the performance
                     type: boolean
                   tolerations:
                     description: If specified, the pod's tolerations.

diff --git a/config/install.yaml b/config/install.yaml
@@ -1252,7 +1252,7 @@ spec:
                     type: object
                   encryption:
                     description: Whether encrypt the data at rest, defaults to false
-                      Enabling encryption might impact the performace, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest
+                      Enabling encryption might impact the performance, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest
                       for the detail Toggling the value will impact encypting/decrypting
                       existing messages.
                     type: boolean
@@ -2180,7 +2180,7 @@ spec:
                     type: array
                   tls:
                     description: Whether enable TLS, defaults to false Enabling TLS
-                      might impact the performace
+                      might impact the performance
                     type: boolean
                   tolerations:
                     description: If specified, the pod's tolerations.

diff --git a/controllers/pipeline/validate.go b/controllers/pipeline/validate.go
@@ -49,11 +49,11 @@ func ValidatePipeline(pl *dfv1.Pipeline) error {
 	}
 
 	if len(sources) == 0 {
-		return fmt.Errorf("pipeline has no source, at lease one vertex with 'source' defined is requried")
+		return fmt.Errorf("pipeline has no source, at lease one vertex with 'source' defined is required")
 	}
 
 	if len(sinks) == 0 {
-		return fmt.Errorf("pipeline has no sink, at lease one vertex with 'sink' defined is requried")
+		return fmt.Errorf("pipeline has no sink, at lease one vertex with 'sink' defined is required")
 	}
 
 	for k, u := range udfs {

diff --git a/docs/APIs.md b/docs/APIs.md
@@ -1612,7 +1612,7 @@ fields under “otBucket” include “maxValueSize”, “history”, “ttl”
 <em>(Optional)</em>
 <p>
 Whether encrypt the data at rest, defaults to false Enabling encryption
-might impact the performace, see
+might impact the performance, see
 <a href="https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest">https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest</a>
 for the detail Toggling the value will impact encypting/decrypting
 existing messages.
@@ -1627,7 +1627,7 @@ existing messages.
 <em>(Optional)</em>
 <p>
 Whether enable TLS, defaults to false Enabling TLS might impact the
-performace
+performance
 </p>
 </td>
 </tr>

diff --git a/pkg/apis/numaflow/v1alpha1/generated.proto b/pkg/apis/numaflow/v1alpha1/generated.proto
diff --git a/pkg/apis/numaflow/v1alpha1/jetstream_buffer_service.go b/pkg/apis/numaflow/v1alpha1/jetstream_buffer_service.go
@@ -93,12 +93,12 @@ type JetStreamBufferService struct {
 	// +optional
 	BufferConfig *string `json:"bufferConfig,omitempty" protobuf:"bytes,18,opt,name=bufferConfig"`
 	// Whether encrypt the data at rest, defaults to false
-	// Enabling encryption might impact the performace, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest for the detail
+	// Enabling encryption might impact the performance, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest for the detail
 	// Toggling the value will impact encypting/decrypting existing messages.
 	// +optional
 	Encryption bool `json:"encryption,omitempty" protobuf:"bytes,19,opt,name=encryption"`
 	// Whether enable TLS, defaults to false
-	// Enabling TLS might impact the performace
+	// Enabling TLS might impact the performance
 	// +optional
 	TLS bool `json:"tls,omitempty" protobuf:"bytes,20,opt,name=tls"`
 }

diff --git a/pkg/isb/redis/read.go b/pkg/isb/redis/read.go
@@ -226,7 +226,7 @@ func (br *BufferRead) Read(_ context.Context, count int64) ([]*isb.ReadMessage,
 			return messages, fmt.Errorf("XReadGroup failed, %w", err)
 		}
 
-		// NOTE: If all messages have been delivered and acknowleged, the XREADGROUP 0-0 call returns an empty
+		// NOTE: If all messages have been delivered and acknowledged, the XREADGROUP 0-0 call returns an empty
 		// list of messages in the stream. At this point we want to read everything from last delivered which would be >
 		if len(xstreams) == 1 && len(xstreams[0].Messages) == 0 {
 			br.log.Infow("We have delivered and acknowledged all PENDING msgs, setting checkBacklog to false")

diff --git a/pkg/isb/redis/write.go b/pkg/isb/redis/write.go
@@ -116,7 +116,7 @@ func (bw *BufferWrite) refreshWriteInfo(ctx context.Context) {
 	}
 }
 
-// trim is used to explicity call TRIM on buffer being full
+// trim is used to explicitly call TRIM on buffer being full
 func (bw *BufferWrite) trim(_ context.Context) {
 	ctx := clients.RedisContext
 	bw.log.Infow("Explicit trim on MINID", zap.String("MINID", bw.minId.Load()))

diff --git a/pkg/sources/kafka/metrics.go b/pkg/sources/kafka/metrics.go
@@ -12,11 +12,11 @@ var kafkaSourceReadCount = promauto.NewCounterVec(prometheus.CounterOpts{
 	Help:      "Total number of messages Read",
 }, []string{"vertex", "pipeline"})
 
-// kafkaSourceAckCount is used to indicate the number of messages Acknowleged
+// kafkaSourceAckCount is used to indicate the number of messages Acknowledged
 var kafkaSourceAckCount = promauto.NewCounterVec(prometheus.CounterOpts{
 	Subsystem: "kafka_source",
 	Name:      "ack_total",
-	Help:      "Total number of messages Acknowleged",
+	Help:      "Total number of messages Acknowledged",
 }, []string{"vertex", "pipeline"})
 
 // kafkaSourceOffsetAckErrors is used to indicate the number of errors while reading from kafka source with offsets