Init...

Author: Strabox

.gitignore

@@ -0,0 +1 @@
+/.idea

Gopkg.lock

@@ -0,0 +1,30 @@
+# Gopkg.toml example
+#
+# Refer to https://golang.github.io/dep/docs/Gopkg.toml.html
+# for detailed Gopkg.toml documentation.
+#
+# required = ["github.com/user/thing/cmd/thing"]
+# ignored = ["github.com/user/project/pkgX", "bitbucket.org/user/project/pkgA/pkgY"]
+#
+# [[constraint]]
+# name = "github.com/user/project"
+# version = "1.0.0"
+#
+# [[constraint]]
+# name = "github.com/user/project2"
+# branch = "dev"
+# source = "github.com/myfork/project2"
+#
+# [[override]]
+# name = "github.com/x/y"
+# version = "2.4.0"
+#
+# [prune]
+# non-go = false
+# go-tests = true
+# unused-packages = true
+
+
+[prune]
+ go-tests = true
+ unused-packages = true

Gopkg.toml

@@ -0,0 +1,89 @@
+##################### CARAVELA's MAKEFILE #########################
+GOCMD=go
+
+######### Builtin GO tools #########
+GOBUILD=$(GOCMD) build
+GOINSTALL=$(GOCMD) install
+GOCLEAN=$(GOCMD) clean
+GOTEST=$(GOCMD) test
+GOVET=$(GOCMD) vet
+
+GOGET=$(GOCMD) get
+
+######### External GO tools #########
+GOLINT=golint
+GOCOV=gocov
+GOCOVHTML=gocov-html
+GODEPGRAPH=godepgraph
+
+############ Output Files ###########
+EXE=.exe
+BINARY_NAME=caravela$(EXE)
+BINARY_NAME_LINUX=$(BINARY_NAME)_linux$(EXE)
+BINARY_NAME_WIN=$(BINARY_NAME)_win$(EXE)
+
+############################## COMMANDS ############################
+
+all: test build
+
+build:
+@echo Building for the current machine settings...
+$(GOBUILD) -o $(BINARY_NAME) -v
+
+build-linux:
+@echo Building for linux...
+env GOOS=linux $(GOBUILD) -o $(BINARY_NAME) -v
+
+build-windows:
+@echo Building for windows...
+env GOOS=windows $(GOBUILD) -o $(BINARY_NAME) -v
+
+clean:
+@echo Cleaning project...
+$(GOCLEAN)
+rm -f $(BINARY_NAME)
+rm -f $(BINARY_NAME_LINUX)
+rm -f $(BINARY_NAME_WIN)
+
+install:
+@echo Installing CARAVELA in the local GO environment...
+$(GOINSTALL) -v -gcflags "-N -l" .
+
+test:
+@echo Testing...
+$(GOTEST) -v ./...
+
+test-cov:
+@echo Testing and coverage report generation...
+$(GOCOV) test ./... | $(GOCOVHTML) > coverage.html
+
+test-verify:
+$(MAKE) test
+@echo Running vet tool to static analyze the code
+$(GOVET) -v ./...
+@echo Running lint tool to static analyze the code style
+
+dep-graph:
+@echo Generating package import dependency graph...
+$(GODEPGRAPH) -s -p github.com/docker github.com/strabox/caravela | dot -Tpng -o importsGraph.png
+
+docker-build:
+@echo Building Docker container...
+docker build --build-arg exec_file=$(BINARY_NAME) --rm -t strabox/caravela:latest .
+
+docker-upload:
+@echo Building Docker container and uploading to DockerHub...
+docker build --build-arg exec_file=$(BINARY_NAME) --rm -t strabox/caravela:latest .
+docker push strabox/caravela:latest
+
+install-external-tools:
+@echo Installing external tools...
+@echo Installing lint - Code style analyzer (from google)
+$(GOGET) github.com/golang/lint
+@echo Installing gocov - Code coverage generator
+$(GOGET) github.com/axw/gocov/gocov
+@echo Installing gocov-html - Code coverage html generator
+$(GOGET) -u gopkg.in/matm/v1/gocov-html
+@echo Installing godepgraph - Code package dependency graph generator
+$(GOGET) github.com/kisielk/godepgraph
+

Makefile

