Plasma GitLab Archive
Projects Blog Knowledge

sig
  type shortstr = string
  type octet = int
  type reply_text = string
  type path = string
  type longlong = Netnumber.uint8
  type bit = bool
  type class_id = int
  type longstr = string
  type peer_properties = Netamqp_rtypes.table
  type exchange_name = string
  type delivery_tag = Netnumber.uint8
  type timestamp = float
  type consumer_tag = string
  type long = Netnumber.uint4
  type reply_code = int
  type message_count = Netnumber.uint4
  type method_id = int
  type no_wait = bool
  type no_ack = bool
  type queue_name = string
  type redelivered = bool
  type table = Netamqp_rtypes.table
  type short = int
  type no_local = bool
  type arg_Connection_start =
      Netamqp_methods_0_9.octet * Netamqp_methods_0_9.octet *
      Netamqp_methods_0_9.peer_properties * Netamqp_methods_0_9.longstr *
      Netamqp_methods_0_9.longstr
  type arg_Connection_start_ok =
      Netamqp_methods_0_9.peer_properties * Netamqp_methods_0_9.shortstr *
      Netamqp_methods_0_9.longstr * Netamqp_methods_0_9.shortstr
  type arg_Connection_secure = Netamqp_methods_0_9.longstr
  type arg_Connection_secure_ok = Netamqp_methods_0_9.longstr
  type arg_Connection_tune =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.long *
      Netamqp_methods_0_9.short
  type arg_Connection_tune_ok =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.long *
      Netamqp_methods_0_9.short
  type arg_Connection_open =
      Netamqp_methods_0_9.path * Netamqp_methods_0_9.shortstr *
      Netamqp_methods_0_9.bit
  type arg_Connection_open_ok = Netamqp_methods_0_9.shortstr
  type arg_Connection_close =
      Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
      Netamqp_methods_0_9.class_id * Netamqp_methods_0_9.method_id
  type arg_Channel_open = Netamqp_methods_0_9.shortstr
  type arg_Channel_open_ok = Netamqp_methods_0_9.longstr
  type arg_Channel_flow = Netamqp_methods_0_9.bit
  type arg_Channel_flow_ok = Netamqp_methods_0_9.bit
  type arg_Channel_close =
      Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
      Netamqp_methods_0_9.class_id * Netamqp_methods_0_9.method_id
  type arg_Exchange_declare =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
      Netamqp_methods_0_9.shortstr * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.no_wait *
      Netamqp_methods_0_9.table
  type arg_Exchange_delete =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.no_wait
  type arg_Queue_declare =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
  type arg_Queue_declare_ok =
      Netamqp_methods_0_9.queue_name * Netamqp_methods_0_9.message_count *
      Netamqp_methods_0_9.long
  type arg_Queue_bind =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
      Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
  type arg_Queue_unbind =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
      Netamqp_methods_0_9.table
  type arg_Queue_purge =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.no_wait
  type arg_Queue_purge_ok = Netamqp_methods_0_9.message_count
  type arg_Queue_delete =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.no_wait
  type arg_Queue_delete_ok = Netamqp_methods_0_9.message_count
  type arg_Basic_qos =
      Netamqp_methods_0_9.long * Netamqp_methods_0_9.short *
      Netamqp_methods_0_9.bit
  type arg_Basic_consume =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.no_local *
      Netamqp_methods_0_9.no_ack * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
  type arg_Basic_consume_ok = Netamqp_methods_0_9.consumer_tag
  type arg_Basic_cancel =
      Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.no_wait
  type arg_Basic_cancel_ok = Netamqp_methods_0_9.consumer_tag
  type arg_Basic_publish =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
      Netamqp_methods_0_9.shortstr * Netamqp_methods_0_9.bit *
      Netamqp_methods_0_9.bit
  type arg_Basic_return =
      Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
      Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr
  type arg_Basic_deliver =
      Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.delivery_tag *
      Netamqp_methods_0_9.redelivered * Netamqp_methods_0_9.exchange_name *
      Netamqp_methods_0_9.shortstr
  type arg_Basic_get =
      Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
      Netamqp_methods_0_9.no_ack
  type arg_Basic_get_ok =
      Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.redelivered *
      Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
      Netamqp_methods_0_9.message_count
  type arg_Basic_get_empty = Netamqp_methods_0_9.shortstr
  type arg_Basic_ack =
      Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.bit
  type arg_Basic_reject =
      Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.bit
  type arg_Basic_recover_async = Netamqp_methods_0_9.bit
  type arg_Basic_recover = Netamqp_methods_0_9.bit
  type method_t =
      [ `Basic_ack of Netamqp_methods_0_9.arg_Basic_ack
      | `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
      | `Basic_cancel_ok of Netamqp_methods_0_9.arg_Basic_cancel_ok
      | `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
      | `Basic_consume_ok of Netamqp_methods_0_9.arg_Basic_consume_ok
      | `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
      | `Basic_get of Netamqp_methods_0_9.arg_Basic_get
      | `Basic_get_empty of Netamqp_methods_0_9.arg_Basic_get_empty
      | `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
      | `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
      | `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
      | `Basic_qos_ok
      | `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
      | `Basic_recover_async of Netamqp_methods_0_9.arg_Basic_recover_async
      | `Basic_recover_ok
      | `Basic_reject of Netamqp_methods_0_9.arg_Basic_reject
      | `Basic_return of Netamqp_methods_0_9.arg_Basic_return
      | `Channel_close of Netamqp_methods_0_9.arg_Channel_close
      | `Channel_close_ok
      | `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
      | `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
      | `Channel_open of Netamqp_methods_0_9.arg_Channel_open
      | `Channel_open_ok of Netamqp_methods_0_9.arg_Channel_open_ok
      | `Connection_close of Netamqp_methods_0_9.arg_Connection_close
      | `Connection_close_ok
      | `Connection_open of Netamqp_methods_0_9.arg_Connection_open
      | `Connection_open_ok of Netamqp_methods_0_9.arg_Connection_open_ok
      | `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
      | `Connection_secure_ok of Netamqp_methods_0_9.arg_Connection_secure_ok
      | `Connection_start of Netamqp_methods_0_9.arg_Connection_start
      | `Connection_start_ok of Netamqp_methods_0_9.arg_Connection_start_ok
      | `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune
      | `Connection_tune_ok of Netamqp_methods_0_9.arg_Connection_tune_ok
      | `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
      | `Exchange_declare_ok
      | `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
      | `Exchange_delete_ok
      | `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
      | `Queue_bind_ok
      | `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
      | `Queue_declare_ok of Netamqp_methods_0_9.arg_Queue_declare_ok
      | `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
      | `Queue_delete_ok of Netamqp_methods_0_9.arg_Queue_delete_ok
      | `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
      | `Queue_purge_ok of Netamqp_methods_0_9.arg_Queue_purge_ok
      | `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
      | `Queue_unbind_ok
      | `Tx_commit
      | `Tx_commit_ok
      | `Tx_rollback
      | `Tx_rollback_ok
      | `Tx_select
      | `Tx_select_ok ]
  type sync_client_to_server_method_t =
      [ `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
      | `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
      | `Basic_get of Netamqp_methods_0_9.arg_Basic_get
      | `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
      | `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
      | `Channel_close of Netamqp_methods_0_9.arg_Channel_close
      | `Channel_close_ok
      | `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
      | `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
      | `Channel_open of Netamqp_methods_0_9.arg_Channel_open
      | `Connection_close of Netamqp_methods_0_9.arg_Connection_close
      | `Connection_close_ok
      | `Connection_open of Netamqp_methods_0_9.arg_Connection_open
      | `Connection_secure_ok of Netamqp_methods_0_9.arg_Connection_secure_ok
      | `Connection_start_ok of Netamqp_methods_0_9.arg_Connection_start_ok
      | `Connection_tune_ok of Netamqp_methods_0_9.arg_Connection_tune_ok
      | `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
      | `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
      | `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
      | `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
      | `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
      | `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
      | `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
      | `Tx_commit
      | `Tx_rollback
      | `Tx_select ]
  type sync_server_to_client_method_t =
      [ `Basic_cancel_ok of Netamqp_methods_0_9.arg_Basic_cancel_ok
      | `Basic_consume_ok of Netamqp_methods_0_9.arg_Basic_consume_ok
      | `Basic_get_empty of Netamqp_methods_0_9.arg_Basic_get_empty
      | `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
      | `Basic_qos_ok
      | `Basic_recover_ok
      | `Channel_close of Netamqp_methods_0_9.arg_Channel_close
      | `Channel_close_ok
      | `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
      | `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
      | `Channel_open_ok of Netamqp_methods_0_9.arg_Channel_open_ok
      | `Connection_close of Netamqp_methods_0_9.arg_Connection_close
      | `Connection_close_ok
      | `Connection_open_ok of Netamqp_methods_0_9.arg_Connection_open_ok
      | `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
      | `Connection_start of Netamqp_methods_0_9.arg_Connection_start
      | `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune
      | `Exchange_declare_ok
      | `Exchange_delete_ok
      | `Queue_bind_ok
      | `Queue_declare_ok of Netamqp_methods_0_9.arg_Queue_declare_ok
      | `Queue_delete_ok of Netamqp_methods_0_9.arg_Queue_delete_ok
      | `Queue_purge_ok of Netamqp_methods_0_9.arg_Queue_purge_ok
      | `Queue_unbind_ok
      | `Tx_commit_ok
      | `Tx_rollback_ok
      | `Tx_select_ok ]
  type sync_client_initiated_method_t =
      [ `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
      | `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
      | `Basic_get of Netamqp_methods_0_9.arg_Basic_get
      | `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
      | `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
      | `Channel_close of Netamqp_methods_0_9.arg_Channel_close
      | `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
      | `Channel_open of Netamqp_methods_0_9.arg_Channel_open
      | `Connection_close of Netamqp_methods_0_9.arg_Connection_close
      | `Connection_open of Netamqp_methods_0_9.arg_Connection_open
      | `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
      | `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
      | `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
      | `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
      | `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
      | `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
      | `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
      | `Tx_commit
      | `Tx_rollback
      | `Tx_select ]
  type sync_server_initiated_method_t =
      [ `Channel_close of Netamqp_methods_0_9.arg_Channel_close
      | `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
      | `Connection_close of Netamqp_methods_0_9.arg_Connection_close
      | `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
      | `Connection_start of Netamqp_methods_0_9.arg_Connection_start
      | `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune ]
  type async_client_to_server_method_t =
      [ `Basic_ack of Netamqp_methods_0_9.arg_Basic_ack
      | `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
      | `Basic_recover_async of Netamqp_methods_0_9.arg_Basic_recover_async
      | `Basic_reject of Netamqp_methods_0_9.arg_Basic_reject ]
  type async_server_to_client_method_t =
      [ `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
      | `Basic_return of Netamqp_methods_0_9.arg_Basic_return ]
  type content_method_t =
      [ `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
      | `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
      | `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
      | `Basic_return of Netamqp_methods_0_9.arg_Basic_return ]
  type method_type_t =
      [ `Basic_ack
      | `Basic_cancel
      | `Basic_cancel_ok
      | `Basic_consume
      | `Basic_consume_ok
      | `Basic_deliver
      | `Basic_get
      | `Basic_get_empty
      | `Basic_get_ok
      | `Basic_publish
      | `Basic_qos
      | `Basic_qos_ok
      | `Basic_recover
      | `Basic_recover_async
      | `Basic_recover_ok
      | `Basic_reject
      | `Basic_return
      | `Channel_close
      | `Channel_close_ok
      | `Channel_flow
      | `Channel_flow_ok
      | `Channel_open
      | `Channel_open_ok
      | `Connection_close
      | `Connection_close_ok
      | `Connection_open
      | `Connection_open_ok
      | `Connection_secure
      | `Connection_secure_ok
      | `Connection_start
      | `Connection_start_ok
      | `Connection_tune
      | `Connection_tune_ok
      | `Exchange_declare
      | `Exchange_declare_ok
      | `Exchange_delete
      | `Exchange_delete_ok
      | `Queue_bind
      | `Queue_bind_ok
      | `Queue_declare
      | `Queue_declare_ok
      | `Queue_delete
      | `Queue_delete_ok
      | `Queue_purge
      | `Queue_purge_ok
      | `Queue_unbind
      | `Queue_unbind_ok
      | `Tx_commit
      | `Tx_commit_ok
      | `Tx_rollback
      | `Tx_rollback_ok
      | `Tx_select
      | `Tx_select_ok ]
  type sync_client_to_server_method_type_t =
      [ `Basic_cancel
      | `Basic_consume
      | `Basic_get
      | `Basic_qos
      | `Basic_recover
      | `Channel_close
      | `Channel_close_ok
      | `Channel_flow
      | `Channel_flow_ok
      | `Channel_open
      | `Connection_close
      | `Connection_close_ok
      | `Connection_open
      | `Connection_secure_ok
      | `Connection_start_ok
      | `Connection_tune_ok
      | `Exchange_declare
      | `Exchange_delete
      | `Queue_bind
      | `Queue_declare
      | `Queue_delete
      | `Queue_purge
      | `Queue_unbind
      | `Tx_commit
      | `Tx_rollback
      | `Tx_select ]
  type sync_server_to_client_method_type_t =
      [ `Basic_cancel_ok
      | `Basic_consume_ok
      | `Basic_get_empty
      | `Basic_get_ok
      | `Basic_qos_ok
      | `Basic_recover_ok
      | `Channel_close
      | `Channel_close_ok
      | `Channel_flow
      | `Channel_flow_ok
      | `Channel_open_ok
      | `Connection_close
      | `Connection_close_ok
      | `Connection_open_ok
      | `Connection_secure
      | `Connection_start
      | `Connection_tune
      | `Exchange_declare_ok
      | `Exchange_delete_ok
      | `Queue_bind_ok
      | `Queue_declare_ok
      | `Queue_delete_ok
      | `Queue_purge_ok
      | `Queue_unbind_ok
      | `Tx_commit_ok
      | `Tx_rollback_ok
      | `Tx_select_ok ]
  type sync_client_initiated_method_type_t =
      [ `Basic_cancel
      | `Basic_consume
      | `Basic_get
      | `Basic_qos
      | `Basic_recover
      | `Channel_close
      | `Channel_flow
      | `Channel_open
      | `Connection_close
      | `Connection_open
      | `Exchange_declare
      | `Exchange_delete
      | `Queue_bind
      | `Queue_declare
      | `Queue_delete
      | `Queue_purge
      | `Queue_unbind
      | `Tx_commit
      | `Tx_rollback
      | `Tx_select ]
  type sync_server_initiated_method_type_t =
      [ `Channel_close
      | `Channel_flow
      | `Connection_close
      | `Connection_secure
      | `Connection_start
      | `Connection_tune ]
  type async_client_to_server_method_type_t =
      [ `Basic_ack | `Basic_publish | `Basic_recover_async | `Basic_reject ]
  type async_server_to_client_method_type_t =
      [ `Basic_deliver | `Basic_return ]
  type content_method_type_t =
      [ `Basic_deliver | `Basic_get_ok | `Basic_publish | `Basic_return ]
  val type_of_method :
    Netamqp_methods_0_9.method_t -> Netamqp_methods_0_9.method_type_t
  val responses_of_method :
    Netamqp_methods_0_9.method_type_t ->
    Netamqp_methods_0_9.method_type_t list
  val content_method_types : Netamqp_methods_0_9.method_type_t list
  val string_of_method_type : Netamqp_methods_0_9.method_type_t -> string
  val string_of_method_id : class_id:int -> meth_id:int -> string
  type props_t =
      [ `P_basic of
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.table option *
          Netamqp_methods_0_9.octet option *
          Netamqp_methods_0_9.octet option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.timestamp option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option *
          Netamqp_methods_0_9.shortstr option
      | `P_channel
      | `P_connection
      | `P_exchange
      | `P_queue
      | `P_tx ]
  type message_t =
      [ `Body of Netxdr_mstring.mstring list
      | `Header of Netamqp_methods_0_9.props_t * int64
      | `Heartbeat
      | `Method of Netamqp_methods_0_9.method_t
      | `Proto_header of string ]
  val decode_method_message :
    Netamqp_types.frame -> Netamqp_methods_0_9.method_t
  val encode_method_message :
    Netamqp_methods_0_9.method_t -> int -> Netamqp_types.frame
  val decode_header_message :
    Netamqp_types.frame -> Netamqp_methods_0_9.props_t * int64
  val encode_header_message :
    Netamqp_methods_0_9.props_t -> int64 -> int -> Netamqp_types.frame
  val encode_heartbeat_message : unit -> Netamqp_types.frame
  val encode_body_message :
    Netxdr_mstring.mstring list -> int -> Netamqp_types.frame
  val encode_proto_header_message : string -> Netamqp_types.frame
  val decode_message : Netamqp_types.frame -> Netamqp_methods_0_9.message_t
  val encode_message :
    Netamqp_methods_0_9.message_t -> int -> Netamqp_types.frame
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml