Documentation
¶
Overview ¶
Package repository is a generated GoMock package.
Index ¶
- func CreateRepositoryFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, ...) (*domain.Repository, domain.Status)
- func ReplaceRepositoryFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, name string, ...) (*domain.Repository, domain.Status)
- func SanitizeRepository(repository *domain.Repository)
- type MockService
- func (m *MockService) CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName, imageName string) (*domain.OciRegistryCheckResult, domain.Status)
- func (m *MockService) CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName, imageName, tag string) (*domain.OciRegistryCheckResult, domain.Status)
- func (m *MockService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo domain.Repository) (*domain.Repository, domain.Status)
- func (m *MockService) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) domain.Status
- func (m *MockService) EXPECT() *MockServiceMockRecorder
- func (m *MockService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*domain.Repository, domain.Status)
- func (m *MockService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.DeviceList, domain.Status)
- func (m *MockService) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.FleetList, domain.Status)
- func (m *MockService) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (*domain.RepositoryList, domain.Status)
- func (m *MockService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Repository, domain.Status)
- func (m *MockService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo domain.Repository) (*domain.Repository, domain.Status)
- func (m *MockService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, ...) (*domain.Repository, domain.Status)
- type MockServiceMockRecorder
- func (mr *MockServiceMockRecorder) CheckRepositoryOciImage(ctx, orgId, repositoryName, imageName any) *gomock.Call
- func (mr *MockServiceMockRecorder) CheckRepositoryOciTag(ctx, orgId, repositoryName, imageName, tag any) *gomock.Call
- func (mr *MockServiceMockRecorder) CreateRepository(ctx, orgId, repo any) *gomock.Call
- func (mr *MockServiceMockRecorder) DeleteRepository(ctx, orgId, name any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetRepository(ctx, orgId, name any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetRepositoryDeviceReferences(ctx, orgId, name any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetRepositoryFleetReferences(ctx, orgId, name any) *gomock.Call
- func (mr *MockServiceMockRecorder) ListRepositories(ctx, orgId, params any) *gomock.Call
- func (mr *MockServiceMockRecorder) PatchRepository(ctx, orgId, name, patch any) *gomock.Call
- func (mr *MockServiceMockRecorder) ReplaceRepository(ctx, orgId, name, repo any) *gomock.Call
- func (mr *MockServiceMockRecorder) ReplaceRepositoryStatusByError(ctx, orgId, name, repository, err any) *gomock.Call
- type Service
- type ServiceHandler
- func (h *ServiceHandler) CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName, imageName string) (*domain.OciRegistryCheckResult, domain.Status)
- func (h *ServiceHandler) CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName, imageName, tag string) (*domain.OciRegistryCheckResult, domain.Status)
- func (h *ServiceHandler) CreateRepository(ctx context.Context, orgId uuid.UUID, repository domain.Repository) (*domain.Repository, domain.Status)
- func (h *ServiceHandler) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) domain.Status
- func (h *ServiceHandler) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*domain.Repository, domain.Status)
- func (h *ServiceHandler) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.DeviceList, domain.Status)
- func (h *ServiceHandler) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.FleetList, domain.Status)
- func (h *ServiceHandler) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (*domain.RepositoryList, domain.Status)
- func (h *ServiceHandler) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Repository, domain.Status)
- func (h *ServiceHandler) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, ...) (*domain.Repository, domain.Status)
- func (h *ServiceHandler) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, ...) (*domain.Repository, domain.Status)
- type TracedService
- func (_d *TracedService) CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName string, imageName string) (op1 *domain.OciRegistryCheckResult, s1 domain.Status)
- func (_d *TracedService) CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName string, imageName string, ...) (op1 *domain.OciRegistryCheckResult, s1 domain.Status)
- func (_d *TracedService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo domain.Repository) (rp1 *domain.Repository, s1 domain.Status)
- func (_d *TracedService) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) (s1 domain.Status)
- func (_d *TracedService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (rp1 *domain.Repository, s1 domain.Status)
- func (_d *TracedService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (dp1 *domain.DeviceList, s1 domain.Status)
- func (_d *TracedService) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (fp1 *domain.FleetList, s1 domain.Status)
- func (_d *TracedService) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (rp1 *domain.RepositoryList, s1 domain.Status)
- func (_d *TracedService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (rp1 *domain.Repository, s1 domain.Status)
- func (_d *TracedService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo domain.Repository) (rp1 *domain.Repository, s1 domain.Status)
- func (_d *TracedService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, ...) (rp1 *domain.Repository, s1 domain.Status)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateRepositoryFromUntrusted ¶
func CreateRepositoryFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, repository domain.Repository) (*domain.Repository, domain.Status)
CreateRepositoryFromUntrusted sanitizes an untrusted repository document, then creates it.
func ReplaceRepositoryFromUntrusted ¶
func ReplaceRepositoryFromUntrusted(ctx context.Context, svc Service, orgId uuid.UUID, name string, repository domain.Repository) (*domain.Repository, domain.Status)
ReplaceRepositoryFromUntrusted sanitizes an untrusted repository document, then replaces it.
func SanitizeRepository ¶
func SanitizeRepository(repository *domain.Repository)
SanitizeRepository clears status and managed metadata from an untrusted repository document (HTTP body).
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) CheckRepositoryOciImage ¶
func (m *MockService) CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName, imageName string) (*domain.OciRegistryCheckResult, domain.Status)
CheckRepositoryOciImage mocks base method.
func (*MockService) CheckRepositoryOciTag ¶
func (m *MockService) CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName, imageName, tag string) (*domain.OciRegistryCheckResult, domain.Status)
CheckRepositoryOciTag mocks base method.
func (*MockService) CreateRepository ¶
func (m *MockService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo domain.Repository) (*domain.Repository, domain.Status)
CreateRepository mocks base method.
func (*MockService) DeleteRepository ¶
func (m *MockService) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) domain.Status
DeleteRepository 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) GetRepository ¶
func (m *MockService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*domain.Repository, domain.Status)
GetRepository mocks base method.
func (*MockService) GetRepositoryDeviceReferences ¶
func (m *MockService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.DeviceList, domain.Status)
GetRepositoryDeviceReferences mocks base method.
func (*MockService) GetRepositoryFleetReferences ¶
func (m *MockService) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.FleetList, domain.Status)
GetRepositoryFleetReferences mocks base method.
func (*MockService) ListRepositories ¶
func (m *MockService) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (*domain.RepositoryList, domain.Status)
ListRepositories mocks base method.
func (*MockService) PatchRepository ¶
func (m *MockService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Repository, domain.Status)
PatchRepository mocks base method.
func (*MockService) ReplaceRepository ¶
func (m *MockService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo domain.Repository) (*domain.Repository, domain.Status)
ReplaceRepository mocks base method.
func (*MockService) ReplaceRepositoryStatusByError ¶
func (m *MockService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository domain.Repository, err error) (*domain.Repository, domain.Status)
ReplaceRepositoryStatusByError mocks base method.
type MockServiceMockRecorder ¶
type MockServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockServiceMockRecorder is the mock recorder for MockService.
func (*MockServiceMockRecorder) CheckRepositoryOciImage ¶
func (mr *MockServiceMockRecorder) CheckRepositoryOciImage(ctx, orgId, repositoryName, imageName any) *gomock.Call
CheckRepositoryOciImage indicates an expected call of CheckRepositoryOciImage.
func (*MockServiceMockRecorder) CheckRepositoryOciTag ¶
func (mr *MockServiceMockRecorder) CheckRepositoryOciTag(ctx, orgId, repositoryName, imageName, tag any) *gomock.Call
CheckRepositoryOciTag indicates an expected call of CheckRepositoryOciTag.
func (*MockServiceMockRecorder) CreateRepository ¶
func (mr *MockServiceMockRecorder) CreateRepository(ctx, orgId, repo any) *gomock.Call
CreateRepository indicates an expected call of CreateRepository.
func (*MockServiceMockRecorder) DeleteRepository ¶
func (mr *MockServiceMockRecorder) DeleteRepository(ctx, orgId, name any) *gomock.Call
DeleteRepository indicates an expected call of DeleteRepository.
func (*MockServiceMockRecorder) GetRepository ¶
func (mr *MockServiceMockRecorder) GetRepository(ctx, orgId, name any) *gomock.Call
GetRepository indicates an expected call of GetRepository.
func (*MockServiceMockRecorder) GetRepositoryDeviceReferences ¶
func (mr *MockServiceMockRecorder) GetRepositoryDeviceReferences(ctx, orgId, name any) *gomock.Call
GetRepositoryDeviceReferences indicates an expected call of GetRepositoryDeviceReferences.
func (*MockServiceMockRecorder) GetRepositoryFleetReferences ¶
func (mr *MockServiceMockRecorder) GetRepositoryFleetReferences(ctx, orgId, name any) *gomock.Call
GetRepositoryFleetReferences indicates an expected call of GetRepositoryFleetReferences.
func (*MockServiceMockRecorder) ListRepositories ¶
func (mr *MockServiceMockRecorder) ListRepositories(ctx, orgId, params any) *gomock.Call
ListRepositories indicates an expected call of ListRepositories.
func (*MockServiceMockRecorder) PatchRepository ¶
func (mr *MockServiceMockRecorder) PatchRepository(ctx, orgId, name, patch any) *gomock.Call
PatchRepository indicates an expected call of PatchRepository.
func (*MockServiceMockRecorder) ReplaceRepository ¶
func (mr *MockServiceMockRecorder) ReplaceRepository(ctx, orgId, name, repo any) *gomock.Call
ReplaceRepository indicates an expected call of ReplaceRepository.
func (*MockServiceMockRecorder) ReplaceRepositoryStatusByError ¶
func (mr *MockServiceMockRecorder) ReplaceRepositoryStatusByError(ctx, orgId, name, repository, err any) *gomock.Call
ReplaceRepositoryStatusByError indicates an expected call of ReplaceRepositoryStatusByError.
type Service ¶
type Service interface {
CreateRepository(ctx context.Context, orgId uuid.UUID, repo domain.Repository) (*domain.Repository, domain.Status)
ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (*domain.RepositoryList, domain.Status)
GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*domain.Repository, domain.Status)
ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo domain.Repository) (*domain.Repository, domain.Status)
DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) domain.Status
PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Repository, domain.Status)
ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository domain.Repository, err error) (*domain.Repository, domain.Status)
GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.FleetList, domain.Status)
GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.DeviceList, domain.Status)
CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName, imageName, tag string) (*domain.OciRegistryCheckResult, domain.Status)
CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName, imageName string) (*domain.OciRegistryCheckResult, domain.Status)
}
func WrapWithTracing ¶
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 repositorystore.Store, events events.Service, log logrus.FieldLogger) *ServiceHandler
NewServiceHandler creates a new repository ServiceHandler instance.
func (*ServiceHandler) CheckRepositoryOciImage ¶
func (h *ServiceHandler) CheckRepositoryOciImage(ctx context.Context, orgId uuid.UUID, repositoryName, imageName string) (*domain.OciRegistryCheckResult, domain.Status)
func (*ServiceHandler) CheckRepositoryOciTag ¶
func (h *ServiceHandler) CheckRepositoryOciTag(ctx context.Context, orgId uuid.UUID, repositoryName, imageName, tag string) (*domain.OciRegistryCheckResult, domain.Status)
func (*ServiceHandler) CreateRepository ¶
func (h *ServiceHandler) CreateRepository(ctx context.Context, orgId uuid.UUID, repository domain.Repository) (*domain.Repository, domain.Status)
func (*ServiceHandler) DeleteRepository ¶
func (*ServiceHandler) GetRepository ¶
func (h *ServiceHandler) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*domain.Repository, domain.Status)
func (*ServiceHandler) GetRepositoryDeviceReferences ¶
func (h *ServiceHandler) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*domain.DeviceList, domain.Status)
func (*ServiceHandler) GetRepositoryFleetReferences ¶
func (*ServiceHandler) ListRepositories ¶
func (h *ServiceHandler) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (*domain.RepositoryList, domain.Status)
func (*ServiceHandler) PatchRepository ¶
func (h *ServiceHandler) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (*domain.Repository, domain.Status)
func (*ServiceHandler) ReplaceRepository ¶
func (h *ServiceHandler) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repository domain.Repository) (*domain.Repository, domain.Status)
func (*ServiceHandler) ReplaceRepositoryStatusByError ¶
func (h *ServiceHandler) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository domain.Repository, err error) (*domain.Repository, domain.Status)
type TracedService ¶
type TracedService struct {
// contains filtered or unexported fields
}
TracedService wraps a Service implementation with OpenTelemetry tracing.
func (*TracedService) CheckRepositoryOciImage ¶
func (*TracedService) CheckRepositoryOciTag ¶
func (*TracedService) CreateRepository ¶
func (_d *TracedService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo domain.Repository) (rp1 *domain.Repository, s1 domain.Status)
func (*TracedService) DeleteRepository ¶
func (*TracedService) GetRepository ¶
func (_d *TracedService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (rp1 *domain.Repository, s1 domain.Status)
func (*TracedService) GetRepositoryDeviceReferences ¶
func (_d *TracedService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (dp1 *domain.DeviceList, s1 domain.Status)
func (*TracedService) GetRepositoryFleetReferences ¶
func (*TracedService) ListRepositories ¶
func (_d *TracedService) ListRepositories(ctx context.Context, orgId uuid.UUID, params domain.ListRepositoriesParams) (rp1 *domain.RepositoryList, s1 domain.Status)
func (*TracedService) PatchRepository ¶
func (_d *TracedService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch domain.PatchRequest) (rp1 *domain.Repository, s1 domain.Status)
func (*TracedService) ReplaceRepository ¶
func (_d *TracedService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo domain.Repository) (rp1 *domain.Repository, s1 domain.Status)
func (*TracedService) ReplaceRepositoryStatusByError ¶
func (_d *TracedService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository domain.Repository, e1 error) (rp1 *domain.Repository, s1 domain.Status)