handler

Sep 23, 2025

Changes in this version

type Config

+ MaxResponseAttributeSize func() uint64

Jul 18, 2025

Changes in this version

type Config

+ CORSContainerID func() *cid.ID

May 30, 2025

Changes in this version

+ var ErrContainerNotFound = errors.New("container not found")

+ var ErrEmptyBrowsePage = errors.New("empty browse page")

+ var ErrObjectNotFound = errors.New("object not found")

+ var ErrQuotaLimitReached = errors.New("quota limit reached")

+ func ResponseError(r *fasthttp.RequestCtx, msg string, code int)

type AppParams

+ CORSCache *cache.CORSCache

+ CORSCnrID cid.ID

type Config

+ ArchiveCompression func() bool

+ CORS func() *data.CORSRule

+ CORSContainerSet func() bool

+ EnableFilepathSlashFallback func() bool

+ FormContainerZone func(string) string

+ type ContainerContract interface

+ GetContainerByID func(cid.ID) (*container.Container, error)

type Handler

+ func (h *Handler) DownloadTar(req *fasthttp.RequestCtx)

+ func (h *Handler) DownloadZip(req *fasthttp.RequestCtx)

+ func (h *Handler) Preflight(req *fasthttp.RequestCtx)

+ func (h *Handler) SetCORSHeaders(req *fasthttp.RequestCtx)

+ type ListFunc func(ctx context.Context, bucketInfo *data.BucketInfo, prefix string) (*GetObjectsResponse, error)

+ type Middleware struct

+ Enabled bool

+ Func MiddlewareFunc

+ type MiddlewareFunc func(param MiddlewareParam) bool

+ type MiddlewareParam struct

+ BktInfo *data.BucketInfo

+ Context context.Context

+ Path string

+ Request *fasthttp.RequestCtx

+ type ObjectHandlerFunc func(context.Context, *fasthttp.RequestCtx, oid.Address)

type TestFrostFS

+ func (t *TestFrostFS) GetContainerByID(cid cid.ID) (*container.Container, error)

+ func (t *TestFrostFS) SetObject(addr oid.Address, obj *object.Object)

Dec 20, 2024

Changes in this version

type Config

+ EnableFilepathFallback func() bool

type ResponseObject

+ IsDeleteMarker bool

Nov 20, 2024

Changes in this version

+ type BrowsePageData struct

+ Container string

+ HasErrors bool

+ Objects []ResponseObject

+ Prefix string

+ Protocol string

type Config

+ IndexPageEnabled func() bool

+ IndexPageTemplate func() string

+ type GetObjectsResponse struct

+ type ResponseObject struct

+ Created string

+ FileName string

+ FilePath string

+ GetURL string

+ IsDir bool

+ OID string

+ Size string

+ type ResponseObjectExtended struct

+ Error error

+ Object ResponseObject

Oct 18, 2024

Changes in this version

type FrostFS

+ GetObject func(context.Context, PrmObjectGet) (*Object, error)

+ HeadObject func(context.Context, PrmObjectHead) (*object.Object, error)

+ InitMultiObjectReader func(ctx context.Context, p PrmInitMultiObjectReader) (io.Reader, error)

+ RangeObject func(context.Context, PrmObjectRange) (io.ReadCloser, error)

+ type Object struct

+ Header object.Object

+ Payload io.ReadCloser

+ type PrmInitMultiObjectReader struct

+ Addr oid.Address

+ Bearer *bearer.Token

+ Ln uint64

+ Off uint64

+ type PrmObjectGet struct

+ Address oid.Address

+ type PrmObjectHead struct

+ Address oid.Address

+ type PrmObjectRange struct

+ Address oid.Address

+ PayloadRange [2]uint64

type TestFrostFS

+ func (t *TestFrostFS) GetObject(_ context.Context, prm PrmObjectGet) (*Object, error)

+ func (t *TestFrostFS) HeadObject(_ context.Context, prm PrmObjectHead) (*object.Object, error)

+ func (t *TestFrostFS) InitMultiObjectReader(context.Context, PrmInitMultiObjectReader) (io.Reader, error)

