virtualnode

Documentation

Index

• func BuildSDKVirtualNodeSpec(vn *appmesh.VirtualNode, ...) (*appmeshsdk.VirtualNodeSpec, error)
• func ExtractVirtualServiceReferences(vn *appmesh.VirtualNode) []appmesh.VirtualServiceReference
• func IsVirtualNodeActive(vn *appmesh.VirtualNode) bool
• func NewEnqueueRequestsForMeshEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForMeshEvents
• type MembershipDesignator
  • func NewMembershipDesignator(k8sClient client.Client) MembershipDesignator
• type ResourceManager
  • func NewDefaultResourceManager(k8sClient client.Client, appMeshSDK services.AppMesh, ...) ResourceManager

Functions

func BuildSDKVirtualNodeSpec

func BuildSDKVirtualNodeSpec(vn *appmesh.VirtualNode, vsByKey map[types.NamespacedName]*appmesh.VirtualService) (*appmeshsdk.VirtualNodeSpec, error)

func ExtractVirtualServiceReferences

func ExtractVirtualServiceReferences(vn *appmesh.VirtualNode) []appmesh.VirtualServiceReference

ExtractVirtualServiceReferences extracts all virtualServiceReferences for this VirtualNode

func IsVirtualNodeActive

func IsVirtualNodeActive(vn *appmesh.VirtualNode) bool

IsVirtualNodeActive checks whether given virtualNode is active. virtualNode is active when its VirtualNodeActive condition equals true.

func NewEnqueueRequestsForMeshEvents

func NewEnqueueRequestsForMeshEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForMeshEvents

Types

type MembershipDesignator

type MembershipDesignator interface {
	// Designate will choose a VirtualNode for given pod or nil if it don't belong to any VirtualNode.
	Designate(ctx context.Context, pod *corev1.Pod) (*appmesh.VirtualNode, error)
}

MembershipDesignator designates VirtualNode membership for pods.

func NewMembershipDesignator

func NewMembershipDesignator(k8sClient client.Client) MembershipDesignator

NewMembershipDesignator creates new MembershipDesignator.

type ResourceManager

type ResourceManager interface {
	// Reconcile will create/update AppMesh VirtualNode to match vn.spec, and update vn.status
	Reconcile(ctx context.Context, vn *appmesh.VirtualNode) error

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

ResourceManager is dedicated to manage AppMesh VirtualNode resources for k8s VirtualNode CRs.

func NewDefaultResourceManager

func NewDefaultResourceManager(
	k8sClient client.Client,
	appMeshSDK services.AppMesh,
	referencesResolver references.Resolver,
	accountID string,
	log logr.Logger) ResourceManager