repository

Documentation

Index

• type ClusterRepository
  • func NewClusterRepository() *ClusterRepository
  • func (r *ClusterRepository) CreateCluster(cluster dbmodel.ClusterInfo) string
  • func (r *ClusterRepository) DeleteCluster(id string) error
  • func (r *ClusterRepository) GetCluster(id string) dbmodel.ClusterInfo
  • func (r *ClusterRepository) GetClusters() []dbmodel.ClusterInfo
• type JobRepository
  • func NewJobRepository() *JobRepository
  • func (r *JobRepository) CreateJob(jobCreateRequest dbmodel.JobSettings) int64
  • func (r *JobRepository) DeleteJob(id int64) error
  • func (r *JobRepository) GetJob(id int64) dbmodel.Job
  • func (r *JobRepository) GetJobs() model.JobsListResponse
• type RunRepository
  • func NewRunRepository(timePerRunLifeState int64) *RunRepository
  • func (r *RunRepository) CancelRun(id int64) error
  • func (r *RunRepository) CreateRun(runReq model.JobsRunsSubmitRequest, jobID int64) int64
  • func (r *RunRepository) DeleteRun(id int64) error
  • func (r *RunRepository) GetRun(id int64) dbmodel.Run
  • func (r *RunRepository) GetRunOutput(id int64) azure.JobsRunsGetOutputResponse
  • func (r *RunRepository) GetRuns() azure.JobsRunsListResponse

Types

type ClusterRepository

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

ClusterRepository is a store for Cluster instances

func NewClusterRepository

func NewClusterRepository() *ClusterRepository

NewClusterRepository creates a new ClusterRepository

func (*ClusterRepository) CreateCluster

func (r *ClusterRepository) CreateCluster(cluster dbmodel.ClusterInfo) string

CreateCluster adds an ID to the specified cluster and adds it to the collection

func (*ClusterRepository) DeleteCluster

func (r *ClusterRepository) DeleteCluster(id string) error

DeleteCluster deletes the cluster with the specified ID

func (*ClusterRepository) GetCluster

func (r *ClusterRepository) GetCluster(id string) dbmodel.ClusterInfo

GetCluster returns the Cluster with the specified ID or an empty Cluster

func (*ClusterRepository) GetClusters

func (r *ClusterRepository) GetClusters() []dbmodel.ClusterInfo

GetClusters returns all Clusters

type JobRepository

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

JobRepository is a store for Job instances

func NewJobRepository

func NewJobRepository() *JobRepository

NewJobRepository creates a new JobRepository

func (*JobRepository) CreateJob

func (r *JobRepository) CreateJob(jobCreateRequest dbmodel.JobSettings) int64

CreateJob adds an ID to the specified job and adds it to the collection

func (*JobRepository) DeleteJob

func (r *JobRepository) DeleteJob(id int64) error

DeleteJob deletes the job with the specified ID

func (*JobRepository) GetJob

func (r *JobRepository) GetJob(id int64) dbmodel.Job

GetJob returns the Job with the specified ID or an empty Job

func (*JobRepository) GetJobs

func (r *JobRepository) GetJobs() model.JobsListResponse

GetJobs returns all Jobs

type RunRepository

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

RunRepository is a store for Run instances

func NewRunRepository

func NewRunRepository(timePerRunLifeState int64) *RunRepository

NewRunRepository creates a new RunRepository

func (*RunRepository) CancelRun

func (r *RunRepository) CancelRun(id int64) error

CancelRun cancels the run with the specified ID

func (*RunRepository) CreateRun

func (r *RunRepository) CreateRun(runReq model.JobsRunsSubmitRequest, jobID int64) int64

CreateRun adds an ID to the specified run and adds it to the collection

func (*RunRepository) DeleteRun

func (r *RunRepository) DeleteRun(id int64) error

DeleteRun deletes the run with the specified ID

func (*RunRepository) GetRun

func (r *RunRepository) GetRun(id int64) dbmodel.Run

GetRun returns the Run with the specified ID or an empty Run

func (*RunRepository) GetRunOutput

func (r *RunRepository) GetRunOutput(id int64) azure.JobsRunsGetOutputResponse

GetRunOutput returns the Run output along with the run as metadata or an empty run output

func (*RunRepository) GetRuns

func (r *RunRepository) GetRuns() azure.JobsRunsListResponse

GetRuns returns all Runs