Documentation ¶
Index ¶
- Constants
- Variables
- func EtcdExecutorKey(taskID string) string
- func EtcdRunKey(runID string) string
- func EtcdTaskFetcherLockKey(taskID 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 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
Constants ¶
View Source
const (
EtcdChangeGroupMinRevisionRange = 100
)
View Source
const (
MaxCacheKeyLength = 200
)
Variables ¶
View Source
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") EtcdLocksDir = path.Join(EtcdSchedulerBaseDir, "locks") EtcdCompactChangeGroupsLockKey = path.Join(EtcdLocksDir, "compactchangegroups") EtcdCacheCleanerLockKey = path.Join(EtcdLocksDir, "cachecleaner") EtcdWorkspaceCleanerLockKey = path.Join(EtcdLocksDir, "workspacecleaner") EtcdTaskUpdaterLockKey = path.Join(EtcdLocksDir, "taskupdater") EtcdMaintenanceKey = "maintenance" )
View Source
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 EtcdRunKey ¶
func EtcdTaskFetcherLockKey ¶ added in v0.4.0
func EtcdTaskKey ¶
func GenExecutorTask ¶ added in v0.3.0
func GenExecutorTaskSpecData ¶ added in v0.3.0
func NewRunEvent ¶
func OSTRootGroup ¶ added in v0.3.0
func OSTSubGroupTypes ¶ added in v0.3.0
func OSTSubGroups ¶ added in v0.3.0
func OSTSubGroupsAndGroupTypes ¶ added in v0.3.0
Types ¶
Click to show internal directories.
Click to hide internal directories.