v1alpha2

package
v0.12.3 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha2 contains API Schema definitions for the discovery.mesh.gloo.solo.io v1alpha2 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 (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "discovery.mesh.gloo.solo.io", Version: "v1alpha2"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1alpha2_mesh_proto protoreflect.FileDescriptor
View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1alpha2_traffic_target_proto protoreflect.FileDescriptor
View Source 
var File_github_com_solo_io_gloo_mesh_api_discovery_v1alpha2_workload_proto protoreflect.FileDescriptor
View Source 
var MeshGVK = schema.GroupVersionKind{
	Group:   "discovery.mesh.gloo.solo.io",
	Version: "v1alpha2",
	Kind:    "Mesh",
}

GroupVersionKind for Mesh

View Source 
var TrafficTargetGVK = schema.GroupVersionKind{
	Group:   "discovery.mesh.gloo.solo.io",
	Version: "v1alpha2",
	Kind:    "TrafficTarget",
}

GroupVersionKind for TrafficTarget

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

GroupVersionKind for Workload

Functions

func AddToScheme 

func AddToScheme(s *runtime.Scheme) error

func NewMeshClient 

func NewMeshClient(client client.Client) *meshClient

func NewTrafficTargetClient 

func NewTrafficTargetClient(client client.Client) *trafficTargetClient

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/v1alpha2/v1alpha2 APIs
	TrafficTargets() TrafficTargetClient
	// clienset for the discovery.mesh.gloo.solo.io/v1alpha2/v1alpha2 APIs
	Workloads() WorkloadClient
	// clienset for the discovery.mesh.gloo.solo.io/v1alpha2/v1alpha2 APIs
	Meshes() MeshClient
}

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

func NewClientset 

func NewClientset(client client.Client) Clientset

func NewClientsetFromConfig 

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

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

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 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 {

	// The mesh type indicates information specific to the particular type of
	// Mesh represented by this Mesh resource.
	//
	// Types that are assignable to MeshType:
	//	*MeshSpec_Istio_
	//	*MeshSpec_AwsAppMesh_
	//	*MeshSpec_Linkerd
	//	*MeshSpec_ConsulConnect
	//	*MeshSpec_Osm
	MeshType isMeshSpec_MeshType `protobuf_oneof:"mesh_type"`
	// Information about the Gloo Mesh certificate agent if it has been installed to the remote cluster.
	AgentInfo *MeshSpec_AgentInfo `protobuf:"bytes,5,opt,name=agent_info,json=agentInfo,proto3" json:"agent_info,omitempty"`
	// contains filtered or unexported fields
}

Meshes represent a currently registered service mesh.

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) GetIstio 

func (x *MeshSpec) GetIstio() *MeshSpec_Istio

func (*MeshSpec) GetLinkerd 

func (x *MeshSpec) GetLinkerd() *MeshSpec_LinkerdMesh

func (*MeshSpec) GetMeshType 

func (m *MeshSpec) GetMeshType() isMeshSpec_MeshType

func (*MeshSpec) GetOsm 

func (x *MeshSpec) GetOsm() *MeshSpec_OSM

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

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 agent is installed
	AgentNamespace string `protobuf:"bytes,1,opt,name=agent_namespace,json=agentNamespace,proto3" json:"agent_namespace,omitempty"`
	// contains filtered or unexported fields
}

information about the Gloo Mesh Cert-Agent which may be installed to the remote cluster which contains 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 added in v0.10.8 

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 {

	// AWS name for the AppMesh instance, must be unique across the AWS account.
	AwsName string `protobuf:"bytes,1,opt,name=aws_name,json=awsName,proto3" json:"aws_name,omitempty"`
	// The AWS region the AWS 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 Mesh.
	Arn string `protobuf:"bytes,4,opt,name=arn,proto3" json:"arn,omitempty"`
	// The k8s clusters on which sidecars for this AppMesh instance have been discovered.
	Clusters []string `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

Mesh object representing AWS AppMesh.

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

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 {
	AwsAppMesh *MeshSpec_AwsAppMesh `protobuf:"bytes,2,opt,name=aws_app_mesh,json=awsAppMesh,proto3,oneof"`
}

type MeshSpec_ConsulConnect 

type MeshSpec_ConsulConnect struct {
	ConsulConnect *MeshSpec_ConsulConnectMesh `protobuf:"bytes,4,opt,name=consul_connect,json=consulConnect,proto3,oneof"`
}

type MeshSpec_ConsulConnectMesh 

type MeshSpec_ConsulConnectMesh struct {
	Installation *MeshSpec_MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// contains filtered or unexported fields
}

Mesh object representing an installed ConsulConnect control plane.

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() *MeshSpec_MeshInstallation

func (*MeshSpec_ConsulConnectMesh) ProtoMessage 

func (*MeshSpec_ConsulConnectMesh) ProtoMessage()

func (*MeshSpec_ConsulConnectMesh) ProtoReflect added in v0.10.8 

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 {

	// Configuration metadata about the istio control plane installation.
	Installation *MeshSpec_MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// Configuration metadata for Istio Citadel (Istio's security component).
	CitadelInfo *MeshSpec_Istio_CitadelInfo `protobuf:"bytes,2,opt,name=citadel_info,json=citadelInfo,proto3" json:"citadel_info,omitempty"`
	// Configuration metadata for Istio IngressGateway (the Istio Ingress).
	IngressGateways []*MeshSpec_Istio_IngressGatewayInfo `protobuf:"bytes,3,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
}

Mesh object representing an installed Istio control plane

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) GetCitadelInfo 

func (x *MeshSpec_Istio) GetCitadelInfo() *MeshSpec_Istio_CitadelInfo

func (*MeshSpec_Istio) GetIngressGateways 

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

func (*MeshSpec_Istio) GetInstallation 

func (x *MeshSpec_Istio) GetInstallation() *MeshSpec_MeshInstallation

func (*MeshSpec_Istio) GetSmartDnsProxyingEnabled added in v0.12.0 

func (x *MeshSpec_Istio) GetSmartDnsProxyingEnabled() bool

func (*MeshSpec_Istio) ProtoMessage 

func (*MeshSpec_Istio) ProtoMessage()

func (*MeshSpec_Istio) ProtoReflect added in v0.10.8 

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 {
	Istio *MeshSpec_Istio `protobuf:"bytes,1,opt,name=istio,proto3,oneof"`
}

type MeshSpec_Istio_CitadelInfo 

type MeshSpec_Istio_CitadelInfo struct {

	//
	//Istio trust domain used for https/spiffe identity.
	//https://spiffe.io/spiffe/concepts/#trust-domain
	//https://istio.io/docs/reference/glossary/#identity
	//
	//If empty will default to "cluster.local".
	TrustDomain string `protobuf:"bytes,1,opt,name=trust_domain,json=trustDomain,proto3" json:"trust_domain,omitempty"`
	//
	//istio-citadel service account, used to determine identity for the Istio CA cert.
	//If empty will default to "istio-citadel".
	CitadelServiceAccount string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration metadata for Istio Citadel (Istio's security component).

func (*MeshSpec_Istio_CitadelInfo) Descriptor deprecated 

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

Deprecated: Use MeshSpec_Istio_CitadelInfo.ProtoReflect.Descriptor instead.

func (*MeshSpec_Istio_CitadelInfo) Equal 

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

Equal function

func (*MeshSpec_Istio_CitadelInfo) GetCitadelServiceAccount 

func (x *MeshSpec_Istio_CitadelInfo) GetCitadelServiceAccount() string

func (*MeshSpec_Istio_CitadelInfo) GetTrustDomain 

func (x *MeshSpec_Istio_CitadelInfo) GetTrustDomain() string

func (*MeshSpec_Istio_CitadelInfo) ProtoMessage 

func (*MeshSpec_Istio_CitadelInfo) ProtoMessage()

func (*MeshSpec_Istio_CitadelInfo) ProtoReflect added in v0.10.8 

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

func (*MeshSpec_Istio_CitadelInfo) Reset 

func (x *MeshSpec_Istio_CitadelInfo) Reset()

func (*MeshSpec_Istio_CitadelInfo) String 

func (x *MeshSpec_Istio_CitadelInfo) String() string

type MeshSpec_Istio_IngressGatewayInfo 

type MeshSpec_Istio_IngressGatewayInfo struct {

	// Labels matching the workload which backs the gateway,
	// defaults to `{"istio": "ingressgateway"}`.
	WorkloadLabels map[string]string `` /* 191-byte string literal not displayed */
	// 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).
	ExternalAddress string `protobuf:"bytes,2,opt,name=external_address,json=externalAddress,proto3" json:"external_address,omitempty"`
	// The externally-reachable port on which the gateway is listening for TLS connections.
	// This will be the port used for cross-cluster connectivity.
	// List of common ports: 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
}

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) GetExternalAddress 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetExternalAddress() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort 

func (x *MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort() uint32

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

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_Linkerd 

type MeshSpec_Linkerd struct {
	Linkerd *MeshSpec_LinkerdMesh `protobuf:"bytes,3,opt,name=linkerd,proto3,oneof"`
}

type MeshSpec_LinkerdMesh 

type MeshSpec_LinkerdMesh struct {
	Installation *MeshSpec_MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// The cluster domain suffix this Linkerd mesh is configured with.
	// See https://linkerd.io/2/tasks/using-custom-domain/ for info.
	ClusterDomain string `protobuf:"bytes,2,opt,name=cluster_domain,json=clusterDomain,proto3" json:"cluster_domain,omitempty"`
	// contains filtered or unexported fields
}

Mesh object representing an installed Linkerd control plane.

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() *MeshSpec_MeshInstallation

func (*MeshSpec_LinkerdMesh) ProtoMessage 

func (*MeshSpec_LinkerdMesh) ProtoMessage()

func (*MeshSpec_LinkerdMesh) ProtoReflect added in v0.10.8 

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_MeshInstallation 

type MeshSpec_MeshInstallation struct {

	// Namespace in which the control plane has been installed.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 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 */
	// Version of the Mesh that has been installed.
	// 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"`
	// contains filtered or unexported fields
}

The cluster on which the control plane for this mesh is deployed. Not all MeshTypes have a MeshInstallation. Only self-hosted control planes such as Istio and Linkerd will have installation metadata.

func (*MeshSpec_MeshInstallation) Descriptor deprecated 

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

Deprecated: Use MeshSpec_MeshInstallation.ProtoReflect.Descriptor instead.

func (*MeshSpec_MeshInstallation) Equal 

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

Equal function

func (*MeshSpec_MeshInstallation) GetCluster 

func (x *MeshSpec_MeshInstallation) GetCluster() string

func (*MeshSpec_MeshInstallation) GetNamespace 

func (x *MeshSpec_MeshInstallation) GetNamespace() string

func (*MeshSpec_MeshInstallation) GetPodLabels 

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

func (*MeshSpec_MeshInstallation) GetVersion 

func (x *MeshSpec_MeshInstallation) GetVersion() string

func (*MeshSpec_MeshInstallation) ProtoMessage 

func (*MeshSpec_MeshInstallation) ProtoMessage()

func (*MeshSpec_MeshInstallation) ProtoReflect added in v0.10.8 

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

func (*MeshSpec_MeshInstallation) Reset 

func (x *MeshSpec_MeshInstallation) Reset()

func (*MeshSpec_MeshInstallation) String 

func (x *MeshSpec_MeshInstallation) String() string

type MeshSpec_OSM 

type MeshSpec_OSM struct {

	// Information about where OSM is installed in a managed Kubernetes Cluster.
	Installation *MeshSpec_MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	// contains filtered or unexported fields
}

https://github.com/openservicemesh/osm

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() *MeshSpec_MeshInstallation

func (*MeshSpec_OSM) ProtoMessage 

func (*MeshSpec_OSM) ProtoMessage()

func (*MeshSpec_OSM) ProtoReflect added in v0.10.8 

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 {
	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 mesh-networking
	// has reconciled 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 FailoverServices, if any, which applies to this mesh.
	AppliedFailoverServices []*MeshStatus_AppliedFailoverService `` /* 132-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) GetAppliedFailoverServices 

func (x *MeshStatus) GetAppliedFailoverServices() []*MeshStatus_AppliedFailoverService

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

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_AppliedFailoverService 

type MeshStatus_AppliedFailoverService struct {

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

AppliedFailoverService represents a FailoverService that has been applied to this Mesh. If an existing FailoverService becomes invalid the last applied FailoverService will be used.

func (*MeshStatus_AppliedFailoverService) Descriptor deprecated 

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

Deprecated: Use MeshStatus_AppliedFailoverService.ProtoReflect.Descriptor instead.

func (*MeshStatus_AppliedFailoverService) Equal 

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

Equal function

func (*MeshStatus_AppliedFailoverService) GetObservedGeneration 

func (x *MeshStatus_AppliedFailoverService) GetObservedGeneration() int64

func (*MeshStatus_AppliedFailoverService) GetRef 

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

func (*MeshStatus_AppliedFailoverService) GetSpec 

func (x *MeshStatus_AppliedFailoverService) GetSpec() *v1alpha2.FailoverServiceSpec

func (*MeshStatus_AppliedFailoverService) ProtoMessage 

func (*MeshStatus_AppliedFailoverService) ProtoMessage()

func (*MeshStatus_AppliedFailoverService) ProtoReflect added in v0.10.8 

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

func (*MeshStatus_AppliedFailoverService) Reset 

func (x *MeshStatus_AppliedFailoverService) Reset()

func (*MeshStatus_AppliedFailoverService) String 

func (x *MeshStatus_AppliedFailoverService) String() string

type MeshStatus_AppliedVirtualMesh 

type MeshStatus_AppliedVirtualMesh struct {

	// Reference to the VirtualMesh.
	Ref *v1.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 last known valid spec of the VirtualMesh.
	Spec *v1alpha2.VirtualMeshSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

AppliedVirtualMesh represents a VirtualMesh that has been applied to this Mesh. If an existing 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() *v1.ObjectRef

func (*MeshStatus_AppliedVirtualMesh) GetSpec 

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

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage 

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage()

func (*MeshStatus_AppliedVirtualMesh) ProtoReflect added in v0.10.8 

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/v1alpha2 APIs

func NewMulticlusterClientset 

func NewMulticlusterClientset(client multicluster.Client) MulticlusterClientset

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 MulticlusterTrafficTargetClient 

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

Provides TrafficTargetClients for multiple clusters.

func NewMulticlusterTrafficTargetClient 

func NewMulticlusterTrafficTargetClient(client multicluster.Client) MulticlusterTrafficTargetClient

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 TrafficTarget 

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

	Spec   TrafficTargetSpec   `json:"spec,omitempty"`
	Status TrafficTargetStatus `json:"status,omitempty"`
}

TrafficTarget is the Schema for the trafficTarget API

func (*TrafficTarget) DeepCopy 

func (in *TrafficTarget) DeepCopy() *TrafficTarget

func (*TrafficTarget) DeepCopyInto 

func (in *TrafficTarget) DeepCopyInto(out *TrafficTarget)

func (*TrafficTarget) DeepCopyObject 

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

func (TrafficTarget) GVK added in v0.10.5 

func (TrafficTarget) GVK() schema.GroupVersionKind

GVK returns the GroupVersionKind associated with the resource type.

type TrafficTargetClient 

type TrafficTargetClient interface {
	TrafficTargetReader
	TrafficTargetWriter
	TrafficTargetStatusWriter
}

Client knows how to perform CRUD operations on TrafficTargets.

type TrafficTargetList 

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

TrafficTargetList contains a list of TrafficTarget

func (*TrafficTargetList) DeepCopy 

func (in *TrafficTargetList) DeepCopy() *TrafficTargetList

func (*TrafficTargetList) DeepCopyInto 

func (in *TrafficTargetList) DeepCopyInto(out *TrafficTargetList)

func (*TrafficTargetList) DeepCopyObject 

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

type TrafficTargetReader 

type TrafficTargetReader interface {
	// Get retrieves a TrafficTarget for the given object key
	GetTrafficTarget(ctx context.Context, key client.ObjectKey) (*TrafficTarget, error)

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

Reader knows how to read and list TrafficTargets.

type TrafficTargetSlice 

type TrafficTargetSlice []*TrafficTarget

TrafficTargetSlice represents a slice of *TrafficTarget

type TrafficTargetSpec 

type TrafficTargetSpec struct {

	// The type of traffic target backing the TrafficTarget.
	//
	// Types that are assignable to Type:
	//	*TrafficTargetSpec_KubeService_
	Type isTrafficTargetSpec_Type `protobuf_oneof:"type"`
	// The mesh with which this traffic target is associated.
	Mesh *v1.ObjectRef `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// contains filtered or unexported fields
}

* The TrafficTarget is an abstraction for a traffic target which we have discovered to be part of a given mesh.

func (*TrafficTargetSpec) DeepCopyInto 

func (in *TrafficTargetSpec) DeepCopyInto(out *TrafficTargetSpec)

DeepCopyInto for the TrafficTarget.Spec

func (*TrafficTargetSpec) Descriptor deprecated 

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

Deprecated: Use TrafficTargetSpec.ProtoReflect.Descriptor instead.

func (*TrafficTargetSpec) Equal 

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

Equal function

func (*TrafficTargetSpec) GetKubeService 

func (x *TrafficTargetSpec) GetKubeService() *TrafficTargetSpec_KubeService

func (*TrafficTargetSpec) GetMesh 

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

func (*TrafficTargetSpec) GetType 

func (m *TrafficTargetSpec) GetType() isTrafficTargetSpec_Type

func (*TrafficTargetSpec) MarshalJSON 

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

MarshalJSON is a custom marshaler for TrafficTargetSpec

func (*TrafficTargetSpec) ProtoMessage 

func (*TrafficTargetSpec) ProtoMessage()

func (*TrafficTargetSpec) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetSpec) Reset 

func (x *TrafficTargetSpec) Reset()

func (*TrafficTargetSpec) String 

func (x *TrafficTargetSpec) String() string

func (*TrafficTargetSpec) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for TrafficTargetSpec

type TrafficTargetSpec_KubeService 

type TrafficTargetSpec_KubeService struct {

	// A reference to the kube-native traffic target that this TrafficTarget represents.
	Ref *v1.ClusterObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Selectors for the set of pods targeted by the k8s Service.
	WorkloadSelectorLabels map[string]string `` /* 217-byte string literal not displayed */
	// Labels on the underlying k8s Service itself.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The ports exposed by the underlying service.
	Ports []*TrafficTargetSpec_KubeService_KubeServicePort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// Subsets for routing, based on labels.
	Subsets map[string]*TrafficTargetSpec_KubeService_Subset `` /* 155-byte string literal not displayed */
	// Each endpoints subset is a group of endpoint 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
	Endpoints []*TrafficTargetSpec_KubeService_EndpointsSubset `protobuf:"bytes,6,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficTargetSpec_KubeService) Descriptor deprecated 

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

Deprecated: Use TrafficTargetSpec_KubeService.ProtoReflect.Descriptor instead.

func (*TrafficTargetSpec_KubeService) Equal 

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

Equal function

func (*TrafficTargetSpec_KubeService) GetEndpoints added in v0.12.0 

func (x *TrafficTargetSpec_KubeService) GetEndpoints() []*TrafficTargetSpec_KubeService_EndpointsSubset

func (*TrafficTargetSpec_KubeService) GetLabels 

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

func (*TrafficTargetSpec_KubeService) GetPorts 

func (x *TrafficTargetSpec_KubeService) GetPorts() []*TrafficTargetSpec_KubeService_KubeServicePort

func (*TrafficTargetSpec_KubeService) GetRef 

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

func (*TrafficTargetSpec_KubeService) GetSubsets 

func (x *TrafficTargetSpec_KubeService) GetSubsets() map[string]*TrafficTargetSpec_KubeService_Subset

func (*TrafficTargetSpec_KubeService) GetWorkloadSelectorLabels 

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

func (*TrafficTargetSpec_KubeService) ProtoMessage 

func (*TrafficTargetSpec_KubeService) ProtoMessage()

func (*TrafficTargetSpec_KubeService) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetSpec_KubeService) Reset 

func (x *TrafficTargetSpec_KubeService) Reset()

func (*TrafficTargetSpec_KubeService) String 

func (x *TrafficTargetSpec_KubeService) String() string

type TrafficTargetSpec_KubeService_ 

type TrafficTargetSpec_KubeService_ struct {
	// Metadata about the kube-native traffic target backing this TrafficTarget.
	KubeService *TrafficTargetSpec_KubeService `protobuf:"bytes,1,opt,name=kube_service,json=kubeService,proto3,oneof"`
}

type TrafficTargetSpec_KubeService_EndpointsSubset added in v0.12.0 

type TrafficTargetSpec_KubeService_EndpointsSubset struct {
	IpAddresses []string                                         `protobuf:"bytes,1,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
	Ports       []*TrafficTargetSpec_KubeService_KubeServicePort `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 + port pairs is the cartesian product of the following lists

func (*TrafficTargetSpec_KubeService_EndpointsSubset) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use TrafficTargetSpec_KubeService_EndpointsSubset.ProtoReflect.Descriptor instead.

func (*TrafficTargetSpec_KubeService_EndpointsSubset) Equal added in v0.12.0 

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

Equal function

func (*TrafficTargetSpec_KubeService_EndpointsSubset) GetIpAddresses added in v0.12.0 

func (x *TrafficTargetSpec_KubeService_EndpointsSubset) GetIpAddresses() []string

func (*TrafficTargetSpec_KubeService_EndpointsSubset) GetPorts added in v0.12.0 

func (x *TrafficTargetSpec_KubeService_EndpointsSubset) GetPorts() []*TrafficTargetSpec_KubeService_KubeServicePort

func (*TrafficTargetSpec_KubeService_EndpointsSubset) ProtoMessage added in v0.12.0 

func (*TrafficTargetSpec_KubeService_EndpointsSubset) ProtoMessage()

func (*TrafficTargetSpec_KubeService_EndpointsSubset) ProtoReflect added in v0.12.0 

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

func (*TrafficTargetSpec_KubeService_EndpointsSubset) Reset added in v0.12.0 

func (x *TrafficTargetSpec_KubeService_EndpointsSubset) Reset()

func (*TrafficTargetSpec_KubeService_EndpointsSubset) String added in v0.12.0 

func (x *TrafficTargetSpec_KubeService_EndpointsSubset) String() string

type TrafficTargetSpec_KubeService_KubeServicePort 

type TrafficTargetSpec_KubeService_KubeServicePort struct {

	// External-facing port for this k8s service (NOT the service's target port on the backing pods).
	Port     uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Available in k8s 1.18+, specifies the application protocol.
	AppProtocol string `protobuf:"bytes,4,opt,name=app_protocol,json=appProtocol,proto3" json:"app_protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficTargetSpec_KubeService_KubeServicePort) Descriptor deprecated 

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

Deprecated: Use TrafficTargetSpec_KubeService_KubeServicePort.ProtoReflect.Descriptor instead.

func (*TrafficTargetSpec_KubeService_KubeServicePort) Equal 

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

Equal function

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetAppProtocol 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) GetAppProtocol() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetName 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) GetName() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetPort 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) GetPort() uint32

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetProtocol 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) GetProtocol() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoMessage 

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoMessage()

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetSpec_KubeService_KubeServicePort) Reset 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) Reset()

