messaging

package
v0.41.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
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"
)

Variables

This section is empty.

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.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL