Documentation ¶
Index ¶
- func FromRequestHandlerToHandler(sync RequestHandler) generic.Handler
- func RegisterRequestGeneratingHandler(ctx context.Context, controller RequestController, apply apply.Apply, ...)
- func RegisterRequestStatusHandler(ctx context.Context, controller RequestController, condition condition.Cond, ...)
- func UpdateRequestDeepCopyOnChange(client RequestClient, obj *v1.Request, ...) (*v1.Request, error)
- type Interface
- type RequestCache
- type RequestClient
- type RequestController
- type RequestGeneratingHandler
- type RequestHandler
- type RequestIndexer
- type RequestStatusHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromRequestHandlerToHandler ¶
func FromRequestHandlerToHandler(sync RequestHandler) generic.Handler
func RegisterRequestGeneratingHandler ¶
func RegisterRequestGeneratingHandler(ctx context.Context, controller RequestController, apply apply.Apply, condition condition.Cond, name string, handler RequestGeneratingHandler, opts *generic.GeneratingHandlerOptions)
func RegisterRequestStatusHandler ¶
func RegisterRequestStatusHandler(ctx context.Context, controller RequestController, condition condition.Cond, name string, handler RequestStatusHandler)
Types ¶
type Interface ¶
type Interface interface {
Request() RequestController
}
func New ¶
func New(controllerFactory controller.SharedControllerFactory) Interface
type RequestCache ¶
type RequestClient ¶
type RequestClient interface { Create(*v1.Request) (*v1.Request, error) Update(*v1.Request) (*v1.Request, error) UpdateStatus(*v1.Request) (*v1.Request, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.Request, error) List(namespace string, opts metav1.ListOptions) (*v1.RequestList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Request, err error) }
type RequestController ¶
type RequestController interface { generic.ControllerMeta RequestClient OnChange(ctx context.Context, name string, sync RequestHandler) OnRemove(ctx context.Context, name string, sync RequestHandler) Enqueue(namespace, name string) EnqueueAfter(namespace, name string, duration time.Duration) Cache() RequestCache }
func NewRequestController ¶
func NewRequestController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RequestController
type RequestGeneratingHandler ¶
type RequestGeneratingHandler func(obj *v1.Request, status v1.RequestStatus) ([]runtime.Object, v1.RequestStatus, error)
type RequestStatusHandler ¶
type RequestStatusHandler func(obj *v1.Request, status v1.RequestStatus) (v1.RequestStatus, error)
Click to show internal directories.
Click to hide internal directories.