Skip to content
This repository has been archived by the owner on Dec 1, 2018. It is now read-only.

Commit

Permalink
Merge branch 'master' into fix_es_mapping
Browse files Browse the repository at this point in the history
  • Loading branch information
AlmogBaku committed Sep 2, 2016
2 parents 6ecdc58 + 2a7fbcf commit ab7a19f
Show file tree
Hide file tree
Showing 16 changed files with 351 additions and 239 deletions.
5 changes: 5 additions & 0 deletions Godeps/Godeps.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 2 additions & 3 deletions Makefile
Original file line number Diff line number Diff line change
@@ -1,17 +1,16 @@
all: build

TAG = v1.2.0-beta.0
TAG = v1.2.0-beta.2
PREFIX = gcr.io/google_containers
FLAGS =

SUPPORTED_KUBE_VERSIONS = "1.2.4"
TEST_NAMESPACE = heapster-e2e-tests

deps:
go get github.com/tools/godep
which godep || go get github.com/tools/godep

build: clean deps
GOOS=linux GOARCH=amd64 CGO_ENABLED=0 godep go build ./...
GOOS=linux GOARCH=amd64 CGO_ENABLED=0 godep go build -o heapster k8s.io/heapster/metrics
GOOS=linux GOARCH=amd64 CGO_ENABLED=0 godep go build -o eventer k8s.io/heapster/events

Expand Down
2 changes: 0 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,6 @@ It can be extended to support other cluster management solutions easily.
Heapster collects and interprets various signals like compute resource usage, lifecycle events, etc, and exports cluster metrics via [REST endpoints](docs/model.md).
**Note: Some of the endpoints are only valid in Kubernetes clusters**

Use [Kubedash](https://github.com/kubernetes/kubedash) to visualize data exported by Heapster.

Heapster supports multiple sources of data.
More information [here](docs/source-configuration.md).

Expand Down
125 changes: 0 additions & 125 deletions RELEASES.md

This file was deleted.

15 changes: 0 additions & 15 deletions deploy/docker-compose/README.md

This file was deleted.

28 changes: 0 additions & 28 deletions deploy/docker-compose/docker-compose.yml

This file was deleted.

8 changes: 0 additions & 8 deletions deploy/docker-compose/sample-hosts.json

This file was deleted.

11 changes: 0 additions & 11 deletions docs/hacking.md

This file was deleted.

20 changes: 13 additions & 7 deletions integration/framework.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,10 @@ type kubeFramework interface {
GetProxyUrlForService(service *api.Service) string

// Returns the node hostnames.
GetNodes() ([]string, error)
GetNodeNames() ([]string, error)

// Returns the nodes.
GetNodes() (*api.NodeList, error)

// Returns pod names in the cluster.
// TODO: Remove, or mix with namespace
Expand Down Expand Up @@ -410,22 +413,25 @@ func (self *realKubeFramework) GetProxyUrlForService(service *api.Service) strin
return fmt.Sprintf("%s/api/v1/proxy/namespaces/default/services/%s/", self.masterIP, service.Name)
}

func (self *realKubeFramework) GetNodes() ([]string, error) {
func (self *realKubeFramework) GetNodeNames() ([]string, error) {
var nodes []string
nodeList, err := self.kubeClient.Nodes().List(api.ListOptions{
LabelSelector: labels.Everything(),
FieldSelector: fields.Everything(),
})
nodeList, err := self.GetNodes()
if err != nil {
return nodes, err
}

for _, node := range nodeList.Items {
nodes = append(nodes, node.Name)
}
return nodes, nil
}

func (self *realKubeFramework) GetNodes() (*api.NodeList, error) {
return self.kubeClient.Nodes().List(api.ListOptions{
LabelSelector: labels.Everything(),
FieldSelector: fields.Everything(),
})
}

func (self *realKubeFramework) GetAllRunningPods() ([]api.Pod, error) {
return getRunningPods(true, self.kubeClient)
}
Expand Down
Loading

0 comments on commit ab7a19f

Please sign in to comment.