v1

package
v1.1.0-beta27 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2021 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the discovery.mesh.gloo.solo.io v1 API group +k8s:deepcopy-gen=package,register +groupName=discovery.mesh.gloo.solo.io

NOTE: Boilerplate only. Ignore this file. Used to register the Go types with the Kubernetes internal scheme

Definitions for the Kubernetes types

Definitions for the Kubernetes types

Index

Constants

This section is empty.

Variables

View Source 
var (
	DestinationSpec_KubeService_ServiceType_name = map[int32]string{
		0: "CLUSTER_IP",
		1: "NODE_PORT",
		2: "LOAD_BALANCER",
		3: "EXTERNAL_NAME",
	}
	DestinationSpec_KubeService_ServiceType_value = map[string]int32{
		"CLUSTER_IP":    0,
		"NODE_PORT":     1,
		"LOAD_BALANCER": 2,
		"EXTERNAL_NAME": 3,
	}
)

Enum value maps for DestinationSpec_KubeService_ServiceType.

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "discovery.mesh.gloo.solo.io", Version: "v1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var DestinationGVK = schema.GroupVersionKind{
	Group:   "discovery.mesh.gloo.solo.io",
	Version: "v1",
	Kind:    "Destination",
}

GroupVersionKind for Destination

View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1_destination_proto protoreflect.FileDescriptor
View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1_mesh_proto protoreflect.FileDescriptor
View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1_workload_proto protoreflect.FileDescriptor
View Source 
var MeshGVK = schema.GroupVersionKind{
	Group:   "discovery.mesh.gloo.solo.io",
	Version: "v1",
	Kind:    "Mesh",
}

GroupVersionKind for Mesh

View Source 
var WorkloadGVK = schema.GroupVersionKind{
	Group:   "discovery.mesh.gloo.solo.io",
	Version: "v1",
	Kind:    "Workload",
}

GroupVersionKind for Workload

Functions

func AddToScheme 

func AddToScheme(s *runtime.Scheme) error

func NewDestinationClient 

func NewDestinationClient(client client.Client) *destinationClient

func NewMeshClient 

func NewMeshClient(client client.Client) *meshClient

func NewWorkloadClient 

func NewWorkloadClient(client client.Client) *workloadClient

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Clientset 

type Clientset interface {
	// clienset for the discovery.mesh.gloo.solo.io/v1/v1 APIs
	Destinations() DestinationClient
	// clienset for the discovery.mesh.gloo.solo.io/v1/v1 APIs
	Workloads() WorkloadClient
	// clienset for the discovery.mesh.gloo.solo.io/v1/v1 APIs
	Meshes() MeshClient
}

clienset for the discovery.mesh.gloo.solo.io/v1 APIs

func NewClientset 

func NewClientset(client client.Client) Clientset

func NewClientsetFromConfig 

func NewClientsetFromConfig(cfg *rest.Config) (Clientset, error)

type Destination 

type Destination struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DestinationSpec   `json:"spec,omitempty"`
	Status DestinationStatus `json:"status,omitempty"`
}

Destination is the Schema for the destination API

func (*Destination) DeepCopy 

func (in *Destination) DeepCopy() *Destination

func (*Destination) DeepCopyInto 

func (in *Destination) DeepCopyInto(out *Destination)

func (*Destination) DeepCopyObject 

func (in *Destination) DeepCopyObject() runtime.Object

func (Destination) GVK 

func (Destination) GVK() schema.GroupVersionKind

GVK returns the GroupVersionKind associated with the resource type.

type DestinationClient 

type DestinationClient interface {
	DestinationReader
	DestinationWriter
	DestinationStatusWriter
}

Client knows how to perform CRUD operations on Destinations.

type DestinationList 

type DestinationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Destination `json:"items"`
}

DestinationList contains a list of Destination

func (*DestinationList) DeepCopy 

func (in *DestinationList) DeepCopy() *DestinationList

func (*DestinationList) DeepCopyInto 

func (in *DestinationList) DeepCopyInto(out *DestinationList)

func (*DestinationList) DeepCopyObject 

func (in *DestinationList) DeepCopyObject() runtime.Object

type DestinationReader 

type DestinationReader interface {
	// Get retrieves a Destination for the given object key
	GetDestination(ctx context.Context, key client.ObjectKey) (*Destination, error)

	// List retrieves list of Destinations for a given namespace and list options.
	ListDestination(ctx context.Context, opts ...client.ListOption) (*DestinationList, error)
}

Reader knows how to read and list Destinations.

type DestinationSlice 

type DestinationSlice []*Destination

DestinationSlice represents a slice of *Destination

type DestinationSpec 

type DestinationSpec struct {

	// Describes the platform-specific Destination.
	//
	// Types that are assignable to Type:
	//	*DestinationSpec_KubeService_
	//	*DestinationSpec_ExternalService_
	Type isDestinationSpec_Type `protobuf_oneof:"type"`
	// The mesh that controls this Destination. Can be omitted if the
	// Destination isn't associated with any particular mesh, eg for External Services.
	Mesh *v1.ObjectRef `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// contains filtered or unexported fields
}

The Destination is an abstraction for any entity capable of receiving networking requests.

func (*DestinationSpec) DeepCopyInto 

func (in *DestinationSpec) DeepCopyInto(out *DestinationSpec)

DeepCopyInto for the Destination.Spec

func (*DestinationSpec) Descriptor deprecated 

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

Deprecated: Use DestinationSpec.ProtoReflect.Descriptor instead.

func (*DestinationSpec) Equal 

func (m *DestinationSpec) Equal(that interface{}) bool

Equal function

func (*DestinationSpec) GetExternalService 

func (x *DestinationSpec) GetExternalService() *DestinationSpec_ExternalService

func (*DestinationSpec) GetKubeService 

func (x *DestinationSpec) GetKubeService() *DestinationSpec_KubeService

func (*DestinationSpec) GetMesh 

func (x *DestinationSpec) GetMesh() *v1.ObjectRef

func (*DestinationSpec) GetType 

func (m *DestinationSpec) GetType() isDestinationSpec_Type

func (*DestinationSpec) Hash 

func (m *DestinationSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec) MarshalJSON 

func (this *DestinationSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for DestinationSpec

func (*DestinationSpec) ProtoMessage 

func (*DestinationSpec) ProtoMessage()

func (*DestinationSpec) ProtoReflect 

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

func (*DestinationSpec) Reset 

func (x *DestinationSpec) Reset()

func (*DestinationSpec) String 

func (x *DestinationSpec) String() string

func (*DestinationSpec) UnmarshalJSON 

func (this *DestinationSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for DestinationSpec

type DestinationSpec_ExternalService 

type DestinationSpec_ExternalService struct {

	// The name of the service
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The list of hosts which will resolve to this Destination for
	// services within the Virtual Mesh.
	Hosts []string `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// The List of addresses which will resolve to this service for
	// services within the Virtual Mesh.
	Addresses []string `protobuf:"bytes,3,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// The associated ports of the external service
	Ports []*DestinationSpec_ExternalService_ServicePort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// List of endpoints, to which any requests to this Destionation
	// will be load balanced across.
	Endpoints []*DestinationSpec_ExternalService_ExternalEndpoint `protobuf:"bytes,5,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

Describes a service external to the mesh

func (*DestinationSpec_ExternalService) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_ExternalService.ProtoReflect.Descriptor instead.

func (*DestinationSpec_ExternalService) Equal 

func (m *DestinationSpec_ExternalService) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_ExternalService) GetAddresses 

func (x *DestinationSpec_ExternalService) GetAddresses() []string

func (*DestinationSpec_ExternalService) GetEndpoints 

func (x *DestinationSpec_ExternalService) GetEndpoints() []*DestinationSpec_ExternalService_ExternalEndpoint

func (*DestinationSpec_ExternalService) GetHosts 

func (x *DestinationSpec_ExternalService) GetHosts() []string

func (*DestinationSpec_ExternalService) GetName 

func (x *DestinationSpec_ExternalService) GetName() string

func (*DestinationSpec_ExternalService) GetPorts 

func (x *DestinationSpec_ExternalService) GetPorts() []*DestinationSpec_ExternalService_ServicePort

func (*DestinationSpec_ExternalService) Hash 

func (m *DestinationSpec_ExternalService) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_ExternalService) ProtoMessage 

func (*DestinationSpec_ExternalService) ProtoMessage()

func (*DestinationSpec_ExternalService) ProtoReflect 

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

func (*DestinationSpec_ExternalService) Reset 

func (x *DestinationSpec_ExternalService) Reset()

func (*DestinationSpec_ExternalService) String 

func (x *DestinationSpec_ExternalService) String() string

type DestinationSpec_ExternalService_ 

type DestinationSpec_ExternalService_ struct {
	// ExternalService is a Destination representing a service
	// external to the Mesh. It can be used to expose a given hostname
	// or IP address to all clusters in the Virtual Mesh.
	ExternalService *DestinationSpec_ExternalService `protobuf:"bytes,3,opt,name=external_service,json=externalService,proto3,oneof"`
}

type DestinationSpec_ExternalService_ExternalEndpoint 

type DestinationSpec_ExternalService_ExternalEndpoint struct {

	// The address of the external service. Can be a domain or an IP.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// The port(s) of the external endpoint. Eg: `https: 443`
	Ports map[string]uint32 `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

ExternalEndpoint represents the address/port(s) of the external service which will receive requests sent to this Destination.

func (*DestinationSpec_ExternalService_ExternalEndpoint) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_ExternalService_ExternalEndpoint.ProtoReflect.Descriptor instead.

func (*DestinationSpec_ExternalService_ExternalEndpoint) Equal 

func (m *DestinationSpec_ExternalService_ExternalEndpoint) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_ExternalService_ExternalEndpoint) GetAddress 

func (x *DestinationSpec_ExternalService_ExternalEndpoint) GetAddress() string

func (*DestinationSpec_ExternalService_ExternalEndpoint) GetPorts 

func (x *DestinationSpec_ExternalService_ExternalEndpoint) GetPorts() map[string]uint32

func (*DestinationSpec_ExternalService_ExternalEndpoint) Hash 

func (m *DestinationSpec_ExternalService_ExternalEndpoint) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_ExternalService_ExternalEndpoint) ProtoMessage 

func (*DestinationSpec_ExternalService_ExternalEndpoint) ProtoMessage()

func (*DestinationSpec_ExternalService_ExternalEndpoint) ProtoReflect 

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

func (*DestinationSpec_ExternalService_ExternalEndpoint) Reset 

func (x *DestinationSpec_ExternalService_ExternalEndpoint) Reset()

func (*DestinationSpec_ExternalService_ExternalEndpoint) String 

func (x *DestinationSpec_ExternalService_ExternalEndpoint) String() string

type DestinationSpec_ExternalService_ServicePort 

type DestinationSpec_ExternalService_ServicePort struct {

	// The port number. Must be a valid, non-negative integer port number.
	Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// A label for the port, eg "http"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The protocol used in communications with this Destination
	// MUST BE one of HTTP|HTTPS|GRPC|HTTP2|MONGO|TCP|TLS.
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

ServicePort describes a port accessible on this Destination

func (*DestinationSpec_ExternalService_ServicePort) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_ExternalService_ServicePort.ProtoReflect.Descriptor instead.

func (*DestinationSpec_ExternalService_ServicePort) Equal 

func (m *DestinationSpec_ExternalService_ServicePort) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_ExternalService_ServicePort) GetName 

func (x *DestinationSpec_ExternalService_ServicePort) GetName() string

func (*DestinationSpec_ExternalService_ServicePort) GetNumber 

func (x *DestinationSpec_ExternalService_ServicePort) GetNumber() uint32

func (*DestinationSpec_ExternalService_ServicePort) GetProtocol 

func (x *DestinationSpec_ExternalService_ServicePort) GetProtocol() string

func (*DestinationSpec_ExternalService_ServicePort) Hash 

func (m *DestinationSpec_ExternalService_ServicePort) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_ExternalService_ServicePort) ProtoMessage 

func (*DestinationSpec_ExternalService_ServicePort) ProtoMessage()

func (*DestinationSpec_ExternalService_ServicePort) ProtoReflect 

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

func (*DestinationSpec_ExternalService_ServicePort) Reset 

func (x *DestinationSpec_ExternalService_ServicePort) Reset()

func (*DestinationSpec_ExternalService_ServicePort) String 

func (x *DestinationSpec_ExternalService_ServicePort) String() string

type DestinationSpec_KubeService 

type DestinationSpec_KubeService struct {

	// Reference to the Kubernetes service object.
	Ref *v1.ClusterObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Selectors for the set of pods targeted by the Kubernetes service.
	WorkloadSelectorLabels map[string]string `` /* 217-byte string literal not displayed */
	// Labels on the Kubernetes service.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The ports exposed by the underlying service.
	Ports []*DestinationSpec_KubeService_KubeServicePort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// Subsets for routing, based on labels.
	Subsets map[string]*DestinationSpec_KubeService_Subset `` /* 155-byte string literal not displayed */
	// The region the service resides in, typically representing a large geographic area.
	Region string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	// Each endpoints subset is a group of endpoints arranged in terms of IP/port pairs.
	// This API mirrors the [Kubernetes Endpoints API](https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.20/#endpoints-v1-core).
	EndpointSubsets []*DestinationSpec_KubeService_EndpointsSubset `protobuf:"bytes,7,rep,name=endpoint_subsets,json=endpointSubsets,proto3" json:"endpoint_subsets,omitempty"`
	// Describes the address data for Kubernetes Services exposed to external traffic (i.e. for non ClusterIP type Services).
	ExternalAddresses []*DestinationSpec_KubeService_ExternalAddress `protobuf:"bytes,8,rep,name=external_addresses,json=externalAddresses,proto3" json:"external_addresses,omitempty"`
	// Describes the Kubernetes Service type.
	ServiceType DestinationSpec_KubeService_ServiceType `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

Describes a Kubernetes service.

func (*DestinationSpec_KubeService) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService) Equal 

