extensions

package

v1.1.2 Latest Latest Go to latest Published: Sep 29, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

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/solo-io/gloo-mesh

Documentation ¶

Index ¶

func InputSnapshotFromProto(name string, in *v1beta1.DiscoverySnapshot) input.LocalSnapshot
func InputSnapshotToProto(in input.LocalSnapshot) *v1beta1.DiscoverySnapshot
func NewClientset(rootCtx context.Context) *clientset
func ObjectMetaFromProto(meta *v1beta1.ObjectMeta) metav1.ObjectMeta
func ObjectMetaToProto(meta metav1.ObjectMeta) *v1beta1.ObjectMeta
type Clients
- func NewClientsFromSettings(ctx context.Context, extensionsServerOptions []*settingsv1.GrpcServer) (Clients, error)
- func (c Clients) WatchPushNotifications(ctx context.Context, pushFn PushFunc) error
type Clientset
type PushFunc

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InputSnapshotFromProto ¶

func InputSnapshotFromProto(name string, in *v1beta1.DiscoverySnapshot) input.LocalSnapshot

InputSnapshotFromProto constructs a Networking input snapshot from proto Discovery Snapshot This method is not intended to be used here, but called from implementing servers.

func InputSnapshotToProto ¶

func InputSnapshotToProto(in input.LocalSnapshot) *v1beta1.DiscoverySnapshot

InputSnapshotToProto constructs a proto-compatible Discovery Snapshot from a networking input snapshot

func NewClientset ¶

func NewClientset(rootCtx context.Context) *clientset

func ObjectMetaFromProto ¶

func ObjectMetaFromProto(meta *v1beta1.ObjectMeta) metav1.ObjectMeta

ObjectMetaToProto constructs a k8s ObjectMeta from a proto-compatible version

func ObjectMetaToProto ¶

func ObjectMetaToProto(meta metav1.ObjectMeta) *v1beta1.ObjectMeta

ObjectMetaToProto constructs a proto-compatible version of a k8s ObjectMeta

Types ¶

type Clients ¶

type Clients []v1beta1.NetworkingExtensionsClient

Clients provides a convenience wrapper for a set of clients to communicate with multiple Extension Servers

func NewClientsFromSettings ¶

func NewClientsFromSettings(ctx context.Context, extensionsServerOptions []*settingsv1.GrpcServer) (Clients, error)

func (Clients) WatchPushNotifications ¶

func (c Clients) WatchPushNotifications(ctx context.Context, pushFn PushFunc) error

WatchPushNotifications watches push notifications from the available extension servers until the context is cancelled. Will call pushFn() when a notification is received.

type Clientset ¶

type Clientset interface {
	// ConfigureServers updates the set of servers this Clientset is configured with.
	// Restarts the notification watches if servers were updated, using the new pushFn to handle notification pushes.
	ConfigureServers(extensionsServerOptions []*settingsv1.GrpcServer, pushFn PushFunc) error

	// GetClients returns the set of Extension clients that are cached with this Clientset.
	// Must be called after UpdateServers
	GetClients() Clients
}

Clientset provides a handle to fetching a set of cached gRPC clients

type PushFunc ¶

type PushFunc func(notification *v1beta1.PushNotification)

A PushFunc handles push notifications from an Extensions Server

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mocks Package mock_extensions is a generated GoMock package.	Package mock_extensions is a generated GoMock package.

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