chilli
Types
This type holds useful bits of data for the active connection.
pub type Connection(user_message) {
Connection(
socket: Socket,
transport: Transport,
subject: Subject(handler.Message(user_message)),
)
}
Constructors
-
Connection( socket: Socket, transport: Transport, subject: Subject(handler.Message(user_message)), )
Arguments
-
transport
This provides a uniform interface for both TCP and SSL methods.
-
pub type ConnectionInfo {
ConnectionInfo(port: Int, ip_address: IpAddress)
}
Constructors
-
ConnectionInfo(port: Int, ip_address: IpAddress)
This is used to describe the connecting client’s IP address.
pub type IpAddress {
IpV4(Int, Int, Int, Int)
IpV6(Int, Int, Int, Int, Int, Int, Int, Int)
}
Constructors
-
IpV4(Int, Int, Int, Int)
-
IpV6(Int, Int, Int, Int, Int, Int, Int, Int)
This is the shape of the function you need to provide for the handler
argument to serve(_ssl)
.
pub type Loop(user_message, data) =
fn(Message(user_message), data, Connection(user_message)) ->
actor.Next(Message(user_message), data)
Your provided loop function with receive these message types as the first argument.
pub type Message(user_message) {
Packet(BitArray)
User(user_message)
}
Constructors
-
Packet(BitArray)
These are messages received from the socket
-
User(user_message)
These are any messages received from the selector returned from
on_init
This holds information about the server. Returned by the start_server
/
start_ssl_server
methods, it will allow you to get access to an
OS-assigned port. Eventually, it will be used for graceful shutdown, and
potentially other information.
pub opaque type Server
pub type SocketReason =
InternalSocketReason
Reasons that serve
might fail
pub type StartError {
ListenerClosed
ListenerTimeout
AcceptorTimeout
AcceptorFailed(process.ExitReason)
AcceptorCrashed(Dynamic)
SystemError(SocketReason)
}
Constructors
-
ListenerClosed
-
ListenerTimeout
-
AcceptorTimeout
-
AcceptorFailed(process.ExitReason)
-
AcceptorCrashed(Dynamic)
-
SystemError(SocketReason)
Functions
pub fn get_client_info(
conn: Connection(a),
) -> Result(ConnectionInfo, Nil)
Tries to read the IP address and port of a connected client. It will return valid IPv4 or IPv6 addresses, attempting to return the most relevant one for the client.
pub fn get_server_info(
server: Server,
timeout: Int,
) -> Result(ConnectionInfo, CallError(State))
Returns the user-provided port or the OS-assigned value if 0 was provided.
pub fn get_supervisor(server: Server) -> Subject(Message)
Gets the underlying supervisor Subject
from the Server
.
pub fn handler(
on_init: fn(Connection(a)) -> #(b, Option(Selector(a))),
loop: fn(Message(a), b, Connection(a)) -> Next(Message(a), b),
) -> Handler(a, b)
Create a new handler for each connection. The required arguments mirror the
actor.start
API from gleam_otp
. The default pool is 10 accceptor
processes.
pub fn send(
conn: Connection(a),
msg: BytesBuilder,
) -> Result(Nil, SocketReason)
Sends a BytesBuilder message over the socket using the active transport
pub fn serve(
handler: Handler(a, b),
port: Int,
) -> Result(Subject(Message), StartError)
Start the TCP server with the given handler on the provided port
pub fn serve_ssl(
handler: Handler(a, b),
port port: Int,
certfile certfile: String,
keyfile keyfile: String,
) -> Result(Subject(Message), StartError)
Start the SSL server with the given handler on the provided port. The key and cert files must be provided, valid, and readable by the current user.
pub fn start_server(
handler: Handler(a, b),
port: Int,
) -> Result(Server, StartError)
Starts a TCP server and returns the Server
construct. This is useful if
you need access to the port. In the future, it will also allow graceful
shutdown. There may also be other metadata attached to this return value.
pub fn start_ssl_server(
handler: Handler(a, b),
port port: Int,
certfile certfile: String,
keyfile keyfile: String,
) -> Result(Server, StartError)
Starts an SSL server and returns the Server
construct. This is useful if
you need access to the port. In the future, it will also allow graceful
shutdown. There may also be other metadata attached to this return value.
pub fn with_close(
handler: Handler(a, b),
on_close: fn(b) -> Nil,
) -> Handler(a, b)
Adds a function to the handler to be called when the connection is closed.
pub fn with_http2(handler: Handler(a, b)) -> Handler(a, b)
Sets the ALPN supported protocols to include HTTP/2. It’s currently being
exposed only for mist
to provide this support. For a TCP library, you
definitely do not need it.
pub fn with_pool_size(
handler: Handler(a, b),
size: Int,
) -> Handler(a, b)
Modify the size of the acceptor pool