server

Documentation

Index

• Constants
• func LogMiddleware(next http.Handler) http.Handler
• func SetupLogging(buf *LogBuffer)
• type LogBuffer
  • func NewLogBuffer(maxSize int) *LogBuffer
  • func (lb *LogBuffer) Recent(n int) []string
  • func (lb *LogBuffer) Subscribe() chan string
  • func (lb *LogBuffer) Unsubscribe(ch chan string)
  • func (lb *LogBuffer) Write(p []byte) (n int, err error)
• type Server
  • func New(cfg *config.Config, version string) *Server
  • func (s *Server) Run(ctx context.Context) error

Constants

const (
	DefaultKeepAlive = 5 * time.Minute
)

Functions

func LogMiddleware

func LogMiddleware(next http.Handler) http.Handler

LogMiddleware logs HTTP requests to the standard logger with timing info.

func SetupLogging

func SetupLogging(buf *LogBuffer)

SetupLogging redirects log output to the in-memory buffer and, by default, mirrors it to stderr and ~/.csghub-lite/logs/csghub-lite.log.

Types

type LogBuffer

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

LogBuffer is a thread-safe ring buffer for log lines, supporting SSE subscribers.

func NewLogBuffer

func NewLogBuffer(maxSize int) *LogBuffer

func (*LogBuffer) Recent

func (lb *LogBuffer) Recent(n int) []string

func (*LogBuffer) Subscribe

func (lb *LogBuffer) Subscribe() chan string

func (*LogBuffer) Unsubscribe

func (lb *LogBuffer) Unsubscribe(ch chan string)

func (*LogBuffer) Write

func (lb *LogBuffer) Write(p []byte) (n int, err error)

type Server

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

func New

func New(cfg *config.Config, version string) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context) error