v1alpha1

May 18, 2021

Changes in this version

type KafkaSourceStatus

+ Claims string

Apr 7, 2021

Changes in this version

type KafkaSourceStatus

+ Selector string

Jan 13, 2021

Changes in this version

type KafkaSourceSpec

+ Consumers *int32

type KafkaSourceStatus

+ Consumers int32

Nov 10, 2020

Changes in this version

+ const KafkaConditionDeployed

+ const KafkaConditionReady

+ const KafkaConditionResources

+ const KafkaConditionSinkProvided

+ const KafkaEventType

+ const KafkaKeyTypeLabel

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var KafkaKeyTypeAllowed = []string

+ var KafkaSourceCondSet = apis.NewLivingConditionSet(KafkaConditionSinkProvided, KafkaConditionDeployed)

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func DeploymentIsAvailable(d *appsv1.DeploymentStatus, def bool) bool

+ func KafkaEventSource(namespace, kafkaSourceName, topic string) string

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type KafkaLimitsSpec struct

+ ResourceCPU string

+ ResourceMemory string

+ func (in *KafkaLimitsSpec) DeepCopy() *KafkaLimitsSpec

+ func (in *KafkaLimitsSpec) DeepCopyInto(out *KafkaLimitsSpec)

+ type KafkaRequestsSpec struct

+ ResourceCPU string

+ ResourceMemory string

+ func (in *KafkaRequestsSpec) DeepCopy() *KafkaRequestsSpec

+ func (in *KafkaRequestsSpec) DeepCopyInto(out *KafkaRequestsSpec)

+ type KafkaResourceSpec struct

+ Limits KafkaLimitsSpec

+ Requests KafkaRequestsSpec

+ func (in *KafkaResourceSpec) DeepCopy() *KafkaResourceSpec

+ func (in *KafkaResourceSpec) DeepCopyInto(out *KafkaResourceSpec)

+ type KafkaSource struct

+ Spec KafkaSourceSpec

+ Status KafkaSourceStatus

+ func (*KafkaSource) GetConditionSet() apis.ConditionSet

+ func (*KafkaSource) GetGroupVersionKind() schema.GroupVersionKind

+ func (in *KafkaSource) DeepCopy() *KafkaSource

+ func (in *KafkaSource) DeepCopyInto(out *KafkaSource)

+ func (in *KafkaSource) DeepCopyObject() runtime.Object

+ func (k *KafkaSource) GetStatus() *duckv1.Status

+ func (k *KafkaSource) SetDefaults(ctx context.Context)

+ func (r *KafkaSource) Validate(ctx context.Context) *apis.FieldError

+ func (sink *KafkaSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error

+ func (source *KafkaSource) ConvertTo(ctx context.Context, obj apis.Convertible) error

+ type KafkaSourceList struct

+ Items []KafkaSource

+ func (in *KafkaSourceList) DeepCopy() *KafkaSourceList

+ func (in *KafkaSourceList) DeepCopyInto(out *KafkaSourceList)

+ func (in *KafkaSourceList) DeepCopyObject() runtime.Object

+ type KafkaSourceSpec struct

+ CloudEventOverrides *duckv1.CloudEventOverrides

+ ConsumerGroup string

+ Resources KafkaResourceSpec

+ ServiceAccountName string

+ Sink *duckv1.Destination

+ Topics []string

+ func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec

+ func (in *KafkaSourceSpec) DeepCopyInto(out *KafkaSourceSpec)

+ type KafkaSourceStatus struct

+ func (in *KafkaSourceStatus) DeepCopy() *KafkaSourceStatus

+ func (in *KafkaSourceStatus) DeepCopyInto(out *KafkaSourceStatus)

+ func (s *KafkaSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition

+ func (s *KafkaSourceStatus) InitializeConditions()

+ func (s *KafkaSourceStatus) IsReady() bool

+ func (s *KafkaSourceStatus) MarkDeployed(d *appsv1.Deployment)

+ func (s *KafkaSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})

+ func (s *KafkaSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})

+ func (s *KafkaSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})

+ func (s *KafkaSourceStatus) MarkResourcesCorrect()

+ func (s *KafkaSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{})

+ func (s *KafkaSourceStatus) MarkSink(uri *apis.URL)