proxy

package
v0.0.0-...-f111e62 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2017 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL