m3server

Documentation

Index

• Variables
• func GenerateTextFilesEnv(env m3util.QsmEnvironment)
• func GetEnvId(r *http.Request) m3util.QsmEnvID
• func GetEnvironment(r *http.Request) *m3db.QsmDbEnvironment
• func GetTrioConnType(conns [6]m3point.Point) string
• func GetTrioTableCsv(ppd *pointdb.ServerPointPackData) [][]string
• func GetTrioTransitionTableCsv() [][]string
• func GetTrioTransitionTableTxt(ppd *pointdb.ServerPointPackData) map[Int2][7]string
• func ReadRequestMsg(w http.ResponseWriter, r *http.Request, reqMsg proto.Message) bool
• func SendResponse(w http.ResponseWriter, status int, format string, args ...interface{})
• func WriteResponseMsg(w http.ResponseWriter, r *http.Request, resMsg proto.Message)
• type Int2
• type NodeToMsgBuilder
  • func (n *NodeToMsgBuilder) VisitNode(node m3space.SpaceTimeNodeIfc)
• type QsmApp
  • func MakeApp(envId m3util.QsmEnvID) *QsmApp
  • func (app *QsmApp) AddHandler(path string, handleFunc func(http.ResponseWriter, *http.Request)) *mux.Route

Variables

var Log = m3util.NewLogger("m3server", m3util.INFO)

Functions

func GenerateTextFilesEnv

func GenerateTextFilesEnv(env m3util.QsmEnvironment)

func GetEnvId

func GetEnvId(r *http.Request) m3util.QsmEnvID

func GetEnvironment

func GetEnvironment(r *http.Request) *m3db.QsmDbEnvironment

func GetTrioConnType

func GetTrioConnType(conns [6]m3point.Point) string

Return the kind of connection between 2 trios depending of the distance square values A3 => All connections have a DS of 3 A5 => All connections have a DS of 5 X135 => All DS present 1, 3 and 5 G13 => 1 and 3 are present but no DS 5 (The type we use)

func GetTrioTableCsv

func GetTrioTableCsv(ppd *pointdb.ServerPointPackData) [][]string

func GetTrioTransitionTableCsv

func GetTrioTransitionTableCsv() [][]string

func GetTrioTransitionTableTxt

func GetTrioTransitionTableTxt(ppd *pointdb.ServerPointPackData) map[Int2][7]string

func ReadRequestMsg

func ReadRequestMsg(w http.ResponseWriter, r *http.Request, reqMsg proto.Message) bool

func SendResponse

func SendResponse(w http.ResponseWriter, status int, format string, args ...interface{})

func WriteResponseMsg

func WriteResponseMsg(w http.ResponseWriter, r *http.Request, resMsg proto.Message)

Types

type Int2

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

type NodeToMsgBuilder

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

func (*NodeToMsgBuilder) VisitNode

func (n *NodeToMsgBuilder) VisitNode(node m3space.SpaceTimeNodeIfc)

type QsmApp

type QsmApp struct {
	HttpServerDone *sync.WaitGroup
	Server         *http.Server
	Router         *mux.Router
	Env            *m3db.QsmDbEnvironment
}

func MakeApp

func MakeApp(envId m3util.QsmEnvID) *QsmApp

func (*QsmApp) AddHandler

func (app *QsmApp) AddHandler(path string, handleFunc func(http.ResponseWriter, *http.Request)) *mux.Route