Class: PipeFitter::DataPipelineClient

Inherits:
Object
  • Object
show all
Defined in:
lib/pipe_fitter/data_pipeline_client.rb

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ DataPipelineClient

Returns a new instance of DataPipelineClient.



7
8
9
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 7

def initialize(options)
  @options = options.map { |k, v| [k.to_sym, v] }.to_h
end

Instance Method Details

#activate(pipeline_id, parameter_file, start_timestamp) ⇒ Object 



42
43
44
45
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 42

def activate(pipeline_id, parameter_file, start_timestamp)
  p = parameter_file ? Pipeline.load_yaml(parameter_file) : Pipeline.new
  exec(:activate_pipeline, p.activate_opts(pipeline_id, start_timestamp)).to_h
end

#create(pipeline) ⇒ Object 



37
38
39
40
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 37

def create(pipeline)
  res = exec(:create_pipeline, pipeline.create_opts)
  [res.pipeline_id, put_definition(res.pipeline_id, pipeline)]
end

#definition(pipeline_id) ⇒ Object 



26
27
28
29
30
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 26

def definition(pipeline_id)
  res = exec(:get_pipeline_definition, pipeline_id: pipeline_id)
  desc = description(pipeline_id)
  Pipeline.create(res.to_h, desc.to_h)
end

#diff(pipeline_id, definition_file, format = :color) ⇒ Object 



16
17
18
19
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 16

def diff(pipeline_id, definition_file, format = :color)
  p = Pipeline.load_yaml(definition_file)
  definition(pipeline_id).diff(p, format.to_sym)
end

#put_definition(pipeline_id, pipeline) ⇒ Object 



32
33
34
35
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 32

def put_definition(pipeline_id, pipeline)
  sync_tags(pipeline_id, pipeline)
  exec(:put_pipeline_definition, pipeline.put_definition_opts(pipeline_id)).to_h
end

#register(definition_file) ⇒ Object 



11
12
13
14
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 11

def register(definition_file)
  p = Pipeline.load_yaml(definition_file)
  create(p)
end

#update(pipeline_id, definition_file) ⇒ Object 



21
22
23
24
 
# File 'lib/pipe_fitter/data_pipeline_client.rb', line 21

def update(pipeline_id, definition_file)
  p = Pipeline.load_yaml(definition_file)
  put_definition(pipeline_id, p)
end