middleware

Documentation

Index

• Constants
• func NewCatchError(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewContext(mc ring.MemcacheRing, log srv.LowLevelLogger, policyList conf.PolicyList, ...) func(http.Handler) http.Handler
• func NewCopyMiddleware(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewFormPost(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewHealthcheck(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewRatelimiter(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewRequestLogger(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewTempAuth(config conf.Section) (func(http.Handler) http.Handler, error)
• func NewTempURL(config conf.Section) (func(http.Handler) http.Handler, error)
• func Recover(w http.ResponseWriter, r *http.Request, msg string)
• func RegisterInfo(name string, data interface{})
• func RemoveItemsWithPrefix(header http.Header, prefix string)
• type AccountInfo
• type AuthorizeFunc
• type CopyWriter
  • func (cw *CopyWriter) Header() http.Header
  • func (cw *CopyWriter) Write(stuff []byte) (int, error)
  • func (cw *CopyWriter) WriteHeader(status int)
• type PipeResponseWriter
  • func NewPipeResponseWriter(writer *io.PipeWriter, done chan bool, logger srv.LowLevelLogger) *PipeResponseWriter
  • func (w *PipeResponseWriter) Close()
  • func (w *PipeResponseWriter) Header() http.Header
  • func (w *PipeResponseWriter) Write(stuff []byte) (int, error)
  • func (w *PipeResponseWriter) WriteHeader(status int)
• type ProxyContext
  • func GetProxyContext(r *http.Request) *ProxyContext
  • func (ctx *ProxyContext) DefaultPolicyIndex() int
  • func (ctx *ProxyContext) GetAccountInfo(account string) *AccountInfo
  • func (ctx *ProxyContext) GetContainerInfo(account, container string) *client.ContainerInfo
  • func (ctx *ProxyContext) HTTPClient() *http.Client
  • func (ctx *ProxyContext) InvalidateAccountInfo(account string)
  • func (ctx *ProxyContext) InvalidateContainerInfo(account, container string)
  • func (ctx *ProxyContext) NewSubRequest(request *http.Request, method string, url string, body io.Reader) (*http.Request, error)
  • func (ctx *ProxyContext) PolicyByName(name string) *conf.Policy
  • func (ctx *ProxyContext) Response() (bool, int)
  • func (ctx *ProxyContext) Subrequest(method, path string, body io.Reader, writer http.ResponseWriter) (*http.Request, error)
• type ProxyContextMiddleware
  • func (m *ProxyContextMiddleware) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Constants

const (
	FP_INVALID = iota
	FP_ERROR
	FP_EXPIRED
	FP_SCOPE_ACCOUNT
	FP_SCOPE_CONTAINER
)

const (
	SCOPE_INVALID = iota
	SCOPE_ACCOUNT
	SCOPE_CONTAINER
)

Functions

func NewCatchError

func NewCatchError(config conf.Section) (func(http.Handler) http.Handler, error)

func NewContext

func NewContext(mc ring.MemcacheRing, log srv.LowLevelLogger, policyList conf.PolicyList, httpClient *http.Client) func(http.Handler) http.Handler

func NewCopyMiddleware

func NewCopyMiddleware(config conf.Section) (func(http.Handler) http.Handler, error)

func NewFormPost

func NewFormPost(config conf.Section) (func(http.Handler) http.Handler, error)

func NewHealthcheck

func NewHealthcheck(config conf.Section) (func(http.Handler) http.Handler, error)

func NewRatelimiter

func NewRatelimiter(config conf.Section) (func(http.Handler) http.Handler, error)

func NewRequestLogger

func NewRequestLogger(config conf.Section) (func(http.Handler) http.Handler, error)

func NewTempAuth

func NewTempAuth(config conf.Section) (func(http.Handler) http.Handler, error)

func NewTempURL

func NewTempURL(config conf.Section) (func(http.Handler) http.Handler, error)

func Recover

func Recover(w http.ResponseWriter, r *http.Request, msg string)

func RegisterInfo

func RegisterInfo(name string, data interface{})

func RemoveItemsWithPrefix

func RemoveItemsWithPrefix(header http.Header, prefix string)

Types

type AccountInfo

type AccountInfo struct {
	ContainerCount int64
	ObjectCount    int64
	ObjectBytes    int64
	Metadata       map[string]string
	SysMetadata    map[string]string
}

type AuthorizeFunc

type AuthorizeFunc func(r *http.Request) bool

type CopyWriter

type CopyWriter struct {
	Logger srv.LowLevelLogger
	// contains filtered or unexported fields
}

func (*CopyWriter) Header

func (cw *CopyWriter) Header() http.Header

func (*CopyWriter) Write

func (cw *CopyWriter) Write(stuff []byte) (int, error)

func (*CopyWriter) WriteHeader

func (cw *CopyWriter) WriteHeader(status int)

type PipeResponseWriter

type PipeResponseWriter struct {
	Logger srv.LowLevelLogger
	// contains filtered or unexported fields
}

func NewPipeResponseWriter

func NewPipeResponseWriter(writer *io.PipeWriter, done chan bool, logger srv.LowLevelLogger) *PipeResponseWriter

func (*PipeResponseWriter) Close

func (w *PipeResponseWriter) Close()

func (*PipeResponseWriter) Header

func (w *PipeResponseWriter) Header() http.Header

func (*PipeResponseWriter) Write

func (w *PipeResponseWriter) Write(stuff []byte) (int, error)

func (*PipeResponseWriter) WriteHeader

func (w *PipeResponseWriter) WriteHeader(status int)

type ProxyContext

type ProxyContext struct {
	*ProxyContextMiddleware
	C         client.ProxyClient
	Authorize AuthorizeFunc
	Logger    srv.LowLevelLogger
	// contains filtered or unexported fields
}

func GetProxyContext

func GetProxyContext(r *http.Request) *ProxyContext

func (*ProxyContext) DefaultPolicyIndex

func (ctx *ProxyContext) DefaultPolicyIndex() int

func (*ProxyContext) GetAccountInfo

func (ctx *ProxyContext) GetAccountInfo(account string) *AccountInfo

func (*ProxyContext) GetContainerInfo

func (ctx *ProxyContext) GetContainerInfo(account, container string) *client.ContainerInfo

func (*ProxyContext) HTTPClient

func (ctx *ProxyContext) HTTPClient() *http.Client

func (*ProxyContext) InvalidateAccountInfo

func (ctx *ProxyContext) InvalidateAccountInfo(account string)

func (*ProxyContext) InvalidateContainerInfo

func (ctx *ProxyContext) InvalidateContainerInfo(account, container string)

func (*ProxyContext) NewSubRequest

func (ctx *ProxyContext) NewSubRequest(request *http.Request, method string, url string, body io.Reader) (*http.Request, error)

func (*ProxyContext) PolicyByName

func (ctx *ProxyContext) PolicyByName(name string) *conf.Policy

func (*ProxyContext) Response

func (ctx *ProxyContext) Response() (bool, int)

func (*ProxyContext) Subrequest

func (ctx *ProxyContext) Subrequest(method, path string, body io.Reader, writer http.ResponseWriter) (*http.Request, error)

type ProxyContextMiddleware

type ProxyContextMiddleware struct {
	Cache ring.MemcacheRing
	// contains filtered or unexported fields
}

func (*ProxyContextMiddleware) ServeHTTP

func (m *ProxyContextMiddleware) ServeHTTP(writer http.ResponseWriter, request *http.Request)