watchers

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 4, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: daemonset.go

Generated by this command: 

mockgen -source=daemonset.go -package=watchers -destination=mock_daemonset.go DaemonsetEventHandlerAPI

Package watchers is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: node.go

Generated by this command: 

mockgen -source=node.go -package=watchers -destination=mock_node.go NodeEventHandlerAPI

Package watchers is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: pod.go

Generated by this command: 

mockgen -source=pod.go -package=watchers -destination=mock_pod.go PodEventHandlerAPI

Package watchers is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DaemonsetEventHandler 

type DaemonsetEventHandler struct {
	// contains filtered or unexported fields
}

func (*DaemonsetEventHandler) Create 

func (h *DaemonsetEventHandler) Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create handle create event

func (*DaemonsetEventHandler) Delete 

func (h *DaemonsetEventHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete handle delete event

func (*DaemonsetEventHandler) Generic 

func (h *DaemonsetEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create handle generic event

func (*DaemonsetEventHandler) Update 

func (h *DaemonsetEventHandler) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Update handle update event

type DaemonsetEventHandlerAPI 

type DaemonsetEventHandlerAPI interface {
	Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
}

func NewDaemonsetEventHandler 

func NewDaemonsetEventHandler(client client.Client) DaemonsetEventHandlerAPI

type DaemonsetPredicate 

type DaemonsetPredicate struct {
	predicate.Funcs
}

func (DaemonsetPredicate) Delete 

func (DaemonsetPredicate) Delete(e event.DeleteEvent) bool

func (DaemonsetPredicate) Generic 

func (DaemonsetPredicate) Generic(e event.GenericEvent) bool

func (DaemonsetPredicate) Update 

func (DaemonsetPredicate) Update(e event.UpdateEvent) bool

type MockDaemonsetEventHandlerAPI 

type MockDaemonsetEventHandlerAPI struct {
	// contains filtered or unexported fields
}

MockDaemonsetEventHandlerAPI is a mock of DaemonsetEventHandlerAPI interface.

func NewMockDaemonsetEventHandlerAPI 

func NewMockDaemonsetEventHandlerAPI(ctrl *gomock.Controller) *MockDaemonsetEventHandlerAPI

NewMockDaemonsetEventHandlerAPI creates a new mock instance.

func (*MockDaemonsetEventHandlerAPI) Create 

func (m *MockDaemonsetEventHandlerAPI) Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create mocks base method.

func (*MockDaemonsetEventHandlerAPI) Delete 

func (m *MockDaemonsetEventHandlerAPI) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete mocks base method.

func (*MockDaemonsetEventHandlerAPI) EXPECT 

func (m *MockDaemonsetEventHandlerAPI) EXPECT() *MockDaemonsetEventHandlerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDaemonsetEventHandlerAPI) Generic 

func (m *MockDaemonsetEventHandlerAPI) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Generic mocks base method.

func (*MockDaemonsetEventHandlerAPI) Update 

func (m *MockDaemonsetEventHandlerAPI) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Update mocks base method.

type MockDaemonsetEventHandlerAPIMockRecorder 

type MockDaemonsetEventHandlerAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockDaemonsetEventHandlerAPIMockRecorder is the mock recorder for MockDaemonsetEventHandlerAPI.

func (*MockDaemonsetEventHandlerAPIMockRecorder) Create 

func (mr *MockDaemonsetEventHandlerAPIMockRecorder) Create(ctx, evt, q any) *gomock.Call

Create indicates an expected call of Create.

func (*MockDaemonsetEventHandlerAPIMockRecorder) Delete 

func (mr *MockDaemonsetEventHandlerAPIMockRecorder) Delete(ctx, evt, q any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockDaemonsetEventHandlerAPIMockRecorder) Generic 

func (mr *MockDaemonsetEventHandlerAPIMockRecorder) Generic(ctx, evt, q any) *gomock.Call

Generic indicates an expected call of Generic.

func (*MockDaemonsetEventHandlerAPIMockRecorder) Update 

func (mr *MockDaemonsetEventHandlerAPIMockRecorder) Update(ctx, evt, q any) *gomock.Call

Update indicates an expected call of Update.

type MockNodeEventHandlerAPI 

type MockNodeEventHandlerAPI struct {
	// contains filtered or unexported fields
}

MockNodeEventHandlerAPI is a mock of NodeEventHandlerAPI interface.

func NewMockNodeEventHandlerAPI 

func NewMockNodeEventHandlerAPI(ctrl *gomock.Controller) *MockNodeEventHandlerAPI

NewMockNodeEventHandlerAPI creates a new mock instance.

func (*MockNodeEventHandlerAPI) Create 

func (m *MockNodeEventHandlerAPI) Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create mocks base method.

func (*MockNodeEventHandlerAPI) Delete 

func (m *MockNodeEventHandlerAPI) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete mocks base method.

func (*MockNodeEventHandlerAPI) EXPECT 

func (m *MockNodeEventHandlerAPI) EXPECT() *MockNodeEventHandlerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNodeEventHandlerAPI) Generic 

