Plasma GitLab Archive
Projects Blog Knowledge

sig
  type connector =
      [ `Implied | `Inet of string * int | `Sockaddr of Unix.sockaddr ]
  type transport_layer =
      [ `Custom of
          unit ->
          Netamqp_transport.amqp_multiplex_controller Uq_engines.engine
      | `TCP of Netamqp_endpoint.connector
      | `TLS of
          Netamqp_endpoint.connector *
          (module Netsys_crypto_types.TLS_CONFIG) ]
  type endpoint
  type state =
      [ `Connected of bool
      | `Disconnected
      | `Disconnecting of bool
      | `Error of exn
      | `Off ]
  type proto_revision_0_9 = [ `One ]
  type protocol = [ `AMQP_0_9 of Netamqp_endpoint.proto_revision_0_9 ]
  type sync_client_to_server_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.sync_client_to_server_method_t ]
  type sync_server_to_client_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_to_client_method_t ]
  type sync_client_initiated_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.sync_client_initiated_method_t ]
  type sync_server_initiated_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_initiated_method_t ]
  type sync_server_initiated_method_type_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_initiated_method_type_t ]
  type async_client_to_server_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.async_client_to_server_method_t ]
  type async_server_to_client_method_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.async_server_to_client_method_t ]
  type async_server_to_client_method_type_t =
      [ `AMQP_0_9 of Netamqp_methods_0_9.async_server_to_client_method_type_t ]
  type method_type_t = [ `AMQP_0_9 of Netamqp_methods_0_9.method_type_t ]
  type props_t = [ `AMQP_0_9 of Netamqp_methods_0_9.props_t ]
  type data = Netamqp_endpoint.props_t * Netxdr_mstring.mstring list
  val create :
    Netamqp_endpoint.transport_layer ->
    Netamqp_endpoint.protocol ->
    Unixqueue.event_system -> Netamqp_endpoint.endpoint
  val configure_timeout : Netamqp_endpoint.endpoint -> float -> unit
  val get_timeout : Netamqp_endpoint.endpoint -> float
  val default_port : int
  val connect : Netamqp_endpoint.endpoint -> unit
  val disconnect : Netamqp_endpoint.endpoint -> unit
  val quick_disconnect : Netamqp_endpoint.endpoint -> unit
  val reset : Netamqp_endpoint.endpoint -> unit
  val state : Netamqp_endpoint.endpoint -> Netamqp_endpoint.state
  val state_change_e :
    Netamqp_endpoint.endpoint -> Netamqp_endpoint.state Uq_engines.engine
  val event_system : Netamqp_endpoint.endpoint -> Unixqueue.event_system
  val protocol : Netamqp_endpoint.endpoint -> Netamqp_endpoint.protocol
  val getsockname : Netamqp_endpoint.endpoint -> Netamqp_transport.sockaddr
  val getpeername : Netamqp_endpoint.endpoint -> Netamqp_transport.sockaddr
  val enable_channel :
    Netamqp_endpoint.endpoint -> Netamqp_types.channel -> unit
  val disable_channel :
    Netamqp_endpoint.endpoint -> Netamqp_types.channel -> unit
  val is_channel_enabled :
    Netamqp_endpoint.endpoint -> Netamqp_types.channel -> bool
  val suggest_channel : Netamqp_endpoint.endpoint -> Netamqp_types.channel
  val flow_control :
    Netamqp_endpoint.endpoint -> Netamqp_types.channel -> bool -> unit
  val drop_frames : Netamqp_endpoint.endpoint -> unit
  val clear_output : Netamqp_endpoint.endpoint -> unit
  val expect_eof : Netamqp_endpoint.endpoint -> unit
  val set_max_frame_size : Netamqp_endpoint.endpoint -> int -> unit
  val eff_max_frame_size : Netamqp_endpoint.endpoint -> int
  val announce_e : Netamqp_endpoint.endpoint -> unit Uq_engines.engine
  val announce_s : Netamqp_endpoint.endpoint -> unit
  val sync_c2s_e :
    ?no_wait:Netamqp_endpoint.sync_server_to_client_method_t ->
    ?on_timeout:(unit -> unit) ->
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.sync_client_initiated_method_t ->
    Netamqp_endpoint.data option ->
    Netamqp_types.channel ->
    float ->
    (Netamqp_endpoint.sync_server_to_client_method_t *
     Netamqp_endpoint.data option)
    Uq_engines.engine
  val sync_c2s_s :
    ?no_wait:Netamqp_endpoint.sync_server_to_client_method_t ->
    ?on_timeout:(unit -> unit) ->
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.sync_client_initiated_method_t ->
    Netamqp_endpoint.data option ->
    Netamqp_types.channel ->
    float ->
    Netamqp_endpoint.sync_server_to_client_method_t *
    Netamqp_endpoint.data option
  val register_sync_s2c :
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.sync_server_initiated_method_type_t ->
    Netamqp_types.channel ->
    (Netamqp_endpoint.sync_server_initiated_method_t ->
     Netamqp_endpoint.sync_client_to_server_method_t option) ->
    (unit -> unit) -> unit
  val async_c2s :
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.async_client_to_server_method_t ->
    Netamqp_endpoint.data option -> Netamqp_types.channel -> unit
  val async_c2s_e :
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.async_client_to_server_method_t ->
    Netamqp_endpoint.data option ->
    Netamqp_types.channel -> unit Uq_engines.engine
  val async_c2s_s :
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.async_client_to_server_method_t ->
    Netamqp_endpoint.data option -> Netamqp_types.channel -> unit
  val register_async_s2c :
    Netamqp_endpoint.endpoint ->
    Netamqp_endpoint.async_server_to_client_method_type_t ->
    Netamqp_types.channel ->
    (Netamqp_endpoint.async_server_to_client_method_t ->
     Netamqp_endpoint.data option -> unit) ->
    unit
  val propagate_error :
    Netamqp_endpoint.endpoint -> exn -> Netamqp_types.channel option -> unit
  val abort_and_propagate_error : Netamqp_endpoint.endpoint -> exn -> unit
  val listen_for_errors :
    Netamqp_endpoint.endpoint ->
    Netamqp_types.channel option -> (exn -> bool) -> unit
  val create_method_exception :
    Netamqp_endpoint.protocol ->
    class_id:int -> meth_id:int -> reply_code:int -> reply_text:string -> exn
  val tls_session_props :
    Netamqp_endpoint.endpoint -> Nettls_support.tls_session_props option
  module Debug : sig val enable : bool Pervasives.ref end
  val sync : ('-> 'Uq_engines.engine) -> '-> 'b
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml