tasks_client

Feb 5, 2025

Changes in this version

+ const DeviceRenderOpUpdate

+ const DeviceRenderTask

+ const FleetRolloutOpUpdate

+ const FleetRolloutTask

+ const FleetSelectorMatchOpDeleteAll

+ const FleetSelectorMatchOpUpdate

+ const FleetSelectorMatchOpUpdateOverlap

+ const FleetSelectorMatchTask

+ const FleetValidateOpUpdate

+ const FleetValidateTask

+ const RepositoryUpdateOpDeleteAll

+ const RepositoryUpdateOpUpdate

+ const RepositoryUpdatesTask

+ const TemplateVersionPopulateOpCreated

+ func TaskQueuePublisher(provider queues.Provider) (queues.Publisher, error)

+ type CallbackManager interface

+ AllDevicesDeletedCallback func(orgId uuid.UUID)

+ AllFleetsDeletedCallback func(orgId uuid.UUID)

+ AllRepositoriesDeletedCallback func(orgId uuid.UUID)

+ DeviceSourceUpdated func(orgId uuid.UUID, name string)

+ DeviceUpdatedCallback func(orgId uuid.UUID, before, after *api.Device)

+ DeviceUpdatedNoRenderCallback func(orgId uuid.UUID, before, after *api.Device)

+ FleetRolloutSelectionUpdated func(orgId uuid.UUID, name string)

+ FleetSourceUpdated func(orgId uuid.UUID, name string)

+ FleetUpdatedCallback func(orgId uuid.UUID, before, after *api.Fleet)

+ RepositoryUpdatedCallback func(orgId uuid.UUID, before, after *api.Repository)

+ TemplateVersionCreatedCallback func(orgId uuid.UUID, before, after *api.TemplateVersion)

+ func NewCallbackManager(publisher queues.Publisher, log logrus.FieldLogger) CallbackManager

+ type MockCallbackManager struct

+ func NewMockCallbackManager(ctrl *gomock.Controller) *MockCallbackManager

+ func (m *MockCallbackManager) AllDevicesDeletedCallback(orgId uuid.UUID)

+ func (m *MockCallbackManager) AllFleetsDeletedCallback(orgId uuid.UUID)

+ func (m *MockCallbackManager) AllRepositoriesDeletedCallback(orgId uuid.UUID)

+ func (m *MockCallbackManager) DeviceSourceUpdated(orgId uuid.UUID, name string)

+ func (m *MockCallbackManager) DeviceUpdatedCallback(orgId uuid.UUID, before, after *v1alpha1.Device)

+ func (m *MockCallbackManager) DeviceUpdatedNoRenderCallback(orgId uuid.UUID, before, after *v1alpha1.Device)

+ func (m *MockCallbackManager) EXPECT() *MockCallbackManagerMockRecorder

+ func (m *MockCallbackManager) FleetRolloutSelectionUpdated(orgId uuid.UUID, name string)

+ func (m *MockCallbackManager) FleetSourceUpdated(orgId uuid.UUID, name string)

+ func (m *MockCallbackManager) FleetUpdatedCallback(orgId uuid.UUID, before, after *v1alpha1.Fleet)

+ func (m *MockCallbackManager) RepositoryUpdatedCallback(orgId uuid.UUID, before, after *v1alpha1.Repository)

+ func (m *MockCallbackManager) TemplateVersionCreatedCallback(orgId uuid.UUID, before, after *v1alpha1.TemplateVersion)

+ type MockCallbackManagerMockRecorder struct

+ func (mr *MockCallbackManagerMockRecorder) AllDevicesDeletedCallback(orgId any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) AllFleetsDeletedCallback(orgId any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) AllRepositoriesDeletedCallback(orgId any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) DeviceSourceUpdated(orgId, name any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) DeviceUpdatedCallback(orgId, before, after any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) DeviceUpdatedNoRenderCallback(orgId, before, after any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) FleetRolloutSelectionUpdated(orgId, name any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) FleetSourceUpdated(orgId, name any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) FleetUpdatedCallback(orgId, before, after any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) RepositoryUpdatedCallback(orgId, before, after any) *gomock.Call

+ func (mr *MockCallbackManagerMockRecorder) TemplateVersionCreatedCallback(orgId, before, after any) *gomock.Call

+ type ResourceReference struct

+ Kind string

+ Name string

+ Op string

+ OrgID uuid.UUID

+ Owner string

+ TaskName string