roomstate

Documentation

Index

• type Manager
  • func NewManager(log kitlog.Logger) *Manager
  • func (m *Manager) AddEndpoint(who refs.FeedRef, edp muxrpc.Endpoint)
  • func (m *Manager) AlreadyAdded(who refs.FeedRef, edp muxrpc.Endpoint) bool
  • func (m *Manager) Has(who refs.FeedRef) (muxrpc.Endpoint, bool)
  • func (m *Manager) List() []string
  • func (m *Manager) ListAsRefs() []refs.FeedRef
  • func (m *Manager) RegisterAttendantsUpdates(sink broadcasts.AttendantsEmitter)
  • func (m *Manager) RegisterLegacyEndpoints(sink broadcasts.EndpointsEmitter)
  • func (m *Manager) Remove(who refs.FeedRef)

Types

type Manager

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

func NewManager

func NewManager(log kitlog.Logger) *Manager

func (*Manager) AddEndpoint

func (m *Manager) AddEndpoint(who refs.FeedRef, edp muxrpc.Endpoint)

AddEndpoint adds the endpoint to the room

func (*Manager) AlreadyAdded

func (m *Manager) AlreadyAdded(who refs.FeedRef, edp muxrpc.Endpoint) bool

AlreadyAdded returns true if the peer was already added to the room. if it isn't it will be added.

func (*Manager) Has

func (m *Manager) Has(who refs.FeedRef) (muxrpc.Endpoint, bool)

Has returns true and the endpoint if the peer is in the room

func (*Manager) List

func (m *Manager) List() []string

List just returns a list of feed references as strings

func (*Manager) ListAsRefs

func (m *Manager) ListAsRefs() []refs.FeedRef

func (*Manager) RegisterAttendantsUpdates

func (m *Manager) RegisterAttendantsUpdates(sink broadcasts.AttendantsEmitter)

func (*Manager) RegisterLegacyEndpoints

func (m *Manager) RegisterLegacyEndpoints(sink broadcasts.EndpointsEmitter)

func (*Manager) Remove

func (m *Manager) Remove(who refs.FeedRef)

Remove removes the peer from the room