v1beta1

package
v1.0.0-beta4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_solo_io_gloo_mesh_api_networking_extensions_v1beta1_networking_extensions_proto protoreflect.FileDescriptor

Functions

func RegisterNetworkingExtensionsServer 

func RegisterNetworkingExtensionsServer(s *grpc.Server, srv NetworkingExtensionsServer)

Types

type DestinationObject 

type DestinationObject struct {

	// metadata of the object
	Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// the spec of the object
	Spec *v1.DestinationSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the status of the object
	Status *v1.DestinationStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

a proto-serializable representation of a Destination object

func (*DestinationObject) Descriptor deprecated 

func (*DestinationObject) Descriptor() ([]byte, []int)

Deprecated: Use DestinationObject.ProtoReflect.Descriptor instead.

func (*DestinationObject) GetMetadata 

func (x *DestinationObject) GetMetadata() *ObjectMeta

func (*DestinationObject) GetSpec 

func (x *DestinationObject) GetSpec() *v1.DestinationSpec

func (*DestinationObject) GetStatus 

func (x *DestinationObject) GetStatus() *v1.DestinationStatus

func (*DestinationObject) ProtoMessage 

func (*DestinationObject) ProtoMessage()

func (*DestinationObject) ProtoReflect 

func (x *DestinationObject) ProtoReflect() protoreflect.Message

func (*DestinationObject) Reset 

func (x *DestinationObject) Reset()

func (*DestinationObject) String 

func (x *DestinationObject) String() string

type DiscoverySnapshot 

type DiscoverySnapshot struct {

	// all meshes in the discovery snapshot
	Meshes []*MeshObject `protobuf:"bytes,1,rep,name=meshes,proto3" json:"meshes,omitempty"`
	// all Destinations in the discovery snapshot
	Destinations []*DestinationObject `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// all workloads in the discovery snapshot
	Workloads []*WorkloadObject `protobuf:"bytes,3,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

a Protobuf representation of the set of Discovery objects used to produce the Networking outputs.

func (*DiscoverySnapshot) Descriptor deprecated 

func (*DiscoverySnapshot) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverySnapshot.ProtoReflect.Descriptor instead.

func (*DiscoverySnapshot) GetDestinations 

func (x *DiscoverySnapshot) GetDestinations() []*DestinationObject

func (*DiscoverySnapshot) GetMeshes 

func (x *DiscoverySnapshot) GetMeshes() []*MeshObject

func (*DiscoverySnapshot) GetWorkloads 

func (x *DiscoverySnapshot) GetWorkloads() []*WorkloadObject

func (*DiscoverySnapshot) ProtoMessage 

func (*DiscoverySnapshot) ProtoMessage()

func (*DiscoverySnapshot) ProtoReflect 

func (x *DiscoverySnapshot) ProtoReflect() protoreflect.Message

func (*DiscoverySnapshot) Reset 

func (x *DiscoverySnapshot) Reset()

func (*DiscoverySnapshot) String 

func (x *DiscoverySnapshot) String() string

type ExtensionPatchRequest 

type ExtensionPatchRequest struct {

	// the set of discovery objects provided as inputs for the Gloo Mesh translation
	Inputs *DiscoverySnapshot `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// the base set of output objects translated by Gloo Mesh.
	// these may have been operated upon by a previous Extension server if multiple servers
	// have been configured.
	Outputs []*GeneratedObject `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

the parameters provided to the Extensions server when requesting patches

func (*ExtensionPatchRequest) Descriptor deprecated 

func (*ExtensionPatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExtensionPatchRequest.ProtoReflect.Descriptor instead.

func (*ExtensionPatchRequest) GetInputs 

func (x *ExtensionPatchRequest) GetInputs() *DiscoverySnapshot

func (*ExtensionPatchRequest) GetOutputs 

func (x *ExtensionPatchRequest) GetOutputs() []*GeneratedObject

func (*ExtensionPatchRequest) ProtoMessage 

func (*ExtensionPatchRequest) ProtoMessage()

func (*ExtensionPatchRequest) ProtoReflect 

func (x *ExtensionPatchRequest) ProtoReflect() protoreflect.Message

func (*ExtensionPatchRequest) Reset 

func (x *ExtensionPatchRequest) Reset()

func (*ExtensionPatchRequest) String 

func (x *ExtensionPatchRequest) String() string

type ExtensionPatchResponse 

type ExtensionPatchResponse struct {

	// the set of modified/added output objects desired by the Extension server.
	PatchedOutputs []*GeneratedObject `protobuf:"bytes,1,rep,name=patched_outputs,json=patchedOutputs,proto3" json:"patched_outputs,omitempty"`
	// contains filtered or unexported fields
}

the set of patches the server wishes to apply to the Gloo Mesh Networking outputs. Any objects provided here will be inserted into the final Gloo Mesh snapshot. If an object already exists in the snapshot, it will be overridden by the version provided here. If multiple extensions servers are configured, this response may be operated upon by Extension patches provided by subsequent servers.

func (*ExtensionPatchResponse) Descriptor deprecated 

func (*ExtensionPatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExtensionPatchResponse.ProtoReflect.Descriptor instead.

func (*ExtensionPatchResponse) GetPatchedOutputs 

func (x *ExtensionPatchResponse) GetPatchedOutputs() []*GeneratedObject

func (*ExtensionPatchResponse) ProtoMessage 

func (*ExtensionPatchResponse) ProtoMessage()

func (*ExtensionPatchResponse) ProtoReflect 

func (x *ExtensionPatchResponse) ProtoReflect() protoreflect.Message

func (*ExtensionPatchResponse) Reset 

func (x *ExtensionPatchResponse) Reset()

func (*ExtensionPatchResponse) String 

func (x *ExtensionPatchResponse) String() string

type GeneratedObject 

type GeneratedObject struct {

	// metadata of the object
	Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// type of the object.
	//
	// Types that are assignable to Type:
	//	*GeneratedObject_DestinationRule
	//	*GeneratedObject_EnvoyFilter
	//	*GeneratedObject_ServiceEntry
	//	*GeneratedObject_VirtualService
	//	*GeneratedObject_ConfigMap_
	//	*GeneratedObject_XdsConfig
	Type isGeneratedObject_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

a generated object can be of any output type supported by Gloo Mesh. the content of the type field should be used to determine the type of the output object. TODO(ilackarms): consider parameterizing Gloo Mesh to allow excluding GeneratedObjects from patch requests in the case where an implementer only performs additions (no updates required).

func (*GeneratedObject) Descriptor deprecated 

func (*GeneratedObject) Descriptor() ([]byte, []int)

Deprecated: Use GeneratedObject.ProtoReflect.Descriptor instead.

func (*GeneratedObject) GetConfigMap 

func (x *GeneratedObject) GetConfigMap() *GeneratedObject_ConfigMap

func (*GeneratedObject) GetDestinationRule 

func (x *GeneratedObject) GetDestinationRule() *v1alpha3.DestinationRule

func (*GeneratedObject) GetEnvoyFilter 

func (x *GeneratedObject) GetEnvoyFilter() *v1alpha3.EnvoyFilter

func (*GeneratedObject) GetMetadata 

func (x *GeneratedObject) GetMetadata() *ObjectMeta

func (*GeneratedObject) GetServiceEntry 

func (x *GeneratedObject) GetServiceEntry() *v1alpha3.ServiceEntry

func (*GeneratedObject) GetType 

func (m *GeneratedObject) GetType() isGeneratedObject_Type

func (*GeneratedObject) GetVirtualService 

func (x *GeneratedObject) GetVirtualService() *v1alpha3.VirtualService

func (*GeneratedObject) GetXdsConfig 

func (x *GeneratedObject) GetXdsConfig() *v1beta1.XdsConfigSpec

func (*GeneratedObject) ProtoMessage 

func (*GeneratedObject) ProtoMessage()

func (*GeneratedObject) ProtoReflect 

func (x *GeneratedObject) ProtoReflect() protoreflect.Message

func (*GeneratedObject) Reset 

func (x *GeneratedObject) Reset()

func (*GeneratedObject) String 

func (x *GeneratedObject) String() string

type GeneratedObject_ConfigMap 

type GeneratedObject_ConfigMap struct {
	Data map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GeneratedObject_ConfigMap) Descriptor deprecated 

func (*GeneratedObject_ConfigMap) Descriptor() ([]byte, []int)

Deprecated: Use GeneratedObject_ConfigMap.ProtoReflect.Descriptor instead.

func (*GeneratedObject_ConfigMap) GetData 

func (x *GeneratedObject_ConfigMap) GetData() map[string]string

func (*GeneratedObject_ConfigMap) ProtoMessage 

func (*GeneratedObject_ConfigMap) ProtoMessage()

func (*GeneratedObject_ConfigMap) ProtoReflect 

func (x *GeneratedObject_ConfigMap) ProtoReflect() protoreflect.Message

func (*GeneratedObject_ConfigMap) Reset 

func (x *GeneratedObject_ConfigMap) Reset()

func (*GeneratedObject_ConfigMap) String 

func (x *GeneratedObject_ConfigMap) String() string

type GeneratedObject_ConfigMap_ 

type GeneratedObject_ConfigMap_ struct {
	ConfigMap *GeneratedObject_ConfigMap `protobuf:"bytes,6,opt,name=config_map,json=configMap,proto3,oneof"`
}

type GeneratedObject_DestinationRule 

type GeneratedObject_DestinationRule struct {
	DestinationRule *v1alpha3.DestinationRule `protobuf:"bytes,2,opt,name=destination_rule,json=destinationRule,proto3,oneof"`
}

type GeneratedObject_EnvoyFilter 

type GeneratedObject_EnvoyFilter struct {
	EnvoyFilter *v1alpha3.EnvoyFilter `protobuf:"bytes,3,opt,name=envoy_filter,json=envoyFilter,proto3,oneof"`
}

type GeneratedObject_ServiceEntry 

type GeneratedObject_ServiceEntry struct {
	ServiceEntry *v1alpha3.ServiceEntry `protobuf:"bytes,4,opt,name=service_entry,json=serviceEntry,proto3,oneof"`
}

type GeneratedObject_VirtualService 

type GeneratedObject_VirtualService struct {
	VirtualService *v1alpha3.VirtualService `protobuf:"bytes,5,opt,name=virtual_service,json=virtualService,proto3,oneof"`
}

type GeneratedObject_XdsConfig 

type GeneratedObject_XdsConfig struct {
	XdsConfig *v1beta1.XdsConfigSpec `protobuf:"bytes,7,opt,name=xds_config,json=xdsConfig,proto3,oneof"`
}

type MeshObject 

type MeshObject struct {

	// metadata of the object
	Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// the spec of the object
	Spec *v1.MeshSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the status of the object
	Status *v1.MeshStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

a proto-serializable representation of a Mesh object

func (*MeshObject) Descriptor deprecated 

func (*MeshObject) Descriptor() ([]byte, []int)

Deprecated: Use MeshObject.ProtoReflect.Descriptor instead.

func (*MeshObject) GetMetadata 

func (x *MeshObject) GetMetadata() *ObjectMeta

func (*MeshObject) GetSpec 

func (x *MeshObject) GetSpec() *v1.MeshSpec

func (*MeshObject) GetStatus 

func (x *MeshObject) GetStatus() *v1.MeshStatus

func (*MeshObject) ProtoMessage 

func (*MeshObject) ProtoMessage()

func (*MeshObject) ProtoReflect 

func (x *MeshObject) ProtoReflect() protoreflect.Message

func (*MeshObject) Reset 

func (x *MeshObject) Reset()

func (*MeshObject) String 

func (x *MeshObject) String() string

type NetworkingExtensionsClient 

type NetworkingExtensionsClient interface {
	// GetExtensionPatches fetches a set of patches to the output configuration from the Extensions server.
	// The current discovery snapshot and translated outputs are provided in the ExtensionPatchRequest
	GetExtensionPatches(ctx context.Context, in *ExtensionPatchRequest, opts ...grpc.CallOption) (*ExtensionPatchResponse, error)
	// WatchPushNotifications initiates a streaming connection which allows the NetworkingExtensions server
	// to push notifications to Gloo Mesh telling it to resync its configuration.
	// This allows a NetworkingExtensions server to trigger Gloo Mesh to resync its state for
	// events triggered by objects not watched by Gloo Mesh.
	WatchPushNotifications(ctx context.Context, in *WatchPushNotificationsRequest, opts ...grpc.CallOption) (NetworkingExtensions_WatchPushNotificationsClient, error)
}

NetworkingExtensionsClient is the client API for NetworkingExtensions service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNetworkingExtensionsClient 

func NewNetworkingExtensionsClient(cc grpc.ClientConnInterface) NetworkingExtensionsClient

type NetworkingExtensionsServer 

type NetworkingExtensionsServer interface {
	// GetExtensionPatches fetches a set of patches to the output configuration from the Extensions server.
	// The current discovery snapshot and translated outputs are provided in the ExtensionPatchRequest
	GetExtensionPatches(context.Context, *ExtensionPatchRequest) (*ExtensionPatchResponse, error)
	// WatchPushNotifications initiates a streaming connection which allows the NetworkingExtensions server
	// to push notifications to Gloo Mesh telling it to resync its configuration.
	// This allows a NetworkingExtensions server to trigger Gloo Mesh to resync its state for
	// events triggered by objects not watched by Gloo Mesh.
	WatchPushNotifications(*WatchPushNotificationsRequest, NetworkingExtensions_WatchPushNotificationsServer) error
}

NetworkingExtensionsServer is the server API for NetworkingExtensions service.

type NetworkingExtensions_WatchPushNotificationsClient 

type NetworkingExtensions_WatchPushNotificationsClient interface {
	Recv() (*PushNotification, error)
	grpc.ClientStream
}

type NetworkingExtensions_WatchPushNotificationsServer 

type NetworkingExtensions_WatchPushNotificationsServer interface {
	Send(*PushNotification) error
	grpc.ServerStream
}

type ObjectMeta 

type ObjectMeta struct {

	// the Kubernetes name of the object
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the Kubernetes namespace of the object
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// the Kubernetes clusterName of the object (used internally by Gloo Mesh)
	ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// the Kubernetes labels on the object
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// the Kubernetes annotations on the object
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

ObjectMeta is a simplified clone of the Kubernetes ObjectMeta used to represent object metadata for Kubernetes objects passed as messages in the NetworkingExtensions API.

func (*ObjectMeta) Descriptor deprecated 

func (*ObjectMeta) Descriptor() ([]byte, []int)

Deprecated: Use ObjectMeta.ProtoReflect.Descriptor instead.

func (*ObjectMeta) GetAnnotations 

func (x *ObjectMeta) GetAnnotations() map[string]string

func (*ObjectMeta) GetClusterName 

func (x *ObjectMeta) GetClusterName() string

func (*ObjectMeta) GetLabels 

func (x *ObjectMeta) GetLabels() map[string]string

func (*ObjectMeta) GetName 

func (x *ObjectMeta) GetName() string

func (*ObjectMeta) GetNamespace 

func (x *ObjectMeta) GetNamespace() string

func (*ObjectMeta) ProtoMessage 

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) ProtoReflect 

func (x *ObjectMeta) ProtoReflect() protoreflect.Message

func (*ObjectMeta) Reset 

func (x *ObjectMeta) Reset()

func (*ObjectMeta) String 

func (x *ObjectMeta) String() string

type PushNotification 

type PushNotification struct {
	// contains filtered or unexported fields
}

triggers a resync of Gloo Mesh objects

func (*PushNotification) Descriptor deprecated 

func (*PushNotification) Descriptor() ([]byte, []int)

Deprecated: Use PushNotification.ProtoReflect.Descriptor instead.

func (*PushNotification) ProtoMessage 

func (*PushNotification) ProtoMessage()

func (*PushNotification) ProtoReflect 

func (x *PushNotification) ProtoReflect() protoreflect.Message

func (*PushNotification) Reset 

func (x *PushNotification) Reset()

func (*PushNotification) String 

func (x *PushNotification) String() string

type UnimplementedNetworkingExtensionsServer 

type UnimplementedNetworkingExtensionsServer struct {
}

UnimplementedNetworkingExtensionsServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkingExtensionsServer) GetExtensionPatches 

func (*UnimplementedNetworkingExtensionsServer) GetExtensionPatches(context.Context, *ExtensionPatchRequest) (*ExtensionPatchResponse, error)

func (*UnimplementedNetworkingExtensionsServer) WatchPushNotifications 

func (*UnimplementedNetworkingExtensionsServer) WatchPushNotifications(*WatchPushNotificationsRequest, NetworkingExtensions_WatchPushNotificationsServer) error

type WatchPushNotificationsRequest 

type WatchPushNotificationsRequest struct {
	// contains filtered or unexported fields
}

request to initiate push notifications

func (*WatchPushNotificationsRequest) Descriptor deprecated 

func (*WatchPushNotificationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchPushNotificationsRequest.ProtoReflect.Descriptor instead.

func (*WatchPushNotificationsRequest) ProtoMessage 

func (*WatchPushNotificationsRequest) ProtoMessage()

func (*WatchPushNotificationsRequest) ProtoReflect 

func (x *WatchPushNotificationsRequest) ProtoReflect() protoreflect.Message

func (*WatchPushNotificationsRequest) Reset 

func (x *WatchPushNotificationsRequest) Reset()

func (*WatchPushNotificationsRequest) String 

func (x *WatchPushNotificationsRequest) String() string

type WorkloadObject 

type WorkloadObject struct {

	// metadata of the object
	Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// the spec of the object
	Spec *v1.WorkloadSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the status of the object
	Status *v1.WorkloadStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

a proto-serializable representation of a Workload object

func (*WorkloadObject) Descriptor deprecated 

func (*WorkloadObject) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadObject.ProtoReflect.Descriptor instead.

func (*WorkloadObject) GetMetadata 

func (x *WorkloadObject) GetMetadata() *ObjectMeta

func (*WorkloadObject) GetSpec 

func (x *WorkloadObject) GetSpec() *v1.WorkloadSpec

func (*WorkloadObject) GetStatus 

func (x *WorkloadObject) GetStatus() *v1.WorkloadStatus

func (*WorkloadObject) ProtoMessage 

func (*WorkloadObject) ProtoMessage()

func (*WorkloadObject) ProtoReflect 

func (x *WorkloadObject) ProtoReflect() protoreflect.Message

func (*WorkloadObject) Reset 

func (x *WorkloadObject) Reset()

func (*WorkloadObject) String 

func (x *WorkloadObject) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.