Documentation
¶
Index ¶
- func DeletePipelineBind(pName string) (ok bool, err error)
- func GetPipelineBind() (pb *scheduler.PipelineBind, err error)
- func PipeBindPrefix() string
- func PipelineLockPrefix() string
- func UpdatePipelineBind(pName string, nName string) (ok bool, err error)
- func UpdatePipelineBindIfNotExist(pName string, nName string) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeletePipelineBind ¶
DeletePipelineBind delete pipeline bind in etcd
func GetPipelineBind ¶
func GetPipelineBind() (pb *scheduler.PipelineBind, err error)
GetPipelineBind get pipeline bind from etcd
func PipeBindPrefix ¶
func PipeBindPrefix() string
PipeBindPrefix returns etcd prefix of pipeline bind
func PipelineLockPrefix ¶
func PipelineLockPrefix() string
PipelineLockPrefix returns etcd prefix of lock
func UpdatePipelineBind ¶
UpdatePipelineBind update pipeline bind ignore exists
func UpdatePipelineBindIfNotExist ¶
UpdatePipelineBindIfNotExist update pipeline bind if the pipeline not exist in pipeline bind
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.