supervisor

Mar 3, 2017

Changes in this version

+ type JobHealth struct

+ LastRun int64

+ Name string

+ NextRun int64

+ Paused bool

+ Status string

Jun 24, 2016

Changes in this version

+ var Version = "(development)"

+ func AuthHeader(r *http.Request) (string, string)

+ func Authenticate(tokens map[string]string, next http.Handler) http.Handler

+ func ShouldOAuthRedirect(path string) bool

type ArchiveAPI

+ Tasks chan *db.Task

+ type AuthConfig struct

+ Basic BasicAuthConfig

+ OAuth OAuthConfig

+ Tokens map[string]string

+ type AuthZConfig struct

+ Orgs []string

+ type Authenticator interface

+ IsAuthenticated func(*http.Request) bool

+ RequireAuth func(http.ResponseWriter, *http.Request)

+ var UserAuthenticator Authenticator

+ type BasicAuthConfig struct

+ Password string

+ User string

+ type BasicAuthenticator struct

+ Cfg BasicAuthConfig

+ func (ba BasicAuthenticator) IsAuthenticated(r *http.Request) bool

+ func (ba BasicAuthenticator) RequireAuth(w http.ResponseWriter, r *http.Request)

type Config

+ Addr string

+ Auth AuthConfig

+ SkipSSLVerify bool

+ WebRoot string

+ type GithubVerifier struct

+ Orgs []string

+ func (gv *GithubVerifier) Membership(user goth.User, c *http.Client) (map[string]interface{}, error)

+ func (gv *GithubVerifier) Verify(user string, membership map[string]interface{}) bool

+ type JWTCreator struct

+ SigningKey *rsa.PrivateKey

+ func (jc JWTCreator) GenToken(user interface{}, membership interface{}, maxAge int) (string, error)

+ func (jc JWTCreator) ServeHTTP(w http.ResponseWriter, r *http.Request)

type JobAPI

+ Tasks chan *db.Task

+ type MembershipChecker interface

+ Membership func(goth.User, *http.Client) (map[string]interface{}, error)

+ Verify func(string, map[string]interface{}) bool

+ var OAuthVerifier MembershipChecker

+ type OAuthConfig struct

+ Authorization AuthZConfig

+ BaseURL string

+ Client *http.Client

+ JWTPrivateKey *rsa.PrivateKey

+ JWTPublicKey *rsa.PublicKey

+ Key string

+ Provider string

+ ProviderURL string

+ Secret string

+ Sessions SessionsConfig

+ SigningKey string

+ type OAuthenticator struct

+ Cfg OAuthConfig

+ func (oa OAuthenticator) IsAuthenticated(r *http.Request) bool

+ func (oa OAuthenticator) OAuthCallback() http.Handler

+ func (oa OAuthenticator) RequireAuth(w http.ResponseWriter, r *http.Request)

+ type SessionsConfig struct

+ DSN string

+ MaxAge int

+ Type string

type StatusAPI

+ Data *db.DB

+ Super *Supervisor

type Supervisor

+ Web *WebServer

+ func (s *Supervisor) FailUnfinishedTasks() error

+ func (s *Supervisor) RemoveTaskFromRunq(id uuid.UUID)

+ func (s *Supervisor) ReschedulePendingTasks() error

+ type UAAVerifier struct

+ Groups []string

+ UAA string

+ func (uv *UAAVerifier) Membership(user goth.User, c *http.Client) (map[string]interface{}, error)

+ func (uv *UAAVerifier) Verify(user string, membership map[string]interface{}) bool

+ type WebServer struct

+ Addr string

+ Auth AuthConfig

+ Authenticator http.Handler

+ Database *db.DB

+ Supervisor *Supervisor

+ WebRoot string

+ func (ws *WebServer) ProtectedAPIs() (http.Handler, error)

+ func (ws *WebServer) Setup() error

+ func (ws *WebServer) Start()

+ func (ws *WebServer) UnauthenticatedResources(next http.Handler) http.Handler

Feb 23, 2016

Changes in this version

+ type ClientError struct

+ Error string

+ func ClientErrorf(format string, v ...interface{}) ClientError

+ func (e ClientError) JSON() string

type Job

+ Name string

type JobRepresentation

+ Name string

+ type StatusAPI struct

