middleware

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 30, 2018 License: Apache-2.0 Imports: 45 Imported by: 1

Documentation

Index

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
)
View Source 
const (
	DELETE_MARKER_CONTENT_TYPE = "application/x-deleted;swift_versions_deleted=1"
	CLIENT_VERSIONS_LOC        = "X-Versions-Location"
	CLIENT_HISTORY_LOC         = "X-History-Location"
	SYSMETA_VERSIONS_LOC       = "X-Container-Sysmeta-Versions-Location"
	SYSMETA_VERSIONS_MODE      = "X-Container-Sysmeta-Versions-Mode"
)

Variables

View Source 
var S3Subresources = map[string]bool{
	"acl":                          true,
	"delete":                       true,
	"lifecycle":                    true,
	"location":                     true,
	"logging":                      true,
	"notification":                 true,
	"partNumber":                   true,
	"policy":                       true,
	"requestPayment":               true,
	"torrent":                      true,
	"uploads":                      true,
	"uploadId":                     true,
	"versionId":                    true,
	"versioning":                   true,
	"versions":                     true,
	"website":                      true,
	"response-cache-control":       true,
	"response-content-disposition": true,
	"response-content-encoding":    true,
	"response-content-language":    true,
	"response-content-type":        true,
	"response-expires":             true,
	"cors":                         true,
	"tagging":                      true,
	"restore":                      true,
}

Functions

func AuthorizeUnconfirmedIdentity 

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

func BucketAlreadyExistsResponse added in v1.6.0 

func BucketAlreadyExistsResponse(writer http.ResponseWriter, request *http.Request)

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 CopyItems added in v0.0.2 

func CopyItems(dest, src http.Header)

TODO: This seems like it might copy headers it shouldn't. Also, shouldn't it be called copyHeaders instead?

func CopyItemsExclude added in v0.0.2 

func CopyItemsExclude(dest, src http.Header, exclude []string)

func InvalidBucketNameResponse added in v1.6.0 

func InvalidBucketNameResponse(writer http.ResponseWriter, request *http.Request)

func NewAccountQuota added in v1.3.0 

func NewAccountQuota(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewAuthToken 

func NewAuthToken(section conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewBulk added in v0.0.2 

func NewBulk(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewCaptureWriter added in v1.4.0 

func NewCaptureWriter() *captureWriter

func NewCatchError 

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

func NewContainerQuota added in v1.3.0 

func NewContainerQuota(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewContext 

func NewContext(debugResponses bool, mc ring.MemcacheRing, log srv.LowLevelLogger, proxyClientFactory client.ProxyClient) func(http.Handler) http.Handler

func NewCopyMiddleware 

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

func NewCors 

func NewCors(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewCrossDomain added in v1.3.0 

func NewCrossDomain(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewFormPost 

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

func NewHealthcheck 

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

func NewKeystoneAuth 

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

func NewMultirange 

func NewMultirange(config conf.Section, metricsScope tally.Scope) (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, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewRequestLogger 

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

func NewS3Api added in v1.4.0 

func NewS3Api(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewS3Auth added in v1.4.0 

func NewS3Auth(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewS3BucketList added in v1.4.0 

func NewS3BucketList() *s3BucketList

func NewS3Error added in v1.4.0 

func NewS3Error() *s3Error

func NewS3ObjectList added in v1.4.0 

func NewS3ObjectList(ver string) s3ObjectList

func NewStaticWeb 

func NewStaticWeb(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewTempAuth 

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

func NewTempURL 

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

func NewVersionedWrites added in v0.0.2 

func NewVersionedWrites(config conf.Section, metricsScope tally.Scope) (func(http.Handler) http.Handler, error)

func NewXlo 

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

func NoSuchBucketResponse added in v1.6.0 

func NoSuchBucketResponse(writer http.ResponseWriter, request *http.Request)

func ParseACL 

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

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

func PipedGet added in v0.0.2 

func PipedGet(urlStr string, request *http.Request, source string, auth AuthorizeFunc) (io.ReadCloser, http.Header, int)

func Recover 

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

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)

func SignatureDoesNotMatchResponse added in v1.6.0 

func SignatureDoesNotMatchResponse(writer http.ResponseWriter, request *http.Request)

Types

type AccountInfo 

type AccountInfo struct {
	ContainerCount int64
	ObjectCount    int64
	ObjectBytes    int64
	Metadata       map[string]string
	SysMetadata    map[string]string
	StatusCode     int `json:"status"`
}

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 ObjectListingRecord added in v1.6.0 

type ObjectListingRecord struct {
	Name         string `json:"name"`
	LastModified string `json:"last_modified"`
	Size         int64  `json:"bytes"`
	ContentType  string `json:"content_type"`
	ETag         string `json:"hash"`
	Subdir       string `json:"subdir"`
}

type PipeResponseWriter 

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

func NewPipeResponseWriter 

func NewPipeResponseWriter(writer *io.PipeWriter, ready chan struct{}, 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.RequestClient
	Authorize       AuthorizeFunc
	RemoteUsers     []string
	StorageOwner    bool
	ResellerRequest bool
	ACL             string

	Logger *zap.Logger
	TxId   string

	Source string
	S3Auth *S3AuthInfo
	// contains filtered or unexported fields
}

func GetProxyContext 

func GetProxyContext(r *http.Request) *ProxyContext

func (*ProxyContext) AutoCreateAccount 

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

func (*ProxyContext) GetAccountInfo 

func (pc *ProxyContext) GetAccountInfo(ctx context.Context, account string) (*AccountInfo, error)

func (*ProxyContext) InvalidateAccountInfo 

func (pc *ProxyContext) InvalidateAccountInfo(ctx context.Context, account string)

func (*ProxyContext) Response 

func (ctx *ProxyContext) Response() (time.Time, 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)

type S3AuthInfo added in v1.4.0 

type S3AuthInfo struct {
	Key          string
	Signature    string
	StringToSign string
	Account      string
}

type VersionedContainerWriter added in v0.0.2 

type VersionedContainerWriter struct {
	http.ResponseWriter
}

func (*VersionedContainerWriter) WriteHeader added in v0.0.2 

func (vcw *VersionedContainerWriter) WriteHeader(status int)

type VersionedObjectWriter added in v0.0.2 

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

func NewVersionedObjectWriter added in v0.0.2 

func NewVersionedObjectWriter() *VersionedObjectWriter

func (*VersionedObjectWriter) Header added in v0.0.2 

func (vow *VersionedObjectWriter) Header() http.Header

func (*VersionedObjectWriter) Write added in v0.0.2 

func (vow *VersionedObjectWriter) Write(stuff []byte) (int, error)

func (*VersionedObjectWriter) WriteHeader added in v0.0.2 

func (vow *VersionedObjectWriter) WriteHeader(status int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.