krb v0.15.0 · OCaml Package

type on_error := [

| `Call of Async.Socket.Address.Inet.t -> exn -> unit
| `Ignore
| `Raise

]

val serve : 
  ?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_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_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_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 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.

package krb