Documentation
¶
Index ¶
- func GenExpectationPodsKey(jobKey, replicaType string) string
- func GenExpectationServicesKey(jobKey, replicaType string) string
- func GetPortFromJob(spec map[v1.ReplicaType]*v1.ReplicaSpec, rtype v1.ReplicaType, ...) (int32, error)
- func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenExpectationPodsKey ¶
func GetPortFromJob ¶
func GetPortFromJob(spec map[v1.ReplicaType]*v1.ReplicaSpec, rtype v1.ReplicaType, containerName, portName string) (int32, error)
GetPortFromJob gets the port of job default container.
func RecheckDeletionTimestamp ¶
RecheckDeletionTimestamp returns a CanAdopt() function to recheck deletion.
The CanAdopt() function calls getObject() to fetch the latest value, and denies adoption attempts if that object has a non-nil DeletionTimestamp.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.