sched

Documentation

Overview

Copyright 2020 Fugue, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Fugue, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Fugue, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type Options
• type Scheduler
  • func NewGraphScheduler() Scheduler
• type Status

Types

type Options

type Options struct {
	BuildID    string
	Name       string
	Runner     project.Runner
	Executor   exec.Executor
	Rules      []*project.Rule
	RunRemote  bool
	NumWorkers int
}

Options used to configure the Scheduler

type Scheduler

type Scheduler interface {

	// Run specified Rules
	Run(context.Context, Options) error
}

Scheduler for jobs

func NewGraphScheduler

func NewGraphScheduler() Scheduler

NewGraphScheduler returns a default scheduler

type Status

type Status int

Status indicates the running state of a rule in the scheduler

const (

	// Unscheduled says that Rule has not had a chance to run yet
	Unscheduled Status = iota

	// Running indicates the Rule is currently running
	Running

	// Error indicates that Rule execution was attempted but had an error
	Error

	// Completed indicates the Rule ran successfully
	Completed
)