handler

Documentation

Overview

Package handler /*

## License This project is licensed under the APACHE Licence. Refer to https://github.com/mstgnz/go-minio-cdn/blob/main/LICENSE for more information.

Index

• type AwsHandler
  • func NewAwsHandler(awsService service.AwsService) AwsHandler
• type BatchDeleteRequest
• type BatchUploadRequest
• type HealthChecker
  • func NewHealthChecker(minioClient *minio.Client, awsService service.AwsService, ...) *HealthChecker
  • func (h *HealthChecker) HealthCheck(c *fiber.Ctx) error
• type Image
  • func NewImage(minioClient *minio.Client, awsService service.AwsService, ...) Image
• type ImageProcessRequest
• type MinioHandler
  • func NewMinioHandler(minioClient *minio.Client) MinioHandler
• type MonitoringStats
• type UploadUrlRequest
• type WebSocketHandler
  • func NewWebSocketHandler(stats *service.StatsService) WebSocketHandler

Types

type AwsHandler

type AwsHandler interface {
	GlacierVaultList(c *fiber.Ctx) error
	BucketList(c *fiber.Ctx) error
	BucketExists(c *fiber.Ctx) error
}

func NewAwsHandler

func NewAwsHandler(awsService service.AwsService) AwsHandler

type BatchDeleteRequest

type BatchDeleteRequest struct {
	Bucket    string   `json:"bucket" validate:"required"`
	Files     []string `json:"files" validate:"required,min=1"`
	AWSDelete bool     `json:"aws_delete"`
}

BatchDeleteRequest represents the request body for batch deletions

type BatchUploadRequest

type BatchUploadRequest struct {
	Bucket    string   `json:"bucket" validate:"required"`
	Path      string   `json:"path"`
	Files     []string `json:"files" validate:"required,min=1"`
	AWSUpload bool     `json:"aws_upload"`
}

BatchUploadRequest represents the request body for batch uploads

type HealthChecker

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

func NewHealthChecker

func NewHealthChecker(minioClient *minio.Client, awsService service.AwsService, cache service.CacheService) *HealthChecker

func (*HealthChecker) HealthCheck

func (h *HealthChecker) HealthCheck(c *fiber.Ctx) error

HealthCheck handles health check requests

type Image

type Image interface {
	GetImage(c *fiber.Ctx) error
	UploadImage(c *fiber.Ctx) error
	DeleteImage(c *fiber.Ctx) error
	ResizeImage(c *fiber.Ctx) error
	UploadWithUrl(c *fiber.Ctx) error
	BatchUpload(c *fiber.Ctx) error
	BatchDelete(c *fiber.Ctx) error
}

func NewImage

func NewImage(minioClient *minio.Client, awsService service.AwsService, imageService *service.ImageService, cacheService service.CacheService) Image

type ImageProcessRequest

type ImageProcessRequest struct {
	File        []byte
	Width       uint
	Height      uint
	ContentType string
	Filename    string
}

ImageProcessRequest represents an image processing request

type MinioHandler

type MinioHandler interface {
	BucketList(c *fiber.Ctx) error
	BucketExists(c *fiber.Ctx) error
	CreateBucket(c *fiber.Ctx) error
	RemoveBucket(c *fiber.Ctx) error
}

func NewMinioHandler

func NewMinioHandler(minioClient *minio.Client) MinioHandler

type MonitoringStats

type MonitoringStats struct {
	Timestamp     time.Time        `json:"timestamp"`
	ActiveUploads int              `json:"active_uploads"`
	UploadSpeed   float64          `json:"upload_speed"`
	CacheHitRate  float64          `json:"cache_hit_rate"`
	CPUUsage      float64          `json:"cpu_usage"`
	MemoryUsage   float64          `json:"memory_usage"`
	DiskUsage     map[string]int64 `json:"disk_usage"`
	Errors        []string         `json:"errors"`
}

type UploadUrlRequest

type UploadUrlRequest struct {
	Path      string `json:"path"`
	Bucket    string `json:"bucket" validate:"required"`
	URL       string `json:"url" validate:"required,url"`
	AWSUpload bool   `json:"aws_upload"`
}

UploadUrlRequest represents the request body for URL-based uploads

type WebSocketHandler

type WebSocketHandler interface {
	HandleWebSocket(c *websocket.Conn) error
	MonitorStats(c *fiber.Ctx) error
}

func NewWebSocketHandler

func NewWebSocketHandler(stats *service.StatsService) WebSocketHandler