module Cable

Overview

TODO Write documentation for Cable

Included Modules

Defined in:

cable.cr
cable/channel.cr
cable/connection.cr
cable/debug.cr
cable/handler.cr
cable/logger.cr
cable/payload.cr
cable/server.cr
cable/websocket_pinger.cr

Constant Summary

HABITAT_SETTINGS = [{decl: route : String = Cable.message(:default_mount_path), example: "/cable", validation: nil}, {decl: token : String = "token", example: "token", validation: nil}, {decl: url : String = ENV.fetch("REDIS_URL", "redis://localhost:6379"), example: "redis://localhost:6379", validation: nil}, {decl: disable_sec_websocket_protocol_header : Bool = false, example: nil, validation: nil}, {decl: pool_redis_publish : Bool = false, example: nil, validation: nil}, {decl: redis_pool_size : Int32 = 5, example: nil, validation: nil}, {decl: redis_pool_timeout : Float64 = 5.0, example: nil, validation: nil}] of Nil
INTERNAL = {message_types: {welcome: "welcome", disconnect: "disconnect", ping: "ping", confirmation: "confirm_subscription", rejection: "reject_subscription", unsubscribe: "confirm_unsubscription"}, disconnect_reasons: {unauthorized: "unauthorized", invalid_request: "invalid_request", server_restart: "server_restart"}, default_mount_path: "/cable", protocols: ["actioncable-v1-json", "actioncable-unsupported"]}
Logger = Log.for(self)
VERSION = "0.2.1"

Class Method Summary

Instance Method Summary

Class Method Detail

def self.configure(&) #

[View source]
def self.message(event : Symbol) #

[View source]
def self.restart #

[View source]
def self.server #

[View source]
def self.settings #

[View source]

Instance Method Detail

def settings #

[View source]