Documentation
¶
Index ¶
Constants ¶
View Source
const ErrorUnrecognizedResourceType = "unrecognized resource type"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AllSupportedJobResourceTypes ¶
type AllSupportedJobResourceTypes struct {
// contains filtered or unexported fields
}
AllSupportedJobResourceTypes is a bridge/interface to all adapters implementing various job types instead of asking multiple adapters you ask a single service that aggregates all of them
func NewAllSupportedJobResourceTypes ¶
func NewAllSupportedJobResourceTypes(cfg *rest.Config) AllSupportedJobResourceTypes
func (*AllSupportedJobResourceTypes) GetScheduledJobHealthStatus ¶
func (all *AllSupportedJobResourceTypes) GetScheduledJobHealthStatus(ctx context.Context, gvk schema.GroupVersionKind, trackingId string, namespace string) (v1alpha1.JobHealthStatus, error)
type KubernetesJobResourceType ¶
type KubernetesJobResourceType struct {
// contains filtered or unexported fields
}
func NewKubernetesJobResourceType ¶
func NewKubernetesJobResourceType(cfg *rest.Config) KubernetesJobResourceType
NewKubernetesJobResourceType is creating an instance of a `Kind: Job` checker
func (KubernetesJobResourceType) GetScheduledJobHealthStatus ¶
func (kj KubernetesJobResourceType) GetScheduledJobHealthStatus(ctx context.Context, trackingId string, namespace string) (v1alpha1.JobHealthStatus, error)
func (KubernetesJobResourceType) MatchesGVK ¶
func (kj KubernetesJobResourceType) MatchesGVK(gvk schema.GroupVersionKind) bool
type SupportedJobResourceType ¶
type SupportedJobResourceType interface {
MatchesGVK(gvk schema.GroupVersionKind) bool
GetScheduledJobHealthStatus(ctx context.Context, trackingId string, namespace string) (v1alpha1.JobHealthStatus, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.