server

Documentation

Overview

Package server implements rest server handling "jump" requests and optionally updating stats service

Index

• type LogRecord
• type Picker
• type RLBServer
  • func NewRLBServer(nodePicker Picker, emsg, statsURL string, port int, version string) *RLBServer
  • func (s *RLBServer) DoJump(w http.ResponseWriter, r *http.Request)
  • func (s *RLBServer) Run()
  • func (s *RLBServer) Shutdown()

Types

type LogRecord

type LogRecord struct {
	ID       string    `json:"id,omitempty"`
	FromIP   string    `json:"from_ip"`
	TS       time.Time `json:"ts,omitempty"`
	FileName string    `json:"file_name"`
	Service  string    `json:"service"`
	DestHost string    `json:"dest"`
	Referer  string    `json:"referer"`
}

LogRecord for stats

type Picker

type Picker interface {
	Pick(svc string, resource string) (resURL string, node picker.Node, err error)
	Nodes() map[string][]picker.Node
	Status() (bool, []string)
}

Picker defines pick method to return final redirect url from service and resource

type RLBServer

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

RLBServer - main rlb server

func NewRLBServer

func NewRLBServer(nodePicker Picker, emsg, statsURL string, port int, version string) *RLBServer

NewRLBServer makes a new rlb server for map of services

func (*RLBServer) DoJump

func (s *RLBServer) DoJump(w http.ResponseWriter, r *http.Request)

DoJump - jump to alive server for svc, url = Query("url")

func (*RLBServer) Run

func (s *RLBServer) Run()

Run activates alive updater and web server

func (*RLBServer) Shutdown

func (s *RLBServer) Shutdown()

Shutdown rlb http server