-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathelasticsearchIngestPipeline.ts
More file actions
183 lines (175 loc) · 8.86 KB
/
Copy pathelasticsearchIngestPipeline.ts
File metadata and controls
183 lines (175 loc) · 8.86 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
// *** WARNING: this file was generated by pulumi-language-nodejs. ***
// *** Do not edit by hand unless you're certain you know what you are doing! ***
import * as pulumi from "@pulumi/pulumi";
import * as inputs from "./types/input";
import * as outputs from "./types/output";
import * as utilities from "./utilities";
export class ElasticsearchIngestPipeline extends pulumi.CustomResource {
/**
* Get an existing ElasticsearchIngestPipeline resource's state with the given name, ID, and optional extra
* properties used to qualify the lookup.
*
* @param name The _unique_ name of the resulting resource.
* @param id The _unique_ provider ID of the resource to lookup.
* @param state Any extra arguments used during the lookup.
* @param opts Optional settings to control the behavior of the CustomResource.
*/
public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: ElasticsearchIngestPipelineState, opts?: pulumi.CustomResourceOptions): ElasticsearchIngestPipeline {
return new ElasticsearchIngestPipeline(name, <any>state, { ...opts, id: id });
}
/** @internal */
public static readonly __pulumiType = 'elasticstack:index/elasticsearchIngestPipeline:ElasticsearchIngestPipeline';
/**
* Returns true if the given object is an instance of ElasticsearchIngestPipeline. This is designed to work even
* when multiple copies of the Pulumi SDK have been loaded into the same process.
*/
public static isInstance(obj: any): obj is ElasticsearchIngestPipeline {
if (obj === undefined || obj === null) {
return false;
}
return obj['__pulumiType'] === ElasticsearchIngestPipeline.__pulumiType;
}
/**
* Description of the ingest pipeline.
*/
declare public readonly description: pulumi.Output<string | undefined>;
/**
* Elasticsearch connection configuration block. This property will be removed in a future provider version. Configure the
* Elasticsearch connection via the provider configuration instead.
*
* @deprecated Deprecated
*/
declare public readonly elasticsearchConnection: pulumi.Output<outputs.ElasticsearchIngestPipelineElasticsearchConnection | undefined>;
/**
* Optional user metadata about the index template.
*/
declare public readonly metadata: pulumi.Output<string | undefined>;
/**
* The name of the ingest pipeline.
*/
declare public readonly name: pulumi.Output<string>;
/**
* Processors to run immediately after a processor failure. Each processor supports a processor-level `on_failure` value.
* If a processor without an `on_failure` value fails, Elasticsearch uses this pipeline-level parameter as a fallback. The
* processors in this parameter run sequentially in the order specified. Elasticsearch will not attempt to run the
* pipeline’s remaining processors. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html.
* Each record must be a valid JSON document
*/
declare public readonly onFailures: pulumi.Output<string[] | undefined>;
/**
* Processors used to perform transformations on documents before indexing. Processors run sequentially in the order
* specified. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html. Each record must be a
* valid JSON document.
*/
declare public readonly processors: pulumi.Output<string[]>;
/**
* Create a ElasticsearchIngestPipeline resource with the given unique name, arguments, and options.
*
* @param name The _unique_ name of the resource.
* @param args The arguments to use to populate this resource's properties.
* @param opts A bag of options that control this resource's behavior.
*/
constructor(name: string, args: ElasticsearchIngestPipelineArgs, opts?: pulumi.CustomResourceOptions)
constructor(name: string, argsOrState?: ElasticsearchIngestPipelineArgs | ElasticsearchIngestPipelineState, opts?: pulumi.CustomResourceOptions) {
let resourceInputs: pulumi.Inputs = {};
opts = opts || {};
if (opts.id) {
const state = argsOrState as ElasticsearchIngestPipelineState | undefined;
resourceInputs["description"] = state?.description;
resourceInputs["elasticsearchConnection"] = state?.elasticsearchConnection;
resourceInputs["metadata"] = state?.metadata;
resourceInputs["name"] = state?.name;
resourceInputs["onFailures"] = state?.onFailures;
resourceInputs["processors"] = state?.processors;
} else {
const args = argsOrState as ElasticsearchIngestPipelineArgs | undefined;
if (args?.processors === undefined && !opts.urn) {
throw new Error("Missing required property 'processors'");
}
resourceInputs["description"] = args?.description;
resourceInputs["elasticsearchConnection"] = args?.elasticsearchConnection;
resourceInputs["metadata"] = args?.metadata;
resourceInputs["name"] = args?.name;
resourceInputs["onFailures"] = args?.onFailures;
resourceInputs["processors"] = args?.processors;
}
opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts);
super(ElasticsearchIngestPipeline.__pulumiType, name, resourceInputs, opts, false /*dependency*/, utilities.getPackage());
}
}
/**
* Input properties used for looking up and filtering ElasticsearchIngestPipeline resources.
*/
export interface ElasticsearchIngestPipelineState {
/**
* Description of the ingest pipeline.
*/
description?: pulumi.Input<string>;
/**
* Elasticsearch connection configuration block. This property will be removed in a future provider version. Configure the
* Elasticsearch connection via the provider configuration instead.
*
* @deprecated Deprecated
*/
elasticsearchConnection?: pulumi.Input<inputs.ElasticsearchIngestPipelineElasticsearchConnection>;
/**
* Optional user metadata about the index template.
*/
metadata?: pulumi.Input<string>;
/**
* The name of the ingest pipeline.
*/
name?: pulumi.Input<string>;
/**
* Processors to run immediately after a processor failure. Each processor supports a processor-level `on_failure` value.
* If a processor without an `on_failure` value fails, Elasticsearch uses this pipeline-level parameter as a fallback. The
* processors in this parameter run sequentially in the order specified. Elasticsearch will not attempt to run the
* pipeline’s remaining processors. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html.
* Each record must be a valid JSON document
*/
onFailures?: pulumi.Input<pulumi.Input<string>[]>;
/**
* Processors used to perform transformations on documents before indexing. Processors run sequentially in the order
* specified. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html. Each record must be a
* valid JSON document.
*/
processors?: pulumi.Input<pulumi.Input<string>[]>;
}
/**
* The set of arguments for constructing a ElasticsearchIngestPipeline resource.
*/
export interface ElasticsearchIngestPipelineArgs {
/**
* Description of the ingest pipeline.
*/
description?: pulumi.Input<string>;
/**
* Elasticsearch connection configuration block. This property will be removed in a future provider version. Configure the
* Elasticsearch connection via the provider configuration instead.
*
* @deprecated Deprecated
*/
elasticsearchConnection?: pulumi.Input<inputs.ElasticsearchIngestPipelineElasticsearchConnection>;
/**
* Optional user metadata about the index template.
*/
metadata?: pulumi.Input<string>;
/**
* The name of the ingest pipeline.
*/
name?: pulumi.Input<string>;
/**
* Processors to run immediately after a processor failure. Each processor supports a processor-level `on_failure` value.
* If a processor without an `on_failure` value fails, Elasticsearch uses this pipeline-level parameter as a fallback. The
* processors in this parameter run sequentially in the order specified. Elasticsearch will not attempt to run the
* pipeline’s remaining processors. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html.
* Each record must be a valid JSON document
*/
onFailures?: pulumi.Input<pulumi.Input<string>[]>;
/**
* Processors used to perform transformations on documents before indexing. Processors run sequentially in the order
* specified. See: https://www.elastic.co/guide/en/elasticsearch/reference/current/processors.html. Each record must be a
* valid JSON document.
*/
processors: pulumi.Input<pulumi.Input<string>[]>;
}