// This file is auto-generated, don't edit it
import * as $dara from '@darabonba/typescript';


export class UpdatePipelineRequestExecutePolicyRunOnce extends $dara.Model {
  /**
   * @remarks
   * The start timestamp.
   * 
   * @example
   * 1772519013
   */
  fromTime?: number;
  /**
   * @remarks
   * The end timestamp.
   * 
   * @example
   * 1772605413
   */
  toTime?: number;
  static names(): { [key: string]: string } {
    return {
      fromTime: 'fromTime',
      toTime: 'toTime',
    };
  }

  static types(): { [key: string]: any } {
    return {
      fromTime: 'number',
      toTime: 'number',
    };
  }

  validate() {
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestExecutePolicyScheduled extends $dara.Model {
  /**
   * @remarks
   * The start timestamp.
   * 
   * @example
   * 1772519013
   */
  fromTime?: number;
  /**
   * @remarks
   * The execution interval.
   * 
   * @example
   * 86400
   */
  interval?: string;
  static names(): { [key: string]: string } {
    return {
      fromTime: 'fromTime',
      interval: 'interval',
    };
  }

  static types(): { [key: string]: any } {
    return {
      fromTime: 'number',
      interval: 'string',
    };
  }

  validate() {
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestExecutePolicy extends $dara.Model {
  /**
   * @remarks
   * The execution mode.
   * 
   * @example
   * runOnce
   */
  mode?: string;
  /**
   * @remarks
   * The one-time execution configuration.
   */
  runOnce?: UpdatePipelineRequestExecutePolicyRunOnce;
  /**
   * @remarks
   * The scheduled execution configuration.
   */
  scheduled?: UpdatePipelineRequestExecutePolicyScheduled;
  static names(): { [key: string]: string } {
    return {
      mode: 'mode',
      runOnce: 'runOnce',
      scheduled: 'scheduled',
    };
  }

  static types(): { [key: string]: any } {
    return {
      mode: 'string',
      runOnce: UpdatePipelineRequestExecutePolicyRunOnce,
      scheduled: UpdatePipelineRequestExecutePolicyScheduled,
    };
  }

  validate() {
    if(this.runOnce && typeof (this.runOnce as any).validate === 'function') {
      (this.runOnce as any).validate();
    }
    if(this.scheduled && typeof (this.scheduled as any).validate === 'function') {
      (this.scheduled as any).validate();
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestPipelineNodes extends $dara.Model {
  /**
   * @remarks
   * The node ID.
   * 
   * @example
   * node_1
   */
  id?: string;
  /**
   * @remarks
   * The node parameters.
   */
  parameters?: { [key: string]: any };
  /**
   * @remarks
   * The node type.
   * 
   * @example
   * dedup-fuzzy
   */
  type?: string;
  static names(): { [key: string]: string } {
    return {
      id: 'id',
      parameters: 'parameters',
      type: 'type',
    };
  }

  static types(): { [key: string]: any } {
    return {
      id: 'string',
      parameters: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' },
      type: 'string',
    };
  }

  validate() {
    if(this.parameters) {
      $dara.Model.validateMap(this.parameters);
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestPipeline extends $dara.Model {
  /**
   * @remarks
   * The pipeline nodes.
   */
  nodes?: UpdatePipelineRequestPipelineNodes[];
  static names(): { [key: string]: string } {
    return {
      nodes: 'nodes',
    };
  }

  static types(): { [key: string]: any } {
    return {
      nodes: { 'type': 'array', 'itemType': UpdatePipelineRequestPipelineNodes },
    };
  }

  validate() {
    if(Array.isArray(this.nodes)) {
      $dara.Model.validateArray(this.nodes);
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestSinkDataset extends $dara.Model {
  /**
   * @remarks
   * The dataset name.
   * 
   * @example
   * dataset_1
   */
  dataset?: string;
  /**
   * @remarks
   * The workspace ID.
   * 
   * @example
   * workspace-test
   */
  workspace?: string;
  static names(): { [key: string]: string } {
    return {
      dataset: 'dataset',
      workspace: 'workspace',
    };
  }

  static types(): { [key: string]: any } {
    return {
      dataset: 'string',
      workspace: 'string',
    };
  }

  validate() {
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestSink extends $dara.Model {
  /**
   * @remarks
   * The destination dataset configuration.
   */
  dataset?: UpdatePipelineRequestSinkDataset;
  /**
   * @remarks
   * The sink type.
   * 
   * @example
   * dataset
   */
  type?: string;
  static names(): { [key: string]: string } {
    return {
      dataset: 'dataset',
      type: 'type',
    };
  }

  static types(): { [key: string]: any } {
    return {
      dataset: UpdatePipelineRequestSinkDataset,
      type: 'string',
    };
  }

  validate() {
    if(this.dataset && typeof (this.dataset as any).validate === 'function') {
      (this.dataset as any).validate();
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestSourceLogstore extends $dara.Model {
  /**
   * @remarks
   * The Logstore name.
   * 
   * @example
   * test-logstore
   */
  logstore?: string;
  /**
   * @remarks
   * The filter query.
   * 
   * @example
   * status:500 and method:GET
   */
  query?: string;
  static names(): { [key: string]: string } {
    return {
      logstore: 'logstore',
      query: 'query',
    };
  }

  static types(): { [key: string]: any } {
    return {
      logstore: 'string',
      query: 'string',
    };
  }

  validate() {
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequestSource extends $dara.Model {
  /**
   * @remarks
   * The Log Service Logstore configuration.
   */
  logstore?: UpdatePipelineRequestSourceLogstore;
  /**
   * @remarks
   * The source type.
   * 
   * @example
   * logstore
   */
  type?: string;
  static names(): { [key: string]: string } {
    return {
      logstore: 'logstore',
      type: 'type',
    };
  }

  static types(): { [key: string]: any } {
    return {
      logstore: UpdatePipelineRequestSourceLogstore,
      type: 'string',
    };
  }

  validate() {
    if(this.logstore && typeof (this.logstore as any).validate === 'function') {
      (this.logstore as any).validate();
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class UpdatePipelineRequest extends $dara.Model {
  /**
   * @remarks
   * The pipeline description.
   * 
   * @example
   * test pipeline
   */
  description?: string;
  /**
   * @remarks
   * The execution policy.
   */
  executePolicy?: UpdatePipelineRequestExecutePolicy;
  /**
   * @remarks
   * The pipeline configuration.
   */
  pipeline?: UpdatePipelineRequestPipeline;
  /**
   * @remarks
   * The data sink configuration.
   */
  sink?: UpdatePipelineRequestSink;
  /**
   * @remarks
   * The data source configuration.
   */
  source?: UpdatePipelineRequestSource;
  static names(): { [key: string]: string } {
    return {
      description: 'description',
      executePolicy: 'executePolicy',
      pipeline: 'pipeline',
      sink: 'sink',
      source: 'source',
    };
  }

  static types(): { [key: string]: any } {
    return {
      description: 'string',
      executePolicy: UpdatePipelineRequestExecutePolicy,
      pipeline: UpdatePipelineRequestPipeline,
      sink: UpdatePipelineRequestSink,
      source: UpdatePipelineRequestSource,
    };
  }

  validate() {
    if(this.executePolicy && typeof (this.executePolicy as any).validate === 'function') {
      (this.executePolicy as any).validate();
    }
    if(this.pipeline && typeof (this.pipeline as any).validate === 'function') {
      (this.pipeline as any).validate();
    }
    if(this.sink && typeof (this.sink as any).validate === 'function') {
      (this.sink as any).validate();
    }
    if(this.source && typeof (this.source as any).validate === 'function') {
      (this.source as any).validate();
    }
    super.validate();
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}