fastcgi

Documentation

Index

• Constants
• type Config
• type FCGIClient
  • func Dial(network, address string) (fcgi *FCGIClient, err error)
  • func DialContext(ctx context.Context, network, address string) (fcgi *FCGIClient, err error)
  • func DialWithDialerContext(ctx context.Context, network, address string, dialer net.Dialer) (fcgi *FCGIClient, err error)
  • func (c *FCGIClient) Close()
  • func (c *FCGIClient) Do(p map[string]string, req io.Reader) (r io.Reader, err error)
  • func (c *FCGIClient) Get(p map[string]string, body io.Reader, l int64) (resp *http.Response, err error)
  • func (c *FCGIClient) Head(p map[string]string) (resp *http.Response, err error)
  • func (c *FCGIClient) Options(p map[string]string) (resp *http.Response, err error)
  • func (c *FCGIClient) Post(p map[string]string, method string, bodyType string, body io.Reader, l int64) (resp *http.Response, err error)
  • func (c *FCGIClient) PostFile(p map[string]string, data url.Values, file map[string]string) (resp *http.Response, err error)
  • func (c *FCGIClient) PostForm(p map[string]string, data url.Values) (resp *http.Response, err error)
  • func (c *FCGIClient) Request(p map[string]string, req io.Reader) (resp *http.Response, err error)
  • func (c *FCGIClient) SetReadTimeout(t time.Duration) error
  • func (c *FCGIClient) SetSendTimeout(t time.Duration) error
• type Handler
  • func NewHandler(rule *Rule, cfg *Config, next fasthttp.RequestHandler) (*Handler, error)
  • func (h *Handler) Serve(reqCtx *fasthttp.RequestCtx)
• type Rule
  • func (r *Rule) DoReplace(ctx *fasthttp.RequestCtx, tmplName string) (string, error)
  • func (r *Rule) ReplaceVariable(ctx *fasthttp.RequestCtx, w io.Writer, tag string) (int, error)
• type UpstreamGetter
  • func NewRoundRobinUpstream(upstream super.Upstream) (UpstreamGetter, error)

Constants

const (
	// BeginRequest is the begin request flag.
	BeginRequest uint8 = iota + 1
	// AbortRequest is the abort request flag.
	AbortRequest
	// EndRequest is the end request flag.
	EndRequest
	// Params is the parameters flag.
	Params
	// Stdin is the standard input flag.
	Stdin
	// Stdout is the standard output flag.
	Stdout
	// Stderr is the standard error flag.
	Stderr
	// Data is the data flag.
	Data
	// GetValues is the get values flag.
	GetValues
	// GetValuesResult is the get values result flag.
	GetValuesResult
	// UnknownType is the unknown type flag.
	UnknownType
	// MaxType is the maximum type flag.
	MaxType = UnknownType
)

const (
	// Responder is the responder flag.
	Responder uint8 = iota + 1
	// Authorizer is the authorizer flag.
	Authorizer
	// Filter is the filter flag.
	Filter
)

const (
	// RequestComplete is the completed request flag.
	RequestComplete uint8 = iota
	// CantMultiplexConns is the multiplexed connections flag.
	CantMultiplexConns
	// Overloaded is the overloaded flag.
	Overloaded
	// UnknownRole is the unknown role flag.
	UnknownRole
)

const (
	// MaxConns is the maximum connections flag.
	MaxConns string = "MAX_CONNS"
	// MaxRequests is the maximum requests flag.
	MaxRequests string = "MAX_REQS"
	// MultiplexConns is the multiplex connections flag.
	MultiplexConns string = "MPXS_CONNS"
)

const FCGIHeaderLen uint8 = 8

FCGIHeaderLen describes header length.

const FCGIKeepConn uint8 = 1

FCGIKeepConn describes keep connection mode.

const FCGIListenSockFileno uint8 = 0

FCGIListenSockFileno describes listen socket file number.

const FCGINullRequestID uint8 = 0

FCGINullRequestID describes the null request ID.

const Version1 uint8 = 1

Version1 describes the version.

Types

type Config

type Config struct {
	Debug       bool
	KeepConn    bool
	ReadTimeout time.Duration
	SendTimeout time.Duration
	Upstream    super.Upstream
}

type FCGIClient

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

