msg

package

v0.1.1 Latest Latest Go to latest Published: Aug 14, 2024 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broadcast struct {
	// contains filtered or unexported fields
}

func NewBroadcast[T target.Portal_](
	port target.Port,
	_ *sig.Map[string, T],
) *Broadcast

func (b *Broadcast) BroadcastMsg(ctx context.Context, conn rpc.Conn)

type Client struct {
	// contains filtered or unexported fields
}

func NewClient(port target.Port) (sender *Client)

func (s *Client) Close() (err error)

func (s *Client) Connect(ctx context.Context, portal target.Portal_) (err error)

func (s *Client) Init(reloader Reloader, apphost target.ApphostCache) *Client

func (s *Client) Send(msg target.Msg) (err error)

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler(
	reloader Reloader,
	apphost target.ApphostCache,
) *Handler

func (s *Handler) HandleMsg(ctx context.Context, msg target.Msg)

type Reloader interface {
	Reload() error
}