sse

package module

v0.0.0-...-4baa293 Latest Latest Go to latest Published: Oct 19, 2018 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrStreamerStopped = errors.New("this streamer stopped")
)

This section is empty.

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

func (c *Client) GetConnectionID() ID

func (c *Client) GetUserKey() string

type ID [16]byte

type Options struct {
	NoXAccelBuffering  bool
	SendChanBufferSize uint
	UserAuthenticator  UserAuthenticator
}

func NewDefaultOptions() Options

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

Streamer SSE Streamer

func NewStreamer(options Options) *Streamer

func (s *Streamer) Broadcast(event string, data string) error

func (s *Streamer) BroadcastJson(event string, data interface{}) error

func (s *Streamer) ConnectionCount() int

func (s *Streamer) Dispatcher(client *Client, rw http.ResponseWriter, r *http.Request)

func (s *Streamer) Multicast(event string, data string, users []string) error

func (s *Streamer) MulticastJson(event string, data interface{}, users []string) error

func (s *Streamer) NewClient(userKey string) (*Client, error)

func (s *Streamer) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (s *Streamer) SetHTTPHeaders(rw http.ResponseWriter)

func (s *Streamer) Start()

func (s *Streamer) Stop()

func (s *Streamer) Unicast(event string, data string, clientID ID) error

func (s *Streamer) UnicastJson(event string, data interface{}, clientID ID) error

type UserAuthenticator func(r *http.Request) (userKey string, err error)