# frozen_string_literal: true # #Kubernetes # # No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator) # # The version of the OpenAPI document: unversioned # # Generated by: https://openapi-generator.tech # OpenAPI Generator version: 6.5.0-SNAPSHOT # require 'date' require 'time' module Zilla # CronJobSpec describes how the job execution will look like and when it will actually run. class IoK8sApiBatchV1CronJobSpec # Specifies how to treat concurrent executions of a Job. Valid values are: - \"Allow\" (default): allows CronJobs to run concurrently; - \"Forbid\": forbids concurrent runs, skipping next run if previous run hasn't finished yet; - \"Replace\": cancels currently running job and replaces it with a new one attr_accessor :concurrency_policy # The number of failed finished jobs to retain. Value must be non-negative integer. Defaults to 1. attr_accessor :failed_jobs_history_limit attr_accessor :job_template # The schedule in Cron format, see https://en.wikipedia.org/wiki/Cron. attr_accessor :schedule # Optional deadline in seconds for starting the job if it misses scheduled time for any reason. Missed jobs executions will be counted as failed ones. attr_accessor :starting_deadline_seconds # The number of successful finished jobs to retain. Value must be non-negative integer. Defaults to 3. attr_accessor :successful_jobs_history_limit # This flag tells the controller to suspend subsequent executions, it does not apply to already started executions. Defaults to false. attr_accessor :suspend # The time zone name for the given schedule, see https://en.wikipedia.org/wiki/List_of_tz_database_time_zones. If not specified, this will default to the time zone of the kube-controller-manager process. The set of valid time zone names and the time zone offset is loaded from the system-wide time zone database by the API server during CronJob validation and the controller manager during execution. If no system-wide time zone database can be found a bundled version of the database is used instead. If the time zone name becomes invalid during the lifetime of a CronJob or due to a change in host configuration, the controller will stop creating new new Jobs and will create a system event with the reason UnknownTimeZone. More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones This is beta field and must be enabled via the `CronJobTimeZone` feature gate. attr_accessor :time_zone # Attribute mapping from ruby-style variable name to JSON key. def self.attribute_map { concurrency_policy: :concurrencyPolicy, failed_jobs_history_limit: :failedJobsHistoryLimit, job_template: :jobTemplate, schedule: :schedule, starting_deadline_seconds: :startingDeadlineSeconds, successful_jobs_history_limit: :successfulJobsHistoryLimit, suspend: :suspend, time_zone: :timeZone } end # Returns all the JSON keys this model knows about def self.acceptable_attributes attribute_map.values end # Attribute type mapping. def self.openapi_types { concurrency_policy: :String, failed_jobs_history_limit: :Integer, job_template: :IoK8sApiBatchV1JobTemplateSpec, schedule: :String, starting_deadline_seconds: :Integer, successful_jobs_history_limit: :Integer, suspend: :Boolean, time_zone: :String } end # List of attributes with nullable: true def self.openapi_nullable Set.new([]) end # Initializes the object # @param [Hash] attributes Model attributes in the form of hash def initialize(attributes = {}) unless attributes.is_a?(Hash) raise ArgumentError, 'The input argument (attributes) must be a hash in `Zilla::IoK8sApiBatchV1CronJobSpec` initialize method' end # check to see if the attribute exists and convert string to symbol for hash key attributes = attributes.each_with_object({}) do |(k, v), h| unless self.class.attribute_map.key?(k.to_sym) raise ArgumentError, "`#{k}` is not a valid attribute in `Zilla::IoK8sApiBatchV1CronJobSpec`. Please check the name to make sure it's valid. List of attributes: " + self.class.attribute_map.keys.inspect end h[k.to_sym] = v end self.concurrency_policy = attributes[:concurrency_policy] if attributes.key?(:concurrency_policy) if attributes.key?(:failed_jobs_history_limit) self.failed_jobs_history_limit = attributes[:failed_jobs_history_limit] end self.job_template = attributes[:job_template] if attributes.key?(:job_template) self.schedule = attributes[:schedule] if attributes.key?(:schedule) if attributes.key?(:starting_deadline_seconds) self.starting_deadline_seconds = attributes[:starting_deadline_seconds] end if attributes.key?(:successful_jobs_history_limit) self.successful_jobs_history_limit = attributes[:successful_jobs_history_limit] end self.suspend = attributes[:suspend] if attributes.key?(:suspend) return unless attributes.key?(:time_zone) self.time_zone = attributes[:time_zone] end # Show invalid properties with the reasons. Usually used together with valid? # @return Array for valid properties with the reasons def list_invalid_properties invalid_properties = [] invalid_properties.push('invalid value for "job_template", job_template cannot be nil.') if @job_template.nil? invalid_properties.push('invalid value for "schedule", schedule cannot be nil.') if @schedule.nil? invalid_properties end # Check to see if the all the properties in the model are valid # @return true if the model is valid def valid? return false if @job_template.nil? return false if @schedule.nil? true end # Checks equality by comparing each attribute. # @param [Object] Object to be compared def ==(other) return true if equal?(other) self.class == other.class && concurrency_policy == other.concurrency_policy && failed_jobs_history_limit == other.failed_jobs_history_limit && job_template == other.job_template && schedule == other.schedule && starting_deadline_seconds == other.starting_deadline_seconds && successful_jobs_history_limit == other.successful_jobs_history_limit && suspend == other.suspend && time_zone == other.time_zone end # @see the `==` method # @param [Object] Object to be compared def eql?(other) self == other end # Calculates hash code according to all attributes. # @return [Integer] Hash code def hash [concurrency_policy, failed_jobs_history_limit, job_template, schedule, starting_deadline_seconds, successful_jobs_history_limit, suspend, time_zone].hash end # Builds the object from hash # @param [Hash] attributes Model attributes in the form of hash # @return [Object] Returns the model itself def self.build_from_hash(attributes) new.build_from_hash(attributes) end # Builds the object from hash # @param [Hash] attributes Model attributes in the form of hash # @return [Object] Returns the model itself def build_from_hash(attributes) return nil unless attributes.is_a?(Hash) attributes = attributes.transform_keys(&:to_sym) self.class.openapi_types.each_pair do |key, type| if attributes[self.class.attribute_map[key]].nil? && self.class.openapi_nullable.include?(key) send("#{key}=", nil) elsif type =~ /\AArray<(.*)>/i # check to ensure the input is an array given that the attribute # is documented as an array but the input is not if attributes[self.class.attribute_map[key]].is_a?(Array) send("#{key}=", attributes[self.class.attribute_map[key]].map do |v| _deserialize(::Regexp.last_match(1), v) end) end elsif !attributes[self.class.attribute_map[key]].nil? send("#{key}=", _deserialize(type, attributes[self.class.attribute_map[key]])) end end self end # Deserializes the data based on type # @param string type Data type # @param string value Value to be deserialized # @return [Object] Deserialized data def _deserialize(type, value) case type.to_sym when :Time Time.parse(value) when :Date Date.parse(value) when :String value.to_s when :Integer value.to_i when :Float value.to_f when :Boolean if value.to_s =~ /\A(true|t|yes|y|1)\z/i true else false end when :Object # generic object (usually a Hash), return directly value when /\AArray<(?.+)>\z/ inner_type = Regexp.last_match[:inner_type] value.map { |v| _deserialize(inner_type, v) } when /\AHash<(?.+?), (?.+)>\z/ k_type = Regexp.last_match[:k_type] v_type = Regexp.last_match[:v_type] {}.tap do |hash| value.each do |k, v| hash[_deserialize(k_type, k)] = _deserialize(v_type, v) end end else # model # models (e.g. Pet) or oneOf klass = Zilla.const_get(type) klass.respond_to?(:openapi_one_of) ? klass.build(value) : klass.build_from_hash(value) end end # Returns the string representation of the object # @return [String] String presentation of the object def to_s to_hash.to_s end # to_body is an alias to to_hash (backward compatibility) # @return [Hash] Returns the object in the form of hash def to_body to_hash end # Returns the object in the form of hash # @return [Hash] Returns the object in the form of hash def to_hash hash = {} self.class.attribute_map.each_pair do |attr, param| value = send(attr) if value.nil? is_nullable = self.class.openapi_nullable.include?(attr) next if !is_nullable || (is_nullable && !instance_variable_defined?(:"@#{attr}")) end hash[param] = _to_hash(value) end hash end # Outputs non-array value in the form of hash # For object, use to_hash. Otherwise, just return the value # @param [Object] value Any valid value # @return [Hash] Returns the value in the form of hash def _to_hash(value) if value.is_a?(Array) value.compact.map { |v| _to_hash(v) } elsif value.is_a?(Hash) {}.tap do |hash| value.each { |k, v| hash[k] = _to_hash(v) } end elsif value.respond_to? :to_hash value.to_hash else value end end end end