middleware

type Direction int

type Middleware interface {
	// Name returns the middleware identifier (e.g., "encrypt", "compress").
	Name() string

	// Direction returns which data paths this middleware participates in.
	Direction() Direction
}

type ReadMiddleware interface {
	// WrapReader wraps a reader on the download path. The info parameter
	// provides metadata about the object being read.
	WrapReader(ctx context.Context, r io.ReadCloser, info *driver.ObjectInfo) (io.ReadCloser, error)
}

type Registration struct {
	// Middleware is the middleware instance.
	Middleware Middleware

	// Scope determines when this middleware is active.
	// When nil, defaults to ScopeGlobal.
	Scope Scope

	// Direction overrides the middleware's own Direction() when non-zero.
	// This allows registering a bidirectional middleware for only reads or writes.
	Direction Direction

	// Priority controls execution order. Lower values run first.
	// Default is 0. Use negative values to run before default priority.
	Priority int
}

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

type Scope interface {
	// Match returns true if the middleware should be active.
	Match(ctx context.Context, bucket, key string) bool

	// String returns a human-readable description for debugging.
	String() string
}

type ScopeAnd struct {
	Scopes []Scope
}

type ScopeBucket struct {
	Buckets []string
}

type ScopeContentType struct {
	Types []string
}

type ScopeFunc struct {
	Fn   func(ctx context.Context, bucket, key string) bool
	Desc string
}

type ScopeGlobal struct{}

type ScopeKeyPattern struct {
	Patterns []string
}

type ScopeNot struct {
	Inner Scope
}

type ScopeOr struct {
	Scopes []Scope
}

type WriteMiddleware interface {
	// WrapWriter wraps a writer on the upload path. The key parameter
	// identifies the object being written.
	WrapWriter(ctx context.Context, w io.WriteCloser, key string) (io.WriteCloser, error)
}