Anoma.Node.Transport.IntraNode behaviour (Anoma v0.34.0)

Summary

Callbacks

call(arg1, map)

I send a call message to a remote node over the wire, and expect a response back.

cast(arg1, map)

I cast a message to a remote node over the wire, and do not expect a result back.

publish(arg1, t, t)

I send an event across the wire to another node, and do not expect a result back.

Callbacks

call(arg1, map)

@callback call(
  Anoma.Node.Transport.NetworkRegister.Advert.GRPCAddress.t()
  | Anoma.Node.Transport.NetworkRegister.Advert.TCPAddress.t(),
  map()
) :: {:ok, term()}

I send a call message to a remote node over the wire, and expect a response back.

cast(arg1, map)

@callback cast(
  Anoma.Node.Transport.NetworkRegister.Advert.GRPCAddress.t()
  | Anoma.Node.Transport.NetworkRegister.Advert.TCPAddress.t(),
  map()
) :: :ok

I cast a message to a remote node over the wire, and do not expect a result back.

publish(arg1, t, t)

@callback publish(
  Anoma.Node.Transport.NetworkRegister.Advert.GRPCAddress.t()
  | Anoma.Node.Transport.NetworkRegister.Advert.TCPAddress.t(),
  String.t(),
  EventBroker.Event.t()
) :: :ok

I send an event across the wire to another node, and do not expect a result back.