lapine.bend relies on unsafe/foreign

def AMQP.connect_cfg source · line 38 · raw

@+cfg:0xa3e9a274150f1e39ad6bd42f0b13518f/types.Config -> IO(Result<&1, &1, Pair(U32, String), Nat>)

def AMQP.apply_qos source · line 48 · raw

@chan:Nat -> @+cfg:0xa3e9a274150f1e39ad6bd42f0b13518f/types.Config -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Unit>))

def AMQP.recv_map source · line 53 · raw

@got:Pair(Nat, Result<&1, &1, Pair(U32, String), Pair(String, Nat)>) -> @+queue:String -> Pair(Nat, Result<&1, &1, Pair(U32, String), 0xa3e9a274150f1e39ad6bd42f0b13518f/types.Delivery>)

def AMQP.recv source · line 63 · raw

@chan:Nat -> @+queue:String -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), 0xa3e9a274150f1e39ad6bd42f0b13518f/types.Delivery>))

effect AMQP.connect source · line 4 · raw

@host:String -> @port:U32 -> @user:String -> @pass:String -> @vhost:String -> IO(Result<&1, &1, Pair(U32, String), Nat>)

foreign: effs/amqp_connect.c, effs/amqp_connect.js

effect AMQP.channel source · line 9 · raw

@conn:Nat -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Nat>))

foreign: effs/amqp_channel.c, effs/amqp_channel.js

effect AMQP.qos source · line 14 · raw

@chan:Nat -> @prefetch:U32 -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Unit>))

foreign: effs/amqp_qos.c, effs/amqp_qos.js

effect AMQP.consume source · line 19 · raw

@chan:Nat -> @+queue:String -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Pair(String, Nat)>))

foreign: effs/amqp_consume.c, effs/amqp_consume.js

effect AMQP.ack source · line 24 · raw

@chan:Nat -> @tag:Nat -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Unit>))

foreign: effs/amqp_ack.c, effs/amqp_ack.js

effect AMQP.publish source · line 29 · raw

@chan:Nat -> @exchange:String -> @routing_key:String -> @body:String -> IO(Pair(Nat, Result<&1, &1, Pair(U32, String), Unit>))

foreign: effs/amqp_publish.c, effs/amqp_publish.js

effect AMQP.close source · line 34 · raw

@conn:Nat -> IO(Unit)

foreign: effs/amqp_close.c, effs/amqp_close.js