common

Documentation

Index

• Constants
• func Cleanup(cmd *cobra.Command, cleanOpts *CleanOptions) error
• func ConvertMemberTokenSecret(secret *corev1.Secret) *corev1.Secret
• func CreateClusterClaim(cmd *cobra.Command, k8sClient client.Client, namespace string, ...) error
• func CreateClusterSet(cmd *cobra.Command, k8sClient client.Client, namespace string, ...) error
• func CreateMemberToken(cmd *cobra.Command, k8sClient client.Client, name string, namespace string, ...) error
• func DeleteMemberToken(cmd *cobra.Command, k8sClient client.Client, name string, namespace string) error
• func NewClient(cmd *cobra.Command) (client.Client, error)
• func OutputJoinConfig(cmd *cobra.Command, writer io.Writer, ...) error
• func OutputMemberTokenSecret(tokenSecret *corev1.Secret, writer io.Writer) error
• func Rollback(cmd *cobra.Command, k8sClient client.Client, res []map[string]interface{}) error
• type CleanOptions
• type ClusterSetJoinConfig
• type FakeCtrlRuntimeClient
  • func (fc FakeCtrlRuntimeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (fc FakeCtrlRuntimeClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (fc FakeCtrlRuntimeClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Constants

const (
	ClusterSetJoinConfigAPIVersion = "multicluster.antrea.io/v1alpha1"
	ClusterSetJoinConfigKind       = "ClusterSetJoinConfig"

	CreateByAntctlAnnotation = "multicluster.antrea.io/created-by-antctl"

	DefaultMemberNamespace = "kube-system"
	DefaultLeaderNamespace = "antrea-multicluster"
)

Functions

func Cleanup

func Cleanup(cmd *cobra.Command, cleanOpts *CleanOptions) error

func ConvertMemberTokenSecret

func ConvertMemberTokenSecret(secret *corev1.Secret) *corev1.Secret

ConvertMemberTokenSecret generates a token Secret manifest for creating the input Secret in a member cluster.

func CreateClusterClaim

func CreateClusterClaim(cmd *cobra.Command, k8sClient client.Client, namespace string, clusterset string, clusterID string, createdRes *[]map[string]interface{}) error

func CreateClusterSet

func CreateClusterSet(cmd *cobra.Command, k8sClient client.Client, namespace string, clusterset string,
	leaderServer string, secret string, memberClusterID string, leaderClusterID string, leaderClusterNamespace string, createdRes *[]map[string]interface{}) error

func CreateMemberToken

func CreateMemberToken(cmd *cobra.Command, k8sClient client.Client, name string, namespace string, createdRes *[]map[string]interface{}) error

func DeleteMemberToken

func DeleteMemberToken(cmd *cobra.Command, k8sClient client.Client, name string, namespace string) error

func NewClient

func NewClient(cmd *cobra.Command) (client.Client, error)

func OutputJoinConfig

func OutputJoinConfig(cmd *cobra.Command, writer io.Writer, clusterSetID, leaderClusterID, leaderNamespace string, tokenSecret *corev1.Secret) error

func OutputMemberTokenSecret

func OutputMemberTokenSecret(tokenSecret *corev1.Secret, writer io.Writer) error

func Rollback

func Rollback(cmd *cobra.Command, k8sClient client.Client, res []map[string]interface{}) error

Types

type CleanOptions

type CleanOptions struct {
	Namespace  string
	ClusterSet string
	K8sClient  client.Client
}

type ClusterSetJoinConfig

type ClusterSetJoinConfig struct {
	APIVersion      string `yaml:"apiVersion"`
	Kind            string `yaml:"kind"`
	ClusterSetID    string `yaml:"clusterSetID"`
	ClusterID       string `yaml:"clusterID,omitempty"`
	Namespace       string `yaml:"namespace,omitempty"`
	LeaderClusterID string `yaml:"leaderClusterID"`
	LeaderNamespace string `yaml:"leaderNamespace"`
	LeaderAPIServer string `yaml:"leaderAPIServer"`
	TokenSecretName string `yaml:"tokenSecretName,omitempty"`
	TokenSecretFile string `yaml:"tokenSecretFile,omitempty"`
}

"omitempty" fields (clusterID, namespace, tokenSecretName, tokenSecretFile) can be populated by the corresponding command line options if not set in the config file.

type FakeCtrlRuntimeClient

type FakeCtrlRuntimeClient struct {
	client.Client
	ShouldError bool
}

func (FakeCtrlRuntimeClient) Create

func (fc FakeCtrlRuntimeClient) Create(
	ctx context.Context,
	obj client.Object,
	opts ...client.CreateOption) error

func (FakeCtrlRuntimeClient) Delete

func (fc FakeCtrlRuntimeClient) Delete(
	ctx context.Context,
	obj client.Object,
	opts ...client.DeleteOption) error

func (FakeCtrlRuntimeClient) Update

func (fc FakeCtrlRuntimeClient) Update(
	ctx context.Context,
	obj client.Object,
	opts ...client.UpdateOption) error