func (*TrafficTargetSpec_KubeService_KubeServicePort) String 

func (x *TrafficTargetSpec_KubeService_KubeServicePort) String() string

type TrafficTargetSpec_KubeService_Subset 

type TrafficTargetSpec_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 (*TrafficTargetSpec_KubeService_Subset) Descriptor deprecated 

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

Deprecated: Use TrafficTargetSpec_KubeService_Subset.ProtoReflect.Descriptor instead.

func (*TrafficTargetSpec_KubeService_Subset) Equal 

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

Equal function

func (*TrafficTargetSpec_KubeService_Subset) GetValues 

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

func (*TrafficTargetSpec_KubeService_Subset) ProtoMessage 

func (*TrafficTargetSpec_KubeService_Subset) ProtoMessage()

func (*TrafficTargetSpec_KubeService_Subset) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetSpec_KubeService_Subset) Reset 

func (x *TrafficTargetSpec_KubeService_Subset) Reset()

func (*TrafficTargetSpec_KubeService_Subset) String 

func (x *TrafficTargetSpec_KubeService_Subset) String() string

type TrafficTargetStatus 

type TrafficTargetStatus struct {

	// The most recent generation observed in the the TrafficPolicy metadata.
	// if the observedGeneration does not match generation, the controller has not received 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 Traffic Policies that have been applied to this TrafficTarget
	AppliedTrafficPolicies []*TrafficTargetStatus_AppliedTrafficPolicy `` /* 129-byte string literal not displayed */
	// The set of Access Policies that have been applied to this TrafficTarget
	AppliedAccessPolicies []*TrafficTargetStatus_AppliedAccessPolicy `` /* 126-byte string literal not displayed */
	// The local fully qualified domain
	LocalFqdn string `protobuf:"bytes,5,opt,name=local_fqdn,json=localFqdn,proto3" json:"local_fqdn,omitempty"`
	// Federation metadata. Only populated if this traffic target is federated through a VirtualMesh.
	AppliedFederation *TrafficTargetStatus_AppliedFederation `protobuf:"bytes,6,opt,name=applied_federation,json=appliedFederation,proto3" json:"applied_federation,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficTargetStatus) DeepCopyInto 

func (in *TrafficTargetStatus) DeepCopyInto(out *TrafficTargetStatus)

DeepCopyInto for the TrafficTarget.Status

func (*TrafficTargetStatus) Descriptor deprecated 

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

Deprecated: Use TrafficTargetStatus.ProtoReflect.Descriptor instead.

func (*TrafficTargetStatus) Equal 

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

Equal function

func (*TrafficTargetStatus) GetAppliedAccessPolicies 

func (x *TrafficTargetStatus) GetAppliedAccessPolicies() []*TrafficTargetStatus_AppliedAccessPolicy

func (*TrafficTargetStatus) GetAppliedFederation added in v0.12.0 

func (x *TrafficTargetStatus) GetAppliedFederation() *TrafficTargetStatus_AppliedFederation

func (*TrafficTargetStatus) GetAppliedTrafficPolicies 

func (x *TrafficTargetStatus) GetAppliedTrafficPolicies() []*TrafficTargetStatus_AppliedTrafficPolicy

func (*TrafficTargetStatus) GetLocalFqdn 

func (x *TrafficTargetStatus) GetLocalFqdn() string

func (*TrafficTargetStatus) GetObservedGeneration 

func (x *TrafficTargetStatus) GetObservedGeneration() int64

func (*TrafficTargetStatus) MarshalJSON 

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

MarshalJSON is a custom marshaler for TrafficTargetStatus

func (*TrafficTargetStatus) ProtoMessage 

func (*TrafficTargetStatus) ProtoMessage()

func (*TrafficTargetStatus) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetStatus) Reset 

func (x *TrafficTargetStatus) Reset()

func (*TrafficTargetStatus) String 

func (x *TrafficTargetStatus) String() string

func (*TrafficTargetStatus) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for TrafficTargetStatus

type TrafficTargetStatusWriter 

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

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

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

type TrafficTargetStatus_AppliedAccessPolicy 

type TrafficTargetStatus_AppliedAccessPolicy struct {

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

AppliedAccessPolicy represents a access policy that has been applied to the TrafficTarget. if an existing Access Policy becomes invalid, the last applied policy will be used

func (*TrafficTargetStatus_AppliedAccessPolicy) Descriptor deprecated 

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

Deprecated: Use TrafficTargetStatus_AppliedAccessPolicy.ProtoReflect.Descriptor instead.

func (*TrafficTargetStatus_AppliedAccessPolicy) Equal 

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

Equal function

func (*TrafficTargetStatus_AppliedAccessPolicy) GetObservedGeneration 

func (x *TrafficTargetStatus_AppliedAccessPolicy) GetObservedGeneration() int64

func (*TrafficTargetStatus_AppliedAccessPolicy) GetRef 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) GetSpec 

func (x *TrafficTargetStatus_AppliedAccessPolicy) GetSpec() *v1alpha2.AccessPolicySpec

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoMessage 

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoMessage()

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) Reset 

func (x *TrafficTargetStatus_AppliedAccessPolicy) Reset()

func (*TrafficTargetStatus_AppliedAccessPolicy) String 

func (x *TrafficTargetStatus_AppliedAccessPolicy) String() string

type TrafficTargetStatus_AppliedFederation 

type TrafficTargetStatus_AppliedFederation struct {

	//*
	//For any workload that this traffic target has federated to (i.e., any Workload controlled by a mesh whose ref appears in `federated_to_meshes`),
	//a client in that workload will be able to reach this traffic target at this DNS name. This includes workloads on clusters other than
	//the one hosting this service.
	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 service's `multicluster_dns_name`.
	FederatedToMeshes []*v1.ObjectRef `protobuf:"bytes,2,rep,name=federated_to_meshes,json=federatedToMeshes,proto3" json:"federated_to_meshes,omitempty"`
	// contains filtered or unexported fields
}

Federation policy applied to this TrafficTarget, allowing access to the traffic target from other meshes/clusters.

func (*TrafficTargetStatus_AppliedFederation) Descriptor deprecated 

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

Deprecated: Use TrafficTargetStatus_AppliedFederation.ProtoReflect.Descriptor instead.

func (*TrafficTargetStatus_AppliedFederation) Equal 

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

Equal function

func (*TrafficTargetStatus_AppliedFederation) GetFederatedHostname added in v0.12.0 

func (x *TrafficTargetStatus_AppliedFederation) GetFederatedHostname() string

func (*TrafficTargetStatus_AppliedFederation) GetFederatedToMeshes 

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

func (*TrafficTargetStatus_AppliedFederation) ProtoMessage 

func (*TrafficTargetStatus_AppliedFederation) ProtoMessage()

func (*TrafficTargetStatus_AppliedFederation) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetStatus_AppliedFederation) Reset 

func (x *TrafficTargetStatus_AppliedFederation) Reset()

func (*TrafficTargetStatus_AppliedFederation) String 

func (x *TrafficTargetStatus_AppliedFederation) String() string

type TrafficTargetStatus_AppliedTrafficPolicy 

type TrafficTargetStatus_AppliedTrafficPolicy struct {

	// reference to the traffic policy
	Ref *v1.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// the observed generation of the accepted traffic policy
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// the last known valid spec of the traffic policy
	Spec *v1alpha2.TrafficPolicySpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

AppliedTrafficPolicy represents a traffic policy that has been applied to the TrafficTarget. if an existing Traffic Policy becomes invalid, the last applied policy will be used

func (*TrafficTargetStatus_AppliedTrafficPolicy) Descriptor deprecated 

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

Deprecated: Use TrafficTargetStatus_AppliedTrafficPolicy.ProtoReflect.Descriptor instead.

func (*TrafficTargetStatus_AppliedTrafficPolicy) Equal 

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

Equal function

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetObservedGeneration 

func (x *TrafficTargetStatus_AppliedTrafficPolicy) GetObservedGeneration() int64

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetRef 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetSpec 

func (x *TrafficTargetStatus_AppliedTrafficPolicy) GetSpec() *v1alpha2.TrafficPolicySpec

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoMessage 

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoMessage()

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoReflect added in v0.10.8 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) Reset 

func (x *TrafficTargetStatus_AppliedTrafficPolicy) Reset()

func (*TrafficTargetStatus_AppliedTrafficPolicy) String 

func (x *TrafficTargetStatus_AppliedTrafficPolicy) String() string

type TrafficTargetTransitionFunction 

type TrafficTargetTransitionFunction func(existing, desired *TrafficTarget) error

TrafficTargetTransitionFunction instructs the TrafficTargetWriter how to transition between an existing TrafficTarget object and a desired on an Upsert

type TrafficTargetWriter 

type TrafficTargetWriter interface {
	// Create saves the TrafficTarget object.
	CreateTrafficTarget(ctx context.Context, obj *TrafficTarget, opts ...client.CreateOption) error

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

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

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

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

	// Create or Update the TrafficTarget object.
	UpsertTrafficTarget(ctx context.Context, obj *TrafficTarget, transitionFuncs ...TrafficTargetTransitionFunction) error
}

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

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

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 {

	// Specifies the underlying type of workload that this Workload is abstracting.
	//
	// Types that are assignable to WorkloadType:
	//	*WorkloadSpec_Kubernetes
	WorkloadType isWorkloadSpec_WorkloadType `protobuf_oneof:"workload_type"`
	// The mesh with which this workload is associated.
	Mesh *v1.ObjectRef `protobuf:"bytes,4,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// Appmesh specific metadata.
	AppMesh *WorkloadSpec_AppMesh `protobuf:"bytes,5,opt,name=app_mesh,json=appMesh,proto3" json:"app_mesh,omitempty"`
	// contains filtered or unexported fields
}

