manager

Documentation

Overview

Copyright 2018 StreamSets Inc. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2018 StreamSets Inc. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type Manager
  • func NewManager(config execution.Config, runtimeInfo *common.RuntimeInfo, ...) (Manager, error)
• type PipelineManager
  • func (p *PipelineManager) CreatePreviewer(pipelineId string) (execution.Previewer, error)
  • func (p *PipelineManager) GetPreviewer(previewerId string) (execution.Previewer, error)
  • func (p *PipelineManager) GetRunner(pipelineId string) execution.Runner
  • func (p *PipelineManager) ResetOffset(pipelineId string) error
  • func (p *PipelineManager) StartPipeline(pipelineId string, runtimeParameters map[string]interface{}) (*common.PipelineState, error)
  • func (p *PipelineManager) StopPipeline(pipelineId string) (*common.PipelineState, error)

Types

type Manager

type Manager interface {
	CreatePreviewer(pipelineId string) (execution.Previewer, error)
	GetPreviewer(previewerId string) (execution.Previewer, error)
	GetRunner(pipelineId string) execution.Runner
	StartPipeline(
		pipelineId string,
		runtimeParameters map[string]interface{},
	) (*common.PipelineState, error)
	StopPipeline(pipelineId string) (*common.PipelineState, error)
	ResetOffset(pipelineId string) error
}

func NewManager

func NewManager(
	config execution.Config,
	runtimeInfo *common.RuntimeInfo,
	pipelineStoreTask store.PipelineStoreTask,
) (Manager, error)

type PipelineManager

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

func (*PipelineManager) CreatePreviewer

func (p *PipelineManager) CreatePreviewer(pipelineId string) (execution.Previewer, error)

func (*PipelineManager) GetPreviewer

func (p *PipelineManager) GetPreviewer(previewerId string) (execution.Previewer, error)

func (*PipelineManager) GetRunner

func (p *PipelineManager) GetRunner(pipelineId string) execution.Runner

func (*PipelineManager) ResetOffset

func (p *PipelineManager) ResetOffset(pipelineId string) error

func (*PipelineManager) StartPipeline

func (p *PipelineManager) StartPipeline(
	pipelineId string,
	runtimeParameters map[string]interface{},
) (*common.PipelineState, error)

func (*PipelineManager) StopPipeline

func (p *PipelineManager) StopPipeline(pipelineId string) (*common.PipelineState, error)