Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for cadvisorapi (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/kubelet/stats/host_stats_provider.go

    	getPodLogStats(podNamespace, podName string, podUID types.UID, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error)
    	// getPodContainerLogStats gets stats associated with container log usage
    	getPodContainerLogStats(podNamespace, podName string, podUID types.UID, containerName string, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error)
    	// getPodEtcHostsStats gets stats associated with pod etc-hosts usage
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:55:59 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. pkg/kubelet/stats/host_stats_provider_fake.go

    }
    
    func (f *fakeHostStatsProvider) getPodEtcHostsStats(podUID types.UID, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) {
    	return nil, fmt.Errorf("not implemented")
    }
    
    func fakeMetricsProvidersToStats(metricsProviders []volume.MetricsProvider, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) {
    	result := rootFsInfoToFsStats(rootFsInfo)
    	for i, metricsProvider := range metricsProviders {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:57:17 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/container_manager_linux_test.go

    	defer mockCtrlError.Finish()
    
    	mockCadvisor := cadvisortest.NewMockInterface(mockCtrl)
    	rootfs := cadvisorapiv2.FsInfo{
    		Capacity: 8000,
    	}
    	mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil)
    	mockCadvisorError := cadvisortest.NewMockInterface(mockCtrlError)
    	mockCadvisorError.EXPECT().RootFsInfo().Return(cadvisorapiv2.FsInfo{}, errors.New("Unable to get rootfs data from cAdvisor interface"))
    	cases := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top