Documentation ¶
Index ¶
- func AllInstance() (all []*pipeline.Instance, err error)
- func AllInstanceMap() (all map[string]*pipeline.Instance, err error)
- func AllPipelines() (list []*pipeline.Pipeline, err error)
- func AllPipelinesMap() (mapping map[string]*pipeline.Pipeline, err error)
- func CreatePipeline(d *pipeline.Pipeline, opts ...clientv3.OpOption) (ok bool, err error)
- func DeleteCompletePipeline(name string) (err error)
- func DeletePipeline(name string) (err error)
- func DeletePosition(name string) (err error)
- func GetInstance(pipeName string) (ins *pipeline.Instance, err error)
- func GetPipeline(name string) (p *pipeline.Pipeline, err error)
- func GetPosition(pipeName string) (p *pipeline.Position, err error)
- func InstancePrefix() string
- func PipelinePrefix() string
- func PositionPrefix() string
- func UpdatePipeline(pipeName string, opts ...pipeline.OptionPipeline) (ok bool, err error)
- func UpdatePosition(p *pipeline.Position) (err error)
- func UpdatePositionSafe(pipeName string, opts ...pipeline.OptionPosition) (ok bool, err error)
- type PagePipeline
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllInstance ¶
AllInstance returns all pipeline instances in array form
func AllInstanceMap ¶
AllInstanceMap returns all pipeline instances in map form
func AllPipelines ¶
AllPipelines get all info of pipelines from etcd in array form
func AllPipelinesMap ¶
AllPipelinesMap returns all pipelines from etcd in map form
func CreatePipeline ¶
CreatePipeline write pipeline info to etcd
func DeleteCompletePipeline ¶
DeleteCompletePipeline delete pipeline, contains pipeline info, pipeline position
func DeletePipeline ¶
DeletePipeline delete pipeline info by name
func DeletePosition ¶
DeletePosition delete pipeline positon by pipeline name in etcd
func GetInstance ¶
GetInstance get a pipeline instance from etcd get by pipeline name pipeName
func GetPipeline ¶
GetPipeline get pipeline info from etcd
func GetPosition ¶
GetPosition get pipeline position from etcd
func InstancePrefix ¶
func InstancePrefix() string
InstancePrefix returns etcd prefix of pipeline instance
func PipelinePrefix ¶
func PipelinePrefix() string
PipelinePrefix returns etcd prefix of pipeline info
func PositionPrefix ¶
func PositionPrefix() string
PositionPrefix returns etcd prefix of pipeline position
func UpdatePipeline ¶
func UpdatePipeline(pipeName string, opts ...pipeline.OptionPipeline) (ok bool, err error)
UpdatePipeline update pipeline info in etcd
func UpdatePosition ¶
UpdatePosition update pipeline position in etcd
func UpdatePositionSafe ¶
func UpdatePositionSafe(pipeName string, opts ...pipeline.OptionPosition) (ok bool, err error)
UpdatePositionSafe update pipeline position in etcd in safe mode. there will be version judgment when updating
Types ¶
type PagePipeline ¶
PagePipeline for pipeline pages
func PagePipelines ¶
func PagePipelines(page int, size int) (res *PagePipeline, err error)
PagePipelines get a PagePipeline by page and size