tasks_client

package
v0.9.4 Latest Latest
Warning

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

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

Documentation

Overview

Package tasks_client 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"
	TemplateVersionPopulateOpCreated = "create"
	FleetValidateOpUpdate            = "update"
	DeviceRenderOpUpdate             = "update"
	RepositoryUpdateOpUpdate         = "update"
)

Variables

This section is empty.

Functions

func TaskQueuePublisher 

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

Types

type CallbackManager 

type CallbackManager interface {
	DeviceUpdatedCallback(ctx context.Context, orgId uuid.UUID, before, after *api.Device)
	DeviceUpdatedNoRenderCallback(ctx context.Context, orgId uuid.UUID, before, after *api.Device)
	FleetUpdatedCallback(ctx context.Context, orgId uuid.UUID, before, after *api.Fleet)
	RepositoryUpdatedCallback(ctx context.Context, orgId uuid.UUID, before, after *api.Repository)
	TemplateVersionCreatedCallback(ctx context.Context, orgId uuid.UUID, before, after *api.TemplateVersion)
	FleetSourceUpdated(ctx context.Context, orgId uuid.UUID, name string)
	DeviceSourceUpdated(ctx context.Context, orgId uuid.UUID, name string)
	FleetRolloutSelectionUpdated(ctx context.Context, 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) DeviceSourceUpdated 

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

DeviceSourceUpdated mocks base method.

func (*MockCallbackManager) DeviceUpdatedCallback 

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

DeviceUpdatedCallback mocks base method.

func (*MockCallbackManager) DeviceUpdatedNoRenderCallback 

func (m *MockCallbackManager) DeviceUpdatedNoRenderCallback(ctx context.Context, 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(ctx context.Context, orgId uuid.UUID, name string)

FleetRolloutSelectionUpdated mocks base method.

func (*MockCallbackManager) FleetSourceUpdated 

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

FleetSourceUpdated mocks base method.

func (*MockCallbackManager) FleetUpdatedCallback 

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

FleetUpdatedCallback mocks base method.

func (*MockCallbackManager) RepositoryUpdatedCallback 

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

RepositoryUpdatedCallback mocks base method.

func (*MockCallbackManager) TemplateVersionCreatedCallback 

func (m *MockCallbackManager) TemplateVersionCreatedCallback(ctx context.Context, 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) DeviceSourceUpdated 

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

DeviceSourceUpdated indicates an expected call of DeviceSourceUpdated.

func (*MockCallbackManagerMockRecorder) DeviceUpdatedCallback 

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

DeviceUpdatedCallback indicates an expected call of DeviceUpdatedCallback.

func (*MockCallbackManagerMockRecorder) DeviceUpdatedNoRenderCallback 

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

DeviceUpdatedNoRenderCallback indicates an expected call of DeviceUpdatedNoRenderCallback.

func (*MockCallbackManagerMockRecorder) FleetRolloutSelectionUpdated 

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

FleetRolloutSelectionUpdated indicates an expected call of FleetRolloutSelectionUpdated.

func (*MockCallbackManagerMockRecorder) FleetSourceUpdated 

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

FleetSourceUpdated indicates an expected call of FleetSourceUpdated.

func (*MockCallbackManagerMockRecorder) FleetUpdatedCallback 

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

FleetUpdatedCallback indicates an expected call of FleetUpdatedCallback.

func (*MockCallbackManagerMockRecorder) RepositoryUpdatedCallback 

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

RepositoryUpdatedCallback indicates an expected call of RepositoryUpdatedCallback.

func (*MockCallbackManagerMockRecorder) TemplateVersionCreatedCallback 

func (mr *MockCallbackManagerMockRecorder) TemplateVersionCreatedCallback(ctx, 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.