extensions

Documentation

Index

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

Functions

func InputSnapshotFromProto

func InputSnapshotFromProto(name string, in *v1alpha1.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 implementating servers.

func InputSnapshotToProto

func InputSnapshotToProto(in input.LocalSnapshot) *v1alpha1.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 *v1alpha1.ObjectMeta) metav1.ObjectMeta

ObjectMetaToProto constructs a k8s ObjectMeta from a proto-compatible version

func ObjectMetaToProto

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

ObjectMetaToProto constructs a proto-compatible version of a k8s ObjectMeta

Types

type Clients

type Clients []v1alpha1.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 []*v1alpha2.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 []*v1alpha2.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 *v1alpha1.PushNotification)

A PushFunc handles push notifications from an Extensions Server