Receive and dispatch minio events

[muhamadazmy]

The minio service will monitor all the events that is pushed from minio process. (it uses zos streams)

If minio reported that the tlog and/or the data shards are experiencing some errors. The minio service will update the service state to error

for example

// minio.state in zrobot

{
  'actions': {'install': 'ok', 'start': 'ok'},
  'data_shards': {'172.18.0.1:1024': 'error', '172.18.0.1:1025': 'error', '172.18.0.1:1026': 'error'}, 
  'status': {'running': 'ok'}, 
  'tlog_shards': {'': 'ok'}
}

How to test

• Deploy minio service (using s3 service)
• Kill one of the zdbs (may be drop the port forward)
• Try to upload a file
• Check the minio service state

[Pishoy]

verified but you need to exist js_shell and login again to it to get correct state otherwise the state will not change and be as before

• here is the minio

  
  In [91]: minio.state
  Out[91]: {'data_shards': {'10.102.71.171:1041': 'ok', '10.102.178.130:1036': 'ok', '10.102.234.229:1036': 'ok', '10.102.201.133:1041': 'ok', '10.102.114.69:1042': 'ok', '10.102.104.231:1031': 'ok', '10.102.167.219:1036': 'ok'}, 'actions': {'install': 'ok', 'start': 'ok'}, 'tlog_shards': {'10.102.115.21:1034': 'ok'}, 'status': {'running': 'ok'}}

- kill one of zdbs

In [88]: zdb = robot.services.get(name='227c0216-e4b3-46cf-ae76-5180b6deb01e') In [90]: zdb.schedule_action('stop').wait(die=True) Out[90]: stop

 - upload files 
- check state still not reported well after stop zdb (10.102.71.171 1041) even if i recall it again 

In [91]: minio.state Out[91]: {'data_shards': {'10.102.71.171:1041': 'ok', '10.102.178.130:1036': 'ok', '10.102.234.229:1036': 'ok', '10.102.201.133:1041': 'ok', '10.102.114.69:1042': 'ok', '10.102.104.231:1031': 'ok', '10.102.167.219:1036': 'ok'}, 'actions': {'install': 'ok', 'start': 'ok'}, 'tlog_shards': {'10.102.115.21:1034': 'ok'}, 'status': {'running': 'ok'}}

-   open new js shell session to give the correct state

In [5]: arobot Out[5]: js_object:config:j.clients.zrobot:zos-aclvm

god_token_ = '303164396566393632366334363065613165663564333431e087def35d9cf69b4e293cd9712869badbce96ac28cfb17937e05b8b68e17110a50e61d336bb15891a2bc19449bfb18ec47144f698d2d4b3c9525a
    bb9f8612ee50898b7f2cd63a793c7fbacf9bb8fa45bd2951ea2560ca63630e6b954b15609719308d56780eedf427cf5f8973d15392d9d33bb8fa5c08cf5e65c3c48b1eb4b26d0f8ae9b4e4ace491'

jwt_ = ''

secrets_ = [ ]

url = 'http://172.26.131.96:6600'

In [6]: arobot = j.clients.zrobot.robots.get('zos-aclvm')

In [7]: minio = arobot.services.get(name='ceb5f1bb-cca7-4caa-ad33-f19c5d0e5516')

In [8]: minio.state Out[8]: {'tlog_shards': {'10.102.115.21:1034': 'ok'}, 'data_shards': {'10.102.71.171:1041': 'error', '10.102.234.229:1036': 'ok', '10.102.114.69:1042': 'ok', '10.102.178.130:1036': 'ok', '10.102.167.219:1036': 'ok', '10.102.104.231:1031': 'ok', '10.102.201.133:1041': 'ok'}, 'status': {'running': 'ok'}, 'actions': {'start': 'ok', 'install': 'ok'}}

 - js version 

0-templates commit 4c752681b84a8edfe9aeca09a8f7471a47f9b5e5 Author: serboctor boctor.sarah@gmail.com Date: Wed Oct 31 13:11:55 2018 +0200

Fix state check in etcd

jumpscale_core commit b26808a525946a867dcb7b2db1dcb2300dbac1a7 Author: Reem Khamis reem.khamis@gmail.com Date: Mon Oct 22 15:58:15 2018 +0200

Make sure that we always not set ttl to sshkeys loaded for configmanager

jumpscale_lib commit 2b5751839e0e220900d13b9845a16716a57f1bd7 Author: Andrew Ayoub prog.andrew2015@yahoo.com Date: Mon Oct 29 09:37:37 2018 +0200

Development simple traefik (#209)

create traefik SAL

jumpscale_prefab commit 625ab647d69c2e85be6cacd6889ab2535c508486 Author: Maxime Daniel root@maxux.net Date: Thu Oct 18 23:29:53 2018 +0200

Update register_capacity init script