func (m *MockNodeEventHandlerAPI) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Generic mocks base method.

func (*MockNodeEventHandlerAPI) Update 

func (m *MockNodeEventHandlerAPI) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Update mocks base method.

type MockNodeEventHandlerAPIMockRecorder 

type MockNodeEventHandlerAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockNodeEventHandlerAPIMockRecorder is the mock recorder for MockNodeEventHandlerAPI.

func (*MockNodeEventHandlerAPIMockRecorder) Create 

func (mr *MockNodeEventHandlerAPIMockRecorder) Create(ctx, evt, q any) *gomock.Call

Create indicates an expected call of Create.

func (*MockNodeEventHandlerAPIMockRecorder) Delete 

func (mr *MockNodeEventHandlerAPIMockRecorder) Delete(ctx, evt, q any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockNodeEventHandlerAPIMockRecorder) Generic 

func (mr *MockNodeEventHandlerAPIMockRecorder) Generic(ctx, evt, q any) *gomock.Call

Generic indicates an expected call of Generic.

func (*MockNodeEventHandlerAPIMockRecorder) Update 

func (mr *MockNodeEventHandlerAPIMockRecorder) Update(ctx, evt, q any) *gomock.Call

Update indicates an expected call of Update.

type MockPodEventHandlerAPI 

type MockPodEventHandlerAPI struct {
	// contains filtered or unexported fields
}

MockPodEventHandlerAPI is a mock of PodEventHandlerAPI interface.

func NewMockPodEventHandlerAPI 

func NewMockPodEventHandlerAPI(ctrl *gomock.Controller) *MockPodEventHandlerAPI

NewMockPodEventHandlerAPI creates a new mock instance.

func (*MockPodEventHandlerAPI) Create 

func (m *MockPodEventHandlerAPI) Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create mocks base method.

func (*MockPodEventHandlerAPI) Delete 

func (m *MockPodEventHandlerAPI) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete mocks base method.

func (*MockPodEventHandlerAPI) EXPECT 

func (m *MockPodEventHandlerAPI) EXPECT() *MockPodEventHandlerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPodEventHandlerAPI) Generic 

func (m *MockPodEventHandlerAPI) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Generic mocks base method.

func (*MockPodEventHandlerAPI) Update 

func (m *MockPodEventHandlerAPI) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Update mocks base method.

type MockPodEventHandlerAPIMockRecorder 

type MockPodEventHandlerAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockPodEventHandlerAPIMockRecorder is the mock recorder for MockPodEventHandlerAPI.

func (*MockPodEventHandlerAPIMockRecorder) Create 

func (mr *MockPodEventHandlerAPIMockRecorder) Create(ctx, evt, q any) *gomock.Call

Create indicates an expected call of Create.

func (*MockPodEventHandlerAPIMockRecorder) Delete 

