catalog

package
v1.3.0 Latest Latest
Warning

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

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

Documentation

Overview

Package catalog is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateCatalogFromUntrusted 

func CreateCatalogFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, catalog domain.Catalog) (*domain.Catalog, domain.Status)

CreateCatalogFromUntrusted sanitizes an untrusted catalog document, then creates it.

func CreateCatalogItemFromUntrusted 

func CreateCatalogItemFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, catalogName string, item domain.CatalogItem) (*domain.CatalogItem, domain.Status)

CreateCatalogItemFromUntrusted sanitizes an untrusted catalog item document, then creates it.

func NilOutManagedCatalogItemMetaProperties 

func NilOutManagedCatalogItemMetaProperties(om *domain.CatalogItemMeta)

NilOutManagedCatalogItemMetaProperties clears the CatalogItemMeta fields that are managed by the service and must not be set by API callers. Catalog-specific; deliberately left un-relocated to internal/service/common (no other resource needs it).

func ReplaceCatalogFromUntrusted 

func ReplaceCatalogFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, name string, catalog domain.Catalog, enforceOwnership bool) (*domain.Catalog, domain.Status)

ReplaceCatalogFromUntrusted sanitizes an untrusted catalog document, then replaces it.

func ReplaceCatalogItemFromUntrusted 

func ReplaceCatalogItemFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, catalogName, itemName string, item domain.CatalogItem, enforceOwnership bool) (*domain.CatalogItem, domain.Status)

ReplaceCatalogItemFromUntrusted sanitizes an untrusted catalog item document, then replaces it.

func SanitizeCatalog 

func SanitizeCatalog(catalog *domain.Catalog)

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

func SanitizeCatalogItem 

func SanitizeCatalogItem(item *domain.CatalogItem)

SanitizeCatalogItem clears managed metadata from an untrusted catalog item document.

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) CreateCatalog 

func (m *MockService) CreateCatalog(ctx context.Context, orgId uuid.UUID, catalog domain.Catalog) (*domain.Catalog, domain.Status)

CreateCatalog mocks base method.

func (*MockService) CreateCatalogItem 

func (m *MockService) CreateCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, item domain.CatalogItem) (*domain.CatalogItem, domain.Status)

CreateCatalogItem mocks base method.

func (*MockService) DeleteCatalog 

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

DeleteCatalog mocks base method.

func (*MockService) DeleteCatalogItem 

func (m *MockService) DeleteCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName, itemName string, enforceOwnership bool) domain.Status

DeleteCatalogItem 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) GetCatalog 

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

GetCatalog mocks base method.

func (*MockService) GetCatalogItem 

func (m *MockService) GetCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName, itemName string) (*domain.CatalogItem, domain.Status)

GetCatalogItem mocks base method.

func (*MockService) GetCatalogItemDeployments 

func (m *MockService) GetCatalogItemDeployments(ctx context.Context, orgId uuid.UUID, catalogName, itemName string, params domain.GetCatalogItemDeploymentsParams) (*domain.CatalogItemDeploymentList, domain.Status)

GetCatalogItemDeployments mocks base method.

func (*MockService) GetCatalogStatus 

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

GetCatalogStatus mocks base method.

func (*MockService) ListAllCatalogItems 

func (m *MockService) ListAllCatalogItems(ctx context.Context, orgId uuid.UUID, params domain.ListAllCatalogItemsParams) (*domain.CatalogItemList, domain.Status)

ListAllCatalogItems mocks base method.

func (*MockService) ListCatalogItems 

func (m *MockService) ListCatalogItems(ctx context.Context, orgId uuid.UUID, catalogName string, params domain.ListCatalogItemsParams) (*domain.CatalogItemList, domain.Status)

ListCatalogItems mocks base method.

func (*MockService) ListCatalogs 

func (m *MockService) ListCatalogs(ctx context.Context, orgId uuid.UUID, params domain.ListCatalogsParams) (*domain.CatalogList, domain.Status)

ListCatalogs mocks base method.

func (*MockService) PatchCatalog 

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

PatchCatalog mocks base method.

func (*MockService) PatchCatalogItem 

