object

Documentation

Index

• type ChunkedReaderWrapper
  • func (wrapper *ChunkedReaderWrapper) Read(p []byte) (n int, err error)
  • func (wrapper *ChunkedReaderWrapper) ReadHeader() (s string, err error)
  • func (wrapper *ChunkedReaderWrapper) ReadHeaderGetChunkSize() (i int, err error)
• type Handler
  • func New(s3Handler *s3_handler.Handler) *Handler
  • func (handler *Handler) CompleteMultiPartHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) CompleteMultiPartParseInput(r *http.Request) (*s3.CompleteMultipartUploadInput, error)
  • func (handler *Handler) CopyHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) CopyParseInput(r *http.Request) (*s3.CopyObjectInput, error)
  • func (handler *Handler) DeleteHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) DeleteParseInput(r *http.Request) (*s3.DeleteObjectInput, error)
  • func (handler *Handler) GetHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) GetParseInput(r *http.Request) (*s3.GetObjectInput, error)
  • func (handler *Handler) HeadHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) HeadParseInput(r *http.Request) (*s3.HeadObjectInput, error)
  • func (handler *Handler) MultiDeleteHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) MultiDeleteParseInput(r *http.Request) (*s3.DeleteObjectsInput, error)
  • func (handler *Handler) MultiPartHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) MultiPartParseInput(r *http.Request) (*s3.CreateMultipartUploadInput, error)
  • func (handler *Handler) PutHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) PutParseInput(r *http.Request) (*s3manager.UploadInput, error)
  • func (handler *Handler) Register(mux *mux.Router)
  • func (handler *Handler) UploadPartHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) UploadPartParseInput(r *http.Request) (*s3.UploadPartInput, error)
• type Object
• type ReaderWrapper
  • func (wrapper ReaderWrapper) Read(p []byte) (n int, err error)
  • func (wrapper ReaderWrapper) Seek(offset int64, whence int) (int64, error)

Types

type ChunkedReaderWrapper

type ChunkedReaderWrapper struct {
	Reader            *io.ReadCloser
	ChunkNextPosition int
	ChunkSize         int
}

func (*ChunkedReaderWrapper) Read

func (wrapper *ChunkedReaderWrapper) Read(p []byte) (n int, err error)

func (*ChunkedReaderWrapper) ReadHeader

func (wrapper *ChunkedReaderWrapper) ReadHeader() (s string, err error)

func (*ChunkedReaderWrapper) ReadHeaderGetChunkSize

func (wrapper *ChunkedReaderWrapper) ReadHeaderGetChunkSize() (i int, err error)

type Handler

type Handler struct {
	*s3_handler.Handler
	// contains filtered or unexported fields
}

func New

func New(s3Handler *s3_handler.Handler) *Handler

func (*Handler) CompleteMultiPartHandle

func (handler *Handler) CompleteMultiPartHandle(writer http.ResponseWriter, request *http.Request)

Handle completing multipart upload

func (*Handler) CompleteMultiPartParseInput

func (handler *Handler) CompleteMultiPartParseInput(r *http.Request) (*s3.CompleteMultipartUploadInput, error)

Parse input for complete multipart upload command

func (*Handler) CopyHandle

func (handler *Handler) CopyHandle(writer http.ResponseWriter, request *http.Request)

Handle copy command

func (*Handler) CopyParseInput

func (handler *Handler) CopyParseInput(r *http.Request) (*s3.CopyObjectInput, error)

Parse input for copy command

func (*Handler) DeleteHandle

func (handler *Handler) DeleteHandle(writer http.ResponseWriter, request *http.Request)

Handle delete operation

func (*Handler) DeleteParseInput

func (handler *Handler) DeleteParseInput(r *http.Request) (*s3.DeleteObjectInput, error)

Parse input for delete

func (*Handler) GetHandle

func (handler *Handler) GetHandle(writer http.ResponseWriter, request *http.Request)

Handle get request

