rooms

Documentation

Index

• Variables
• type AttendantEventPublisher
• type AttendantsGetter
• type MetadataGetter
• type PeerRPCAdapter
  • func NewPeerRPCAdapter(logger logging.Logger) *PeerRPCAdapter
  • func (a *PeerRPCAdapter) GetAttendants(ctx context.Context, peer transport.Peer) (<-chan RoomAttendantsEvent, error)
  • func (a *PeerRPCAdapter) GetMetadata(ctx context.Context, peer transport.Peer) (messages.RoomMetadataResponse, error)
• type RoomAttendantsEvent
  • func MustNewRoomAttendantsEvent(typ RoomAttendantsEventType, id refs.Identity) RoomAttendantsEvent
  • func NewRoomAttendantsEvent(typ RoomAttendantsEventType, id refs.Identity) (RoomAttendantsEvent, error)
  • func (e RoomAttendantsEvent) Id() refs.Identity
  • func (e RoomAttendantsEvent) IsZero() bool
  • func (e RoomAttendantsEvent) Typ() RoomAttendantsEventType
• type RoomAttendantsEventType
  • func NewRoomAttendantsEventTypeFromRoomAttendantsReponseType(v messages.RoomAttendantsResponseType) (RoomAttendantsEventType, error)
  • func (t RoomAttendantsEventType) IsZero() bool
• type Scanner
  • func NewScanner(metadataGetter MetadataGetter, attendantsGetter AttendantsGetter, ...) *Scanner
  • func (s Scanner) Run(ctx context.Context, peer transport.Peer) error

Variables

var (
	RoomAttendantsEventTypeJoined = RoomAttendantsEventType{"joined"}
	RoomAttendantsEventTypeLeft   = RoomAttendantsEventType{"left"}
)

Types

type AttendantEventPublisher

type AttendantEventPublisher interface {
	PublishAttendantEvent(ctx context.Context, portal transport.Peer, event RoomAttendantsEvent) error
}

type AttendantsGetter

type AttendantsGetter interface {
	GetAttendants(ctx context.Context, peer transport.Peer) (<-chan RoomAttendantsEvent, error)
}

type MetadataGetter

type MetadataGetter interface {
	GetMetadata(ctx context.Context, peer transport.Peer) (messages.RoomMetadataResponse, error)
}

type PeerRPCAdapter

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

func NewPeerRPCAdapter

func NewPeerRPCAdapter(logger logging.Logger) *PeerRPCAdapter

func (*PeerRPCAdapter) GetAttendants

func (a *PeerRPCAdapter) GetAttendants(ctx context.Context, peer transport.Peer) (<-chan RoomAttendantsEvent, error)

func (*PeerRPCAdapter) GetMetadata

func (a *PeerRPCAdapter) GetMetadata(ctx context.Context, peer transport.Peer) (messages.RoomMetadataResponse, error)

type RoomAttendantsEvent

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

func MustNewRoomAttendantsEvent

func MustNewRoomAttendantsEvent(typ RoomAttendantsEventType, id refs.Identity) RoomAttendantsEvent

func NewRoomAttendantsEvent

func NewRoomAttendantsEvent(typ RoomAttendantsEventType, id refs.Identity) (RoomAttendantsEvent, error)

func (RoomAttendantsEvent) Id

func (e RoomAttendantsEvent) Id() refs.Identity

func (RoomAttendantsEvent) IsZero

func (e RoomAttendantsEvent) IsZero() bool

func (RoomAttendantsEvent) Typ

func (e RoomAttendantsEvent) Typ() RoomAttendantsEventType

type RoomAttendantsEventType

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

func NewRoomAttendantsEventTypeFromRoomAttendantsReponseType

func NewRoomAttendantsEventTypeFromRoomAttendantsReponseType(v messages.RoomAttendantsResponseType) (RoomAttendantsEventType, error)

func (RoomAttendantsEventType) IsZero

func (t RoomAttendantsEventType) IsZero() bool

type Scanner

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

func NewScanner

func NewScanner(
	metadataGetter MetadataGetter,
	attendantsGetter AttendantsGetter,
	publisher AttendantEventPublisher,
	logger logging.Logger,
) *Scanner

func (Scanner) Run

func (s Scanner) Run(ctx context.Context, peer transport.Peer) error