fleet

package
v1.3.0-test Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package fleet is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateFleetFromUntrusted 

func CreateFleetFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, fleet domain.Fleet) (*domain.Fleet, domain.Status)

CreateFleetFromUntrusted sanitizes an untrusted fleet document, then creates it.

func EmitFleetRolloutStartedEvent 

func EmitFleetRolloutStartedEvent(ctx context.Context, eventsService events.Service, orgId uuid.UUID, templateVersionName string, fleetName string, immediateRollout bool)

EmitFleetRolloutStartedEvent emits the FleetRolloutStarted event. Exported because internal/service/templateversion triggers a fleet rollout as part of deploying a template version and needs to emit this fleet-owned event without depending on a shared events hub for fleet-specific decisions.

func EmitFleetUpdatedEvent 

func EmitFleetUpdatedEvent(ctx context.Context, eventsService events.Service, log logrus.FieldLogger, resourceKind domain.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)

EmitFleetUpdatedEvent handles all fleet-related event emission logic for a fleet create/update/delete.

func ReplaceFleetFromUntrusted 

func ReplaceFleetFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, name string, fleet domain.Fleet, enforceOwnership bool) (*domain.Fleet, domain.Status)

ReplaceFleetFromUntrusted sanitizes an untrusted fleet document, then replaces it.

func SanitizeFleet 

func SanitizeFleet(fleet *domain.Fleet)

SanitizeFleet clears status and managed metadata from an untrusted fleet document (HTTP body or ResourceSync YAML). Callers that must set Owner must not use this.

Types

type MockService 

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

MockService is a mock of Service interface.

func NewMockService 

func NewMockService(ctrl *gomock.Controller) *MockService

NewMockService creates a new mock instance.

func (*MockService) CreateFleet 

func (m *MockService) CreateFleet(ctx context.Context, orgId uuid.UUID, fleet domain.Fleet) (*domain.Fleet, domain.Status)

CreateFleet mocks base method.

func (*MockService) DeleteFleet 

func (m *MockService) DeleteFleet(ctx context.Context, orgId uuid.UUID, name string, enforceOwnership bool) domain.Status

DeleteFleet mocks base method.

func (*MockService) EXPECT 

func (m *MockService) EXPECT() *MockServiceMockRecorder

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

func (*MockService) GetFleet 

func (m *MockService) GetFleet(ctx context.Context, orgId uuid.UUID, name string, params domain.GetFleetParams) (*domain.Fleet, domain.Status)

GetFleet mocks base method.

func (*MockService) GetFleetRepositoryRefs 

func (m *MockService) GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*domain.RepositoryList, domain.Status)

GetFleetRepositoryRefs mocks base method.

func (*MockService) GetFleetStatus 

func (m *MockService) GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*domain.Fleet, domain.Status)

GetFleetStatus mocks base method.

func (*MockService) ListDisruptionBudgetFleets 

func (m *MockService) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)

ListDisruptionBudgetFleets mocks base method.

func (*MockService) ListFleetRolloutDeviceSelection 

func (m *MockService) ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)

ListFleetRolloutDeviceSelection mocks base method.

func (*MockService) ListFleets 

func (m *MockService) ListFleets(ctx context.Context, orgId uuid.UUID, params domain.ListFleetsParams) (*domain.FleetList, domain.Status)

ListFleets mocks base method.

func (*MockService) OverwriteFleetRepositoryRefs 

func (m *MockService) OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) domain.Status

OverwriteFleetRepositoryRefs mocks base method.

func (*MockService) PatchFleet 

func (m *MockService) PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (*domain.Fleet, domain.Status)

PatchFleet mocks base method.

func (*MockService) ReplaceFleet 

func (m *MockService) ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet, enforceOwnership bool) (*domain.Fleet, domain.Status)

ReplaceFleet mocks base method.

func (*MockService) ReplaceFleetStatus 

func (m *MockService) ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet) (*domain.Fleet, domain.Status)

