crunchybridgecluster

package
v2.8.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2025 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

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

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

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL