Class: Cloudmunda::Zeebe::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/cloudmunda/zeebe/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(url: ::Cloudmunda.zeebe_url) ⇒ Client

Returns a new instance of Client.



10
11
12
 
# File 'lib/cloudmunda/zeebe/client.rb', line 10

def initialize(url: ::Cloudmunda.zeebe_url)
  @client = ::Zeebe::Client::GatewayProtocol::Gateway::Stub.new(url, authentication_headers)
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.



8
9
10
 
# File 'lib/cloudmunda/zeebe/client.rb', line 8

def client
  @client
end

Instance Method Details

#activate_jobs(params = {}) ⇒ Object 



14
15
16
17
 
# File 'lib/cloudmunda/zeebe/client.rb', line 14

def activate_jobs(params = {})
  run(:activate_jobs,
      ::Zeebe::Client::GatewayProtocol::ActivateJobsRequest.new(params))
end

#cancel_workflow_instance(params = {}) ⇒ Object 



19
20
21
22
 
# File 'lib/cloudmunda/zeebe/client.rb', line 19

def cancel_workflow_instance(params = {})
  run(:cancel_workflow_instance,
      ::Zeebe::Client::GatewayProtocol::CancelWorkflowInstanceRequest.new(params))
end

#complete_job(params = {}) ⇒ Object 



24
25
26
27
 
# File 'lib/cloudmunda/zeebe/client.rb', line 24

def complete_job(params = {})
  run(:complete_job,
      ::Zeebe::Client::GatewayProtocol::CompleteJobRequest.new(params))
end

#create_process_instance(params = {}) ⇒ Object 



29
30
31
32
 
# File 'lib/cloudmunda/zeebe/client.rb', line 29

def create_process_instance(params = {})
  run(:create_process_instance,
      ::Zeebe::Client::GatewayProtocol::CreateProcessInstanceRequest.new(params))
end

#deploy_process(params = {}) ⇒ Object 



34
35
36
37
 
# File 'lib/cloudmunda/zeebe/client.rb', line 34

def deploy_process(params = {})
  run(:deploy_process,
      ::Zeebe::Client::GatewayProtocol::DeployProcessRequest.new(params))
end

#fail_job(params = {}) ⇒ Object 



39
40
41
42
 
# File 'lib/cloudmunda/zeebe/client.rb', line 39

def fail_job(params = {})
  run(:fail_job,
      ::Zeebe::Client::GatewayProtocol::FailJobRequest.new(params))
end

#publish_message(params = {}) ⇒ Object 



49
50
51
52
 
# File 'lib/cloudmunda/zeebe/client.rb', line 49

def publish_message(params = {})
  run(:publish_message,
      ::Zeebe::Client::GatewayProtocol::PublishMessageRequest.new(params))
end

#resolve_incident(params = {}) ⇒ Object 



54
55
56
57
 
# File 'lib/cloudmunda/zeebe/client.rb', line 54

def resolve_incident(params = {})
  run(:resolve_incident,
      ::Zeebe::Client::GatewayProtocol::ResolveIncidentRequest.new(params))
end

#set_variables(params = {}) ⇒ Object 



59
60
61
62
 
# File 'lib/cloudmunda/zeebe/client.rb', line 59

def set_variables(params = {})
  run(:set_variables,
      ::Zeebe::Client::GatewayProtocol::SetVariablesRequest.new(params))
end

#throw_error(params = {}) ⇒ Object 



44
45
46
47
 
# File 'lib/cloudmunda/zeebe/client.rb', line 44

def throw_error(params = {})
  run(:throw_error,
      ::Zeebe::Client::GatewayProtocol::ThrowErrorRequest.new(params))
end

#topology(params = {}) ⇒ Object 



64
65
66
67
 
# File 'lib/cloudmunda/zeebe/client.rb', line 64

def topology(params = {})
  run(:topology,
      ::Zeebe::Client::GatewayProtocol::TopologyRequest.new(params))
end

#update_job_retries(params = {}) ⇒ Object 



69
70
71
72
 
# File 'lib/cloudmunda/zeebe/client.rb', line 69

def update_job_retries(params = {})
  run(:update_job_retries,
      ::Zeebe::Client::GatewayProtocol::UpdateJobRetriesRequest.new(params))
end