func (m *MockService) PatchCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName, itemName string, patch domain.PatchRequest, enforceOwnership bool) (*domain.CatalogItem, domain.Status)

PatchCatalogItem mocks base method.

func (*MockService) PatchCatalogStatus 

func (m *MockService) PatchCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Catalog, domain.Status)

PatchCatalogStatus mocks base method.

func (*MockService) ReplaceCatalog 

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

ReplaceCatalog mocks base method.

func (*MockService) ReplaceCatalogItem 

func (m *MockService) ReplaceCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName, itemName string, item domain.CatalogItem, enforceOwnership bool) (*domain.CatalogItem, domain.Status)

ReplaceCatalogItem mocks base method.

func (*MockService) ReplaceCatalogStatus 

func (m *MockService) ReplaceCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, catalog domain.Catalog) (*domain.Catalog, domain.Status)

ReplaceCatalogStatus mocks base method.

type MockServiceMockRecorder 

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

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder) CreateCatalog 

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

CreateCatalog indicates an expected call of CreateCatalog.

func (*MockServiceMockRecorder) CreateCatalogItem 

func (mr *MockServiceMockRecorder) CreateCatalogItem(ctx, orgId, catalogName, item any) *gomock.Call

CreateCatalogItem indicates an expected call of CreateCatalogItem.

func (*MockServiceMockRecorder) DeleteCatalog 

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

DeleteCatalog indicates an expected call of DeleteCatalog.

func (*MockServiceMockRecorder) DeleteCatalogItem 

func (mr *MockServiceMockRecorder) DeleteCatalogItem(ctx, orgId, catalogName, itemName, enforceOwnership any) *gomock.Call

DeleteCatalogItem indicates an expected call of DeleteCatalogItem.

func (*MockServiceMockRecorder) GetCatalog 

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

GetCatalog indicates an expected call of GetCatalog.

func (*MockServiceMockRecorder) GetCatalogItem 

func (mr *MockServiceMockRecorder) GetCatalogItem(ctx, orgId, catalogName, itemName any) *gomock.Call

GetCatalogItem indicates an expected call of GetCatalogItem.

func (*MockServiceMockRecorder) GetCatalogItemDeployments 

func (mr *MockServiceMockRecorder) GetCatalogItemDeployments(ctx, orgId, catalogName, itemName, params any) *gomock.Call

GetCatalogItemDeployments indicates an expected call of GetCatalogItemDeployments.

func (*MockServiceMockRecorder) GetCatalogStatus 

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

GetCatalogStatus indicates an expected call of GetCatalogStatus.

func (*MockServiceMockRecorder) ListAllCatalogItems 

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

ListAllCatalogItems indicates an expected call of ListAllCatalogItems.

func (*MockServiceMockRecorder) ListCatalogItems 

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

ListCatalogItems indicates an expected call of ListCatalogItems.

func (*MockServiceMockRecorder) ListCatalogs 

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

ListCatalogs indicates an expected call of ListCatalogs.

func (*MockServiceMockRecorder) PatchCatalog 

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

PatchCatalog indicates an expected call of PatchCatalog.

func (*MockServiceMockRecorder) PatchCatalogItem 

func (mr *MockServiceMockRecorder) PatchCatalogItem(ctx, orgId, catalogName, itemName, patch, enforceOwnership any) *gomock.Call

PatchCatalogItem indicates an expected call of PatchCatalogItem.

func (*MockServiceMockRecorder) PatchCatalogStatus 

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

PatchCatalogStatus indicates an expected call of PatchCatalogStatus.

func (*MockServiceMockRecorder) ReplaceCatalog 

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

ReplaceCatalog indicates an expected call of ReplaceCatalog.

func (*MockServiceMockRecorder) ReplaceCatalogItem 

func (mr *MockServiceMockRecorder) ReplaceCatalogItem(ctx, orgId, catalogName, itemName, item, enforceOwnership any) *gomock.Call

ReplaceCatalogItem indicates an expected call of ReplaceCatalogItem.

func (*MockServiceMockRecorder) ReplaceCatalogStatus 

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

ReplaceCatalogStatus indicates an expected call of ReplaceCatalogStatus.

type Service 

