store

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 GetExecutorTasks(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 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 OSTRootGroup(group string) string
• 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 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 OSTSubGroupTypes(group string) []string
• func OSTSubGroups(group string) []string
• func OSTSubGroupsAndGroupTypes(group string) []string
• 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

const (
	MaxChangegroupNameLength = 256
)

Functions

func AtomicPutExecutorTask

func AtomicPutExecutorTask(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)

func AtomicPutRun

func AtomicPutRun(ctx context.Context, e *etcd.Store, r *types.Run, runEvent *types.RunEvent, cgt *types.ChangeGroupsUpdateToken) (*types.Run, error)

func DeleteExecutor

func DeleteExecutor(ctx context.Context, e *etcd.Store, executorID string) error

func DeleteExecutorTask

func DeleteExecutorTask(ctx context.Context, e *etcd.Store, etID string) error

func DeleteRun

func DeleteRun(ctx context.Context, e *etcd.Store, runID string) error

func GetExecutor

func GetExecutor(ctx context.Context, e *etcd.Store, executorID string) (*types.Executor, error)

func GetExecutorTask

func GetExecutorTask(ctx context.Context, e *etcd.Store, etID string) (*types.ExecutorTask, error)

func GetExecutorTasks

func GetExecutorTasks(ctx context.Context, e *etcd.Store, executorID string) ([]*types.ExecutorTask, error)

func GetExecutorTasksForRun

func GetExecutorTasksForRun(ctx context.Context, e *etcd.Store, runID string) ([]*types.ExecutorTask, error)

func GetExecutors

func GetExecutors(ctx context.Context, e *etcd.Store) ([]*types.Executor, error)

func GetRun

func GetRun(ctx context.Context, e *etcd.Store, runID string) (*types.Run, int64, error)

func GetRunEtcdOrOST

func GetRunEtcdOrOST(ctx context.Context, e *etcd.Store, dm *datamanager.DataManager, runID string) (*types.Run, error)

func GetRuns

func GetRuns(ctx context.Context, e *etcd.Store) ([]*types.Run, error)

func OSTCacheDir

func OSTCacheDir() string

func OSTCacheKey

func OSTCacheKey(p string) string

func OSTCachePath

func OSTCachePath(key string) string

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 OSTRootGroup

func OSTRootGroup(group string) string

func OSTRunTaskArchivePath

func OSTRunTaskArchivePath(rtID string, step int) string

func OSTRunTaskArchivesBaseDir

func OSTRunTaskArchivesBaseDir(rtID string) string

func OSTRunTaskArchivesDataDir

func OSTRunTaskArchivesDataDir(rtID string) string

func OSTRunTaskArchivesRunPath

func OSTRunTaskArchivesRunPath(rtID, runID string) string

func OSTRunTaskArchivesRunsDir

func OSTRunTaskArchivesRunsDir(rtID string) string

func OSTRunTaskLogsBaseDir

func OSTRunTaskLogsBaseDir(rtID string) string

func OSTRunTaskLogsDataDir

func OSTRunTaskLogsDataDir(rtID string) string

func OSTRunTaskLogsRunPath

func OSTRunTaskLogsRunPath(rtID, runID string) string

func OSTRunTaskLogsRunsDir

func OSTRunTaskLogsRunsDir(rtID string) string

func OSTRunTaskSetupLogPath

func OSTRunTaskSetupLogPath(rtID string) string

func OSTRunTaskStepLogPath

func OSTRunTaskStepLogPath(rtID string, step int) string

func OSTSaveRunAction

func OSTSaveRunAction(r *types.Run) (*datamanager.Action, error)

func OSTSaveRunConfigAction

func OSTSaveRunConfigAction(rc *types.RunConfig) (*datamanager.Action, error)

func OSTSubGroupTypes

func OSTSubGroupTypes(group string) []string

func OSTSubGroups

func OSTSubGroups(group string) []string

func OSTSubGroupsAndGroupTypes

func OSTSubGroupsAndGroupTypes(group string) []string

func OSTUpdateRunCounterAction

func OSTUpdateRunCounterAction(ctx context.Context, c uint64, group string) (*datamanager.Action, error)

func PutExecutor

func PutExecutor(ctx context.Context, e *etcd.Store, executor *types.Executor) (*types.Executor, error)

func UpdateExecutorTaskStatus

func UpdateExecutorTaskStatus(ctx context.Context, e *etcd.Store, et *types.ExecutorTask) (*types.ExecutorTask, error)