cla

Documentation

Index

• type Cache
  • func NewCache(expirationTime time.Duration, metrics metrics.Metrics) (*Cache, error)
  • func (c *Cache) GetCLA(ctx context.Context, meshName, meshHash string, cluster envoy_common.Cluster, ...) (proto.Message, error)

Types

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

func NewCache(
	expirationTime time.Duration,
	metrics metrics.Metrics,
) (*Cache, error)

func (*Cache) GetCLA

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