Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type KafkaAuthSpec
- type KafkaBinding
- func (sink *KafkaBinding) ConvertFrom(ctx context.Context, obj apis.Convertible) error
- func (source *KafkaBinding) ConvertTo(ctx context.Context, obj apis.Convertible) error
- func (in *KafkaBinding) DeepCopy() *KafkaBinding
- func (in *KafkaBinding) DeepCopyInto(out *KafkaBinding)
- func (in *KafkaBinding) DeepCopyObject() runtime.Object
- func (kfb *KafkaBinding) Do(ctx context.Context, ps *duckv1.WithPod)
- func (sb *KafkaBinding) GetBindingStatus() duck.BindableStatus
- func (*KafkaBinding) GetConditionSet() apis.ConditionSet
- func (*KafkaBinding) GetGroupVersionKind() schema.GroupVersionKind
- func (k *KafkaBinding) GetStatus() *duckv1.Status
- func (sb *KafkaBinding) GetSubject() tracker.Reference
- func (s *KafkaBinding) GetUntypedSpec() interface{}
- func (r *KafkaBinding) SetDefaults(ctx context.Context)
- func (kfb *KafkaBinding) Undo(ctx context.Context, ps *duckv1.WithPod)
- func (r *KafkaBinding) Validate(ctx context.Context) *apis.FieldError
- type KafkaBindingList
- type KafkaBindingSpec
- type KafkaBindingStatus
- func (in *KafkaBindingStatus) DeepCopy() *KafkaBindingStatus
- func (in *KafkaBindingStatus) DeepCopyInto(out *KafkaBindingStatus)
- func (sbs *KafkaBindingStatus) InitializeConditions()
- func (sbs *KafkaBindingStatus) MarkBindingAvailable()
- func (sbs *KafkaBindingStatus) MarkBindingUnavailable(reason, message string)
- func (sbs *KafkaBindingStatus) SetObservedGeneration(gen int64)
- type KafkaNetSpec
- type KafkaSASLSpec
- type KafkaTLSSpec
- type SecretValueFromSource
Constants ¶
const ( // KafkaBindingConditionReady is configured to indicate whether the Binding // has been configured for resources subject to its runtime contract. KafkaBindingConditionReady = apis.ConditionReady )
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: bindings.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 KafkaAuthSpec ¶
type KafkaAuthSpec struct { // Bootstrap servers are the Kafka servers the consumer will connect to. // +required BootstrapServers []string `json:"bootstrapServers"` Net KafkaNetSpec `json:"net,omitempty"` }
func (*KafkaAuthSpec) ConvertFrom ¶ added in v0.16.0
func (sink *KafkaAuthSpec) ConvertFrom(_ context.Context, obj apis.Convertible) error
ConvertFrom implements apis.Convertible. Converts obj from v1beta1.KafkaAuthSpec into v1alpha1.KafkaAuthSpec
func (*KafkaAuthSpec) ConvertTo ¶ added in v0.16.0
func (source *KafkaAuthSpec) ConvertTo(_ context.Context, obj apis.Convertible) error
ConvertTo implements apis.Convertible. Converts source (from v1alpha1.KafkaAuthSpec) into v1beta1.KafkaAuthSpec
func (*KafkaAuthSpec) DeepCopy ¶
func (in *KafkaAuthSpec) DeepCopy() *KafkaAuthSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaAuthSpec.
func (*KafkaAuthSpec) DeepCopyInto ¶
func (in *KafkaAuthSpec) DeepCopyInto(out *KafkaAuthSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaBinding ¶
type KafkaBinding struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec KafkaBindingSpec `json:"spec,omitempty"` Status KafkaBindingStatus `json:"status,omitempty"` }
+genclient +genreconciler +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object KafkaBinding is the Schema for the kafkasources API. +k8s:openapi-gen=true
func (*KafkaBinding) ConvertFrom ¶ added in v0.16.0
func (sink *KafkaBinding) ConvertFrom(ctx context.Context, obj apis.Convertible) error
ConvertFrom implements apis.Convertible. Converts obj from v1beta1.KafkaBinding into v1alpha1.KafkaBinding
func (*KafkaBinding) ConvertTo ¶ added in v0.16.0
func (source *KafkaBinding) ConvertTo(ctx context.Context, obj apis.Convertible) error
ConvertTo implements apis.Convertible. Converts source (from v1alpha1.KafkaBinding) into v1beta1.KafkaBinding
func (*KafkaBinding) DeepCopy ¶
func (in *KafkaBinding) DeepCopy() *KafkaBinding
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaBinding.
func (*KafkaBinding) DeepCopyInto ¶
func (in *KafkaBinding) DeepCopyInto(out *KafkaBinding)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaBinding) DeepCopyObject ¶
func (in *KafkaBinding) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*KafkaBinding) Do ¶
func (kfb *KafkaBinding) Do(ctx context.Context, ps *duckv1.WithPod)
Do implements psbinding.Bindable
func (*KafkaBinding) GetBindingStatus ¶
func (sb *KafkaBinding) GetBindingStatus() duck.BindableStatus
GetBindingStatus implements psbinding.Bindable
func (*KafkaBinding) GetConditionSet ¶ added in v0.16.0
func (*KafkaBinding) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*KafkaBinding) GetGroupVersionKind ¶
func (*KafkaBinding) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*KafkaBinding) GetStatus ¶ added in v0.16.0
func (k *KafkaBinding) GetStatus() *duckv1.Status
GetStatus retrieves the duck status for this resource. Implements the KRShaped interface.
func (*KafkaBinding) GetSubject ¶
func (sb *KafkaBinding) GetSubject() tracker.Reference
GetSubject implements psbinding.Bindable
func (*KafkaBinding) GetUntypedSpec ¶
func (s *KafkaBinding) GetUntypedSpec() interface{}
GetUntypedSpec implements apis.HasSpec
func (*KafkaBinding) SetDefaults ¶
func (r *KafkaBinding) SetDefaults(ctx context.Context)
SetDefaults ensures KafkaBinding reflects the default values.
func (*KafkaBinding) Validate ¶
func (r *KafkaBinding) Validate(ctx context.Context) *apis.FieldError
Validate ensures KafkaBinding is properly configured.
type KafkaBindingList ¶
type KafkaBindingList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []KafkaBinding `json:"items"` }
KafkaBindingList contains a list of KafkaBindings.
func (*KafkaBindingList) DeepCopy ¶
func (in *KafkaBindingList) DeepCopy() *KafkaBindingList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaBindingList.
func (*KafkaBindingList) DeepCopyInto ¶
func (in *KafkaBindingList) DeepCopyInto(out *KafkaBindingList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaBindingList) DeepCopyObject ¶
func (in *KafkaBindingList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaBindingSpec ¶
type KafkaBindingSpec struct { duckv1alpha1.BindingSpec `json:",inline"` KafkaAuthSpec `json:",inline"` }
KafkaBindingSpec defines the desired state of the KafkaBinding.
func (*KafkaBindingSpec) DeepCopy ¶
func (in *KafkaBindingSpec) DeepCopy() *KafkaBindingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaBindingSpec.
func (*KafkaBindingSpec) DeepCopyInto ¶
func (in *KafkaBindingSpec) DeepCopyInto(out *KafkaBindingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaBindingStatus ¶
KafkaBindingStatus defines the observed state of KafkaBinding.
func (*KafkaBindingStatus) DeepCopy ¶
func (in *KafkaBindingStatus) DeepCopy() *KafkaBindingStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaBindingStatus.
func (*KafkaBindingStatus) DeepCopyInto ¶
func (in *KafkaBindingStatus) DeepCopyInto(out *KafkaBindingStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaBindingStatus) InitializeConditions ¶
func (sbs *KafkaBindingStatus) InitializeConditions()
InitializeConditions populates the KafkaBindingStatus's conditions field with all of its conditions configured to Unknown.
func (*KafkaBindingStatus) MarkBindingAvailable ¶
func (sbs *KafkaBindingStatus) MarkBindingAvailable()
MarkBindingAvailable marks the KafkaBinding's Ready condition to True.
func (*KafkaBindingStatus) MarkBindingUnavailable ¶
func (sbs *KafkaBindingStatus) MarkBindingUnavailable(reason, message string)
MarkBindingUnavailable marks the KafkaBinding's Ready condition to False with the provided reason and message.
func (*KafkaBindingStatus) SetObservedGeneration ¶
func (sbs *KafkaBindingStatus) SetObservedGeneration(gen int64)
SetObservedGeneration implements psbinding.BindableStatus
type KafkaNetSpec ¶
type KafkaNetSpec struct { SASL KafkaSASLSpec `json:"sasl,omitempty"` TLS KafkaTLSSpec `json:"tls,omitempty"` }
func (*KafkaNetSpec) DeepCopy ¶
func (in *KafkaNetSpec) DeepCopy() *KafkaNetSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaNetSpec.
func (*KafkaNetSpec) DeepCopyInto ¶
func (in *KafkaNetSpec) DeepCopyInto(out *KafkaNetSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSASLSpec ¶
type KafkaSASLSpec struct { Enable bool `json:"enable,omitempty"` // User is the Kubernetes secret containing the SASL username. // +optional User SecretValueFromSource `json:"user,omitempty"` // Password is the Kubernetes secret containing the SASL password. // +optional Password SecretValueFromSource `json:"password,omitempty"` // Type of saslType, defaults to plain (vs SCRAM-SHA-512 or SCRAM-SHA-256) // +optional Type SecretValueFromSource `json:"type,omitempty"` }
func (*KafkaSASLSpec) DeepCopy ¶
func (in *KafkaSASLSpec) DeepCopy() *KafkaSASLSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSASLSpec.
func (*KafkaSASLSpec) DeepCopyInto ¶
func (in *KafkaSASLSpec) DeepCopyInto(out *KafkaSASLSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaTLSSpec ¶
type KafkaTLSSpec struct { Enable bool `json:"enable,omitempty"` // Cert is the Kubernetes secret containing the client certificate. // +optional Cert SecretValueFromSource `json:"cert,omitempty"` // Key is the Kubernetes secret containing the client key. // +optional Key SecretValueFromSource `json:"key,omitempty"` // CACert is the Kubernetes secret containing the server CA cert. // +optional CACert SecretValueFromSource `json:"caCert,omitempty"` }
func (*KafkaTLSSpec) DeepCopy ¶
func (in *KafkaTLSSpec) DeepCopy() *KafkaTLSSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTLSSpec.
func (*KafkaTLSSpec) DeepCopyInto ¶
func (in *KafkaTLSSpec) DeepCopyInto(out *KafkaTLSSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SecretValueFromSource ¶
type SecretValueFromSource struct { // The Secret key to select from. SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"` }
SecretValueFromSource represents the source of a secret value
func (*SecretValueFromSource) DeepCopy ¶
func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretValueFromSource.
func (*SecretValueFromSource) DeepCopyInto ¶
func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.