type Service interface {
	CreateCatalog(ctx context.Context, orgId uuid.UUID, catalog domain.Catalog) (*domain.Catalog, domain.Status)
	ListCatalogs(ctx context.Context, orgId uuid.UUID, params domain.ListCatalogsParams) (*domain.CatalogList, domain.Status)
	GetCatalog(ctx context.Context, orgId uuid.UUID, name string) (*domain.Catalog, domain.Status)
	ReplaceCatalog(ctx context.Context, orgId uuid.UUID, name string, catalog domain.Catalog, enforceOwnership bool) (*domain.Catalog, domain.Status)
	DeleteCatalog(ctx context.Context, orgId uuid.UUID, name string, enforceOwnership bool) domain.Status
	PatchCatalog(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (*domain.Catalog, domain.Status)
	GetCatalogStatus(ctx context.Context, orgId uuid.UUID, name string) (*domain.Catalog, domain.Status)
	ReplaceCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, catalog domain.Catalog) (*domain.Catalog, domain.Status)
	PatchCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Catalog, domain.Status)
	ListAllCatalogItems(ctx context.Context, orgId uuid.UUID, params domain.ListAllCatalogItemsParams) (*domain.CatalogItemList, domain.Status)
	ListCatalogItems(ctx context.Context, orgId uuid.UUID, catalogName string, params domain.ListCatalogItemsParams) (*domain.CatalogItemList, domain.Status)
	GetCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string) (*domain.CatalogItem, domain.Status)
	CreateCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, item domain.CatalogItem) (*domain.CatalogItem, domain.Status)
	ReplaceCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, item domain.CatalogItem, enforceOwnership bool) (*domain.CatalogItem, domain.Status)
	PatchCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, patch domain.PatchRequest, enforceOwnership bool) (*domain.CatalogItem, domain.Status)
	DeleteCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, enforceOwnership bool) domain.Status
	GetCatalogItemDeployments(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, params domain.GetCatalogItemDeploymentsParams) (*domain.CatalogItemDeploymentList, 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 catalogstore.Store, deviceStore devicestore.Store, fleetStore fleetstore.Store, events events.Service, log logrus.FieldLogger) *ServiceHandler

NewServiceHandler creates a new catalog ServiceHandler instance.

func (*ServiceHandler) CreateCatalog 

func (h *ServiceHandler) CreateCatalog(ctx context.Context, orgId uuid.UUID, catalog domain.Catalog) (*domain.Catalog, domain.Status)

func (*ServiceHandler) CreateCatalogItem 

func (h *ServiceHandler) CreateCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, item domain.CatalogItem) (*domain.CatalogItem, domain.Status)

func (*ServiceHandler) DeleteCatalog 

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

func (*ServiceHandler) DeleteCatalogItem 

func (h *ServiceHandler) DeleteCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, enforceOwnership bool) domain.Status

func (*ServiceHandler) GetCatalog 

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

func (*ServiceHandler) GetCatalogItem 

func (h *ServiceHandler) GetCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string) (*domain.CatalogItem, domain.Status)

func (*ServiceHandler) GetCatalogItemDeployments 

func (h *ServiceHandler) GetCatalogItemDeployments(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, params domain.GetCatalogItemDeploymentsParams) (*domain.CatalogItemDeploymentList, domain.Status)

func (*ServiceHandler) GetCatalogStatus 

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

func (*ServiceHandler) ListAllCatalogItems 

func (h *ServiceHandler) ListAllCatalogItems(ctx context.Context, orgId uuid.UUID, params domain.ListAllCatalogItemsParams) (*domain.CatalogItemList, domain.Status)

func (*ServiceHandler) ListCatalogItems 

func (h *ServiceHandler) ListCatalogItems(ctx context.Context, orgId uuid.UUID, catalogName string, params domain.ListCatalogItemsParams) (*domain.CatalogItemList, domain.Status)

func (*ServiceHandler) ListCatalogs 

func (h *ServiceHandler) ListCatalogs(ctx context.Context, orgId uuid.UUID, params domain.ListCatalogsParams) (*domain.CatalogList, domain.Status)

func (*ServiceHandler) PatchCatalog 

