Module: NginxStreamPusher

Extended by:

NginxStreamPusher

Included in:

NginxStreamPusher

Defined in:

lib/nginx_stream_pusher.rb

Constant Summary

RootCA =

'/etc/ssl/certs'

DEFAULT_URL =

Addressable::URI.parse 'https://localhost:8123/live-pub'

DEFAULT_TIMEOUT =

10

@@base_url =

nil

@@user =

nil

@@pass =

nil

@@timeout =

nil

Instance Method Summary

• #base_url ⇒ Object
• #base_url=(url) ⇒ Object
• #pass ⇒ Object
• #pass=(password) ⇒ Object
• #publish!(channel, text) ⇒ Object
• #timeout ⇒ Object
• #timeout=(new_timeout) ⇒ Object
• #user ⇒ Object
• #user=(username) ⇒ Object

Instance Method Details

#base_url ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 18

def base_url
  @@base_url || DEFAULT_URL
end

#base_url=(url) ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 15

def base_url=(url)
  @@base_url = Addressable::URI.parse url
end

#pass ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 34

def pass
  @@pass
end

#pass=(password) ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 31

def pass=(password)
  @@pass = password
end

#publish!(channel, text) ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 46

def publish!(channel, text)
  url = base_url.dup
  url.query_values = { :id => channel }
  post_url(url, text)
end

#timeout ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 42

def timeout
  @@timeout || DEFAULT_TIMEOUT
end

#timeout=(new_timeout) ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 39

def timeout=(new_timeout)
  @@timeout = new_timeout
end

#user ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 26

def user
  @@user
end

#user=(username) ⇒ Object

# File 'lib/nginx_stream_pusher.rb', line 23

def user=(username)
  @@user = username
end