class PlaceOS::Driver::TransportTCP

Defined in:

placeos-driver/transport/tcp.cr

Constructors

Instance Method Summary

Instance methods inherited from class PlaceOS::Driver::Transport

before_request(&before_request : HTTP::Request -> ) before_request, client_cert_file : String client_cert_file, connect(connect_timeout : Int32) : Nil connect, cookies : HTTP::Cookies cookies, disconnect : Nil disconnect, exec(message) : SSH2::Channel exec, http_uri_override : URI | Nil http_uri_override, http_uri_override=(http_uri_override : URI | Nil) http_uri_override=, logger(*args, **options)
logger(*args, **options, &) logger, pre_processor : Bytes -> Bytes | Nil | Nil
pre_processor(&pre_processor : Bytes -> Bytes | Nil) pre_processor, pre_processor=(pre_processor : Bytes -> Bytes | Nil | Nil) pre_processor=, private_key_file : String private_key_file, proxy_in_use : String | Nil proxy_in_use, send(message) : PlaceOS::Driver::Transport
send(message, task : PlaceOS::Driver::Task, &_block : Bytes, PlaceOS::Driver::Task -> Nil) : PlaceOS::Driver::Transport send, start_tls(verify_mode : OpenSSL::SSL::VerifyMode, context : OpenSSL::SSL::Context) : Nil start_tls, terminate : Nil terminate, tokenizer : Tokenizer | Nil tokenizer, tokenizer=(tokenizer : Tokenizer | Nil) tokenizer=

Macros inherited from class PlaceOS::Driver::Transport

__build_http_helper__ __build_http_helper__

Constructor Detail

def self.new(queue : PlaceOS::Driver::Queue, ip : String, port : Int32, settings : PlaceOS::Driver::Settings, start_tls : Bool = false, uri : Nil | String = nil, makebreak : Bool = false, &received : Bytes, PlaceOS::Driver::Task | Nil -> Nil) #

timeouts in seconds


[View source]

Instance Method Detail

def connect(connect_timeout : Int32 = 10) : Nil #

[View source]
def disconnect : Nil #

[View source]
def enable_multicast_loop(state = true) #

def http(method, path, body : HTTP::Client::BodyType = nil, params : Hash(String, String | Nil) | URI::Params = URI::Params.new, headers : Hash(String, String) | HTTP::Headers = HTTP::Headers.new, secure = false, concurrent = true) : HTTP::Client::Response #

def received : Slice(UInt8), PlaceOS::Driver::Task? -> Nil #

[View source]
def received=(received : Slice(UInt8), Nil | PlaceOS::Driver::Task -> _) #

[View source]
def send(message) : PlaceOS::Driver::TransportTCP #

[View source]
def send(message, task : PlaceOS::Driver::Task, &block : Bytes, PlaceOS::Driver::Task -> Nil) : PlaceOS::Driver::TransportTCP #

[View source]
def start_tls(verify_mode = OpenSSL::SSL::VerifyMode::NONE, context = @tls) : Nil #

upgrades to an encrpyted socket, can be called from a received function


[View source]
def terminate : Nil #

[View source]