cloudmap

Documentation

Index

• func ArePodContainersReady(pod *corev1.Pod) bool
• func NewDefaultInstancesReconciler(k8sClient client.Client, cloudMapSDK services.CloudMap, log logr.Logger, ...) *defaultInstancesReconciler
• func NewDefaultVirtualNodeEndpointResolver(k8sClient client.Client, log logr.Logger) *defaultVirtualNodeEndpointResolver
• func NewEnqueueRequestsForPodEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForPodEvents
• func ShouldPodBeInEndpoints(pod *corev1.Pod) bool
• type InstancesReconciler
• type ResourceManager
  • func NewDefaultResourceManager(k8sClient client.Client, cloudMapSDK services.CloudMap, ...) ResourceManager
• type VirtualNodeEndpointResolver

Functions

func ArePodContainersReady

func ArePodContainersReady(pod *corev1.Pod) bool

func NewDefaultInstancesReconciler

func NewDefaultInstancesReconciler(k8sClient client.Client, cloudMapSDK services.CloudMap, log logr.Logger, stopChan <-chan struct{}) *defaultInstancesReconciler

func NewDefaultVirtualNodeEndpointResolver

func NewDefaultVirtualNodeEndpointResolver(k8sClient client.Client, log logr.Logger) *defaultVirtualNodeEndpointResolver

func NewEnqueueRequestsForPodEvents

func NewEnqueueRequestsForPodEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForPodEvents

func ShouldPodBeInEndpoints

func ShouldPodBeInEndpoints(pod *corev1.Pod) bool

Types

type InstancesReconciler

type InstancesReconciler interface {
	Reconcile(ctx context.Context, ms *appmesh.Mesh, vn *appmesh.VirtualNode, service serviceSummary,
		readyPods []*corev1.Pod, notReadyPods []*corev1.Pod, nodeInfoByName map[string]nodeAttributes) error
}

type ResourceManager

type ResourceManager interface {
	// Reconcile will create/update AppMesh CloudMap Resources
	Reconcile(ctx context.Context, vn *appmesh.VirtualNode) error

	// Cleanup will delete AppMesh CloudMap resources created for VirtualNode.
	Cleanup(ctx context.Context, vn *appmesh.VirtualNode) error
}

func NewDefaultResourceManager

func NewDefaultResourceManager(
	k8sClient client.Client,
	cloudMapSDK services.CloudMap,
	referencesResolver references.Resolver,
	virtualNodeEndpointResolver VirtualNodeEndpointResolver,
	instancesReconciler InstancesReconciler,
	enableCustomHealthCheck bool,
	log logr.Logger) ResourceManager

type VirtualNodeEndpointResolver

type VirtualNodeEndpointResolver interface {
	Resolve(ctx context.Context, vn *appmesh.VirtualNode) ([]*corev1.Pod, []*corev1.Pod, []*corev1.Pod, error)
}