+ func (p StatusAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

type Supervisor

+ func (s *Supervisor) ScheduleTask(t *Task)

+ func (s *Supervisor) Sweep() error

Jan 8, 2016

Changes in this version

+ var DEV_MODE_SCHEDULING bool = false

+ func JSON(w http.ResponseWriter, thing interface{})

+ func JSONLiteral(w http.ResponseWriter, thing string)

+ func Sentencify(words []string) string

+ type AdhocTask struct

+ ArchiveUUID uuid.UUID

+ JobUUID uuid.UUID

+ Op Operation

+ Owner string

+ RestoreKey string

+ TargetUUID uuid.UUID

+ type ArchiveAPI struct

+ AdhocChan chan AdhocTask

+ Data *db.DB

+ ResyncChan chan int

+ func (self ArchiveAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Config struct

+ DatabaseDSN string

+ DatabaseType string

+ MaxTimeout uint

+ Port string

+ PrivateKeyFile string

+ PurgeAgent string

+ Workers uint

+ type InvalidParametersError struct

+ Errors map[string]string

+ func InvalidParameters(names ...string) InvalidParametersError

+ func (e *InvalidParametersError) IsValid() bool

+ func (e *InvalidParametersError) Validate(name string, value interface{}, fn Validator)

+ func (e InvalidParametersError) Error() string

+ func (e InvalidParametersError) JSON() string

+ type JSONError interface

+ JSON func() string

+ type Job struct

+ Agent string

+ NextRun time.Time

+ Paused bool

+ Spec *timespec.Spec

+ StoreEndpoint string

+ StorePlugin string

+ TargetEndpoint string

+ TargetPlugin string

+ UUID uuid.UUID

+ func (j *Job) Reschedule() error

+ func (j *Job) Runnable() bool

+ func (j *Job) Task() *Task

+ type JobAPI struct

+ AdhocChan chan AdhocTask

+ Data *db.DB

+ ResyncChan chan int

+ func (self JobAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type JobFailedError struct

+ FailedJobs []JobRepresentation

+ func (e JobFailedError) Error() string

+ type JobRepresentation struct

+ Error error

+ Tspec string

+ UUID uuid.UUID

+ type MetaAPI struct

+ PrivateKeyFile string

+ func (self MetaAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type MissingParametersError struct

+ Missing []string

+ func MissingParameters(names ...string) MissingParametersError

+ func (e *MissingParametersError) Check(name string, value string)

+ func (e MissingParametersError) Error() string

+ func (e MissingParametersError) IsValid() bool

+ func (e MissingParametersError) JSON() string

+ type Operation int

+ const BACKUP

+ const PURGE

+ const RESTORE

+ func (o Operation) String() string

+ type PingAPI struct

+ func (p PingAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type RetentionAPI struct

+ Data *db.DB

+ ResyncChan chan int

+ func (self RetentionAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type ScheduleAPI struct

+ Data *db.DB

+ ResyncChan chan int

+ func (self ScheduleAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Status int

+ const CANCELED

+ const DONE

+ const PENDING

+ const RUNNING

+ type StoreAPI struct

+ Data *db.DB

+ ResyncChan chan int

+ func (self StoreAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Supervisor struct

+ Database *db.DB

+ Port string

+ PrivateKeyFile string

+ PurgeAgent string

+ Timeout time.Duration

+ Workers uint

+ func NewSupervisor() *Supervisor

+ func (s *Supervisor) CheckSchedule()

+ func (s *Supervisor) GetAllJobs() ([]*Job, error)

+ func (s *Supervisor) PurgeArchives()

+ func (s *Supervisor) ReadConfig(path string) error

+ func (s *Supervisor) Resync() error

+ func (s *Supervisor) Run() error

+ func (s *Supervisor) ScheduleAdhoc(a AdhocTask)

+ func (s *Supervisor) SchedulePurgeTask(archive *db.AnnotatedArchive) error

+ func (s *Supervisor) SpawnAPI()

+ func (s *Supervisor) SpawnScheduler()

+ func (s *Supervisor) SpawnWorker()

+ func (s *Supervisor) SpawnWorkers()

+ type TargetAPI struct

+ Data *db.DB

+ ResyncChan chan int

+ func (self TargetAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Task struct

+ Agent string

+ ArchiveUUID uuid.UUID

+ Attempts int

+ Op Operation

+ Output []string

+ RestoreKey string

+ StartedAt time.Time

+ Status Status

+ StoppedAt time.Time

+ StoreEndpoint string

+ StorePlugin string

+ TargetEndpoint string

+ TargetPlugin string

+ TimeoutAt time.Time

+ UUID uuid.UUID

+ func NewPendingTask(Op Operation) *Task

+ type TaskAPI struct

+ Data *db.DB

+ func (self TaskAPI) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type UpdateOp int

+ const FAILED

+ const OUTPUT

+ const PURGE_ARCHIVE

+ const RESTORE_KEY

+ const STOPPED

+ type Validator func(name string, value interface{}) error

+ type WorkerRequest struct

+ Operation string

+ RestoreKey string

+ StoreEndpoint string

+ StorePlugin string

+ TargetEndpoint string

+ TargetPlugin string

+ type WorkerUpdate struct

+ Archive uuid.UUID

+ Op UpdateOp

+ Output string

+ StoppedAt time.Time

+ Task uuid.UUID

+ TaskSuccess bool