wsgo

package

Go to main page

Versions in this module

v0

v0.0.18

Apr 20, 2024

v0.0.17

Mar 25, 2024

v0.0.16

Mar 4, 2024

Changes in this version

+ func PrintPythonTraceback()

v0.0.15

Feb 26, 2024

Changes in this version

+ func DeinitPythonInterpreter()

+ func GetRateLimitKey(ip net.IP) string

v0.0.14

Feb 11, 2024

Changes in this version

+ func LogRequestJob(job *RequestJob)

+ func Send504(job *RequestJob)

v0.0.13

Feb 10, 2024

Changes in this version

+ func PrintRequestStats()

v0.0.12

May 16, 2023

Changes in this version

+ const DISCONNECT

+ const HTTP_204

+ const HTTP_504

+ const RETRY

+ func ParkJob(job *RequestJob)

type BufferingReader

+ func (b *BufferingReader) Readline(p []byte) (n int, err error)

+ func (b *BufferingReader) Rewind() error

+ type ParkedJob struct

+ type ParkedJobNotification struct

+ type RequestReader interface

+ Read func([]byte) (n int, err error)

+ Readline func([]byte) (n int, err error)

+ Rewind func() error

v0.0.11

May 8, 2023

Changes in this version

+ type FancyScheduler struct

+ func NewFancyScheduler() *FancyScheduler

+ func (sched *FancyScheduler) CalculateJobPriority(job *RequestJob) int

+ func (sched *FancyScheduler) FindJobInQueue(job *RequestJob) int

+ func (sched *FancyScheduler) GetAgedRequestCount(remoteAddr string) RequestCount

+ func (sched *FancyScheduler) GetHighestPriorityJob() (*RequestJob, int)

+ func (sched *FancyScheduler) GetLowestPriorityJob() (*RequestJob, int)

+ func (sched *FancyScheduler) GrabJob() *RequestJob

+ func (sched *FancyScheduler) HandleJob(job *RequestJob, timeout time.Duration) error

+ func (sched *FancyScheduler) JobFinished(job *RequestJob, elapsed int64, cpu_elapsed int64)

+ type RequestCount struct

+ type RequestJob struct

+ type Scheduler interface

+ GrabJob func() *RequestJob

+ HandleJob func(job *RequestJob, timeout time.Duration) error

+ JobFinished func(job *RequestJob, elapsed int64, cpu_elapsed int64)

+ type SimpleScheduler struct

+ func NewSimpleScheduler() *SimpleScheduler

+ func (sched *SimpleScheduler) GrabJob() *RequestJob

+ func (sched *SimpleScheduler) HandleJob(job *RequestJob, timeout time.Duration) error

+ func (sched *SimpleScheduler) JobFinished(job *RequestJob, elapsed int64, cpu_elapsed int64)

v0.0.10

Apr 11, 2023

v0.0.9

Feb 12, 2023

v0.0.8

Nov 28, 2022

Changes in this version

+ func AddJobToQueue(job *Job)

+ func DeriveCacheKey(req *http.Request) string

+ func DetermineRequestPriority(req *http.Request) int

+ func FlagJobFinished(job *Job)

+ func GetActiveRequestsBySource(source string) int

+ func GetRemoteAddr(req *http.Request) string

+ func GetThreadCpuTime() uint64

+ func GetWeightedCpuTime(url string) int64

+ func GetWeightedResponseTime(url string) int64

+ func JobGrabber()

type Job

+ func GrabJobFromQueue() *Job

type PythonWorker

+ func (worker *PythonWorker) BackgroundWorkerRun()

+ func (worker *PythonWorker) RunPythonTask(task func(), timeout int) (time.Time, int64, int64)

v0.0.7

Nov 21, 2022

v0.0.6

Aug 23, 2022

v0.0.5

Aug 23, 2022

Changes in this version

+ func Iif(condition bool, ifTrue int, ifFalse int) int