ReplaceFleetStatus mocks base method.

func (*MockService) StartFleetApplication 

func (m *MockService) StartFleetApplication(ctx context.Context, orgId uuid.UUID, name, appName string) (*domain.Fleet, domain.Status)

StartFleetApplication mocks base method.

func (*MockService) StopFleetApplication 

func (m *MockService) StopFleetApplication(ctx context.Context, orgId uuid.UUID, name, appName string) (*domain.Fleet, domain.Status)

StopFleetApplication mocks base method.

func (*MockService) UpdateFleetAnnotations 

func (m *MockService) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) domain.Status

UpdateFleetAnnotations mocks base method.

func (*MockService) UpdateFleetConditions 

func (m *MockService) UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []domain.Condition) domain.Status

UpdateFleetConditions mocks base method.

type MockServiceMockRecorder 

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

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder) CreateFleet 

func (mr *MockServiceMockRecorder) CreateFleet(ctx, orgId, fleet any) *gomock.Call

CreateFleet indicates an expected call of CreateFleet.

func (*MockServiceMockRecorder) DeleteFleet 

func (mr *MockServiceMockRecorder) DeleteFleet(ctx, orgId, name, enforceOwnership any) *gomock.Call

DeleteFleet indicates an expected call of DeleteFleet.

func (*MockServiceMockRecorder) GetFleet 

func (mr *MockServiceMockRecorder) GetFleet(ctx, orgId, name, params any) *gomock.Call

GetFleet indicates an expected call of GetFleet.

func (*MockServiceMockRecorder) GetFleetRepositoryRefs 

func (mr *MockServiceMockRecorder) GetFleetRepositoryRefs(ctx, orgId, name any) *gomock.Call

GetFleetRepositoryRefs indicates an expected call of GetFleetRepositoryRefs.

func (*MockServiceMockRecorder) GetFleetStatus 

func (mr *MockServiceMockRecorder) GetFleetStatus(ctx, orgId, name any) *gomock.Call

GetFleetStatus indicates an expected call of GetFleetStatus.

func (*MockServiceMockRecorder) ListDisruptionBudgetFleets 

func (mr *MockServiceMockRecorder) ListDisruptionBudgetFleets(ctx, orgId any) *gomock.Call

ListDisruptionBudgetFleets indicates an expected call of ListDisruptionBudgetFleets.

func (*MockServiceMockRecorder) ListFleetRolloutDeviceSelection 

func (mr *MockServiceMockRecorder) ListFleetRolloutDeviceSelection(ctx, orgId any) *gomock.Call

ListFleetRolloutDeviceSelection indicates an expected call of ListFleetRolloutDeviceSelection.

func (*MockServiceMockRecorder) ListFleets 

func (mr *MockServiceMockRecorder) ListFleets(ctx, orgId, params any) *gomock.Call

ListFleets indicates an expected call of ListFleets.

func (*MockServiceMockRecorder) OverwriteFleetRepositoryRefs 

func (mr *MockServiceMockRecorder) OverwriteFleetRepositoryRefs(ctx, orgId, name any, repositoryNames ...any) *gomock.Call

OverwriteFleetRepositoryRefs indicates an expected call of OverwriteFleetRepositoryRefs.

func (*MockServiceMockRecorder) PatchFleet 

func (mr *MockServiceMockRecorder) PatchFleet(ctx, orgId, name, patch, enforceOwnership any) *gomock.Call

PatchFleet indicates an expected call of PatchFleet.

func (*MockServiceMockRecorder) ReplaceFleet 

func (mr *MockServiceMockRecorder) ReplaceFleet(ctx, orgId, name, fleet, enforceOwnership any) *gomock.Call

ReplaceFleet indicates an expected call of ReplaceFleet.

func (*MockServiceMockRecorder) ReplaceFleetStatus 

func (mr *MockServiceMockRecorder) ReplaceFleetStatus(ctx, orgId, name, fleet any) *gomock.Call

