proxy

Documentation

Index

• Variables
• func LoadConfig(configFile string) (*models.Config, error)
• func LoadConfigString(config string) (*models.Config, error)
• func RunDaemon(listener bool, workerCt int)
• type Reason
• type Server
  • func NewServer(ctx *models.ServerCtx) (*Server, error)
  • func (m *Server) Run()
  • func (m *Server) RunListeners()
  • func (m *Server) Shutdown(reason Reason)

Variables

var Conf *models.Config

Global Access to Config

Functions

func LoadConfig

func LoadConfig(configFile string) (*models.Config, error)

LoadConfig from @configFile (read from disk?) also available is a

func LoadConfigString

func LoadConfigString(config string) (*models.Config, error)

LoadConfigString from @config data confl format

func RunDaemon

func RunDaemon(listener bool, workerCt int)

Start a DataUX Service, can be either worker, listener, both

@listener  true/false   do we run the listeneners (mysql)?
            if not then this is a worker only node
@workerct  over-ride # of workers

Types

type Reason

type Reason struct {
	Reason string

	Message string
	// contains filtered or unexported fields
}

Reason info on internal events

type Server

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

Server is the main DataUX server, the running process and responsible for:

1. starting *listeners* - network transports/protocols (mysql,mongo,redis)
2. routing requests through *Handlers*(plugins) which filter, transform, log, etc
3. connecting front-end requests to the execution/planning engine

func NewServer

func NewServer(ctx *models.ServerCtx) (*Server, error)

func (*Server) Run

func (m *Server) Run()

Run the listeners

func (*Server) RunListeners

func (m *Server) RunListeners()

RunListeners a blocking runner, that starts [mysql,?] tcp listeners and returns if connection to listeners cannot be established

func (*Server) Shutdown

func (m *Server) Shutdown(reason Reason)

Shutdown listeners and close down