http

Documentation

Index

• Constants
• Variables
• func NewClient(address string, opts ...ClientOpt) cmds.Executor
• func NewHandler(env cmds.Environment, root *cmds.Command, cfg *ServerConfig) http.Handler
• type ClientOpt
  • func ClientWithAPIPrefix(apiPrefix string) ClientOpt
  • func ClientWithFallback(exe cmds.Executor) ClientOpt
  • func ClientWithHTTPClient(hc *http.Client) ClientOpt
  • func ClientWithUserAgent(ua string) ClientOpt
• type Response
  • func (res *Response) Error() *cmds.Error
  • func (res *Response) Length() uint64
  • func (res *Response) Next() (interface{}, error)
  • func (res *Response) Request() *cmds.Request
• type ResponseEmitter
  • func NewFlushForwarder(r cmds.ResponseEmitter, f http.Flusher) ResponseEmitter
  • func NewResponseEmitter(w http.ResponseWriter, method string, req *cmds.Request, ...) (ResponseEmitter, error)
• type ResponseEmitterOption
• type ServerConfig
  • func NewServerConfig() *ServerConfig
  • func (cfg *ServerConfig) AllowedMethods() []string
  • func (cfg *ServerConfig) AllowedOrigins() []string
  • func (cfg *ServerConfig) AppendAllowedOrigins(origins ...string)
  • func (cfg *ServerConfig) SetAllowCredentials(flag bool)
  • func (cfg *ServerConfig) SetAllowedMethods(methods ...string)
  • func (cfg *ServerConfig) SetAllowedOrigins(origins ...string)

Constants

const (
	ACAOrigin      = "Access-Control-Allow-Origin"
	ACAMethods     = "Access-Control-Allow-Methods"
	ACACredentials = "Access-Control-Allow-Credentials"
)

const (
	ApiUrlFormat = "%s%s/%s?%s"
)

const (
	StreamErrHeader = "X-Stream-Error"
)

Variables

var (
	HeadRequest = fmt.Errorf("HEAD request")

	AllowedExposedHeadersArr = []string{streamHeader, channelHeader, extraContentLengthHeader}
	AllowedExposedHeaders    = strings.Join(AllowedExposedHeadersArr, ", ")
)

var (
	ErrNotFound = errors.New("404 page not found")
)

var (
	MIMEEncodings = map[string]cmds.EncodingType{
		"application/json": cmds.JSON,
		"application/xml":  cmds.XML,
		"text/plain":       cmds.Text,
	}
)

var OptionSkipMap = map[string]bool{
	"api": true,
}

Functions

func NewClient

func NewClient(address string, opts ...ClientOpt) cmds.Executor

NewClient constructs a new HTTP-backed command executor.

func NewHandler

func NewHandler(env cmds.Environment, root *cmds.Command, cfg *ServerConfig) http.Handler

Types

type ClientOpt

type ClientOpt func(*client)

ClientOpt is an option that can be passed to the HTTP client constructor.

func ClientWithAPIPrefix

func ClientWithAPIPrefix(apiPrefix string) ClientOpt

ClientWithAPIPrefix specifies an API URL prefix.

func ClientWithFallback

func ClientWithFallback(exe cmds.Executor) ClientOpt

ClientWithFallback adds a fallback executor to the client.

Note: This may run the PreRun function twice.

func ClientWithHTTPClient

func ClientWithHTTPClient(hc *http.Client) ClientOpt

ClientWithHTTPClient specifies a custom http.Client. Defaults to http.DefaultClient.

func ClientWithUserAgent

func ClientWithUserAgent(ua string) ClientOpt

ClientWithUserAgent specifies the HTTP user agent for the client.

type Response

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

func (*Response) Error

func (res *Response) Error() *cmds.Error

func (*Response) Length

func (res *Response) Length() uint64

func (*Response) Next

func (res *Response) Next() (interface{}, error)

func (*Response) Request

func (res *Response) Request() *cmds.Request

type ResponseEmitter

type ResponseEmitter interface {
	cmds.ResponseEmitter
	http.Flusher
}

func NewFlushForwarder

func NewFlushForwarder(r cmds.ResponseEmitter, f http.Flusher) ResponseEmitter

func NewResponseEmitter

func NewResponseEmitter(w http.ResponseWriter, method string, req *cmds.Request, opts ...ResponseEmitterOption) (ResponseEmitter, error)

NewResponeEmitter returns a new ResponseEmitter.

type ResponseEmitterOption

type ResponseEmitterOption func(*responseEmitter)

ResponseEmitterOption is the type describing options to the NewResponseEmitter function.

type ServerConfig

type ServerConfig struct {
	// APIPath is the prefix of all request paths.
	// Example: host:port/api/v0/add. Here the APIPath is /api/v0
	APIPath string

	// Headers is an optional map of headers that is written out.
	Headers map[string][]string
	// contains filtered or unexported fields
}

func NewServerConfig

func NewServerConfig() *ServerConfig

func (*ServerConfig) AllowedMethods

func (cfg *ServerConfig) AllowedMethods() []string

func (*ServerConfig) AllowedOrigins

func (cfg *ServerConfig) AllowedOrigins() []string

func (*ServerConfig) AppendAllowedOrigins

func (cfg *ServerConfig) AppendAllowedOrigins(origins ...string)

func (*ServerConfig) SetAllowCredentials

func (cfg *ServerConfig) SetAllowCredentials(flag bool)

func (*ServerConfig) SetAllowedMethods

func (cfg *ServerConfig) SetAllowedMethods(methods ...string)

func (*ServerConfig) SetAllowedOrigins

func (cfg *ServerConfig) SetAllowedOrigins(origins ...string)