ls3

package module

Go to main page

Versions in this module

v0

v0.21.1

Dec 29, 2022

Changes in this version

+ var PreAuthenticationIdentity = &Identity

v0.21.0

Dec 29, 2022

Changes in this version

+ var StatRegistry = prometheus.NewRegistry()

+ func ParseAmzTime(text string) (t time.Time, err error)

+ type ServerOptions struct

+ ClientIP security.ClientIP

+ ClientTLS security.ClientTLS

+ Domain string

+ Filesystem BucketFilesystemProvider

+ GlobalPolicy []*PolicyStatement

+ Identity IdentityProvider

+ Log *zap.Logger

+ Signer Signer

v0.20.1

Aug 19, 2022

v0.20.0

Aug 19, 2022

Changes in this version

+ const IdentityUnauthenticatedPublic

+ var AccountProblem = ErrorCode

+ var ErrMissingAccessKeyId = &Error

+ func JoinContext(parent PolicyContextVars, this PolicyContextVars) *joinContext

+ func MatchesConditions(conditions PolicyConditions, context PolicyContextVars) bool

+ func WildcardMatch(rule, obj T) bool

+ type Action string

+ const GetBucketLocation

+ const GetObject

+ const ListAllMyBuckets

+ const ListBucket

+ type ConditionOperator string

+ const Bool

+ const IpAddress

+ const NotIpAddress

+ const StringEquals

+ const StringEqualsIgnoreCase

+ const StringLike

+ const StringNotEquals

+ const StringNotEqualsIgnoreCase

+ const StringNotLike

type Error

+ func EvaluatePolicy(action Action, resource Resource, policies []*PolicyStatement, ...) *Error

+ func (e *Error) Is(target error) bool

+ type FileIdentityProvider struct

+ func NewFileIdentityProvider(log *zap.Logger, path string, cache time.Duration) (*FileIdentityProvider, error)

+ func (fp *FileIdentityProvider) Get(keyId string) (*Identity, error)

+ type Identity struct

+ AccessKeyId string

+ Name string

+ Policy []*PolicyStatement

+ SecretAccessKey string

+ type IdentityProvider interface

+ Get func(keyId string) (*Identity, error)

+ type Keyring map[string]*Identity

+ func (k Keyring) Get(keyId string) (*Identity, error)

+ type ListBucketResult struct

+ CommonPrefixes []CommonPrefixes

+ Contents []Contents

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ Marker string

+ MaxKeys int

+ Name string

+ NextMarker string

+ Prefix string

+ XMLName xml.Name

+ func (r *ListBucketResult) Get(k string) (string, bool)

+ type ListBucketResultV2 struct

+ CommonPrefixes []CommonPrefixes

+ Contents []Contents

+ ContinuationToken string

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ MaxKeys int

+ Name string

+ NextContinuationToken string

+ Prefix string

+ StartAfter string

+ XMLName xml.Name

+ func (r *ListBucketResultV2) Get(k string) (string, bool)

+ type MapContext map[string]string

+ func (ctx MapContext) Get(k string) (string, bool)

+ type MultiIdentityProvider []IdentityProvider

+ func (mp MultiIdentityProvider) Get(keyId string) (*Identity, error)

+ type NullContext struct

+ func (NullContext) Get(_ string) (string, bool)

type Object

+ func (obj *Object) Get(k string) (string, bool)

+ type OptionalList []T

+ func (l *OptionalList[T]) UnmarshalJSON(b []byte) error

+ type PolicyConditions map[ConditionOperator]map[string]OptionalList[string]

+ type PolicyContextVars interface

+ Get func(k string) (string, bool)

+ type PolicyStatement struct

+ Action OptionalList[Action]

+ Condition PolicyConditions

+ Deny bool

+ Resource OptionalList[Resource]

+ func (p *PolicyStatement) AppliesTo(action Action, resource Resource, context PolicyContextVars) bool

type RequestContext

+ Identity *Identity

+ RemoteIP net.IP

+ Secure bool

+ func (ctx *RequestContext) CheckAccess(action Action, resource Resource, vars PolicyContextVars) *Error

+ func (ctx *RequestContext) Get(k string) (string, bool)

+ type Resource string

v0.10.0

Jul 22, 2022

Changes in this version

type Object

+ ContentType string

v0.9.0

Jul 22, 2022

Changes in this version

+ var AuthorizationHeaderMalformed = ErrorCode

+ var InvalidSecurity = ErrorCode

type Authorization

+ func ParseAuthorizationHeader(hdr string) (*Authorization, error)

type Credential

+ Type string

type Object

+ ETag string

type RequestContext

+ Request *http.Request

type SignAWSV4

+ func (s SignAWSV4) VerifyHeaders(r *http.Request) error

+ func (s SignAWSV4) VerifyQuery(r *http.Request) error

v0.8.0

Jul 21, 2022

Changes in this version

+ var MalformedXML = ErrorCode

v0.7.0

Jul 21, 2022

v0.6.0

Jul 21, 2022

Changes in this version

+ type BucketIterator struct

+ Continue string

+ IsTruncated bool

+ func NewBucketIterator(fs fs.FS) *BucketIterator

+ func (it *BucketIterator) CommonPrefixes() (prefixes []CommonPrefixes)

+ func (it *BucketIterator) PrefixScan(prefix string, delimiter string, maxKeys int) ([]Contents, error)

+ func (it *BucketIterator) Seek(after string)

+ type CommonPrefixes struct