func (h *ServiceHandler) PatchCatalog(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (*domain.Catalog, 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) PatchCatalogItem 

func (h *ServiceHandler) PatchCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, patch domain.PatchRequest, enforceOwnership bool) (*domain.CatalogItem, domain.Status)

func (*ServiceHandler) PatchCatalogStatus 

func (h *ServiceHandler) PatchCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Catalog, domain.Status)

func (*ServiceHandler) ReplaceCatalog 

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

func (*ServiceHandler) ReplaceCatalogItem 

func (h *ServiceHandler) ReplaceCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, item domain.CatalogItem, enforceOwnership bool) (*domain.CatalogItem, domain.Status)

func (*ServiceHandler) ReplaceCatalogStatus 

func (h *ServiceHandler) ReplaceCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, catalog domain.Catalog) (*domain.Catalog, domain.Status)

type TracedService 

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

TracedService wraps a Service implementation with OpenTelemetry tracing.

func (*TracedService) CreateCatalog 

func (_d *TracedService) CreateCatalog(ctx context.Context, orgId uuid.UUID, catalog domain.Catalog) (cp1 *domain.Catalog, s1 domain.Status)

func (*TracedService) CreateCatalogItem 

func (_d *TracedService) CreateCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, item domain.CatalogItem) (cp1 *domain.CatalogItem, s1 domain.Status)

func (*TracedService) DeleteCatalog 

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

func (*TracedService) DeleteCatalogItem 

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

func (*TracedService) GetCatalog 

func (_d *TracedService) GetCatalog(ctx context.Context, orgId uuid.UUID, name string) (cp1 *domain.Catalog, s1 domain.Status)

func (*TracedService) GetCatalogItem 

func (_d *TracedService) GetCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string) (cp1 *domain.CatalogItem, s1 domain.Status)

func (*TracedService) GetCatalogItemDeployments 

func (_d *TracedService) GetCatalogItemDeployments(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, params domain.GetCatalogItemDeploymentsParams) (cp1 *domain.CatalogItemDeploymentList, s1 domain.Status)

func (*TracedService) GetCatalogStatus 

func (_d *TracedService) GetCatalogStatus(ctx context.Context, orgId uuid.UUID, name string) (cp1 *domain.Catalog, s1 domain.Status)

func (*TracedService) ListAllCatalogItems 

func (_d *TracedService) ListAllCatalogItems(ctx context.Context, orgId uuid.UUID, params domain.ListAllCatalogItemsParams) (cp1 *domain.CatalogItemList, s1 domain.Status)

func (*TracedService) ListCatalogItems 

func (_d *TracedService) ListCatalogItems(ctx context.Context, orgId uuid.UUID, catalogName string, params domain.ListCatalogItemsParams) (cp1 *domain.CatalogItemList, s1 domain.Status)

func (*TracedService) ListCatalogs 

func (_d *TracedService) ListCatalogs(ctx context.Context, orgId uuid.UUID, params domain.ListCatalogsParams) (cp1 *domain.CatalogList, s1 domain.Status)

func (*TracedService) PatchCatalog 

func (_d *TracedService) PatchCatalog(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest, enforceOwnership bool) (cp1 *domain.Catalog, s1 domain.Status)

func (*TracedService) PatchCatalogItem 

func (_d *TracedService) PatchCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, patch domain.PatchRequest, enforceOwnership bool) (cp1 *domain.CatalogItem, s1 domain.Status)

func (*TracedService) PatchCatalogStatus 

func (_d *TracedService) PatchCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (cp1 *domain.Catalog, s1 domain.Status)

func (*TracedService) ReplaceCatalog 

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

func (*TracedService) ReplaceCatalogItem 

func (_d *TracedService) ReplaceCatalogItem(ctx context.Context, orgId uuid.UUID, catalogName string, itemName string, item domain.CatalogItem, enforceOwnership bool) (cp1 *domain.CatalogItem, s1 domain.Status)

func (*TracedService) ReplaceCatalogStatus 

func (_d *TracedService) ReplaceCatalogStatus(ctx context.Context, orgId uuid.UUID, name string, catalog domain.Catalog) (cp1 *domain.Catalog, 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.