func (m *DestinationSpec_KubeService) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService) GetEndpointSubsets 

func (x *DestinationSpec_KubeService) GetEndpointSubsets() []*DestinationSpec_KubeService_EndpointsSubset

func (*DestinationSpec_KubeService) GetExternalAddresses added in v1.1.0 

func (x *DestinationSpec_KubeService) GetExternalAddresses() []*DestinationSpec_KubeService_ExternalAddress

func (*DestinationSpec_KubeService) GetLabels 

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

func (*DestinationSpec_KubeService) GetPorts 

func (x *DestinationSpec_KubeService) GetPorts() []*DestinationSpec_KubeService_KubeServicePort

func (*DestinationSpec_KubeService) GetRef 

func (x *DestinationSpec_KubeService) GetRef() *v1.ClusterObjectRef

func (*DestinationSpec_KubeService) GetRegion 

func (x *DestinationSpec_KubeService) GetRegion() string

func (*DestinationSpec_KubeService) GetServiceType added in v1.1.0 

func (x *DestinationSpec_KubeService) GetServiceType() DestinationSpec_KubeService_ServiceType

func (*DestinationSpec_KubeService) GetSubsets 

func (x *DestinationSpec_KubeService) GetSubsets() map[string]*DestinationSpec_KubeService_Subset

func (*DestinationSpec_KubeService) GetWorkloadSelectorLabels 

func (x *DestinationSpec_KubeService) GetWorkloadSelectorLabels() map[string]string

func (*DestinationSpec_KubeService) Hash 

func (m *DestinationSpec_KubeService) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService) ProtoMessage 

func (*DestinationSpec_KubeService) ProtoMessage()

func (*DestinationSpec_KubeService) ProtoReflect 

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

func (*DestinationSpec_KubeService) Reset 

func (x *DestinationSpec_KubeService) Reset()

func (*DestinationSpec_KubeService) String 

func (x *DestinationSpec_KubeService) String() string

type DestinationSpec_KubeService_ 

type DestinationSpec_KubeService_ struct {
	// KubeService is a kube-native Destination representing a kubernetes
	// service running inside of a kubernetes cluster.
	KubeService *DestinationSpec_KubeService `protobuf:"bytes,1,opt,name=kube_service,json=kubeService,proto3,oneof"`
}

type DestinationSpec_KubeService_EndpointPort added in v1.0.4 

type DestinationSpec_KubeService_EndpointPort struct {

	// Port on which the endpoints can be reached
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the port
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Protocol on which this port serves traffic (HTTP, TCP, UDP, etc...)
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Available in Kubernetes 1.18+, describes the application protocol.
	AppProtocol string `protobuf:"bytes,4,opt,name=app_protocol,json=appProtocol,proto3" json:"app_protocol,omitempty"`
	// contains filtered or unexported fields
}

Describes the endpoints's ports. See [here](https://kubernetes.io/docs/reference/kubernetes-api/service-resources/endpoints-v1/) for more information.

func (*DestinationSpec_KubeService_EndpointPort) Descriptor deprecated added in v1.0.4 

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

Deprecated: Use DestinationSpec_KubeService_EndpointPort.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_EndpointPort) Equal added in v1.0.4 

func (m *DestinationSpec_KubeService_EndpointPort) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_EndpointPort) GetAppProtocol added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) GetAppProtocol() string

func (*DestinationSpec_KubeService_EndpointPort) GetName added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) GetName() string

func (*DestinationSpec_KubeService_EndpointPort) GetPort added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) GetPort() uint32

func (*DestinationSpec_KubeService_EndpointPort) GetProtocol added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) GetProtocol() string

func (*DestinationSpec_KubeService_EndpointPort) Hash added in v1.0.4 

func (m *DestinationSpec_KubeService_EndpointPort) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_EndpointPort) ProtoMessage added in v1.0.4 

func (*DestinationSpec_KubeService_EndpointPort) ProtoMessage()

func (*DestinationSpec_KubeService_EndpointPort) ProtoReflect added in v1.0.4 

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

func (*DestinationSpec_KubeService_EndpointPort) Reset added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) Reset()

func (*DestinationSpec_KubeService_EndpointPort) String added in v1.0.4 

func (x *DestinationSpec_KubeService_EndpointPort) String() string

type DestinationSpec_KubeService_EndpointsSubset 

type DestinationSpec_KubeService_EndpointsSubset struct {
	Endpoints []*DestinationSpec_KubeService_EndpointsSubset_Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Ports     []*DestinationSpec_KubeService_EndpointPort             `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

A series of IP addresses and their associated ports. The list of IP and port pairs is the cartesian product of the endpoint and port lists.

func (*DestinationSpec_KubeService_EndpointsSubset) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService_EndpointsSubset.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_EndpointsSubset) Equal 

func (m *DestinationSpec_KubeService_EndpointsSubset) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_EndpointsSubset) GetEndpoints 

func (x *DestinationSpec_KubeService_EndpointsSubset) GetEndpoints() []*DestinationSpec_KubeService_EndpointsSubset_Endpoint

func (*DestinationSpec_KubeService_EndpointsSubset) GetPorts 

func (x *DestinationSpec_KubeService_EndpointsSubset) GetPorts() []*DestinationSpec_KubeService_EndpointPort

func (*DestinationSpec_KubeService_EndpointsSubset) Hash 

func (m *DestinationSpec_KubeService_EndpointsSubset) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_EndpointsSubset) ProtoMessage 

func (*DestinationSpec_KubeService_EndpointsSubset) ProtoMessage()

func (*DestinationSpec_KubeService_EndpointsSubset) ProtoReflect 

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

func (*DestinationSpec_KubeService_EndpointsSubset) Reset 

func (x *DestinationSpec_KubeService_EndpointsSubset) Reset()

func (*DestinationSpec_KubeService_EndpointsSubset) String 

func (x *DestinationSpec_KubeService_EndpointsSubset) String() string

type DestinationSpec_KubeService_EndpointsSubset_Endpoint 

type DestinationSpec_KubeService_EndpointsSubset_Endpoint struct {
	IpAddress string `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// Labels which belong to this IP. These are taken from the backing workload instance.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The zone and sub-zone (if controlled by Istio) of the endpoint.
	SubLocality *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality `protobuf:"bytes,3,opt,name=sub_locality,json=subLocality,proto3" json:"sub_locality,omitempty"`
	// contains filtered or unexported fields
}

An endpoint exposed by this service.

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService_EndpointsSubset_Endpoint.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) Equal 

func (m *DestinationSpec_KubeService_EndpointsSubset_Endpoint) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) GetIpAddress 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint) GetIpAddress() string

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) GetLabels 

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

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) GetSubLocality 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint) GetSubLocality() *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) Hash 

func (m *DestinationSpec_KubeService_EndpointsSubset_Endpoint) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) ProtoMessage 

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) ProtoMessage()

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) ProtoReflect 

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

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) Reset 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint) Reset()

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint) String 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint) String() string

type DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality 

type DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality struct {

	// A subdivision of a geographical region, see [here](https://kubernetes.io/docs/reference/labels-annotations-taints/#topologykubernetesiozone) for more information.
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// A subdivision of zone. Only applies to Istio-controlled Destinations, see [here](https://istio.io/latest/docs/tasks/traffic-management/locality-load-balancing/) for more information.
	SubZone string `protobuf:"bytes,2,opt,name=sub_zone,json=subZone,proto3" json:"sub_zone,omitempty"`
	// contains filtered or unexported fields
}

A subdivision of a region representing a set of physically colocated compute resources.

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Equal 

func (m *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) GetSubZone 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) GetSubZone() string

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) GetZone 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) GetZone() string

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Hash 

func (m *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) ProtoMessage 

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) ProtoMessage()

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) ProtoReflect 

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

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Reset 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) Reset()

func (*DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) String 

func (x *DestinationSpec_KubeService_EndpointsSubset_Endpoint_SubLocality) String() string

type DestinationSpec_KubeService_ExternalAddress added in v1.1.0 

type DestinationSpec_KubeService_ExternalAddress struct {

	// The externally-reachable address for this Kubernetes Service, either an IP address or DNS name.
	//
	// Types that are assignable to ExternalAddressType:
	//	*DestinationSpec_KubeService_ExternalAddress_DnsName
	//	*DestinationSpec_KubeService_ExternalAddress_Ip
	ExternalAddressType isDestinationSpec_KubeService_ExternalAddress_ExternalAddressType `protobuf_oneof:"external_address_type"`
	// contains filtered or unexported fields
}

Describes the address data for Kubernetes Services exposed to external traffic (i.e. for non ClusterIP type Services).

func (*DestinationSpec_KubeService_ExternalAddress) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use DestinationSpec_KubeService_ExternalAddress.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_ExternalAddress) Equal added in v1.1.0 

func (m *DestinationSpec_KubeService_ExternalAddress) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_ExternalAddress) GetDnsName added in v1.1.0 

func (x *DestinationSpec_KubeService_ExternalAddress) GetDnsName() string

func (*DestinationSpec_KubeService_ExternalAddress) GetExternalAddressType added in v1.1.0 

func (m *DestinationSpec_KubeService_ExternalAddress) GetExternalAddressType() isDestinationSpec_KubeService_ExternalAddress_ExternalAddressType

func (*DestinationSpec_KubeService_ExternalAddress) GetIp added in v1.1.0 

func (x *DestinationSpec_KubeService_ExternalAddress) GetIp() string

func (*DestinationSpec_KubeService_ExternalAddress) Hash added in v1.1.0 

func (m *DestinationSpec_KubeService_ExternalAddress) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_ExternalAddress) ProtoMessage added in v1.1.0 

func (*DestinationSpec_KubeService_ExternalAddress) ProtoMessage()

func (*DestinationSpec_KubeService_ExternalAddress) ProtoReflect added in v1.1.0 

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

func (*DestinationSpec_KubeService_ExternalAddress) Reset added in v1.1.0 

func (x *DestinationSpec_KubeService_ExternalAddress) Reset()

func (*DestinationSpec_KubeService_ExternalAddress) String added in v1.1.0 

func (x *DestinationSpec_KubeService_ExternalAddress) String() string

type DestinationSpec_KubeService_ExternalAddress_DnsName added in v1.1.0 

type DestinationSpec_KubeService_ExternalAddress_DnsName struct {
	// An externally accessible DNS name.
	DnsName string `protobuf:"bytes,5,opt,name=dns_name,json=dnsName,proto3,oneof"`
}

type DestinationSpec_KubeService_ExternalAddress_Ip added in v1.1.0 

type DestinationSpec_KubeService_ExternalAddress_Ip struct {
	// An externally accessible IP address.
	Ip string `protobuf:"bytes,6,opt,name=ip,proto3,oneof"`
}

