v1alpha1

package
v0.11.3 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 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 (*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.

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 (*TrafficTargetObject) GetStatus

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

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 (*WatchPushNotificationsRequest) Reset

func (x *WatchPushNotificationsRequest) Reset()

func (*WatchPushNotificationsRequest) 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

Jump to

Keyboard shortcuts

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