Skip to content

Commit f94e94f

Browse files
committed
fix spec
1 parent 036c134 commit f94e94f

File tree

4 files changed

+31
-25
lines changed

4 files changed

+31
-25
lines changed

api/compute/v1alpha1/function_types.go

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -161,10 +161,10 @@ type SourceConnectorSpec struct {
161161
// Archive points to a nar archive containing the connector. It can reference built-in connectors using the
162162
// builtin:// scheme.
163163
// +kubebuilder:validation:Optional
164-
Archive string `json:"archive,omitempty"`
164+
SourceType string `json:"sourceType,omitempty"` // refer to `--source-type` as builtin connector
165165
// Builtin holds the resolved name of a built-in source connector.
166166
// +kubebuilder:validation:Optional
167-
Builtin string `json:"builtin,omitempty"`
167+
BatchSourceConfig *BatchSourceConfig `json:"batchSourceConfig,omitempty"`
168168
// ClassName is the fully qualified source implementation class.
169169
// +kubebuilder:validation:Optional
170170
ClassName string `json:"className,omitempty"`
@@ -179,13 +179,6 @@ type SourceConnectorSpec struct {
179179

180180
// SinkConnectorSpec describes configurable fields when a function overrides its sink implementation.
181181
type SinkConnectorSpec struct {
182-
// Archive points to a nar archive containing the connector. It can reference built-in connectors using the
183-
// builtin:// scheme.
184-
// +kubebuilder:validation:Optional
185-
Archive string `json:"archive,omitempty"`
186-
// Builtin holds the resolved name of a built-in sink connector.
187-
// +kubebuilder:validation:Optional
188-
Builtin string `json:"builtin,omitempty"`
189182
// SinkType refers to the built-in sink identifier when using connectors packaged with Pulsar.
190183
// +kubebuilder:validation:Optional
191184
SinkType string `json:"sinkType,omitempty"`

api/compute/v1alpha1/zz_generated.deepcopy.go

Lines changed: 5 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

config/crd/bases/compute.functionmesh.io_functionmeshes.yaml

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3712,10 +3712,6 @@ spec:
37123712
type: boolean
37133713
sinkConfig:
37143714
properties:
3715-
archive:
3716-
type: string
3717-
builtin:
3718-
type: string
37193715
className:
37203716
type: string
37213717
configs:
@@ -3730,15 +3726,23 @@ spec:
37303726
type: boolean
37313727
sourceConfig:
37323728
properties:
3733-
archive:
3734-
type: string
3735-
builtin:
3736-
type: string
3729+
batchSourceConfig:
3730+
properties:
3731+
discoveryTriggererClassName:
3732+
type: string
3733+
discoveryTriggererConfig:
3734+
type: object
3735+
x-kubernetes-preserve-unknown-fields: true
3736+
required:
3737+
- discoveryTriggererClassName
3738+
type: object
37373739
className:
37383740
type: string
37393741
configs:
37403742
type: object
37413743
x-kubernetes-preserve-unknown-fields: true
3744+
sourceType:
3745+
type: string
37423746
typeClassName:
37433747
type: string
37443748
type: object

config/crd/bases/compute.functionmesh.io_functions.yaml

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3709,10 +3709,6 @@ spec:
37093709
type: boolean
37103710
sinkConfig:
37113711
properties:
3712-
archive:
3713-
type: string
3714-
builtin:
3715-
type: string
37163712
className:
37173713
type: string
37183714
configs:
@@ -3727,15 +3723,23 @@ spec:
37273723
type: boolean
37283724
sourceConfig:
37293725
properties:
3730-
archive:
3731-
type: string
3732-
builtin:
3733-
type: string
3726+
batchSourceConfig:
3727+
properties:
3728+
discoveryTriggererClassName:
3729+
type: string
3730+
discoveryTriggererConfig:
3731+
type: object
3732+
x-kubernetes-preserve-unknown-fields: true
3733+
required:
3734+
- discoveryTriggererClassName
3735+
type: object
37343736
className:
37353737
type: string
37363738
configs:
37373739
type: object
37383740
x-kubernetes-preserve-unknown-fields: true
3741+
sourceType:
3742+
type: string
37393743
typeClassName:
37403744
type: string
37413745
type: object

0 commit comments

Comments
 (0)