Documentation ¶
Overview ¶
+k8s:deepcopy-gen=package +groupName=eventing.knative.dev
Index ¶
- Constants
- Variables
- func ErrImmutableField(field string) *apis.FieldError
- func Kind(kind string) schema.GroupKind
- func RegisterConditionSet(cs apis.ConditionSet)
- func Resource(resource string) schema.GroupResource
- type Auth
- type KafkaSink
- func (ks *KafkaSink) CheckImmutableFields(ctx context.Context, original *KafkaSink) *apis.FieldError
- func (ks *KafkaSink) ConvertFrom(ctx context.Context, from apis.Convertible) error
- func (ks *KafkaSink) ConvertTo(ctx context.Context, to apis.Convertible) error
- func (in *KafkaSink) DeepCopy() *KafkaSink
- func (in *KafkaSink) DeepCopyInto(out *KafkaSink)
- func (in *KafkaSink) DeepCopyObject() runtime.Object
- func (ks *KafkaSink) GetConditionSet() apis.ConditionSet
- func (ks *KafkaSink) GetGroupVersionKind() schema.GroupVersionKind
- func (ks *KafkaSink) GetStatus() *duckv1.Status
- func (ks *KafkaSink) GetUntypedSpec() interface{}
- func (ks *KafkaSink) SetDefaults(ctx context.Context)
- func (ks *KafkaSink) Validate(ctx context.Context) *apis.FieldError
- type KafkaSinkList
- type KafkaSinkSpec
- func (kss *KafkaSinkSpec) CheckImmutableFields(ctx context.Context, original *KafkaSinkSpec) *apis.FieldError
- func (in *KafkaSinkSpec) DeepCopy() *KafkaSinkSpec
- func (in *KafkaSinkSpec) DeepCopyInto(out *KafkaSinkSpec)
- func (kss KafkaSinkSpec) HasAuthConfig() bool
- func (kss *KafkaSinkSpec) SetDefaults(ctx context.Context)
- func (kss *KafkaSinkSpec) Validate(ctx context.Context) *apis.FieldError
- type KafkaSinkStatus
- type Secret
- type SecretReference
Constants ¶
const ( // CloudEvents binary content mode. ModeBinary = "binary" // CloudEvents structured content mode. ModeStructured = "structured" )
const (
ConditionAddressable apis.ConditionType = "Addressable"
)
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: eventing.GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects.
Functions ¶
func ErrImmutableField ¶
func ErrImmutableField(field string) *apis.FieldError
func RegisterConditionSet ¶
func RegisterConditionSet(cs apis.ConditionSet)
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource.
Types ¶
type Auth ¶ added in v0.21.0
type Auth struct { // Auth Secret Secret *Secret `json:"secret,omitempty"` }
func (*Auth) DeepCopy ¶ added in v0.21.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Auth.
func (*Auth) DeepCopyInto ¶ added in v0.21.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSink ¶
type KafkaSink struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` // Spec defines the desired state of the Kafka Sink. Spec KafkaSinkSpec `json:"spec,omitempty"` // Status represents the current state of the KafkaSink. // This data may be out of date. // +optional Status KafkaSinkStatus `json:"status,omitempty"` }
KafkaSink is an addressable resource that represent a Kafka topic.
func (*KafkaSink) CheckImmutableFields ¶
func (*KafkaSink) ConvertFrom ¶
func (*KafkaSink) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSink.
func (*KafkaSink) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaSink) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*KafkaSink) GetConditionSet ¶
func (ks *KafkaSink) GetConditionSet() apis.ConditionSet
func (*KafkaSink) GetGroupVersionKind ¶
func (ks *KafkaSink) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns GroupVersionKind for KafkaSinks.
func (*KafkaSink) GetStatus ¶
GetStatus retrieves the status of the Kafka Sink. Implements the KRShaped interface.
func (*KafkaSink) GetUntypedSpec ¶
func (ks *KafkaSink) GetUntypedSpec() interface{}
GetUntypedSpec returns the spec of the Kafka Sink.
func (*KafkaSink) SetDefaults ¶
SetDefaults sets KafkaSink defaults.
type KafkaSinkList ¶
type KafkaSinkList struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ListMeta `json:"metadata,omitempty"` Items []KafkaSink `json:"items"` }
KafkaSinkList defines a list of Kafka Sink.
func (*KafkaSinkList) DeepCopy ¶
func (in *KafkaSinkList) DeepCopy() *KafkaSinkList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSinkList.
func (*KafkaSinkList) DeepCopyInto ¶
func (in *KafkaSinkList) DeepCopyInto(out *KafkaSinkList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaSinkList) DeepCopyObject ¶
func (in *KafkaSinkList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaSinkSpec ¶
type KafkaSinkSpec struct { // Topic name to send events. Topic string `json:"topic"` // Number of topic partitions. // +optional NumPartitions *int32 `json:"numPartitions,omitempty"` // Topic replication factor // +optional ReplicationFactor *int16 `json:"replicationFactor,omitempty"` // Kafka Broker bootstrap servers. BootstrapServers []string `json:"bootstrapServers"` // CloudEvent content mode of Kafka messages sent to the topic. // Possible values: // - structured // - binary // // - default: structured. // // - https://github.com/cloudevents/spec/blob/v1.0/spec.md#message // - https://github.com/cloudevents/spec/blob/v1.0/kafka-protocol-binding.md#33-structured-content-mode // - https://github.com/cloudevents/spec/blob/v1.0/kafka-protocol-binding.md#32-binary-content-mode' // // +optional ContentMode *string `json:"contentMode,omitempty"` // Auth configurations. Auth *Auth `json:"auth,omitempty"` }
KafkaSinkSpec defines the desired state of the Kafka Sink.
func (*KafkaSinkSpec) CheckImmutableFields ¶
func (kss *KafkaSinkSpec) CheckImmutableFields(ctx context.Context, original *KafkaSinkSpec) *apis.FieldError
func (*KafkaSinkSpec) DeepCopy ¶
func (in *KafkaSinkSpec) DeepCopy() *KafkaSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSinkSpec.
func (*KafkaSinkSpec) DeepCopyInto ¶
func (in *KafkaSinkSpec) DeepCopyInto(out *KafkaSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (KafkaSinkSpec) HasAuthConfig ¶ added in v0.21.0
func (kss KafkaSinkSpec) HasAuthConfig() bool
func (*KafkaSinkSpec) SetDefaults ¶
func (kss *KafkaSinkSpec) SetDefaults(ctx context.Context)
SetDefaults sets KafkaSinkSpec defaults.
func (*KafkaSinkSpec) Validate ¶
func (kss *KafkaSinkSpec) Validate(ctx context.Context) *apis.FieldError
type KafkaSinkStatus ¶
type KafkaSinkStatus struct { // inherits duck/v1 Status, which currently provides: // * ObservedGeneration - the 'Generation' of the Kafka Sink that was last processed by the controller. // * Conditions - the latest available observations of a resource's current state. duckv1.Status `json:",inline"` // Kafka Sink is Addressable. Address duckv1.Addressable `json:"address,omitempty"` }
KafkaSinkStatus represents the current state of the KafkaSink.
func (*KafkaSinkStatus) DeepCopy ¶
func (in *KafkaSinkStatus) DeepCopy() *KafkaSinkStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSinkStatus.
func (*KafkaSinkStatus) DeepCopyInto ¶
func (in *KafkaSinkStatus) DeepCopyInto(out *KafkaSinkStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaSinkStatus) GetConditionSet ¶
func (ks *KafkaSinkStatus) GetConditionSet() apis.ConditionSet
func (*KafkaSinkStatus) InitializeConditions ¶
func (kss *KafkaSinkStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*KafkaSinkStatus) SetAddress ¶
func (ks *KafkaSinkStatus) SetAddress(url *apis.URL)
SetAddress makes this Kafka Sink addressable by setting the URI. It also sets the ConditionAddressable to true.
type Secret ¶ added in v0.21.0
type Secret struct { // Secret reference for SASL and SSL configurations. Ref *SecretReference `json:"ref,omitempty"` }
func (*Secret) DeepCopy ¶ added in v0.21.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Secret.
func (*Secret) DeepCopyInto ¶ added in v0.21.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SecretReference ¶ added in v0.21.0
type SecretReference struct { // Secret name. Name string `json:"name"` }
func (*SecretReference) DeepCopy ¶ added in v0.21.0
func (in *SecretReference) DeepCopy() *SecretReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretReference.
func (*SecretReference) DeepCopyInto ¶ added in v0.21.0
func (in *SecretReference) DeepCopyInto(out *SecretReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.