func (*Handler) GetParseInput

func (handler *Handler) GetParseInput(r *http.Request) (*s3.GetObjectInput, error)

Parse request for GET

func (*Handler) HeadHandle

func (handler *Handler) HeadHandle(writer http.ResponseWriter, request *http.Request)

Handle HEAD request

func (*Handler) HeadParseInput

func (handler *Handler) HeadParseInput(r *http.Request) (*s3.HeadObjectInput, error)

Parse input for HEAD request

func (*Handler) MultiDeleteHandle

func (handler *Handler) MultiDeleteHandle(writer http.ResponseWriter, request *http.Request)

Handle request for deleting multiple files

func (*Handler) MultiDeleteParseInput

func (handler *Handler) MultiDeleteParseInput(r *http.Request) (*s3.DeleteObjectsInput, error)

Parse input for multi delete operation

func (*Handler) MultiPartHandle

func (handler *Handler) MultiPartHandle(writer http.ResponseWriter, request *http.Request)

Handle request to create multipart upload

func (*Handler) MultiPartParseInput

func (handler *Handler) MultiPartParseInput(r *http.Request) (*s3.CreateMultipartUploadInput, error)

Parse request for creating a multipart upload

func (*Handler) PutHandle

func (handler *Handler) PutHandle(writer http.ResponseWriter, request *http.Request)

Handle an upload

func (*Handler) PutParseInput

func (handler *Handler) PutParseInput(r *http.Request) (*s3manager.UploadInput, error)

Parse request for upload

func (*Handler) Register

func (handler *Handler) Register(mux *mux.Router)

Register all HTTP handlers

func (*Handler) UploadPartHandle

func (handler *Handler) UploadPartHandle(writer http.ResponseWriter, request *http.Request)

Handle uploading part of a multipart file

func (*Handler) UploadPartParseInput

func (handler *Handler) UploadPartParseInput(r *http.Request) (*s3.UploadPartInput, error)

Parse input for multipart upload

type Object

type Object interface {
	HeadHandle(writer http.ResponseWriter, request *http.Request)
	HeadParseInput(r *http.Request) (*s3.HeadObjectInput, error)
	GetHandle(writer http.ResponseWriter, request *http.Request)
	GetParseInput(r *http.Request) (*s3.GetObjectInput, error)
	PutHandle(writer http.ResponseWriter, request *http.Request)
	PutParseInput(r *http.Request) (*s3manager.UploadInput, error)
	MultiPartHandle(writer http.ResponseWriter, request *http.Request)
	MultiPartParseInput(r *http.Request) (*s3.CreateMultipartUploadInput, error)
	UploadPartHandle(writer http.ResponseWriter, request *http.Request)
	UploadPartParseInput(r *http.Request) (*s3.UploadPartInput, error)
	CompleteMultiPartHandle(writer http.ResponseWriter, request *http.Request)
	CompleteMultiPartParseInput(r *http.Request) (*s3.CompleteMultipartUploadInput, error)
	CopyHandle(writer http.ResponseWriter, request *http.Request)
	CopyParseInput(r *http.Request) (*s3.CopyObjectInput, error)
	DeleteHandle(writer http.ResponseWriter, request *http.Request)
	DeleteParseInput(r *http.Request) (*s3.DeleteObjectInput, error)
	MultiDeleteHandle(writer http.ResponseWriter, request *http.Request)
	MultiDeleteParseInput(r *http.Request) (*s3.DeleteObjectsInput, error)
	New(s3Handler *s3_handler.Handler) Handler
	Register(mux *mux.Router)
}

Interface for object functions

type ReaderWrapper

type ReaderWrapper struct {
	Reader io.ReadCloser
}

func (ReaderWrapper) Read

func (wrapper ReaderWrapper) Read(p []byte) (n int, err error)

func (ReaderWrapper) Seek

func (wrapper ReaderWrapper) Seek(offset int64, whence int) (int64, error)