package krb
A library for using Kerberos for both Rpc and Tcp communication
Install
Dune Dependency
Authors
Maintainers
Sources
krb-v0.16.0.tar.gz
sha256=353675621e4c5a888f2483dc1bb7281bd17ce4ed7dfd2f40142257f98db7c77d
doc/krb.public/Krb_public/Rpc/Transport/Tcp/index.html
Module Transport.TcpSource
type on_error := tcp_on_errortype on_handshake_error := tcp_on_handshake_errorSource
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.trefer to Kerberized_tcp and Kerberized_rpc for details on these arguments.
Source
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.trefer to Kerberized_tcp and Kerberized_rpc for details on these arguments.
Source
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.trefer to Kerberized_tcp and Kerberized_rpc for details on these arguments.
Source
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.trefer to Kerberized_tcp and Kerberized_rpc for details on these arguments.
Source
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.trefer to Kerberized_tcp and Kerberized_rpc for details on these arguments.