room

package

v0.0.0-...-7695c73 Latest Latest Go to latest Published: Jun 25, 2015 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/feedlabs/elasticfeed

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func InitSessionManager()
func NewChannelEvent(ep model.EventType, user, msg string) model.Event
func NewEntryEvent(ep model.EventType, user, msg string) model.Event
func NewEvent(ep model.EventType, user, msg string) model.Event
func NewFeedEvent(ep model.EventType, user, msg string) model.Event
func NewSocketEvent(msg []byte, ws *websocket.Conn, ch chan []byte) model.SocketEvent
func NewSystemEvent(ep model.EventType, user, msg string) model.Event
type FeedRoomManager
- func NewFeedRoomManager() *FeedRoomManager
type Subscriber
type Subscription

Constants ¶

View Source

const (
	CHANNEL_JOIN    = 0
	CHANNEL_LEAVE   = 1
	CHANNEL_MESSAGE = 2

	SYSTEM_FEED_MESSAGE = 1

	FEED_RELOAD        = 1
	FEED_EMPTY         = 2
	FEED_ENTRY_NEW     = 3
	FEED_ENTRY_INIT    = 4
	FEED_ENTRY_MORE    = 5
	FEED_HIDE          = 6
	FEED_SHOW          = 7
	FEED_ENTRY_MESSAGE = 8

	ENTRY_UPDATE = 1
	ENTRY_DELETE = 2
	ENTRY_SHOW   = 3
	ENTRY_HIDE   = 4
)

Variables ¶

This section is empty.

Functions ¶

func InitSessionManager ¶

func InitSessionManager()

func NewChannelEvent ¶

func NewChannelEvent(ep model.EventType, user, msg string) model.Event

func NewEntryEvent ¶

func NewEntryEvent(ep model.EventType, user, msg string) model.Event

func NewEvent ¶

func NewEvent(ep model.EventType, user, msg string) model.Event

func NewFeedEvent ¶

func NewFeedEvent(ep model.EventType, user, msg string) model.Event

func NewSocketEvent ¶

func NewSocketEvent(msg []byte, ws *websocket.Conn, ch chan []byte) model.SocketEvent

func NewSystemEvent ¶

func NewSystemEvent(ep model.EventType, user, msg string) model.Event

Types ¶

type FeedRoomManager ¶

type FeedRoomManager struct {
	Subscribe   chan Subscriber
	Unsubscribe chan string
	Publish     chan model.Event

	ResourceEvent chan model.SocketEvent

	WaitingList *list.List
	Subscribers *list.List
}

var (
	FeedRoom       *FeedRoomManager
	GlobalSessions *session.Manager
)

func NewFeedRoomManager ¶

func NewFeedRoomManager() *FeedRoomManager

func (*FeedRoomManager) BroadcastWebSocket ¶

func (this *FeedRoomManager) BroadcastWebSocket(event model.Event)

func (*FeedRoomManager) Join ¶

func (this *FeedRoomManager) Join(user string, ws *websocket.Conn)

func (*FeedRoomManager) Leave ¶

func (this *FeedRoomManager) Leave(user string)

func (*FeedRoomManager) Run ¶

func (this *FeedRoomManager) Run()

type Subscriber ¶

type Subscriber struct {
	Name string
	Conn *websocket.Conn
}

type Subscription ¶

type Subscription struct {
	Archive []model.Event
	New     <-chan model.Event
}

Source Files ¶

View all Source files

feed.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL