tasks_client

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: May 14, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package tasks is a generated GoMock package.

Index

Constants

View Source 
const (
	// Task to roll out a fleet's template to its devices upon update
	FleetRolloutTask = "fleet-rollout"

	// Task to set devices' owners
	FleetSelectorMatchTask = "fleet-selector-match"

	// Task to validate a fleet template
	FleetValidateTask = "fleet-template-validate"

	// Task to render device
	DeviceRenderTask = "device-render"

	// Task to re-evaluate fleets and devices if a repository resource changes
	RepositoryUpdatesTask = "repository-updates"
)
View Source 
const (
	FleetRolloutOpUpdate              = "update"
	FleetSelectorMatchOpUpdate        = "update"
	FleetSelectorMatchOpUpdateOverlap = "update-overlap"
	FleetSelectorMatchOpDeleteAll     = "delete-all"
	TemplateVersionPopulateOpCreated  = "create"
	FleetValidateOpUpdate             = "update"
	DeviceRenderOpUpdate              = "update"
	RepositoryUpdateOpUpdate          = "update"
	RepositoryUpdateOpDeleteAll       = "delete-all"
)

Variables

This section is empty.

Functions

func TaskQueuePublisher 

func TaskQueuePublisher(queuesProvider queues.Provider) (queues.Publisher, error)

Types

type CallbackManager 

type CallbackManager interface {
	DeviceUpdatedCallback(orgId uuid.UUID, before, after *api.Device)
	DeviceUpdatedNoRenderCallback(orgId uuid.UUID, before, after *api.Device)
	FleetUpdatedCallback(orgId uuid.UUID, before, after *api.Fleet)
	RepositoryUpdatedCallback(orgId uuid.UUID, before, after *api.Repository)
	TemplateVersionCreatedCallback(orgId uuid.UUID, before, after *api.TemplateVersion)
	AllRepositoriesDeletedCallback(orgId uuid.UUID)
	AllFleetsDeletedCallback(orgId uuid.UUID)
	AllDevicesDeletedCallback(orgId uuid.UUID)
	FleetSourceUpdated(orgId uuid.UUID, name string)
	DeviceSourceUpdated(orgId uuid.UUID, name string)
	FleetRolloutSelectionUpdated(orgId uuid.UUID, name string)
}

func NewCallbackManager 

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

type MockCallbackManager 

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

MockCallbackManager is a mock of CallbackManager interface.

func NewMockCallbackManager 

func NewMockCallbackManager(ctrl *gomock.Controller) *MockCallbackManager

NewMockCallbackManager creates a new mock instance.

func (*MockCallbackManager) AllDevicesDeletedCallback 

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

AllDevicesDeletedCallback mocks base method.

func (*MockCallbackManager) AllFleetsDeletedCallback 

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

AllFleetsDeletedCallback mocks base method.

func (*MockCallbackManager) AllRepositoriesDeletedCallback 

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

AllRepositoriesDeletedCallback mocks base method.

func (*MockCallbackManager) DeviceSourceUpdated 

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

DeviceSourceUpdated mocks base method.

func (*MockCallbackManager) DeviceUpdatedCallback 

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

DeviceUpdatedCallback mocks base method.

func (*MockCallbackManager) DeviceUpdatedNoRenderCallback 

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

DeviceUpdatedNoRenderCallback mocks base method.

func (*MockCallbackManager) EXPECT 

func (m *MockCallbackManager) EXPECT() *MockCallbackManagerMockRecorder

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

func (*MockCallbackManager) FleetRolloutSelectionUpdated 

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

FleetRolloutSelectionUpdated mocks base method.

func (*MockCallbackManager) FleetSourceUpdated 

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

FleetSourceUpdated mocks base method.

func (*MockCallbackManager) FleetUpdatedCallback 

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

FleetUpdatedCallback mocks base method.

func (*MockCallbackManager) RepositoryUpdatedCallback 

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

RepositoryUpdatedCallback mocks base method.

func (*MockCallbackManager) TemplateVersionCreatedCallback 

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

TemplateVersionCreatedCallback mocks base method.

type MockCallbackManagerMockRecorder 

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

MockCallbackManagerMockRecorder is the mock recorder for MockCallbackManager.

func (*MockCallbackManagerMockRecorder) AllDevicesDeletedCallback 

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

AllDevicesDeletedCallback indicates an expected call of AllDevicesDeletedCallback.

func (*MockCallbackManagerMockRecorder) AllFleetsDeletedCallback 

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

AllFleetsDeletedCallback indicates an expected call of AllFleetsDeletedCallback.

func (*MockCallbackManagerMockRecorder) AllRepositoriesDeletedCallback 

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

AllRepositoriesDeletedCallback indicates an expected call of AllRepositoriesDeletedCallback.

func (*MockCallbackManagerMockRecorder) DeviceSourceUpdated 

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

DeviceSourceUpdated indicates an expected call of DeviceSourceUpdated.

func (*MockCallbackManagerMockRecorder) DeviceUpdatedCallback 

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

DeviceUpdatedCallback indicates an expected call of DeviceUpdatedCallback.

func (*MockCallbackManagerMockRecorder) DeviceUpdatedNoRenderCallback 

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

DeviceUpdatedNoRenderCallback indicates an expected call of DeviceUpdatedNoRenderCallback.

func (*MockCallbackManagerMockRecorder) FleetRolloutSelectionUpdated 

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

FleetRolloutSelectionUpdated indicates an expected call of FleetRolloutSelectionUpdated.

func (*MockCallbackManagerMockRecorder) FleetSourceUpdated 

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

FleetSourceUpdated indicates an expected call of FleetSourceUpdated.

func (*MockCallbackManagerMockRecorder) FleetUpdatedCallback 

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

FleetUpdatedCallback indicates an expected call of FleetUpdatedCallback.

func (*MockCallbackManagerMockRecorder) RepositoryUpdatedCallback 

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

RepositoryUpdatedCallback indicates an expected call of RepositoryUpdatedCallback.

func (*MockCallbackManagerMockRecorder) TemplateVersionCreatedCallback 

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

TemplateVersionCreatedCallback indicates an expected call of TemplateVersionCreatedCallback.

type ResourceReference 

type ResourceReference struct {
	TaskName string
	Op       string
	OrgID    uuid.UUID
	Kind     string
	Name     string
	Owner    string
}

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.