// This file is auto-generated, don't edit it import * as $dara from '@darabonba/typescript'; export class PreviewDataPipelineRequestOutputsProcessorsConfigAssignments 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 PreviewDataPipelineRequestOutputsProcessorsConfigProjections 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 PreviewDataPipelineRequestOutputsProcessorsConfigRules 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 data 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 PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditionsField 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 PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditions extends $dara.Model { /** * @remarks * The field reference. */ field?: PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditionsField; /** * @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: PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditionsField, 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 PreviewDataPipelineRequestOutputsProcessorsConfigScopeMetricName 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 PreviewDataPipelineRequestOutputsProcessorsConfigScopeServiceName 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 PreviewDataPipelineRequestOutputsProcessorsConfigScope extends $dara.Model { /** * @remarks * The additional field conditions. */ conditions?: PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditions[]; /** * @remarks * The metric name scope. */ metricName?: PreviewDataPipelineRequestOutputsProcessorsConfigScopeMetricName; /** * @remarks * The service name scope. */ serviceName?: PreviewDataPipelineRequestOutputsProcessorsConfigScopeServiceName; static names(): { [key: string]: string } { return { conditions: 'conditions', metricName: 'metricName', serviceName: 'serviceName', }; } static types(): { [key: string]: any } { return { conditions: { 'type': 'array', 'itemType': PreviewDataPipelineRequestOutputsProcessorsConfigScopeConditions }, metricName: PreviewDataPipelineRequestOutputsProcessorsConfigScopeMetricName, serviceName: PreviewDataPipelineRequestOutputsProcessorsConfigScopeServiceName, }; } 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 PreviewDataPipelineRequestOutputsProcessorsConfigSelector 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 PreviewDataPipelineRequestOutputsProcessorsConfigTarget 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 PreviewDataPipelineRequestOutputsProcessorsConfig extends $dara.Model { /** * @remarks * The list of applications. */ applications?: string[]; /** * @remarks * The list of field assignments. */ assignments?: PreviewDataPipelineRequestOutputsProcessorsConfigAssignments[]; /** * @remarks * The filter expression. * * @example * attributes["http.route"] != "/health" */ expression?: string; /** * @remarks * The list of fields. */ fields?: string[]; /** * @remarks * The extended parameters. */ parameters?: { [key: string]: any }; /** * @remarks * The list of field projections. */ projections?: PreviewDataPipelineRequestOutputsProcessorsConfigProjections[]; /** * @remarks * The list of data masking rules. */ rules?: PreviewDataPipelineRequestOutputsProcessorsConfigRules[]; /** * @remarks * The effective scope of pipeline processing. */ scope?: PreviewDataPipelineRequestOutputsProcessorsConfigScope; /** * @remarks * The SPL script. * * @example * * | extend latency_ms = duration / 1000000 */ script?: string; /** * @remarks * The service selector. */ selector?: PreviewDataPipelineRequestOutputsProcessorsConfigSelector; /** * @remarks * The processing target. */ target?: PreviewDataPipelineRequestOutputsProcessorsConfigTarget; 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': PreviewDataPipelineRequestOutputsProcessorsConfigAssignments }, expression: 'string', fields: { 'type': 'array', 'itemType': 'string' }, parameters: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' }, projections: { 'type': 'array', 'itemType': PreviewDataPipelineRequestOutputsProcessorsConfigProjections }, rules: { 'type': 'array', 'itemType': PreviewDataPipelineRequestOutputsProcessorsConfigRules }, scope: PreviewDataPipelineRequestOutputsProcessorsConfigScope, script: 'string', selector: PreviewDataPipelineRequestOutputsProcessorsConfigSelector, target: PreviewDataPipelineRequestOutputsProcessorsConfigTarget, }; } 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 PreviewDataPipelineRequestOutputsProcessors extends $dara.Model { /** * @remarks * The processor configuration. */ config?: PreviewDataPipelineRequestOutputsProcessorsConfig; /** * @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: PreviewDataPipelineRequestOutputsProcessorsConfig, 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 PreviewDataPipelineRequestOutputs extends $dara.Model { /** * @remarks * The name of the output. * * @example * checkout_route */ name?: string; /** * @remarks * The branch processors. */ processors?: PreviewDataPipelineRequestOutputsProcessors[]; static names(): { [key: string]: string } { return { name: 'name', processors: 'processors', }; } static types(): { [key: string]: any } { return { name: 'string', processors: { 'type': 'array', 'itemType': PreviewDataPipelineRequestOutputsProcessors }, }; } validate() { if(Array.isArray(this.processors)) { $dara.Model.validateArray(this.processors); } super.validate(); } constructor(map?: { [key: string]: any }) { super(map); } } export class PreviewDataPipelineRequestProcessorsConfigAssignments 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 PreviewDataPipelineRequestProcessorsConfigProjections 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 PreviewDataPipelineRequestProcessorsConfigRules 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 data 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 PreviewDataPipelineRequestProcessorsConfigScopeConditionsField extends $dara.Model { /** * @remarks * The JSON object container. * * @example * resources */ 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 PreviewDataPipelineRequestProcessorsConfigScopeConditions extends $dara.Model { /** * @remarks * The field reference. */ field?: PreviewDataPipelineRequestProcessorsConfigScopeConditionsField; /** * @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: PreviewDataPipelineRequestProcessorsConfigScopeConditionsField, 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 PreviewDataPipelineRequestProcessorsConfigScopeMetricName 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 PreviewDataPipelineRequestProcessorsConfigScopeServiceName 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 PreviewDataPipelineRequestProcessorsConfigScope extends $dara.Model { /** * @remarks * The additional field conditions. */ conditions?: PreviewDataPipelineRequestProcessorsConfigScopeConditions[]; /** * @remarks * The metric name scope. */ metricName?: PreviewDataPipelineRequestProcessorsConfigScopeMetricName; /** * @remarks * The service name scope. */ serviceName?: PreviewDataPipelineRequestProcessorsConfigScopeServiceName; static names(): { [key: string]: string } { return { conditions: 'conditions', metricName: 'metricName', serviceName: 'serviceName', }; } static types(): { [key: string]: any } { return { conditions: { 'type': 'array', 'itemType': PreviewDataPipelineRequestProcessorsConfigScopeConditions }, metricName: PreviewDataPipelineRequestProcessorsConfigScopeMetricName, serviceName: PreviewDataPipelineRequestProcessorsConfigScopeServiceName, }; } 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 PreviewDataPipelineRequestProcessorsConfigSelector 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 PreviewDataPipelineRequestProcessorsConfigTarget 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 PreviewDataPipelineRequestProcessorsConfig extends $dara.Model { /** * @remarks * The list of applications. */ applications?: string[]; /** * @remarks * The list of field assignments. */ assignments?: PreviewDataPipelineRequestProcessorsConfigAssignments[]; /** * @remarks * The filter expression. * * @example * attributes["http.route"] != "/health" */ expression?: string; /** * @remarks * The list of fields. */ fields?: string[]; /** * @remarks * The extended parameters. */ parameters?: { [key: string]: any }; /** * @remarks * The list of field projections. */ projections?: PreviewDataPipelineRequestProcessorsConfigProjections[]; /** * @remarks * The list of data masking rules. */ rules?: PreviewDataPipelineRequestProcessorsConfigRules[]; /** * @remarks * The effective scope of pipeline processing. */ scope?: PreviewDataPipelineRequestProcessorsConfigScope; /** * @remarks * The SPL script. * * @example * * | extend latency_ms = duration / 1000000 */ script?: string; /** * @remarks * The service selector. */ selector?: PreviewDataPipelineRequestProcessorsConfigSelector; /** * @remarks * The processing target. */ target?: PreviewDataPipelineRequestProcessorsConfigTarget; 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': PreviewDataPipelineRequestProcessorsConfigAssignments }, expression: 'string', fields: { 'type': 'array', 'itemType': 'string' }, parameters: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' }, projections: { 'type': 'array', 'itemType': PreviewDataPipelineRequestProcessorsConfigProjections }, rules: { 'type': 'array', 'itemType': PreviewDataPipelineRequestProcessorsConfigRules }, scope: PreviewDataPipelineRequestProcessorsConfigScope, script: 'string', selector: PreviewDataPipelineRequestProcessorsConfigSelector, target: PreviewDataPipelineRequestProcessorsConfigTarget, }; } 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 PreviewDataPipelineRequestProcessors extends $dara.Model { /** * @remarks * The processor configuration. */ config?: PreviewDataPipelineRequestProcessorsConfig; /** * @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: PreviewDataPipelineRequestProcessorsConfig, 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 PreviewDataPipelineRequestSinks extends $dara.Model { /** * @remarks * The list of datasets. */ datasets?: string[]; /** * @remarks * SLS Logstore * * @example * error-spans */ logstore?: string; /** * @remarks * The name of the output destination. * * @example * error-archive */ name?: string; /** * @remarks * SLS Project * * @example * customer-project */ project?: string; /** * @remarks * The type of the output destination. * * @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 PreviewDataPipelineRequestSourceConfigTimeRange 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 PreviewDataPipelineRequestSourceConfig extends $dara.Model { /** * @remarks * The run mode. * * @example * continuous */ runMode?: string; /** * @remarks * The read start position. * * @example * latest */ startFrom?: string; /** * @remarks * The backfill time range. */ timeRange?: PreviewDataPipelineRequestSourceConfigTimeRange; static names(): { [key: string]: string } { return { runMode: 'runMode', startFrom: 'startFrom', timeRange: 'timeRange', }; } static types(): { [key: string]: any } { return { runMode: 'string', startFrom: 'string', timeRange: PreviewDataPipelineRequestSourceConfigTimeRange, }; } 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 PreviewDataPipelineRequestSource extends $dara.Model { /** * @remarks * The datasource config. */ config?: PreviewDataPipelineRequestSourceConfig; /** * @remarks * The type of the data source. * * @example * traces-default */ type?: string; static names(): { [key: string]: string } { return { config: 'config', type: 'type', }; } static types(): { [key: string]: any } { return { config: PreviewDataPipelineRequestSourceConfig, 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 PreviewDataPipelineRequest extends $dara.Model { /** * @remarks * The description of the pipeline. * * @example * Preview error span routing. */ description?: string; /** * @remarks * The start time of the preview. The value is a UNIX timestamp in seconds. * * @example * 1784563200 */ fromTime?: number; /** * @remarks * The type of the pipeline. * * @example * custom */ kind?: string; /** * @remarks * The named outputs. */ outputs?: PreviewDataPipelineRequestOutputs[]; /** * @remarks * The pipeline name. * * @example * trace-archive-routing */ pipelineName?: string; /** * @remarks * The common processors. */ processors?: PreviewDataPipelineRequestProcessors[]; /** * @remarks * The output destinations. */ sinks?: PreviewDataPipelineRequestSinks[]; /** * @remarks * The data source. */ source?: PreviewDataPipelineRequestSource; /** * @remarks * The end time for the preview. The value is a UNIX timestamp in seconds. * * @example * 1784566800 */ toTime?: number; static names(): { [key: string]: string } { return { description: 'description', fromTime: 'fromTime', kind: 'kind', outputs: 'outputs', pipelineName: 'pipelineName', processors: 'processors', sinks: 'sinks', source: 'source', toTime: 'toTime', }; } static types(): { [key: string]: any } { return { description: 'string', fromTime: 'number', kind: 'string', outputs: { 'type': 'array', 'itemType': PreviewDataPipelineRequestOutputs }, pipelineName: 'string', processors: { 'type': 'array', 'itemType': PreviewDataPipelineRequestProcessors }, sinks: { 'type': 'array', 'itemType': PreviewDataPipelineRequestSinks }, source: PreviewDataPipelineRequestSource, toTime: '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); } }