virtualservice

Documentation

Index

• Constants
• func BuildSDKVirtualServiceSpec(vs *appmesh.VirtualService, ...) (*appmeshsdk.VirtualServiceSpec, error)
• func ExtractVirtualNodeReferences(vs *appmesh.VirtualService) []appmesh.VirtualNodeReference
• func ExtractVirtualRouterReferences(vs *appmesh.VirtualService) []appmesh.VirtualRouterReference
• func IsVirtualServiceActive(vs *appmesh.VirtualService) bool
• func NewEnqueueRequestsForMeshEvents(k8sClient client.Client, log logr.Logger) *enqueueRequestsForMeshEvents
• func NewEnqueueRequestsForVirtualNodeEvents(referencesIndexer references.ObjectReferenceIndexer, log logr.Logger) *enqueueRequestsForVirtualNodeEvents
• func NewEnqueueRequestsForVirtualRouterEvents(referencesIndexer references.ObjectReferenceIndexer, log logr.Logger) *enqueueRequestsForVirtualRouterEvents
• func VirtualNodeReferenceIndexFunc(obj client.Object) []types.NamespacedName
• func VirtualRouterReferenceIndexFunc(obj client.Object) []types.NamespacedName
• type ResourceManager
  • func NewDefaultResourceManager(k8sClient client.Client, appMeshSDK services.AppMesh, ...) ResourceManager

Constants

const (
	ReferenceKindVirtualNode   = "VirtualNode"
	ReferenceKindVirtualRouter = "VirtualRouter"
)

Functions

func BuildSDKVirtualServiceSpec

func BuildSDKVirtualServiceSpec(vs *appmesh.VirtualService, vnByKey map[types.NamespacedName]*appmesh.VirtualNode, vrByKey map[types.NamespacedName]*appmesh.VirtualRouter) (*appmeshsdk.VirtualServiceSpec, error)

func ExtractVirtualNodeReferences

func ExtractVirtualNodeReferences(vs *appmesh.VirtualService) []appmesh.VirtualNodeReference

func ExtractVirtualRouterReferences

func ExtractVirtualRouterReferences(vs *appmesh.VirtualService) []appmesh.VirtualRouterReference

func IsVirtualServiceActive

func IsVirtualServiceActive(vs *appmesh.VirtualService) bool

IsVirtualServiceActive checks whether given virtualService is active. virtualService is active when its VirtualServiceActive 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 NewEnqueueRequestsForVirtualRouterEvents

func NewEnqueueRequestsForVirtualRouterEvents(referencesIndexer references.ObjectReferenceIndexer, log logr.Logger) *enqueueRequestsForVirtualRouterEvents

func VirtualNodeReferenceIndexFunc

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

func VirtualRouterReferenceIndexFunc

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

Types

type ResourceManager

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

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

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

func NewDefaultResourceManager

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