Cli

.gitignore

@@ -0,0 +1,66 @@
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/**/usage.statistics.xml
+.idea/**/dictionaries
+.idea/**/shelf
+
+# Generated files
+.idea/**/contentModel.xml
+
+# Sensitive or high-churn files
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+.idea/**/dbnavigator.xml
+
+# Gradle
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# Gradle and Maven with auto-import
+# When using Gradle or Maven with auto-import, you should exclude module files,
+# since they will be recreated, and may cause churn.  Uncomment if using
+# auto-import.
+# .idea/modules.xml
+# .idea/*.iml
+# .idea/modules
+
+# CMake
+cmake-build-*/
+
+# Mongo Explorer plugin
+.idea/**/mongoSettings.xml
+
+# File-based project format
+*.iws
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+# Editor-based Rest Client
+.idea/httpRequests
+
+# Android studio 3.1+ serialized cache file
+.idea/caches/build_file_checksums.ser

Makefile

@@ -0,0 +1,41 @@
+
+.PHONY: test
+
+all: | clean deps gen_protobuf build gen_mocks test
+
+clean:
+	@rm -rf ./gen/*
+	@rm -rf ./test/cli/mocks/*
+	@rm -rf ./test/common/mocks/*
+
+deps:
+	@echo syncing dependencies...
+	@go get github.com/onsi/ginkgo
+	@go get github.com/onsi/gomega
+	@go get github.com/vektra/mockery/.../
+	@go get github.com/stretchr/testify/mock
+	@go get -u google.golang.org/grpc
+	@go get -u github.com/golang/protobuf/protoc-gen-go
+
+build: build_cli
+
+build_cli:
+	@echo building cli...
+	@go build -o go-scheduler-cli ./cmd/go-scheduler-cli
+	@chmod +x go-scheduler-cli
+
+gen_mocks:
+	@echo generating mocks...
+	@${GOPATH}/bin/mockery -all -dir pkg/cli -output test/cli/mocks -case=underscore
+	@${GOPATH}/bin/mockery -all -dir pkg/common -output test/common/mocks -case=underscore
+	@${GOPATH}/bin/mockery -all -dir pkg/master -output test/master/mocks -case=underscore
+	@${GOPATH}/bin/mockery -all -dir gen/protobuf/master -output test/master/mocks -case=underscore
+
+gen_protobuf:
+	@echo generating protobuf APIs...
+	@command -v protoc >/dev/null 2>&1 || { echo >&2 "protoc is not installed. "; exit 1; }
+	@protoc --go_out=plugins=grpc,paths=source_relative:./gen ./protobuf/master/master.proto
+
+test:
+	@echo running tests...
+	@${GOPATH}/bin/ginkgo -r ./test

README.md

@@ -1,2 +1,47 @@
 # go-scheduler
-This is a distributed job scheduler for linux systems built in Go.
+This is a distributed job scheduler for linux systems built in Go. It can run arbitrary docker images on a cluster of computers.
+
+# Install
+
+## Get the package
+`go get github.com/kmacmcfarlane/go-scheduler`
+
+## Build the project
+`make`
+
+## Generate Certificates with EasyRSA
+The cluster uses x509 certificates to authenticate the client, master, and node applications.
+
+# CLI
+The go-scheduler CLI client allows you to control work run on the cluster.
+
+## Install Client Certificate
+The client certificate is used to authenticate with your cluster. The certificate must have file permission 600.
+
+`mkdir ~/.go-scheduler`
+`cp ~/Downloads/client.crt ~/.go-scheduler/client.crt`
+`chmod 600 ~/.go-scheduler/client.crt`
+
+## Start a Job
+
+`go-scheduler-cli start --image redis --name redisCache --master 192.168.1.80`
+
+## Stop a Job
+
+`go-scheduler-cli stop --name redisCache --master 192.168.1.80`
+
+## Query Job Status
+
+`go-scheduler-cli query --name redisCache --master 192.168.1.80`
+
+## Stream Log Output
+
+`go-scheduler-cli log --name redisCache --master 192.168.1.80`
+
+## Status Codes
+go-scheduler-cli returns the following status codes:
+
+0: success
+1: error parsing command-line arguments
+2: error parsing command-line arguments
+3: application error

cmd/go-scheduler-cli/main.go

@@ -0,0 +1,33 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"github.com/kmacmcfarlane/go-scheduler/internal/grpc"
+	"github.com/kmacmcfarlane/go-scheduler/pkg/cli"
+	"github.com/kmacmcfarlane/go-scheduler/pkg/common"
+	"os"
+)
+
+func main() {
+
+	ctx := context.Background()
+
+	logger := common.NewConsoleLogger()
+
+	clientFactory := grpc.NewMasterClientFactory()
+
+	clientService := cli.NewClientService(ctx, clientFactory, logger)
+
+	commandParser := cli.NewCommandParser(clientService, logger)
+
+	// Parse and execute Command
+	err := commandParser.Parse(os.Args)
+
+	if nil != err {
+		fmt.Fprintln(os.Stderr, err.Error())
+		os.Exit(1)
+	}
+
+	os.Exit(0)
+}