Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgConnection ¶
type MsgConnection struct{}
func (*MsgConnection) RecvAndReply ¶
func (m *MsgConnection) RecvAndReply(handler fabric.Handler)
func (*MsgConnection) SendAndRecv ¶
func (m *MsgConnection) SendAndRecv(msg any, receiver fabric.Receiver) error
type Nats ¶
type Nats struct {
// contains filtered or unexported fields
}
type ReplayConnection ¶
type ReplayConnection struct {
// contains filtered or unexported fields
}
ReplayConnection is a connection for pub/sub/replay
func (*ReplayConnection) Publish ¶
func (b *ReplayConnection) Publish(msg any) error
Publish publishes a message to a broadcast channel
Click to show internal directories.
Click to hide internal directories.