signal

README

This package is not being used right now. However, it could be planned to server as and abstraction layer between current used solution and AreYouIN.

Documentation

Index

• Variables
• type Broadcast
  • func NewBroadcast() *Broadcast
  • func (bc *Broadcast) Close()
  • func (bc *Broadcast) Join() *Listener
  • func (bc *Broadcast) Send(signal *Signal)
• type Listener
  • func (l *Listener) Leave()
  • func (l *Listener) Recv() (*Signal, error)
• type Signal

Variables

var (
	ErrListenerClosed = errors.New("listener closed")
)

Types

type Broadcast

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

func NewBroadcast

func NewBroadcast() *Broadcast

func (*Broadcast) Close

func (bc *Broadcast) Close()

func (*Broadcast) Join

func (bc *Broadcast) Join() *Listener

func (*Broadcast) Send

func (bc *Broadcast) Send(signal *Signal)

type Listener

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

A listener must be used only from a goroutine.

func (*Listener) Leave

func (l *Listener) Leave()

Can be called from another thread

func (*Listener) Recv

func (l *Listener) Recv() (*Signal, error)

Must be called from the same goroutine over all the lifecycle of the listener

type Signal

type Signal struct {
	Key  string
	Data interface{}
}