diff --git a/hack/update-codegen-dockerized.sh b/hack/update-codegen-dockerized.sh index e6fff2caa1c..cd5232fa825 100755 --- a/hack/update-codegen-dockerized.sh +++ b/hack/update-codegen-dockerized.sh @@ -118,6 +118,7 @@ function generate_antrea_client_code { --plural-exceptions "AntreaClusterNetworkPolicyStats:AntreaClusterNetworkPolicyStats" \ --plural-exceptions "ClusterGroupMembers:ClusterGroupMembers" \ --plural-exceptions "GroupMembers:GroupMembers" \ + --plural-exceptions "NodeLatencyStats:NodeLatencyStats" \ --go-header-file hack/boilerplate/license_header.go.txt # Generate listers with K8s codegen tools. diff --git a/pkg/agent/monitortool/monitor.go b/pkg/agent/monitortool/monitor.go index 73ce81379ab..6f5294eba40 100644 --- a/pkg/agent/monitortool/monitor.go +++ b/pkg/agent/monitortool/monitor.go @@ -392,7 +392,7 @@ func (m *NodeLatencyMonitor) report() { klog.ErrorS(err, "Failed to get Antrea client") return } - if _, err := antreaClient.StatsV1alpha1().NodeLatencyStatses().Create(context.TODO(), summary, metav1.CreateOptions{}); err != nil { + if _, err := antreaClient.StatsV1alpha1().NodeLatencyStats().Create(context.TODO(), summary, metav1.CreateOptions{}); err != nil { klog.ErrorS(err, "Failed to create NodeIPLatencyStats") } } diff --git a/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_nodelatencystats.go b/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_nodelatencystats.go index 9ce2c4d2541..2759511f411 100644 --- a/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_nodelatencystats.go +++ b/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_nodelatencystats.go @@ -25,29 +25,29 @@ import ( testing "k8s.io/client-go/testing" ) -// FakeNodeLatencyStatses implements NodeLatencyStatsInterface -type FakeNodeLatencyStatses struct { +// FakeNodeLatencyStats implements NodeLatencyStatsInterface +type FakeNodeLatencyStats struct { Fake *FakeStatsV1alpha1 } -var nodelatencystatsesResource = v1alpha1.SchemeGroupVersion.WithResource("nodelatencystats") +var nodelatencystatsResource = v1alpha1.SchemeGroupVersion.WithResource("nodelatencystats") -var nodelatencystatsesKind = v1alpha1.SchemeGroupVersion.WithKind("NodeLatencyStats") +var nodelatencystatsKind = v1alpha1.SchemeGroupVersion.WithKind("NodeLatencyStats") // Get takes name of the nodeLatencyStats, and returns the corresponding nodeLatencyStats object, and an error if there is any. -func (c *FakeNodeLatencyStatses) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.NodeLatencyStats, err error) { +func (c *FakeNodeLatencyStats) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.NodeLatencyStats, err error) { obj, err := c.Fake. - Invokes(testing.NewRootGetAction(nodelatencystatsesResource, name), &v1alpha1.NodeLatencyStats{}) + Invokes(testing.NewRootGetAction(nodelatencystatsResource, name), &v1alpha1.NodeLatencyStats{}) if obj == nil { return nil, err } return obj.(*v1alpha1.NodeLatencyStats), err } -// List takes label and field selectors, and returns the list of NodeLatencyStatses that match those selectors. -func (c *FakeNodeLatencyStatses) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.NodeLatencyStatsList, err error) { +// List takes label and field selectors, and returns the list of NodeLatencyStats that match those selectors. +func (c *FakeNodeLatencyStats) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.NodeLatencyStatsList, err error) { obj, err := c.Fake. - Invokes(testing.NewRootListAction(nodelatencystatsesResource, nodelatencystatsesKind, opts), &v1alpha1.NodeLatencyStatsList{}) + Invokes(testing.NewRootListAction(nodelatencystatsResource, nodelatencystatsKind, opts), &v1alpha1.NodeLatencyStatsList{}) if obj == nil { return nil, err } @@ -66,9 +66,9 @@ func (c *FakeNodeLatencyStatses) List(ctx context.Context, opts v1.ListOptions) } // Create takes the representation of a nodeLatencyStats and creates it. Returns the server's representation of the nodeLatencyStats, and an error, if there is any. -func (c *FakeNodeLatencyStatses) Create(ctx context.Context, nodeLatencyStats *v1alpha1.NodeLatencyStats, opts v1.CreateOptions) (result *v1alpha1.NodeLatencyStats, err error) { +func (c *FakeNodeLatencyStats) Create(ctx context.Context, nodeLatencyStats *v1alpha1.NodeLatencyStats, opts v1.CreateOptions) (result *v1alpha1.NodeLatencyStats, err error) { obj, err := c.Fake. - Invokes(testing.NewRootCreateAction(nodelatencystatsesResource, nodeLatencyStats), &v1alpha1.NodeLatencyStats{}) + Invokes(testing.NewRootCreateAction(nodelatencystatsResource, nodeLatencyStats), &v1alpha1.NodeLatencyStats{}) if obj == nil { return nil, err } @@ -76,8 +76,8 @@ func (c *FakeNodeLatencyStatses) Create(ctx context.Context, nodeLatencyStats *v } // Delete takes name of the nodeLatencyStats and deletes it. Returns an error if one occurs. -func (c *FakeNodeLatencyStatses) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { +func (c *FakeNodeLatencyStats) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { _, err := c.Fake. - Invokes(testing.NewRootDeleteActionWithOptions(nodelatencystatsesResource, name, opts), &v1alpha1.NodeLatencyStats{}) + Invokes(testing.NewRootDeleteActionWithOptions(nodelatencystatsResource, name, opts), &v1alpha1.NodeLatencyStats{}) return err } diff --git a/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_stats_client.go b/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_stats_client.go index 9758bc7d792..1a3b7966222 100644 --- a/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_stats_client.go +++ b/pkg/client/clientset/versioned/typed/stats/v1alpha1/fake/fake_stats_client.go @@ -42,8 +42,8 @@ func (c *FakeStatsV1alpha1) NetworkPolicyStats(namespace string) v1alpha1.Networ return &FakeNetworkPolicyStats{c, namespace} } -func (c *FakeStatsV1alpha1) NodeLatencyStatses() v1alpha1.NodeLatencyStatsInterface { - return &FakeNodeLatencyStatses{c} +func (c *FakeStatsV1alpha1) NodeLatencyStats() v1alpha1.NodeLatencyStatsInterface { + return &FakeNodeLatencyStats{c} } // RESTClient returns a RESTClient that is used to communicate diff --git a/pkg/client/clientset/versioned/typed/stats/v1alpha1/nodelatencystats.go b/pkg/client/clientset/versioned/typed/stats/v1alpha1/nodelatencystats.go index 6cc3b3eb6e6..f4593b86653 100644 --- a/pkg/client/clientset/versioned/typed/stats/v1alpha1/nodelatencystats.go +++ b/pkg/client/clientset/versioned/typed/stats/v1alpha1/nodelatencystats.go @@ -26,10 +26,10 @@ import ( rest "k8s.io/client-go/rest" ) -// NodeLatencyStatsesGetter has a method to return a NodeLatencyStatsInterface. +// NodeLatencyStatsGetter has a method to return a NodeLatencyStatsInterface. // A group's client should implement this interface. -type NodeLatencyStatsesGetter interface { - NodeLatencyStatses() NodeLatencyStatsInterface +type NodeLatencyStatsGetter interface { + NodeLatencyStats() NodeLatencyStatsInterface } // NodeLatencyStatsInterface has methods to work with NodeLatencyStats resources. @@ -41,20 +41,20 @@ type NodeLatencyStatsInterface interface { NodeLatencyStatsExpansion } -// nodeLatencyStatses implements NodeLatencyStatsInterface -type nodeLatencyStatses struct { +// nodeLatencyStats implements NodeLatencyStatsInterface +type nodeLatencyStats struct { client rest.Interface } -// newNodeLatencyStatses returns a NodeLatencyStatses -func newNodeLatencyStatses(c *StatsV1alpha1Client) *nodeLatencyStatses { - return &nodeLatencyStatses{ +// newNodeLatencyStats returns a NodeLatencyStats +func newNodeLatencyStats(c *StatsV1alpha1Client) *nodeLatencyStats { + return &nodeLatencyStats{ client: c.RESTClient(), } } // Get takes name of the nodeLatencyStats, and returns the corresponding nodeLatencyStats object, and an error if there is any. -func (c *nodeLatencyStatses) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.NodeLatencyStats, err error) { +func (c *nodeLatencyStats) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.NodeLatencyStats, err error) { result = &v1alpha1.NodeLatencyStats{} err = c.client.Get(). Resource("nodelatencystats"). @@ -65,8 +65,8 @@ func (c *nodeLatencyStatses) Get(ctx context.Context, name string, options v1.Ge return } -// List takes label and field selectors, and returns the list of NodeLatencyStatses that match those selectors. -func (c *nodeLatencyStatses) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.NodeLatencyStatsList, err error) { +// List takes label and field selectors, and returns the list of NodeLatencyStats that match those selectors. +func (c *nodeLatencyStats) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.NodeLatencyStatsList, err error) { var timeout time.Duration if opts.TimeoutSeconds != nil { timeout = time.Duration(*opts.TimeoutSeconds) * time.Second @@ -82,7 +82,7 @@ func (c *nodeLatencyStatses) List(ctx context.Context, opts v1.ListOptions) (res } // Create takes the representation of a nodeLatencyStats and creates it. Returns the server's representation of the nodeLatencyStats, and an error, if there is any. -func (c *nodeLatencyStatses) Create(ctx context.Context, nodeLatencyStats *v1alpha1.NodeLatencyStats, opts v1.CreateOptions) (result *v1alpha1.NodeLatencyStats, err error) { +func (c *nodeLatencyStats) Create(ctx context.Context, nodeLatencyStats *v1alpha1.NodeLatencyStats, opts v1.CreateOptions) (result *v1alpha1.NodeLatencyStats, err error) { result = &v1alpha1.NodeLatencyStats{} err = c.client.Post(). Resource("nodelatencystats"). @@ -94,7 +94,7 @@ func (c *nodeLatencyStatses) Create(ctx context.Context, nodeLatencyStats *v1alp } // Delete takes name of the nodeLatencyStats and deletes it. Returns an error if one occurs. -func (c *nodeLatencyStatses) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { +func (c *nodeLatencyStats) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { return c.client.Delete(). Resource("nodelatencystats"). Name(name). diff --git a/pkg/client/clientset/versioned/typed/stats/v1alpha1/stats_client.go b/pkg/client/clientset/versioned/typed/stats/v1alpha1/stats_client.go index 287da4aff63..24c6e20bfe3 100644 --- a/pkg/client/clientset/versioned/typed/stats/v1alpha1/stats_client.go +++ b/pkg/client/clientset/versioned/typed/stats/v1alpha1/stats_client.go @@ -30,7 +30,7 @@ type StatsV1alpha1Interface interface { AntreaNetworkPolicyStatsGetter MulticastGroupsGetter NetworkPolicyStatsGetter - NodeLatencyStatsesGetter + NodeLatencyStatsGetter } // StatsV1alpha1Client is used to interact with features provided by the stats.antrea.io group. @@ -54,8 +54,8 @@ func (c *StatsV1alpha1Client) NetworkPolicyStats(namespace string) NetworkPolicy return newNetworkPolicyStats(c, namespace) } -func (c *StatsV1alpha1Client) NodeLatencyStatses() NodeLatencyStatsInterface { - return newNodeLatencyStatses(c) +func (c *StatsV1alpha1Client) NodeLatencyStats() NodeLatencyStatsInterface { + return newNodeLatencyStats(c) } // NewForConfig creates a new StatsV1alpha1Client for the given config.