references

Documentation

Index

• type Resolver
  • func NewDefaultResolver(k8sClient client.Client, meshClient services.ServiceMeshClient, ...) Resolver

Types

type Resolver

type Resolver interface {
	ResolveResourceRef(resourceRef *servicemeshapi.ResourceRef, crdObj *metav1.ObjectMeta) *servicemeshapi.ResourceRef
	// ResolveMeshReference returns a mesh CR based on ref
	ResolveMeshReference(ctx context.Context, ref *servicemeshapi.ResourceRef) (*servicemeshapi.Mesh, error)
	// ResolveMeshId returns MehId for a given RefOrId
	ResolveMeshId(ctx context.Context, meshRef *servicemeshapi.RefOrId, crdObj *metav1.ObjectMeta) (*api.OCID, error)
	// ResolveMeshRefById returns MeshRef for a given meshId
	ResolveMeshRefById(ctx context.Context, meshId *api.OCID) (*commons.MeshRef, error)
	// ResolveVirtualServiceReference returns a virtual service CR based on ref
	ResolveVirtualServiceReference(ctx context.Context, ref *servicemeshapi.ResourceRef) (*servicemeshapi.VirtualService, error)
	// ResolveVirtualServiceIdAndName returns ResourceRef for a given RefOrId
	ResolveVirtualServiceIdAndName(ctx context.Context, virtualServiceRef *servicemeshapi.RefOrId, crdObj *metav1.ObjectMeta) (*commons.ResourceRef, error)
	// ResolveVirtualServiceRefById returns VirtualServiceRef for a given virtualServiceId
	ResolveVirtualServiceRefById(ctx context.Context, virtualServiceId *api.OCID) (*commons.ResourceRef, error)
	// ResolveVirtualServiceById returns a virtual service sdk based on OCID
	ResolveVirtualServiceById(ctx context.Context, virtualServiceId *api.OCID) (*sdk.VirtualService, error)
	// ResolveVirtualServiceList resolves all the virtual services under a given namespace
	ResolveVirtualServiceListByNamespace(ctx context.Context, namespace string) (servicemeshapi.VirtualServiceList, error)
	// ResolveVirtualDeploymentReference returns a virtual deployment CR based on ref
	ResolveVirtualDeploymentReference(ctx context.Context, ref *servicemeshapi.ResourceRef) (*servicemeshapi.VirtualDeployment, error)
	// ResolveVirtualDeploymentId returns VirtualDeploymentId for a given VirtualDeploymentRefOrId
	ResolveVirtualDeploymentId(ctx context.Context, virtualDeploymentRef *servicemeshapi.RefOrId, crdObj *metav1.ObjectMeta) (*api.OCID, error)
	// ResolveHasVirtualDeploymentWithListener returns bool that indicate if the virtual service is referred by any virtual deployment that has listeners
	ResolveHasVirtualDeploymentWithListener(ctx context.Context, compartmentId *api.OCID, virtualServiceId *api.OCID) (bool, error)
	// ResolveIngressGatewayReference returns a ingress gateway CR based on ref
	ResolveIngressGatewayReference(ctx context.Context, ref *servicemeshapi.ResourceRef) (*servicemeshapi.IngressGateway, error)
	// ResolveIngressGatewayIdAndNameAndMeshId returns IngressGatewayRef for a given IngressGatewayRefOrId
	ResolveIngressGatewayIdAndNameAndMeshId(ctx context.Context, IngressGatewayRef *servicemeshapi.RefOrId, crdObj *metav1.ObjectMeta) (*commons.ResourceRef, error)
	// ResolveServiceReference returns a k8s service based on ref from Cache
	ResolveServiceReference(ctx context.Context, ref *servicemeshapi.ResourceRef) (*corev1.Service, error)
	// ResolveServiceReferenceWithApiReader returns a k8s service based on ref from K8s API Server
	ResolveServiceReferenceWithApiReader(ctx context.Context, ref *servicemeshapi.ResourceRef) (*corev1.Service, error)
}

func NewDefaultResolver

func NewDefaultResolver(k8sClient client.Client, meshClient services.ServiceMeshClient, log loggerutil.OSOKLogger, cache customCache.CacheMapClient, k8sDirectReader client.Reader) Resolver

NewDefaultResolver constructs new defaultResolver