func (mr *MockPodEventHandlerAPIMockRecorder) Delete(ctx, evt, q any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockPodEventHandlerAPIMockRecorder) Generic 

func (mr *MockPodEventHandlerAPIMockRecorder) Generic(ctx, evt, q any) *gomock.Call

Generic indicates an expected call of Generic.

func (*MockPodEventHandlerAPIMockRecorder) Update 

func (mr *MockPodEventHandlerAPIMockRecorder) Update(ctx, evt, q any) *gomock.Call

Update indicates an expected call of Update.

type NodeEventHandler 

type NodeEventHandler struct {
	// contains filtered or unexported fields
}

func (*NodeEventHandler) Create 

func (h *NodeEventHandler) Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create handle create event

func (*NodeEventHandler) Delete 

func (h *NodeEventHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete handle delete event

func (*NodeEventHandler) Generic 

func (h *NodeEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Create handle generic event

func (*NodeEventHandler) Update 

func (h *NodeEventHandler) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])

Update handle update event

type NodeEventHandlerAPI 

type NodeEventHandlerAPI interface {
	Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
}

func NewNodeEventHandler 

func NewNodeEventHandler(client client.Client, workerMgr workermgr.WorkerMgrAPI) NodeEventHandlerAPI

type NodePredicate 

type NodePredicate struct {
	predicate.Funcs
}

func (NodePredicate) Create 

func (NodePredicate) Create(e event.CreateEvent) bool

func (NodePredicate) Delete 

func (NodePredicate) Delete(e event.DeleteEvent) bool

func (NodePredicate) Generic 

func (NodePredicate) Generic(e event.GenericEvent) bool

func (NodePredicate) Update 

func (NodePredicate) Update(e event.UpdateEvent) bool

type PodEventHandler 

type PodEventHandler struct {
	// contains filtered or unexported fields
}

func (*PodEventHandler) Create 

func (h *PodEventHandler) Create(
	ctx context.Context,
	evt event.TypedCreateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create handle pod create event

func (*PodEventHandler) Delete 

func (h *PodEventHandler) Delete(
	ctx context.Context,
	evt event.TypedDeleteEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Delete handle pod delete event

func (*PodEventHandler) Generic 

func (h *PodEventHandler) Generic(
	ctx context.Context,
	evt event.TypedGenericEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create handle pod generic event

func (*PodEventHandler) Update 

func (h *PodEventHandler) Update(
	ctx context.Context,
	evt event.TypedUpdateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Update handle pod update event

type PodEventHandlerAPI 

type PodEventHandlerAPI interface {
	Create(ctx context.Context, evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Update(ctx context.Context, evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
	Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request])
}

func NewPodEventHandler 

func NewPodEventHandler(client client.Client, workerMgr workermgr.WorkerMgrAPI) PodEventHandlerAPI

type PodLabelPredicate 

type PodLabelPredicate struct {
	predicate.Funcs
}

func (PodLabelPredicate) Update 

func (PodLabelPredicate) Update(e event.UpdateEvent) bool

type SpecChangedOrDeletionPredicate 

type SpecChangedOrDeletionPredicate struct {
	predicate.Funcs
}

SpecChangedOrDeletionPredicate implements predicate.Predicate interface. triggering reconciliation only if the Spec field has changed or the DeletionTimestamp has been updated.

func (SpecChangedOrDeletionPredicate) Create 

func (SpecChangedOrDeletionPredicate) Create(e event.CreateEvent) bool

Create returns true, allowing reconciliation when a new resource is created.

func (SpecChangedOrDeletionPredicate) Delete 

func (SpecChangedOrDeletionPredicate) Delete(e event.DeleteEvent) bool

Delete returns true, allowing reconciliation when a resource is deleted.

func (SpecChangedOrDeletionPredicate) Update 

func (SpecChangedOrDeletionPredicate) Update(e event.UpdateEvent) bool

Update implements the update event filter for Spec or DeletionTimestamp changes.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.