Documentation
¶
Index ¶
- Constants
- Variables
- func CheckHealth(ctx context.Context, m *mesheryv1alpha1.MeshSync, client *kubernetes.Clientset) error
- func ErrConditionFalse(reason string) error
- func ErrGettingEndpoint(err error) error
- func ErrGettingResource(err error) error
- func ErrReplicasNotReady(reason string) error
- func GetObjects(m *mesheryv1alpha1.MeshSync) map[string]Object
- type Object
Constants ¶
View Source
const ( ErrGettingResourceCode = "1013" ErrReplicasNotReadyCode = "1014" ErrConditionFalseCode = "1015" ErrGettingEndpointCode = "1016" )
View Source
const (
ServerObject = "server-object"
)
Variables ¶
View Source
var ( MesheryLabel = map[string]string{ "app": "meshery", } MeshSyncLabel = map[string]string{ "app": MesheryLabel["app"], "component": "meshsync", } MesheryAnnotation = map[string]string{ "meshery/component-type": "management-plane", } // Resource limits and requests CPURequest = resource.MustParse("500m") CPULimit = resource.MustParse("4") MemoryRequest = resource.MustParse("512Mi") MemoryLimit = resource.MustParse("4Gi") Deployment = &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "meshery-meshsync", Labels: MeshSyncLabel, Annotations: MesheryAnnotation, }, Spec: appsv1.DeploymentSpec{ Replicas: &val1, Selector: &metav1.LabelSelector{ MatchLabels: MeshSyncLabel, }, Template: PodTemplate, }, } PodTemplate = corev1.PodTemplateSpec{ ObjectMeta: metav1.ObjectMeta{ Name: "meshery-meshsync", Labels: MeshSyncLabel, Annotations: MesheryAnnotation, }, Spec: corev1.PodSpec{ ServiceAccountName: "meshery-operator", ShareProcessNamespace: &valtrue, TerminationGracePeriodSeconds: &val60, Containers: []corev1.Container{ { Name: "meshsync", Image: "meshery/meshsync:stable-latest", ImagePullPolicy: corev1.PullAlways, Ports: []corev1.ContainerPort{ { Name: "client", HostPort: val11000, ContainerPort: val11000, }, }, Command: []string{ "./meshery-meshsync", }, Env: []corev1.EnvVar{ { Name: "BROKER_URL", Value: "http://localhost:4222", }, }, Resources: corev1.ResourceRequirements{ Requests: corev1.ResourceList{ corev1.ResourceCPU: CPURequest, corev1.ResourceMemory: MemoryRequest, }, Limits: corev1.ResourceList{ corev1.ResourceCPU: CPULimit, corev1.ResourceMemory: MemoryLimit, }, }, }, }, }, } )
Functions ¶
func CheckHealth ¶
func CheckHealth(ctx context.Context, m *mesheryv1alpha1.MeshSync, client *kubernetes.Clientset) error
func ErrConditionFalse ¶
func ErrGettingEndpoint ¶
func ErrGettingResource ¶
func ErrReplicasNotReady ¶
func GetObjects ¶
func GetObjects(m *mesheryv1alpha1.MeshSync) map[string]Object
Types ¶
Click to show internal directories.
Click to hide internal directories.