juvuln

type BadGateway Error

type ChiServerOptions struct {
	BaseURL     string
	BaseRouter  chi.Router
	Middlewares []MiddlewareFunc
}

type DomainPathParam string

type DomainQueryParam string

type Error struct {

	// Error code
	Code int `json:"code"`

	// Error message
	Message string `json:"message"`
}

type GetModuleAtRevisionParams struct {

	// A domain
	Domain DomainQueryParam `json:"domain"`

	// The module name
	Module ModuleParam `json:"module"`

	// The language of the module
	Language LanguageParam `json:"language"`

	// The module revision. The keyword 'latest' will return the latest revision.
	Revision RevisionParam `json:"revision"`
}

type InternalServerError Error

type LanguageParam string

type MiddlewareFunc func(http.HandlerFunc) http.HandlerFunc

type ModuleParam string

type NewSubscriber struct {

	// On the format [userinfo@]host[:port].
	Authority string `json:"authority"`

	// A list of supported languages.
	Languages []string            `json:"languages"`
	Scheme    NewSubscriberScheme `json:"scheme"`
	Uuid      string              `json:"uuid"`
}

type NewSubscriberScheme SubscriberScheme

type NotFound Error

type ProgramCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ProgramRevision struct {
	Domain      string
	Name        string
	ProgramUuid uuid.UUID
	Type        string
	Schedule    string
	Deadline    int32
	Language    string
	Revision    int32
	Code        []byte
	Checksum    string
	// contains filtered or unexported fields
}

type RestApi struct{}

type RevisionParam string

type ServerInterface interface {
	// Get module
	// (GET /v1/library)
	GetModuleAtRevision(w http.ResponseWriter, r *http.Request, params GetModuleAtRevisionParams)
	// Subscribe as a worker.
	// (POST /v1/subscribers)
	WorkerSubscribe(w http.ResponseWriter, r *http.Request)
	// Unsubscribe as a worker
	// (DELETE /v1/subscribers/{uuid})
	WorkerUnsubscribe(w http.ResponseWriter, r *http.Request, uuid UuidParam)
	// Check if subscriber has been added
	// (GET /v1/subscribers/{uuid})
	CheckWorker(w http.ResponseWriter, r *http.Request, uuid UuidParam)
	// Update Load Data
	// (PUT /v1/subscribers/{uuid}/load)
	WorkerLoadUpdate(w http.ResponseWriter, r *http.Request, uuid UuidParam)
	// Proxy interface for webhooks
	// (POST /v1/webhooks/{domain}/{uuid})
	ForwardWebhook(w http.ResponseWriter, r *http.Request, domain DomainPathParam, uuid UuidParam)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
}

type SubscriberScheme string

type Unauthorized Error

type UpdateLoad struct {
	Load int64 `json:"load"`
}

type UuidParam string

type Worker struct {
	sync.Mutex

	Id        string
	URI       string
	Languages []string
	// contains filtered or unexported fields
}

type WorkerLoadUpdateJSONRequestBody UpdateLoad

type WorkerSubscribeJSONBodyScheme string

type WorkerSubscribeJSONRequestBody NewSubscriber

type WorkerTask struct {
	Language    string    `json:"language"`
	Deadline    int       `json:"deadline"`
	Domain      string    `json:"domain"`
	ProgramUuid uuid.UUID `json:"program_uuid"`
	SourceCode  string    `json:"source_code"`
}