virtualrouter

Documentation

Index

• Constants
• func BuildSDKRouteSpec(vr *appmesh.VirtualRouter, route appmesh.Route, ...) (*appmeshsdk.RouteSpec, error)
• func BuildSDKVirtualRouterSpec(vr *appmesh.VirtualRouter) (*appmeshsdk.VirtualRouterSpec, error)
• func ExtractVirtualNodeReferences(vr *appmesh.VirtualRouter) []appmesh.VirtualNodeReference
• func IsVirtualRouterActive(vr *appmesh.VirtualRouter) bool
• func NewEnqueueRequestsForMeshEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForMeshEvents
• func NewEnqueueRequestsForVirtualNodeEvents(referencesIndexer references.ObjectReferenceIndexer, log logr.Logger) *enqueueRequestsForVirtualNodeEvents
• func VirtualNodeReferenceIndexFunc(obj client.Object) []types.NamespacedName
• type ResourceManager
  • func NewDefaultResourceManager(k8sClient client.Client, appMeshSDK services.AppMesh, ...) ResourceManager

Constants

const (
	ReferenceKindVirtualNode = "VirtualNode"
)

Functions

func BuildSDKRouteSpec

func BuildSDKRouteSpec(vr *appmesh.VirtualRouter, route appmesh.Route, vnByKey map[types.NamespacedName]*appmesh.VirtualNode) (*appmeshsdk.RouteSpec, error)

func BuildSDKVirtualRouterSpec

func BuildSDKVirtualRouterSpec(vr *appmesh.VirtualRouter) (*appmeshsdk.VirtualRouterSpec, error)

func ExtractVirtualNodeReferences

func ExtractVirtualNodeReferences(vr *appmesh.VirtualRouter) []appmesh.VirtualNodeReference

ExtractVirtualNodeReferences extracts all virtualNodeReferences for this virtualRouter

func IsVirtualRouterActive

func IsVirtualRouterActive(vr *appmesh.VirtualRouter) bool

IsVirtualRouterActive checks whether given virtualRouter is active. virtualRouter is active when its VirtualRouterActive condition equals true.

func NewEnqueueRequestsForMeshEvents

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

func NewEnqueueRequestsForVirtualNodeEvents

func NewEnqueueRequestsForVirtualNodeEvents(referencesIndexer references.ObjectReferenceIndexer, log logr.Logger) *enqueueRequestsForVirtualNodeEvents

func VirtualNodeReferenceIndexFunc

func VirtualNodeReferenceIndexFunc(obj client.Object) []types.NamespacedName

Types

type ResourceManager

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

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

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

func NewDefaultResourceManager

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