Skip to content

Commit

Permalink
fix: removed parallel
Browse files Browse the repository at this point in the history
  • Loading branch information
@alexec
alexec committed Jun 10, 2021
1 parent 4cd5e8b commit 268b1ec
Show file tree
Hide file tree
Showing 16 changed files with 238 additions and 537 deletions.
401 changes: 176 additions & 225 deletions api/v1alpha1/generated.pb.go
View file

Large diffs are not rendered by default.

8 changes: 0 additions & 8 deletions api/v1alpha1/generated.proto
View file

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

3 changes: 0 additions & 3 deletions api/v1alpha1/kafka.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,4 @@ type Kafka struct {
Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"`
Version string `json:"version,omitempty" protobuf:"bytes,4,opt,name=version"`
NET *KafkaNET `json:"net,omitempty" protobuf:"bytes,5,opt,name=net"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:default=1
Parallel uint32 `json:"parallel,omitempty" protobuf:"varint,6,opt,name=parallel"`
}
2 changes: 1 addition & 1 deletion api/v1alpha1/retry_policy.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@ package v1alpha1
type RetryPolicy string

const (
RetryNever RetryPolicy = "Never" // give up straight away
RetryNever RetryPolicy = "Never" // give up straight away
RetryAlways RetryPolicy = "Always" // keep trying and never give up
)
3 changes: 0 additions & 3 deletions api/v1alpha1/stan.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,4 @@ type STAN struct {
ClusterID string `json:"clusterId,omitempty" protobuf:"bytes,5,opt,name=clusterId"`
Subject string `json:"subject" protobuf:"bytes,3,opt,name=subject"`
SubjectPrefix SubjectPrefix `json:"subjectPrefix,omitempty" protobuf:"bytes,6,opt,name=subjectPrefix,casttype=SubjectPrefix"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:default=1
Parallel uint32 `json:"parallel,omitempty" protobuf:"varint,7,opt,name=parallel"`
}
40 changes: 0 additions & 40 deletions config/ci.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -731,11 +731,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -759,11 +754,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -807,11 +797,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -839,11 +824,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -2591,11 +2571,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -2619,11 +2594,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -2667,11 +2637,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -2699,11 +2664,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down
20 changes: 0 additions & 20 deletions config/crd/bases/dataflow.argoproj.io_pipelines.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1097,11 +1097,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -1125,11 +1120,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -1173,11 +1163,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -1205,11 +1190,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down
20 changes: 0 additions & 20 deletions config/crd/bases/dataflow.argoproj.io_steps.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1057,11 +1057,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -1085,11 +1080,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -1133,11 +1123,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -1165,11 +1150,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down
40 changes: 0 additions & 40 deletions config/default.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -731,11 +731,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -759,11 +754,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -807,11 +797,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -839,11 +824,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -2591,11 +2571,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand All @@ -2619,11 +2594,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down Expand Up @@ -2667,11 +2637,6 @@ spec:
tls:
type: object
type: object
parallel:
default: 1
format: int32
minimum: 1
type: integer
topic:
type: string
version:
Expand Down Expand Up @@ -2699,11 +2664,6 @@ spec:
type: string
natsUrl:
type: string
parallel:
default: 1
format: int32
minimum: 1
type: integer
subject:
type: string
subjectPrefix:
Expand Down
Loading

0 comments on commit 268b1ec

Please sign in to comment.