server

Documentation

Index

• Variables
• type DB
  • func NewDB(driver string, address string) (*DB, error)
  • func (s *DB) Transaction(fc func(tx *DB) error) (err error)
• type JobObserver
  • func (s *JobObserver) Check() error
  • func (s *JobObserver) Start()
• type Scheduler
  • func (s *Scheduler) GetAction(ctx context.Context, _ *api.GetActionRequest) (*api.GetActionResponse, error)
  • func (s *Scheduler) GetActionControl(ctx context.Context, _ *api.GetActionControlRequest) (*api.GetActionControlResponse, error)
  • func (s *Scheduler) GetWorkspaceVersion(_ context.Context, req *api.GetWorkspaceVersionRequest) (*api.GetWorkspaceVersionResponse, error)
  • func (s *Scheduler) UpdateJobLog(_ context.Context, req *api.UpdateJobLogRequest) (*api.UpdateJobLogResponse, error)
  • func (s *Scheduler) UpdateJobStatus(_ context.Context, req *api.UpdateJobStatusRequest) (*api.UpdateJobStatusResponse, error)
• type Server
  • func New(projects map[string]*api.Project, db *DB, git utils.Git) *Server
  • func (s *Server) StartJobObserver() error
  • func (s *Server) StartScheduler(address string) error
  • func (s *Server) StartWeb(address string) error
• type Web
  • func (s *Web) ApproveJob(_ context.Context, req *api.ApproveJobRequest) (*api.ApproveJobResponse, error)
  • func (s *Web) CancelJob(_ context.Context, req *api.CancelJobRequest) (*api.CancelJobResponse, error)
  • func (s *Web) GetJob(_ context.Context, req *api.GetJobRequest) (*api.GetJobResponse, error)
  • func (s *Web) ListProjects(_ context.Context, _ *api.ListProjectsRequest) (*api.ListProjectsResponse, error)
  • func (s *Web) ListWorkspaces(_ context.Context, req *api.ListWorkspacesRequest) (*api.ListWorkspacesResponse, error)
  • func (s *Web) RefreshProject(_ context.Context, req *api.RefreshProjectRequest) (*api.RefreshProjectResponse, error)
  • func (s *Web) SubmitJob(_ context.Context, req *api.SubmitJobRequest) (*api.SubmitJobResponse, error)

Variables

var (
	ErrInvalidStateTransition = fmt.Errorf("invalid state transition")
)

Types

type DB

type DB struct {
	*gorm.DB
}

func NewDB

func NewDB(driver string, address string) (*DB, error)

func (*DB) Transaction

func (s *DB) Transaction(fc func(tx *DB) error) (err error)

type JobObserver

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

func (*JobObserver) Check

func (s *JobObserver) Check() error

func (*JobObserver) Start

func (s *JobObserver) Start()

type Scheduler

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

func (*Scheduler) GetAction

func (s *Scheduler) GetAction(ctx context.Context, _ *api.GetActionRequest) (*api.GetActionResponse, error)

func (*Scheduler) GetActionControl

func (s *Scheduler) GetActionControl(ctx context.Context, _ *api.GetActionControlRequest) (*api.GetActionControlResponse, error)

func (*Scheduler) GetWorkspaceVersion

func (s *Scheduler) GetWorkspaceVersion(_ context.Context, req *api.GetWorkspaceVersionRequest) (*api.GetWorkspaceVersionResponse, error)

func (*Scheduler) UpdateJobLog

func (s *Scheduler) UpdateJobLog(_ context.Context, req *api.UpdateJobLogRequest) (*api.UpdateJobLogResponse, error)

func (*Scheduler) UpdateJobStatus

func (s *Scheduler) UpdateJobStatus(_ context.Context, req *api.UpdateJobStatusRequest) (*api.UpdateJobStatusResponse, error)

type Server

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

func New

func New(projects map[string]*api.Project, db *DB, git utils.Git) *Server

func (*Server) StartJobObserver

func (s *Server) StartJobObserver() error

func (*Server) StartScheduler

func (s *Server) StartScheduler(address string) error

func (*Server) StartWeb

func (s *Server) StartWeb(address string) error

type Web

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

func (*Web) ApproveJob

func (s *Web) ApproveJob(_ context.Context, req *api.ApproveJobRequest) (*api.ApproveJobResponse, error)

func (*Web) CancelJob

func (s *Web) CancelJob(_ context.Context, req *api.CancelJobRequest) (*api.CancelJobResponse, error)

func (*Web) GetJob

func (s *Web) GetJob(_ context.Context, req *api.GetJobRequest) (*api.GetJobResponse, error)

func (*Web) ListProjects

func (s *Web) ListProjects(_ context.Context, _ *api.ListProjectsRequest) (*api.ListProjectsResponse, error)

func (*Web) ListWorkspaces

func (s *Web) ListWorkspaces(_ context.Context, req *api.ListWorkspacesRequest) (*api.ListWorkspacesResponse, error)

func (*Web) RefreshProject

func (s *Web) RefreshProject(_ context.Context, req *api.RefreshProjectRequest) (*api.RefreshProjectResponse, error)

func (*Web) SubmitJob

func (s *Web) SubmitJob(_ context.Context, req *api.SubmitJobRequest) (*api.SubmitJobResponse, error)