v2

Jul 1, 2020

Changes in this version

+ func AckResponse(streamClient ads.AggregatedDiscoveryService_StreamAggregatedResourcesClient, ...)

Feb 28, 2020

Changes in this version

+ const EnvoyCluster

+ const EnvoyClusterLoadAssignment

+ const EnvoyListener

+ const EnvoyRouteConfiguration

+ func DisableReconnect()

+ func EnableReconnect()

+ func HandleEnvoyCluster(client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ func HandleEnvoyClusterLoadAssignment(client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ func HandleEnvoyListener(client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ func HandleEnvoyRouteConfiguration(client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ func HandleTypeURL(url string, client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ func RegisterTypeURLHandleFunc(url string, f TypeURLHandleFunc)

+ type ADSClient struct

+ AdsConfig *ADSConfig

+ MosnConfig *v2.MOSNConfig

+ RecvControlChan chan int

+ SendControlChan chan int

+ StopChan chan int

+ StreamClient ads.AggregatedDiscoveryService_StreamAggregatedResourcesClient

+ StreamClientMutex sync.RWMutex

+ func (adsClient *ADSClient) Start()

+ func (adsClient *ADSClient) Stop()

+ type ADSConfig struct

+ APIType core.ApiConfigSource_ApiType

+ RefreshDelay *time.Duration

+ Services []*ServiceConfig

+ StreamClient *StreamClient

+ func (c *ADSConfig) GetStreamClient() ads.AggregatedDiscoveryService_StreamAggregatedResourcesClient

+ type ClusterConfig struct

+ Address []string

+ ConnectTimeout *time.Duration

+ LbPolicy envoy_api_v2.Cluster_LbPolicy

+ TlsContext *envoy_api_v2_auth.UpstreamTlsContext

+ func (c *ClusterConfig) GetEndpoint() (string, *time.Duration)

+ type ServiceConfig struct

+ ClusterConfig *ClusterConfig

+ Timeout *time.Duration

+ type StreamClient struct

+ Cancel context.CancelFunc

+ Client ads.AggregatedDiscoveryService_StreamAggregatedResourcesClient

+ Conn *grpc.ClientConn

+ type TypeURLHandleFunc func(client *ADSClient, resp *envoy_api_v2.DiscoveryResponse)

+ type XDSConfig struct

+ ADSConfig *ADSConfig

+ Clusters map[string]*ClusterConfig

+ func (c *XDSConfig) Init(dynamicResources *bootstrap.Bootstrap_DynamicResources, ...) error