controllers

package
v0.0.0-...-dd65ee0 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2024 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: controllers/checkout.go

Generated by this command: 

mockgen -source controllers/checkout.go -package controllers -self_package=github.com/hybrid-cloud-patterns/patterns-operator/controllers

Package controllers is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: controllers/drift.go

Generated by this command: 

mockgen -source controllers/drift.go -package controllers -self_package=github.com/hybrid-cloud-patterns/patterns-operator/controllers

Package controllers is a generated GoMock package.

Index

Constants

View Source 
const (
	// UpdateEvent is the name of the update event
	PatternStartEvent   = "Pattern started"
	PatternEndEvent     = "Pattern completed"
	PatternRefreshEvent = "Pattern refreshed"

	// RefreshIntervalMinutes is the minimum time between updates (4h)
	RefreshIntervalMinutes float64 = 240

	// AnalyticsSent is an int bit-field that stores which info has already been sent
	AnalyticsSentIdentify = 0x0
	AnalyticsSentStart    = 0x1
	AnalyticsSentEnd      = 0x2
	AnalyticsSentRefresh  = 0x3

	MinSubDomainParts = 3
)
View Source 
const (
	// Default Operator Namespace
	OperatorNamespace = "openshift-operators"
	// Default Operator Config Map Name
	OperatorConfigMap = "patterns-operator-config"
	// Default Subscription Namespace
	SubscriptionNamespace = "openshift-operators"
	// Default Application Namespace
	ApplicationNamespace = "openshift-gitops"
)

Below are the default constants that we will use throughout the patterns operator code

View Source 
const (
	GitOpsDefaultChannel                = "gitops-1.11"
	GitOpsDefaultPackageName            = "openshift-gitops-operator"
	GitOpsDefaultCatalogSource          = "redhat-operators"
	GitOpsDefaultCatalogSourceNamespace = "openshift-marketplace"
	GitOpsDefaultApprovalPlan           = "Automatic"
)

GitOps Subscription

View Source 
const (
	// Require manual intervention before Argo will sync new content. Default: False
	GitOpsDefaultManualSync = "false"
	// Require manual confirmation before installing and upgrading operators. Default: False
	GitOpsDefaultManualApproval = "false"
	// Dangerous. Force a specific version to be installed. Default: False
	GitOpsDefaultUseCSV = "false"
)

GitOps Configuration

View Source 
const ReconcileLoopRequeueTime = 180 * time.Second
View Source 
const VPTmpFolder = "vp"

Variables

View Source 
var DefaultPatternOperatorConfig = map[string]string{
	"gitops.catalogSource":       GitOpsDefaultCatalogSource,
	"gitops.name":                GitOpsDefaultPackageName,
	"gitops.channel":             GitOpsDefaultChannel,
	"gitops.sourceNamespace":     GitOpsDefaultCatalogSourceNamespace,
	"gitops.installApprovalPlan": GitOpsDefaultApprovalPlan,
	"gitops.ManualSync":          GitOpsDefaultManualSync,
}

Functions

func DropLocalGitPaths 

func DropLocalGitPaths() error

func GetGit 

func GetGit(gitOps GitOperations, repoURL, revision, localFolder string, gitAuth map[string][]byte) error

Types

type GitAuthenticationBackend 

type GitAuthenticationBackend uint
const (
	GitAuthNone     GitAuthenticationBackend = 0
	GitAuthPassword GitAuthenticationBackend = 1
	GitAuthSsh      GitAuthenticationBackend = 2
)

type GitClient 

type GitClient interface {
	NewRemoteClient(c *config.RemoteConfig) RemoteClient
}

type GitOperations 

type GitOperations interface {
	CloneAndCheckout(repoURL, revision, localFolder string, gitAuth map[string][]byte) error
}

type GitOperationsImpl 

type GitOperationsImpl struct{}

func (*GitOperationsImpl) CloneAndCheckout 

func (g *GitOperationsImpl) CloneAndCheckout(repoURL, revision, localFolder string, gitAuth map[string][]byte) error

type GitOpsConfig 

type GitOpsConfig map[string]string
var PatternsOperatorConfig GitOpsConfig

type MockGitClient 

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

MockGitClient is a mock of GitClient interface.

func NewMockGitClient 

func NewMockGitClient(ctrl *gomock.Controller) *MockGitClient

NewMockGitClient creates a new mock instance.

func (*MockGitClient) EXPECT 

func (m *MockGitClient) EXPECT() *MockGitClientMockRecorder

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

func (*MockGitClient) NewRemoteClient 

