server

package

v0.0.5 Latest Latest Go to latest Published: Aug 18, 2020 License: MIT Imports: 25 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

type DB struct {
	*gorm.DB
}

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

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

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

func (s *JobObserver) Check() error

func (s *JobObserver) Start()

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

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 struct {
	// contains filtered or unexported fields
}

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 struct {
	// contains filtered or unexported fields
}

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)