Module Internal.TcpSource

type on_error := tcp_on_error
type on_handshake_error := tcp_on_handshake_error
Sourceval serve : ?override_supported_versions:int list -> ?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
Sourceval client : ?override_supported_versions:int list -> ?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