FCGIClient implements a FastCGI client, which is a standard for interfacing external applications with Web servers.

func Dial

func Dial(network, address string) (fcgi *FCGIClient, err error)

Dial connects to the fcgi responder at the specified network address, using default net.Dialer. See func net.Dial for a description of the network and address parameters.

func DialContext

func DialContext(ctx context.Context, network, address string) (fcgi *FCGIClient, err error)

DialContext is like Dial but passes ctx to dialer.Dial.

func DialWithDialerContext

func DialWithDialerContext(ctx context.Context, network, address string, dialer net.Dialer) (fcgi *FCGIClient, err error)

DialWithDialerContext connects to the fcgi responder at the specified network address, using custom net.Dialer and a context. See func net.Dial for a description of the network and address parameters.

func (*FCGIClient) Close

func (c *FCGIClient) Close()

Close closes fcgi connection

func (*FCGIClient) Do

func (c *FCGIClient) Do(p map[string]string, req io.Reader) (r io.Reader, err error)

Do made the request and returns a io.Reader that translates the data read from fcgi responder out of fcgi packet before returning it.

func (*FCGIClient) Get

func (c *FCGIClient) Get(p map[string]string, body io.Reader, l int64) (resp *http.Response, err error)

Get issues a GET request to the fcgi responder.

func (*FCGIClient) Head

func (c *FCGIClient) Head(p map[string]string) (resp *http.Response, err error)

Head issues a HEAD request to the fcgi responder.

func (*FCGIClient) Options

func (c *FCGIClient) Options(p map[string]string) (resp *http.Response, err error)

Options issues an OPTIONS request to the fcgi responder.

func (*FCGIClient) Post

func (c *FCGIClient) Post(p map[string]string, method string, bodyType string, body io.Reader, l int64) (resp *http.Response, err error)

Post issues a POST request to the fcgi responder. with request body in the format that bodyType specified

func (*FCGIClient) PostFile

func (c *FCGIClient) PostFile(p map[string]string, data url.Values, file map[string]string) (resp *http.Response, err error)

PostFile issues a POST to the fcgi responder in multipart(RFC 2046) standard, with form as a string key to a list values (url.Values), and/or with file as a string key to a list file path.

func (*FCGIClient) PostForm

func (c *FCGIClient) PostForm(p map[string]string, data url.Values) (resp *http.Response, err error)

PostForm issues a POST to the fcgi responder, with form as a string key to a list values (url.Values)

func (*FCGIClient) Request

func (c *FCGIClient) Request(p map[string]string, req io.Reader) (resp *http.Response, err error)

Request returns a HTTP Response with Header and Body from fcgi responder

func (*FCGIClient) SetReadTimeout

func (c *FCGIClient) SetReadTimeout(t time.Duration) error

SetReadTimeout sets the read timeout for future calls that read from the fcgi responder. A zero value for t means no timeout will be set.

func (*FCGIClient) SetSendTimeout

func (c *FCGIClient) SetSendTimeout(t time.Duration) error

SetSendTimeout sets the read timeout for future calls that send data to the fcgi responder. A zero value for t means no timeout will be set.

type Handler

type Handler struct {
	Debug       bool
	KeepConn    bool
	ReadTimeout time.Duration
	SendTimeout time.Duration

	Next fasthttp.RequestHandler
	UpstreamGetter
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(rule *Rule, cfg *Config, next fasthttp.RequestHandler) (*Handler, error)

func (*Handler) Serve

func (h *Handler) Serve(reqCtx *fasthttp.RequestCtx)

type Rule

type Rule struct {
	Root           string
	Index          string
	SplitPathInfo  *regexp.Regexp
	CatchStderr    string
	Params         map[string]string
	ServerSoftware string
	ServerName     string
	// contains filtered or unexported fields
}

func (*Rule) DoReplace

func (r *Rule) DoReplace(ctx *fasthttp.RequestCtx, tmplName string) (string, error)

func (*Rule) ReplaceVariable

func (r *Rule) ReplaceVariable(ctx *fasthttp.RequestCtx, w io.Writer, tag string) (int, error)

type UpstreamGetter

type UpstreamGetter interface {
	GetAddress() (network string, address string)
}

func NewRoundRobinUpstream

func NewRoundRobinUpstream(upstream super.Upstream) (UpstreamGetter, error)