/* * Copyright 2018-2023 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. */ package com.amazonaws.services.mwaa.model; import java.io.Serializable; import javax.annotation.Generated; import com.amazonaws.protocol.StructuredPojo; import com.amazonaws.protocol.ProtocolMarshaller; /** *
* Defines the Apache Airflow log types to send to CloudWatch Logs. *
* * @see AWS API * Documentation */ @Generated("com.amazonaws:aws-java-sdk-code-generator") public class LoggingConfigurationInput implements Serializable, Cloneable, StructuredPojo { /** ** Publishes Airflow DAG processing logs to CloudWatch Logs. *
*/ private ModuleLoggingConfigurationInput dagProcessingLogs; /** ** Publishes Airflow scheduler logs to CloudWatch Logs. *
*/ private ModuleLoggingConfigurationInput schedulerLogs; /** ** Publishes Airflow task logs to CloudWatch Logs. *
*/ private ModuleLoggingConfigurationInput taskLogs; /** ** Publishes Airflow web server logs to CloudWatch Logs. *
*/ private ModuleLoggingConfigurationInput webserverLogs; /** ** Publishes Airflow worker logs to CloudWatch Logs. *
*/ private ModuleLoggingConfigurationInput workerLogs; /** ** Publishes Airflow DAG processing logs to CloudWatch Logs. *
* * @param dagProcessingLogs * Publishes Airflow DAG processing logs to CloudWatch Logs. */ public void setDagProcessingLogs(ModuleLoggingConfigurationInput dagProcessingLogs) { this.dagProcessingLogs = dagProcessingLogs; } /** ** Publishes Airflow DAG processing logs to CloudWatch Logs. *
* * @return Publishes Airflow DAG processing logs to CloudWatch Logs. */ public ModuleLoggingConfigurationInput getDagProcessingLogs() { return this.dagProcessingLogs; } /** ** Publishes Airflow DAG processing logs to CloudWatch Logs. *
* * @param dagProcessingLogs * Publishes Airflow DAG processing logs to CloudWatch Logs. * @return Returns a reference to this object so that method calls can be chained together. */ public LoggingConfigurationInput withDagProcessingLogs(ModuleLoggingConfigurationInput dagProcessingLogs) { setDagProcessingLogs(dagProcessingLogs); return this; } /** ** Publishes Airflow scheduler logs to CloudWatch Logs. *
* * @param schedulerLogs * Publishes Airflow scheduler logs to CloudWatch Logs. */ public void setSchedulerLogs(ModuleLoggingConfigurationInput schedulerLogs) { this.schedulerLogs = schedulerLogs; } /** ** Publishes Airflow scheduler logs to CloudWatch Logs. *
* * @return Publishes Airflow scheduler logs to CloudWatch Logs. */ public ModuleLoggingConfigurationInput getSchedulerLogs() { return this.schedulerLogs; } /** ** Publishes Airflow scheduler logs to CloudWatch Logs. *
* * @param schedulerLogs * Publishes Airflow scheduler logs to CloudWatch Logs. * @return Returns a reference to this object so that method calls can be chained together. */ public LoggingConfigurationInput withSchedulerLogs(ModuleLoggingConfigurationInput schedulerLogs) { setSchedulerLogs(schedulerLogs); return this; } /** ** Publishes Airflow task logs to CloudWatch Logs. *
* * @param taskLogs * Publishes Airflow task logs to CloudWatch Logs. */ public void setTaskLogs(ModuleLoggingConfigurationInput taskLogs) { this.taskLogs = taskLogs; } /** ** Publishes Airflow task logs to CloudWatch Logs. *
* * @return Publishes Airflow task logs to CloudWatch Logs. */ public ModuleLoggingConfigurationInput getTaskLogs() { return this.taskLogs; } /** ** Publishes Airflow task logs to CloudWatch Logs. *
* * @param taskLogs * Publishes Airflow task logs to CloudWatch Logs. * @return Returns a reference to this object so that method calls can be chained together. */ public LoggingConfigurationInput withTaskLogs(ModuleLoggingConfigurationInput taskLogs) { setTaskLogs(taskLogs); return this; } /** ** Publishes Airflow web server logs to CloudWatch Logs. *
* * @param webserverLogs * Publishes Airflow web server logs to CloudWatch Logs. */ public void setWebserverLogs(ModuleLoggingConfigurationInput webserverLogs) { this.webserverLogs = webserverLogs; } /** ** Publishes Airflow web server logs to CloudWatch Logs. *
* * @return Publishes Airflow web server logs to CloudWatch Logs. */ public ModuleLoggingConfigurationInput getWebserverLogs() { return this.webserverLogs; } /** ** Publishes Airflow web server logs to CloudWatch Logs. *
* * @param webserverLogs * Publishes Airflow web server logs to CloudWatch Logs. * @return Returns a reference to this object so that method calls can be chained together. */ public LoggingConfigurationInput withWebserverLogs(ModuleLoggingConfigurationInput webserverLogs) { setWebserverLogs(webserverLogs); return this; } /** ** Publishes Airflow worker logs to CloudWatch Logs. *
* * @param workerLogs * Publishes Airflow worker logs to CloudWatch Logs. */ public void setWorkerLogs(ModuleLoggingConfigurationInput workerLogs) { this.workerLogs = workerLogs; } /** ** Publishes Airflow worker logs to CloudWatch Logs. *
* * @return Publishes Airflow worker logs to CloudWatch Logs. */ public ModuleLoggingConfigurationInput getWorkerLogs() { return this.workerLogs; } /** ** Publishes Airflow worker logs to CloudWatch Logs. *
* * @param workerLogs * Publishes Airflow worker logs to CloudWatch Logs. * @return Returns a reference to this object so that method calls can be chained together. */ public LoggingConfigurationInput withWorkerLogs(ModuleLoggingConfigurationInput workerLogs) { setWorkerLogs(workerLogs); return this; } /** * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be * redacted from this string using a placeholder value. * * @return A string representation of this object. * * @see java.lang.Object#toString() */ @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("{"); if (getDagProcessingLogs() != null) sb.append("DagProcessingLogs: ").append(getDagProcessingLogs()).append(","); if (getSchedulerLogs() != null) sb.append("SchedulerLogs: ").append(getSchedulerLogs()).append(","); if (getTaskLogs() != null) sb.append("TaskLogs: ").append(getTaskLogs()).append(","); if (getWebserverLogs() != null) sb.append("WebserverLogs: ").append(getWebserverLogs()).append(","); if (getWorkerLogs() != null) sb.append("WorkerLogs: ").append(getWorkerLogs()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof LoggingConfigurationInput == false) return false; LoggingConfigurationInput other = (LoggingConfigurationInput) obj; if (other.getDagProcessingLogs() == null ^ this.getDagProcessingLogs() == null) return false; if (other.getDagProcessingLogs() != null && other.getDagProcessingLogs().equals(this.getDagProcessingLogs()) == false) return false; if (other.getSchedulerLogs() == null ^ this.getSchedulerLogs() == null) return false; if (other.getSchedulerLogs() != null && other.getSchedulerLogs().equals(this.getSchedulerLogs()) == false) return false; if (other.getTaskLogs() == null ^ this.getTaskLogs() == null) return false; if (other.getTaskLogs() != null && other.getTaskLogs().equals(this.getTaskLogs()) == false) return false; if (other.getWebserverLogs() == null ^ this.getWebserverLogs() == null) return false; if (other.getWebserverLogs() != null && other.getWebserverLogs().equals(this.getWebserverLogs()) == false) return false; if (other.getWorkerLogs() == null ^ this.getWorkerLogs() == null) return false; if (other.getWorkerLogs() != null && other.getWorkerLogs().equals(this.getWorkerLogs()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getDagProcessingLogs() == null) ? 0 : getDagProcessingLogs().hashCode()); hashCode = prime * hashCode + ((getSchedulerLogs() == null) ? 0 : getSchedulerLogs().hashCode()); hashCode = prime * hashCode + ((getTaskLogs() == null) ? 0 : getTaskLogs().hashCode()); hashCode = prime * hashCode + ((getWebserverLogs() == null) ? 0 : getWebserverLogs().hashCode()); hashCode = prime * hashCode + ((getWorkerLogs() == null) ? 0 : getWorkerLogs().hashCode()); return hashCode; } @Override public LoggingConfigurationInput clone() { try { return (LoggingConfigurationInput) super.clone(); } catch (CloneNotSupportedException e) { throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e); } } @com.amazonaws.annotation.SdkInternalApi @Override public void marshall(ProtocolMarshaller protocolMarshaller) { com.amazonaws.services.mwaa.model.transform.LoggingConfigurationInputMarshaller.getInstance().marshall(this, protocolMarshaller); } }