messaging

Jan 27, 2022

Changes in this version

+ const KafkaChannelConditionDispatcherReady

+ const KafkaChannelConditionEndpointsReady

+ const KafkaChannelConditionServiceReady

+ func MarkDispatcherFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)

+ func MarkDispatcherUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)

+ func MarkEndpointsFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)

+ func MarkEndpointsTrue(kcs *messaging.KafkaChannelStatus)

+ func MarkServiceFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)

+ func MarkServiceTrue(kcs *messaging.KafkaChannelStatus)

+ func MarkServiceUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)

+ func PropagateDispatcherStatus(kcs *messaging.KafkaChannelStatus, ds *appsv1.DeploymentStatus)

+ func RegisterConsolidatedKafkaChannelConditionSet()