View Source Envio.Channels (envio v1.0.0)

Channels storage.

It manages all the channels currently existing in the system.

Summary

Returns a specification to start this module under a supervisor.

init(state)

Default initialization callback (noop.)

Registers new channel.

Starts a new channels bucket.

state()

Get list of active subscriptions.

Returns a specification to start this module under a supervisor.

Default initialization callback (noop.)

@spec register(atom() | {atom(), atom()}, [{atom(), Envio.Channel.t()}]) ::
  :ok | {:error, {:already_registered, Envio.Channel.t()}}

Registers new channel.

Starts a new channels bucket.

@spec state() :: Envio.State.t()

Get list of active subscriptions.