common

Documentation

Index

• Constants
• Variables
• func EtcdExecutorKey(taskID string) string
• func EtcdRunKey(runID string) string
• func EtcdTaskKey(taskID string) string
• func GenExecutorTask(r *types.Run, rt *types.RunTask, rc *types.RunConfig, executor *types.Executor) *types.ExecutorTask
• func GenExecutorTaskSpecData(r *types.Run, rt *types.RunTask, rc *types.RunConfig) *types.ExecutorTaskSpecData
• func NewErrNotExist(err error) error
• func NewRunEvent(ctx context.Context, e *etcd.Store, runID string, phase types.RunPhase, ...) (*types.RunEvent, error)
• func OSTRootGroup(group string) string
• func OSTSubGroupTypes(group string) []string
• func OSTSubGroups(group string) []string
• func OSTSubGroupsAndGroupTypes(group string) []string
• type DataType
• type ErrNotExist
  • func (e ErrNotExist) Error() string

Constants

const (
	EtcdChangeGroupMinRevisionRange = 100
)

const (
	MaxCacheKeyLength = 200
)

Variables

var (
	EtcdSchedulerBaseDir = "scheduler"

	EtcdRunsDir             = path.Join(EtcdSchedulerBaseDir, "runs")
	EtcdRunSequenceKey      = path.Join(EtcdSchedulerBaseDir, "runsequence")
	EtcdRunEventKey         = path.Join(EtcdSchedulerBaseDir, "runevents")
	EtcdRunEventSequenceKey = path.Join(EtcdSchedulerBaseDir, "runeventsequence")

	EtcdChangeGroupsDir           = path.Join(EtcdSchedulerBaseDir, "changegroups")
	EtcdChangeGroupMinRevisionKey = path.Join(EtcdSchedulerBaseDir, "changegroupsminrev")

	EtcdExecutorsDir = path.Join(EtcdSchedulerBaseDir, "executors")
	EtcdTasksDir     = path.Join(EtcdSchedulerBaseDir, "tasks")

	EtcdPingKey = path.Join(EtcdSchedulerBaseDir, "ping")

	EtcdCompactChangeGroupsLockKey = path.Join(EtcdSchedulerBaseDir, "compactchangegroupslock")
	EtcdCacheCleanerLockKey        = path.Join(EtcdSchedulerBaseDir, "locks", "cachecleaner")
	EtcdWorkspaceCleanerLockKey    = path.Join(EtcdSchedulerBaseDir, "locks", "workspacecleaner")
	EtcdTaskUpdaterLockKey         = path.Join(EtcdSchedulerBaseDir, "locks", "taskupdater")

	EtcdMaintenanceKey = "maintenance"
)

var (
	StorageDataDir        = ""
	StorageRunsDir        = path.Join(StorageDataDir, "runs")
	StorageRunsConfigDir  = path.Join(StorageDataDir, "runsconfig")
	StorageRunsIndexesDir = path.Join(StorageDataDir, "runsindexes")
	StorageCountersDir    = path.Join(StorageDataDir, "counters")
)

Functions

func EtcdExecutorKey

func EtcdExecutorKey(taskID string) string

func EtcdRunKey

func EtcdRunKey(runID string) string

func EtcdTaskKey

func EtcdTaskKey(taskID string) string

func GenExecutorTask

func GenExecutorTask(r *types.Run, rt *types.RunTask, rc *types.RunConfig, executor *types.Executor) *types.ExecutorTask

func GenExecutorTaskSpecData

func GenExecutorTaskSpecData(r *types.Run, rt *types.RunTask, rc *types.RunConfig) *types.ExecutorTaskSpecData

func NewErrNotExist

func NewErrNotExist(err error) error

func NewRunEvent

func NewRunEvent(ctx context.Context, e *etcd.Store, runID string, phase types.RunPhase, result types.RunResult) (*types.RunEvent, error)

func OSTRootGroup

func OSTRootGroup(group string) string

func OSTSubGroupTypes

func OSTSubGroupTypes(group string) []string

func OSTSubGroups

func OSTSubGroups(group string) []string

func OSTSubGroupsAndGroupTypes

func OSTSubGroupsAndGroupTypes(group string) []string

Types

type DataType

type DataType string

const (
	DataTypeRun        DataType = "run"
	DataTypeRunConfig  DataType = "runconfig"
	DataTypeRunCounter DataType = "runcounter"
)

type ErrNotExist

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

func (ErrNotExist) Error

func (e ErrNotExist) Error() string