ReplaceFleetStatus indicates an expected call of ReplaceFleetStatus.

func (*MockServiceMockRecorder) StartFleetApplication 

func (mr *MockServiceMockRecorder) StartFleetApplication(ctx, orgId, name, appName any) *gomock.Call

StartFleetApplication indicates an expected call of StartFleetApplication.

func (*MockServiceMockRecorder) StopFleetApplication 

func (mr *MockServiceMockRecorder) StopFleetApplication(ctx, orgId, name, appName any) *gomock.Call

StopFleetApplication indicates an expected call of StopFleetApplication.

func (*MockServiceMockRecorder) UpdateFleetAnnotations 

func (mr *MockServiceMockRecorder) UpdateFleetAnnotations(ctx, orgId, name, annotations, deleteKeys any) *gomock.Call

UpdateFleetAnnotations indicates an expected call of UpdateFleetAnnotations.

func (*MockServiceMockRecorder) UpdateFleetConditions 

func (mr *MockServiceMockRecorder) UpdateFleetConditions(ctx, orgId, name, conditions any) *gomock.Call

UpdateFleetConditions indicates an expected call of UpdateFleetConditions.

type Service 

type Service interface {
	CreateFleet(ctx context.Context, orgId uuid.UUID, fleet domain.Fleet) (*domain.Fleet, domain.Status)
	ListFleets(ctx context.Context, orgId uuid.UUID, params domain.ListFleetsParams) (*domain.FleetList, domain.Status)
	GetFleet(ctx context.Context, orgId uuid.UUID, name string, params domain.GetFleetParams) (*domain.Fleet, domain.Status)
	ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet, enforceOwnership bool) (*domain.Fleet, domain.Status)
	DeleteFleet(ctx context.Context, orgId uuid.UUID, name string, enforceOwnership bool) domain.Status
	GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*domain.Fleet, domain.Status)
	ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet) (*domain.Fleet, domain.Status)
	PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (*domain.Fleet, domain.Status)
	ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)
	ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)
	UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []domain.Condition) domain.Status
	UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) domain.Status
	OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) domain.Status
	GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*domain.RepositoryList, domain.Status)
	StopFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (*domain.Fleet, domain.Status)
	StartFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (*domain.Fleet, domain.Status)
}

func WrapWithTracing 

func WrapWithTracing(inner Service) Service

WrapWithTracing returns a Service that wraps inner with tracing spans, or nil if inner is nil.

type ServiceHandler 

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

func NewServiceHandler 

func NewServiceHandler(store fleetstore.Store, events events.Service, log logrus.FieldLogger) *ServiceHandler

NewServiceHandler creates a new fleet ServiceHandler instance.

func (*ServiceHandler) CreateFleet 

func (h *ServiceHandler) CreateFleet(ctx context.Context, orgId uuid.UUID, fleet domain.Fleet) (*domain.Fleet, domain.Status)

func (*ServiceHandler) DeleteFleet 

func (h *ServiceHandler) DeleteFleet(ctx context.Context, orgId uuid.UUID, name string, enforceOwnership bool) domain.Status

func (*ServiceHandler) GetFleet 

func (h *ServiceHandler) GetFleet(ctx context.Context, orgId uuid.UUID, name string, params domain.GetFleetParams) (*domain.Fleet, domain.Status)

func (*ServiceHandler) GetFleetRepositoryRefs 

func (h *ServiceHandler) GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*domain.RepositoryList, domain.Status)

func (*ServiceHandler) GetFleetStatus 

func (h *ServiceHandler) GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*domain.Fleet, domain.Status)

func (*ServiceHandler) ListDisruptionBudgetFleets 

func (h *ServiceHandler) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)

func (*ServiceHandler) ListFleetRolloutDeviceSelection 

func (h *ServiceHandler) ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*domain.FleetList, domain.Status)

func (*ServiceHandler) ListFleets 

