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
Constants ¶
View Source
const (
ReferenceKindVirtualNode = "VirtualNode"
)
Variables ¶
This section is empty.
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 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
Source Files
Click to show internal directories.
Click to hide internal directories.