Documentation ¶
Index ¶
- type OneShotSender
- func (oss *OneShotSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
- func (oss *OneShotSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, ...)
- func (oss *OneShotSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
- type RepeatingAllSender
- func (ras *RepeatingAllSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
- func (ras *RepeatingAllSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, ...)
- func (ras *RepeatingAllSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
- type RepeatingSender
- func (rs *RepeatingSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
- func (rs *RepeatingSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, ...)
- func (rs *RepeatingSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OneShotSender ¶
type OneShotSender struct {
// contains filtered or unexported fields
}
func NewOneShotSender ¶
func NewOneShotSender(logger log.Logger, msg []byte, connPub sconn.ServerConnectionPublisher, recipients ...common.RMId) *OneShotSender
func (*OneShotSender) ConnectedRMs ¶
func (oss *OneShotSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
func (*OneShotSender) ConnectionEstablished ¶
func (oss *OneShotSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, done func())
func (*OneShotSender) ConnectionLost ¶
func (oss *OneShotSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
type RepeatingAllSender ¶
type RepeatingAllSender struct {
// contains filtered or unexported fields
}
func NewRepeatingAllSender ¶
func NewRepeatingAllSender(msg []byte) *RepeatingAllSender
func (*RepeatingAllSender) ConnectedRMs ¶
func (ras *RepeatingAllSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
func (*RepeatingAllSender) ConnectionEstablished ¶
func (ras *RepeatingAllSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, done func())
func (*RepeatingAllSender) ConnectionLost ¶
func (ras *RepeatingAllSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
type RepeatingSender ¶
type RepeatingSender struct {
// contains filtered or unexported fields
}
func NewRepeatingSender ¶
func NewRepeatingSender(msg []byte, recipients ...common.RMId) *RepeatingSender
func (*RepeatingSender) ConnectedRMs ¶
func (rs *RepeatingSender) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)
func (*RepeatingSender) ConnectionEstablished ¶
func (rs *RepeatingSender) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, done func())
func (*RepeatingSender) ConnectionLost ¶
func (rs *RepeatingSender) ConnectionLost(common.RMId, map[common.RMId]sconn.ServerConnection)
Click to show internal directories.
Click to hide internal directories.