* The Workload is an abstraction for a workload/client which mesh-discovery has discovered to be part of a given mesh (i.e. its traffic is managed by an in-mesh sidecar).

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) GetWorkloadType 

func (m *WorkloadSpec) GetWorkloadType() isWorkloadSpec_WorkloadType

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

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 Appmesh envoy proxy container.
	VirtualNodeName string `protobuf:"bytes,1,opt,name=virtual_node_name,json=virtualNodeName,proto3" json:"virtual_node_name,omitempty"`
	// Needed for declaring Appmesh VirtualNode listeners.
	Ports []*WorkloadSpec_AppMesh_ContainerPort `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

Information relevant to AppMesh-injected workloads.

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

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
}

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

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 ref to the underlying kubernetes controller which is managing the pods associated with the workloads.
	//It has the generic name controller as it can represent a deployment, daemonset, or statefulset.
	Controller *v1.ClusterObjectRef `protobuf:"bytes,1,opt,name=controller,proto3" json:"controller,omitempty"`
	//*
	//These are the labels directly from the pods that this controller owns.
	//NB: these labels are read directly from the pod template metadata.labels
	//defined in the workload spec.
	//We need these to determine which services are backed by this workload.
	PodLabels map[string]string `` /* 176-byte string literal not displayed */
	// Service account attached to 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
}

Information describing a Kubernetes-based 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 added in v0.10.8 

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 mesh-networking
	// has reconciled 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 */
	// 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 added in v0.12.3 

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

func (*WorkloadStatus) GetAppliedWasmDeployments added in v0.12.3 

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

func (*WorkloadStatus) GetObservedGeneration 

func (x *WorkloadStatus) GetObservedGeneration() int64

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

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

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 referenced AccessLogRecord object
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

AppliedAccessLogRecord represents an AccessLogRecord that has been applied to this Workload.

func (*WorkloadStatus_AppliedAccessLogRecord) Descriptor deprecated added in v0.12.3 

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

Deprecated: Use WorkloadStatus_AppliedAccessLogRecord.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_AppliedAccessLogRecord) Equal added in v0.12.3 

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

Equal function

func (*WorkloadStatus_AppliedAccessLogRecord) GetErrors added in v0.12.3 

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

func (*WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration added in v0.12.3 

func (x *WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedAccessLogRecord) GetRef added in v0.12.3 

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

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage added in v0.12.3 

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage()

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoReflect added in v0.12.3 

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

func (*WorkloadStatus_AppliedAccessLogRecord) Reset added in v0.12.3 

func (x *WorkloadStatus_AppliedAccessLogRecord) Reset()

func (*WorkloadStatus_AppliedAccessLogRecord) String added in v0.12.3 

func (x *WorkloadStatus_AppliedAccessLogRecord) String() string

type WorkloadStatus_AppliedWasmDeployment added in v0.12.3 

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 accepted WasmDeployment.
	ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// any errors encountered while processing the referenced WasmDeployment object
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatus_AppliedWasmDeployment) Descriptor deprecated added in v0.12.3 

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

Deprecated: Use WorkloadStatus_AppliedWasmDeployment.ProtoReflect.Descriptor instead.

func (*WorkloadStatus_AppliedWasmDeployment) Equal added in v0.12.3 

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

Equal function

func (*WorkloadStatus_AppliedWasmDeployment) GetErrors added in v0.12.3 

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

func (*WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration added in v0.12.3 

func (x *WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedWasmDeployment) GetRef added in v0.12.3 

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

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage added in v0.12.3 

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage()

func (*WorkloadStatus_AppliedWasmDeployment) ProtoReflect added in v0.12.3 

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

func (*WorkloadStatus_AppliedWasmDeployment) Reset added in v0.12.3 

func (x *WorkloadStatus_AppliedWasmDeployment) Reset()

func (*WorkloadStatus_AppliedWasmDeployment) String added in v0.12.3 

func (x *WorkloadStatus_AppliedWasmDeployment) 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_v1alpha2 is a generated GoMock package.
 Package mock_v1alpha2 is a generated GoMock package.
mocks
Package mock_v1alpha2sets is a generated GoMock package.
 Package mock_v1alpha2sets 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.