server

Documentation

Overview

Package server provides network listeners, e.g. an HTTP (web/REST/JSON) server.

Index

• func DefaultAction(ctx *b.Context, spec m.Map, msg *b.Message, rsp http.ResponseWriter, ...)
• func DoneHandler(ctx *b.Context) (loop bool)
• func GetSid(hdrp *http.Header) (sid string)
• func LoginAction(ctx *b.Context, spec m.Map, msg *b.Message, rsp http.ResponseWriter, ...)
• func PollAction(ctx *b.Context, spec m.Map, pollmsg *b.Message, rsp http.ResponseWriter, ...)
• func Route(ctx *b.Context, rsp http.ResponseWriter, req *http.Request)
• func SetSid(hdr *http.Header, sid string)
• func StartServer(ctx *b.Context)
• func SyncAction(ctx *b.Context, spec m.Map, msg *b.Message, rsp http.ResponseWriter, ...)
• type RqActionHandler
  • func GetActionHandler(ctx *b.Context, spec m.Map, msg *b.Message) RqActionHandler
• type ServerState
  • func (st *ServerState) GetSessionMailbox(sid string) chan b.Message
• type Session
• type Sessions
  • func (s *Sessions) Get(ctx *b.Context, sid string) *Session

Functions

func DefaultAction

func DefaultAction(ctx *b.Context, spec m.Map, msg *b.Message,
	rsp http.ResponseWriter, s *Session)

func DoneHandler

func DoneHandler(ctx *b.Context) (loop bool)

func GetSid

func GetSid(hdrp *http.Header) (sid string)

func LoginAction

func LoginAction(ctx *b.Context, spec m.Map, msg *b.Message,
	rsp http.ResponseWriter, s *Session)

func PollAction

func PollAction(ctx *b.Context, spec m.Map, pollmsg *b.Message,
	rsp http.ResponseWriter, s *Session)

func Route

func Route(ctx *b.Context, rsp http.ResponseWriter, req *http.Request)

func SetSid

func SetSid(hdr *http.Header, sid string)

func StartServer

func StartServer(ctx *b.Context)

func SyncAction

func SyncAction(ctx *b.Context, spec m.Map, msg *b.Message,
	rsp http.ResponseWriter, s *Session)

Types

type RqActionHandler

type RqActionHandler = func(
	*b.Context, m.Map, *b.Message, http.ResponseWriter, *Session)

func GetActionHandler

func GetActionHandler(ctx *b.Context, spec m.Map, msg *b.Message) RqActionHandler

type ServerState

type ServerState struct {
	Server   *http.Server
	Sessions *Sessions
}

func (*ServerState) GetSessionMailbox

func (st *ServerState) GetSessionMailbox(sid string) chan b.Message

type Session

type Session struct {
	Mailbox   chan b.Message
	SessionId string
}

type Sessions

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

func (*Sessions) Get

func (s *Sessions) Get(ctx *b.Context, sid string) *Session