The following functions are used to reduce code duplication between this implementation and lib/krb_for_low_latency_transport. They implement the guts of kerberized_rpc.ml abstractly over a Protocol.Connection.
val handle_client :
(module Krb_public__.Protocol_intf.Connection with type t = 'conn) ->
?heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ->
?handshake_timeout:Time_float_unix.Span.t ->
(Client_identity.t ->
Async.Socket.Address.Inet.t ->
Async.Rpc.Connection.t ->
'a) ->
'a Async.Rpc.Implementations.t ->
(Async.Socket.Address.Inet.t ->
Async.Rpc.Transport.t ->
'conn ->
unit Async.Deferred.t)
Core.Staged.tval handle_client_with_anon :
(module Krb_public__.Protocol_intf.Connection with type t = 'conn) ->
?heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ->
?handshake_timeout:Time_float_unix.Span.t ->
(Client_identity.t option ->
Async.Socket.Address.Inet.t ->
Async.Rpc.Connection.t ->
'a) ->
'a Async.Rpc.Implementations.t ->
(Async.Socket.Address.Inet.t ->
Async.Rpc.Transport.t ->
'conn option ->
unit Async.Deferred.t)
Core.Staged.tval client :
(module Krb_public__.Protocol_intf.Connection with type t = 'conn) ->
?heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ->
?implementations:
(Server_principal.t -> 'a Async.Rpc.Connection.Client_implementations.t) ->
?description:Core.Info.t ->
?on_credential_forwarding_request:
(Server_principal.t -> On_credential_forwarding_request.t) ->
finish_handshake_by:Time_float_unix.t ->
Async.Tcp.Where_to_connect.inet ->
Async.Rpc.Transport.t ->
'conn ->
Async.Rpc.Connection.t Async.Deferred.Or_error.tmodule For_testing : sig ... end