vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Change the default redis host to localhost. Fix some whitespace issues in the userevents module.

Browse source
This commit is contained in:
Jake Moshenko 2014-10-14 14:37:02 -04:00
parent 44637dad96
commit fa6a06502d
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
config.py
View file

@ -80,11 +80,11 @@ class DefaultConfig(object):
AUTHENTICATION_TYPE = 'Database' AUTHENTICATION_TYPE = 'Database'
# Build logs # Build logs
BUILDLOGS_REDIS = {'host': 'logs.quay.io'} BUILDLOGS_REDIS = {'host': 'localhost'}
BUILDLOGS_OPTIONS = [] BUILDLOGS_OPTIONS = []
# Real-time user events # Real-time user events
USER_EVENTS_REDIS = {'host': 'logs.quay.io'} USER_EVENTS_REDIS = {'host': 'localhost'}
# Stripe config # Stripe config
BILLING_TYPE = 'FakeStripe' BILLING_TYPE = 'FakeStripe'

8
data/userevent.py
View file

@ -30,7 +30,7 @@ class UserEventsBuilderModule(object):
if not redis_config: if not redis_config:
# This is the old key name. # This is the old key name.
redis_config = { redis_config = {
'host': app.config.get('USER_EVENTS_REDIS_HOSTNAME') 'host': app.config.get('USER_EVENTS_REDIS_HOSTNAME'),
} }
user_events = UserEventBuilder(redis_config) user_events = UserEventBuilder(redis_config)
@ -45,7 +45,7 @@ class UserEventsBuilderModule(object):
class UserEvent(object): class UserEvent(object):
""" """
Defines a helper class for publishing to realtime user events Defines a helper class for publishing to realtime user events
as backed by Redis. as backed by Redis.
""" """
@ -74,7 +74,7 @@ class UserEvent(object):
thread = threading.Thread(target=conduct) thread = threading.Thread(target=conduct)
thread.start() thread.start()
class UserEventListener(object): class UserEventListener(object):
""" """
Defines a helper class for subscribing to realtime user events as Defines a helper class for subscribing to realtime user events as
@ -90,7 +90,7 @@ class UserEventListener(object):
@staticmethod @staticmethod
def _user_event_key(username, event_id): def _user_event_key(username, event_id):
return 'user/%s/events/%s' % (username, event_id) return 'user/%s/events/%s' % (username, event_id)
def event_stream(self): def event_stream(self):
""" """
Starts listening for events on the channel(s), yielding for each event Starts listening for events on the channel(s), yielding for each event