k8s

type Client ¶

type Client struct {
	// contains filtered or unexported fields
}

func NewClient(clientset *kubernetes.Clientset) *Client

func (c *Client) NodeMetrics(ctx context.Context, nodeName string) (NodeMetrics, error)

type ClientInterface ¶

type ClientInterface interface {
	NodeMetrics(ctx context.Context, nodeName string) (NodeMetrics, error)
}

type ClientMock ¶

type ClientMock struct {
	// NodeMetricsFunc mocks the NodeMetrics method.
	NodeMetricsFunc func(ctx context.Context, nodeName string) (NodeMetrics, error)
	// contains filtered or unexported fields
}

ClientMock is a mock implementation of ClientInterface.

func TestSomethingThatUsesClientInterface(t *testing.T) {

	// make and configure a mocked ClientInterface
	mockedClientInterface := &ClientMock{
		NodeMetricsFunc: func(ctx context.Context, nodeName string) (NodeMetrics, error) {
			panic("mock out the NodeMetrics method")
		},
	}

	// use mockedClientInterface in code that requires ClientInterface
	// and then make assertions.

}

func (mock *ClientMock) NodeMetrics(ctx context.Context, nodeName string) (NodeMetrics, error)

func (mock *ClientMock) NodeMetricsCalls() []struct {
	Ctx      context.Context
	NodeName string
}

len(mockedClientInterface.NodeMetricsCalls())

type MetricValue ¶

type MetricValue struct {
	Value       float64
	TimestampMs int64
}

type NodeMetrics ¶

type NodeMetrics struct {
	PodCPUUsageSecondsTotal  PodMetric
	PodMemoryWorkingSetBytes PodMetric
}

type PodKey ¶

type PodKey struct {
	Name      string
	Namespace string
}

type PodMetric ¶

type PodMetric map[PodKey]MetricValue