diff --git a/plugin/traffic/xds/client.go b/plugin/traffic/xds/client.go index 315304b47..9e08631e7 100644 --- a/plugin/traffic/xds/client.go +++ b/plugin/traffic/xds/client.go @@ -110,7 +110,7 @@ func (c *Client) Run() { } if first { - log.Info("gRPC stream established to %q", c.to) + log.Infof("gRPC stream established to %q", c.to) c.setSynced() first = false } diff --git a/plugin/traffic/xds/fields.go b/plugin/traffic/xds/fields.go index af4411a8b..c052ae50b 100644 --- a/plugin/traffic/xds/fields.go +++ b/plugin/traffic/xds/fields.go @@ -1,13 +1,13 @@ package xds -// Assignment returns the current assignment map. +// Assignments returns the current assignment map. func (c *Client) Assignments() *assignment { c.mu.RLock() defer c.mu.RUnlock() return c.assignments } -// SetAssignment sets the assignment map. +// SetAssignments sets the assignment map. func (c *Client) SetAssignments(a *assignment) { c.mu.Lock() defer c.mu.Unlock() @@ -42,14 +42,14 @@ func (c *Client) SetNonce(typeURL, n string) { c.nonce[typeURL] = n } -// SetSynced sets the synced boolean to true. +// setSynced sets the synced boolean to true. func (c *Client) setSynced() { c.mu.Lock() defer c.mu.Unlock() c.synced = true } -// Synced return true if the clients has synced. +// HasSynced return true if the clients has synced. func (c *Client) HasSynced() bool { c.mu.RLock() defer c.mu.RUnlock()