dao_pipe

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
  • func PagePipelines(page int, size int) (res *PagePipeline, err error)

Functions

func AllInstance

func AllInstance() (all []*pipeline.Instance, err error)

func AllInstanceMap

func AllInstanceMap() (all map[string]*pipeline.Instance, err error)

func AllPipelines

func AllPipelines() (list []*pipeline.Pipeline, err error)

func AllPipelinesMap

func AllPipelinesMap() (mapping map[string]*pipeline.Pipeline, err error)

func CreatePipeline

func CreatePipeline(d *pipeline.Pipeline, opts ...clientv3.OpOption) (ok bool, err error)

func DeleteCompletePipeline

func DeleteCompletePipeline(name string) (err error)

func DeletePipeline

func DeletePipeline(name string) (err error)

func DeletePosition

func DeletePosition(name string) (err error)

func GetInstance

func GetInstance(pipeName string) (ins *pipeline.Instance, err error)

func GetPipeline

func GetPipeline(name string) (p *pipeline.Pipeline, err error)

func GetPosition

func GetPosition(pipeName string) (p *pipeline.Position, err error)

func InstancePrefix

func InstancePrefix() string

func PipelinePrefix

func PipelinePrefix() string

func PositionPrefix

func PositionPrefix() string

func UpdatePipeline

func UpdatePipeline(pipeName string, opts ...pipeline.OptionPipeline) (ok bool, err error)

func UpdatePosition

func UpdatePosition(p *pipeline.Position) (err error)

func UpdatePositionSafe

func UpdatePositionSafe(pipeName string, opts ...pipeline.OptionPosition) (ok bool, err error)

Types

type PagePipeline

type PagePipeline struct {
	Page  int
	Total int
	Data  []*pipeline.Pipeline
}

func PagePipelines

func PagePipelines(page int, size int) (res *PagePipeline, err error)