Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 56 for cadvisorapi (0.18 sec)

  1. pkg/kubelet/winstats/network_stats.go

    		packetsOutboundDiscardedCounter: packetsOutboundDiscardedCounter,
    		packetsOutboundErrorsCounter:    packetsOutboundErrorsCounter,
    		adapterStats:                    map[string]cadvisorapi.InterfaceStats{},
    	}, nil
    }
    
    func (n *networkCounter) getData() ([]cadvisorapi.InterfaceStats, error) {
    	packetsReceivedPerSecondData, err := n.packetsReceivedPerSecondCounter.getDataList()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. pkg/kubelet/cadvisor/util.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package cadvisor
    
    import (
    	"strings"
    
    	cadvisorapi "github.com/google/cadvisor/info/v1"
    	cadvisorapi2 "github.com/google/cadvisor/info/v2"
    	"k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper"
    )
    
    const (
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 04 05:08:20 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. pkg/kubelet/cadvisor/cadvisor_linux.go

    }
    
    func (cc *cadvisorClient) ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) {
    	return cc.GetContainerInfoV2(name, options)
    }
    
    func (cc *cadvisorClient) VersionInfo() (*cadvisorapi.VersionInfo, error) {
    	return cc.GetVersionInfo()
    }
    
    func (cc *cadvisorClient) MachineInfo() (*cadvisorapi.MachineInfo, error) {
    	return cc.GetMachineInfo()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 22:07:20 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  4. pkg/kubelet/winstats/perfcounter_nodestats.go

    }
    
    func (p *perfCounterNodeStatsClient) getMachineInfo() (*cadvisorapi.MachineInfo, error) {
    	hostname, err := os.Hostname()
    	if err != nil {
    		return nil, err
    	}
    
    	systemUUID, err := getSystemUUID()
    	if err != nil {
    		return nil, err
    	}
    
    	bootId, err := getBootID()
    	if err != nil {
    		return nil, err
    	}
    
    	return &cadvisorapi.MachineInfo{
    		NumCores:       ProcessorCount(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 26 18:37:21 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. pkg/kubelet/winstats/perfcounter_nodestats_test.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package winstats
    
    import (
    	"os"
    	"strconv"
    	"testing"
    	"time"
    
    	cadvisorapi "github.com/google/cadvisor/info/v1"
    	"github.com/google/uuid"
    	"github.com/stretchr/testify/assert"
    	"k8s.io/apimachinery/pkg/util/wait"
    )
    
    func TestMonitoring(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 26 18:37:21 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/topologymanager/numa_info.go

    */
    
    package topologymanager
    
    import (
    	"fmt"
    
    	cadvisorapi "github.com/google/cadvisor/info/v1"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    )
    
    type NUMADistances map[int][]uint64
    
    type NUMAInfo struct {
    	Nodes         []int
    	NUMADistances NUMADistances
    }
    
    func NewNUMAInfo(topology []cadvisorapi.Node, opts PolicyOptions) (*NUMAInfo, error) {
    	var numaNodes []int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:14 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  7. pkg/kubelet/runonce_test.go

    	cadvisor := cadvisortest.NewMockInterface(mockCtrl)
    	cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).AnyTimes()
    	cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{
    		Usage:     400,
    		Capacity:  1000,
    		Available: 600,
    	}, nil).AnyTimes()
    	cadvisor.EXPECT().RootFsInfo().Return(cadvisorapiv2.FsInfo{
    		Usage:    9,
    		Capacity: 10,
    	}, nil).AnyTimes()
    	fakeSecretManager := secret.NewFakeManager()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/cpumanager/topology_hints_test.go

    }
    
    func returnMachineInfo() cadvisorapi.MachineInfo {
    	return cadvisorapi.MachineInfo{
    		NumCores: 12,
    		Topology: []cadvisorapi.Node{
    			{Id: 0,
    				Cores: []cadvisorapi.Core{
    					{SocketID: 0, Id: 0, Threads: []int{0, 6}},
    					{SocketID: 0, Id: 1, Threads: []int{1, 7}},
    					{SocketID: 0, Id: 2, Threads: []int{2, 8}},
    				},
    			},
    			{Id: 1,
    				Cores: []cadvisorapi.Core{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/fake_kuberuntime_manager.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package kuberuntime
    
    import (
    	"context"
    	"net/http"
    	"time"
    
    	cadvisorapi "github.com/google/cadvisor/info/v1"
    	"go.opentelemetry.io/otel/trace"
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:55:59 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/memorymanager/memory_manager.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package memorymanager
    
    import (
    	"context"
    	"fmt"
    	"sync"
    
    	cadvisorapi "github.com/google/cadvisor/info/v1"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    	"k8s.io/apimachinery/pkg/util/sets"
    	runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1"
    	"k8s.io/klog/v2"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
Back to top