Plasma GitLab Archive
Projects Blog Knowledge

sig
  type 't result = [ `Error of exn | `Ok of 't ]
  type 't result_eof = [ `End_of_file | `Error of exn | `Ok of 't ]
  type sockaddr = [ `Implied | `Sockaddr of Unix.sockaddr ]
  val string_of_sockaddr : Netamqp_transport.sockaddr -> string
  exception Error of string
  class type amqp_multiplex_controller =
    object
      method abort_rw : unit -> unit
      method alive : bool
      method cancel_rd_polling : unit -> unit
      method cancel_shutting_down : unit -> unit
      method eff_max_frame_size : int
      method event_system : Unixqueue.event_system
      method getpeername : Netamqp_transport.sockaddr
      method getsockname : Netamqp_transport.sockaddr
      method inactivate : unit -> unit
      method read_eof : bool
      method reading : bool
      method set_max_frame_size : int -> unit
      method set_timeout : notify:(unit -> unit) -> float -> unit
      method start_reading :
        when_done:(Netamqp_types.frame Netamqp_transport.result_eof -> unit) ->
        unit -> unit
      method start_shutting_down :
        when_done:(unit Netamqp_transport.result -> unit) -> unit -> unit
      method start_writing :
        when_done:(unit Netamqp_transport.result -> unit) ->
        Netamqp_types.frame -> unit
      method tls_session_props : Nettls_support.tls_session_props option
      method transport_type : Netamqp_types.transport_type
      method writing : bool
    end
  val tcp_amqp_multiplex_controller :
    ?close_inactive_descr:bool ->
    ?preclose:(unit -> unit) ->
    ?tls_config:(module Netsys_crypto_types.TLS_CONFIG) * string option ->
    Unix.file_descr ->
    Unixqueue.event_system -> Netamqp_transport.amqp_multiplex_controller
  module Debug : sig val enable : bool Pervasives.ref end
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml