Documentation ¶
Index ¶
- Constants
- func AtomicPutExecutorTask(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)
- func AtomicPutRun(ctx context.Context, e *etcd.Store, r *types.Run, runEvent *types.RunEvent, ...) (*types.Run, error)
- func DeleteExecutor(ctx context.Context, e *etcd.Store, executorID string) error
- func DeleteExecutorTask(ctx context.Context, e *etcd.Store, etID string) error
- func DeleteRun(ctx context.Context, e *etcd.Store, runID string) error
- func GetExecutor(ctx context.Context, e *etcd.Store, executorID string) (*types.Executor, error)
- func GetExecutorTask(ctx context.Context, e *etcd.Store, etID string) (*types.ExecutorTask, error)
- func GetExecutorTasksCountByExecutor(ctx context.Context, e *etcd.Store) (map[string]int, error)
- func GetExecutorTasksForExecutor(ctx context.Context, e *etcd.Store, executorID string) ([]*types.ExecutorTask, error)
- func GetExecutorTasksForRun(ctx context.Context, e *etcd.Store, runID string) ([]*types.ExecutorTask, error)
- func GetExecutors(ctx context.Context, e *etcd.Store) ([]*types.Executor, error)
- func GetRun(ctx context.Context, e *etcd.Store, runID string) (*types.Run, int64, error)
- func GetRunEtcdOrOST(ctx context.Context, e *etcd.Store, dm *datamanager.DataManager, runID string) (*types.Run, error)
- func GetRuns(ctx context.Context, e *etcd.Store) ([]*types.Run, error)
- func OSTArchivesBaseDir() string
- func OSTCacheDir() string
- func OSTCacheKey(p string) string
- func OSTCachePath(key string) string
- func OSTGetRun(dm *datamanager.DataManager, runID string) (*types.Run, error)
- func OSTGetRunConfig(dm *datamanager.DataManager, runConfigID string) (*types.RunConfig, error)
- func OSTRunTaskArchivePath(rtID string, step int) string
- func OSTRunTaskArchivesBaseDir(rtID string) string
- func OSTRunTaskArchivesDataDir(rtID string) string
- func OSTRunTaskArchivesRunPath(rtID, runID string) string
- func OSTRunTaskArchivesRunsDir(rtID string) string
- func OSTRunTaskIDFromPath(archivePath string) (string, error)
- func OSTRunTaskLogsBaseDir(rtID string) string
- func OSTRunTaskLogsDataDir(rtID string) string
- func OSTRunTaskLogsRunPath(rtID, runID string) string
- func OSTRunTaskLogsRunsDir(rtID string) string
- func OSTRunTaskSetupLogPath(rtID string) string
- func OSTRunTaskStepLogPath(rtID string, step int) string
- func OSTSaveRunAction(r *types.Run) (*datamanager.Action, error)
- func OSTSaveRunConfigAction(rc *types.RunConfig) (*datamanager.Action, error)
- func OSTUpdateRunCounterAction(ctx context.Context, c uint64, group string) (*datamanager.Action, error)
- func PutExecutor(ctx context.Context, e *etcd.Store, executor *types.Executor) (*types.Executor, error)
- func UpdateExecutorTaskStatus(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)
Constants ¶
View Source
const (
MaxChangegroupNameLength = 256
)
Variables ¶
This section is empty.
Functions ¶
func AtomicPutExecutorTask ¶
func AtomicPutExecutorTask(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)
func AtomicPutRun ¶
func DeleteExecutor ¶
func DeleteExecutorTask ¶
func GetExecutor ¶
func GetExecutorTask ¶
func GetExecutorTasksCountByExecutor ¶ added in v0.6.0
func GetExecutorTasksForExecutor ¶ added in v0.6.0
func GetExecutorTasksForRun ¶
func GetExecutors ¶
func GetRunEtcdOrOST ¶
func GetRunEtcdOrOST(ctx context.Context, e *etcd.Store, dm *datamanager.DataManager, runID string) (*types.Run, error)
func OSTArchivesBaseDir ¶ added in v0.3.0
func OSTArchivesBaseDir() string
func OSTCacheDir ¶
func OSTCacheDir() string
func OSTCacheKey ¶
func OSTCachePath ¶
func OSTGetRun ¶
func OSTGetRun(dm *datamanager.DataManager, runID string) (*types.Run, error)
func OSTGetRunConfig ¶
func OSTGetRunConfig(dm *datamanager.DataManager, runConfigID string) (*types.RunConfig, error)
func OSTRunTaskArchivePath ¶
func OSTRunTaskIDFromPath ¶ added in v0.3.0
func OSTRunTaskLogsBaseDir ¶
func OSTRunTaskLogsDataDir ¶
func OSTRunTaskLogsRunPath ¶
func OSTRunTaskLogsRunsDir ¶
func OSTRunTaskSetupLogPath ¶
func OSTRunTaskStepLogPath ¶
func OSTSaveRunAction ¶
func OSTSaveRunAction(r *types.Run) (*datamanager.Action, error)
func OSTSaveRunConfigAction ¶
func OSTSaveRunConfigAction(rc *types.RunConfig) (*datamanager.Action, error)
func PutExecutor ¶
func UpdateExecutorTaskStatus ¶
func UpdateExecutorTaskStatus(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.