Documentation
¶
Overview ¶
Package release is a generated GoMock package.
Package release is a generated GoMock package.
Index ¶
- Constants
- func NewReleaseWorker(spec ReleaseWorkerSpec) worker.Worker
- type MockeventRecorder
- func (m *MockeventRecorder) EXPECT() *MockeventRecorderMockRecorder
- func (m *MockeventRecorder) RecordReleaseChecksPassed(ctx context.Context, release *models.StackRelease) *errors.ServiceError
- func (m *MockeventRecorder) RecordReleaseChecksStarted(ctx context.Context, release *models.StackRelease) *errors.ServiceError
- func (m *MockeventRecorder) RecordReleaseStarted(ctx context.Context, release *models.StackRelease) *errors.ServiceError
- type MockeventRecorderMockRecorder
- type MockimageBuildService
- type MockimageBuildServiceMockRecorder
- type MockpostgresAddonService
- type MockpostgresAddonServiceMockRecorder
- type MockregistryClientProvider
- type MockregistryClientProviderMockRecorder
- type MockreleaseService
- func (m *MockreleaseService) AppendImageDigests(ctx context.Context, id string, digests map[string]string) *errors.ServiceError
- func (m *MockreleaseService) EXPECT() *MockreleaseServiceMockRecorder
- func (m *MockreleaseService) InternalGet(ctx context.Context, releaseID string) (*models.StackRelease, *errors.ServiceError)
- func (m *MockreleaseService) InternalGetActiveByStackID(ctx context.Context, stackID string) (*models.StackRelease, *errors.ServiceError)
- func (m *MockreleaseService) InternalListActive(ctx context.Context) ([]*models.StackRelease, *errors.ServiceError)
- func (m *MockreleaseService) MarkFailed(ctx context.Context, id, message string, outcome *models.ReleaseOutcome) (bool, *errors.ServiceError)
- func (m *MockreleaseService) MarkFailedWithValidationErrors(ctx context.Context, id, message string, verrs models.ReleaseValidationErrors) (bool, *errors.ServiceError)
- func (m *MockreleaseService) MarkInProgress(ctx context.Context, id string) (bool, *errors.ServiceError)
- func (m *MockreleaseService) MarkReleased(ctx context.Context, id string, outcome models.ReleaseOutcome) (bool, *errors.ServiceError)
- func (m *MockreleaseService) MarkSuperseded(ctx context.Context, id, reason string) (bool, *errors.ServiceError)
- func (m_2 *MockreleaseService) SaveManifest(ctx context.Context, id string, m *models.ReleaseManifest, rev string, ...) (bool, *errors.ServiceError)
- func (m *MockreleaseService) SetConvergeClockStartedAt(ctx context.Context, id string, startedAt *time.Time) *errors.ServiceError
- type MockreleaseServiceMockRecorder
- func (mr *MockreleaseServiceMockRecorder) AppendImageDigests(ctx, id, digests any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) InternalGet(ctx, releaseID any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) InternalGetActiveByStackID(ctx, stackID any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) InternalListActive(ctx any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) MarkFailed(ctx, id, message, outcome any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) MarkFailedWithValidationErrors(ctx, id, message, verrs any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) MarkInProgress(ctx, id any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) MarkReleased(ctx, id, outcome any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) MarkSuperseded(ctx, id, reason any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) SaveManifest(ctx, id, m, rev, pins, rendererVersion any) *gomock.Call
- func (mr *MockreleaseServiceMockRecorder) SetConvergeClockStartedAt(ctx, id, startedAt any) *gomock.Call
- type MocksecretService
- type MocksecretServiceMockRecorder
- type MockstackService
- type MockstackServiceMockRecorder
- type MocksubReconciler
- type MocksubReconcilerMockRecorder
- type MockvolumeService
- type MockvolumeServiceMockRecorder
- type ReleaseWorkerSpec
Constants ¶
const (
ReleaseWorkerName = "release-worker"
)
Variables ¶
This section is empty.
Functions ¶
func NewReleaseWorker ¶
func NewReleaseWorker(spec ReleaseWorkerSpec) worker.Worker
Types ¶
type MockeventRecorder ¶
type MockeventRecorder struct {
// contains filtered or unexported fields
}
MockeventRecorder is a mock of eventRecorder interface.
func NewMockeventRecorder ¶
func NewMockeventRecorder(ctrl *gomock.Controller) *MockeventRecorder
NewMockeventRecorder creates a new mock instance.
func (*MockeventRecorder) EXPECT ¶
func (m *MockeventRecorder) EXPECT() *MockeventRecorderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockeventRecorder) RecordReleaseChecksPassed ¶
func (m *MockeventRecorder) RecordReleaseChecksPassed(ctx context.Context, release *models.StackRelease) *errors.ServiceError
RecordReleaseChecksPassed mocks base method.
func (*MockeventRecorder) RecordReleaseChecksStarted ¶
func (m *MockeventRecorder) RecordReleaseChecksStarted(ctx context.Context, release *models.StackRelease) *errors.ServiceError
RecordReleaseChecksStarted mocks base method.
func (*MockeventRecorder) RecordReleaseStarted ¶
func (m *MockeventRecorder) RecordReleaseStarted(ctx context.Context, release *models.StackRelease) *errors.ServiceError
RecordReleaseStarted mocks base method.
type MockeventRecorderMockRecorder ¶
type MockeventRecorderMockRecorder struct {
// contains filtered or unexported fields
}
MockeventRecorderMockRecorder is the mock recorder for MockeventRecorder.
func (*MockeventRecorderMockRecorder) RecordReleaseChecksPassed ¶
func (mr *MockeventRecorderMockRecorder) RecordReleaseChecksPassed(ctx, release any) *gomock.Call
RecordReleaseChecksPassed indicates an expected call of RecordReleaseChecksPassed.
func (*MockeventRecorderMockRecorder) RecordReleaseChecksStarted ¶
func (mr *MockeventRecorderMockRecorder) RecordReleaseChecksStarted(ctx, release any) *gomock.Call
RecordReleaseChecksStarted indicates an expected call of RecordReleaseChecksStarted.
func (*MockeventRecorderMockRecorder) RecordReleaseStarted ¶
func (mr *MockeventRecorderMockRecorder) RecordReleaseStarted(ctx, release any) *gomock.Call
RecordReleaseStarted indicates an expected call of RecordReleaseStarted.
type MockimageBuildService ¶
type MockimageBuildService struct {
// contains filtered or unexported fields
}
MockimageBuildService is a mock of imageBuildService interface.
func NewMockimageBuildService ¶
func NewMockimageBuildService(ctrl *gomock.Controller) *MockimageBuildService
NewMockimageBuildService creates a new mock instance.
func (*MockimageBuildService) EXPECT ¶
func (m *MockimageBuildService) EXPECT() *MockimageBuildServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockimageBuildService) ListByStackID ¶
func (m *MockimageBuildService) ListByStackID(ctx context.Context, stackID string) ([]*models.ImageBuild, *errors.ServiceError)
ListByStackID mocks base method.
type MockimageBuildServiceMockRecorder ¶
type MockimageBuildServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockimageBuildServiceMockRecorder is the mock recorder for MockimageBuildService.
func (*MockimageBuildServiceMockRecorder) ListByStackID ¶
func (mr *MockimageBuildServiceMockRecorder) ListByStackID(ctx, stackID any) *gomock.Call
ListByStackID indicates an expected call of ListByStackID.
type MockpostgresAddonService ¶
type MockpostgresAddonService struct {
// contains filtered or unexported fields
}
MockpostgresAddonService is a mock of postgresAddonService interface.
func NewMockpostgresAddonService ¶
func NewMockpostgresAddonService(ctrl *gomock.Controller) *MockpostgresAddonService
NewMockpostgresAddonService creates a new mock instance.
func (*MockpostgresAddonService) EXPECT ¶
func (m *MockpostgresAddonService) EXPECT() *MockpostgresAddonServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockpostgresAddonService) InternalGetCredentials ¶
func (m *MockpostgresAddonService) InternalGetCredentials(ctx context.Context, addonID, database string, superuser bool) (*models.PostgresCredentials, *errors.ServiceError)
InternalGetCredentials mocks base method.
type MockpostgresAddonServiceMockRecorder ¶
type MockpostgresAddonServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockpostgresAddonServiceMockRecorder is the mock recorder for MockpostgresAddonService.
func (*MockpostgresAddonServiceMockRecorder) InternalGetCredentials ¶
func (mr *MockpostgresAddonServiceMockRecorder) InternalGetCredentials(ctx, addonID, database, superuser any) *gomock.Call
InternalGetCredentials indicates an expected call of InternalGetCredentials.
type MockregistryClientProvider ¶
type MockregistryClientProvider struct {
// contains filtered or unexported fields
}
MockregistryClientProvider is a mock of registryClientProvider interface.
func NewMockregistryClientProvider ¶
func NewMockregistryClientProvider(ctrl *gomock.Controller) *MockregistryClientProvider
NewMockregistryClientProvider creates a new mock instance.
func (*MockregistryClientProvider) ClientFor ¶
func (m *MockregistryClientProvider) ClientFor(resolved *credentials.ResolvedRegistryCredential) (clients.RegistryClient, error)
ClientFor mocks base method.
func (*MockregistryClientProvider) EXPECT ¶
func (m *MockregistryClientProvider) EXPECT() *MockregistryClientProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockregistryClientProviderMockRecorder ¶
type MockregistryClientProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockregistryClientProviderMockRecorder is the mock recorder for MockregistryClientProvider.
type MockreleaseService ¶
type MockreleaseService struct {
// contains filtered or unexported fields
}
MockreleaseService is a mock of releaseService interface.
func NewMockreleaseService ¶
func NewMockreleaseService(ctrl *gomock.Controller) *MockreleaseService
NewMockreleaseService creates a new mock instance.
func (*MockreleaseService) AppendImageDigests ¶
func (m *MockreleaseService) AppendImageDigests(ctx context.Context, id string, digests map[string]string) *errors.ServiceError
AppendImageDigests mocks base method.
func (*MockreleaseService) EXPECT ¶
func (m *MockreleaseService) EXPECT() *MockreleaseServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockreleaseService) InternalGet ¶
func (m *MockreleaseService) InternalGet(ctx context.Context, releaseID string) (*models.StackRelease, *errors.ServiceError)
InternalGet mocks base method.
func (*MockreleaseService) InternalGetActiveByStackID ¶
func (m *MockreleaseService) InternalGetActiveByStackID(ctx context.Context, stackID string) (*models.StackRelease, *errors.ServiceError)
InternalGetActiveByStackID mocks base method.
func (*MockreleaseService) InternalListActive ¶
func (m *MockreleaseService) InternalListActive(ctx context.Context) ([]*models.StackRelease, *errors.ServiceError)
InternalListActive mocks base method.
func (*MockreleaseService) MarkFailed ¶
func (m *MockreleaseService) MarkFailed(ctx context.Context, id, message string, outcome *models.ReleaseOutcome) (bool, *errors.ServiceError)
MarkFailed mocks base method.
func (*MockreleaseService) MarkFailedWithValidationErrors ¶
func (m *MockreleaseService) MarkFailedWithValidationErrors(ctx context.Context, id, message string, verrs models.ReleaseValidationErrors) (bool, *errors.ServiceError)
MarkFailedWithValidationErrors mocks base method.
func (*MockreleaseService) MarkInProgress ¶
func (m *MockreleaseService) MarkInProgress(ctx context.Context, id string) (bool, *errors.ServiceError)
MarkInProgress mocks base method.
func (*MockreleaseService) MarkReleased ¶
func (m *MockreleaseService) MarkReleased(ctx context.Context, id string, outcome models.ReleaseOutcome) (bool, *errors.ServiceError)
MarkReleased mocks base method.
func (*MockreleaseService) MarkSuperseded ¶
func (m *MockreleaseService) MarkSuperseded(ctx context.Context, id, reason string) (bool, *errors.ServiceError)
MarkSuperseded mocks base method.
func (*MockreleaseService) SaveManifest ¶
func (m_2 *MockreleaseService) SaveManifest(ctx context.Context, id string, m *models.ReleaseManifest, rev string, pins models.ReleasePins, rendererVersion string) (bool, *errors.ServiceError)
SaveManifest mocks base method.
func (*MockreleaseService) SetConvergeClockStartedAt ¶
func (m *MockreleaseService) SetConvergeClockStartedAt(ctx context.Context, id string, startedAt *time.Time) *errors.ServiceError
SetConvergeClockStartedAt mocks base method.
type MockreleaseServiceMockRecorder ¶
type MockreleaseServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockreleaseServiceMockRecorder is the mock recorder for MockreleaseService.
func (*MockreleaseServiceMockRecorder) AppendImageDigests ¶
func (mr *MockreleaseServiceMockRecorder) AppendImageDigests(ctx, id, digests any) *gomock.Call
AppendImageDigests indicates an expected call of AppendImageDigests.
func (*MockreleaseServiceMockRecorder) InternalGet ¶
func (mr *MockreleaseServiceMockRecorder) InternalGet(ctx, releaseID any) *gomock.Call
InternalGet indicates an expected call of InternalGet.
func (*MockreleaseServiceMockRecorder) InternalGetActiveByStackID ¶
func (mr *MockreleaseServiceMockRecorder) InternalGetActiveByStackID(ctx, stackID any) *gomock.Call
InternalGetActiveByStackID indicates an expected call of InternalGetActiveByStackID.
func (*MockreleaseServiceMockRecorder) InternalListActive ¶
func (mr *MockreleaseServiceMockRecorder) InternalListActive(ctx any) *gomock.Call
InternalListActive indicates an expected call of InternalListActive.
func (*MockreleaseServiceMockRecorder) MarkFailed ¶
func (mr *MockreleaseServiceMockRecorder) MarkFailed(ctx, id, message, outcome any) *gomock.Call
MarkFailed indicates an expected call of MarkFailed.
func (*MockreleaseServiceMockRecorder) MarkFailedWithValidationErrors ¶
func (mr *MockreleaseServiceMockRecorder) MarkFailedWithValidationErrors(ctx, id, message, verrs any) *gomock.Call
MarkFailedWithValidationErrors indicates an expected call of MarkFailedWithValidationErrors.
func (*MockreleaseServiceMockRecorder) MarkInProgress ¶
func (mr *MockreleaseServiceMockRecorder) MarkInProgress(ctx, id any) *gomock.Call
MarkInProgress indicates an expected call of MarkInProgress.
func (*MockreleaseServiceMockRecorder) MarkReleased ¶
func (mr *MockreleaseServiceMockRecorder) MarkReleased(ctx, id, outcome any) *gomock.Call
MarkReleased indicates an expected call of MarkReleased.
func (*MockreleaseServiceMockRecorder) MarkSuperseded ¶
func (mr *MockreleaseServiceMockRecorder) MarkSuperseded(ctx, id, reason any) *gomock.Call
MarkSuperseded indicates an expected call of MarkSuperseded.
func (*MockreleaseServiceMockRecorder) SaveManifest ¶
func (mr *MockreleaseServiceMockRecorder) SaveManifest(ctx, id, m, rev, pins, rendererVersion any) *gomock.Call
SaveManifest indicates an expected call of SaveManifest.
func (*MockreleaseServiceMockRecorder) SetConvergeClockStartedAt ¶
func (mr *MockreleaseServiceMockRecorder) SetConvergeClockStartedAt(ctx, id, startedAt any) *gomock.Call
SetConvergeClockStartedAt indicates an expected call of SetConvergeClockStartedAt.
type MocksecretService ¶
type MocksecretService struct {
// contains filtered or unexported fields
}
MocksecretService is a mock of secretService interface.
func NewMocksecretService ¶
func NewMocksecretService(ctrl *gomock.Controller) *MocksecretService
NewMocksecretService creates a new mock instance.
func (*MocksecretService) EXPECT ¶
func (m *MocksecretService) EXPECT() *MocksecretServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MocksecretService) InternalGetByID ¶
func (m *MocksecretService) InternalGetByID(ctx context.Context, id string) (*models.Secret, *errors.ServiceError)
InternalGetByID mocks base method.
type MocksecretServiceMockRecorder ¶
type MocksecretServiceMockRecorder struct {
// contains filtered or unexported fields
}
MocksecretServiceMockRecorder is the mock recorder for MocksecretService.
func (*MocksecretServiceMockRecorder) InternalGetByID ¶
func (mr *MocksecretServiceMockRecorder) InternalGetByID(ctx, id any) *gomock.Call
InternalGetByID indicates an expected call of InternalGetByID.
type MockstackService ¶
type MockstackService struct {
// contains filtered or unexported fields
}
MockstackService is a mock of stackService interface.
func NewMockstackService ¶
func NewMockstackService(ctrl *gomock.Controller) *MockstackService
NewMockstackService creates a new mock instance.
func (*MockstackService) EXPECT ¶
func (m *MockstackService) EXPECT() *MockstackServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockstackService) InternalGetStack ¶
func (m *MockstackService) InternalGetStack(ctx context.Context, ID string) (*models.Stack, *errors.ServiceError)
InternalGetStack mocks base method.
func (*MockstackService) UpdateStackCrRevision ¶
func (m *MockstackService) UpdateStackCrRevision(ctx context.Context, ID, revision string) *errors.ServiceError
UpdateStackCrRevision mocks base method.
type MockstackServiceMockRecorder ¶
type MockstackServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockstackServiceMockRecorder is the mock recorder for MockstackService.
func (*MockstackServiceMockRecorder) InternalGetStack ¶
func (mr *MockstackServiceMockRecorder) InternalGetStack(ctx, ID any) *gomock.Call
InternalGetStack indicates an expected call of InternalGetStack.
func (*MockstackServiceMockRecorder) UpdateStackCrRevision ¶
func (mr *MockstackServiceMockRecorder) UpdateStackCrRevision(ctx, ID, revision any) *gomock.Call
UpdateStackCrRevision indicates an expected call of UpdateStackCrRevision.
type MocksubReconciler ¶
type MocksubReconciler struct {
// contains filtered or unexported fields
}
MocksubReconciler is a mock of subReconciler interface.
func NewMocksubReconciler ¶
func NewMocksubReconciler(ctrl *gomock.Controller) *MocksubReconciler
NewMocksubReconciler creates a new mock instance.
func (*MocksubReconciler) EXPECT ¶
func (m *MocksubReconciler) EXPECT() *MocksubReconcilerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MocksubReconciler) Reconcile ¶
func (m *MocksubReconciler) Reconcile(ctx context.Context, release *models.StackRelease) (subReconcilerResult, error)
Reconcile mocks base method.
type MocksubReconcilerMockRecorder ¶
type MocksubReconcilerMockRecorder struct {
// contains filtered or unexported fields
}
MocksubReconcilerMockRecorder is the mock recorder for MocksubReconciler.
func (*MocksubReconcilerMockRecorder) Name ¶
func (mr *MocksubReconcilerMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
type MockvolumeService ¶
type MockvolumeService struct {
// contains filtered or unexported fields
}
MockvolumeService is a mock of volumeService interface.
func NewMockvolumeService ¶
func NewMockvolumeService(ctrl *gomock.Controller) *MockvolumeService
NewMockvolumeService creates a new mock instance.
func (*MockvolumeService) EXPECT ¶
func (m *MockvolumeService) EXPECT() *MockvolumeServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockvolumeService) ListVolumesUsedByStack ¶
func (m *MockvolumeService) ListVolumesUsedByStack(ctx context.Context, stackID string) ([]*models.Volume, *errors.ServiceError)
ListVolumesUsedByStack mocks base method.
type MockvolumeServiceMockRecorder ¶
type MockvolumeServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockvolumeServiceMockRecorder is the mock recorder for MockvolumeService.
func (*MockvolumeServiceMockRecorder) ListVolumesUsedByStack ¶
func (mr *MockvolumeServiceMockRecorder) ListVolumesUsedByStack(ctx, stackID any) *gomock.Call
ListVolumesUsedByStack indicates an expected call of ListVolumesUsedByStack.
type ReleaseWorkerSpec ¶
type ReleaseWorkerSpec struct {
ReleaseService releaseService
EventRecorder eventRecorder
StackService stackService
ImageBuildService imageBuildService
ClusterManager clustermanager.ClusterManager
CRBuilder builders.ClusterResourceBuilder
SecretBuilder builders.SecretBuilder
SecretService secretService
CredentialResolver credentials.Resolver
PostgresAddonService postgresAddonService
VolumeService volumeService
Resolver *stackdeploy.Resolver
ReleaseWorkerEnqueuer workermanager.BackgroundJobEnqueuer
ValidationRecords stores.ResourceValidationRecordStore
RegistryClients registryClientProvider
ImageRegistryStore stores.ClusterImageRegistryStore
ImageRegistryResource clusterresource.ClusterImageRegistryService
Env string
}