server

Documentation

Index

• Constants
• Variables
• func Router(cfg *Config) *gin.Engine
• type AuthConfig
• type Config
• type ErrorResponse
• type FileURLBuilder
• type Filer
• type MinioInteractor
• type MultipartFile
  • func NewMultipartFile(file *multipart.FileHeader) (*MultipartFile, error)
  • func (mf *MultipartFile) Checksum() string
  • func (mf *MultipartFile) ContentType() string
  • func (mf *MultipartFile) Open() io.Reader
  • func (mf *MultipartFile) Size() int
• type Storage
  • func NewStorage(cfg StorageConfig) (*Storage, error)
  • func (u *Storage) GetFile(file Filer) (*StorageFile, error)
  • func (u *Storage) GetFileByChecksum(checksum string) (*StorageFile, error)
  • func (u *Storage) UploadFile(file Filer, reader io.Reader) error
  • func (u *Storage) UploadFileIfNotExists(file Filer) error
• type StorageConfig
• type StorageFile
  • func (sf *StorageFile) Read(p []byte) (n int, err error)

Constants

const AccessTokenHeaderName = "X-Access-Token"

AccessTokenHeaderName _

const ErrFileNotFoundCode = "FILE_NOT_FOUND"

ErrFileNotFoundCode _

Variables

var ErrFileNotFound = errors.New(ErrFileNotFoundCode)

ErrFileNotFound _

var ErrMissingAccessToken = errors.New("MISSING_ACCESS_TOKEN")

ErrMissingAccessToken _

var ErrNotAuthorized = errors.New("NOT_AUTHORIZED")

ErrNotAuthorized _

var ErrUnknown = errors.New("UNKNOWN_ERROR")

ErrUnknown _

Functions

func Router

func Router(cfg *Config) *gin.Engine

Router _

Types

type AuthConfig

type AuthConfig struct {
	AllowedAccessToken string
}

AuthConfig _

type Config

type Config struct {
	S3Host             string
	S3AccessKey        string
	S3AccessSecret     string
	S3Bucket           string
	S3Path             string
	Host               string
	AllowedAccessToken string
}

Config _

type ErrorResponse

type ErrorResponse struct {
	Code        string `json:"code"`
	Message     string `json:"message"`
	Description string `json:"description"`
}

ErrorResponse _

type FileURLBuilder

type FileURLBuilder = func(checksum string) string

FileURLBuilder _

type Filer

type Filer interface {
	Checksum() string
	ContentType() string
	Size() int
	Open() io.Reader
}

Filer _

type MinioInteractor

type MinioInteractor interface {
	PutObject(bucketName string, objectName string, reader io.Reader, objectSize int64, opts minio.PutObjectOptions) (n int64, err error)
	StatObject(bucketName string, objectName string, opts minio.StatObjectOptions) (minio.ObjectInfo, error)
	GetObject(bucketName, objectName string, opts minio.GetObjectOptions) (*minio.Object, error)
}

MinioInteractor _

type MultipartFile

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

MultipartFile _

func NewMultipartFile

func NewMultipartFile(file *multipart.FileHeader) (*MultipartFile, error)

NewMultipartFile _

func (*MultipartFile) Checksum

func (mf *MultipartFile) Checksum() string

Checksum _

func (*MultipartFile) ContentType

func (mf *MultipartFile) ContentType() string

ContentType _

func (*MultipartFile) Open

func (mf *MultipartFile) Open() io.Reader

Open _

func (*MultipartFile) Size

func (mf *MultipartFile) Size() int

Size _

type Storage

type Storage struct {
	S3Bucket   string
	S3Path     string
	URLBuilder FileURLBuilder
	// contains filtered or unexported fields
}

Storage _

func NewStorage

func NewStorage(cfg StorageConfig) (*Storage, error)

NewStorage _

func (*Storage) GetFile

func (u *Storage) GetFile(file Filer) (*StorageFile, error)

GetFile _

func (*Storage) GetFileByChecksum

func (u *Storage) GetFileByChecksum(checksum string) (*StorageFile, error)

GetFileByChecksum _

func (*Storage) UploadFile

func (u *Storage) UploadFile(file Filer, reader io.Reader) error

UploadFile _

func (*Storage) UploadFileIfNotExists

func (u *Storage) UploadFileIfNotExists(file Filer) error

UploadFileIfNotExists _

type StorageConfig

type StorageConfig struct {
	S3Host         string
	S3AccessKey    string
	S3AccessSecret string
	S3Bucket       string
	S3Path         string
	URLBuilder     FileURLBuilder
}

StorageConfig _

type StorageFile

type StorageFile struct {
	URL      string `json:"url"`
	Size     int    `json:"size"`
	Checksum string `json:"checksum"`
	MimeType string `json:"mime_type"`
	// contains filtered or unexported fields
}

StorageFile _

func (*StorageFile) Read

func (sf *StorageFile) Read(p []byte) (n int, err error)

Read _