diff options
| author | altaf-creator <dev@altafcreator.com> | 2025-11-16 19:08:29 +0800 |
|---|---|---|
| committer | altaf-creator <dev@altafcreator.com> | 2025-11-16 19:08:29 +0800 |
| commit | 434aa8343fdcbb4d5002f934979913c099489bee (patch) | |
| tree | 55bab4ec5a6151be57797d34f61faf5ea744471b /frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts | |
| parent | 893c388d4e99442a36005e5971a87730623f946e (diff) | |
sdk, del
Diffstat (limited to 'frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts')
| -rw-r--r-- | frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts | 97 |
1 files changed, 0 insertions, 97 deletions
diff --git a/frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts b/frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts deleted file mode 100644 index cc19c22..0000000 --- a/frontend-old/node_modules/@grpc/grpc-js/src/subchannel-interface.ts +++ /dev/null @@ -1,97 +0,0 @@ -/* - * Copyright 2022 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 { SubchannelRef } from './channelz'; -import { ConnectivityState } from './connectivity-state'; -import { Subchannel } from './subchannel'; - -export type ConnectivityStateListener = ( - subchannel: SubchannelInterface, - previousState: ConnectivityState, - newState: ConnectivityState, - keepaliveTime: number, - errorMessage?: string -) => void; - -/** - * This is an interface for load balancing policies to use to interact with - * subchannels. This allows load balancing policies to wrap and unwrap - * subchannels. - * - * Any load balancing policy that wraps subchannels must unwrap the subchannel - * in the picker, so that other load balancing policies consistently have - * access to their own wrapper objects. - */ -export interface SubchannelInterface { - getConnectivityState(): ConnectivityState; - addConnectivityStateListener(listener: ConnectivityStateListener): void; - removeConnectivityStateListener(listener: ConnectivityStateListener): void; - startConnecting(): void; - getAddress(): string; - throttleKeepalive(newKeepaliveTime: number): void; - ref(): void; - unref(): void; - getChannelzRef(): SubchannelRef; - /** - * If this is a wrapper, return the wrapped subchannel, otherwise return this - */ - getRealSubchannel(): Subchannel; - /** - * Returns true if this and other both proxy the same underlying subchannel. - * Can be used instead of directly accessing getRealSubchannel to allow mocks - * to avoid implementing getRealSubchannel - */ - realSubchannelEquals(other: SubchannelInterface): boolean; -} - -export abstract class BaseSubchannelWrapper implements SubchannelInterface { - constructor(protected child: SubchannelInterface) {} - - getConnectivityState(): ConnectivityState { - return this.child.getConnectivityState(); - } - addConnectivityStateListener(listener: ConnectivityStateListener): void { - this.child.addConnectivityStateListener(listener); - } - removeConnectivityStateListener(listener: ConnectivityStateListener): void { - this.child.removeConnectivityStateListener(listener); - } - startConnecting(): void { - this.child.startConnecting(); - } - getAddress(): string { - return this.child.getAddress(); - } - throttleKeepalive(newKeepaliveTime: number): void { - this.child.throttleKeepalive(newKeepaliveTime); - } - ref(): void { - this.child.ref(); - } - unref(): void { - this.child.unref(); - } - getChannelzRef(): SubchannelRef { - return this.child.getChannelzRef(); - } - getRealSubchannel(): Subchannel { - return this.child.getRealSubchannel(); - } - realSubchannelEquals(other: SubchannelInterface): boolean { - return this.getRealSubchannel() === other.getRealSubchannel(); - } -} |
