v1alpha1

package
v0.11.2 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2020 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_v1alpha1_networking_extensions_proto protoreflect.FileDescriptor

Functions

func RegisterNetworkingExtensionsServer 

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

Types

type DiscoverySnapshot 

type DiscoverySnapshot struct {

	// all meshes in the discovery snapshot
	Meshes []*MeshObject `protobuf:"bytes,1,rep,name=meshes,proto3" json:"meshes,omitempty"`
	// all traffic targets in the discovery snapshot
	TrafficTargets []*TrafficTargetObject `protobuf:"bytes,2,rep,name=traffic_targets,json=trafficTargets,proto3" json:"traffic_targets,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) GetMeshes 

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

func (*DiscoverySnapshot) GetTrafficTargets 

func (x *DiscoverySnapshot) GetTrafficTargets() []*TrafficTargetObject

func (*DiscoverySnapshot) GetWorkloads 

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

func (*DiscoverySnapshot) ProtoMessage 

func (*DiscoverySnapshot) ProtoMessage()

func (*DiscoverySnapshot) ProtoReflect added in v0.10.8 

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 added in v0.10.8 

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 added in v0.10.8 

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 added in v0.10.4 

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 added in v0.10.4 

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

func (*GeneratedObject) ProtoMessage 

func (*GeneratedObject) ProtoMessage()

func (*GeneratedObject) ProtoReflect added in v0.10.8 

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

func (*GeneratedObject) Reset 

func (x *GeneratedObject) Reset()

func (*GeneratedObject) String 

func (x *GeneratedObject) String() string

type GeneratedObject_ConfigMap added in v0.10.4 

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

func (*GeneratedObject_ConfigMap) Descriptor deprecated added in v0.10.4 

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

Deprecated: Use GeneratedObject_ConfigMap.ProtoReflect.Descriptor instead.

func (*GeneratedObject_ConfigMap) GetData added in v0.10.4 

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

func (*GeneratedObject_ConfigMap) ProtoMessage added in v0.10.4 

func (*GeneratedObject_ConfigMap) ProtoMessage()

func (*GeneratedObject_ConfigMap) ProtoReflect added in v0.10.8 

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

func (*GeneratedObject_ConfigMap) Reset added in v0.10.4 

func (x *GeneratedObject_ConfigMap) Reset()

func (*GeneratedObject_ConfigMap) String added in v0.10.4 

func (x *GeneratedObject_ConfigMap) String() string

type GeneratedObject_ConfigMap_ added in v0.10.4 

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 added in v0.10.4 

type GeneratedObject_XdsConfig struct {
	XdsConfig *v1alpha1.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 *v1alpha2.MeshSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the status of the object
	Status *v1alpha2.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() *v1alpha2.MeshSpec

func (*MeshObject) GetStatus 

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

func (*MeshObject) ProtoMessage 

func (*MeshObject) ProtoMessage()

func (*MeshObject) ProtoReflect added in v0.10.8 

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 K8s 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 added in v0.10.8 

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 added in v0.10.8 

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

func (*PushNotification) Reset 

func (x *PushNotification) Reset()

func (*PushNotification) String 

func (x *PushNotification) String() string

type TrafficTargetObject 

type TrafficTargetObject struct {

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

a proto-serializable representation of a TrafficTarget object

func (*TrafficTargetObject) Descriptor deprecated 

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

Deprecated: Use TrafficTargetObject.ProtoReflect.Descriptor instead.

func (*TrafficTargetObject) GetMetadata 

func (x *TrafficTargetObject) GetMetadata() *ObjectMeta

func (*TrafficTargetObject) GetSpec 

func (x *TrafficTargetObject) GetSpec() *v1alpha2.TrafficTargetSpec

func (*TrafficTargetObject) GetStatus 

func (x *TrafficTargetObject) GetStatus() *v1alpha2.TrafficTargetStatus

func (*TrafficTargetObject) ProtoMessage 

func (*TrafficTargetObject) ProtoMessage()

func (*TrafficTargetObject) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetObject) Reset 

func (x *TrafficTargetObject) Reset()

func (*TrafficTargetObject) String 

func (x *TrafficTargetObject) 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 added in v0.10.8 

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 *v1alpha2.WorkloadSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the status of the object
	Status *v1alpha2.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() *v1alpha2.WorkloadSpec

func (*WorkloadObject) GetStatus 

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

func (*WorkloadObject) ProtoMessage 

func (*WorkloadObject) ProtoMessage()

func (*WorkloadObject) ProtoReflect added in v0.10.8 

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.