func (m *MockGitClient) NewRemoteClient(c *config.RemoteConfig) RemoteClient

NewRemoteClient mocks base method.

type MockGitClientMockRecorder 

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

MockGitClientMockRecorder is the mock recorder for MockGitClient.

func (*MockGitClientMockRecorder) NewRemoteClient 

func (mr *MockGitClientMockRecorder) NewRemoteClient(c any) *gomock.Call

NewRemoteClient indicates an expected call of NewRemoteClient.

type MockGitOperations 

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

MockGitOperations is a mock of GitOperations interface.

func NewMockGitOperations 

func NewMockGitOperations(ctrl *gomock.Controller) *MockGitOperations

NewMockGitOperations creates a new mock instance.

func (*MockGitOperations) CloneAndCheckout 

func (m *MockGitOperations) CloneAndCheckout(repoURL, revision, localFolder string, gitAuth map[string][]byte) error

CloneAndCheckout mocks base method.

func (*MockGitOperations) EXPECT 

func (m *MockGitOperations) EXPECT() *MockGitOperationsMockRecorder

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

type MockGitOperationsMockRecorder 

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

MockGitOperationsMockRecorder is the mock recorder for MockGitOperations.

func (*MockGitOperationsMockRecorder) CloneAndCheckout 

func (mr *MockGitOperationsMockRecorder) CloneAndCheckout(repoURL, revision, localFolder, gitAuth any) *gomock.Call

CloneAndCheckout indicates an expected call of CloneAndCheckout.

type MockRemoteClient 

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

MockRemoteClient is a mock of RemoteClient interface.

func NewMockRemoteClient 

func NewMockRemoteClient(ctrl *gomock.Controller) *MockRemoteClient

NewMockRemoteClient creates a new mock instance.

func (*MockRemoteClient) EXPECT 

func (m *MockRemoteClient) EXPECT() *MockRemoteClientMockRecorder

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

func (*MockRemoteClient) List 

func (m *MockRemoteClient) List(o *v5.ListOptions) ([]*plumbing.Reference, error)

List mocks base method.

type MockRemoteClientMockRecorder 

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

MockRemoteClientMockRecorder is the mock recorder for MockRemoteClient.

func (*MockRemoteClientMockRecorder) List 

func (mr *MockRemoteClientMockRecorder) List(o any) *gomock.Call

List indicates an expected call of List.

type MockdriftWatcher 

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

MockdriftWatcher is a mock of driftWatcher interface.

func NewMockdriftWatcher 

func NewMockdriftWatcher(ctrl *gomock.Controller) *MockdriftWatcher

NewMockdriftWatcher creates a new mock instance.

func (*MockdriftWatcher) EXPECT 

func (m *MockdriftWatcher) EXPECT() *MockdriftWatcherMockRecorder

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

type MockdriftWatcherMockRecorder 

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

MockdriftWatcherMockRecorder is the mock recorder for MockdriftWatcher.

type PatternReconciler 

type PatternReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	AnalyticsClient VpAnalyticsInterface
	// contains filtered or unexported fields
}

PatternReconciler reconciles a Pattern object

func (*PatternReconciler) Reconcile 

func (r *PatternReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. The Reconcile function compares the state specified by the Pattern object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.10.0/pkg/reconcile

func (*PatternReconciler) SetupWithManager 

func (r *PatternReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RemoteClient 

type RemoteClient interface {
	List(o *git.ListOptions) (rfs []*plumbing.Reference, err error)
}

type VpAnalytics 

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

func AnalyticsInit 

func AnalyticsInit(disabled bool, logger logr.Logger) *VpAnalytics

func (*VpAnalytics) SendPatternEndEventInfo 

func (v *VpAnalytics) SendPatternEndEventInfo(p *api.Pattern) bool

Sends an EndEvent the first time it is invoked. Subsequent invocations will send a Refresh event returns true if the status object in the crd should be updated

func (*VpAnalytics) SendPatternInstallationInfo 

func (v *VpAnalytics) SendPatternInstallationInfo(p *api.Pattern) bool

This called at the beginning of the reconciliation loop and only once returns true if the status object in the crd should be updated

func (*VpAnalytics) SendPatternStartEventInfo 

func (v *VpAnalytics) SendPatternStartEventInfo(p *api.Pattern) bool

returns true if the status object in the crd should be updated

type VpAnalyticsInterface 

type VpAnalyticsInterface interface {
	SendPatternInstallationInfo(p *api.Pattern) bool
	SendPatternStartEventInfo(p *api.Pattern) bool
	SendPatternEndEventInfo(p *api.Pattern) bool
}

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.