Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.1.2

Jun 1, 2026

Changes in this version

type Job

+ Warnings []string

type JobCompleteEvent

+ Warnings []string

type JobErrorEvent

+ Warnings []string

type JobManager

+ func (m *JobManager) UpdateStatusWithWarnings(id, status, resultPath, errMsg string, warnings []string)

type JobProgressEvent

+ Warnings []string

v0.1.1

May 31, 2026

Changes in this version

+ const JobStatusCanceled

+ const JobStatusDone

+ const JobStatusFailed

+ const JobStatusQueued

+ const JobStatusRunning

+ var ErrJobNotFound = errors.New("job not found")

+ var Version = "dev"

+ func ConcurrencyLimitMiddleware(maxConcurrent int) func(http.Handler) http.Handler

+ func SizeLimitMiddleware(maxBytes int64) func(http.Handler) http.Handler

+ type CleanupManager struct

+ func NewCleanupManager(tempDir string, ttl time.Duration, logger *slog.Logger) *CleanupManager

+ func (c *CleanupManager) CleanupOnce() error

+ func (c *CleanupManager) Start()

+ func (c *CleanupManager) Stop()

+ type Job struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Error string

+ From string

+ ID string

+ ResultPath string

+ Status string

+ To string

+ UploadID string

+ type JobCompleteEvent struct

+ DownloadURL string

+ Event string

+ JobID string

+ type JobErrorEvent struct

+ Error string

+ Event string

+ JobID string

+ type JobManager struct

+ func NewJobManager() *JobManager

+ func (m *JobManager) CreateJob(uploadID, from, to string) (*Job, error)

+ func (m *JobManager) DeleteJob(id string) bool

+ func (m *JobManager) GetJob(id string) (*Job, error)

+ func (m *JobManager) ListJobs() []*Job

+ func (m *JobManager) PruneJobs(before time.Time) int

+ func (m *JobManager) UpdateStatus(id, status, resultPath, errMsg string)

+ type JobProgressEvent struct

+ Event string

+ JobID string

+ Message string

+ Status string

+ type JobStore interface

+ GetJob func(id string) (*Job, error)

+ type SSEWriter struct

+ func NewSSEWriter(w http.ResponseWriter) (*SSEWriter, error)

+ func (s *SSEWriter) WriteEvent(event string, data any) error

+ type Server struct

+ func NewServer(engine *core.Engine, addr string, opts ...ServerOption) *Server

+ func (s *Server) Handler() http.Handler

+ func (s *Server) ListenAndServe() error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerMode int

+ const ServerModeLocalUI

+ const ServerModePublicAPI

+ type ServerOption func(*Server)

+ func WithCORSOrigin(origin string) ServerOption

+ func WithLogger(logger *slog.Logger) ServerOption

+ func WithMaxRunningJobs(n int) ServerOption

+ func WithMaxUploadSize(size int64) ServerOption

+ func WithRequestTimeout(timeout time.Duration) ServerOption

+ func WithServerMode(mode ServerMode) ServerOption

+ func WithUI(enabled bool) ServerOption

+ func WithVersion(version string) ServerOption