| import asyncio | |
| import hiredis | |
| import logging | |
| import sys | |
| from collections import deque | |
| logger = logging.getLogger('pylib.aio.redis_server') | |
| class RedisProtocol(asyncio.Protocol): | |
| def __init__(self, loop): |
| apiVersion: v1 | |
| kind: Pod | |
| metadata: | |
| name: pod-w-message | |
| spec: | |
| containers: | |
| - name: messager | |
| image: "ubuntu:14.04" | |
| command: ["/bin/sh","-c"] | |
| args: ["sleep 60 && /bin/echo Sleep expired > /dev/termination-log"] |
| Traceback (most recent call last): | |
| File "/home/josh/authbox/apps/s/s.py", line 100, in <module> | |
| result = command.run(selector, argv) | |
| File "/home/josh/authbox/apps/s/tooler/command.py", line 210, in run | |
| return self.fn(*args, **vargs) | |
| File "/home/josh/authbox/apps/s/sensu.py", line 276, in silence_hour | |
| stash_nodes(expand_names(names), 3600) | |
| File "/home/josh/authbox/apps/s/sensu.py", line 270, in stash_nodes | |
| expire_seconds=expire_seconds, | |
| File "/home/josh/authbox/apps/s/sensu.py", line 264, in stash_paths |
We've built an example (simple) rocksdb server available at: http://authbox-cdn.s3.amazonaws.com/mirror/sada-sliding
The server should run inside an ubuntu docker container with flags:
./sada-sliding --port 9015 --rocksdb_db_path /data \
--rocksdb_create_if_missing_one_off --version_timestamp_ms 9999999999999
This will start it up, and create the database on the first run. What we want is
| $ sudo pip3 install tooler | |
| $ git clone [email protected]:qix/tooler && cd tooler | |
| $ ./example/tool.py named:nginx* disk.free | |
| nginx2$ df -mah | grep '/$' | |
| nginx3$ df -mah | grep '/$' | |
| nginx7$ df -mah | grep '/$' | |
| nginx6$ df -mah | grep '/$' | |
| nginx1$ df -mah | grep '/$' | |
| nginx5$ df -mah | grep '/$' | |
| nginx4$ df -mah | grep '/$' |
| from __future__ import absolute_import | |
| import os | |
| from fabric.api import ( | |
| local, | |
| task, | |
| ) | |
| from util import ( | |
| status, |
| from __future__ import absolute_import | |
| import cPickle | |
| import zlib | |
| from hyperloglog import SlidingHyperLogLog | |
| def shlld_from_string(string, error_rate, window_count): | |
| lpfm = cPickle.loads(zlib.decompress(string)) if string else None | |
| return SlidingHyperLogLog( |
| 2015-07-29 20:11:00 =SUPERVISOR REPORT==== | |
| Supervisor: {local,riak_core_handoff_sender_sup} | |
| Context: child_terminated | |
| Reason: vnode_died | |
| Offender: [{pid,<0.25521.9>},{name,riak_core_handoff_sender},{mfargs,{riak_core_handoff_sender,start_link,undefined}},{restart_type,temporary},{shutdown,brutal_kill},{child_type,worker}] | |
| 2015-07-29 20:11:00 =ERROR REPORT==== | |
| ** Generic server <0.25378.9> terminating | |
| ** Last message in was {'$gen_cast',{work,{fold,#Fun<riak_kv_multi_backend.13.132002736>,#Fun<riak_kv_vnode.37.91169427>},{server,undefined,{<0.25521.9>,#Ref<0.0.25.251807>}},<0.25375.9>}} | |
| ** When Server state == {state,riak_kv_worker,{state,687933387884272662670093837274656655736483872768}} |
| 2015-07-29 19:12:51 =CRASH REPORT==== | |
| crasher: | |
| initial call: riak_core_vnode:init/1 | |
| pid: <0.28158.0> | |
| registered_name: [] | |
| exception exit: {{{badmatch,{reply,{riak_kv_w1c_put_reply_v1,ok,primary},{state,598016783243797190163421821199338462144370835456,riak_kv_multi_backend,false,{state,[{<<"leveldb_mult">>,riak_kv_eleveldb_backend,{state,<<>>,"/var/lib/riak/leveldb/598016783243797190163421821199338462144370835456",[{block_cache_threshold,33554432},{block_restart_interval,16},{block_size_steps,16},{compression,true},{create_if_missing,true},{delete_threshold,1000},{eleveldb_threads,71},{fadvise_willneed,false},{limited_developer_mem,false},{sst_block_size,4096},{tiered_slow_level,0},{total_leveldb_mem_percent,35},{use_bloomfilter,true},{write_buffer_size,22216967}],[{block_cache_threshold,33554432},{block_restart_interval,16},{block_size_steps,16},{compression,true},{create_if_missing,true},{data_root,"/var/lib/riak/leveldb"},{delete_threshold,1000},{eleveldb_threads,71},{fadvise_willneed,false |
| oot@riak10:/home/josh# riak-admin cluster status | |
| ---- Cluster Status ---- | |
| Ring ready: true | |
| +----------------------------------------+-------+-------+-----+-------+ | |
| | node |status | avail |ring |pending| | |
| +----------------------------------------+-------+-------+-----+-------+ | |
| | (C) [email protected] |leaving| up | 21.5| 16.7 | | |
| | [email protected] |leaving| up | 11.9| 16.7 | | |
| | [email protected] |leaving| up | 16.8| 16.7 | |