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) (ok bool, err error)
- func DeletePipeline(name string) (ok bool, err error)
- func DeletePosition(name string) (ok bool, 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 GetRecord(pipeName string) (r *pipeline.RecordPosition, err error)
- func InstancePrefix() string
- func PipelinePrefix() string
- func PositionPrefix() string
- func RecordPrefix() 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)
- func UpdateRecord(p *pipeline.RecordPosition) (err error)
- func UpdateRecordSafe(pipeName string, opts ...pipeline.OptionRecord) (ok bool, err error)
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 GetRecord ¶ added in v1.1.3
func GetRecord(pipeName string) (r *pipeline.RecordPosition, err error)
GetRecord get pipeline record 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 RecordPrefix ¶ added in v1.1.3
func RecordPrefix() string
RecordPrefix returns etcd record prefix
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
func UpdateRecord ¶ added in v1.1.3
func UpdateRecord(p *pipeline.RecordPosition) (err error)
UpdatePosition update pipeline record position in etcd
func UpdateRecordSafe ¶ added in v1.1.3
func UpdateRecordSafe(pipeName string, opts ...pipeline.OptionRecord) (ok bool, err error)
UpdateRecordSafe update pipeline record position in etcd in safe mode. there will be version judgment when updating
Types ¶
This section is empty.
Source Files