Versions in this module Expand all Collapse all v0 v0.43.1 Nov 11, 2024 v0.43.0 Oct 22, 2024 Changes in this version + const KafkaBindingConditionReady + var AddToScheme = SchemeBuilder.AddToScheme + var FuzzerFuncs = fuzzer.MergeFuzzerFuncs(func(codecs serializer.CodecFactory) []interface{} { ... }) + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + func Kind(kind string) schema.GroupKind + func RegisterDefaults(scheme *runtime.Scheme) error + func Resource(resource string) schema.GroupResource + type KafkaAuthSpec struct + BootstrapServers []string + Net KafkaNetSpec + func (in *KafkaAuthSpec) DeepCopy() *KafkaAuthSpec + func (in *KafkaAuthSpec) DeepCopyInto(out *KafkaAuthSpec) + func (sink *KafkaAuthSpec) ConvertFrom(_ context.Context, source apis.Convertible) error + func (source *KafkaAuthSpec) ConvertTo(_ context.Context, sink apis.Convertible) error + type KafkaBinding struct + Spec KafkaBindingSpec + Status KafkaBindingStatus + func (*KafkaBinding) GetConditionSet() apis.ConditionSet + func (*KafkaBinding) GetGroupVersionKind() schema.GroupVersionKind + func (in *KafkaBinding) DeepCopy() *KafkaBinding + func (in *KafkaBinding) DeepCopyInto(out *KafkaBinding) + func (in *KafkaBinding) DeepCopyObject() runtime.Object + func (k *KafkaBinding) GetStatus() *duckv1.Status + func (kfb *KafkaBinding) Do(ctx context.Context, ps *duckv1.WithPod) + func (kfb *KafkaBinding) Undo(ctx context.Context, ps *duckv1.WithPod) + func (r *KafkaBinding) SetDefaults(ctx context.Context) + func (r *KafkaBinding) Validate(ctx context.Context) *apis.FieldError + func (s *KafkaBinding) GetUntypedSpec() interface{} + func (sb *KafkaBinding) GetBindingStatus() duck.BindableStatus + func (sb *KafkaBinding) GetSubject() tracker.Reference + func (sink *KafkaBinding) ConvertFrom(_ context.Context, source apis.Convertible) error + func (source *KafkaBinding) ConvertTo(_ context.Context, sink apis.Convertible) error + type KafkaBindingList struct + Items []KafkaBinding + func (in *KafkaBindingList) DeepCopy() *KafkaBindingList + func (in *KafkaBindingList) DeepCopyInto(out *KafkaBindingList) + func (in *KafkaBindingList) DeepCopyObject() runtime.Object + type KafkaBindingSpec struct + func (in *KafkaBindingSpec) DeepCopy() *KafkaBindingSpec + func (in *KafkaBindingSpec) DeepCopyInto(out *KafkaBindingSpec) + type KafkaBindingStatus struct + 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 struct + SASL KafkaSASLSpec + TLS KafkaTLSSpec + func (in *KafkaNetSpec) DeepCopy() *KafkaNetSpec + func (in *KafkaNetSpec) DeepCopyInto(out *KafkaNetSpec) + type KafkaSASLSpec struct + Enable bool + Password SecretValueFromSource + Type SecretValueFromSource + User SecretValueFromSource + func (in *KafkaSASLSpec) DeepCopy() *KafkaSASLSpec + func (in *KafkaSASLSpec) DeepCopyInto(out *KafkaSASLSpec) + type KafkaTLSSpec struct + CACert SecretValueFromSource + Cert SecretValueFromSource + Enable bool + Key SecretValueFromSource + func (in *KafkaTLSSpec) DeepCopy() *KafkaTLSSpec + func (in *KafkaTLSSpec) DeepCopyInto(out *KafkaTLSSpec) + type SecretValueFromSource struct + SecretKeyRef *corev1.SecretKeySelector + func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource + func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)
Go to main page