func BootstrapContentsForTesting(contents []byte) grpc.ServerOption
BootstrapContentsForTesting returns a grpc.ServerOption which allows users to inject a bootstrap configuration used by only this server, instead of the global configuration from the environment variables.
This function should ONLY be used for testing and may not work with some other features, including the CSDS service.
Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
func NewXDSResolverWithConfigForTesting(bootstrapConfig []byte) (resolver.Builder, error)
NewXDSResolverWithConfigForTesting creates a new xDS resolver builder using the provided xDS bootstrap config instead of the global configuration from the supported environment variables. The resolver.Builder is meant to be used in conjunction with the grpc.WithResolvers DialOption.
This function should ONLY be used for testing and may not work with some other features, including the CSDS service.
Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
func ServingModeCallback(cb ServingModeCallbackFunc) grpc.ServerOption
ServingModeCallback returns a grpc.ServerOption which allows users to register a callback to get notified about serving mode changes.
GRPCServer wraps a gRPC server and provides server-side xDS functionality, by communication with a management server using xDS APIs. It implements the grpc.ServiceRegistrar interface and can be passed to service registration functions in IDL generated code.
type GRPCServer struct {
// contains filtered or unexported fields
}
func NewGRPCServer(opts ...grpc.ServerOption) (*GRPCServer, error)
NewGRPCServer creates an xDS-enabled gRPC server using the passed in opts. The underlying gRPC server has no service registered and has not started to accept requests yet.
func (s *GRPCServer) GetServiceInfo() map[string]grpc.ServiceInfo
GetServiceInfo returns a map from service names to ServiceInfo. Service names include the package names, in the form of <package>.<service>.
func (s *GRPCServer) GracefulStop()
GracefulStop stops the underlying gRPC server gracefully. It stops the server from accepting new connections and RPCs and blocks until all the pending RPCs are finished.
func (s *GRPCServer) RegisterService(sd *grpc.ServiceDesc, ss any)
RegisterService registers a service and its implementation to the underlying gRPC server. It is called from the IDL generated code. This must be called before invoking Serve.
func (s *GRPCServer) Serve(lis net.Listener) error
Serve gets the underlying gRPC server to accept incoming connections on the listener lis, which is expected to be listening on a TCP port.
A connection to the management server, to receive xDS configuration, is initiated here.
Serve will return a non-nil error unless Stop or GracefulStop is called.
func (s *GRPCServer) Stop()
Stop stops the underlying gRPC server. It immediately closes all open connections. It cancels all active RPCs on the server side and the corresponding pending RPCs on the client side will get notified by connection errors.
ServingModeCallbackFunc is the callback that users can register to get notified about the server's serving mode changes. The callback is invoked with the address of the listener and its new mode.
Users must not perform any blocking operations in this callback.
type ServingModeCallbackFunc func(addr net.Addr, args ServingModeChangeArgs)
ServingModeChangeArgs wraps the arguments passed to the serving mode callback function.
type ServingModeChangeArgs struct {
// Mode is the new serving mode of the server listener.
Mode connectivity.ServingMode
// Err is set to a non-nil error if the server has transitioned into
// not-serving mode.
Err error
}
| Name | Synopsis |
|---|---|
| .. | |
| bootstrap | Package bootstrap provides the functionality to register possible options for aspects of the xDS client through the bootstrap file. |
| csds | Package csds implements features to dump the status (xDS responses) the xds_client is using. |
| googledirectpath | Package googledirectpath implements a resolver that configures xds to make cloud to prod directpath connection. |