+ Prefix string

+ type Contents struct

+ ChecksumAlgorithm string

+ ETag string

+ Key string

+ LastModified time.Time

+ Size int

+ StorageClass string

type Server

+ func (s *Server) ListObjects(ctx *RequestContext) *Error

v0.5.0

Jul 21, 2022

Changes in this version

+ var InternalError = ErrorCode

+ type BucketFilesystemProvider interface

+ ListBuckets func() ([]string, error)

+ Open func(bucket string) (fs.FS, error)

type Server

+ func (s *Server) ListBuckets(ctx *RequestContext) *Error

type SingleBucketFilesystem

+ func (p *SingleBucketFilesystem) ListBuckets() ([]string, error)

+ func (p *SingleBucketFilesystem) Open(_ string) (fs.FS, error)

type SubdirBucketFilesystem

+ func (p *SubdirBucketFilesystem) ListBuckets() ([]string, error)

+ func (p *SubdirBucketFilesystem) Open(bucket string) (fs.FS, error)

v0.4.0

Jul 21, 2022

v0.3.0

Jul 21, 2022

v0.2.0

Jul 21, 2022

Changes in this version

+ var InvalidBucketState = ErrorCode

+ var NoSuchBucket = ErrorCode

+ type BucketLookup func(bucket string) (fs.FS, error)

+ func SingleBucketFilesystem(fileSystem fs.FS) BucketLookup

+ func SubdirBucketFilesystem(base fs.FS) BucketLookup

type RequestContext

+ Filesystem fs.FS

+ type SignAWSV4 struct

+ AccessKeyID string

+ MaxCredentialValidity time.Duration

+ Region string

+ SecretAccessKey string

+ func (s SignAWSV4) Sign(r *http.Request, payload []byte) error

+ func (s SignAWSV4) SigningRegion() string

+ func (s SignAWSV4) Verify(r *http.Request) error

type Signer

+ Sign func(r *http.Request, payload []byte) error

+ SigningRegion func() string

v0.1.0

Jul 21, 2022

Changes in this version

+ var AccessDenied = ErrorCode

+ var BadDigest = ErrorCode

+ var ExpiredToken = ErrorCode

+ var InvalidAccessKeyId = ErrorCode

+ var InvalidArgument = ErrorCode

+ var InvalidBucketName = ErrorCode

+ var InvalidObjectState = ErrorCode

+ var InvalidRange = ErrorCode

+ var InvalidRequest = ErrorCode

+ var InvalidToken = ErrorCode

+ var MethodNotAllowed = ErrorCode

+ var MissingSecurityHeader = ErrorCode

+ var NoSuchKey = ErrorCode

+ var NotImplemented = ErrorCode

+ var SignatureDoesNotMatch = ErrorCode

+ type Authorization struct

+ Credentials Credential

+ Method []byte

+ Signature []byte

+ SignedHeaders []string

+ func ParseAuthorization(hdr []byte) (*Authorization, error)

+ func (a Authorization) AppendFormat(b []byte) []byte

+ type Credential struct

+ AccessKeyID []byte

+ Date time.Time

+ Method []byte

+ Region []byte

+ Service []byte

+ func ParseCredential(value []byte) (*Credential, error)

+ func (c Credential) AppendFormat(b []byte) []byte

+ type ErrInvalidAuthorizationHeader struct

+ func (e *ErrInvalidAuthorizationHeader) Error() string

+ type ErrInvalidCredential struct

+ func (e *ErrInvalidCredential) Error() string

+ type Error struct

+ Message string

+ func ErrorFrom(err error) *Error

+ func (e *Error) Error() string

+ type ErrorCode struct

+ Code string

+ StatusCode int

+ type Method func(ctx *RequestContext) *Error

+ type Object struct

+ LastModified time.Time

+ Range *http_range.Range

+ Size int64

+ type RequestContext struct

+ Bucket string

+ ID uuid.UUID

+ func (ctx *RequestContext) Header() http.Header

+ func (ctx *RequestContext) SendKnownError(err *Error)

+ func (ctx *RequestContext) SendPlain(statusCode int) io.Writer

+ func (ctx *RequestContext) SendXML(statusCode int, payload any)

+ type Server struct

+ func NewServer(log *zap.Logger, signer Signer, filesystem fs.FS, pathStyle bool) *Server

+ func (s *Server) GetBucketLocation(ctx *RequestContext) *Error

+ func (s *Server) GetObject(ctx *RequestContext) *Error

+ func (s *Server) HeadBucket(ctx *RequestContext) *Error

+ func (s *Server) HeadObject(ctx *RequestContext) *Error

+ func (s *Server) ListObjectsV2(ctx *RequestContext) *Error

+ func (s *Server) ServeHTTP(rw http.ResponseWriter, r *http.Request)

+ type Signer struct

+ AccessKeyID string

+ MaxCredentialValidity time.Duration

+ Region string

+ SecretAccessKey string

+ func (s *Signer) CanonicalRequest(r *http.Request, hashedPayload []byte, signedHeaders []string) []byte

+ func (s *Signer) RequestDate(r *http.Request) (time.Time, error)

+ func (s *Signer) SigningKey(at time.Time) []byte

+ func (s *Signer) StringToSign(at time.Time, canonicalRequest []byte) []byte

+ func (s *Signer) Verify(r *http.Request) ([]byte, error)

+ type WrappedError struct

+ Cause error

+ func (e WrappedError) Unwrap() error

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