v0.0.4

Aug 22, 2022

v0.0.3

Apr 11, 2022

v0.0.2

Apr 5, 2022

Changes in this version

+ const HIT

+ const HIT_BUT_EXPIRING_SOON

+ const MISS

+ var EXITCODE_INVALID int = 27

+ func AddCron(function *C.PyObject, period int, min int, hour int, day int, mon int, ...)

+ func AddWsgiRequestReader(requestId int64, reader io.Reader)

+ func AllWorkersAreStuck() bool

+ func CachePage(cw *CacheWriter, req *http.Request)

+ func CallApplication(requestId int64, req *http.Request) *C.PyObject

+ func CanAccelResponse(job *Job) bool

+ func CreateStartResponseFunction(requestId int64) *C.PyObject

+ func CreateWsgiEnvironment(requestId int64, req *http.Request) *C.PyObject

+ func CronRoutine()

+ func CronTick()

+ func DurationUntilNextCron() time.Duration

+ func ExitProcessInvalid(msg string)

+ func ExtractCookies(cookies string, filter string) string

+ func GetWeightedLoadTime(url string) int64

+ func InitPythonInterpreter(module_name string)

+ func IsRequestHeavy(req *http.Request) bool

+ func LogRequest(req *http.Request, statusCode int, finishTime time.Time, elapsed int, ...)

+ func NewMonitor()

+ func ParseFlags()

+ func PrintMemoryStats()

+ func PruneCache()

+ func PyDictSet(dict *C.PyObject, key string, value string)

+ func PyDictSetObject(dict *C.PyObject, key string, obj *C.PyObject)

+ func PyEval(code string) (*C.PyObject, func())

+ func ReadWsgiResponseToWriter(response *C.PyObject, w io.Writer) error

+ func RecordPageStats(url string, timeMillis int64)

+ func RemoveWsgiRequestReader(requestId int64)

+ func ResolveAccel(job *Job)

+ func RunProcess(wg *sync.WaitGroup, process int)

+ func RunProcessManager()

+ func Serve(w http.ResponseWriter, req *http.Request)

+ func Shutdown(message string)

+ func StartWorkers()

+ func StartupWsgo(initMux func(*http.ServeMux))

+ func TryStatic(w http.ResponseWriter, req *http.Request) bool

+ type BackgroundJob struct

+ type BufferingReader struct

+ func NewBufferingReader(r io.Reader, bufLen int) *BufferingReader

+ func (b *BufferingReader) Read(p []byte) (int, error)

+ type CacheWriter struct

+ func NewCacheOnlyCacheWriter() *CacheWriter

+ func NewCacheWriter(w http.ResponseWriter) *CacheWriter

+ func NewNonCachingCacheWriter(w http.ResponseWriter) *CacheWriter

+ func (cw *CacheWriter) Flush() error

+ func (cw *CacheWriter) Header() http.Header

+ func (cw *CacheWriter) Write(b []byte) (int, error)

+ func (cw *CacheWriter) WriteHeader(statusCode int)

+ func (cw *CacheWriter) WriteOld(b []byte) (int, error)

+ type Cron struct

+ type Job struct

+ type PageCacheEntry struct

+ func (entry *PageCacheEntry) Size() uint64

+ type PageStat struct

+ type PythonWorker struct

+ func (worker *PythonWorker) HandleBackgroundJob(job *BackgroundJob)

+ func (worker *PythonWorker) HandleJob(job *Job)

+ func (worker *PythonWorker) Run()

+ type ResponseStart struct

+ func GetWsgiResponseStart(requestId int64) *ResponseStart

+ type RollingAverage struct

+ func NewRollingAverage() RollingAverage

+ func (r *RollingAverage) Add(sample int64)

+ func (r *RollingAverage) GetFilteredMax() int64

+ type TryCacheResponse int

+ func TryCache(w http.ResponseWriter, req *http.Request) TryCacheResponse

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL