summaryrefslogtreecommitdiff
path: root/frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts
diff options
context:
space:
mode:
Diffstat (limited to 'frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts')
-rw-r--r--frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts63
1 files changed, 63 insertions, 0 deletions
diff --git a/frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts b/frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts
new file mode 100644
index 0000000..2110e85
--- /dev/null
+++ b/frontend-old/node_modules/@grpc/grpc-js/src/resolver-uds.ts
@@ -0,0 +1,63 @@
+/*
+ * Copyright 2019 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License 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.
+ */
+
+import { Resolver, ResolverListener, registerResolver } from './resolver';
+import { SubchannelAddress } from './subchannel-address';
+import { GrpcUri } from './uri-parser';
+import { ChannelOptions } from './channel-options';
+
+class UdsResolver implements Resolver {
+ private addresses: SubchannelAddress[] = [];
+ private hasReturnedResult = false;
+ constructor(
+ target: GrpcUri,
+ private listener: ResolverListener,
+ channelOptions: ChannelOptions
+ ) {
+ let path: string;
+ if (target.authority === '') {
+ path = '/' + target.path;
+ } else {
+ path = target.path;
+ }
+ this.addresses = [{ path }];
+ }
+ updateResolution(): void {
+ if (!this.hasReturnedResult) {
+ this.hasReturnedResult = true;
+ process.nextTick(
+ this.listener.onSuccessfulResolution,
+ this.addresses,
+ null,
+ null,
+ null,
+ {}
+ );
+ }
+ }
+
+ destroy() {
+ // This resolver owns no resources, so we do nothing here.
+ }
+
+ static getDefaultAuthority(target: GrpcUri): string {
+ return 'localhost';
+ }
+}
+
+export function setup() {
+ registerResolver('unix', UdsResolver);
+}