type DestinationSpec_KubeService_KubeServicePort 

type DestinationSpec_KubeService_KubeServicePort struct {

	// External-facing port for this Kubernetes service (*not* the service's target port on the targeted pods).
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the port
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Protocol on which this port serves traffic (HTTP, TCP, UDP, etc...)
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Available in Kubernetes 1.18+, describes the application protocol.
	AppProtocol string `protobuf:"bytes,4,opt,name=app_protocol,json=appProtocol,proto3" json:"app_protocol,omitempty"`
	// A Kubernetes Service's spec.targetPort can either be a string referring to the port name, or a number referring to the number. See [this reference](https://kubernetes.io/docs/reference/kubernetes-api/service-resources/service-v1/#ServiceSpec).
	//
	// Types that are assignable to TargetPort:
	//	*DestinationSpec_KubeService_KubeServicePort_TargetPortName
	//	*DestinationSpec_KubeService_KubeServicePort_TargetPortNumber
	TargetPort isDestinationSpec_KubeService_KubeServicePort_TargetPort `protobuf_oneof:"target_port"`
	// Populated for NodePort or LoadBalancer Services.
	NodePort uint32 `protobuf:"varint,7,opt,name=node_port,json=nodePort,proto3" json:"node_port,omitempty"`
	// contains filtered or unexported fields
}

Describes the service's ports. See [here](https://kubernetes.io/docs/concepts/services-networking/service/#multi-port-services) for more information.

func (*DestinationSpec_KubeService_KubeServicePort) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService_KubeServicePort.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_KubeServicePort) Equal 

func (m *DestinationSpec_KubeService_KubeServicePort) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_KubeServicePort) GetAppProtocol 

func (x *DestinationSpec_KubeService_KubeServicePort) GetAppProtocol() string

func (*DestinationSpec_KubeService_KubeServicePort) GetName 

func (x *DestinationSpec_KubeService_KubeServicePort) GetName() string

func (*DestinationSpec_KubeService_KubeServicePort) GetNodePort added in v1.1.0 

func (x *DestinationSpec_KubeService_KubeServicePort) GetNodePort() uint32

func (*DestinationSpec_KubeService_KubeServicePort) GetPort 

func (x *DestinationSpec_KubeService_KubeServicePort) GetPort() uint32

func (*DestinationSpec_KubeService_KubeServicePort) GetProtocol 

func (x *DestinationSpec_KubeService_KubeServicePort) GetProtocol() string

func (*DestinationSpec_KubeService_KubeServicePort) GetTargetPort added in v1.0.4 

func (m *DestinationSpec_KubeService_KubeServicePort) GetTargetPort() isDestinationSpec_KubeService_KubeServicePort_TargetPort

func (*DestinationSpec_KubeService_KubeServicePort) GetTargetPortName added in v1.0.4 

func (x *DestinationSpec_KubeService_KubeServicePort) GetTargetPortName() string

func (*DestinationSpec_KubeService_KubeServicePort) GetTargetPortNumber added in v1.0.4 

func (x *DestinationSpec_KubeService_KubeServicePort) GetTargetPortNumber() uint32

func (*DestinationSpec_KubeService_KubeServicePort) Hash 

func (m *DestinationSpec_KubeService_KubeServicePort) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_KubeServicePort) ProtoMessage 

func (*DestinationSpec_KubeService_KubeServicePort) ProtoMessage()

func (*DestinationSpec_KubeService_KubeServicePort) ProtoReflect 

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

func (*DestinationSpec_KubeService_KubeServicePort) Reset 

func (x *DestinationSpec_KubeService_KubeServicePort) Reset()

func (*DestinationSpec_KubeService_KubeServicePort) String 

func (x *DestinationSpec_KubeService_KubeServicePort) String() string

type DestinationSpec_KubeService_KubeServicePort_TargetPortName added in v1.0.4 

type DestinationSpec_KubeService_KubeServicePort_TargetPortName struct {
	// Name of the target port
	TargetPortName string `protobuf:"bytes,5,opt,name=target_port_name,json=targetPortName,proto3,oneof"`
}

type DestinationSpec_KubeService_KubeServicePort_TargetPortNumber added in v1.0.4 

type DestinationSpec_KubeService_KubeServicePort_TargetPortNumber struct {
	// Number of the target port
	TargetPortNumber uint32 `protobuf:"varint,6,opt,name=target_port_number,json=targetPortNumber,proto3,oneof"`
}

type DestinationSpec_KubeService_ServiceType added in v1.1.0 

type DestinationSpec_KubeService_ServiceType int32

Describes the Kubernetes Service type. 

const (
	// A ClusterIP Service.
	DestinationSpec_KubeService_CLUSTER_IP DestinationSpec_KubeService_ServiceType = 0
	// A NodePort Service.
	DestinationSpec_KubeService_NODE_PORT DestinationSpec_KubeService_ServiceType = 1
	// A LoadBalancer Service.
	DestinationSpec_KubeService_LOAD_BALANCER DestinationSpec_KubeService_ServiceType = 2
	// An ExternalName Service.
	DestinationSpec_KubeService_EXTERNAL_NAME DestinationSpec_KubeService_ServiceType = 3
)

func (DestinationSpec_KubeService_ServiceType) Descriptor added in v1.1.0 

func (DestinationSpec_KubeService_ServiceType) Descriptor() protoreflect.EnumDescriptor

func (DestinationSpec_KubeService_ServiceType) Enum added in v1.1.0 

func (x DestinationSpec_KubeService_ServiceType) Enum() *DestinationSpec_KubeService_ServiceType

func (DestinationSpec_KubeService_ServiceType) EnumDescriptor deprecated added in v1.1.0 

func (DestinationSpec_KubeService_ServiceType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DestinationSpec_KubeService_ServiceType.Descriptor instead.

func (DestinationSpec_KubeService_ServiceType) Number added in v1.1.0 

func (x DestinationSpec_KubeService_ServiceType) Number() protoreflect.EnumNumber

func (DestinationSpec_KubeService_ServiceType) String added in v1.1.0 

func (x DestinationSpec_KubeService_ServiceType) String() string

func (DestinationSpec_KubeService_ServiceType) Type added in v1.1.0 

func (DestinationSpec_KubeService_ServiceType) Type() protoreflect.EnumType

type DestinationSpec_KubeService_Subset 

type DestinationSpec_KubeService_Subset struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Subsets for routing, based on labels.

func (*DestinationSpec_KubeService_Subset) Descriptor deprecated 

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

Deprecated: Use DestinationSpec_KubeService_Subset.ProtoReflect.Descriptor instead.

func (*DestinationSpec_KubeService_Subset) Equal 

func (m *DestinationSpec_KubeService_Subset) Equal(that interface{}) bool

Equal function

func (*DestinationSpec_KubeService_Subset) GetValues 

func (x *DestinationSpec_KubeService_Subset) GetValues() []string

func (*DestinationSpec_KubeService_Subset) Hash 

func (m *DestinationSpec_KubeService_Subset) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationSpec_KubeService_Subset) ProtoMessage 

func (*DestinationSpec_KubeService_Subset) ProtoMessage()

func (*DestinationSpec_KubeService_Subset) ProtoReflect 

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

func (*DestinationSpec_KubeService_Subset) Reset 

func (x *DestinationSpec_KubeService_Subset) Reset()

func (*DestinationSpec_KubeService_Subset) String 

func (x *DestinationSpec_KubeService_Subset) String() string

type DestinationStatus 

type DestinationStatus struct {

	// The most recent generation observed in the the TrafficPolicy metadata.
	// If the `observedGeneration` does not match `metadata.generation`, Gloo Mesh has not processed the most
	// recent version of this resource.
	ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// The set of TrafficPolicies that have been applied to this Destination.
	// {{/* Note: validation of this field disabled because it slows down cue tremendously*/}}
	AppliedTrafficPolicies []*v11.AppliedTrafficPolicy `` /* 129-byte string literal not displayed */
	// The set of AccessPolicies that have been applied to this Destination.
	AppliedAccessPolicies []*DestinationStatus_AppliedAccessPolicy `` /* 126-byte string literal not displayed */
	// The fully qualified domain name for requests originating from a source *coloated* with this Destination.
	// For Kubernetes services, "colocated" means within the same Kubernetes cluster.
	LocalFqdn string `protobuf:"bytes,5,opt,name=local_fqdn,json=localFqdn,proto3" json:"local_fqdn,omitempty"`
	// Federation metadata. Only populated if this Destination is federated through a VirtualMesh.
	AppliedFederation *DestinationStatus_AppliedFederation `protobuf:"bytes,6,opt,name=applied_federation,json=appliedFederation,proto3" json:"applied_federation,omitempty"`
	// The set of TrafficPolicy traffic shifts that reference subsets on this Destination.
	RequiredSubsets []*RequiredSubsets `protobuf:"bytes,7,rep,name=required_subsets,json=requiredSubsets,proto3" json:"required_subsets,omitempty"`
	// contains filtered or unexported fields
}

func (*DestinationStatus) DeepCopyInto 

func (in *DestinationStatus) DeepCopyInto(out *DestinationStatus)

DeepCopyInto for the Destination.Status

func (*DestinationStatus) Descriptor deprecated 

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

Deprecated: Use DestinationStatus.ProtoReflect.Descriptor instead.

func (*DestinationStatus) Equal 

func (m *DestinationStatus) Equal(that interface{}) bool

Equal function

func (*DestinationStatus) GetAppliedAccessPolicies 

func (x *DestinationStatus) GetAppliedAccessPolicies() []*DestinationStatus_AppliedAccessPolicy

func (*DestinationStatus) GetAppliedFederation 

func (x *DestinationStatus) GetAppliedFederation() *DestinationStatus_AppliedFederation

func (*DestinationStatus) GetAppliedTrafficPolicies 

func (x *DestinationStatus) GetAppliedTrafficPolicies() []*v11.AppliedTrafficPolicy

func (*DestinationStatus) GetLocalFqdn 

func (x *DestinationStatus) GetLocalFqdn() string

func (*DestinationStatus) GetObservedGeneration 

func (x *DestinationStatus) GetObservedGeneration() int64

func (*DestinationStatus) GetRequiredSubsets added in v1.1.0 

func (x *DestinationStatus) GetRequiredSubsets() []*RequiredSubsets

func (*DestinationStatus) Hash 

func (m *DestinationStatus) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationStatus) MarshalJSON 

func (this *DestinationStatus) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for DestinationStatus

func (*DestinationStatus) ProtoMessage 

func (*DestinationStatus) ProtoMessage()

func (*DestinationStatus) ProtoReflect 

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

func (*DestinationStatus) Reset 

func (x *DestinationStatus) Reset()

func (*DestinationStatus) String 

func (x *DestinationStatus) String() string

func (*DestinationStatus) UnmarshalJSON 

func (this *DestinationStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for DestinationStatus

type DestinationStatusWriter 

type DestinationStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Destination object.
	UpdateDestinationStatus(ctx context.Context, obj *Destination, opts ...client.UpdateOption) error

	// Patch patches the given Destination object's subresource.
	PatchDestinationStatus(ctx context.Context, obj *Destination, patch client.Patch, opts ...client.PatchOption) error
}

StatusWriter knows how to update status subresource of a Destination object.

type DestinationStatus_AppliedAccessPolicy 

type DestinationStatus_AppliedAccessPolicy struct {

	// Reference to the AccessPolicy object.
	Ref *v1.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The observed generation of the accepted AccessPolicy.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// The spec of the last known valid AccessPolicy.
	Spec *v11.AccessPolicySpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Describes an [AccessPolicy]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.access_policy" >}}) that applies to this Destination. If an existing AccessPolicy becomes invalid, the last valid applied policy will be used.

func (*DestinationStatus_AppliedAccessPolicy) Descriptor deprecated 

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

Deprecated: Use DestinationStatus_AppliedAccessPolicy.ProtoReflect.Descriptor instead.

func (*DestinationStatus_AppliedAccessPolicy) Equal 

func (m *DestinationStatus_AppliedAccessPolicy) Equal(that interface{}) bool

Equal function

func (*DestinationStatus_AppliedAccessPolicy) GetObservedGeneration 

func (x *DestinationStatus_AppliedAccessPolicy) GetObservedGeneration() int64

func (*DestinationStatus_AppliedAccessPolicy) GetRef 

func (x *DestinationStatus_AppliedAccessPolicy) GetRef() *v1.ObjectRef

func (*DestinationStatus_AppliedAccessPolicy) GetSpec 

func (x *DestinationStatus_AppliedAccessPolicy) GetSpec() *v11.AccessPolicySpec

func (*DestinationStatus_AppliedAccessPolicy) Hash 

func (m *DestinationStatus_AppliedAccessPolicy) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationStatus_AppliedAccessPolicy) ProtoMessage 

