helpers

Documentation

Index

• Constants
• func ApplyCRDDirectly(clients *CRDClientHolder, recorder events.Recorder, ...) []resourceapply.ApplyResult
• func ApplyManifestWork(ctx context.Context, client workclient.Interface, ...) error
• func CleanUpSubmarinerManifests(ctx context.Context, client kubernetes.Interface, recorder events.Recorder, ...) error
• func GenerateIPSecPSKSecret(client kubernetes.Interface, brokerNamespace string) error
• func GetBrokerAPIServer(dynamicClient dynamic.Interface) (string, error)
• func GetBrokerTokenAndCA(client kubernetes.Interface, brokerNS, clusterName string) (token, ca string, err error)
• func GetClusterType(managedCluster *clusterv1.ManagedCluster) string
• func GetEnv(key, defaultValue string) string
• func GetIPSecPSK(client kubernetes.Interface, brokerNamespace string) (string, error)
• func GetManagedClusterInfo(managedCluster *clusterv1.ManagedCluster) configv1alpha1.ManagedClusterInfo
• func UpdateSubmarinerConfigStatus(client configclient.Interface, namespace, name string, ...) (*configv1alpha1.SubmarinerConfigStatus, bool, error)
• type CRDClientHolder
  • func NewCRDClientHolder() *CRDClientHolder
  • func (c *CRDClientHolder) WithAPIExtensionsClient(client apiextensionsclient.Interface) *CRDClientHolder
• type UpdateSubmarinerConfigStatusFunc
  • func UpdateSubmarinerConfigConditionFn(cond metav1.Condition) UpdateSubmarinerConfigStatusFunc
  • func UpdateSubmarinerConfigStatusFn(cond metav1.Condition, managedClusterInfo configv1alpha1.ManagedClusterInfo) UpdateSubmarinerConfigStatusFunc

Constants

const (
	ClusterTypeOCP       = "OCP"
	IPSecPSKSecretLength = 48
	IPSecPSKSecretName   = "submariner-ipsec-psk"
	BrokerAPIServer      = "BROKER_API_SERVER"
)

const (
	SubmarinerIKEPort     = 500
	SubmarinerNatTPort    = 4500
	SubmarinerRoutePort   = 4800
	SubmarinerMetricsPort = 8080
)

Functions

func ApplyCRDDirectly

func ApplyCRDDirectly(
	clients *CRDClientHolder,
	recorder events.Recorder,
	manifests resourceapply.AssetFunc,
	files ...string) []resourceapply.ApplyResult

ApplyCRDDirectly is used to apply CRD v1 and v1beta1 since resourceapply in library-go cannot apply CRD v1 with error

func ApplyManifestWork

func ApplyManifestWork(ctx context.Context, client workclient.Interface, required *workv1.ManifestWork) error

func CleanUpSubmarinerManifests

func CleanUpSubmarinerManifests(
	ctx context.Context,
	client kubernetes.Interface,
	recorder events.Recorder,
	assetFunc resourceapply.AssetFunc,
	files ...string) error

CleanUpSubmarinerManifests clean up submariner resources from its manifest files

func GenerateIPSecPSKSecret

func GenerateIPSecPSKSecret(client kubernetes.Interface, brokerNamespace string) error

func GetBrokerAPIServer

func GetBrokerAPIServer(dynamicClient dynamic.Interface) (string, error)

func GetBrokerTokenAndCA

func GetBrokerTokenAndCA(client kubernetes.Interface, brokerNS, clusterName string) (token, ca string, err error)

func GetClusterType

func GetClusterType(managedCluster *clusterv1.ManagedCluster) string

func GetEnv

func GetEnv(key, defaultValue string) string

func GetIPSecPSK

func GetIPSecPSK(client kubernetes.Interface, brokerNamespace string) (string, error)

func GetManagedClusterInfo

func GetManagedClusterInfo(managedCluster *clusterv1.ManagedCluster) configv1alpha1.ManagedClusterInfo

func UpdateSubmarinerConfigStatus

func UpdateSubmarinerConfigStatus(
	client configclient.Interface,
	namespace, name string,
	updateFuncs ...UpdateSubmarinerConfigStatusFunc) (*configv1alpha1.SubmarinerConfigStatus, bool, error)

Types

type CRDClientHolder

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

func NewCRDClientHolder

func NewCRDClientHolder() *CRDClientHolder

func (*CRDClientHolder) WithAPIExtensionsClient

func (c *CRDClientHolder) WithAPIExtensionsClient(client apiextensionsclient.Interface) *CRDClientHolder

type UpdateSubmarinerConfigStatusFunc

type UpdateSubmarinerConfigStatusFunc func(status *configv1alpha1.SubmarinerConfigStatus) error

func UpdateSubmarinerConfigConditionFn

func UpdateSubmarinerConfigConditionFn(cond metav1.Condition) UpdateSubmarinerConfigStatusFunc

func UpdateSubmarinerConfigStatusFn

func UpdateSubmarinerConfigStatusFn(cond metav1.Condition, managedClusterInfo configv1alpha1.ManagedClusterInfo) UpdateSubmarinerConfigStatusFunc