Documentation
¶
Index ¶
- type CrunchyBridgeClusterReconciler
- func (r *CrunchyBridgeClusterReconciler) GetSecretKeys(ctx context.Context, crunchyBridgeCluster *v1beta1.CrunchyBridgeCluster) (string, string, error)
- func (r *CrunchyBridgeClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *CrunchyBridgeClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *CrunchyBridgeClusterReconciler) Watch() handler.EventHandler
- type TestBridgeClient
- func (tbc *TestBridgeClient) CreateCluster(ctx context.Context, apiKey string, ...) (*bridge.ClusterApiResource, error)
- func (tbc *TestBridgeClient) DeleteCluster(ctx context.Context, apiKey, clusterId string) (*bridge.ClusterApiResource, bool, error)
- func (tbc *TestBridgeClient) GetCluster(ctx context.Context, apiKey, id string) (*bridge.ClusterApiResource, error)
- func (tbc *TestBridgeClient) GetClusterRole(ctx context.Context, apiKey, clusterId, roleName string) (*bridge.ClusterRoleApiResource, error)
- func (tbc *TestBridgeClient) GetClusterStatus(ctx context.Context, apiKey, id string) (*bridge.ClusterStatusApiResource, error)
- func (tbc *TestBridgeClient) GetClusterUpgrade(ctx context.Context, apiKey, id string) (*bridge.ClusterUpgradeApiResource, error)
- func (tbc *TestBridgeClient) ListClusters(ctx context.Context, apiKey, teamId string) ([]*bridge.ClusterApiResource, error)
- func (tbc *TestBridgeClient) UpdateCluster(ctx context.Context, apiKey, id string, ...) (*bridge.ClusterApiResource, error)
- func (tbc *TestBridgeClient) UpgradeCluster(ctx context.Context, apiKey, id string, ...) (*bridge.ClusterUpgradeApiResource, error)
- func (tbc *TestBridgeClient) UpgradeClusterHA(ctx context.Context, apiKey, id, action string) (*bridge.ClusterUpgradeApiResource, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CrunchyBridgeClusterReconciler ¶
type CrunchyBridgeClusterReconciler struct {
client.Client
Owner client.FieldOwner
// NewClient is called each time a new Client is needed.
NewClient func() bridge.ClientInterface
}
CrunchyBridgeClusterReconciler reconciles a CrunchyBridgeCluster object
func (*CrunchyBridgeClusterReconciler) GetSecretKeys ¶
func (r *CrunchyBridgeClusterReconciler) GetSecretKeys( ctx context.Context, crunchyBridgeCluster *v1beta1.CrunchyBridgeCluster, ) (string, string, error)
GetSecretKeys gets the secret and returns the expected API key and team id or an error if either of those fields or the Secret are missing
func (*CrunchyBridgeClusterReconciler) Reconcile ¶
func (r *CrunchyBridgeClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile does the work to move the current state of the world toward the desired state described in a v1beta1.CrunchyBridgeCluster identified by req.
func (*CrunchyBridgeClusterReconciler) SetupWithManager ¶
func (r *CrunchyBridgeClusterReconciler) SetupWithManager( mgr ctrl.Manager, ) error
SetupWithManager sets up the controller with the Manager.
func (*CrunchyBridgeClusterReconciler) Watch ¶
func (r *CrunchyBridgeClusterReconciler) Watch() handler.EventHandler
Watch enqueues all existing CrunchyBridgeClusters for reconciles.
type TestBridgeClient ¶
type TestBridgeClient struct {
ApiKey string `json:"apiKey,omitempty"`
TeamId string `json:"teamId,omitempty"`
Clusters []*bridge.ClusterApiResource `json:"clusters,omitempty"`
ClusterRoles []*bridge.ClusterRoleApiResource `json:"clusterRoles,omitempty"`
ClusterStatuses map[string]*bridge.ClusterStatusApiResource `json:"clusterStatuses,omitempty"`
ClusterUpgrades map[string]*bridge.ClusterUpgradeApiResource `json:"clusterUpgrades,omitempty"`
}
func (*TestBridgeClient) CreateCluster ¶
func (tbc *TestBridgeClient) CreateCluster(ctx context.Context, apiKey string, clusterRequestPayload *bridge.PostClustersRequestPayload) (*bridge.ClusterApiResource, error)
func (*TestBridgeClient) DeleteCluster ¶
func (tbc *TestBridgeClient) DeleteCluster(ctx context.Context, apiKey, clusterId string) (*bridge.ClusterApiResource, bool, error)
func (*TestBridgeClient) GetCluster ¶
func (tbc *TestBridgeClient) GetCluster(ctx context.Context, apiKey, id string) (*bridge.ClusterApiResource, error)
func (*TestBridgeClient) GetClusterRole ¶
func (tbc *TestBridgeClient) GetClusterRole(ctx context.Context, apiKey, clusterId, roleName string) (*bridge.ClusterRoleApiResource, error)
func (*TestBridgeClient) GetClusterStatus ¶
func (tbc *TestBridgeClient) GetClusterStatus(ctx context.Context, apiKey, id string) (*bridge.ClusterStatusApiResource, error)
func (*TestBridgeClient) GetClusterUpgrade ¶
func (tbc *TestBridgeClient) GetClusterUpgrade(ctx context.Context, apiKey, id string) (*bridge.ClusterUpgradeApiResource, error)
func (*TestBridgeClient) ListClusters ¶
func (tbc *TestBridgeClient) ListClusters(ctx context.Context, apiKey, teamId string) ([]*bridge.ClusterApiResource, error)
func (*TestBridgeClient) UpdateCluster ¶
func (tbc *TestBridgeClient) UpdateCluster(ctx context.Context, apiKey, id string, clusterRequestPayload *bridge.PatchClustersRequestPayload, ) (*bridge.ClusterApiResource, error)
func (*TestBridgeClient) UpgradeCluster ¶
func (tbc *TestBridgeClient) UpgradeCluster(ctx context.Context, apiKey, id string, clusterRequestPayload *bridge.PostClustersUpgradeRequestPayload, ) (*bridge.ClusterUpgradeApiResource, error)
func (*TestBridgeClient) UpgradeClusterHA ¶
func (tbc *TestBridgeClient) UpgradeClusterHA(ctx context.Context, apiKey, id, action string, ) (*bridge.ClusterUpgradeApiResource, error)
Click to show internal directories.
Click to hide internal directories.