scheduler

Documentation

Index

• type PipelineBind
  • func EmptyPipelineBind() *PipelineBind
  • func (s *PipelineBind) Key() (key string)
  • func (s *PipelineBind) Unmarshal(val []byte) (err error)
  • func (s *PipelineBind) Val() (val string)

Types

type PipelineBind

type PipelineBind struct {
	Bindings map[string]string `json:"bindings"`
}

PipelineBind pipeline bind the node will watch pipeline bind, run pipeline instance if node get the bind, stop instance if node lost bind

func EmptyPipelineBind

func EmptyPipelineBind() *PipelineBind

EmptyPipelineBind returns a empty pipeline bind

func (*PipelineBind) Key

func (s *PipelineBind) Key() (key string)

Key generate etcd prefix of pipeline bind

func (*PipelineBind) Unmarshal

func (s *PipelineBind) Unmarshal(val []byte) (err error)

Unmarshal generate pipeline bind from json data

func (*PipelineBind) Val

func (s *PipelineBind) Val() (val string)

Val marshal pipeline bind to json data