Versions in this module Expand all Collapse all v0 v0.7.1 Jul 2, 2019 v0.7.0 Jun 25, 2019 Changes in this version + const KafkaConditionDeployed + const KafkaConditionEventTypesProvided + const KafkaConditionReady + const KafkaConditionResources + const KafkaConditionSinkProvided + const KafkaEventType + var AddToScheme = SchemeBuilder.AddToScheme + var SchemeBuilder = &scheme.Builder + var SchemeGroupVersion = schema.GroupVersion + func KafkaEventSource(namespace, kafkaSourceName, topic string) string + 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 (current *KafkaSource) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError + func (in *KafkaSource) DeepCopy() *KafkaSource + func (in *KafkaSource) DeepCopyInto(out *KafkaSource) + func (in *KafkaSource) DeepCopyObject() runtime.Object + type KafkaSourceList struct + Items []KafkaSource + func (in *KafkaSourceList) DeepCopy() *KafkaSourceList + func (in *KafkaSourceList) DeepCopyInto(out *KafkaSourceList) + func (in *KafkaSourceList) DeepCopyObject() runtime.Object + type KafkaSourceNetSpec struct + SASL KafkaSourceSASLSpec + TLS KafkaSourceTLSSpec + func (in *KafkaSourceNetSpec) DeepCopy() *KafkaSourceNetSpec + func (in *KafkaSourceNetSpec) DeepCopyInto(out *KafkaSourceNetSpec) + type KafkaSourceSASLSpec struct + Enable bool + Password SecretValueFromSource + User SecretValueFromSource + func (in *KafkaSourceSASLSpec) DeepCopy() *KafkaSourceSASLSpec + func (in *KafkaSourceSASLSpec) DeepCopyInto(out *KafkaSourceSASLSpec) + type KafkaSourceSpec struct + BootstrapServers string + ConsumerGroup string + Net KafkaSourceNetSpec + Resources KafkaResourceSpec + ServiceAccountName string + Sink *corev1.ObjectReference + Topics string + func (in *KafkaSourceSpec) DeepCopy() *KafkaSourceSpec + func (in *KafkaSourceSpec) DeepCopyInto(out *KafkaSourceSpec) + type KafkaSourceStatus struct + SinkURI string + func (in *KafkaSourceStatus) DeepCopy() *KafkaSourceStatus + func (in *KafkaSourceStatus) DeepCopyInto(out *KafkaSourceStatus) + func (s *KafkaSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition + func (s *KafkaSourceStatus) InitializeConditions() + func (s *KafkaSourceStatus) IsReady() bool + func (s *KafkaSourceStatus) MarkDeployed() + func (s *KafkaSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{}) + func (s *KafkaSourceStatus) MarkEventTypes() + func (s *KafkaSourceStatus) MarkNoEventTypes(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 string) + type KafkaSourceTLSSpec struct + CACert SecretValueFromSource + Cert SecretValueFromSource + Enable bool + Key SecretValueFromSource + func (in *KafkaSourceTLSSpec) DeepCopy() *KafkaSourceTLSSpec + func (in *KafkaSourceTLSSpec) DeepCopyInto(out *KafkaSourceTLSSpec) + type SecretValueFromSource struct + SecretKeyRef *corev1.SecretKeySelector + func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource + func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)
Go to main page