Documentation ¶
Index ¶
- Constants
- Variables
- func EtcdExecutorKey(taskID string) string
- func EtcdRunKey(runID string) string
- func EtcdTaskKey(taskID string) string
- func NewErrNotExist(err error) error
- func NewRunEvent(ctx context.Context, e *etcd.Store, runID string, phase types.RunPhase, ...) (*types.RunEvent, error)
- type DataType
- type ErrNotExist
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") EtcdCompactChangeGroupsLockKey = path.Join(EtcdSchedulerBaseDir, "compactchangegroupslock") EtcdCacheCleanerLockKey = path.Join(EtcdSchedulerBaseDir, "locks", "cachecleaner") EtcdTaskUpdaterLockKey = path.Join(EtcdSchedulerBaseDir, "locks", "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 EtcdTaskKey ¶
func NewErrNotExist ¶
Types ¶
type ErrNotExist ¶
type ErrNotExist struct {
// contains filtered or unexported fields
}
func (ErrNotExist) Error ¶
func (e ErrNotExist) Error() string
Click to show internal directories.
Click to hide internal directories.