adds more playbooks

Author: bseto

cmd/reader/ansible-load-nodes.ini

@@ -0,0 +1,24 @@
+[load_nodes]
+# kvrocks-byron-load-test-node-1.us-east-1a ansible_host=127.0.0.1 ansible_port=13538 # will use as a dedicated writer
+kvrocks-byron-load-test-node-10.us-east-1a ansible_host=127.0.0.1 ansible_port=12519
+kvrocks-byron-load-test-node-11.us-east-1a ansible_host=127.0.0.1 ansible_port=10777
+kvrocks-byron-load-test-node-12.us-east-1a ansible_host=127.0.0.1 ansible_port=13170
+kvrocks-byron-load-test-node-13.us-east-1a ansible_host=127.0.0.1 ansible_port=13038
+kvrocks-byron-load-test-node-14.us-east-1a ansible_host=127.0.0.1 ansible_port=13002
+kvrocks-byron-load-test-node-2.us-east-1a ansible_host=127.0.0.1 ansible_port=11613
+kvrocks-byron-load-test-node-3.us-east-1a ansible_host=127.0.0.1 ansible_port=13633
+kvrocks-byron-load-test-node-4.us-east-1a ansible_host=127.0.0.1 ansible_port=12186
+kvrocks-byron-load-test-node-5.us-east-1a ansible_host=127.0.0.1 ansible_port=11648
+kvrocks-byron-load-test-node-6.us-east-1a ansible_host=127.0.0.1 ansible_port=12254
+kvrocks-byron-load-test-node-7.us-east-1a ansible_host=127.0.0.1 ansible_port=10013
+kvrocks-byron-load-test-node-8.us-east-1a ansible_host=127.0.0.1 ansible_port=10041
+kvrocks-byron-load-test-node-9.us-east-1a ansible_host=127.0.0.1 ansible_port=13087
+
+[load_nodes:vars]
+ansible_connection=ssh
+ansible_ssh_common_args='-o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null -o PreferredAuthentications=publickey,password -o PubkeyAuthentication=yes'
+ansible_scp_extra_args='-o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null'
+ansible_sftp_extra_args='-o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null'   
+
+# for debugging
+# ANSIBLE_DEBUG=1 ansible -i ansible-load-nodes.ini load_nodes -a "echo hello"

cmd/reader/ansible.cfg

@@ -0,0 +1,3 @@
+[defaults]
+inventory = ansible-load-nodes.ini
+

cmd/reader/main.go

@@ -53,7 +53,7 @@ func main() {
 	logger.Info("starting service", zap.Int("readers", *numReaders), zap.Duration("delay", *readDelay), zap.Int("start", *start))
 	// goal is to spam reading and client connections
 
-	kvRocksLiteReadTimeout := 50 * time.Millisecond // context timeout
+	kvRocksLiteReadTimeout := 1000 * time.Millisecond // context timeout
 
 	for i := 0; i < *numReaders; i++ {
 		wg.Add(1)

cmd/reader/playbooks/copy-reader.yml

@@ -0,0 +1,13 @@
+---
+# Usage: ansible-playbook -i ../ansible-load-nodes.ini copy-reader.yml
+# Or from parent directory: ansible-playbook -i ansible-load-nodes.ini playbooks/copy-reader.yml
+- name: Copy reader binary to load nodes
+  hosts: load_nodes
+  tasks:
+    - name: Copy reader binary to remote hosts
+      ansible.builtin.copy:
+        src: /Users/byron.seto/Documents/workspace/third_party/kvrocks-controller/cmd/reader/reader
+        dest: /home/ec2-user/reader
+        mode: "0755"
+        owner: ec2-user
+        group: ec2-user

cmd/reader/playbooks/copy-service-file.yml

@@ -0,0 +1,18 @@
+---
+# Usage: ansible-playbook -i ../ansible-load-nodes.ini copy-reader.yml
+# Or from parent directory: ansible-playbook -i ansible-load-nodes.ini playbooks/copy-reader.yml
+- name: Copy reader binary to load nodes
+  hosts: load_nodes
+  become: true
+  tasks:
+    - name: Copy reader service to remote hosts
+      ansible.builtin.copy:
+        src: /Users/byron.seto/Documents/workspace/third_party/kvrocks-controller/cmd/reader/reader.service
+        dest: /etc/systemd/system/reader.service
+        mode: "0644"
+        owner: root
+        group: root
+
+    - name: Reload systemd daemon
+      ansible.builtin.systemd:
+        daemon_reload: yes

cmd/reader/playbooks/start-reader.yml

@@ -0,0 +1,12 @@
+---
+# Usage: ansible-playbook -i ../ansible-load-nodes.ini start-reader.yml
+# Or from parent directory: ansible-playbook -i ansible-load-nodes.ini playbooks/start-reader.yml
+- name: Start reader service on load nodes
+  hosts: load_nodes
+  become: true
+  tasks:
+    - name: Start reader service
+      ansible.builtin.systemd:
+        name: reader
+        state: started
+        enabled: yes

cmd/reader/playbooks/stop-reader.yml

@@ -0,0 +1,11 @@
+---
+# Usage: ansible-playbook -i ../ansible-load-nodes.ini stop-reader.yml
+# Or from parent directory: ansible-playbook -i ansible-load-nodes.ini playbooks/stop-reader.yml
+- name: Stop reader service on load nodes
+  hosts: load_nodes
+  become: true
+  tasks:
+    - name: Stop reader service
+      ansible.builtin.systemd:
+        name: reader
+        state: stopped

cmd/reader/reader

@@ -4,7 +4,7 @@ After=network-online.target syslog.target remote-fs.target nss-lookup.target sys
 Wants=network-online.target
 
 [Service]
-ExecStart=/home/ec2-user/reader
+ExecStart=/home/ec2-user/reader -readers 24 -delay 0ms -start 500000000
 
 LimitNOFILE=1048576
 LimitSTACK=16777216