broadcast

Documentation

Index

• type BroadcastMessage
• type GroupBroadcast
  • func NewGroupBroadcast() *GroupBroadcast
  • func (gb *GroupBroadcast) BroadcastMessage(message BroadcastMessage)
  • func (gb *GroupBroadcast) ListenMessages(stop <-chan struct{}, buffer uint) <-chan BroadcastMessage
  • func (gb *GroupBroadcast) Start(stop <-chan struct{})

Types

type BroadcastMessage

type BroadcastMessage string

type GroupBroadcast

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

func NewGroupBroadcast

func NewGroupBroadcast() *GroupBroadcast

func (*GroupBroadcast) BroadcastMessage

func (gb *GroupBroadcast) BroadcastMessage(message BroadcastMessage)

func (*GroupBroadcast) ListenMessages

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

func (*GroupBroadcast) Start

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