messaging

Documentation

Index

• Constants
• 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()

Constants

const (

	// KafkaChannelConditionDispatcherReady has status True when a Dispatcher deployment is ready
	// Keyed off appsv1.DeploymentAvailable, which means minimum available replicas required are up
	// and running for at least minReadySeconds.
	KafkaChannelConditionDispatcherReady apis.ConditionType = "DispatcherReady"

	// KafkaChannelConditionServiceReady has status True when a k8s Service is ready. This
	// basically just means it exists because there's no meaningful status in Service. See Endpoints
	// below.
	KafkaChannelConditionServiceReady apis.ConditionType = "ServiceReady"

	// KafkaChannelConditionEndpointsReady has status True when a k8s Service Endpoints are backed
	// by at least one endpoint.
	KafkaChannelConditionEndpointsReady apis.ConditionType = "EndpointsReady"
)

Functions

func MarkDispatcherFailed

func MarkDispatcherFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, messageA ...interface{})

func MarkDispatcherUnknown

func MarkDispatcherUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, messageA ...interface{})

func MarkEndpointsFailed

func MarkEndpointsFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, messageA ...interface{})

func MarkEndpointsTrue

func MarkEndpointsTrue(kcs *messaging.KafkaChannelStatus)

func MarkServiceFailed

func MarkServiceFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, messageA ...interface{})

func MarkServiceTrue

func MarkServiceTrue(kcs *messaging.KafkaChannelStatus)

func MarkServiceUnknown

func MarkServiceUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, messageA ...interface{})

func PropagateDispatcherStatus

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

TODO: Unify this with the ones from Eventing. Say: Broker, Trigger.

func RegisterConsolidatedKafkaChannelConditionSet

func RegisterConsolidatedKafkaChannelConditionSet()

RegisterConsolidatedKafkaChannelConditionSet initializes the ConditionSet to those pertaining to the consolidated KafkaChannel.