Skip to content

Commit

Permalink
feat: introducing tags for conditional forwarding (#668)
Browse files Browse the repository at this point in the history 
Signed-off-by: Yashash H L <yashashhl25@gmail.com>
  • Loading branch information
@yhl25
yhl25 committed Apr 14, 2023
1 parent a6e8174 commit b83525d
Show file tree
Hide file tree
Showing 56 changed files with 1,547 additions and 960 deletions.
29 changes: 23 additions & 6 deletions api/json-schema/schema.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17709,15 +17709,13 @@
},
"io.numaproj.numaflow.v1alpha1.ForwardConditions": {
"properties": {
"keyIn": {
"items": {
"type": "string"
},
"type": "array"
"tags": {
"$ref": "#/definitions/io.numaproj.numaflow.v1alpha1.TagConditions",
"description": "Tags used to specify tags for conditional forwarding"
}
},
"required": [
"keyIn"
"tags"
],
"type": "object"
},
Expand Down Expand Up @@ -19133,6 +19131,25 @@
},
"type": "object"
},
"io.numaproj.numaflow.v1alpha1.TagConditions": {
"properties": {
"operator": {
"description": "Operator specifies the type of operation that should be used for conditional forwarding value could be \"and\", \"or\", \"not\"",
"type": "string"
},
"values": {
"description": "Values tag values for conditional forwarding",
"items": {
"type": "string"
},
"type": "array"
}
},
"required": [
"values"
],
"type": "object"
},
"io.numaproj.numaflow.v1alpha1.Templates": {
"properties": {
"daemon": {
Expand Down
29 changes: 23 additions & 6 deletions api/openapi-spec/swagger.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17714,14 +17714,12 @@
"io.numaproj.numaflow.v1alpha1.ForwardConditions": {
"type": "object",
"required": [
"keyIn"
"tags"
],
"properties": {
"keyIn": {
"type": "array",
"items": {
"type": "string"
}
"tags": {
"description": "Tags used to specify tags for conditional forwarding",
"$ref": "#/definitions/io.numaproj.numaflow.v1alpha1.TagConditions"
}
}
},
Expand Down Expand Up @@ -19119,6 +19117,25 @@
}
}
},
"io.numaproj.numaflow.v1alpha1.TagConditions": {
"type": "object",
"required": [
"values"
],
"properties": {
"operator": {
"description": "Operator specifies the type of operation that should be used for conditional forwarding value could be \"and\", \"or\", \"not\"",
"type": "string"
},
"values": {
"description": "Values tag values for conditional forwarding",
"type": "array",
"items": {
"type": "string"
}
}
}
},
"io.numaproj.numaflow.v1alpha1.Templates": {
"type": "object",
"properties": {
Expand Down
21 changes: 16 additions & 5 deletions config/base/crds/full/numaflow.numaproj.io_pipelines.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -59,12 +59,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down
42 changes: 32 additions & 10 deletions config/base/crds/full/numaflow.numaproj.io_vertices.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -594,12 +594,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down Expand Up @@ -3060,12 +3071,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down
63 changes: 48 additions & 15 deletions config/install.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2504,12 +2504,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down Expand Up @@ -8696,12 +8707,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down Expand Up @@ -11162,12 +11184,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down
63 changes: 48 additions & 15 deletions config/namespace-install.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2504,12 +2504,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down Expand Up @@ -8696,12 +8707,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down Expand Up @@ -11162,12 +11184,23 @@ spec:
properties:
conditions:
properties:
keyIn:
items:
type: string
type: array
tags:
properties:
operator:
enum:
- and
- or
- not
type: string
values:
items:
type: string
type: array
required:
- values
type: object
required:
- keyIn
- tags
type: object
from:
type: string
Expand Down

0 comments on commit b83525d

Please sign in to comment.