Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the flow/v1alpha1 API group.
+k8s:deepcopy-gen=package +groupName=flow.typhoon.zeiss.com
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type Bridge
- func (in *Bridge) DeepCopy() *Bridge
- func (in *Bridge) DeepCopyInto(out *Bridge)
- func (in *Bridge) DeepCopyObject() runtime.Object
- func (t *Bridge) GetConditionSet() apis.ConditionSet
- func (*Bridge) GetGroupVersionKind() schema.GroupVersionKind
- func (t *Bridge) GetStatus() *duckv1.Status
- func (t *Bridge) GetStatusManager() *v1alpha1.StatusManager
- type BridgeList
- type BridgeObject_Transformation
- type BridgeSpec
- type Component
- type Correlation
- type EventOptions
- type JQTransformation
- func (in *JQTransformation) DeepCopy() *JQTransformation
- func (in *JQTransformation) DeepCopyInto(out *JQTransformation)
- func (in *JQTransformation) DeepCopyObject() runtime.Object
- func (t *JQTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
- func (t *JQTransformation) GetConditionSet() apis.ConditionSet
- func (*JQTransformation) GetGroupVersionKind() schema.GroupVersionKind
- func (t *JQTransformation) GetSink() *duckv1.Destination
- func (t *JQTransformation) GetStatus() *duckv1.Status
- func (t *JQTransformation) GetStatusManager() *v1alpha1.StatusManager
- func (t *JQTransformation) SetDefaults(ctx context.Context)
- func (t *JQTransformation) Validate(ctx context.Context) *apis.FieldError
- type JQTransformationList
- type JQTransformationSpec
- type Path
- type Response
- type Synchronizer
- func (in *Synchronizer) DeepCopy() *Synchronizer
- func (in *Synchronizer) DeepCopyInto(out *Synchronizer)
- func (in *Synchronizer) DeepCopyObject() runtime.Object
- func (s *Synchronizer) GetAdapterOverrides() *v1alpha1.AdapterOverrides
- func (s *Synchronizer) GetConditionSet() apis.ConditionSet
- func (*Synchronizer) GetGroupVersionKind() schema.GroupVersionKind
- func (s *Synchronizer) GetSink() *duckv1.Destination
- func (s *Synchronizer) GetStatus() *duckv1.Status
- func (s *Synchronizer) GetStatusManager() *v1alpha1.StatusManager
- func (s *Synchronizer) SetDefaults(ctx context.Context)
- func (s *Synchronizer) Validate(ctx context.Context) *apis.FieldError
- type SynchronizerList
- type SynchronizerSpec
- type Transform
- type Transformation
- func (in *Transformation) DeepCopy() *Transformation
- func (in *Transformation) DeepCopyInto(out *Transformation)
- func (in *Transformation) DeepCopyObject() runtime.Object
- func (t *Transformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
- func (t *Transformation) GetConditionSet() apis.ConditionSet
- func (*Transformation) GetGroupVersionKind() schema.GroupVersionKind
- func (t *Transformation) GetSink() *duckv1.Destination
- func (t *Transformation) GetStatus() *duckv1.Status
- func (t *Transformation) GetStatusManager() *v1alpha1.StatusManager
- func (t *Transformation) SetDefaults(ctx context.Context)
- func (t *Transformation) Validate(ctx context.Context) *apis.FieldError
- type TransformationList
- type TransformationSpec
- type ValueFromField
- func (in *ValueFromField) DeepCopy() *ValueFromField
- func (in *ValueFromField) DeepCopyInto(out *ValueFromField)
- func (v *ValueFromField) IsInformed() bool
- func (v *ValueFromField) ToEnvironmentVariable(name string) *corev1.EnvVar
- func (v *ValueFromField) Validate(_ context.Context) *apis.FieldError
- type XMLToJSONTransformation
- func (in *XMLToJSONTransformation) DeepCopy() *XMLToJSONTransformation
- func (in *XMLToJSONTransformation) DeepCopyInto(out *XMLToJSONTransformation)
- func (in *XMLToJSONTransformation) DeepCopyObject() runtime.Object
- func (t *XMLToJSONTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
- func (t *XMLToJSONTransformation) GetConditionSet() apis.ConditionSet
- func (*XMLToJSONTransformation) GetGroupVersionKind() schema.GroupVersionKind
- func (t *XMLToJSONTransformation) GetSink() *duckv1.Destination
- func (t *XMLToJSONTransformation) GetStatus() *duckv1.Status
- func (t *XMLToJSONTransformation) GetStatusManager() *v1alpha1.StatusManager
- func (t *XMLToJSONTransformation) SetDefaults(ctx context.Context)
- func (t *XMLToJSONTransformation) Validate(ctx context.Context) *apis.FieldError
- type XMLToJSONTransformationList
- type XMLToJSONTransformationSpec
- type XSLTTransformation
- func (in *XSLTTransformation) DeepCopy() *XSLTTransformation
- func (in *XSLTTransformation) DeepCopyInto(out *XSLTTransformation)
- func (in *XSLTTransformation) DeepCopyObject() runtime.Object
- func (t *XSLTTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
- func (t *XSLTTransformation) GetConditionSet() apis.ConditionSet
- func (*XSLTTransformation) GetGroupVersionKind() schema.GroupVersionKind
- func (t *XSLTTransformation) GetSink() *duckv1.Destination
- func (t *XSLTTransformation) GetStatus() *duckv1.Status
- func (t *XSLTTransformation) GetStatusManager() *v1alpha1.StatusManager
- func (t *XSLTTransformation) SetDefaults(ctx context.Context)
- func (t *XSLTTransformation) Validate(ctx context.Context) *apis.FieldError
- type XSLTTransformationList
- type XSLTTransformationSpec
Constants ¶
const (
EventTypeXMLToJSONGenericResponse = "com.zeiss.xmltojsontransformation.error"
)
Managed event types
const (
EventTypeXSLTTransformation = "com.zeiss.xslt.transform"
)
Managed event types
Variables ¶
var ( // SchemeBuilder creates a Scheme builder that is used to register types for this custom API. SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme registers the types stored in SchemeBuilder. AddToScheme = SchemeBuilder.AddToScheme )
var AllTypes = []v1alpha1.GroupObject{ {Single: &JQTransformation{}, List: &JQTransformationList{}}, {Single: &Synchronizer{}, List: &SynchronizerList{}}, {Single: &Transformation{}, List: &TransformationList{}}, {Single: &XMLToJSONTransformation{}, List: &XMLToJSONTransformationList{}}, {Single: &XSLTTransformation{}, List: &XSLTTransformationList{}}, }
AllTypes is a list of all the types defined in this package.
var SchemeGroupVersion = schema.GroupVersion{Group: flow.GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type Bridge ¶ added in v0.1.14
type Bridge struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec BridgeSpec `json:"spec"` Status v1alpha1.Status `json:"status,omitempty"` }
Bridge is the Schema for the Bridge target.
func (*Bridge) DeepCopy ¶ added in v0.1.14
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Bridge.
func (*Bridge) DeepCopyInto ¶ added in v0.1.14
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Bridge) DeepCopyObject ¶ added in v0.1.14
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Bridge) GetConditionSet ¶ added in v0.1.14
func (t *Bridge) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*Bridge) GetGroupVersionKind ¶ added in v0.1.14
func (*Bridge) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*Bridge) GetStatusManager ¶ added in v0.1.14
func (t *Bridge) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
type BridgeList ¶ added in v0.1.14
type BridgeList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Bridge `json:"items"` }
BridgeList is a list of component instances.
func (*BridgeList) DeepCopy ¶ added in v0.1.14
func (in *BridgeList) DeepCopy() *BridgeList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BridgeList.
func (*BridgeList) DeepCopyInto ¶ added in v0.1.14
func (in *BridgeList) DeepCopyInto(out *BridgeList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BridgeList) DeepCopyObject ¶ added in v0.1.14
func (in *BridgeList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type BridgeObject_Transformation ¶ added in v0.1.14
type BridgeObject_Transformation struct {
Transformation TransformationSpec
}
BridgeObject_Transformation is a component of a bridge.
func (*BridgeObject_Transformation) DeepCopy ¶ added in v0.1.14
func (in *BridgeObject_Transformation) DeepCopy() *BridgeObject_Transformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BridgeObject_Transformation.
func (*BridgeObject_Transformation) DeepCopyInto ¶ added in v0.1.14
func (in *BridgeObject_Transformation) DeepCopyInto(out *BridgeObject_Transformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BridgeSpec ¶ added in v0.1.14
type BridgeSpec struct {
Components []Component `json:"components"`
}
BridgeSpec defines the desired state of the component.
func (*BridgeSpec) DeepCopy ¶ added in v0.1.14
func (in *BridgeSpec) DeepCopy() *BridgeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BridgeSpec.
func (*BridgeSpec) DeepCopyInto ¶ added in v0.1.14
func (in *BridgeSpec) DeepCopyInto(out *BridgeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Component ¶ added in v0.1.14
type Component struct { // Object is the component object. // +optional // +nullable // +kubebuilder:pruning:PreserveUnknownFields // x-kubernetes-embedded-resource: false Object runtime.RawExtension `json:"object,omitempty"` }
Component holds a component of a bridge.
func (*Component) DeepCopy ¶ added in v0.1.14
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Component.
func (*Component) DeepCopyInto ¶ added in v0.1.14
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Correlation ¶
Correlation holds the request-response matching parameters.
func (*Correlation) DeepCopy ¶
func (in *Correlation) DeepCopy() *Correlation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Correlation.
func (*Correlation) DeepCopyInto ¶
func (in *Correlation) DeepCopyInto(out *Correlation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventOptions ¶
type EventOptions struct { // PayloadPolicy indicates if replies from the target should include // a payload if available. Possible values are: // // - always: will return a with the reply payload if avaliable. // - errors: will only reply with payload in case of an error. // - never: will not reply with payload. // // +optional PayloadPolicy *cloudevents.PayloadPolicy `json:"payloadPolicy,omitempty"` }
EventOptions modifies CloudEvents management at Targets.
func (*EventOptions) DeepCopy ¶
func (in *EventOptions) DeepCopy() *EventOptions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventOptions.
func (*EventOptions) DeepCopyInto ¶
func (in *EventOptions) DeepCopyInto(out *EventOptions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JQTransformation ¶
type JQTransformation struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` Spec JQTransformationSpec `json:"spec"` Status v1alpha1.Status `json:"status,omitempty"` }
func (*JQTransformation) DeepCopy ¶
func (in *JQTransformation) DeepCopy() *JQTransformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JQTransformation.
func (*JQTransformation) DeepCopyInto ¶
func (in *JQTransformation) DeepCopyInto(out *JQTransformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*JQTransformation) DeepCopyObject ¶
func (in *JQTransformation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*JQTransformation) GetAdapterOverrides ¶
func (t *JQTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
GetAdapterOverrides implements AdapterConfigurable.
func (*JQTransformation) GetConditionSet ¶
func (t *JQTransformation) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*JQTransformation) GetGroupVersionKind ¶
func (*JQTransformation) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*JQTransformation) GetSink ¶
func (t *JQTransformation) GetSink() *duckv1.Destination
GetSink implements EventSender.
func (*JQTransformation) GetStatus ¶
func (t *JQTransformation) GetStatus() *duckv1.Status
GetStatus implements duckv1.KRShaped.
func (*JQTransformation) GetStatusManager ¶
func (t *JQTransformation) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
func (*JQTransformation) SetDefaults ¶
func (t *JQTransformation) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*JQTransformation) Validate ¶
func (t *JQTransformation) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type JQTransformationList ¶
type JQTransformationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []JQTransformation `json:"items"` }
JQTransformationList is a list of component instances.
func (*JQTransformationList) DeepCopy ¶
func (in *JQTransformationList) DeepCopy() *JQTransformationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JQTransformationList.
func (*JQTransformationList) DeepCopyInto ¶
func (in *JQTransformationList) DeepCopyInto(out *JQTransformationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*JQTransformationList) DeepCopyObject ¶
func (in *JQTransformationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type JQTransformationSpec ¶
type JQTransformationSpec struct { // The query that gets passed to the JQ library Query string `json:"query"` // EventOptions for targets EventOptions *EventOptions `json:"eventOptions,omitempty"` // Support sending to an event sink instead of replying. duckv1.SourceSpec `json:",inline"` // Adapter spec overrides parameters. // +optional AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"` }
JQTransformationSpec defines the desired state of the component.
func (*JQTransformationSpec) DeepCopy ¶
func (in *JQTransformationSpec) DeepCopy() *JQTransformationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JQTransformationSpec.
func (*JQTransformationSpec) DeepCopyInto ¶
func (in *JQTransformationSpec) DeepCopyInto(out *JQTransformationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Path ¶
type Path struct { Key string `json:"key,omitempty"` Value string `json:"value,omitempty"` Separator string `json:"separator,omitempty"` }
Path is a key-value pair that represents JSON object path
func (*Path) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Path.
func (*Path) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Response ¶
Response defines the response handling configuration.
func (*Response) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Response.
func (*Response) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Synchronizer ¶
type Synchronizer struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec SynchronizerSpec `json:"spec"` Status v1alpha1.Status `json:"status,omitempty"` }
Synchronizer is the Schema for the Synchronizer target.
func (*Synchronizer) DeepCopy ¶
func (in *Synchronizer) DeepCopy() *Synchronizer
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Synchronizer.
func (*Synchronizer) DeepCopyInto ¶
func (in *Synchronizer) DeepCopyInto(out *Synchronizer)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Synchronizer) DeepCopyObject ¶
func (in *Synchronizer) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Synchronizer) GetAdapterOverrides ¶
func (s *Synchronizer) GetAdapterOverrides() *v1alpha1.AdapterOverrides
GetAdapterOverrides implements AdapterConfigurable.
func (*Synchronizer) GetConditionSet ¶
func (s *Synchronizer) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*Synchronizer) GetGroupVersionKind ¶
func (*Synchronizer) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*Synchronizer) GetSink ¶
func (s *Synchronizer) GetSink() *duckv1.Destination
GetSink implements EventSender.
func (*Synchronizer) GetStatus ¶
func (s *Synchronizer) GetStatus() *duckv1.Status
GetStatus implements duckv1.KRShaped.
func (*Synchronizer) GetStatusManager ¶
func (s *Synchronizer) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
func (*Synchronizer) SetDefaults ¶
func (s *Synchronizer) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*Synchronizer) Validate ¶
func (s *Synchronizer) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type SynchronizerList ¶
type SynchronizerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Synchronizer `json:"items"` }
SynchronizerList is a list of component instances.
func (*SynchronizerList) DeepCopy ¶
func (in *SynchronizerList) DeepCopy() *SynchronizerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SynchronizerList.
func (*SynchronizerList) DeepCopyInto ¶
func (in *SynchronizerList) DeepCopyInto(out *SynchronizerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SynchronizerList) DeepCopyObject ¶
func (in *SynchronizerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SynchronizerSpec ¶
type SynchronizerSpec struct { CorrelationKey Correlation `json:"correlationKey"` Response Response `json:"response"` // Support sending to an event sink instead of replying. duckv1.SourceSpec `json:",inline"` // Adapter spec overrides parameters. // +optional AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"` }
SynchronizerSpec defines the desired state of the component.
func (*SynchronizerSpec) DeepCopy ¶
func (in *SynchronizerSpec) DeepCopy() *SynchronizerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SynchronizerSpec.
func (*SynchronizerSpec) DeepCopyInto ¶
func (in *SynchronizerSpec) DeepCopyInto(out *SynchronizerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Transform ¶
Transform describes transformation schemes for different CE types.
func (*Transform) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transform.
func (*Transform) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Transformation ¶
type Transformation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TransformationSpec `json:"spec,omitempty"` Status v1alpha1.Status `json:"status,omitempty"` }
Transformation allows to declaratively perform data transformations on CloudEvents.
func (*Transformation) DeepCopy ¶
func (in *Transformation) DeepCopy() *Transformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transformation.
func (*Transformation) DeepCopyInto ¶
func (in *Transformation) DeepCopyInto(out *Transformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Transformation) DeepCopyObject ¶
func (in *Transformation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Transformation) GetAdapterOverrides ¶
func (t *Transformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
GetAdapterOverrides implements AdapterConfigurable.
func (*Transformation) GetConditionSet ¶
func (t *Transformation) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*Transformation) GetGroupVersionKind ¶
func (*Transformation) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*Transformation) GetSink ¶
func (t *Transformation) GetSink() *duckv1.Destination
GetSink implements EventSender.
func (*Transformation) GetStatus ¶
func (t *Transformation) GetStatus() *duckv1.Status
GetStatus implements duckv1.KRShaped.
func (*Transformation) GetStatusManager ¶
func (t *Transformation) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
func (*Transformation) SetDefaults ¶
func (t *Transformation) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*Transformation) Validate ¶
func (t *Transformation) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type TransformationList ¶
type TransformationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Transformation `json:"items"` }
TransformationList is a list of component instances.
func (*TransformationList) DeepCopy ¶
func (in *TransformationList) DeepCopy() *TransformationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TransformationList.
func (*TransformationList) DeepCopyInto ¶
func (in *TransformationList) DeepCopyInto(out *TransformationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TransformationList) DeepCopyObject ¶
func (in *TransformationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TransformationSpec ¶
type TransformationSpec struct { // Context contains Transformations that must be applied on CE Context Context []Transform `json:"context,omitempty"` // Data contains Transformations that must be applied on CE Data Data []Transform `json:"data,omitempty"` // Support sending to an event sink instead of replying. duckv1.SourceSpec `json:",inline"` // Adapter spec overrides parameters. // +optional AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"` }
TransformationSpec defines the desired state of the component.
func (*TransformationSpec) DeepCopy ¶
func (in *TransformationSpec) DeepCopy() *TransformationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TransformationSpec.
func (*TransformationSpec) DeepCopyInto ¶
func (in *TransformationSpec) DeepCopyInto(out *TransformationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TransformationSpec) Validate ¶
func (ts *TransformationSpec) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type ValueFromField ¶
type ValueFromField struct { // Field value. // +optional Value string `json:"value,omitempty"` // Field value from a Kubernetes Secret. // +optional ValueFromSecret *corev1.SecretKeySelector `json:"valueFromSecret,omitempty"` // Field value from a Kubernetes ConfigMap. // +optional ValueFromConfigMap *corev1.ConfigMapKeySelector `json:"valueFromConfigMap,omitempty"` }
ValueFromField is a struct field that can have its value either defined explicitly or sourced from another entity.
func (*ValueFromField) DeepCopy ¶
func (in *ValueFromField) DeepCopy() *ValueFromField
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueFromField.
func (*ValueFromField) DeepCopyInto ¶
func (in *ValueFromField) DeepCopyInto(out *ValueFromField)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ValueFromField) IsInformed ¶
func (v *ValueFromField) IsInformed() bool
IsInformed returns if the value is informed in any of the available choices.
func (*ValueFromField) ToEnvironmentVariable ¶
func (v *ValueFromField) ToEnvironmentVariable(name string) *corev1.EnvVar
ToEnvironmentVariable returns a kubernetes environment variable from a ValueFromField.
func (*ValueFromField) Validate ¶
func (v *ValueFromField) Validate(_ context.Context) *apis.FieldError
Validate makes sure that only one of the choices is properly informed. nolint:gocyclo
type XMLToJSONTransformation ¶
type XMLToJSONTransformation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec XMLToJSONTransformationSpec `json:"spec,omitempty"` Status v1alpha1.Status `json:"status,omitempty"` }
XMLToJSONTransformation is the schema for the event transformer.
func (*XMLToJSONTransformation) DeepCopy ¶
func (in *XMLToJSONTransformation) DeepCopy() *XMLToJSONTransformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XMLToJSONTransformation.
func (*XMLToJSONTransformation) DeepCopyInto ¶
func (in *XMLToJSONTransformation) DeepCopyInto(out *XMLToJSONTransformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*XMLToJSONTransformation) DeepCopyObject ¶
func (in *XMLToJSONTransformation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*XMLToJSONTransformation) GetAdapterOverrides ¶
func (t *XMLToJSONTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
GetAdapterOverrides implements AdapterConfigurable.
func (*XMLToJSONTransformation) GetConditionSet ¶
func (t *XMLToJSONTransformation) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*XMLToJSONTransformation) GetGroupVersionKind ¶
func (*XMLToJSONTransformation) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*XMLToJSONTransformation) GetSink ¶
func (t *XMLToJSONTransformation) GetSink() *duckv1.Destination
GetSink implements EventSender.
func (*XMLToJSONTransformation) GetStatus ¶
func (t *XMLToJSONTransformation) GetStatus() *duckv1.Status
GetStatus implements duckv1.KRShaped.
func (*XMLToJSONTransformation) GetStatusManager ¶
func (t *XMLToJSONTransformation) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
func (*XMLToJSONTransformation) SetDefaults ¶
func (t *XMLToJSONTransformation) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*XMLToJSONTransformation) Validate ¶
func (t *XMLToJSONTransformation) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type XMLToJSONTransformationList ¶
type XMLToJSONTransformationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []XMLToJSONTransformation `json:"items"` }
XMLToJSONTransformationList is a list of component instances.
func (*XMLToJSONTransformationList) DeepCopy ¶
func (in *XMLToJSONTransformationList) DeepCopy() *XMLToJSONTransformationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XMLToJSONTransformationList.
func (*XMLToJSONTransformationList) DeepCopyInto ¶
func (in *XMLToJSONTransformationList) DeepCopyInto(out *XMLToJSONTransformationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*XMLToJSONTransformationList) DeepCopyObject ¶
func (in *XMLToJSONTransformationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type XMLToJSONTransformationSpec ¶
type XMLToJSONTransformationSpec struct { // EventOptions for targets EventOptions *EventOptions `json:"eventOptions,omitempty"` // Support sending to an event sink instead of replying. duckv1.SourceSpec `json:",inline"` // Adapter spec overrides parameters. // +optional AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"` }
XMLToJSONTransformationSpec defines the desired state of the component.
func (*XMLToJSONTransformationSpec) DeepCopy ¶
func (in *XMLToJSONTransformationSpec) DeepCopy() *XMLToJSONTransformationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XMLToJSONTransformationSpec.
func (*XMLToJSONTransformationSpec) DeepCopyInto ¶
func (in *XMLToJSONTransformationSpec) DeepCopyInto(out *XMLToJSONTransformationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type XSLTTransformation ¶
type XSLTTransformation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec XSLTTransformationSpec `json:"spec"` Status v1alpha1.Status `json:"status,omitempty"` }
XSLTTransformation is the Schema for an XSLT transformation target.
func (*XSLTTransformation) DeepCopy ¶
func (in *XSLTTransformation) DeepCopy() *XSLTTransformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XSLTTransformation.
func (*XSLTTransformation) DeepCopyInto ¶
func (in *XSLTTransformation) DeepCopyInto(out *XSLTTransformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*XSLTTransformation) DeepCopyObject ¶
func (in *XSLTTransformation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*XSLTTransformation) GetAdapterOverrides ¶
func (t *XSLTTransformation) GetAdapterOverrides() *v1alpha1.AdapterOverrides
GetAdapterOverrides implements AdapterConfigurable.
func (*XSLTTransformation) GetConditionSet ¶
func (t *XSLTTransformation) GetConditionSet() apis.ConditionSet
GetConditionSet implements duckv1.KRShaped.
func (*XSLTTransformation) GetGroupVersionKind ¶
func (*XSLTTransformation) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable.
func (*XSLTTransformation) GetSink ¶
func (t *XSLTTransformation) GetSink() *duckv1.Destination
GetSink implements EventSender.
func (*XSLTTransformation) GetStatus ¶
func (t *XSLTTransformation) GetStatus() *duckv1.Status
GetStatus implements duckv1.KRShaped.
func (*XSLTTransformation) GetStatusManager ¶
func (t *XSLTTransformation) GetStatusManager() *v1alpha1.StatusManager
GetStatusManager implements Reconcilable.
func (*XSLTTransformation) SetDefaults ¶
func (t *XSLTTransformation) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*XSLTTransformation) Validate ¶
func (t *XSLTTransformation) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type XSLTTransformationList ¶
type XSLTTransformationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []XSLTTransformation `json:"items"` }
XSLTTransformationList is a list of component instances.
func (*XSLTTransformationList) DeepCopy ¶
func (in *XSLTTransformationList) DeepCopy() *XSLTTransformationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XSLTTransformationList.
func (*XSLTTransformationList) DeepCopyInto ¶
func (in *XSLTTransformationList) DeepCopyInto(out *XSLTTransformationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*XSLTTransformationList) DeepCopyObject ¶
func (in *XSLTTransformationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type XSLTTransformationSpec ¶
type XSLTTransformationSpec struct { // XSLT document that will be used by default for transformation. // Can be omited if the XSLT is informed at each event. // +optional XSLT *ValueFromField `json:"xslt,omitempty"` // Whether the default XSLT can be overriden at each event // +optional AllowPerEventXSLT *bool `json:"allowPerEventXSLT,omitempty"` // Support sending to an event sink instead of replying. duckv1.SourceSpec `json:",inline"` // Adapter spec overrides parameters. // +optional AdapterOverrides *v1alpha1.AdapterOverrides `json:"adapterOverrides,omitempty"` }
XSLTTransformationSpec defines the desired state of the component.
func (*XSLTTransformationSpec) DeepCopy ¶
func (in *XSLTTransformationSpec) DeepCopy() *XSLTTransformationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new XSLTTransformationSpec.
func (*XSLTTransformationSpec) DeepCopyInto ¶
func (in *XSLTTransformationSpec) DeepCopyInto(out *XSLTTransformationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*XSLTTransformationSpec) SetDefaults ¶
func (s *XSLTTransformationSpec) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*XSLTTransformationSpec) Validate ¶
func (s *XSLTTransformationSpec) Validate(ctx context.Context) *apis.FieldError
Validate XSLT spec
Source Files ¶
- bridge_lifecycle.go
- bridge_types.go
- common_lifecycle.go
- common_types.go
- common_validation.go
- doc.go
- jqtransformation_lifecycle.go
- jqtransformation_types.go
- register.go
- synchronizer_lifecycle.go
- synchronizer_types.go
- transformation_defaults.go
- transformation_lifecycle.go
- transformation_types.go
- transformation_validation.go
- xmltojsontransformation_lifecycle.go
- xmltojsontransformation_types.go
- xslt_defaults.go
- xslt_lifecycle.go
- xslt_types.go
- xslt_validation.go
- zz_generated.deepcopy.go