func (*DestinationStatus_AppliedAccessPolicy) ProtoMessage()

func (*DestinationStatus_AppliedAccessPolicy) ProtoReflect 

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

func (*DestinationStatus_AppliedAccessPolicy) Reset 

func (x *DestinationStatus_AppliedAccessPolicy) Reset()

func (*DestinationStatus_AppliedAccessPolicy) String 

func (x *DestinationStatus_AppliedAccessPolicy) String() string

type DestinationStatus_AppliedFederation 

type DestinationStatus_AppliedFederation struct {

	//
	//For any Workload that this Destination has been federated to (i.e., any Workload controlled by a Mesh whose reference appears in `federated_to_meshes`),
	//that Workload will be able to reach this Destination using this DNS name.
	//For Kubernetes Destinations this includes Workloads on clusters other than the one hosting this Destination.
	FederatedHostname string `protobuf:"bytes,1,opt,name=federated_hostname,json=federatedHostname,proto3" json:"federated_hostname,omitempty"`
	// The list of Meshes which are able to resolve this Destination's `federated_hostname`.
	FederatedToMeshes []*v1.ObjectRef `protobuf:"bytes,2,rep,name=federated_to_meshes,json=federatedToMeshes,proto3" json:"federated_to_meshes,omitempty"`
	// Whether the Destination has been federated to the given meshes using a VirtualMesh where
	// [Federation.FlatNetwork]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.virtual_mesh/#virtualmeshspecfederation" >}})
	// is true.
	FlatNetwork bool `protobuf:"varint,3,opt,name=flat_network,json=flatNetwork,proto3" json:"flat_network,omitempty"`
	// Reference to the VirtualMesh object.
	VirtualMeshRef *v1.ObjectRef `protobuf:"bytes,4,opt,name=virtual_mesh_ref,json=virtualMeshRef,proto3" json:"virtual_mesh_ref,omitempty"`
	// Specify a keepalive rule for all requests made within the VirtualMesh which cross clusters within that VirtualMesh,
	// as well as any requests to externalService type destinations.
	TcpKeepalive *v12.TCPKeepalive `protobuf:"bytes,5,opt,name=tcp_keepalive,json=tcpKeepalive,proto3" json:"tcp_keepalive,omitempty"`
	// contains filtered or unexported fields
}

Describes the federation configuration applied to this Destination through a [VirtualMesh]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.virtual_mesh" >}}). Federation allows access to the Destination from other meshes/clusters.

func (*DestinationStatus_AppliedFederation) Descriptor deprecated 

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

Deprecated: Use DestinationStatus_AppliedFederation.ProtoReflect.Descriptor instead.

func (*DestinationStatus_AppliedFederation) Equal 

func (m *DestinationStatus_AppliedFederation) Equal(that interface{}) bool

Equal function

func (*DestinationStatus_AppliedFederation) GetFederatedHostname 

func (x *DestinationStatus_AppliedFederation) GetFederatedHostname() string

func (*DestinationStatus_AppliedFederation) GetFederatedToMeshes 

func (x *DestinationStatus_AppliedFederation) GetFederatedToMeshes() []*v1.ObjectRef

func (*DestinationStatus_AppliedFederation) GetFlatNetwork 

func (x *DestinationStatus_AppliedFederation) GetFlatNetwork() bool

func (*DestinationStatus_AppliedFederation) GetTcpKeepalive added in v1.1.0 

func (x *DestinationStatus_AppliedFederation) GetTcpKeepalive() *v12.TCPKeepalive

func (*DestinationStatus_AppliedFederation) GetVirtualMeshRef added in v1.0.4 

func (x *DestinationStatus_AppliedFederation) GetVirtualMeshRef() *v1.ObjectRef

func (*DestinationStatus_AppliedFederation) Hash 

func (m *DestinationStatus_AppliedFederation) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*DestinationStatus_AppliedFederation) ProtoMessage 

func (*DestinationStatus_AppliedFederation) ProtoMessage()

func (*DestinationStatus_AppliedFederation) ProtoReflect 

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

func (*DestinationStatus_AppliedFederation) Reset 

func (x *DestinationStatus_AppliedFederation) Reset()

func (*DestinationStatus_AppliedFederation) String 

func (x *DestinationStatus_AppliedFederation) String() string

type DestinationTransitionFunction 

type DestinationTransitionFunction func(existing, desired *Destination) error

DestinationTransitionFunction instructs the DestinationWriter how to transition between an existing Destination object and a desired on an Upsert

type DestinationWriter 

