mesh

Documentation

Index

• func BuildSDKMeshSpec(ctx context.Context, ms *appmesh.Mesh) (*appmeshsdk.MeshSpec, error)
• func IsMeshActive(ms *appmesh.Mesh) bool
• func IsMeshReferenced(ms *appmesh.Mesh, reference appmesh.MeshReference) bool
• type MembersFinalizer
  • func NewPendingMembersFinalizer(k8sClient client.Client, eventRecorder record.EventRecorder, log logr.Logger) MembersFinalizer
• type MembershipDesignator
  • func NewMembershipDesignator(k8sClient client.Client) MembershipDesignator
• type ResourceManager
  • func NewDefaultResourceManager(k8sClient client.Client, appMeshSDK services.AppMesh, accountID string, ...) ResourceManager

Functions

func BuildSDKMeshSpec

func BuildSDKMeshSpec(ctx context.Context, ms *appmesh.Mesh) (*appmeshsdk.MeshSpec, error)

func IsMeshActive

func IsMeshActive(ms *appmesh.Mesh) bool

IsMeshActive tests whether given mesh is active. mesh is active when its MeshActive condition equals true.

func IsMeshReferenced

func IsMeshReferenced(ms *appmesh.Mesh, reference appmesh.MeshReference) bool

IsMeshReferenced tests whether given mesh is referenced by meshReference

Types

type MembersFinalizer

type MembersFinalizer interface {
	Finalize(ctx context.Context, ms *appmesh.Mesh) error
}

func NewPendingMembersFinalizer

func NewPendingMembersFinalizer(k8sClient client.Client, eventRecorder record.EventRecorder, log logr.Logger) MembersFinalizer

type MembershipDesignator

type MembershipDesignator interface {
	// Designate will choose a mesh for given namespaced AppMesh CR.
	Designate(ctx context.Context, obj metav1.Object) (*appmesh.Mesh, error)
}

MembershipDesignator designates mesh membership for namespaced AppMesh CRs.

func NewMembershipDesignator

func NewMembershipDesignator(k8sClient client.Client) MembershipDesignator

NewMembershipDesignator creates new MembershipDesignator.

type ResourceManager

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

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

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

func NewDefaultResourceManager

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