dao_sche

Documentation

Index

• func DeletePipelineBind(pName string) (ok bool, err error)
• func GetPipelineBind() (pb *scheduler.PipelineBind, err error)
• func PipeBindPrefix() string
• func SchedulerPrefix() string
• func UpdatePipelineBind(pName string, nName string) (ok bool, err error)
• func UpdatePipelineBindIfNotExist(pName string, nName string) (err error)

Functions

func DeletePipelineBind

func DeletePipelineBind(pName string) (ok bool, err error)

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 SchedulerPrefix

func SchedulerPrefix() string

SchedulerPrefix etcd prefix of scheduler

func UpdatePipelineBind

func UpdatePipelineBind(pName string, nName string) (ok bool, err error)

UpdatePipelineBind update pipeline bind ignore exists

func UpdatePipelineBindIfNotExist

func UpdatePipelineBindIfNotExist(pName string, nName string) (err error)

UpdatePipelineBindIfNotExist update pipeline bind if the pipeline not exist in pipeline bind