type DestinationWriter interface {
	// Create saves the Destination object.
	CreateDestination(ctx context.Context, obj *Destination, opts ...client.CreateOption) error

	// Delete deletes the Destination object.
	DeleteDestination(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Destination object.
	UpdateDestination(ctx context.Context, obj *Destination, opts ...client.UpdateOption) error

	// Patch patches the given Destination object.
	PatchDestination(ctx context.Context, obj *Destination, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Destination objects matching the given options.
	DeleteAllOfDestination(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Destination object.
	UpsertDestination(ctx context.Context, obj *Destination, transitionFuncs ...DestinationTransitionFunction) error
}

Writer knows how to create, delete, and update Destinations.

type Mesh 

type Mesh struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MeshSpec   `json:"spec,omitempty"`
	Status MeshStatus `json:"status,omitempty"`
}

Mesh is the Schema for the mesh API

func (*Mesh) DeepCopy 

func (in *Mesh) DeepCopy() *Mesh

func (*Mesh) DeepCopyInto 

func (in *Mesh) DeepCopyInto(out *Mesh)

func (*Mesh) DeepCopyObject 

func (in *Mesh) DeepCopyObject() runtime.Object

func (Mesh) GVK 

func (Mesh) GVK() schema.GroupVersionKind

GVK returns the GroupVersionKind associated with the resource type.

type MeshClient 

type MeshClient interface {
	MeshReader
	MeshWriter
	MeshStatusWriter
}

Client knows how to perform CRUD operations on Meshs.

type MeshInstallation added in v1.0.12 

type MeshInstallation struct {

	// Namespace in which the control plane has been installed.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The Gloo Mesh cluster in which the control plane has been installed.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// The labels on the control plane pods (read from the deployment).
	PodLabels map[string]string `` /* 176-byte string literal not displayed */
	// The version of the Mesh that has been installed, which is determined using the image tag on the
	// mesh's primary control plane image (e.g. the istio-pilot image tag).
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// The region of the cluster in which the control plane has been installed, which is
	// determined from the value of the [Kubernetes region topology label](https://kubernetes.io/docs/reference/labels-annotations-taints/#topologykubernetesioregion)
	// on any Kubernetes node associated with the cluster of this mesh.
	Region string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

Describes the Kubernetes cluster on which the control plane for this mesh is deployed. Only self-hosted control planes such as Istio, Linkerd, OSM, and ConsulConnect will have installation metadata.

func (*MeshInstallation) Descriptor deprecated added in v1.0.12 

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

Deprecated: Use MeshInstallation.ProtoReflect.Descriptor instead.

func (*MeshInstallation) Equal added in v1.0.12 

func (m *MeshInstallation) Equal(that interface{}) bool

Equal function

func (*MeshInstallation) GetCluster added in v1.0.12 

func (x *MeshInstallation) GetCluster() string

func (*MeshInstallation) GetNamespace added in v1.0.12 

func (x *MeshInstallation) GetNamespace() string

func (*MeshInstallation) GetPodLabels added in v1.0.12 

func (x *MeshInstallation) GetPodLabels() map[string]string

func (*MeshInstallation) GetRegion added in v1.0.12 

func (x *MeshInstallation) GetRegion() string

func (*MeshInstallation) GetVersion added in v1.0.12 

func (x *MeshInstallation) GetVersion() string

func (*MeshInstallation) ProtoMessage added in v1.0.12 

func (*MeshInstallation) ProtoMessage()

func (*MeshInstallation) ProtoReflect added in v1.0.12 

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

func (*MeshInstallation) Reset added in v1.0.12 

func (x *MeshInstallation) Reset()

func (*MeshInstallation) String added in v1.0.12 

func (x *MeshInstallation) String() string

type MeshList 

type MeshList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Mesh `json:"items"`
}

MeshList contains a list of Mesh

func (*MeshList) DeepCopy 

func (in *MeshList) DeepCopy() *MeshList

func (*MeshList) DeepCopyInto 

func (in *MeshList) DeepCopyInto(out *MeshList)

func (*MeshList) DeepCopyObject 

func (in *MeshList) DeepCopyObject() runtime.Object

type MeshReader 

type MeshReader interface {
	// Get retrieves a Mesh for the given object key
	GetMesh(ctx context.Context, key client.ObjectKey) (*Mesh, error)

	// List retrieves list of Meshs for a given namespace and list options.
	ListMesh(ctx context.Context, opts ...client.ListOption) (*MeshList, error)
}

Reader knows how to read and list Meshs.

type MeshSlice 

type MeshSlice []*Mesh

MeshSlice represents a slice of *Mesh

type MeshSpec 

type MeshSpec struct {

	// Describes platform specific properties of the service mesh.
	//
	// Types that are assignable to Type:
	//	*MeshSpec_Istio_
	//	*MeshSpec_AwsAppMesh_
	//	*MeshSpec_Linkerd
	//	*MeshSpec_ConsulConnect
	//	*MeshSpec_Osm
	Type isMeshSpec_Type `protobuf_oneof:"type"`
	// Describes the Gloo Mesh agent if it has been installed to the managed cluster.
	AgentInfo               *MeshSpec_AgentInfo         `protobuf:"bytes,5,opt,name=agent_info,json=agentInfo,proto3" json:"agent_info,omitempty"`
	IssuedCertificateStatus *v1.IssuedCertificateStatus `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Describes a service mesh control plane deployment.

func (*MeshSpec) DeepCopyInto 

func (in *MeshSpec) DeepCopyInto(out *MeshSpec)

DeepCopyInto for the Mesh.Spec

func (*MeshSpec) Descriptor deprecated 

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

Deprecated: Use MeshSpec.ProtoReflect.Descriptor instead.

func (*MeshSpec) Equal 

func (m *MeshSpec) Equal(that interface{}) bool

Equal function

func (*MeshSpec) GetAgentInfo 

func (x *MeshSpec) GetAgentInfo() *MeshSpec_AgentInfo

func (*MeshSpec) GetAwsAppMesh 

func (x *MeshSpec) GetAwsAppMesh() *MeshSpec_AwsAppMesh

func (*MeshSpec) GetConsulConnect 

func (x *MeshSpec) GetConsulConnect() *MeshSpec_ConsulConnectMesh

func (*MeshSpec) GetIssuedCertificateStatus added in v1.1.0 

func (x *MeshSpec) GetIssuedCertificateStatus() *v1.IssuedCertificateStatus

func (*MeshSpec) GetIstio 

func (x *MeshSpec) GetIstio() *MeshSpec_Istio

func (*MeshSpec) GetLinkerd 

func (x *MeshSpec) GetLinkerd() *MeshSpec_LinkerdMesh

func (*MeshSpec) GetOsm 

func (x *MeshSpec) GetOsm() *MeshSpec_OSM

func (*MeshSpec) GetType 

func (m *MeshSpec) GetType() isMeshSpec_Type

func (*MeshSpec) MarshalJSON 

func (this *MeshSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MeshSpec

func (*MeshSpec) ProtoMessage 

func (*MeshSpec) ProtoMessage()

func (*MeshSpec) ProtoReflect 

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

func (*MeshSpec) Reset 

func (x *MeshSpec) Reset()

func (*MeshSpec) String 

func (x *MeshSpec) String() string

func (*MeshSpec) UnmarshalJSON 

func (this *MeshSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MeshSpec

type MeshSpec_AgentInfo 

type MeshSpec_AgentInfo struct {

	// The namespace in which the Gloo Mesh agent is installed.
	AgentNamespace string `protobuf:"bytes,1,opt,name=agent_namespace,json=agentNamespace,proto3" json:"agent_namespace,omitempty"`
	// contains filtered or unexported fields
}

Describes the Gloo Mesh agent which may be installed to the managed cluster containing the mesh control plane.

func (*MeshSpec_AgentInfo) Descriptor deprecated 

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

Deprecated: Use MeshSpec_AgentInfo.ProtoReflect.Descriptor instead.

func (*MeshSpec_AgentInfo) Equal 

func (m *MeshSpec_AgentInfo) Equal(that interface{}) bool

Equal function

func (*MeshSpec_AgentInfo) GetAgentNamespace 

func (x *MeshSpec_AgentInfo) GetAgentNamespace() string

func (*MeshSpec_AgentInfo) ProtoMessage 

func (*MeshSpec_AgentInfo) ProtoMessage()

func (*MeshSpec_AgentInfo) ProtoReflect 

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

func (*MeshSpec_AgentInfo) Reset 

func (x *MeshSpec_AgentInfo) Reset()

func (*MeshSpec_AgentInfo) String 

func (x *MeshSpec_AgentInfo) String() string

type MeshSpec_AwsAppMesh 

type MeshSpec_AwsAppMesh struct {

	// The AWS name for the App Mesh instance, must be unique across all AppMesh instances owned by the AWS account.
	AwsName string `protobuf:"bytes,1,opt,name=aws_name,json=awsName,proto3" json:"aws_name,omitempty"`
	// The AWS region the App Mesh control plane resources exist in.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// The AWS Account ID associated with the Mesh. Populated at REST API registration time.
	AwsAccountId string `protobuf:"bytes,3,opt,name=aws_account_id,json=awsAccountId,proto3" json:"aws_account_id,omitempty"`
	// The unique AWS ARN associated with the App Mesh instance.
	Arn string `protobuf:"bytes,4,opt,name=arn,proto3" json:"arn,omitempty"`
	// The Kubernetes clusters on which sidecars for this App Mesh instance have been discovered.
	Clusters []string `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

Describes an AWS App Mesh instance.

func (*MeshSpec_AwsAppMesh) Descriptor deprecated 

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

Deprecated: Use MeshSpec_AwsAppMesh.ProtoReflect.Descriptor instead.

func (*MeshSpec_AwsAppMesh) Equal 

func (m *MeshSpec_AwsAppMesh) Equal(that interface{}) bool

Equal function

func (*MeshSpec_AwsAppMesh) GetArn 

func (x *MeshSpec_AwsAppMesh) GetArn() string

func (*MeshSpec_AwsAppMesh) GetAwsAccountId 

func (x *MeshSpec_AwsAppMesh) GetAwsAccountId() string

func (*MeshSpec_AwsAppMesh) GetAwsName 

func (x *MeshSpec_AwsAppMesh) GetAwsName() string

func (*MeshSpec_AwsAppMesh) GetClusters 

func (x *MeshSpec_AwsAppMesh) GetClusters() []string

func (*MeshSpec_AwsAppMesh) GetRegion 

func (x *MeshSpec_AwsAppMesh) GetRegion() string

func (*MeshSpec_AwsAppMesh) ProtoMessage 

func (*MeshSpec_AwsAppMesh) ProtoMessage()

func (*MeshSpec_AwsAppMesh) ProtoReflect 

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

func (*MeshSpec_AwsAppMesh) Reset 

func (x *MeshSpec_AwsAppMesh) Reset()

func (*MeshSpec_AwsAppMesh) String 

func (x *MeshSpec_AwsAppMesh) String() string

type MeshSpec_AwsAppMesh_ 

type MeshSpec_AwsAppMesh_ struct {
	// Describes an [AWS App Mesh](https://aws.amazon.com/app-mesh/) service mesh.
	AwsAppMesh *MeshSpec_AwsAppMesh `protobuf:"bytes,2,opt,name=aws_app_mesh,json=awsAppMesh,proto3,oneof"`
}

type MeshSpec_ConsulConnect 

type MeshSpec_ConsulConnect struct {
	// Describes a [Consul Connect](https://www.consul.io/docs/connect) service mesh.
	ConsulConnect *MeshSpec_ConsulConnectMesh `protobuf:"bytes,4,opt,name=consul_connect,json=consulConnect,proto3,oneof"`
}

type MeshSpec_ConsulConnectMesh 

type MeshSpec_ConsulConnectMesh struct {

	// Describes the ConsulConnect control plane deployment.
	Installation *MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// contains filtered or unexported fields
}

Describes a ConsulConnect deployment.

func (*MeshSpec_ConsulConnectMesh) Descriptor deprecated 

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

Deprecated: Use MeshSpec_ConsulConnectMesh.ProtoReflect.Descriptor instead.

func (*MeshSpec_ConsulConnectMesh) Equal 

func (m *MeshSpec_ConsulConnectMesh) Equal(that interface{}) bool

Equal function

func (*MeshSpec_ConsulConnectMesh) GetInstallation 

func (x *MeshSpec_ConsulConnectMesh) GetInstallation() *MeshInstallation

func (*MeshSpec_ConsulConnectMesh) ProtoMessage 

func (*MeshSpec_ConsulConnectMesh) ProtoMessage()

func (*MeshSpec_ConsulConnectMesh) ProtoReflect 

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

func (*MeshSpec_ConsulConnectMesh) Reset 

func (x *MeshSpec_ConsulConnectMesh) Reset()

func (*MeshSpec_ConsulConnectMesh) String 

func (x *MeshSpec_ConsulConnectMesh) String() string

type MeshSpec_Istio 

type MeshSpec_Istio struct {

	// Describes the Istio control plane deployment.
	Installation *MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// The Istio trust domain used for https/[spiffe](https://spiffe.io/spiffe/concepts/#trust-domain) [identity](https://istio.io/docs/reference/glossary/#identity).
	// If empty will default to ["cluster.local"](https://github.com/istio/istio/blob/e768f408a7de224e64ccdfb2634442541ce08e6a/pilot/cmd/pilot-agent/main.go#L118).
	TrustDomain string `protobuf:"bytes,2,opt,name=trust_domain,json=trustDomain,proto3" json:"trust_domain,omitempty"`
	// The istiod service account which determines identity for the Istio CA cert.
	IstiodServiceAccount string `protobuf:"bytes,3,opt,name=istiod_service_account,json=istiodServiceAccount,proto3" json:"istiod_service_account,omitempty"`
	// DEPRECATED: external address data for an ingress gateway destination and workload live in the relevant Destination and Workload objects.
	// Describes the ingress gateway.
	IngressGateways []*MeshSpec_Istio_IngressGatewayInfo `protobuf:"bytes,4,rep,name=ingress_gateways,json=ingressGateways,proto3" json:"ingress_gateways,omitempty"`
	// True if smart DNS proxying is enabled, which allows for arbitrary DNS domains.
	SmartDnsProxyingEnabled bool `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

Describes an Istio deployment.

func (*MeshSpec_Istio) Descriptor deprecated 

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

Deprecated: Use MeshSpec_Istio.ProtoReflect.Descriptor instead.

func (*MeshSpec_Istio) Equal 

func (m *MeshSpec_Istio) Equal(that interface{}) bool

Equal function

func (*MeshSpec_Istio) GetIngressGateways 

func (x *MeshSpec_Istio) GetIngressGateways() []*MeshSpec_Istio_IngressGatewayInfo

func (*MeshSpec_Istio) GetInstallation 

func (x *MeshSpec_Istio) GetInstallation() *MeshInstallation

func (*MeshSpec_Istio) GetIstiodServiceAccount 

func (x *MeshSpec_Istio) GetIstiodServiceAccount() string

func (*MeshSpec_Istio) GetSmartDnsProxyingEnabled 

func (x *MeshSpec_Istio) GetSmartDnsProxyingEnabled() bool

func (*MeshSpec_Istio) GetTrustDomain 

func (x *MeshSpec_Istio) GetTrustDomain() string

func (*MeshSpec_Istio) ProtoMessage 

func (*MeshSpec_Istio) ProtoMessage()

func (*MeshSpec_Istio) ProtoReflect 

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

func (*MeshSpec_Istio) Reset 

func (x *MeshSpec_Istio) Reset()

func (*MeshSpec_Istio) String 

func (x *MeshSpec_Istio) String() string

type MeshSpec_Istio_ 

type MeshSpec_Istio_ struct {
	// Describes an [Istio](https://istio.io/) service mesh.
	Istio *MeshSpec_Istio `protobuf:"bytes,1,opt,name=istio,proto3,oneof"`
}

type MeshSpec_Istio_IngressGatewayInfo 

type MeshSpec_Istio_IngressGatewayInfo struct {

	// TODO: remove name and namespace as ingress gw info now contains a ref
	// The name of the Ingress Gateway Service
	Name string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace in which the ingress gateway is running.
	Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The ingress service selector labels for the gateway.
	// [Defaults to](https://github.com/istio/istio/blob/ab6cc48134a698d7ad218a83390fe27e8098919f/pkg/config/constants/constants.go#L73) `{"istio": "ingressgateway"}`.
	WorkloadLabels map[string]string `` /* 191-byte string literal not displayed */
	// DEPRECATED: in favor of dns_name or external_ip
	ExternalAddress string `protobuf:"bytes,2,opt,name=external_address,json=externalAddress,proto3" json:"external_address,omitempty"`
	// The externally-reachable address on which the gateway is listening for TLS connections.
	// This will be the address used for cross-cluster connectivity.
	// Defaults to the LoadBalancer Address (or NodeIP) of the Kubernetes service (depending on its type).
	//
	// Types that are assignable to ExternalAddressType:
	//	*MeshSpec_Istio_IngressGatewayInfo_DnsName
	//	*MeshSpec_Istio_IngressGatewayInfo_Ip
	ExternalAddressType isMeshSpec_Istio_IngressGatewayInfo_ExternalAddressType `protobuf_oneof:"external_address_type"`
	// The externally-reachable port on which the gateway is listening for TLS connections.
	// This will be the port used for cross-cluster connectivity.
	// See the list of [common ports used by Istio](https://istio.io/latest/docs/ops/deployment/requirements/#ports-used-by-istio).
	// Defaults to 15443 (or the NodePort) of the Kubernetes service (depending on its type).
	ExternalTlsPort uint32 `protobuf:"varint,3,opt,name=external_tls_port,json=externalTlsPort,proto3" json:"external_tls_port,omitempty"`
	// Container port on which the gateway is listening for TLS connections.
	// Defaults to 15443.
	TlsContainerPort uint32 `protobuf:"varint,4,opt,name=tls_container_port,json=tlsContainerPort,proto3" json:"tls_container_port,omitempty"`
	// contains filtered or unexported fields
}

DEPRECATED: external address data for an ingress gateway destination and workload live in the relevant Destination and Workload objects. Describes the ingress gateway.

func (*MeshSpec_Istio_IngressGatewayInfo) Descriptor deprecated 

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

Deprecated: Use MeshSpec_Istio_IngressGatewayInfo.ProtoReflect.Descriptor instead.

func (*MeshSpec_Istio_IngressGatewayInfo) Equal 

func (m *MeshSpec_Istio_IngressGatewayInfo) Equal(that interface{}) bool

Equal function

func (*MeshSpec_Istio_IngressGatewayInfo) GetDnsName added in v1.0.4 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetDnsName() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalAddress 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetExternalAddress() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalAddressType added in v1.0.4 

func (m *MeshSpec_Istio_IngressGatewayInfo) GetExternalAddressType() isMeshSpec_Istio_IngressGatewayInfo_ExternalAddressType

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort() uint32

func (*MeshSpec_Istio_IngressGatewayInfo) GetIp added in v1.0.4 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetIp() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetName added in v1.1.0 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetName() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetNamespace added in v1.1.0 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetNamespace() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetTlsContainerPort 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetTlsContainerPort() uint32

func (*MeshSpec_Istio_IngressGatewayInfo) GetWorkloadLabels 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetWorkloadLabels() map[string]string

func (*MeshSpec_Istio_IngressGatewayInfo) ProtoMessage 

func (*MeshSpec_Istio_IngressGatewayInfo) ProtoMessage()

func (*MeshSpec_Istio_IngressGatewayInfo) ProtoReflect 

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

func (*MeshSpec_Istio_IngressGatewayInfo) Reset 

func (x *MeshSpec_Istio_IngressGatewayInfo) Reset()

func (*MeshSpec_Istio_IngressGatewayInfo) String 

func (x *MeshSpec_Istio_IngressGatewayInfo) String() string

type MeshSpec_Istio_IngressGatewayInfo_DnsName added in v1.0.4 

type MeshSpec_Istio_IngressGatewayInfo_DnsName struct {
	// Will be populated if the LoadBalancer Address is a DNS name
	DnsName string `protobuf:"bytes,5,opt,name=dns_name,json=dnsName,proto3,oneof"`
}

type MeshSpec_Istio_IngressGatewayInfo_Ip added in v1.0.4 

type MeshSpec_Istio_IngressGatewayInfo_Ip struct {
	// Will be populated if the LoadBalancer Address is an IP
	Ip string `protobuf:"bytes,6,opt,name=ip,proto3,oneof"`
}

type MeshSpec_Linkerd 

type MeshSpec_Linkerd struct {
	// Describes a [Linkerd](https://linkerd.io/) service mesh.
	Linkerd *MeshSpec_LinkerdMesh `protobuf:"bytes,3,opt,name=linkerd,proto3,oneof"`
}

type MeshSpec_LinkerdMesh 

type MeshSpec_LinkerdMesh struct {

	// Describes the Linkerd control plane deployment.
	Installation *MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// The cluster domain suffix this Linkerd mesh is configured with. See [this reference](https://linkerd.io/2/tasks/using-custom-domain/) for more info.
	ClusterDomain string `protobuf:"bytes,2,opt,name=cluster_domain,json=clusterDomain,proto3" json:"cluster_domain,omitempty"`
	// contains filtered or unexported fields
}

Describes a Linkerd deployment.

func (*MeshSpec_LinkerdMesh) Descriptor deprecated 

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

Deprecated: Use MeshSpec_LinkerdMesh.ProtoReflect.Descriptor instead.

func (*MeshSpec_LinkerdMesh) Equal 

func (m *MeshSpec_LinkerdMesh) Equal(that interface{}) bool

Equal function

func (*MeshSpec_LinkerdMesh) GetClusterDomain 

func (x *MeshSpec_LinkerdMesh) GetClusterDomain() string

func (*MeshSpec_LinkerdMesh) GetInstallation 

func (x *MeshSpec_LinkerdMesh) GetInstallation() *MeshInstallation

func (*MeshSpec_LinkerdMesh) ProtoMessage 

func (*MeshSpec_LinkerdMesh) ProtoMessage()

func (*MeshSpec_LinkerdMesh) ProtoReflect 

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

func (*MeshSpec_LinkerdMesh) Reset 

func (x *MeshSpec_LinkerdMesh) Reset()

func (*MeshSpec_LinkerdMesh) String 

func (x *MeshSpec_LinkerdMesh) String() string

type MeshSpec_OSM 

type MeshSpec_OSM struct {

	// Describes the OSM control plane deployment.
	Installation *MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// contains filtered or unexported fields
}

Describes an [OSM](https://github.com/openservicemesh/osm) deployment.

func (*MeshSpec_OSM) Descriptor deprecated 

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

Deprecated: Use MeshSpec_OSM.ProtoReflect.Descriptor instead.

func (*MeshSpec_OSM) Equal 

func (m *MeshSpec_OSM) Equal(that interface{}) bool

Equal function

func (*MeshSpec_OSM) GetInstallation 

func (x *MeshSpec_OSM) GetInstallation() *MeshInstallation

func (*MeshSpec_OSM) ProtoMessage 

func (*MeshSpec_OSM) ProtoMessage()

func (*MeshSpec_OSM) ProtoReflect 

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

func (*MeshSpec_OSM) Reset 

func (x *MeshSpec_OSM) Reset()

func (*MeshSpec_OSM) String 

func (x *MeshSpec_OSM) String() string

type MeshSpec_Osm 

type MeshSpec_Osm struct {
	// Describes an [Open Service Mesh](https://openservicemesh.io/) service mesh.
	Osm *MeshSpec_OSM `protobuf:"bytes,6,opt,name=osm,proto3,oneof"`
}

type MeshStatus 

type MeshStatus struct {

	// The observed generation of the Mesh.
	// When this matches the Mesh's metadata.generation, it indicates that Gloo Mesh
	// has processed the latest version of the Mesh.
	ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// The VirtualMesh, if any, which contains this Mesh.
	AppliedVirtualMesh *MeshStatus_AppliedVirtualMesh `protobuf:"bytes,2,opt,name=applied_virtual_mesh,json=appliedVirtualMesh,proto3" json:"applied_virtual_mesh,omitempty"`
	// The VirtualDestinations, if any, which apply to this Mesh.
	AppliedVirtualDestinations []*MeshStatus_AppliedVirtualDestination `` /* 141-byte string literal not displayed */
	// The Destination(s) acting as ingress gateways for east west traffic.
	AppliedEastWestIngressGateways []*MeshStatus_AppliedIngressGateway `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MeshStatus) DeepCopyInto 

func (in *MeshStatus) DeepCopyInto(out *MeshStatus)

DeepCopyInto for the Mesh.Status

func (*MeshStatus) Descriptor deprecated 

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

Deprecated: Use MeshStatus.ProtoReflect.Descriptor instead.

func (*MeshStatus) Equal 

func (m *MeshStatus) Equal(that interface{}) bool

Equal function

func (*MeshStatus) GetAppliedEastWestIngressGateways added in v1.1.0 

func (x *MeshStatus) GetAppliedEastWestIngressGateways() []*MeshStatus_AppliedIngressGateway

func (*MeshStatus) GetAppliedVirtualDestinations 

func (x *MeshStatus) GetAppliedVirtualDestinations() []*MeshStatus_AppliedVirtualDestination

func (*MeshStatus) GetAppliedVirtualMesh 

func (x *MeshStatus) GetAppliedVirtualMesh() *MeshStatus_AppliedVirtualMesh

func (*MeshStatus) GetObservedGeneration 

func (x *MeshStatus) GetObservedGeneration() int64

func (*MeshStatus) MarshalJSON 

func (this *MeshStatus) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MeshStatus

func (*MeshStatus) ProtoMessage 

func (*MeshStatus) ProtoMessage()

func (*MeshStatus) ProtoReflect 

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

func (*MeshStatus) Reset 

func (x *MeshStatus) Reset()

func (*MeshStatus) String 

func (x *MeshStatus) String() string

func (*MeshStatus) UnmarshalJSON 

func (this *MeshStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MeshStatus

type MeshStatusWriter 

type MeshStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Mesh object.
	UpdateMeshStatus(ctx context.Context, obj *Mesh, opts ...client.UpdateOption) error

	// Patch patches the given Mesh object's subresource.
	PatchMeshStatus(ctx context.Context, obj *Mesh, patch client.Patch, opts ...client.PatchOption) error
}

StatusWriter knows how to update status subresource of a Mesh object.

type MeshStatus_AppliedIngressGateway 

type MeshStatus_AppliedIngressGateway struct {

	// The Destination on the mesh that acts as an ingress gateway for the mesh.
	DestinationRef *v11.ObjectRef `protobuf:"bytes,1,opt,name=destination_ref,json=destinationRef,proto3" json:"destination_ref,omitempty"`
	// The externally accessible address(es) for this ingress gateway Destination.
	ExternalAddresses []string `protobuf:"bytes,2,rep,name=external_addresses,json=externalAddresses,proto3" json:"external_addresses,omitempty"`
	// The port on the ingress gateway Destination designated for receiving cross cluster traffic.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// The external facing port on the ingress gateway Destination designated for receiving cross cluster traffic.
	// May differ from the destination_port if the Kubernetes Service is of type NodePort.
	ExternalPort uint32 `protobuf:"varint,4,opt,name=external_port,json=externalPort,proto3" json:"external_port,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshStatus_AppliedIngressGateway) Descriptor deprecated 

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

Deprecated: Use MeshStatus_AppliedIngressGateway.ProtoReflect.Descriptor instead.

func (*MeshStatus_AppliedIngressGateway) Equal 

func (m *MeshStatus_AppliedIngressGateway) Equal(that interface{}) bool

Equal function

func (*MeshStatus_AppliedIngressGateway) GetDestinationRef 

func (x *MeshStatus_AppliedIngressGateway) GetDestinationRef() *v11.ObjectRef

func (*MeshStatus_AppliedIngressGateway) GetExternalAddresses 

func (x *MeshStatus_AppliedIngressGateway) GetExternalAddresses() []string

func (*MeshStatus_AppliedIngressGateway) GetExternalPort 

func (x *MeshStatus_AppliedIngressGateway) GetExternalPort() uint32

func (*MeshStatus_AppliedIngressGateway) GetPort 

func (x *MeshStatus_AppliedIngressGateway) GetPort() uint32

func (*MeshStatus_AppliedIngressGateway) ProtoMessage 

func (*MeshStatus_AppliedIngressGateway) ProtoMessage()

func (*MeshStatus_AppliedIngressGateway) ProtoReflect 

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

func (*MeshStatus_AppliedIngressGateway) Reset 

func (x *MeshStatus_AppliedIngressGateway) Reset()

func (*MeshStatus_AppliedIngressGateway) String 

func (x *MeshStatus_AppliedIngressGateway) String() string

type MeshStatus_AppliedVirtualDestination 

type MeshStatus_AppliedVirtualDestination struct {

	// Reference to the applied VirtualDestination object.
	Ref *v11.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The observed generation of the accepted VirtualDestination.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// Any errors encountered while processing the VirtualDestination.
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Describes a [VirtualDestination]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.networking.v1alpha1.virtual_destination.md" >}}) that applies to this Mesh.

func (*MeshStatus_AppliedVirtualDestination) Descriptor deprecated 

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

Deprecated: Use MeshStatus_AppliedVirtualDestination.ProtoReflect.Descriptor instead.

func (*MeshStatus_AppliedVirtualDestination) Equal 

func (m *MeshStatus_AppliedVirtualDestination) Equal(that interface{}) bool

Equal function

func (*MeshStatus_AppliedVirtualDestination) GetErrors 

func (x *MeshStatus_AppliedVirtualDestination) GetErrors() []string

func (*MeshStatus_AppliedVirtualDestination) GetObservedGeneration 

func (x *MeshStatus_AppliedVirtualDestination) GetObservedGeneration() int64

func (*MeshStatus_AppliedVirtualDestination) GetRef 

func (x *MeshStatus_AppliedVirtualDestination) GetRef() *v11.ObjectRef

func (*MeshStatus_AppliedVirtualDestination) ProtoMessage 

func (*MeshStatus_AppliedVirtualDestination) ProtoMessage()

func (*MeshStatus_AppliedVirtualDestination) ProtoReflect 

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

func (*MeshStatus_AppliedVirtualDestination) Reset 

func (x *MeshStatus_AppliedVirtualDestination) Reset()

func (*MeshStatus_AppliedVirtualDestination) String 

func (x *MeshStatus_AppliedVirtualDestination) String() string

type MeshStatus_AppliedVirtualMesh 

type MeshStatus_AppliedVirtualMesh struct {

	// Reference to the applied VirtualMesh object.
	Ref *v11.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The observed generation of the accepted VirtualMesh.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// The spec of the last known valid VirtualMesh.
	Spec *v12.VirtualMeshSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Describes a [VirtualMesh]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.virtual_mesh" >}}) that applies to this Mesh. If an existing applied VirtualMesh becomes invalid, the last applied VirtualMesh will be used.

func (*MeshStatus_AppliedVirtualMesh) Descriptor deprecated 

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

Deprecated: Use MeshStatus_AppliedVirtualMesh.ProtoReflect.Descriptor instead.

func (*MeshStatus_AppliedVirtualMesh) Equal 

func (m *MeshStatus_AppliedVirtualMesh) Equal(that interface{}) bool

Equal function

func (*MeshStatus_AppliedVirtualMesh) GetObservedGeneration 

func (x *MeshStatus_AppliedVirtualMesh) GetObservedGeneration() int64

func (*MeshStatus_AppliedVirtualMesh) GetRef 

func (x *MeshStatus_AppliedVirtualMesh) GetRef() *v11.ObjectRef

func (*MeshStatus_AppliedVirtualMesh) GetSpec 

func (x *MeshStatus_AppliedVirtualMesh) GetSpec() *v12.VirtualMeshSpec

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage 

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage()

func (*MeshStatus_AppliedVirtualMesh) ProtoReflect 

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

func (*MeshStatus_AppliedVirtualMesh) Reset 

func (x *MeshStatus_AppliedVirtualMesh) Reset()

func (*MeshStatus_AppliedVirtualMesh) String 

func (x *MeshStatus_AppliedVirtualMesh) String() string

type MeshTransitionFunction 

type MeshTransitionFunction func(existing, desired *Mesh) error

MeshTransitionFunction instructs the MeshWriter how to transition between an existing Mesh object and a desired on an Upsert

type MeshWriter 

type MeshWriter interface {
	// Create saves the Mesh object.
	CreateMesh(ctx context.Context, obj *Mesh, opts ...client.CreateOption) error

	// Delete deletes the Mesh object.
	DeleteMesh(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Mesh object.
	UpdateMesh(ctx context.Context, obj *Mesh, opts ...client.UpdateOption) error

	// Patch patches the given Mesh object.
	PatchMesh(ctx context.Context, obj *Mesh, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Mesh objects matching the given options.
	DeleteAllOfMesh(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Mesh object.
	UpsertMesh(ctx context.Context, obj *Mesh, transitionFuncs ...MeshTransitionFunction) error
}

Writer knows how to create, delete, and update Meshs.

type MulticlusterClientset 

type MulticlusterClientset interface {
	// Cluster returns a Clientset for the given cluster
	Cluster(cluster string) (Clientset, error)
}

MulticlusterClientset for the discovery.mesh.gloo.solo.io/v1 APIs

func NewMulticlusterClientset 

func NewMulticlusterClientset(client multicluster.Client) MulticlusterClientset

type MulticlusterDestinationClient 

type MulticlusterDestinationClient interface {
	// Cluster returns a DestinationClient for the given cluster
	Cluster(cluster string) (DestinationClient, error)
}

Provides DestinationClients for multiple clusters.

func NewMulticlusterDestinationClient 

func NewMulticlusterDestinationClient(client multicluster.Client) MulticlusterDestinationClient

type MulticlusterMeshClient 

type MulticlusterMeshClient interface {
	// Cluster returns a MeshClient for the given cluster
	Cluster(cluster string) (MeshClient, error)
}

Provides MeshClients for multiple clusters.

func NewMulticlusterMeshClient 

func NewMulticlusterMeshClient(client multicluster.Client) MulticlusterMeshClient

type MulticlusterWorkloadClient 

type MulticlusterWorkloadClient interface {
	// Cluster returns a WorkloadClient for the given cluster
	Cluster(cluster string) (WorkloadClient, error)
}

Provides WorkloadClients for multiple clusters.

func NewMulticlusterWorkloadClient 

func NewMulticlusterWorkloadClient(client multicluster.Client) MulticlusterWorkloadClient

type RequiredSubsets added in v1.1.0 

type RequiredSubsets struct {

	// Reference to the TrafficPolicy object.
	TrafficPolicyRef *v1.ObjectRef `protobuf:"bytes,1,opt,name=traffic_policy_ref,json=trafficPolicyRef,proto3" json:"traffic_policy_ref,omitempty"`
	// The observed generation of the TrafficPolicy.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// The applied traffic shift.
	TrafficShift *v11.TrafficPolicySpec_Policy_MultiDestination `protobuf:"bytes,3,opt,name=traffic_shift,json=trafficShift,proto3" json:"traffic_shift,omitempty"`
	// contains filtered or unexported fields
}

Describes a [TrafficPolicy]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.traffic_policy" >}}) that references subsets on this Destination in a traffic shift. Note: this is an Istio-specific feature.

func (*RequiredSubsets) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use RequiredSubsets.ProtoReflect.Descriptor instead.

func (*RequiredSubsets) Equal added in v1.1.0 

func (m *RequiredSubsets) Equal(that interface{}) bool

Equal function

func (*RequiredSubsets) GetObservedGeneration added in v1.1.0 

func (x *RequiredSubsets) GetObservedGeneration() int64

func (*RequiredSubsets) GetTrafficPolicyRef added in v1.1.0 

func (x *RequiredSubsets) GetTrafficPolicyRef() *v1.ObjectRef

func (*RequiredSubsets) GetTrafficShift added in v1.1.0 

func (x *RequiredSubsets) GetTrafficShift() *v11.TrafficPolicySpec_Policy_MultiDestination

func (*RequiredSubsets) Hash added in v1.1.0 

func (m *RequiredSubsets) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*RequiredSubsets) ProtoMessage added in v1.1.0 

func (*RequiredSubsets) ProtoMessage()

func (*RequiredSubsets) ProtoReflect added in v1.1.0 

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

func (*RequiredSubsets) Reset added in v1.1.0 

func (x *RequiredSubsets) Reset()

func (*RequiredSubsets) String added in v1.1.0 

func (x *RequiredSubsets) String() string

type Workload 

type Workload struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   WorkloadSpec   `json:"spec,omitempty"`
	Status WorkloadStatus `json:"status,omitempty"`
}

Workload is the Schema for the workload API

func (*Workload) DeepCopy 

func (in *Workload) DeepCopy() *Workload

func (*Workload) DeepCopyInto 

func (in *Workload) DeepCopyInto(out *Workload)

func (*Workload) DeepCopyObject 

func (in *Workload) DeepCopyObject() runtime.Object

func (Workload) GVK 

func (Workload) GVK() schema.GroupVersionKind

GVK returns the GroupVersionKind associated with the resource type.

type WorkloadClient 

type WorkloadClient interface {
	WorkloadReader
	WorkloadWriter
	WorkloadStatusWriter
}

Client knows how to perform CRUD operations on Workloads.

type WorkloadList 

type WorkloadList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Workload `json:"items"`
}

WorkloadList contains a list of Workload

func (*WorkloadList) DeepCopy 

func (in *WorkloadList) DeepCopy() *WorkloadList

func (*WorkloadList) DeepCopyInto 

func (in *WorkloadList) DeepCopyInto(out *WorkloadList)

func (*WorkloadList) DeepCopyObject 

func (in *WorkloadList) DeepCopyObject() runtime.Object

type WorkloadReader 

type WorkloadReader interface {
	// Get retrieves a Workload for the given object key
	GetWorkload(ctx context.Context, key client.ObjectKey) (*Workload, error)

	// List retrieves list of Workloads for a given namespace and list options.
	ListWorkload(ctx context.Context, opts ...client.ListOption) (*WorkloadList, error)
}

Reader knows how to read and list Workloads.

type WorkloadSlice 

type WorkloadSlice []*Workload

WorkloadSlice represents a slice of *Workload

type WorkloadSpec 

type WorkloadSpec struct {

	// Describes platform specific properties of the workload.
	//
	// Types that are assignable to Type:
	//	*WorkloadSpec_Kubernetes
	Type isWorkloadSpec_Type `protobuf_oneof:"type"`
	// The Mesh with which this Workload is associated.
	Mesh *v1.ObjectRef `protobuf:"bytes,4,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// Metadata specific to an App Mesh controlled workload.
	AppMesh *WorkloadSpec_AppMesh `protobuf:"bytes,5,opt,name=app_mesh,json=appMesh,proto3" json:"app_mesh,omitempty"`
	// contains filtered or unexported fields
}

Describes a workload controlled by a discovered service mesh.

func (*WorkloadSpec) DeepCopyInto 

func (in *WorkloadSpec) DeepCopyInto(out *WorkloadSpec)

DeepCopyInto for the Workload.Spec

func (*WorkloadSpec) Descriptor deprecated 

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

Deprecated: Use WorkloadSpec.ProtoReflect.Descriptor instead.

func (*WorkloadSpec) Equal 

func (m *WorkloadSpec) Equal(that interface{}) bool

Equal function

func (*WorkloadSpec) GetAppMesh 

func (x *WorkloadSpec) GetAppMesh() *WorkloadSpec_AppMesh

func (*WorkloadSpec) GetKubernetes 

func (x *WorkloadSpec) GetKubernetes() *WorkloadSpec_KubernetesWorkload

func (*WorkloadSpec) GetMesh 

func (x *WorkloadSpec) GetMesh() *v1.ObjectRef

func (*WorkloadSpec) GetType 

func (m *WorkloadSpec) GetType() isWorkloadSpec_Type

func (*WorkloadSpec) MarshalJSON 

func (this *WorkloadSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WorkloadSpec

func (*WorkloadSpec) ProtoMessage 

func (*WorkloadSpec) ProtoMessage()

func (*WorkloadSpec) ProtoReflect 

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

func (*WorkloadSpec) Reset 

func (x *WorkloadSpec) Reset()

func (*WorkloadSpec) String 

func (x *WorkloadSpec) String() string

func (*WorkloadSpec) UnmarshalJSON 

func (this *WorkloadSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WorkloadSpec

type WorkloadSpec_AppMesh 

type WorkloadSpec_AppMesh struct {

	// The value of the env var APPMESH_VIRTUAL_NODE_NAME on the App Mesh envoy proxy container.
	VirtualNodeName string `protobuf:"bytes,1,opt,name=virtual_node_name,json=virtualNodeName,proto3" json:"virtual_node_name,omitempty"`
	// Ports exposed by this workload. Needed for declaring App Mesh VirtualNode listeners.
	Ports []*WorkloadSpec_AppMesh_ContainerPort `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

Metadata specific to an App Mesh controlled workload.

func (*WorkloadSpec_AppMesh) Descriptor deprecated 

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

Deprecated: Use WorkloadSpec_AppMesh.ProtoReflect.Descriptor instead.

func (*WorkloadSpec_AppMesh) Equal 

func (m *WorkloadSpec_AppMesh) Equal(that interface{}) bool

Equal function

func (*WorkloadSpec_AppMesh) GetPorts 

func (x *WorkloadSpec_AppMesh) GetPorts() []*WorkloadSpec_AppMesh_ContainerPort

func (*WorkloadSpec_AppMesh) GetVirtualNodeName 

func (x *WorkloadSpec_AppMesh) GetVirtualNodeName() string

func (*WorkloadSpec_AppMesh) ProtoMessage 

func (*WorkloadSpec_AppMesh) ProtoMessage()

func (*WorkloadSpec_AppMesh) ProtoReflect 

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

func (*WorkloadSpec_AppMesh) Reset 

func (x *WorkloadSpec_AppMesh) Reset()

func (*WorkloadSpec_AppMesh) String 

func (x *WorkloadSpec_AppMesh) String() string

type WorkloadSpec_AppMesh_ContainerPort 

type WorkloadSpec_AppMesh_ContainerPort struct {
	Port     uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes application container ports.

func (*WorkloadSpec_AppMesh_ContainerPort) Descriptor deprecated 

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

Deprecated: Use WorkloadSpec_AppMesh_ContainerPort.ProtoReflect.Descriptor instead.

func (*WorkloadSpec_AppMesh_ContainerPort) Equal 

func (m *WorkloadSpec_AppMesh_ContainerPort) Equal(that interface{}) bool

Equal function

func (*WorkloadSpec_AppMesh_ContainerPort) GetPort 

func (x *WorkloadSpec_AppMesh_ContainerPort) GetPort() uint32

func (*WorkloadSpec_AppMesh_ContainerPort) GetProtocol 

func (x *WorkloadSpec_AppMesh_ContainerPort) GetProtocol() string

func (*WorkloadSpec_AppMesh_ContainerPort) ProtoMessage 

func (*WorkloadSpec_AppMesh_ContainerPort) ProtoMessage()

func (*WorkloadSpec_AppMesh_ContainerPort) ProtoReflect 

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

func (*WorkloadSpec_AppMesh_ContainerPort) Reset 

func (x *WorkloadSpec_AppMesh_ContainerPort) Reset()

func (*WorkloadSpec_AppMesh_ContainerPort) String 

func (x *WorkloadSpec_AppMesh_ContainerPort) String() string

type WorkloadSpec_Kubernetes 

type WorkloadSpec_Kubernetes struct {
	// Information describing workloads backed by Kubernetes Pods.
	Kubernetes *WorkloadSpec_KubernetesWorkload `protobuf:"bytes,1,opt,name=kubernetes,proto3,oneof"`
}

type WorkloadSpec_KubernetesWorkload 

type WorkloadSpec_KubernetesWorkload struct {

	// Resource reference to the Kubernetes Pod controller (i.e. Deployment, ReplicaSet, DaemonSet) for this Workload..
	Controller *v1.ClusterObjectRef `protobuf:"bytes,1,opt,name=controller,proto3" json:"controller,omitempty"`
	// Labels on the Pod itself (read from `metadata.labels`), which are used to determine which Services front this workload.
	PodLabels map[string]string `` /* 176-byte string literal not displayed */
	// Service account associated with the Pods owned by this controller.
	ServiceAccountName string `protobuf:"bytes,3,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"`
	// contains filtered or unexported fields
}

Describes a Kubernetes workload (e.g. a Deployment or DaemonSet).

func (*WorkloadSpec_KubernetesWorkload) Descriptor deprecated 

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

Deprecated: Use WorkloadSpec_KubernetesWorkload.ProtoReflect.Descriptor instead.

func (*WorkloadSpec_KubernetesWorkload) Equal 

func (m *WorkloadSpec_KubernetesWorkload) Equal(that interface{}) bool

Equal function

func (*WorkloadSpec_KubernetesWorkload) GetController 

func (x *WorkloadSpec_KubernetesWorkload) GetController() *v1.ClusterObjectRef

func (*WorkloadSpec_KubernetesWorkload) GetPodLabels 

func (x *WorkloadSpec_KubernetesWorkload) GetPodLabels() map[string]string

func (*WorkloadSpec_KubernetesWorkload) GetServiceAccountName 

func (x *WorkloadSpec_KubernetesWorkload) GetServiceAccountName() string

func (*WorkloadSpec_KubernetesWorkload) ProtoMessage 

func (*WorkloadSpec_KubernetesWorkload) ProtoMessage()

func (*WorkloadSpec_KubernetesWorkload) ProtoReflect 

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

func (*WorkloadSpec_KubernetesWorkload) Reset 

func (x *WorkloadSpec_KubernetesWorkload) Reset()

func (*WorkloadSpec_KubernetesWorkload) String 

func (x *WorkloadSpec_KubernetesWorkload) String() string

type WorkloadStatus 

type WorkloadStatus struct {

	// The observed generation of the Workload.
	// When this matches the Workload's `metadata.generation` it indicates that Gloo Mesh
	// has processed the latest version of the Workload.
	ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// The set of AccessLogRecords that have been applied to this Workload.
	AppliedAccessLogRecords []*WorkloadStatus_AppliedAccessLogRecord `` /* 134-byte string literal not displayed */
	// The set of WasmDeployments that have been applied to this Workload.
	AppliedWasmDeployments []*WorkloadStatus_AppliedWasmDeployment `` /* 129-byte string literal not displayed */
	// Specifies the [ServiceDependencies]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.networking.v1alpha1.service_dependency/" >}})
	// that apply to this Workload, and the resulting Destination hostnames that this Workload can send traffic to.
	ServiceDependencies *WorkloadStatus_ServiceDependencies `protobuf:"bytes,4,opt,name=service_dependencies,json=serviceDependencies,proto3" json:"service_dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatus) DeepCopyInto 

func (in *WorkloadStatus) DeepCopyInto(out *WorkloadStatus)

DeepCopyInto for the Workload.Status

func (*WorkloadStatus) Descriptor deprecated 

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

Deprecated: Use WorkloadStatus.ProtoReflect.Descriptor instead.

func (*WorkloadStatus) Equal 

func (m *WorkloadStatus) Equal(that interface{}) bool

Equal function

func (*WorkloadStatus) GetAppliedAccessLogRecords 

func (x *WorkloadStatus) GetAppliedAccessLogRecords() []*WorkloadStatus_AppliedAccessLogRecord

func (*WorkloadStatus) GetAppliedWasmDeployments 

func (x *WorkloadStatus) GetAppliedWasmDeployments() []*WorkloadStatus_AppliedWasmDeployment

func (*WorkloadStatus) GetObservedGeneration 

func (x *WorkloadStatus) GetObservedGeneration() int64

func (*WorkloadStatus) GetServiceDependencies added in v1.1.0 

func (x *WorkloadStatus) GetServiceDependencies() *WorkloadStatus_ServiceDependencies

func (*WorkloadStatus) MarshalJSON 

func (this *WorkloadStatus) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WorkloadStatus

func (*WorkloadStatus) ProtoMessage 

func (*WorkloadStatus) ProtoMessage()

func (*WorkloadStatus) ProtoReflect 

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

func (*WorkloadStatus) Reset 

func (x *WorkloadStatus) Reset()

func (*WorkloadStatus) String 

func (x *WorkloadStatus) String() string

func (*WorkloadStatus) UnmarshalJSON 

func (this *WorkloadStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WorkloadStatus

type WorkloadStatusWriter 

type WorkloadStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Workload object.
	UpdateWorkloadStatus(ctx context.Context, obj *Workload, opts ...client.UpdateOption) error

	// Patch patches the given Workload object's subresource.
	PatchWorkloadStatus(ctx context.Context, obj *Workload, patch client.Patch, opts ...client.PatchOption) error
}

StatusWriter knows how to update status subresource of a Workload object.

type WorkloadStatus_AppliedAccessLogRecord 

type WorkloadStatus_AppliedAccessLogRecord struct {

	// Reference to the AccessLogRecord object.
	Ref *v1.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The observed generation of the accepted AccessLogRecord.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// Any errors encountered while processing the AccessLogRecord object
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Describes an [AccessLogRecord]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.observability.v1alpha1.access_logging/" >}}) that applies to this Workload.

func (*WorkloadStatus_AppliedAccessLogRecord) Descriptor deprecated 

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

Deprecated: Use WorkloadStatus_AppliedAccessLogRecord.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_AppliedAccessLogRecord) Equal 

func (m *WorkloadStatus_AppliedAccessLogRecord) Equal(that interface{}) bool

Equal function

func (*WorkloadStatus_AppliedAccessLogRecord) GetErrors 

func (x *WorkloadStatus_AppliedAccessLogRecord) GetErrors() []string

func (*WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration 

func (x *WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedAccessLogRecord) GetRef 

func (x *WorkloadStatus_AppliedAccessLogRecord) GetRef() *v1.ObjectRef

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage 

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage()

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoReflect 

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

func (*WorkloadStatus_AppliedAccessLogRecord) Reset 

func (x *WorkloadStatus_AppliedAccessLogRecord) Reset()

func (*WorkloadStatus_AppliedAccessLogRecord) String 

func (x *WorkloadStatus_AppliedAccessLogRecord) String() string

type WorkloadStatus_AppliedWasmDeployment 

type WorkloadStatus_AppliedWasmDeployment struct {

	// Reference to the WasmDeployment object.
	Ref *v1.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The observed generation of the WasmDeployment.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// Any errors encountered while processing the WasmDeployment object.
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Describes a [WasmDeployment]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.networking.v1alpha1.wasm_deployment/" >}}) that applies to this Workload.

func (*WorkloadStatus_AppliedWasmDeployment) Descriptor deprecated 

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

Deprecated: Use WorkloadStatus_AppliedWasmDeployment.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_AppliedWasmDeployment) Equal 

func (m *WorkloadStatus_AppliedWasmDeployment) Equal(that interface{}) bool

Equal function

func (*WorkloadStatus_AppliedWasmDeployment) GetErrors 

func (x *WorkloadStatus_AppliedWasmDeployment) GetErrors() []string

func (*WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration 

func (x *WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedWasmDeployment) GetRef 

func (x *WorkloadStatus_AppliedWasmDeployment) GetRef() *v1.ObjectRef

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage 

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage()

func (*WorkloadStatus_AppliedWasmDeployment) ProtoReflect 

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

func (*WorkloadStatus_AppliedWasmDeployment) Reset 

func (x *WorkloadStatus_AppliedWasmDeployment) Reset()

func (*WorkloadStatus_AppliedWasmDeployment) String 

func (x *WorkloadStatus_AppliedWasmDeployment) String() string

type WorkloadStatus_ServiceDependencies added in v1.1.0 

type WorkloadStatus_ServiceDependencies struct {

	// The set of [ServiceDependencies]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.networking.v1alpha1.service_dependency/" >}}) that have been applied to this Workload.
	AppliedServiceDependencies []*WorkloadStatus_ServiceDependencies_AppliedServiceDependency `` /* 141-byte string literal not displayed */
	// The set of Destination hostnames that this Workload depends on.
	DestinationHostnames []string `protobuf:"bytes,2,rep,name=destination_hostnames,json=destinationHostnames,proto3" json:"destination_hostnames,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatus_ServiceDependencies) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use WorkloadStatus_ServiceDependencies.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_ServiceDependencies) Equal added in v1.1.0 

func (m *WorkloadStatus_ServiceDependencies) Equal(that interface{}) bool

Equal function

func (*WorkloadStatus_ServiceDependencies) GetAppliedServiceDependencies added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies) GetAppliedServiceDependencies() []*WorkloadStatus_ServiceDependencies_AppliedServiceDependency

func (*WorkloadStatus_ServiceDependencies) GetDestinationHostnames added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies) GetDestinationHostnames() []string

func (*WorkloadStatus_ServiceDependencies) ProtoMessage added in v1.1.0 

func (*WorkloadStatus_ServiceDependencies) ProtoMessage()

func (*WorkloadStatus_ServiceDependencies) ProtoReflect added in v1.1.0 

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

func (*WorkloadStatus_ServiceDependencies) Reset added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies) Reset()

func (*WorkloadStatus_ServiceDependencies) String added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies) String() string

type WorkloadStatus_ServiceDependencies_AppliedServiceDependency added in v1.1.0 

type WorkloadStatus_ServiceDependencies_AppliedServiceDependency struct {

	// Reference to the ServiceDependency object.
	ServiceDependencyRef *v1.ObjectRef `protobuf:"bytes,1,opt,name=service_dependency_ref,json=serviceDependencyRef,proto3" json:"service_dependency_ref,omitempty"`
	// The observed generation of the ServiceDependency.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// contains filtered or unexported fields
}

Describes a [ServiceDependency]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.enterprise.networking.v1alpha1.service_dependency/" >}}) that applies to this workload.

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use WorkloadStatus_ServiceDependencies_AppliedServiceDependency.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) Equal added in v1.1.0 

func (m *WorkloadStatus_ServiceDependencies_AppliedServiceDependency) Equal(that interface{}) bool

Equal function

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) GetObservedGeneration added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies_AppliedServiceDependency) GetObservedGeneration() int64

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) GetServiceDependencyRef added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies_AppliedServiceDependency) GetServiceDependencyRef() *v1.ObjectRef

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) ProtoMessage added in v1.1.0 

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) ProtoMessage()

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) ProtoReflect added in v1.1.0 

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

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) Reset added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies_AppliedServiceDependency) Reset()

func (*WorkloadStatus_ServiceDependencies_AppliedServiceDependency) String added in v1.1.0 

func (x *WorkloadStatus_ServiceDependencies_AppliedServiceDependency) String() string

type WorkloadTransitionFunction 

type WorkloadTransitionFunction func(existing, desired *Workload) error

WorkloadTransitionFunction instructs the WorkloadWriter how to transition between an existing Workload object and a desired on an Upsert

type WorkloadWriter 

type WorkloadWriter interface {
	// Create saves the Workload object.
	CreateWorkload(ctx context.Context, obj *Workload, opts ...client.CreateOption) error

	// Delete deletes the Workload object.
	DeleteWorkload(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Workload object.
	UpdateWorkload(ctx context.Context, obj *Workload, opts ...client.UpdateOption) error

	// Patch patches the given Workload object.
	PatchWorkload(ctx context.Context, obj *Workload, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Workload objects matching the given options.
	DeleteAllOfWorkload(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Workload object.
	UpsertWorkload(ctx context.Context, obj *Workload, transitionFuncs ...WorkloadTransitionFunction) error
}

Writer knows how to create, delete, and update Workloads.

Source Files

View all Source files

Directories

Path Synopsis
Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers
 Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers
mocks
Package mock_controller is a generated GoMock package.
 Package mock_controller is a generated GoMock package.
Package mock_v1 is a generated GoMock package.
 Package mock_v1 is a generated GoMock package.
mocks
Package mock_v1sets is a generated GoMock package.
 Package mock_v1sets is a generated GoMock package.

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.