server

package

v0.12.0 Latest Latest Go to latest Published: Jan 2, 2024 License: Apache-2.0 Imports: 27 Imported by: 165

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/envoyproxy/go-control-plane

Links

Open Source Insights

Documentation ¶

Overview ¶

Package server provides an implementation of a streaming xDS server.

Index ¶

type CallbackFuncs
type Callbacks
type HTTPGateway
- func (h *HTTPGateway) ServeHTTP(req *http.Request) ([]byte, int, error)
type Server
- func NewServer(ctx context.Context, config cache.Cache, callbacks Callbacks, ...) Server
- func NewServerAdvanced(restServer rest.Server, sotwServer sotw.Server, deltaServer delta.Server) Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CallbackFuncs ¶ added in v0.9.6

type CallbackFuncs struct {
	StreamOpenFunc          func(context.Context, int64, string) error
	StreamClosedFunc        func(int64, *core.Node)
	DeltaStreamOpenFunc     func(context.Context, int64, string) error
	DeltaStreamClosedFunc   func(int64, *core.Node)
	StreamRequestFunc       func(int64, *discovery.DiscoveryRequest) error
	StreamResponseFunc      func(context.Context, int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
	StreamDeltaRequestFunc  func(int64, *discovery.DeltaDiscoveryRequest) error
	StreamDeltaResponseFunc func(int64, *discovery.DeltaDiscoveryRequest, *discovery.DeltaDiscoveryResponse)
	FetchRequestFunc        func(context.Context, *discovery.DiscoveryRequest) error
	FetchResponseFunc       func(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
}

CallbackFuncs is a convenience type for implementing the Callbacks interface.

func (CallbackFuncs) OnDeltaStreamClosed ¶ added in v0.9.9

func (c CallbackFuncs) OnDeltaStreamClosed(streamID int64, node *core.Node)

OnDeltaStreamClosed invokes DeltaStreamClosedFunc.

func (CallbackFuncs) OnDeltaStreamOpen ¶ added in v0.9.9

func (c CallbackFuncs) OnDeltaStreamOpen(ctx context.Context, streamID int64, typeURL string) error

OnDeltaStreamOpen invokes DeltaStreamOpenFunc.

func (CallbackFuncs) OnFetchRequest ¶ added in v0.9.6

func (c CallbackFuncs) OnFetchRequest(ctx context.Context, req *discovery.DiscoveryRequest) error

OnFetchRequest invokes FetchRequestFunc.

func (CallbackFuncs) OnFetchResponse ¶ added in v0.9.6

func (c CallbackFuncs) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)

OnFetchResponse invoked FetchResponseFunc.

func (CallbackFuncs) OnStreamClosed ¶ added in v0.9.6

func (c CallbackFuncs) OnStreamClosed(streamID int64, node *core.Node)

OnStreamClosed invokes StreamClosedFunc.

func (CallbackFuncs) OnStreamDeltaRequest ¶ added in v0.9.9

func (c CallbackFuncs) OnStreamDeltaRequest(streamID int64, req *discovery.DeltaDiscoveryRequest) error

OnStreamDeltaRequest invokes StreamDeltaResponseFunc

func (CallbackFuncs) OnStreamDeltaResponse ¶ added in v0.9.9

func (c CallbackFuncs) OnStreamDeltaResponse(streamID int64, req *discovery.DeltaDiscoveryRequest, resp *discovery.DeltaDiscoveryResponse)

OnStreamDeltaResponse invokes StreamDeltaResponseFunc.

func (CallbackFuncs) OnStreamOpen ¶ added in v0.9.6

func (c CallbackFuncs) OnStreamOpen(ctx context.Context, streamID int64, typeURL string) error

OnStreamOpen invokes StreamOpenFunc.

func (CallbackFuncs) OnStreamRequest ¶ added in v0.9.6

func (c CallbackFuncs) OnStreamRequest(streamID int64, req *discovery.DiscoveryRequest) error

OnStreamRequest invokes StreamRequestFunc.

func (CallbackFuncs) OnStreamResponse ¶ added in v0.9.6

func (c CallbackFuncs) OnStreamResponse(ctx context.Context, streamID int64, req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)

OnStreamResponse invokes StreamResponseFunc.

type Callbacks ¶

type Callbacks interface {
	rest.Callbacks
	sotw.Callbacks
	delta.Callbacks
}

Callbacks is a collection of callbacks inserted into the server operation. The callbacks are invoked synchronously.

type HTTPGateway ¶

type HTTPGateway struct {
	// Server is the underlying gRPC server
	Server Server
}

HTTPGateway is a custom implementation of [gRPC gateway](https://github.com/grpc-ecosystem/grpc-gateway) specialized to Envoy xDS API.

func (*HTTPGateway) ServeHTTP ¶

func (h *HTTPGateway) ServeHTTP(req *http.Request) ([]byte, int, error)

type Server ¶

type Server interface {
	endpointservice.EndpointDiscoveryServiceServer
	clusterservice.ClusterDiscoveryServiceServer
	routeservice.RouteDiscoveryServiceServer
	routeservice.ScopedRoutesDiscoveryServiceServer
	routeservice.VirtualHostDiscoveryServiceServer
	listenerservice.ListenerDiscoveryServiceServer
	discovery.AggregatedDiscoveryServiceServer
	secretservice.SecretDiscoveryServiceServer
	runtimeservice.RuntimeDiscoveryServiceServer
	extensionconfigservice.ExtensionConfigDiscoveryServiceServer
	rlsconfigservice.RateLimitConfigDiscoveryServiceServer

	rest.Server
	sotw.Server
	delta.Server
}

Server is a collection of handlers for streaming discovery requests.

func NewServer ¶

func NewServer(ctx context.Context, config cache.Cache, callbacks Callbacks, opts ...config.XDSOption) Server

NewServer creates handlers from a config watcher and callbacks.

func NewServerAdvanced ¶ added in v0.9.7

func NewServerAdvanced(restServer rest.Server, sotwServer sotw.Server, deltaServer delta.Server) Server

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL