typo: upate->update (#3765)
This commit is contained in:
@ -90,7 +90,7 @@ func (wbsa *Aggregator) Start() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Stop stops the aggregator. When the aggregator is closed, it won't call
|
// Stop stops the aggregator. When the aggregator is closed, it won't call
|
||||||
// parent ClientConn to upate balancer state.
|
// parent ClientConn to update balancer state.
|
||||||
func (wbsa *Aggregator) Stop() {
|
func (wbsa *Aggregator) Stop() {
|
||||||
wbsa.mu.Lock()
|
wbsa.mu.Lock()
|
||||||
defer wbsa.mu.Unlock()
|
defer wbsa.mu.Unlock()
|
||||||
|
@ -79,7 +79,7 @@ func (rbsa *balancerStateAggregator) start() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Close closes the aggregator. When the aggregator is closed, it won't call
|
// Close closes the aggregator. When the aggregator is closed, it won't call
|
||||||
// parent ClientConn to upate balancer state.
|
// parent ClientConn to update balancer state.
|
||||||
func (rbsa *balancerStateAggregator) close() {
|
func (rbsa *balancerStateAggregator) close() {
|
||||||
rbsa.mu.Lock()
|
rbsa.mu.Lock()
|
||||||
defer rbsa.mu.Unlock()
|
defer rbsa.mu.Unlock()
|
||||||
|
@ -33,7 +33,7 @@ type clusterUpdateErr struct {
|
|||||||
// TestClusterWatch covers the cases:
|
// TestClusterWatch covers the cases:
|
||||||
// - an update is received after a watch()
|
// - an update is received after a watch()
|
||||||
// - an update for another resource name
|
// - an update for another resource name
|
||||||
// - an upate is received after cancel()
|
// - an update is received after cancel()
|
||||||
func (s) TestClusterWatch(t *testing.T) {
|
func (s) TestClusterWatch(t *testing.T) {
|
||||||
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
||||||
defer cleanup()
|
defer cleanup()
|
||||||
|
@ -55,7 +55,7 @@ type endpointsUpdateErr struct {
|
|||||||
// TestEndpointsWatch covers the cases:
|
// TestEndpointsWatch covers the cases:
|
||||||
// - an update is received after a watch()
|
// - an update is received after a watch()
|
||||||
// - an update for another resource name (which doesn't trigger callback)
|
// - an update for another resource name (which doesn't trigger callback)
|
||||||
// - an upate is received after cancel()
|
// - an update is received after cancel()
|
||||||
func (s) TestEndpointsWatch(t *testing.T) {
|
func (s) TestEndpointsWatch(t *testing.T) {
|
||||||
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
||||||
defer cleanup()
|
defer cleanup()
|
||||||
|
@ -32,7 +32,7 @@ type ldsUpdateErr struct {
|
|||||||
// TestLDSWatch covers the cases:
|
// TestLDSWatch covers the cases:
|
||||||
// - an update is received after a watch()
|
// - an update is received after a watch()
|
||||||
// - an update for another resource name
|
// - an update for another resource name
|
||||||
// - an upate is received after cancel()
|
// - an update is received after cancel()
|
||||||
func (s) TestLDSWatch(t *testing.T) {
|
func (s) TestLDSWatch(t *testing.T) {
|
||||||
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
||||||
defer cleanup()
|
defer cleanup()
|
||||||
|
@ -33,7 +33,7 @@ type rdsUpdateErr struct {
|
|||||||
// TestRDSWatch covers the cases:
|
// TestRDSWatch covers the cases:
|
||||||
// - an update is received after a watch()
|
// - an update is received after a watch()
|
||||||
// - an update for another resource name (which doesn't trigger callback)
|
// - an update for another resource name (which doesn't trigger callback)
|
||||||
// - an upate is received after cancel()
|
// - an update is received after cancel()
|
||||||
func (s) TestRDSWatch(t *testing.T) {
|
func (s) TestRDSWatch(t *testing.T) {
|
||||||
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
v2ClientCh, cleanup := overrideNewXDSV2Client()
|
||||||
defer cleanup()
|
defer cleanup()
|
||||||
|
Reference in New Issue
Block a user