Xirsys.Sockets.TierSession (xturn_sockets v2.2.0)

View Source

Worker that owns one async pipeline tier's accumulator and handler state.

Started by Engine when a tier uses dispatch: :task or dispatch: :pool. Messages are {:push, payload, meta} casts from the parent connection.

Summary

Functions

child_spec(init_arg)

Temporary child spec so a crashed tier is not restarted in-place.

start_link(opts)

Starts a session for one tier of one connection.

Functions

child_spec(init_arg)

Temporary child spec so a crashed tier is not restarted in-place.

Parameters

start_link(opts)

Starts a session for one tier of one connection.

Parameters

opts is a keyword list:

  • :pipeline - compiled %Pipeline{}
  • :tier_key - tier being isolated
  • :conn - parent Conn
  • :owner - parent connection pid (monitored)
  • :transport - transport module for replies