Documentation
¶
Index ¶
- type BatchJobBackendSettings
- type CronJobBackendSettings
- type ExecutionSettings
- type ExecutionSettingsWrapper
- func (e *ExecutionSettingsWrapper) GetBackend() stream.Backend
- func (e *ExecutionSettingsWrapper) GetJobTemplate(request *v1.BackfillRequest) types.NamespacedName
- func (e *ExecutionSettingsWrapper) GetPreviousBackend(ctx context.Context, c client.Client) (*stream.Backend, error)
- func (e *ExecutionSettingsWrapper) GetSchedule() (string, error)
- func (e *ExecutionSettingsWrapper) NamespacedName() types.NamespacedName
- func (e *ExecutionSettingsWrapper) SetSuspended(suspended bool) error
- func (e *ExecutionSettingsWrapper) StateString() string
- func (e *ExecutionSettingsWrapper) Suspended() bool
- func (e *ExecutionSettingsWrapper) ToUnstructured() *unstructured.Unstructured
- func (e *ExecutionSettingsWrapper) Validate() error
- type StreamingBackendSettings
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchJobBackendSettings ¶
type BatchJobBackendSettings struct {
JobTemplateRef corev1.ObjectReference `json:"jobTemplateRef"`
}
type CronJobBackendSettings ¶
type CronJobBackendSettings struct {
Schedule string `json:"schedule"`
JobTemplateRef corev1.ObjectReference `json:"jobTemplateRef"`
}
type ExecutionSettings ¶
type ExecutionSettings struct {
Suspended bool `json:"suspended"`
APIVersion string `json:"apiVersion"`
BackfillJobTemplateRef *corev1.ObjectReference `json:"backfillJobTemplateRef,omitempty"`
StreamingBackend StreamingBackendSettings `json:"streamingBackend"`
}
type ExecutionSettingsWrapper ¶
type ExecutionSettingsWrapper struct {
common.SecretReferenceReader
*status_v0.StatusWrapper
*common.ConfiguratorProvider
*common.OwnerReferenceProvider
Underlying *unstructured.Unstructured
// contains filtered or unexported fields
}
func NewExecutionSettings ¶
func NewExecutionSettings(u *unstructured.Unstructured) *ExecutionSettingsWrapper
func (*ExecutionSettingsWrapper) GetBackend ¶
func (e *ExecutionSettingsWrapper) GetBackend() stream.Backend
func (*ExecutionSettingsWrapper) GetJobTemplate ¶
func (e *ExecutionSettingsWrapper) GetJobTemplate(request *v1.BackfillRequest) types.NamespacedName
func (*ExecutionSettingsWrapper) GetPreviousBackend ¶
func (*ExecutionSettingsWrapper) GetSchedule ¶
func (e *ExecutionSettingsWrapper) GetSchedule() (string, error)
func (*ExecutionSettingsWrapper) NamespacedName ¶
func (e *ExecutionSettingsWrapper) NamespacedName() types.NamespacedName
func (*ExecutionSettingsWrapper) SetSuspended ¶
func (e *ExecutionSettingsWrapper) SetSuspended(suspended bool) error
func (*ExecutionSettingsWrapper) StateString ¶
func (e *ExecutionSettingsWrapper) StateString() string
func (*ExecutionSettingsWrapper) Suspended ¶
func (e *ExecutionSettingsWrapper) Suspended() bool
func (*ExecutionSettingsWrapper) ToUnstructured ¶
func (e *ExecutionSettingsWrapper) ToUnstructured() *unstructured.Unstructured
func (*ExecutionSettingsWrapper) Validate ¶
func (e *ExecutionSettingsWrapper) Validate() error
type StreamingBackendSettings ¶
type StreamingBackendSettings struct {
BatchJobBackend *BatchJobBackendSettings `json:"changeCapture,omitempty"`
CronJobBackend *CronJobBackendSettings `json:"batch,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.