extensions

Documentation

Index

• func InputSnapshotFromProto(name string, in *v1alpha1.DiscoverySnapshot) input.Snapshot
• func InputSnapshotToProto(in input.Snapshot) *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, ...) (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.Snapshot

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.Snapshot) *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.NetworkingExtensionsServer) (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.
	// Returns true if servers were updated, false if options have not changed
	ConfigureServers(extensionsServerOptions []*v1alpha2.NetworkingExtensionsServer) (bool, error)

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

	// WatchPushNotifications watches push notifications from the available extension servers until the Clientset's root context is cancelled.
	// Will call pushFn() when a notification is received.
	// Should be called after UpdateServers
	WatchPushNotifications(pushFn PushFunc) error
}

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