meshsync

Documentation

Index

• Constants
• Variables
• func CheckHealth(ctx context.Context, m *meshplayv1alpha1.MeshSync, ...) error
• func ErrConditionFalse(reason string) error
• func ErrGettingEndpoint(err error) error
• func ErrGettingResource(err error) error
• func ErrReplicasNotReady(reason string) error
• func GetObjects(m *meshplayv1alpha1.MeshSync) map[string]Object
• type Object

Constants

const (
	ErrGettingResourceCode  = "1013"
	ErrReplicasNotReadyCode = "1014"
	ErrConditionFalseCode   = "1015"
	ErrGettingEndpointCode  = "1016"
)

const (
	ServerObject = "server-object"
)

Variables

var (
	MeshplayLabel = map[string]string{
		"app": "meshplay",
	}

	MeshSyncLabel = map[string]string{
		"app":       MeshplayLabel["app"],
		"component": "meshsync",
	}

	MeshplayAnnotation = map[string]string{
		"meshplay/component-type": "management-plane",
	}

	Deployment = &appsv1.Deployment{
		ObjectMeta: metav1.ObjectMeta{
			Name:        "meshplay-meshsync",
			Labels:      MeshSyncLabel,
			Annotations: MeshplayAnnotation,
		},
		Spec: appsv1.DeploymentSpec{
			Replicas: &val1,
			Selector: &metav1.LabelSelector{
				MatchLabels: MeshSyncLabel,
			},
			Template: PodTemplate,
		},
	}

	PodTemplate = corev1.PodTemplateSpec{
		ObjectMeta: metav1.ObjectMeta{
			Name:        "meshplay-meshsync",
			Labels:      MeshSyncLabel,
			Annotations: MeshplayAnnotation,
		},
		Spec: corev1.PodSpec{
			ServiceAccountName:            "meshplay-operator",
			ShareProcessNamespace:         &valtrue,
			TerminationGracePeriodSeconds: &val60,
			Containers: []corev1.Container{
				{
					Name:            "meshsync",
					Image:           "khulnasoft/meshsync:stable-latest",
					ImagePullPolicy: corev1.PullAlways,
					Ports: []corev1.ContainerPort{
						{
							Name:          "client",
							HostPort:      val11000,
							ContainerPort: val11000,
						},
					},
					Command: []string{
						"./meshplay-meshsync", "--broker-url", "$(BROKER_URL)",
					},
					Env: []corev1.EnvVar{
						{
							Name:  "BROKER_URL",
							Value: "http://localhost:4222",
						},
					},
				},
			},
		},
	}
)

Functions

func CheckHealth

func CheckHealth(ctx context.Context, m *meshplayv1alpha1.MeshSync, client *kubernetes.Clientset) error

func ErrConditionFalse

func ErrConditionFalse(reason string) error

func ErrGettingEndpoint

func ErrGettingEndpoint(err error) error

func ErrGettingResource

func ErrGettingResource(err error) error

func ErrReplicasNotReady

func ErrReplicasNotReady(reason string) error

func GetObjects

func GetObjects(m *meshplayv1alpha1.MeshSync) map[string]Object

Types

type Object

type Object interface {
	runtime.Object
	metav1.Object
}