alibabacloud

Documentation

Index

• type Pipeline
  • func ParsePipeline(task *collecttask.CollectTask) (*Pipeline, error)
  • func (p *Pipeline) Key() string
  • func (p *Pipeline) SetupConsumer(st *api.SubTask) error
  • func (p *Pipeline) Start() error
  • func (p *Pipeline) Stop()
  • func (p *Pipeline) Update(f func(api.Pipeline))
  • func (p *Pipeline) View(f func(api.Pipeline))

Types

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func ParsePipeline

func ParsePipeline(task *collecttask.CollectTask) (*Pipeline, error)

func (*Pipeline) Key

func (p *Pipeline) Key() string

func (*Pipeline) SetupConsumer

func (p *Pipeline) SetupConsumer(st *api.SubTask) error

func (*Pipeline) Start

func (p *Pipeline) Start() error

func (*Pipeline) Stop

func (p *Pipeline) Stop()

func (*Pipeline) Update

func (p *Pipeline) Update(f func(api.Pipeline))

func (*Pipeline) View

func (p *Pipeline) View(f func(api.Pipeline))