func (h *ServiceHandler) ListFleets(ctx context.Context, orgId uuid.UUID, params domain.ListFleetsParams) (*domain.FleetList, domain.Status)

func (*ServiceHandler) OverwriteFleetRepositoryRefs 

func (h *ServiceHandler) OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) domain.Status

func (*ServiceHandler) PatchFleet 

func (h *ServiceHandler) PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (*domain.Fleet, domain.Status)

Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) ReplaceFleet 

func (h *ServiceHandler) ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet, enforceOwnership bool) (*domain.Fleet, domain.Status)

func (*ServiceHandler) ReplaceFleetStatus 

func (h *ServiceHandler) ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet) (*domain.Fleet, domain.Status)

func (*ServiceHandler) StartFleetApplication 

func (h *ServiceHandler) StartFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (*domain.Fleet, domain.Status)

StartFleetApplication sets a fleet-level default so that the named application's desiredState is "running" on every device currently owned by this fleet, independent of the application's declarative spec. Same recency-based arbitration against device-level overrides as StopFleetApplication.

func (*ServiceHandler) StopFleetApplication 

func (h *ServiceHandler) StopFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (*domain.Fleet, domain.Status)

StopFleetApplication sets a fleet-level default so that the named application's desiredState is "stopped" on every device currently owned by this fleet, independent of the application's declarative spec. The default is stamped with a fresh version so it wins over an earlier device-level override, but a device-level action issued afterwards would in turn win over it.

func (*ServiceHandler) UpdateFleetAnnotations 

func (h *ServiceHandler) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) domain.Status

func (*ServiceHandler) UpdateFleetConditions 

func (h *ServiceHandler) UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []domain.Condition) domain.Status

type TracedService 

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

TracedService wraps a Service implementation with OpenTelemetry tracing.

func (*TracedService) CreateFleet 

func (_d *TracedService) CreateFleet(ctx context.Context, orgId uuid.UUID, fleet domain.Fleet) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) DeleteFleet 

func (_d *TracedService) DeleteFleet(ctx context.Context, orgId uuid.UUID, name string, enforceOwnership bool) (s1 domain.Status)

func (*TracedService) GetFleet 

func (_d *TracedService) GetFleet(ctx context.Context, orgId uuid.UUID, name string, params domain.GetFleetParams) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) GetFleetRepositoryRefs 

func (_d *TracedService) GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (rp1 *domain.RepositoryList, s1 domain.Status)

func (*TracedService) GetFleetStatus 

func (_d *TracedService) GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) ListDisruptionBudgetFleets 

func (_d *TracedService) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (fp1 *domain.FleetList, s1 domain.Status)

func (*TracedService) ListFleetRolloutDeviceSelection 

func (_d *TracedService) ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (fp1 *domain.FleetList, s1 domain.Status)

func (*TracedService) ListFleets 

func (_d *TracedService) ListFleets(ctx context.Context, orgId uuid.UUID, params domain.ListFleetsParams) (fp1 *domain.FleetList, s1 domain.Status)

func (*TracedService) OverwriteFleetRepositoryRefs 

func (_d *TracedService) OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) (s1 domain.Status)

func (*TracedService) PatchFleet 

func (_d *TracedService) PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) ReplaceFleet 

func (_d *TracedService) ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet, enforceOwnership bool) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) ReplaceFleetStatus 

func (_d *TracedService) ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet domain.Fleet) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) StartFleetApplication 

func (_d *TracedService) StartFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) StopFleetApplication 

func (_d *TracedService) StopFleetApplication(ctx context.Context, orgId uuid.UUID, name string, appName string) (fp1 *domain.Fleet, s1 domain.Status)

func (*TracedService) UpdateFleetAnnotations 

func (_d *TracedService) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) (s1 domain.Status)

func (*TracedService) UpdateFleetConditions 

func (_d *TracedService) UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []domain.Condition) (s1 domain.Status)

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.