@@ -0,0 +1,55 @@
+package caravela
+
+import (
+"github.com/strabox/caravela/api/rest"
+"github.com/strabox/caravela/configuration"
+nodeAPI "github.com/strabox/caravela/node/api"
+)
+
+type RemoteClientMock struct {
+// TODO
+}
+
+func NewRemoteClientMock() *RemoteClientMock {
+return &RemoteClientMock{}
+}
+
+func (mock *RemoteClientMock) CreateOffer(fromSupplierIP string, fromSupplierGUID string, toTraderIP string,
+toTraderGUID string, offerID int64, amount int, cpus int, ram int) error {
+// Do Nothing
+return nil
+}
+
+func (mock *RemoteClientMock) RefreshOffer(toSupplierIP string, fromTraderGUID string, offerID int64) (bool, error) {
+// Do Nothing
+return false, nil
+}
+
+func (mock *RemoteClientMock) RemoveOffer(fromSupplierIP string, fromSupplierGUID, toTraderIP string,
+toTraderGUID string, offerID int64) error {
+// Do Nothing
+return nil
+}
+
+func (mock *RemoteClientMock) GetOffers(toTraderIP string, toTraderGUID string, relay bool,
+fromNodeGUID string) ([]nodeAPI.Offer, error) {
+// Do Nothing
+return nil, nil
+}
+
+func (mock *RemoteClientMock) AdvertiseOffersNeighbor(toNeighborTraderIP string, toNeighborTraderGUID string,
+fromTraderGUID string, traderOfferingGUID string, traderOfferingIP string) error {
+// Do Nothing
+return nil
+}
+
+func (mock *RemoteClientMock) LaunchContainer(toSupplierIP string, fromBuyerIP string, offerID int64, containerImageKey string,
+portMappings []rest.PortMapping, containerArgs []string, cpus int, ram int) error {
+// Do Nothing
+return nil
+}
+
+func (mock *RemoteClientMock) ObtainConfiguration(systemsNodeIP string) (*configuration.Configuration, error) {
+// Do Nothing
+return nil, nil
+}

caravela/api_client_mock.go

@@ -0,0 +1,36 @@
+[ImagesStorage]
+Backend = "DockerHub"
+
+[Caravela]
+APIPort = 8001
+APITimeout = "5s"
+CheckContainersInterval = "30s"
+SupplyingInterval = "30s"
+SpreadOffersInterval = "30s"
+RefreshesCheckInterval = "30s"
+RefreshingInterval = "30s"
+MaxRefreshesFailed = 3
+MaxRefreshesMissed = 2
+RefreshMissedTimeout = "20s"
+ResourcesOvercommit = 50
+ # Cpu Cores Partitions
+ [[Caravela.CpuCoresPartitions]]
+ Cores = 1
+ Percentage = 50
+ [[Caravela.CpuCoresPartitions]]
+ Cores = 2
+ Percentage = 50
+ # Ram Partitions
+ [[Caravela.RamPartitions]]
+ Ram = 256
+ Percentage = 50
+ [[Caravela.RamPartitions]]
+ Ram = 512
+ Percentage = 50
+
+[Overlay]
+OverlayPort = 8000
+ChordTimeout = "3s"
+ChordVirtualNodes = 12
+ChordNumSuccessors = 4
+ChordHashSizeBits = 128

configuration.toml

@@ -0,0 +1,35 @@
+package docker
+
+import (
+"github.com/strabox/caravela/api/rest"
+dockerAPI "github.com/strabox/caravela/docker"
+)
+
+type ClientMock struct {
+// TODO
+}
+
+func NewClientMock() *ClientMock {
+return &ClientMock{}
+}
+
+func (cli *ClientMock) GetDockerCPUAndRAM() (int, int) {
+// TODO
+return 0, 0
+}
+
+func (cli *ClientMock) CheckContainerStatus(containerID string) (dockerAPI.ContainerStatus, error) {
+// TODO
+return dockerAPI.NewContainerStatus(0), nil
+}
+
+func (cli *ClientMock) RunContainer(imageKey string, portMappings []rest.PortMapping, args []string, cpus int64,
+ram int) (string, error) {
+// TODO
+return "", nil
+}
+
+func (cli *ClientMock) RemoveContainer(containerID string) {
+// TODO
+return
+}

docker/client_mock.go

@@ -0,0 +1,7 @@
+package main
+
+import "fmt"
+
+func main() {
+fmt.Println("Caravela Simulator")
+}

main.go

@@ -0,0 +1,44 @@
+package overlay
+
+import (
+nodeAPI "github.com/strabox/caravela/node/api"
+"github.com/strabox/caravela/overlay"
+)
+
+type ChordMock struct {
+// TODO
+}
+
+func NewChordMock() *ChordMock {
+return &ChordMock{}
+}
+
+func (chord *ChordMock) Create(thisNode nodeAPI.OverlayMembership) error {
+// Do Nothing
+return nil
+}
+
+func (chord *ChordMock) Join(overlayNodeIP string, overlayNodePort int, thisNode nodeAPI.OverlayMembership) error {
+// Do Nothing
+return nil
+}
+
+func (chord *ChordMock) Lookup(key []byte) ([]*overlay.Node, error) {
+// Do Nothing
+return nil, nil
+}
+
+func (chord *ChordMock) Neighbors(nodeID []byte) ([]*overlay.Node, error) {
+// Do Nothing
+return nil, nil
+}
+
+func (chord *ChordMock) NodeID() ([]byte, error) {
+// Do Nothing
+return nil, nil
+}
+
+func (chord *ChordMock) Leave() error {
+// Do Nothing
+return nil
+}