package server

import "google.golang.org/grpc/xds/internal/server"

Package server contains internal server-side functionality used by the public facing xds package.

Index ¶

• func NewListenerWrapper(params ListenerWrapperParams) (net.Listener, <-chan struct{})
• type ListenerWrapperParams
• type XDSClientInterface

Functions ¶

func NewListenerWrapper ¶

func NewListenerWrapper(params ListenerWrapperParams) (net.Listener, <-chan struct{})

NewListenerWrapper creates a new listenerWrapper with params. It returns a net.Listener and a channel which is written to, indicating that the former is ready to be passed to grpc.Serve().

Types ¶

type ListenerWrapperParams ¶

type ListenerWrapperParams struct {
	// Listener is the net.Listener passed by the user that is to be wrapped.
	Listener net.Listener
	// ListenerResourceName is the xDS Listener resource to request.
	ListenerResourceName string
	// XDSCredsInUse specifies whether or not the user expressed interest to
	// receive security configuration from the control plane.
	XDSCredsInUse bool
	// XDSClient provides the functionality from the xdsClient required here.
	XDSClient XDSClientInterface
}

ListenerWrapperParams wraps parameters required to create a listenerWrapper.

type XDSClientInterface ¶

type XDSClientInterface interface {
	WatchListener(string, func(xdsclient.ListenerUpdate, error)) func()
	BootstrapConfig() *bootstrap.Config
}

XDSClientInterface wraps the methods on the xdsClient which are required by the listenerWrapper.

Source Files ¶

conn_wrapper.go listener_wrapper.go