broadcast

Documentation

Index

• type GroupBroadcast
  • func NewGroupBroadcast() *GroupBroadcast
  • func (gb *GroupBroadcast) BroadcastMessage(message Message)
  • func (gb *GroupBroadcast) BroadcastMessageTimeout(message Message, timeout time.Duration) bool
  • func (gb *GroupBroadcast) ListenMessages(stop <-chan struct{}, buffer uint) <-chan Message
  • func (gb *GroupBroadcast) Start(stop <-chan struct{})
• type Message

Types

type GroupBroadcast

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

func NewGroupBroadcast

func NewGroupBroadcast() *GroupBroadcast

func (*GroupBroadcast) BroadcastMessage

func (gb *GroupBroadcast) BroadcastMessage(message Message)

func (*GroupBroadcast) BroadcastMessageTimeout

func (gb *GroupBroadcast) BroadcastMessageTimeout(message Message, timeout time.Duration) bool

func (*GroupBroadcast) ListenMessages

func (gb *GroupBroadcast) ListenMessages(stop <-chan struct{}, buffer uint) <-chan Message

func (*GroupBroadcast) Start

func (gb *GroupBroadcast) Start(stop <-chan struct{})

type Message

type Message string