malgomaj

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

type CreateTaskJSONBodyLanguage string

type CreateTaskJSONBody_Http_Headers struct {
	AdditionalProperties map[string]string `json:"-"`
}

type CreateTaskJSONRequestBody NewTask

type Error struct {
	Code    int32  `json:"code"`
	Message string `json:"message"`
}

type MiddlewareFunc func(http.HandlerFunc) http.HandlerFunc

type NewTask struct {
	Deadline int    `json:"deadline"`
	Domain   string `json:"domain"`

	// Optional. When in use the task is executed as a HTTP procedure.
	Http *struct {
		Body    []byte               `json:"body"`
		Headers NewTask_Http_Headers `json:"headers"`
	} `json:"http,omitempty"`
	Language    NewTaskLanguage `json:"language"`
	ProgramUuid string          `json:"program_uuid"`
	SourceCode  []byte          `json:"source_code"`
}

type NewTaskHttp struct {
	Body    []byte               `json:"body"`
	Headers NewTask_Http_Headers `json:"headers"`
}

type NewTaskLanguage string

type NewTask_Http_Headers map[string]string

type NewTask_Libraries map[string][]byte

type Program interface {
	Equals(b Program) bool
	Compile(context.Context) error
	Run(context.Context) error
	RunWithHTTP(context.Context, http.ResponseWriter, *http.Request) error
	Modules() []string
	Language() string

	Id() string
	Deadline() time.Duration
	Checksum() [16]byte // MD5
}

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

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

type Response struct {
	StatusCode int
	Body       []byte
}

type RestApi struct{}

type ServerInterface interface {
	// Get worker status
	// (GET /v1/status)
	GetStatus(w http.ResponseWriter, r *http.Request)
	// Add a new Task
	// (POST /v1/tasks)
	CreateTask(w http.ResponseWriter, r *http.Request)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
}

type Status struct {

	// The current load (aggregated deadlines)
	Load int64 `json:"load"`
}

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