service

Documentation

Index

• Constants
• func EnableGzip(handler http.Handler) http.Handler
• func ServeNow() (err error)
• type Api
• type Job
• type ServerContext
• type WokerPool
  • func NewWorkPool() *WokerPool
  • func (wp *WokerPool) QueueJob(job *Job) bool
  • func (wp *WokerPool) Start()
  • func (wp *WokerPool) Stop()

Constants

const (
	API_INDEX   = "/api"
	API_DEVICES = API_INDEX + "/devices"
	API_UPDATES = API_INDEX + "/updates"
)

const MAX_JOBS = 20

Functions

func EnableGzip

func EnableGzip(handler http.Handler) http.Handler

func ServeNow

func ServeNow() (err error)

Types

type Api

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

type Job

type Job struct {
	Params []interface{}
	Run    func([]interface{})
}

type ServerContext

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

type WokerPool

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

func NewWorkPool

func NewWorkPool() *WokerPool

func (*WokerPool) QueueJob

func (wp *WokerPool) QueueJob(job *Job) bool

func (*WokerPool) Start

func (wp *WokerPool) Start()

func (*WokerPool) Stop

func (wp *WokerPool) Stop()