Locust to Go, Kubernetes to Load

"Go" to "load" test

Image Not Showing Possible Reasons

郭學聰 Hsueh-Tsung KuoSat, 11 Aug 2018

Locust to Go, Kubernetes to Load "Go" to "load" test 郭學聰 Hsueh-Tsung Kuo Sat, 11 Aug 2018

	from locust import HttpLocust, TaskSet, task

	class WebsiteTasks(TaskSet):
	def on_start(self):
	self.client.post("/login", {
	"username": "test_user",
	"password": ""
	})

	@task
	def index(self):
	self.client.get("/")

	@task
	def about(self):
	self.client.get("/about/")

	class WebsiteUser(HttpLocust):
	task_set = WebsiteTasks
	min_wait = 5000
	max_wait = 15000

	from locust import HttpLocust, TaskSet, task

	class WebsiteTasks(TaskSet):
	def on_start(self):
	self.client.post("/login", {
	"username": "test_user",
	"password": ""
	})

	@task(100)
	def index(self):
	self.client.get("/")

	@task(7)
	def about(self):
	self.client.get("/about/")

	class WebsiteUser(HttpLocust):
	task_set = WebsiteTasks
	min_wait = 5000
	max_wait = 15000

	# -- coding: utf-8 --

	from locust import Locust, TaskSet, task

	class MyTaskSet(TaskSet):
	@task(20)
	def hello(self):
	pass

	class Dummy(Locust):
	task_set = MyTaskSet

	package main

	import "github.com/myzhan/boomer"
	import "time"

	func foo() {

	start := boomer.Now()
	time.Sleep(100 * time.Millisecond)
	elapsed := boomer.Now() - start

	// Report your test result as a success, if you write it in python, it will looks like this
	// events.request_success.fire(request_type="http", name="foo", response_time=100, response_length=10)
	boomer.Events.Publish("request_success", "http", "foo", elapsed, int64(10))
	}

	func bar() {

	start := boomer.Now()
	time.Sleep(100 * time.Millisecond)
	elapsed := boomer.Now() - start

	// Report your test result as a failure, if you write it in python, it will looks like this
	// events.request_failure.fire(request_type="udp", name="bar", response_time=100, exception=Exception("udp error"))
	boomer.Events.Publish("request_failure", "udp", "bar", elapsed, "udp error")
	}

	func main(){

	sequencialTask1 := &boomer.Task{
	Name: "foobar1",
	Weight: 10,
	Fn: foobar,
	}

	sequencialTask2 := &boomer.Task{
	Name: "foobar2",
	Weight: 20,
	Fn: foobar,
	}

	boomer.Run(sequencialTask1, sequencialTask2)

	}

	resp, err := http.Get("http://example.com/")
	...
	resp, err := http.Post("http://example.com/upload", "image/jpeg", &buf)
	...
	resp, err := http.PostForm("http://example.com/form",
	url.Values{"key": {"Value"}, "id": {"123"}})

	func exampleGet() {
	start := boomer.Now()
	resp, err := http.Get("https://dl.google.com/go/go1.10.3.src.tar.gz")
	//resp, err := http.Get("https://cache.ruby-lang.org/pub/ruby/2.5/ruby-2.5.1.tar.gz")
	if err == nil {
	func() {
	defer resp.Body.Close()
	_, err = ioutil.ReadAll(resp.Body)
	}()
	}
	elapsed := boomer.Now() - start

	if err == nil {
	boomer.Events.Publish("request_success", "http", "example_get", elapsed, resp.ContentLength)
	} else {
	boomer.Events.Publish("request_failure", "http", "example_get", elapsed, err.Error())
	}
	}