package krb

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type on_error := tcp_on_error
type on_handshake_error := tcp_on_handshake_error
val serve : ?additional_magic_numbers:int list -> ?max_message_size:int -> ?max_connections:int -> ?backlog:int -> ?drop_incoming_connections:bool -> ?buffer_age_limit:Async.Writer.buffer_age_limit -> ?on_kerberos_error:on_error -> ?on_handshake_error:on_handshake_error -> ?on_handler_error:on_error -> ?on_done_with_internal_buffer:[ `Do_nothing | `Zero ] -> authorize:Authorize.t -> where_to_listen:Async.Tcp.Where_to_listen.inet -> krb_mode:Mode.Server.t -> (Async.Socket.Address.Inet.t -> Async.Rpc.Transport.t -> Async_protocol.Connection.t -> unit Async.Deferred.t) -> (Async.Socket.Address.Inet.t, int) Async.Tcp.Server.t Async.Deferred.Or_error.t

refer to Kerberized_tcp and Kerberized_rpc for details on these arguments.

val serve_with_anon : ?max_message_size:int -> ?max_connections:int -> ?backlog:int -> ?drop_incoming_connections:bool -> ?buffer_age_limit:Async.Writer.buffer_age_limit -> ?on_kerberos_error:on_error -> ?on_handshake_error:on_handshake_error -> ?on_handler_error:on_error -> ?on_done_with_internal_buffer:[ `Do_nothing | `Zero ] -> authorize:Authorize.Anon.t -> where_to_listen:Async.Tcp.Where_to_listen.inet -> krb_mode:Mode.Server.t -> (Async.Socket.Address.Inet.t -> Async.Rpc.Transport.t -> Async_protocol.Connection.t option -> unit Async.Deferred.t) -> (Async.Socket.Address.Inet.t, int) Async.Tcp.Server.t Async.Deferred.Or_error.t

refer to Kerberized_tcp and Kerberized_rpc for details on these arguments.

val create_handler : ?max_message_size:int -> ?on_kerberos_error:on_error -> ?on_handshake_error:on_handshake_error -> ?on_handler_error:on_error -> ?on_done_with_internal_buffer:[ `Do_nothing | `Zero ] -> authorize:Authorize.t -> krb_mode:Mode.Server.t -> (Async.Socket.Address.Inet.t -> Async.Rpc.Transport.t -> Async_protocol.Connection.t -> unit Async.Deferred.t) -> (Async.Socket.Address.Inet.t -> Async.Reader.t -> Async.Writer.t -> unit Async.Deferred.t) Async.Deferred.Or_error.t

refer to Kerberized_tcp and Kerberized_rpc for details on these arguments.

val create_handler_with_anon : ?max_message_size:int -> ?on_kerberos_error:on_error -> ?on_handshake_error:on_handshake_error -> ?on_handler_error:on_error -> ?on_done_with_internal_buffer:[ `Do_nothing | `Zero ] -> authorize:Authorize.Anon.t -> krb_mode:Mode.Server.t -> (Async.Socket.Address.Inet.t -> Async.Rpc.Transport.t -> Async_protocol.Connection.t option -> unit Async.Deferred.t) -> (Async.Socket.Address.Inet.t -> Async.Reader.t -> Async.Writer.t -> unit Async.Deferred.t) Async.Deferred.Or_error.t

refer to Kerberized_tcp and Kerberized_rpc for details on these arguments.

val client : ?max_message_size:int -> ?timeout:Core.Time_ns.Span.t -> ?cred_cache:Cred_cache.t -> ?buffer_age_limit:Async.Writer.buffer_age_limit -> ?on_done_with_internal_buffer:[ `Do_nothing | `Zero ] -> ?krb_mode:Mode.Client.t -> authorize:Authorize.t -> Async.Tcp.Where_to_connect.inet -> (Async.Rpc.Transport.t * Async_protocol.Connection.t) Async.Deferred.Or_error.t

refer to Kerberized_tcp and Kerberized_rpc for details on these arguments.

OCaml

Innovation. Community. Security.