+ func (t *TestFrostFS) RangeObject(_ context.Context, prm PrmObjectRange) (io.ReadCloser, error)

Jul 22, 2024

Changes in this version

+ var ErrAccessDenied = errors.New("access denied")

+ var ErrGatewayTimeout = errors.New("gateway timeout")

+ type AppParams struct

+ Cache *cache.BucketCache

+ FrostFS FrostFS

+ Logger *zap.Logger

+ Owner *user.ID

+ Resolver ContainerResolver

+ type ContainerResolver interface

+ Resolve func(ctx context.Context, name string) (*cid.ID, error)

+ type FrostFS interface

+ Container func(context.Context, PrmContainer) (*container.Container, error)

+ CreateObject func(context.Context, PrmObjectCreate) (oid.ID, error)

+ ReadObject func(context.Context, PrmObjectRead) (*ObjectPart, error)

+ SearchObjects func(context.Context, PrmObjectSearch) (ResObjectSearch, error)

+ type ObjectPart struct

+ Head *object.Object

+ Payload io.ReadCloser

+ type PrmAuth struct

+ BearerToken *bearer.Token

+ type PrmContainer struct

+ ContainerID cid.ID

+ type PrmObjectCreate struct

+ BufferMaxSize uint64

+ ClientCut bool

+ Object *object.Object

+ Payload io.Reader

+ WithoutHomomorphicHash bool

+ type PrmObjectRead struct

+ Address oid.Address

+ PayloadRange [2]uint64

+ type PrmObjectSearch struct

+ Container cid.ID

+ Filters object.SearchFilters

+ type ResObjectSearch interface

+ Close func()

+ Iterate func(f func(oid.ID) bool) error

+ Read func(buf []oid.ID) (int, error)

+ type TestFrostFS struct

+ func NewTestFrostFS(key *keys.PrivateKey) *TestFrostFS

+ func (t *TestFrostFS) AllowUserOperation(cnrID cid.ID, userID user.ID, op acl.Op, objID oid.ID)

+ func (t *TestFrostFS) Container(_ context.Context, prm PrmContainer) (*container.Container, error)

+ func (t *TestFrostFS) ContainerID(name string) (*cid.ID, error)

+ func (t *TestFrostFS) CreateObject(_ context.Context, prm PrmObjectCreate) (oid.ID, error)

+ func (t *TestFrostFS) GetEpochDurations(context.Context) (*utils.EpochDurations, error)

+ func (t *TestFrostFS) ReadObject(_ context.Context, prm PrmObjectRead) (*ObjectPart, error)

+ func (t *TestFrostFS) SearchObjects(_ context.Context, prm PrmObjectSearch) (ResObjectSearch, error)

+ func (t *TestFrostFS) SetContainer(cnrID cid.ID, cnr *container.Container)

May 27, 2024

Changes in this version

+ type Config interface

+ BufferMaxSizeForPut func() uint64

+ ClientCut func() bool

+ DefaultTimestamp func() bool

+ NamespaceHeader func() string

+ ZipCompression func() bool

Dec 7, 2023

Changes in this version

+ type Handler struct

+ func New(params *utils.AppParams, settings *Settings, tree *tree.Tree) *Handler

+ func (h *Handler) DownloadByAddressOrBucketName(c *fasthttp.RequestCtx)

+ func (h *Handler) DownloadByAttribute(c *fasthttp.RequestCtx)

+ func (h *Handler) DownloadZipped(c *fasthttp.RequestCtx)

+ func (h *Handler) HeadByAddressOrBucketName(c *fasthttp.RequestCtx)

+ func (h *Handler) HeadByAttribute(c *fasthttp.RequestCtx)

+ func (h *Handler) Upload(req *fasthttp.RequestCtx)

+ type MultipartFile interface

+ FileName func() string

+ type Settings struct

+ func (s *Settings) DefaultTimestamp() bool

+ func (s *Settings) SetDefaultTimestamp(val bool)

+ func (s *Settings) SetZipCompression(val bool)

+ func (s *Settings) ZipCompression() bool