-
Notifications
You must be signed in to change notification settings - Fork 40
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
The conditions.NewCondition function reads cluster state to determine the namespace the operator is running in so that it can manipulate the correct OperatorConditions object in a cluster. However this function's dependency on a specific file existing in a specific location makes it difficult to test code that uses it. The Factory interface is introduced to enable users to provide their own implementations for building a Condition object to manage OperatorCondition resources. Users can now build a factory and inject it into code that builds new conditions. This enables code under test to use the Factory abstraction and enables operator authors to inject custom functionality needed when writing tests.
- Loading branch information
1 parent
0449c0c
commit cf980c8
Showing
3 changed files
with
80 additions
and
57 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,80 @@ | ||
package conditions | ||
|
||
import ( | ||
"fmt" | ||
"os" | ||
|
||
apiv1 "github.com/operator-framework/api/pkg/operators/v1" | ||
"k8s.io/apimachinery/pkg/types" | ||
"sigs.k8s.io/controller-runtime/pkg/client" | ||
|
||
"github.com/operator-framework/operator-lib/internal/utils" | ||
) | ||
|
||
// Factory define the interface for building Conditions. | ||
type Factory interface { | ||
NewCondition(apiv1.ConditionType) (Condition, error) | ||
} | ||
|
||
// InClusterFactory is an implementation of Factory that build Conditions | ||
// ready to be used in a cluster. | ||
type InClusterFactory struct { | ||
Client client.Client | ||
} | ||
|
||
// NewCondition creates a new Condition using the provided client and condition | ||
// type. The condition's name and namespace are determined by the Factory's GetName | ||
// and GetNamespace functions. | ||
func (f InClusterFactory) NewCondition(condType apiv1.ConditionType) (Condition, error) { | ||
conditionName, err := f.getConditionName() | ||
if err != nil { | ||
return nil, fmt.Errorf("get operator condition name: %v", err) | ||
} | ||
conditionNamespace, err := f.getConditionNamespace() | ||
if err != nil { | ||
return nil, fmt.Errorf("get operator condition namespace: %v", err) | ||
} | ||
|
||
objKey := types.NamespacedName{Name: conditionName, Namespace: conditionNamespace} | ||
return &condition{ | ||
namespacedName: objKey, | ||
condType: condType, | ||
client: f.Client, | ||
}, nil | ||
} | ||
|
||
const ( | ||
// operatorCondEnvVar is the env variable which | ||
// contains the name of the Condition CR associated to the operator, | ||
// set by OLM. | ||
operatorCondEnvVar = "OPERATOR_CONDITION_NAME" | ||
) | ||
|
||
// DefaultGetConditionName reads and returns the OPERATOR_CONDITION_NAME environment | ||
// variable. If the variable is unset or empty, it returns an error. | ||
func (f InClusterFactory) getConditionName() (string, error) { | ||
name := os.Getenv(operatorCondEnvVar) | ||
if name == "" { | ||
return "", fmt.Errorf("could not determine operator condition name: environment variable %s not set", operatorCondEnvVar) | ||
} | ||
return name, nil | ||
} | ||
|
||
// readNamespace gets the namespacedName of the operator. | ||
var readNamespace = utils.GetOperatorNamespace | ||
|
||
// DefaultGetConditionNamespace reads the namespace file mounted into a pod in a | ||
// cluster via its service account volume. If the file is not found or cannot be | ||
// read, this function returns an error. | ||
func (f InClusterFactory) getConditionNamespace() (string, error) { | ||
return readNamespace() | ||
} | ||
|
||
// NewCondition returns a new Condition interface using the provided client | ||
// for the specified conditionType. The condition will internally fetch the namespacedName | ||
// of the operatorConditionCRD. | ||
// | ||
// Deprecated: Use InClusterFactory{}.NewCondition() instead. | ||
func NewCondition(cl client.Client, condType apiv1.ConditionType) (Condition, error) { | ||
return InClusterFactory{cl}.NewCondition(condType) | ||
} |
Oops, something went wrong.