// This file is auto-generated, don't edit it import * as $dara from '@darabonba/typescript'; export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigAssignments extends $dara.Model { /** * @remarks * The assignment expression. * * @example * duration / 1000000.0 */ expression?: string; /** * @remarks * The output field. * * @example * latency_ms */ field?: string; static names(): { [key: string]: string } { return { expression: 'expression', field: 'field', }; } static types(): { [key: string]: any } { return { expression: 'string', field: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigProjections extends $dara.Model { /** * @remarks * The source field. * * @example * serviceName */ source?: string; /** * @remarks * The target field. * * @example * service */ target?: string; static names(): { [key: string]: string } { return { source: 'source', target: 'target', }; } static types(): { [key: string]: any } { return { source: 'string', target: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigRules extends $dara.Model { /** * @remarks * The length of the retained prefix. * * @example * 2 */ keepPrefix?: number; /** * @remarks * The length of the retained suffix. * * @example * 2 */ keepSuffix?: number; /** * @remarks * The sensitive keywords. */ keys?: string[]; /** * @remarks * The mask character. * * @example * * */ maskChar?: string; /** * @remarks * The data masking mode. * * @example * keyword */ mode?: string; /** * @remarks * The built-in sensitive types. */ types?: string[]; static names(): { [key: string]: string } { return { keepPrefix: 'keepPrefix', keepSuffix: 'keepSuffix', keys: 'keys', maskChar: 'maskChar', mode: 'mode', types: 'types', }; } static types(): { [key: string]: any } { return { keepPrefix: 'number', keepSuffix: 'number', keys: { 'type': 'array', 'itemType': 'string' }, maskChar: 'string', mode: 'string', types: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.keys)) { $dara.Model.validateArray(this.keys); } if(Array.isArray(this.types)) { $dara.Model.validateArray(this.types); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditionsField extends $dara.Model { /** * @remarks * The JSON object container. * * @example * attributes */ container?: string; /** * @remarks * The reference data type. * * @example * field */ kind?: string; /** * @remarks * The name of the field or dimension. * * @example * serviceName */ name?: string; /** * @remarks * The JSON literal key path. */ path?: string[]; static names(): { [key: string]: string } { return { container: 'container', kind: 'kind', name: 'name', path: 'path', }; } static types(): { [key: string]: any } { return { container: 'string', kind: 'string', name: 'string', path: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.path)) { $dara.Model.validateArray(this.path); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditions extends $dara.Model { /** * @remarks * The field reference. */ field?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditionsField; /** * @remarks * The match type. * * @example * EXACT */ matchType?: string; /** * @remarks * The match values. */ values?: string[]; static names(): { [key: string]: string } { return { field: 'field', matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { field: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditionsField, matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(this.field && typeof (this.field as any).validate === 'function') { (this.field as any).validate(); } if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeMetricName extends $dara.Model { /** * @remarks * The match type. * * @example * EXACT */ matchType?: string; /** * @remarks * The metric names. * * @example * ["http_requests_total"] */ values?: string[]; static names(): { [key: string]: string } { return { matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeServiceName extends $dara.Model { /** * @remarks * The match type. * * @example * EXACT */ matchType?: string; /** * @remarks * The match values. */ values?: string[]; static names(): { [key: string]: string } { return { matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScope extends $dara.Model { /** * @remarks * The additional field conditions. */ conditions?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditions[]; /** * @remarks * The metric name scope. */ metricName?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeMetricName; /** * @remarks * The service name scope. */ serviceName?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeServiceName; static names(): { [key: string]: string } { return { conditions: 'conditions', metricName: 'metricName', serviceName: 'serviceName', }; } static types(): { [key: string]: any } { return { conditions: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeConditions }, metricName: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeMetricName, serviceName: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScopeServiceName, }; } validate() { if(Array.isArray(this.conditions)) { $dara.Model.validateArray(this.conditions); } if(this.metricName && typeof (this.metricName as any).validate === 'function') { (this.metricName as any).validate(); } if(this.serviceName && typeof (this.serviceName as any).validate === 'function') { (this.serviceName as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigSelector extends $dara.Model { /** * @remarks * The service name list. * * @example * ["checkout-*","order-service"] */ serviceNames?: string[]; static names(): { [key: string]: string } { return { serviceNames: 'serviceNames', }; } static types(): { [key: string]: any } { return { serviceNames: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.serviceNames)) { $dara.Model.validateArray(this.serviceNames); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigTarget extends $dara.Model { /** * @remarks * The target workspace. * * @example * target-checkout-ws */ workspace?: string; static names(): { [key: string]: string } { return { workspace: 'workspace', }; } static types(): { [key: string]: any } { return { workspace: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfig extends $dara.Model { /** * @remarks * The list of applications. */ applications?: string[]; /** * @remarks * The list of field assignments. */ assignments?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigAssignments[]; /** * @remarks * The filter expression. * * @example * attributes["http.route"] != "/health" */ expression?: string; /** * @remarks * The list of fields. */ fields?: string[]; /** * @remarks * The additional parameters. */ parameters?: { [key: string]: any }; /** * @remarks * The list of field projections. */ projections?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigProjections[]; /** * @remarks * The list of data masking rules. */ rules?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigRules[]; /** * @remarks * The effective scope of pipeline processing. */ scope?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScope; /** * @remarks * The SPL script. * * @example * * | extend latency_ms = duration / 1000000 */ script?: string; /** * @remarks * The service selector. */ selector?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigSelector; /** * @remarks * The processing target. */ target?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigTarget; static names(): { [key: string]: string } { return { applications: 'applications', assignments: 'assignments', expression: 'expression', fields: 'fields', parameters: 'parameters', projections: 'projections', rules: 'rules', scope: 'scope', script: 'script', selector: 'selector', target: 'target', }; } static types(): { [key: string]: any } { return { applications: { 'type': 'array', 'itemType': 'string' }, assignments: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigAssignments }, expression: 'string', fields: { 'type': 'array', 'itemType': 'string' }, parameters: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' }, projections: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigProjections }, rules: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigRules }, scope: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigScope, script: 'string', selector: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigSelector, target: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfigTarget, }; } validate() { if(Array.isArray(this.applications)) { $dara.Model.validateArray(this.applications); } if(Array.isArray(this.assignments)) { $dara.Model.validateArray(this.assignments); } if(Array.isArray(this.fields)) { $dara.Model.validateArray(this.fields); } if(this.parameters) { $dara.Model.validateMap(this.parameters); } if(Array.isArray(this.projections)) { $dara.Model.validateArray(this.projections); } if(Array.isArray(this.rules)) { $dara.Model.validateArray(this.rules); } if(this.scope && typeof (this.scope as any).validate === 'function') { (this.scope as any).validate(); } if(this.selector && typeof (this.selector as any).validate === 'function') { (this.selector as any).validate(); } if(this.target && typeof (this.target as any).validate === 'function') { (this.target as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputsProcessors extends $dara.Model { /** * @remarks * The processor configuration. */ config?: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfig; /** * @remarks * The processor name. * * @example * drop-health-check */ name?: string; /** * @remarks * The processor type. * * @example * filter */ type?: string; static names(): { [key: string]: string } { return { config: 'config', name: 'name', type: 'type', }; } static types(): { [key: string]: any } { return { config: CreateDataPipelineResponseBodyPipelineOutputsProcessorsConfig, name: 'string', type: 'string', }; } validate() { if(this.config && typeof (this.config as any).validate === 'function') { (this.config as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineOutputs extends $dara.Model { /** * @remarks * The name of the output. * * @example * checkout_route */ name?: string; /** * @remarks * The branch processors. */ processors?: CreateDataPipelineResponseBodyPipelineOutputsProcessors[]; static names(): { [key: string]: string } { return { name: 'name', processors: 'processors', }; } static types(): { [key: string]: any } { return { name: 'string', processors: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputsProcessors }, }; } validate() { if(Array.isArray(this.processors)) { $dara.Model.validateArray(this.processors); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigAssignments extends $dara.Model { /** * @remarks * The assignment expression. * * @example * duration / 1000000.0 */ expression?: string; /** * @remarks * The output field. * * @example * latency_ms */ field?: string; static names(): { [key: string]: string } { return { expression: 'expression', field: 'field', }; } static types(): { [key: string]: any } { return { expression: 'string', field: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigProjections extends $dara.Model { /** * @remarks * The source field. * * @example * serviceName */ source?: string; /** * @remarks * The target field. * * @example * service */ target?: string; static names(): { [key: string]: string } { return { source: 'source', target: 'target', }; } static types(): { [key: string]: any } { return { source: 'string', target: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigRules extends $dara.Model { /** * @remarks * The length of the retained prefix. * * @example * 2 */ keepPrefix?: number; /** * @remarks * The length of the retained suffix. * * @example * 2 */ keepSuffix?: number; /** * @remarks * The sensitive keywords. */ keys?: string[]; /** * @remarks * The mask character. * * @example * * */ maskChar?: string; /** * @remarks * The data masking mode. * * @example * keyword */ mode?: string; /** * @remarks * The built-in sensitive types. */ types?: string[]; static names(): { [key: string]: string } { return { keepPrefix: 'keepPrefix', keepSuffix: 'keepSuffix', keys: 'keys', maskChar: 'maskChar', mode: 'mode', types: 'types', }; } static types(): { [key: string]: any } { return { keepPrefix: 'number', keepSuffix: 'number', keys: { 'type': 'array', 'itemType': 'string' }, maskChar: 'string', mode: 'string', types: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.keys)) { $dara.Model.validateArray(this.keys); } if(Array.isArray(this.types)) { $dara.Model.validateArray(this.types); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditionsField extends $dara.Model { /** * @remarks * The JSON object container. * * @example * attributes */ container?: string; /** * @remarks * The reference data type. * * @example * field */ kind?: string; /** * @remarks * The name of the field or dimension. * * @example * service.name */ name?: string; /** * @remarks * The JSON literal key path. */ path?: string[]; static names(): { [key: string]: string } { return { container: 'container', kind: 'kind', name: 'name', path: 'path', }; } static types(): { [key: string]: any } { return { container: 'string', kind: 'string', name: 'string', path: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.path)) { $dara.Model.validateArray(this.path); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditions extends $dara.Model { /** * @remarks * The field reference. */ field?: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditionsField; /** * @remarks * The match type. * * @example * EXACT */ matchType?: string; /** * @remarks * The match values. */ values?: string[]; static names(): { [key: string]: string } { return { field: 'field', matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { field: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditionsField, matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(this.field && typeof (this.field as any).validate === 'function') { (this.field as any).validate(); } if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeMetricName extends $dara.Model { /** * @remarks * The match type. * * @example * EXACT */ matchType?: string; /** * @remarks * The metric names. * * @example * ["http_requests_total"] */ values?: string[]; static names(): { [key: string]: string } { return { matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeServiceName extends $dara.Model { /** * @remarks * The match type. * * @example * GLOB */ matchType?: string; /** * @remarks * The match values. */ values?: string[]; static names(): { [key: string]: string } { return { matchType: 'matchType', values: 'values', }; } static types(): { [key: string]: any } { return { matchType: 'string', values: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.values)) { $dara.Model.validateArray(this.values); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigScope extends $dara.Model { /** * @remarks * The additional field conditions. */ conditions?: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditions[]; /** * @remarks * The metric name scope. */ metricName?: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeMetricName; /** * @remarks * The service name scope. */ serviceName?: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeServiceName; static names(): { [key: string]: string } { return { conditions: 'conditions', metricName: 'metricName', serviceName: 'serviceName', }; } static types(): { [key: string]: any } { return { conditions: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeConditions }, metricName: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeMetricName, serviceName: CreateDataPipelineResponseBodyPipelineProcessorsConfigScopeServiceName, }; } validate() { if(Array.isArray(this.conditions)) { $dara.Model.validateArray(this.conditions); } if(this.metricName && typeof (this.metricName as any).validate === 'function') { (this.metricName as any).validate(); } if(this.serviceName && typeof (this.serviceName as any).validate === 'function') { (this.serviceName as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigSelector extends $dara.Model { /** * @remarks * The service name list. * * @example * ["checkout-*","order-service"] */ serviceNames?: string[]; static names(): { [key: string]: string } { return { serviceNames: 'serviceNames', }; } static types(): { [key: string]: any } { return { serviceNames: { 'type': 'array', 'itemType': 'string' }, }; } validate() { if(Array.isArray(this.serviceNames)) { $dara.Model.validateArray(this.serviceNames); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfigTarget extends $dara.Model { /** * @remarks * The target workspace. * * @example * target-checkout-ws */ workspace?: string; static names(): { [key: string]: string } { return { workspace: 'workspace', }; } static types(): { [key: string]: any } { return { workspace: 'string', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessorsConfig extends $dara.Model { /** * @remarks * The list of applications. */ applications?: string[]; /** * @remarks * The list of field assignments. */ assignments?: CreateDataPipelineResponseBodyPipelineProcessorsConfigAssignments[]; /** * @remarks * The filter expression. * * @example * attributes["http.route"] != "/health" */ expression?: string; /** * @remarks * The list of fields. */ fields?: string[]; /** * @remarks * The additional parameters. */ parameters?: { [key: string]: any }; /** * @remarks * The list of field projections. */ projections?: CreateDataPipelineResponseBodyPipelineProcessorsConfigProjections[]; /** * @remarks * The list of data masking rules. */ rules?: CreateDataPipelineResponseBodyPipelineProcessorsConfigRules[]; /** * @remarks * The effective scope of pipeline processing. */ scope?: CreateDataPipelineResponseBodyPipelineProcessorsConfigScope; /** * @remarks * The SPL script. * * @example * * | extend latency_ms = duration / 1000000 */ script?: string; /** * @remarks * The service selector. */ selector?: CreateDataPipelineResponseBodyPipelineProcessorsConfigSelector; /** * @remarks * The processing target. */ target?: CreateDataPipelineResponseBodyPipelineProcessorsConfigTarget; static names(): { [key: string]: string } { return { applications: 'applications', assignments: 'assignments', expression: 'expression', fields: 'fields', parameters: 'parameters', projections: 'projections', rules: 'rules', scope: 'scope', script: 'script', selector: 'selector', target: 'target', }; } static types(): { [key: string]: any } { return { applications: { 'type': 'array', 'itemType': 'string' }, assignments: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineProcessorsConfigAssignments }, expression: 'string', fields: { 'type': 'array', 'itemType': 'string' }, parameters: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' }, projections: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineProcessorsConfigProjections }, rules: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineProcessorsConfigRules }, scope: CreateDataPipelineResponseBodyPipelineProcessorsConfigScope, script: 'string', selector: CreateDataPipelineResponseBodyPipelineProcessorsConfigSelector, target: CreateDataPipelineResponseBodyPipelineProcessorsConfigTarget, }; } validate() { if(Array.isArray(this.applications)) { $dara.Model.validateArray(this.applications); } if(Array.isArray(this.assignments)) { $dara.Model.validateArray(this.assignments); } if(Array.isArray(this.fields)) { $dara.Model.validateArray(this.fields); } if(this.parameters) { $dara.Model.validateMap(this.parameters); } if(Array.isArray(this.projections)) { $dara.Model.validateArray(this.projections); } if(Array.isArray(this.rules)) { $dara.Model.validateArray(this.rules); } if(this.scope && typeof (this.scope as any).validate === 'function') { (this.scope as any).validate(); } if(this.selector && typeof (this.selector as any).validate === 'function') { (this.selector as any).validate(); } if(this.target && typeof (this.target as any).validate === 'function') { (this.target as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineProcessors extends $dara.Model { /** * @remarks * The processor configuration. */ config?: CreateDataPipelineResponseBodyPipelineProcessorsConfig; /** * @remarks * The processor name. * * @example * drop-health-check */ name?: string; /** * @remarks * The processor type. * * @example * filter */ type?: string; static names(): { [key: string]: string } { return { config: 'config', name: 'name', type: 'type', }; } static types(): { [key: string]: any } { return { config: CreateDataPipelineResponseBodyPipelineProcessorsConfig, name: 'string', type: 'string', }; } validate() { if(this.config && typeof (this.config as any).validate === 'function') { (this.config as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineSinks extends $dara.Model { /** * @remarks * The dataset list. */ datasets?: string[]; /** * @remarks * SLS Logstore * * @example * error-spans */ logstore?: string; /** * @remarks * The sink name. * * @example * error-archive */ name?: string; /** * @remarks * SLS Project * * @example * customer-project */ project?: string; /** * @remarks * The sink type. * * @example * logstore */ type?: string; static names(): { [key: string]: string } { return { datasets: 'datasets', logstore: 'logstore', name: 'name', project: 'project', type: 'type', }; } static types(): { [key: string]: any } { return { datasets: { 'type': 'array', 'itemType': 'string' }, logstore: 'string', name: 'string', project: 'string', type: 'string', }; } validate() { if(Array.isArray(this.datasets)) { $dara.Model.validateArray(this.datasets); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineSourceConfigTimeRange extends $dara.Model { /** * @remarks * The start time. * * @example * 1722844800 */ from?: number; /** * @remarks * The end time. * * @example * 1722848400 */ to?: number; static names(): { [key: string]: string } { return { from: 'from', to: 'to', }; } static types(): { [key: string]: any } { return { from: 'number', to: 'number', }; } validate() { super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineSourceConfig extends $dara.Model { /** * @remarks * The run mode. * * @example * continuous */ runMode?: string; /** * @remarks * The start position. * * @example * latest */ startFrom?: string; /** * @remarks * The backfill time range. */ timeRange?: CreateDataPipelineResponseBodyPipelineSourceConfigTimeRange; static names(): { [key: string]: string } { return { runMode: 'runMode', startFrom: 'startFrom', timeRange: 'timeRange', }; } static types(): { [key: string]: any } { return { runMode: 'string', startFrom: 'string', timeRange: CreateDataPipelineResponseBodyPipelineSourceConfigTimeRange, }; } validate() { if(this.timeRange && typeof (this.timeRange as any).validate === 'function') { (this.timeRange as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipelineSource extends $dara.Model { /** * @remarks * The datasource config. */ config?: CreateDataPipelineResponseBodyPipelineSourceConfig; /** * @remarks * The data source type. * * @example * traces-default */ type?: string; static names(): { [key: string]: string } { return { config: 'config', type: 'type', }; } static types(): { [key: string]: any } { return { config: CreateDataPipelineResponseBodyPipelineSourceConfig, type: 'string', }; } validate() { if(this.config && typeof (this.config as any).validate === 'function') { (this.config as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBodyPipeline extends $dara.Model { /** * @remarks * The creation time in UTC format that follows the ISO 8601 standard, such as 2026-08-10T05:00:00Z. * * This parameter is required. * * Use the UTC time format: yyyy-MM-ddTHH:mmZ * * @example * 2026-08-10T05:00:00Z */ createTime?: string; /** * @remarks * The description of the pipeline. * * @example * Export selected trace services to the target workspace. */ description?: string; /** * @remarks * The type of the pipeline. * * This parameter is required. * * @example * export */ kind?: string; /** * @remarks * The named outputs. * * This parameter is required. */ outputs?: CreateDataPipelineResponseBodyPipelineOutputs[]; /** * @remarks * The pipeline name. * * This parameter is required. * * @example * export-traces-to-prod */ pipelineName?: string; /** * @remarks * The common processors. * * This parameter is required. */ processors?: CreateDataPipelineResponseBodyPipelineProcessors[]; /** * @remarks * The signal type. * * This parameter is required. * * @example * traces */ signalType?: string; /** * @remarks * The sinks. * * This parameter is required. */ sinks?: CreateDataPipelineResponseBodyPipelineSinks[]; /** * @remarks * The data source. * * This parameter is required. */ source?: CreateDataPipelineResponseBodyPipelineSource; /** * @remarks * The running status. * * This parameter is required. * * @example * Running */ status?: string; /** * @remarks * The status message. * * @example * Pipeline is running. */ statusMessage?: string; /** * @remarks * The update time in ISO 8601 format in UTC. Example: 2026-08-10T05:10:00Z. * * This parameter is required. * * Use the UTC time format: yyyy-MM-ddTHH:mmZ * * @example * 2026-08-10T05:10:00Z */ updateTime?: string; /** * @remarks * The configuration version. * * This parameter is required. * * @example * 3 */ version?: number; static names(): { [key: string]: string } { return { createTime: 'createTime', description: 'description', kind: 'kind', outputs: 'outputs', pipelineName: 'pipelineName', processors: 'processors', signalType: 'signalType', sinks: 'sinks', source: 'source', status: 'status', statusMessage: 'statusMessage', updateTime: 'updateTime', version: 'version', }; } static types(): { [key: string]: any } { return { createTime: 'string', description: 'string', kind: 'string', outputs: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineOutputs }, pipelineName: 'string', processors: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineProcessors }, signalType: 'string', sinks: { 'type': 'array', 'itemType': CreateDataPipelineResponseBodyPipelineSinks }, source: CreateDataPipelineResponseBodyPipelineSource, status: 'string', statusMessage: 'string', updateTime: 'string', version: 'number', }; } validate() { if(Array.isArray(this.outputs)) { $dara.Model.validateArray(this.outputs); } if(Array.isArray(this.processors)) { $dara.Model.validateArray(this.processors); } if(Array.isArray(this.sinks)) { $dara.Model.validateArray(this.sinks); } if(this.source && typeof (this.source as any).validate === 'function') { (this.source as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class CreateDataPipelineResponseBody extends $dara.Model { /** * @remarks * The data pipeline. */ pipeline?: CreateDataPipelineResponseBodyPipeline; /** * @remarks * The request ID. * * @example * 473469C7-AA6F-4DC5-B3DB-A3DC0DE3C83E */ requestId?: string; static names(): { [key: string]: string } { return { pipeline: 'pipeline', requestId: 'requestId', }; } static types(): { [key: string]: any } { return { pipeline: CreateDataPipelineResponseBodyPipeline, requestId: 'string', }; } validate() { if(this.pipeline && typeof (this.pipeline as any).validate === 'function') { (this.pipeline as any).validate(); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } }