v1

package
v0.43.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev

Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev

Index

Constants

View Source 
const (
	// KafkaBindingConditionReady is configured to indicate whether the Binding
	// has been configured for resources subject to its runtime contract.
	KafkaBindingConditionReady = apis.ConditionReady
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var FuzzerFuncs = fuzzer.MergeFuzzerFuncs(
	func(codecs serializer.CodecFactory) []interface{} {
		return []interface{}{
			func(s *KafkaBindingStatus, c fuzz.Continue) {
				c.FuzzNoCustom(s)

				s.Status.SetConditions(nil)

				s.InitializeConditions()
				pkgfuzzer.FuzzConditions(&s.Status, c)
			},
		}
	},
)

FuzzerFuncs includes fuzzing funcs for bindings.knative.dev v1 types

For other examples see https://github.com/kubernetes/apimachinery/blob/master/pkg/apis/meta/fuzzer/fuzzer.go

View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: bindings.GroupName, Version: "v1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

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 

func (sink *KafkaAuthSpec) ConvertFrom(_ context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*KafkaAuthSpec) ConvertTo 

func (source *KafkaAuthSpec) ConvertTo(_ context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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 

func (sink *KafkaBinding) ConvertFrom(_ context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*KafkaBinding) ConvertTo 

func (source *KafkaBinding) ConvertTo(_ context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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 

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 

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) Undo 

func (kfb *KafkaBinding) Undo(ctx context.Context, ps *duckv1.WithPod)

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 

type KafkaBindingStatus struct {
	duckv1.Status `json:",inline"`
}

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.