managers

Documentation

Index

• type PipelineManager
  • func GetManagerForPipeline(client client.Client, pipeline pipelinetypes.Pipeline) *PipelineManager
  • func (p *PipelineManager) IsRunning() bool
  • func (p *PipelineManager) Reload(cfg pipelinetypes.Pipeline)
  • func (p *PipelineManager) Start() error
  • func (p *PipelineManager) Stop()

Types

type PipelineManager

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

PipelineManager is an object for watching MinIO buckets for changes and queuing processing in a pipeline. It exports a method for reloading configuration changes.

func GetManagerForPipeline

func GetManagerForPipeline(client client.Client, pipeline pipelinetypes.Pipeline) *PipelineManager

GetManagerForPipeline returns a PipelineManager for the given transformation pipeline. If one already exists globally, it is returned.

func (*PipelineManager) IsRunning

func (p *PipelineManager) IsRunning() bool

IsRunning returns true if the pipeline manager is already running.

func (*PipelineManager) Reload

func (p *PipelineManager) Reload(cfg pipelinetypes.Pipeline)

Reload reloads the bucket watchers with the given pipeline configuration.

func (*PipelineManager) Start

func (p *PipelineManager) Start() error

Start starts the pipeline manager.

func (*PipelineManager) Stop

func (p *PipelineManager) Stop()

Stop stops the bucket watching goroutine.