middleware

package

v0.0.1 Latest Latest Go to latest Published: Jul 7, 2017 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gholt/hummingbird

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AuthorizeUnconfirmedIdentity(r *http.Request, obj string, referrers []string, roles []string) (bool, error)
func CleanACL(name string, value string) (string, error)
func NewAuthToken(config conf.Section) (func(http.Handler) http.Handler, error)
func NewCatchError(config conf.Section) (func(http.Handler) http.Handler, error)
func NewContext(mc ring.MemcacheRing, log srv.LowLevelLogger, ...) func(http.Handler) http.Handler
func NewCopyMiddleware(config conf.Section) (func(http.Handler) http.Handler, error)
func NewCors(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 NewKeystoneAuth(config conf.Section) (func(http.Handler) http.Handler, error)
func NewMultirange(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 NewStaticWeb(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 NewXlo(config conf.Section) (func(http.Handler) http.Handler, error)
func ParseACL(acl string) ([]string, []string)
func Recover(w http.ResponseWriter, r *http.Request, msg string)
func ReferrerAllowed(referrer string, referrerACL []string) bool
func RegisterInfo(name string, data interface{})
func RemoveItemsWithPrefix(header http.Header, prefix string)
type AccountInfo
type AuthorizeFunc
type CopyWriter
- 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) AutoCreateAccount(account string, headers http.Header)
- func (ctx *ProxyContext) GetAccountInfo(account string) (*AccountInfo, error)
- func (ctx *ProxyContext) InvalidateAccountInfo(account string)
- func (ctx *ProxyContext) Response() (bool, int)
type ProxyContextMiddleware
- func (m *ProxyContextMiddleware) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Constants ¶

View Source

const (
	FP_INVALID = iota
	FP_ERROR
	FP_EXPIRED
	FP_SCOPE_ACCOUNT
	FP_SCOPE_CONTAINER
)

View Source

const (
	SCOPE_INVALID = iota
	SCOPE_ACCOUNT
	SCOPE_CONTAINER
)

Variables ¶

This section is empty.

Functions ¶

func AuthorizeUnconfirmedIdentity ¶

func AuthorizeUnconfirmedIdentity(r *http.Request, obj string, referrers []string, roles []string) (bool, error)

func CleanACL ¶

func CleanACL(name string, value string) (string, error)

Returns a cleaned ACL header value, validating that it meets the formatting requirements for standard Hummingbird ACL strings.

func NewAuthToken ¶

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

func NewCatchError ¶

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

func NewContext ¶

func NewContext(mc ring.MemcacheRing, log srv.LowLevelLogger, proxyDirectClient *client.ProxyDirectClient) func(http.Handler) http.Handler

func NewCopyMiddleware ¶

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

func NewCors ¶

func NewCors(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 NewKeystoneAuth ¶

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

func NewMultirange ¶

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

NewMultirange returns an instance of the multirange middleware with the given config.

This middleware intercepts object GET requests with multiple ranges in the Range header and turns them into separate single-range requests on the backend, combining them into a multipart response. This should simplify the implementation of things like xLO and the object server.

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 NewStaticWeb ¶

func NewStaticWeb(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 NewXlo ¶

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

func ParseACL ¶

func ParseACL(acl string) ([]string, []string)

Parses a standard Hummingbird ACL string into a referrers list and groups list.

func Recover ¶

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

func ReferrerAllowed ¶

func ReferrerAllowed(referrer string, referrerACL []string) bool

Returns True if the referrer should be allowed based on the referrerACL list

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, int)

type CopyWriter ¶

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

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 (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
	RemoteUsers  []string
	StorageOwner bool
	ACL          string

	Logger srv.LowLevelLogger
	TxId   string

	Source string
	// contains filtered or unexported fields
}

func GetProxyContext ¶

func GetProxyContext(r *http.Request) *ProxyContext

func (*ProxyContext) AutoCreateAccount ¶

func (ctx *ProxyContext) AutoCreateAccount(account string, headers http.Header)

func (*ProxyContext) GetAccountInfo ¶

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

func (*ProxyContext) InvalidateAccountInfo ¶

func (ctx *ProxyContext) InvalidateAccountInfo(account string)

func (*ProxyContext) Response ¶

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

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)

Source Files ¶

View all Source files

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