Versions in this module Expand all Collapse all v0 v0.0.4 Nov 11, 2023 v0.0.3 Sep 25, 2023 Changes in this version + func Listen(ctx context.Context, database string, listenAddr string) error + type Broadcast struct + func NewBroadcast[T any]() *Broadcast[T] + func (b *Broadcast[T]) Close() + func (b *Broadcast[T]) Send(msg T) + func (b *Broadcast[T]) Subscribe() <-chan T + func (b *Broadcast[T]) Unsubscribe(ch <-chan T) + type Mux struct + func (m *Mux) HandleConn(ctx context.Context, clientNetConn net.Conn) error + type MuxClientConn struct + func NewMuxClientConn(conn net.Conn) *MuxClientConn + type MuxCommand struct + Database string + ListenAddr string + func NewMuxCommand() *MuxCommand + func (*MuxCommand) SetupCommand(cmd *cli.Command) + func (cmd *MuxCommand) Run(ctx context.Context) error + type MuxServerConn struct + func NewMuxServerConn(conn *pgconn.HijackedConn) *MuxServerConn
Go to main page