server

Documentation

Index

• Constants
• Variables
• func GetCommandsHandler(w http.ResponseWriter, r *http.Request)
• func GetEvents(w http.ResponseWriter, r *http.Request)
• func GetHandler(w http.ResponseWriter, r *http.Request)
• func GetStreamsHandler(w http.ResponseWriter, r *http.Request)
• func IsWebSocket(r *http.Request) bool
• func NewStreamHandler(w http.ResponseWriter, r *http.Request)
• func PostCommandHandler(w http.ResponseWriter, r *http.Request)
• func PostHandler(w http.ResponseWriter, r *http.Request)
• func Random(i int) string
• func Run()
• func ServeWebSocket(w http.ResponseWriter, r *http.Request, o *Observer)
• func SetHeaders(w http.ResponseWriter, r *http.Request)
• func WithCors(h http.Handler) http.Handler
• type Message
  • func NewCommand(prompt, stream string) *Message
  • func NewEvent(text, stream string) *Message
  • func NewMessage(text, stream string) *Message
• type Metadata
  • func GetMetadata(uri string) *Metadata
• type Observer
  • func NewObserver(stream string) *Observer
• type Server
  • func New() *Server
  • func (s *Server) Broadcast(message *Message)
  • func (s *Server) List() map[string]*Stream
  • func (s *Server) Metadata(t *Message)
  • func (s *Server) New(stream, secret string, private bool, ttl int) error
  • func (s *Server) Observe(o *Observer)
  • func (s *Server) Retrieve(message string, streem string, direction, last, limit int64) []*Message
  • func (s *Server) Run()
  • func (s *Server) Store(message *Message)
• type Stream
  • func NewStream(id, secret string, private bool, ttl int) *Stream

Constants

const (
	MaxMessageSize = 1024
	MaxMessages    = 1024
	StreamTTL      = time.Duration(1024) * time.Second
)

Variables

var Default = New()

Functions

func GetCommandsHandler

func GetCommandsHandler(w http.ResponseWriter, r *http.Request)

func GetEvents

func GetEvents(w http.ResponseWriter, r *http.Request)

func GetHandler

func GetHandler(w http.ResponseWriter, r *http.Request)

func GetStreamsHandler

func GetStreamsHandler(w http.ResponseWriter, r *http.Request)

func IsWebSocket

func IsWebSocket(r *http.Request) bool

check if the request is for websockets

func NewStreamHandler

func NewStreamHandler(w http.ResponseWriter, r *http.Request)

func PostCommandHandler

func PostCommandHandler(w http.ResponseWriter, r *http.Request)

func PostHandler

func PostHandler(w http.ResponseWriter, r *http.Request)

func Random

func Random(i int) string

random generate i length alphanum string

func Run

func Run()

func ServeWebSocket

func ServeWebSocket(w http.ResponseWriter, r *http.Request, o *Observer)

serve an actual websocket

func SetHeaders

func SetHeaders(w http.ResponseWriter, r *http.Request)

func WithCors

func WithCors(h http.Handler) http.Handler

Types

type Message

type Message struct {
	Id       string
	Text     string
	Type     string
	Created  int64 `json:",string"`
	Stream   string
	Metadata *Metadata
}

func NewCommand

func NewCommand(prompt, stream string) *Message

func NewEvent

func NewEvent(text, stream string) *Message

func NewMessage

func NewMessage(text, stream string) *Message

type Metadata

type Metadata struct {
	Created     int64
	Title       string
	Description string
	Type        string
	Image       string
	Url         string
	Site        string
}

func GetMetadata

func GetMetadata(uri string) *Metadata

type Observer

type Observer struct {
	Id     string
	Stream string
	Events chan *Message
	Kill   chan bool
}

func NewObserver

func NewObserver(stream string) *Observer

type Server

type Server struct {
	Created int64
	Events  chan *Message
	// contains filtered or unexported fields
}

func New

func New() *Server

func (*Server) Broadcast

func (s *Server) Broadcast(message *Message)

func (*Server) List

func (s *Server) List() map[string]*Stream

func (*Server) Metadata

func (s *Server) Metadata(t *Message)

func (*Server) New

func (s *Server) New(stream, secret string, private bool, ttl int) error

func (*Server) Observe

func (s *Server) Observe(o *Observer)

func (*Server) Retrieve

func (s *Server) Retrieve(message string, streem string, direction, last, limit int64) []*Message

func (*Server) Run

func (s *Server) Run()

func (*Server) Store

func (s *Server) Store(message *Message)

type Stream

type Stream struct {
	// A unique id
	Id string
	// A secret for access
	Secret string
	// Messages in the stream
	Messages []*Message
	// not listed
	Private bool
	// In nanoseconds
	Updated int64
	// In seconds
	TTL int64
	// stream observers
	Observers int64
}

func NewStream

func NewStream(id, secret string, private bool, ttl int) *Stream