Documentation
¶
Index ¶
- func FromResource(job client.Object) (stream.BackendResource, error)
- type Backend
- func (j *Backend) Apply(_ context.Context, _ stream.Definition, _ *v1.BackfillRequest, _ stream.Phase, ...) (reconcile.Result, error)
- func (j *Backend) Get(_ context.Context, _ types.NamespacedName) (stream.BackendResource, error)
- func (j *Backend) NoOp(_ context.Context, _ stream.Definition, _ *v1.BackfillRequest, _ stream.Phase, ...) (reconcile.Result, error)
- func (j *Backend) Remove(_ context.Context, _ stream.Definition, _ stream.Phase, ...) (reconcile.Result, error)
- func (j *Backend) SetupWithController(_ cache.Cache, _ *runtime.Scheme, _ meta.RESTMapper, _ controller.Controller, ...) error
- type BackendResource
- func (j *BackendResource) CurrentConfiguration() (string, error)
- func (j *BackendResource) IsBackfill() bool
- func (j *BackendResource) IsCompleted() bool
- func (j *BackendResource) IsFailed() bool
- func (j *BackendResource) Name() string
- func (j *BackendResource) ToObject() client.Object
- func (j *BackendResource) UID() types.UID
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromResource ¶
func FromResource(job client.Object) (stream.BackendResource, error)
Types ¶
type Backend ¶
type Backend struct {
// contains filtered or unexported fields
}
func NewEmptyBackend ¶
func NewEmptyBackend(eventRecorder record.EventRecorder) *Backend
func (*Backend) Apply ¶
func (j *Backend) Apply(_ context.Context, _ stream.Definition, _ *v1.BackfillRequest, _ stream.Phase, _ *v1.StreamClass, eventFunc controllers.EventFunc) (reconcile.Result, error)
func (*Backend) Get ¶
func (j *Backend) Get(_ context.Context, _ types.NamespacedName) (stream.BackendResource, error)
func (*Backend) NoOp ¶
func (j *Backend) NoOp(_ context.Context, _ stream.Definition, _ *v1.BackfillRequest, _ stream.Phase, eventFunc controllers.EventFunc) (reconcile.Result, error)
func (*Backend) SetupWithController ¶
func (j *Backend) SetupWithController(_ cache.Cache, _ *runtime.Scheme, _ meta.RESTMapper, _ controller.Controller, _ schema.GroupVersionKind) error
type BackendResource ¶
func (*BackendResource) CurrentConfiguration ¶
func (j *BackendResource) CurrentConfiguration() (string, error)
func (*BackendResource) IsBackfill ¶
func (j *BackendResource) IsBackfill() bool
func (*BackendResource) IsCompleted ¶
func (j *BackendResource) IsCompleted() bool
func (*BackendResource) IsFailed ¶
func (j *BackendResource) IsFailed() bool
func (*BackendResource) Name ¶
func (j *BackendResource) Name() string
func (*BackendResource) ToObject ¶
func (j *BackendResource) ToObject() client.Object
func (*BackendResource) UID ¶
func (j *BackendResource) UID() types.UID
Source Files
Click to show internal directories.
Click to hide internal directories.