ads

Documentation

Index

• func ConfigResourcesIsEmpty(resources *admin_v2.ConfigResources) bool
• func SetApiVersionInfo(resources *admin_v2.ConfigResources)
• type AdsCache
  • func NewAdsCache() *AdsCache
  • func (load *AdsCache) CreateApiClusterByCds(status core_v2.ApiStatus, cluster *config_cluster_v3.Cluster)
  • func (load *AdsCache) CreateApiClusterByEds(status core_v2.ApiStatus, ...)
  • func (load *AdsCache) CreateApiListenerByLds(status core_v2.ApiStatus, listener *config_listener_v3.Listener)
  • func (load *AdsCache) CreateApiRouteByRds(status core_v2.ApiStatus, routeConfig *config_route_v3.RouteConfiguration)
  • func (load *AdsCache) GetApiClusterStatus(key string) core_v2.ApiStatus
  • func (load *AdsCache) UpateApiRouteStatus(key string, status core_v2.ApiStatus)
  • func (load *AdsCache) UpdateApiClusterIfExists(status core_v2.ApiStatus, cluster *config_cluster_v3.Cluster) bool
  • func (load *AdsCache) UpdateApiClusterStatus(key string, status core_v2.ApiStatus)
  • func (load *AdsCache) UpdateApiListenerStatus(key string, status core_v2.ApiStatus)
• type Controller
  • func NewController() *Controller
  • func (c *Controller) AdsStreamCreateAndSend(client service_discovery_v3.AggregatedDiscoveryServiceClient, ...) error
  • func (c *Controller) Close()
  • func (c *Controller) HandleAdsStream() error

Functions

func ConfigResourcesIsEmpty

func ConfigResourcesIsEmpty(resources *admin_v2.ConfigResources) bool

func SetApiVersionInfo

func SetApiVersionInfo(resources *admin_v2.ConfigResources)

Types

type AdsCache

type AdsCache struct {
	ListenerCache cache_v2.ListenerCache
	ClusterCache  cache_v2.ClusterCache
	RouteCache    cache_v2.RouteConfigCache
	// contains filtered or unexported fields
}

func NewAdsCache

func NewAdsCache() *AdsCache

func (*AdsCache) CreateApiClusterByCds

func (load *AdsCache) CreateApiClusterByCds(status core_v2.ApiStatus, cluster *config_cluster_v3.Cluster)

func (*AdsCache) CreateApiClusterByEds

func (load *AdsCache) CreateApiClusterByEds(status core_v2.ApiStatus,
	loadAssignment *config_endpoint_v3.ClusterLoadAssignment,
)

func (*AdsCache) CreateApiListenerByLds

func (load *AdsCache) CreateApiListenerByLds(status core_v2.ApiStatus, listener *config_listener_v3.Listener)

func (*AdsCache) CreateApiRouteByRds

func (load *AdsCache) CreateApiRouteByRds(status core_v2.ApiStatus, routeConfig *config_route_v3.RouteConfiguration)

func (*AdsCache) GetApiClusterStatus

func (load *AdsCache) GetApiClusterStatus(key string) core_v2.ApiStatus

func (*AdsCache) UpateApiRouteStatus

func (load *AdsCache) UpateApiRouteStatus(key string, status core_v2.ApiStatus)

func (*AdsCache) UpdateApiClusterIfExists

func (load *AdsCache) UpdateApiClusterIfExists(status core_v2.ApiStatus, cluster *config_cluster_v3.Cluster) bool

UpdateApiClusterIfExists only update api cluster if it exists

func (*AdsCache) UpdateApiClusterStatus

func (load *AdsCache) UpdateApiClusterStatus(key string, status core_v2.ApiStatus)

func (*AdsCache) UpdateApiListenerStatus

func (load *AdsCache) UpdateApiListenerStatus(key string, status core_v2.ApiStatus)

type Controller

type Controller struct {
	Processor *processor
	// contains filtered or unexported fields
}

func NewController

func NewController() *Controller

func (*Controller) AdsStreamCreateAndSend

func (c *Controller) AdsStreamCreateAndSend(client service_discovery_v3.AggregatedDiscoveryServiceClient, ctx context.Context) error

func (*Controller) Close

func (c *Controller) Close()

func (*Controller) HandleAdsStream

func (c *Controller) HandleAdsStream() error