messaging

Documentation

Index

• Constants
• func MarkDispatcherDeploymentFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkDispatcherDeploymentUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkDispatcherServiceFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkDispatcherServiceTrue(kcs *messaging.KafkaChannelStatus)
• func MarkDispatcherServiceUnknown(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkReceiverDeploymentFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkReceiverDeploymentTrue(kcs *messaging.KafkaChannelStatus)
• func MarkReceiverServiceFailed(kcs *messaging.KafkaChannelStatus, reason, messageFormat string, ...)
• func MarkReceiverServiceTrue(kcs *messaging.KafkaChannelStatus)
• func PropagateDispatcherDeploymentStatus(kcs *messaging.KafkaChannelStatus, ds *appsv1.DeploymentStatus)
• func RegisterDistributedKafkaChannelConditionSet()

Constants

const (

	// KafkaChannelConditionReceiverServiceReady has status True when the Receiver's K8S Service is ready.
	// This basically just means it exists because there's no meaningful status in Service.
	KafkaChannelConditionReceiverServiceReady apis.ConditionType = "ReceiverServiceReady"

	// KafkaChannelConditionReceiverDeploymentReady has status True when the Receiver's K8S Deployment is ready.
	KafkaChannelConditionReceiverDeploymentReady apis.ConditionType = "ReceiverDeploymentReady"

	// KafkaChannelConditionDispatcherServiceReady has status True when the Dispatcher's K8S Service is ready.
	// This basically just means it exists because there's no meaningful status in Service.
	// Note - Dispatcher Service is only exposed for Metrics collection and is not an active part of the data-plane.
	KafkaChannelConditionDispatcherServiceReady apis.ConditionType = "DispatcherServiceReady"

	// KafkaChannelConditionDispatcherDeploymentReady has status True when the Receiver's K8S Deployment is ready.
	KafkaChannelConditionDispatcherDeploymentReady apis.ConditionType = "DispatcherDeploymentReady"
)

Functions

func MarkDispatcherDeploymentFailed

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

func MarkDispatcherDeploymentUnknown

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

func MarkDispatcherServiceFailed

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

func MarkDispatcherServiceTrue

func MarkDispatcherServiceTrue(kcs *messaging.KafkaChannelStatus)

func MarkDispatcherServiceUnknown

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

func MarkReceiverDeploymentFailed

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

func MarkReceiverDeploymentTrue

func MarkReceiverDeploymentTrue(kcs *messaging.KafkaChannelStatus)

func MarkReceiverServiceFailed

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

func MarkReceiverServiceTrue

func MarkReceiverServiceTrue(kcs *messaging.KafkaChannelStatus)

func PropagateDispatcherDeploymentStatus

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

func RegisterDistributedKafkaChannelConditionSet

func RegisterDistributedKafkaChannelConditionSet()

RegisterDistributedKafkaChannelConditionSet initializes the ConditionSet to those pertaining to the distributed KafkaChannel.