ssemux

Documentation

Index

• Constants
• type Event
  • func NewCloseEvent() *Event
• type MultiAssoc
  • func NewMultiAssoc() *MultiAssoc
  • func (ma *MultiAssoc) Associate(key string, assocKey string, syncStream *SyncStream)
  • func (ma *MultiAssoc) Disassociate(key string, assocKey string)
  • func (ma *MultiAssoc) Event(assocKey string, event *Event)
• type Store
  • func NewStore() *Store
  • func (s *Store) Associate(key string, assoc string, assocKey string) error
  • func (s *Store) Event(assoc string, assocKey string, event *Event)
  • func (s *Store) New(key string) *Stream
• type Stream
  • func NewStream(key string, closedCh chan string) *Stream
  • func (s *Stream) Handle(w http.ResponseWriter)
• type SyncStream
  • func NewSyncStream(key string, stream *Stream) *SyncStream
  • func (ss *SyncStream) Associate(multiAssoc *MultiAssoc, assocKey string)
  • func (ss *SyncStream) Disassociate()
  • func (ss *SyncStream) Event(event *Event)
  • func (ss *SyncStream) Reset(stream *Stream)

Constants

const CLOSED_CH_BUFFER = 16

const CLOSE_EVENT_FLAG = 0x1

const EVENT_CH_BUFFER = 16

const HEARTBEAT_INTERVAL = time.Second * 15

Types

type Event

type Event struct {
	// SSE fields
	Comment string
	Id      string
	Event   string
	Data    string
	// sender source to exclude from dissemination
	Source string
	// internal flags
	Flag int
}

func NewCloseEvent

func NewCloseEvent() *Event

type MultiAssoc

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

func NewMultiAssoc

func NewMultiAssoc() *MultiAssoc

func (*MultiAssoc) Associate

func (ma *MultiAssoc) Associate(key string, assocKey string, syncStream *SyncStream)

func (*MultiAssoc) Disassociate

func (ma *MultiAssoc) Disassociate(key string, assocKey string)

func (*MultiAssoc) Event

func (ma *MultiAssoc) Event(assocKey string, event *Event)

type Store

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

func NewStore

func NewStore() *Store

func (*Store) Associate

func (s *Store) Associate(key string, assoc string, assocKey string) error

func (*Store) Event

func (s *Store) Event(assoc string, assocKey string, event *Event)

func (*Store) New

func (s *Store) New(key string) *Stream

type Stream

type Stream struct {
	EventCh chan *Event
	ResetCh chan bool
	// contains filtered or unexported fields
}

func NewStream

func NewStream(key string, closedCh chan string) *Stream

func (*Stream) Handle

func (s *Stream) Handle(w http.ResponseWriter)

type SyncStream

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

func NewSyncStream

func NewSyncStream(key string, stream *Stream) *SyncStream

func (*SyncStream) Associate

func (ss *SyncStream) Associate(multiAssoc *MultiAssoc, assocKey string)

func (*SyncStream) Disassociate

func (ss *SyncStream) Disassociate()

func (*SyncStream) Event

func (ss *SyncStream) Event(event *Event)

func (*SyncStream) Reset

func (ss *SyncStream) Reset(stream *Stream)