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 KafkaChannelConditionAddressable + const KafkaChannelConditionChannelServiceReady + const KafkaChannelConditionDispatcherReady + const KafkaChannelConditionEndpointsReady + const KafkaChannelConditionReady + const KafkaChannelConditionServiceReady + const KafkaChannelConditionTopicReady + var AddToScheme = SchemeBuilder.AddToScheme + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + type KafkaChannel struct + Spec KafkaChannelSpec + Status KafkaChannelStatus + func (c *KafkaChannel) GetGroupVersionKind() schema.GroupVersionKind + func (c *KafkaChannel) SetDefaults(ctx context.Context) + func (c *KafkaChannel) Validate(ctx context.Context) *apis.FieldError + func (in *KafkaChannel) DeepCopy() *KafkaChannel + func (in *KafkaChannel) DeepCopyInto(out *KafkaChannel) + func (in *KafkaChannel) DeepCopyObject() runtime.Object + type KafkaChannelList struct + Items []KafkaChannel + func (in *KafkaChannelList) DeepCopy() *KafkaChannelList + func (in *KafkaChannelList) DeepCopyInto(out *KafkaChannelList) + func (in *KafkaChannelList) DeepCopyObject() runtime.Object + type KafkaChannelSpec struct + NumPartitions int32 + ReplicationFactor int16 + Subscribable *eventingduck.Subscribable + func (cs *KafkaChannelSpec) SetDefaults(ctx context.Context) + func (cs *KafkaChannelSpec) Validate(ctx context.Context) *apis.FieldError + func (in *KafkaChannelSpec) DeepCopy() *KafkaChannelSpec + func (in *KafkaChannelSpec) DeepCopyInto(out *KafkaChannelSpec) + type KafkaChannelStatus struct + func (cs *KafkaChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (cs *KafkaChannelStatus) InitializeConditions() + func (cs *KafkaChannelStatus) IsReady() bool + func (cs *KafkaChannelStatus) MarkChannelServiceFailed(reason, messageFormat string, messageA ...interface{}) + func (cs *KafkaChannelStatus) MarkChannelServiceTrue() + func (cs *KafkaChannelStatus) MarkDispatcherFailed(reason, messageFormat string, messageA ...interface{}) + func (cs *KafkaChannelStatus) MarkEndpointsFailed(reason, messageFormat string, messageA ...interface{}) + func (cs *KafkaChannelStatus) MarkEndpointsTrue() + func (cs *KafkaChannelStatus) MarkServiceFailed(reason, messageFormat string, messageA ...interface{}) + func (cs *KafkaChannelStatus) MarkServiceTrue() + func (cs *KafkaChannelStatus) MarkTopicFailed(reason, messageFormat string, messageA ...interface{}) + func (cs *KafkaChannelStatus) MarkTopicTrue() + func (cs *KafkaChannelStatus) PropagateDispatcherStatus(ds *appsv1.DeploymentStatus) + func (cs *KafkaChannelStatus) SetAddress(url *apis.URL) + func (in *KafkaChannelStatus) DeepCopy() *KafkaChannelStatus + func (in *KafkaChannelStatus) DeepCopyInto(out *KafkaChannelStatus)