1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
# Copyright 2011-2013 Amazon.com, Inc. or its affiliates. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"). You
# may not use this file except in compliance with the License. A copy of
# the License is located at
#
# http://aws.amazon.com/apache2.0/
#
# or in the "license" file accompanying this file. This file 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.
module AWS
class SimpleWorkflow
# Domains are used to organize workflows types and activities for
# an account.
#
# @attr_reader [String,nil] description Returns
#
# @attr_reader [Integer,Symbol] retention_period Returns the retention
# period for this domain. The return value may be an integer (number
# of days history is kept around) or the symbol `:none`, implying
# no expiry of closed workflow executions.
#
# @attr_reader [Symbol] status Returns the domain's status. Status will
# be either `:registered` or `:deprecated`.
#
class Domain < Resource
include OptionFormatters
# @api private
def initialize name, options = {}
@name = name.to_s
super(options)
end
# @return [String] Returns the name of this domain.
attr_reader :name
info_attribute :description, :static => true
info_attribute :status, :to_sym => true
config_attribute :retention_period,
:from => 'workflowExecutionRetentionPeriodInDays',
:duration => true,
:static => true
# @return [WorkflowTypeCollection]
def workflow_types
WorkflowTypeCollection.new(self)
end
# @return [ActivityTypeCollection]
def activity_types
ActivityTypeCollection.new(self)
end
# @return [WorkflowExecutionCollection]
def workflow_executions
WorkflowExecutionCollection.new(self)
end
# @return [DecisionTaskCollection]
def decision_tasks
DecisionTaskCollection.new(self)
end
# @return [ActivityTaskCollection]
def activity_tasks
ActivityTaskCollection.new(self)
end
# @return [Boolean] Returns true if this domain has been deprecated.
def deprecated?
self.status == :deprecated
end
# Deprecates the domain. After a domain has been deprecated it cannot
# be used to create new workflow executions or register new types.
# However, you can still use visibility actions on this domain.
#
# Deprecating a domain also deprecates all activity and workflow
# types registered in the domain. Executions that were started
# before the domain was deprecated will continue to run.
#
# @return [nil]
#
def deprecate
client.deprecate_domain(:name => name)
nil
end
alias_method :delete, :deprecate
provider(:describe_domain) do |provider|
provider.provides *info_attributes.keys
provider.provides *config_attributes.keys
provider.find do |resp|
if resp.data['domainInfo']['name'] == name
resp.data['domainInfo'].merge(resp.data['configuration'])
end
end
end
provider(:list_domains) do |provider|
provider.provides *info_attributes.keys
provider.find do |resp|
resp.data['domainInfos'].find{|d| d['name'] == name }
end
end
protected
def resource_identifiers
[[:name,name]]
end
end
end
end
|
