cla

type Cache ¶

type Cache struct {
	// contains filtered or unexported fields
}

Cache is needed to share and cache ClusterLoadAssignments among goroutines which reconcile Dataplane's state. In scope of one mesh ClusterLoadAssignment will be the same for each service so no need to reconcile for each dataplane.

func NewCache(
	rm manager.ReadOnlyResourceManager,
	zone string, expirationTime time.Duration,
	ipFunc lookup.LookupIPFunc,
	metrics metrics.Metrics,
) (*Cache, error)

func (c *Cache) GetCLA(ctx context.Context, meshName, meshHash string, cluster envoy_common.Cluster, apiVersion envoy_common.APIVersion) (proto.Message, error)