v1alpha2

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2020 License: Apache-2.0 Imports: 19 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}
)

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Meshes represent a currently registered service mesh.

func (*MeshSpec) DeepCopyInto 

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

DeepCopyInto for the Mesh.Spec

func (*MeshSpec) Descriptor 

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

func (*MeshSpec) Equal 

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

func (*MeshSpec) GetAgentInfo 

func (m *MeshSpec) GetAgentInfo() *MeshSpec_AgentInfo

func (*MeshSpec) GetAwsAppMesh 

func (m *MeshSpec) GetAwsAppMesh() *MeshSpec_AwsAppMesh

func (*MeshSpec) GetConsulConnect 

func (m *MeshSpec) GetConsulConnect() *MeshSpec_ConsulConnectMesh

func (*MeshSpec) GetIstio 

func (m *MeshSpec) GetIstio() *MeshSpec_Istio

func (*MeshSpec) GetLinkerd 

func (m *MeshSpec) GetLinkerd() *MeshSpec_LinkerdMesh

func (*MeshSpec) GetMeshType 

func (m *MeshSpec) GetMeshType() isMeshSpec_MeshType

func (*MeshSpec) GetOsm 

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

func (m *MeshSpec) Reset()

func (*MeshSpec) String 

func (m *MeshSpec) String() string

func (*MeshSpec) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for MeshSpec

func (*MeshSpec) XXX_DiscardUnknown 

func (m *MeshSpec) XXX_DiscardUnknown()

func (*MeshSpec) XXX_Marshal 

func (m *MeshSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec) XXX_Merge 

func (m *MeshSpec) XXX_Merge(src proto.Message)

func (*MeshSpec) XXX_OneofWrappers 

func (*MeshSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MeshSpec) XXX_Size 

func (m *MeshSpec) XXX_Size() int

func (*MeshSpec) XXX_Unmarshal 

func (m *MeshSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*MeshSpec_AgentInfo) Equal 

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

func (*MeshSpec_AgentInfo) GetAgentNamespace 

func (m *MeshSpec_AgentInfo) GetAgentNamespace() string

func (*MeshSpec_AgentInfo) ProtoMessage 

func (*MeshSpec_AgentInfo) ProtoMessage()

func (*MeshSpec_AgentInfo) Reset 

func (m *MeshSpec_AgentInfo) Reset()

func (*MeshSpec_AgentInfo) String 

func (m *MeshSpec_AgentInfo) String() string

func (*MeshSpec_AgentInfo) XXX_DiscardUnknown 

func (m *MeshSpec_AgentInfo) XXX_DiscardUnknown()

func (*MeshSpec_AgentInfo) XXX_Marshal 

func (m *MeshSpec_AgentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_AgentInfo) XXX_Merge 

func (m *MeshSpec_AgentInfo) XXX_Merge(src proto.Message)

func (*MeshSpec_AgentInfo) XXX_Size 

func (m *MeshSpec_AgentInfo) XXX_Size() int

func (*MeshSpec_AgentInfo) XXX_Unmarshal 

func (m *MeshSpec_AgentInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Mesh object representing AWS AppMesh.

func (*MeshSpec_AwsAppMesh) Descriptor 

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

func (*MeshSpec_AwsAppMesh) Equal 

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

func (*MeshSpec_AwsAppMesh) GetArn 

func (m *MeshSpec_AwsAppMesh) GetArn() string

func (*MeshSpec_AwsAppMesh) GetAwsAccountId 

func (m *MeshSpec_AwsAppMesh) GetAwsAccountId() string

func (*MeshSpec_AwsAppMesh) GetAwsName 

func (m *MeshSpec_AwsAppMesh) GetAwsName() string

func (*MeshSpec_AwsAppMesh) GetClusters 

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

func (*MeshSpec_AwsAppMesh) GetRegion 

func (m *MeshSpec_AwsAppMesh) GetRegion() string

func (*MeshSpec_AwsAppMesh) ProtoMessage 

func (*MeshSpec_AwsAppMesh) ProtoMessage()

func (*MeshSpec_AwsAppMesh) Reset 

func (m *MeshSpec_AwsAppMesh) Reset()

func (*MeshSpec_AwsAppMesh) String 

func (m *MeshSpec_AwsAppMesh) String() string

func (*MeshSpec_AwsAppMesh) XXX_DiscardUnknown 

func (m *MeshSpec_AwsAppMesh) XXX_DiscardUnknown()

func (*MeshSpec_AwsAppMesh) XXX_Marshal 

func (m *MeshSpec_AwsAppMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_AwsAppMesh) XXX_Merge 

func (m *MeshSpec_AwsAppMesh) XXX_Merge(src proto.Message)

func (*MeshSpec_AwsAppMesh) XXX_Size 

func (m *MeshSpec_AwsAppMesh) XXX_Size() int

func (*MeshSpec_AwsAppMesh) XXX_Unmarshal 

func (m *MeshSpec_AwsAppMesh) XXX_Unmarshal(b []byte) error

type MeshSpec_AwsAppMesh_ 

type MeshSpec_AwsAppMesh_ struct {
	AwsAppMesh *MeshSpec_AwsAppMesh `protobuf:"bytes,2,opt,name=aws_app_mesh,json=awsAppMesh,proto3,oneof" json:"aws_app_mesh,omitempty"`
}

func (*MeshSpec_AwsAppMesh_) Equal 

func (this *MeshSpec_AwsAppMesh_) Equal(that interface{}) bool

type MeshSpec_ConsulConnect 

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

func (*MeshSpec_ConsulConnect) Equal 

func (this *MeshSpec_ConsulConnect) Equal(that interface{}) bool

type MeshSpec_ConsulConnectMesh 

type MeshSpec_ConsulConnectMesh struct {
	Installation         *MeshSpec_MeshInstallation `protobuf:"bytes,1,opt,name=installation,proto3" json:"installation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Mesh object representing an installed ConsulConnect control plane.

func (*MeshSpec_ConsulConnectMesh) Descriptor 

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

func (*MeshSpec_ConsulConnectMesh) Equal 

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

func (*MeshSpec_ConsulConnectMesh) GetInstallation 

func (m *MeshSpec_ConsulConnectMesh) GetInstallation() *MeshSpec_MeshInstallation

func (*MeshSpec_ConsulConnectMesh) ProtoMessage 

func (*MeshSpec_ConsulConnectMesh) ProtoMessage()

func (*MeshSpec_ConsulConnectMesh) Reset 

func (m *MeshSpec_ConsulConnectMesh) Reset()

func (*MeshSpec_ConsulConnectMesh) String 

func (m *MeshSpec_ConsulConnectMesh) String() string

func (*MeshSpec_ConsulConnectMesh) XXX_DiscardUnknown 

func (m *MeshSpec_ConsulConnectMesh) XXX_DiscardUnknown()

func (*MeshSpec_ConsulConnectMesh) XXX_Marshal 

func (m *MeshSpec_ConsulConnectMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_ConsulConnectMesh) XXX_Merge 

func (m *MeshSpec_ConsulConnectMesh) XXX_Merge(src proto.Message)

func (*MeshSpec_ConsulConnectMesh) XXX_Size 

func (m *MeshSpec_ConsulConnectMesh) XXX_Size() int

func (*MeshSpec_ConsulConnectMesh) XXX_Unmarshal 

func (m *MeshSpec_ConsulConnectMesh) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

Mesh object representing an installed Istio control plane

func (*MeshSpec_Istio) Descriptor 

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

func (*MeshSpec_Istio) Equal 

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

func (*MeshSpec_Istio) GetCitadelInfo 

func (m *MeshSpec_Istio) GetCitadelInfo() *MeshSpec_Istio_CitadelInfo

func (*MeshSpec_Istio) GetIngressGateways 

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

func (*MeshSpec_Istio) GetInstallation 

func (m *MeshSpec_Istio) GetInstallation() *MeshSpec_MeshInstallation

func (*MeshSpec_Istio) ProtoMessage 

func (*MeshSpec_Istio) ProtoMessage()

func (*MeshSpec_Istio) Reset 

func (m *MeshSpec_Istio) Reset()

func (*MeshSpec_Istio) String 

func (m *MeshSpec_Istio) String() string

func (*MeshSpec_Istio) XXX_DiscardUnknown 

func (m *MeshSpec_Istio) XXX_DiscardUnknown()

func (*MeshSpec_Istio) XXX_Marshal 

func (m *MeshSpec_Istio) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_Istio) XXX_Merge 

func (m *MeshSpec_Istio) XXX_Merge(src proto.Message)

func (*MeshSpec_Istio) XXX_Size 

func (m *MeshSpec_Istio) XXX_Size() int

func (*MeshSpec_Istio) XXX_Unmarshal 

func (m *MeshSpec_Istio) XXX_Unmarshal(b []byte) error

type MeshSpec_Istio_ 

type MeshSpec_Istio_ struct {
	Istio *MeshSpec_Istio `protobuf:"bytes,1,opt,name=istio,proto3,oneof" json:"istio,omitempty"`
}

func (*MeshSpec_Istio_) Equal 

func (this *MeshSpec_Istio_) Equal(that interface{}) bool

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 */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

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

func (*MeshSpec_Istio_CitadelInfo) Descriptor 

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

func (*MeshSpec_Istio_CitadelInfo) Equal 

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

func (*MeshSpec_Istio_CitadelInfo) GetCitadelServiceAccount 

func (m *MeshSpec_Istio_CitadelInfo) GetCitadelServiceAccount() string

func (*MeshSpec_Istio_CitadelInfo) GetTrustDomain 

func (m *MeshSpec_Istio_CitadelInfo) GetTrustDomain() string

func (*MeshSpec_Istio_CitadelInfo) ProtoMessage 

func (*MeshSpec_Istio_CitadelInfo) ProtoMessage()

func (*MeshSpec_Istio_CitadelInfo) Reset 

func (m *MeshSpec_Istio_CitadelInfo) Reset()

func (*MeshSpec_Istio_CitadelInfo) String 

func (m *MeshSpec_Istio_CitadelInfo) String() string

func (*MeshSpec_Istio_CitadelInfo) XXX_DiscardUnknown 

func (m *MeshSpec_Istio_CitadelInfo) XXX_DiscardUnknown()

func (*MeshSpec_Istio_CitadelInfo) XXX_Marshal 

func (m *MeshSpec_Istio_CitadelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_Istio_CitadelInfo) XXX_Merge 

func (m *MeshSpec_Istio_CitadelInfo) XXX_Merge(src proto.Message)

func (*MeshSpec_Istio_CitadelInfo) XXX_Size 

func (m *MeshSpec_Istio_CitadelInfo) XXX_Size() int

func (*MeshSpec_Istio_CitadelInfo) XXX_Unmarshal 

func (m *MeshSpec_Istio_CitadelInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeshSpec_Istio_IngressGatewayInfo) Descriptor 

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

func (*MeshSpec_Istio_IngressGatewayInfo) Equal 

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

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalAddress 

func (m *MeshSpec_Istio_IngressGatewayInfo) GetExternalAddress() string

func (*MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort 

func (m *MeshSpec_Istio_IngressGatewayInfo) GetExternalTlsPort() uint32

func (*MeshSpec_Istio_IngressGatewayInfo) GetTlsContainerPort 

func (m *MeshSpec_Istio_IngressGatewayInfo) GetTlsContainerPort() uint32

func (*MeshSpec_Istio_IngressGatewayInfo) GetWorkloadLabels 

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

func (*MeshSpec_Istio_IngressGatewayInfo) ProtoMessage 

func (*MeshSpec_Istio_IngressGatewayInfo) ProtoMessage()

func (*MeshSpec_Istio_IngressGatewayInfo) Reset 

func (m *MeshSpec_Istio_IngressGatewayInfo) Reset()

func (*MeshSpec_Istio_IngressGatewayInfo) String 

func (m *MeshSpec_Istio_IngressGatewayInfo) String() string

func (*MeshSpec_Istio_IngressGatewayInfo) XXX_DiscardUnknown 

func (m *MeshSpec_Istio_IngressGatewayInfo) XXX_DiscardUnknown()

func (*MeshSpec_Istio_IngressGatewayInfo) XXX_Marshal 

func (m *MeshSpec_Istio_IngressGatewayInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_Istio_IngressGatewayInfo) XXX_Merge 

func (m *MeshSpec_Istio_IngressGatewayInfo) XXX_Merge(src proto.Message)

func (*MeshSpec_Istio_IngressGatewayInfo) XXX_Size 

func (m *MeshSpec_Istio_IngressGatewayInfo) XXX_Size() int

func (*MeshSpec_Istio_IngressGatewayInfo) XXX_Unmarshal 

func (m *MeshSpec_Istio_IngressGatewayInfo) XXX_Unmarshal(b []byte) error

type MeshSpec_Linkerd 

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

func (*MeshSpec_Linkerd) Equal 

func (this *MeshSpec_Linkerd) Equal(that interface{}) bool

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Mesh object representing an installed Linkerd control plane.

func (*MeshSpec_LinkerdMesh) Descriptor 

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

func (*MeshSpec_LinkerdMesh) Equal 

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

func (*MeshSpec_LinkerdMesh) GetClusterDomain 

func (m *MeshSpec_LinkerdMesh) GetClusterDomain() string

func (*MeshSpec_LinkerdMesh) GetInstallation 

func (m *MeshSpec_LinkerdMesh) GetInstallation() *MeshSpec_MeshInstallation

func (*MeshSpec_LinkerdMesh) ProtoMessage 

func (*MeshSpec_LinkerdMesh) ProtoMessage()

func (*MeshSpec_LinkerdMesh) Reset 

func (m *MeshSpec_LinkerdMesh) Reset()

func (*MeshSpec_LinkerdMesh) String 

func (m *MeshSpec_LinkerdMesh) String() string

func (*MeshSpec_LinkerdMesh) XXX_DiscardUnknown 

func (m *MeshSpec_LinkerdMesh) XXX_DiscardUnknown()

func (*MeshSpec_LinkerdMesh) XXX_Marshal 

func (m *MeshSpec_LinkerdMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_LinkerdMesh) XXX_Merge 

func (m *MeshSpec_LinkerdMesh) XXX_Merge(src proto.Message)

func (*MeshSpec_LinkerdMesh) XXX_Size 

func (m *MeshSpec_LinkerdMesh) XXX_Size() int

func (*MeshSpec_LinkerdMesh) XXX_Unmarshal 

func (m *MeshSpec_LinkerdMesh) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*MeshSpec_MeshInstallation) Equal 

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

func (*MeshSpec_MeshInstallation) GetCluster 

func (m *MeshSpec_MeshInstallation) GetCluster() string

func (*MeshSpec_MeshInstallation) GetNamespace 

func (m *MeshSpec_MeshInstallation) GetNamespace() string

func (*MeshSpec_MeshInstallation) GetPodLabels 

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

func (*MeshSpec_MeshInstallation) GetVersion 

func (m *MeshSpec_MeshInstallation) GetVersion() string

func (*MeshSpec_MeshInstallation) ProtoMessage 

func (*MeshSpec_MeshInstallation) ProtoMessage()

func (*MeshSpec_MeshInstallation) Reset 

func (m *MeshSpec_MeshInstallation) Reset()

func (*MeshSpec_MeshInstallation) String 

func (m *MeshSpec_MeshInstallation) String() string

func (*MeshSpec_MeshInstallation) XXX_DiscardUnknown 

func (m *MeshSpec_MeshInstallation) XXX_DiscardUnknown()

func (*MeshSpec_MeshInstallation) XXX_Marshal 

func (m *MeshSpec_MeshInstallation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_MeshInstallation) XXX_Merge 

func (m *MeshSpec_MeshInstallation) XXX_Merge(src proto.Message)

func (*MeshSpec_MeshInstallation) XXX_Size 

func (m *MeshSpec_MeshInstallation) XXX_Size() int

func (*MeshSpec_MeshInstallation) XXX_Unmarshal 

func (m *MeshSpec_MeshInstallation) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

https://github.com/openservicemesh/osm

func (*MeshSpec_OSM) Descriptor 

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

func (*MeshSpec_OSM) Equal 

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

func (*MeshSpec_OSM) GetInstallation 

func (m *MeshSpec_OSM) GetInstallation() *MeshSpec_MeshInstallation

func (*MeshSpec_OSM) ProtoMessage 

func (*MeshSpec_OSM) ProtoMessage()

func (*MeshSpec_OSM) Reset 

func (m *MeshSpec_OSM) Reset()

func (*MeshSpec_OSM) String 

func (m *MeshSpec_OSM) String() string

func (*MeshSpec_OSM) XXX_DiscardUnknown 

func (m *MeshSpec_OSM) XXX_DiscardUnknown()

func (*MeshSpec_OSM) XXX_Marshal 

func (m *MeshSpec_OSM) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshSpec_OSM) XXX_Merge 

func (m *MeshSpec_OSM) XXX_Merge(src proto.Message)

func (*MeshSpec_OSM) XXX_Size 

func (m *MeshSpec_OSM) XXX_Size() int

func (*MeshSpec_OSM) XXX_Unmarshal 

func (m *MeshSpec_OSM) XXX_Unmarshal(b []byte) error

type MeshSpec_Osm 

type MeshSpec_Osm struct {
	Osm *MeshSpec_OSM `protobuf:"bytes,6,opt,name=osm,proto3,oneof" json:"osm,omitempty"`
}

func (*MeshSpec_Osm) Equal 

func (this *MeshSpec_Osm) Equal(that interface{}) bool

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 */
	XXX_NoUnkeyedLiteral    struct{}                             `json:"-"`
	XXX_unrecognized        []byte                               `json:"-"`
	XXX_sizecache           int32                                `json:"-"`
}

func (*MeshStatus) DeepCopyInto 

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

DeepCopyInto for the Mesh.Status

func (*MeshStatus) Descriptor 

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

func (*MeshStatus) Equal 

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

func (*MeshStatus) GetAppliedFailoverServices 

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

func (*MeshStatus) GetAppliedVirtualMesh 

func (m *MeshStatus) GetAppliedVirtualMesh() *MeshStatus_AppliedVirtualMesh

func (*MeshStatus) GetObservedGeneration 

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

func (m *MeshStatus) Reset()

func (*MeshStatus) String 

func (m *MeshStatus) String() string

func (*MeshStatus) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for MeshStatus

func (*MeshStatus) XXX_DiscardUnknown 

func (m *MeshStatus) XXX_DiscardUnknown()

func (*MeshStatus) XXX_Marshal 

func (m *MeshStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshStatus) XXX_Merge 

func (m *MeshStatus) XXX_Merge(src proto.Message)

func (*MeshStatus) XXX_Size 

func (m *MeshStatus) XXX_Size() int

func (*MeshStatus) XXX_Unmarshal 

func (m *MeshStatus) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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 

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

func (*MeshStatus_AppliedFailoverService) Equal 

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

func (*MeshStatus_AppliedFailoverService) GetObservedGeneration 

func (m *MeshStatus_AppliedFailoverService) GetObservedGeneration() int64

func (*MeshStatus_AppliedFailoverService) GetRef 

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

func (*MeshStatus_AppliedFailoverService) GetSpec 

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

func (*MeshStatus_AppliedFailoverService) ProtoMessage 

func (*MeshStatus_AppliedFailoverService) ProtoMessage()

func (*MeshStatus_AppliedFailoverService) Reset 

func (m *MeshStatus_AppliedFailoverService) Reset()

func (*MeshStatus_AppliedFailoverService) String 

func (m *MeshStatus_AppliedFailoverService) String() string

func (*MeshStatus_AppliedFailoverService) XXX_DiscardUnknown 

func (m *MeshStatus_AppliedFailoverService) XXX_DiscardUnknown()

func (*MeshStatus_AppliedFailoverService) XXX_Marshal 

func (m *MeshStatus_AppliedFailoverService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshStatus_AppliedFailoverService) XXX_Merge 

func (m *MeshStatus_AppliedFailoverService) XXX_Merge(src proto.Message)

func (*MeshStatus_AppliedFailoverService) XXX_Size 

func (m *MeshStatus_AppliedFailoverService) XXX_Size() int

func (*MeshStatus_AppliedFailoverService) XXX_Unmarshal 

func (m *MeshStatus_AppliedFailoverService) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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 

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

func (*MeshStatus_AppliedVirtualMesh) Equal 

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

func (*MeshStatus_AppliedVirtualMesh) GetObservedGeneration 

func (m *MeshStatus_AppliedVirtualMesh) GetObservedGeneration() int64

func (*MeshStatus_AppliedVirtualMesh) GetRef 

func (m *MeshStatus_AppliedVirtualMesh) GetRef() *v1.ObjectRef

func (*MeshStatus_AppliedVirtualMesh) GetSpec 

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

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage 

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage()

func (*MeshStatus_AppliedVirtualMesh) Reset 

func (m *MeshStatus_AppliedVirtualMesh) Reset()

func (*MeshStatus_AppliedVirtualMesh) String 

func (m *MeshStatus_AppliedVirtualMesh) String() string

func (*MeshStatus_AppliedVirtualMesh) XXX_DiscardUnknown 

func (m *MeshStatus_AppliedVirtualMesh) XXX_DiscardUnknown()

func (*MeshStatus_AppliedVirtualMesh) XXX_Marshal 

func (m *MeshStatus_AppliedVirtualMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshStatus_AppliedVirtualMesh) XXX_Merge 

func (m *MeshStatus_AppliedVirtualMesh) XXX_Merge(src proto.Message)

func (*MeshStatus_AppliedVirtualMesh) XXX_Size 

func (m *MeshStatus_AppliedVirtualMesh) XXX_Size() int

func (*MeshStatus_AppliedVirtualMesh) XXX_Unmarshal 

func (m *MeshStatus_AppliedVirtualMesh) XXX_Unmarshal(b []byte) error

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

* 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 

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

func (*TrafficTargetSpec) Equal 

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

func (*TrafficTargetSpec) GetKubeService 

func (m *TrafficTargetSpec) GetKubeService() *TrafficTargetSpec_KubeService

func (*TrafficTargetSpec) GetMesh 

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

func (m *TrafficTargetSpec) Reset()

func (*TrafficTargetSpec) String 

func (m *TrafficTargetSpec) String() string

func (*TrafficTargetSpec) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for TrafficTargetSpec

func (*TrafficTargetSpec) XXX_DiscardUnknown 

func (m *TrafficTargetSpec) XXX_DiscardUnknown()

func (*TrafficTargetSpec) XXX_Marshal 

func (m *TrafficTargetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetSpec) XXX_Merge 

func (m *TrafficTargetSpec) XXX_Merge(src proto.Message)

func (*TrafficTargetSpec) XXX_OneofWrappers 

func (*TrafficTargetSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TrafficTargetSpec) XXX_Size 

func (m *TrafficTargetSpec) XXX_Size() int

func (*TrafficTargetSpec) XXX_Unmarshal 

func (m *TrafficTargetSpec) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*TrafficTargetSpec_KubeService) Descriptor 

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

func (*TrafficTargetSpec_KubeService) Equal 

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

func (*TrafficTargetSpec_KubeService) GetLabels 

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

func (*TrafficTargetSpec_KubeService) GetPorts 

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

func (*TrafficTargetSpec_KubeService) GetRef 

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

func (*TrafficTargetSpec_KubeService) GetSubsets 

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

func (*TrafficTargetSpec_KubeService) GetWorkloadSelectorLabels 

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

func (*TrafficTargetSpec_KubeService) ProtoMessage 

func (*TrafficTargetSpec_KubeService) ProtoMessage()

func (*TrafficTargetSpec_KubeService) Reset 

func (m *TrafficTargetSpec_KubeService) Reset()

func (*TrafficTargetSpec_KubeService) String 

func (m *TrafficTargetSpec_KubeService) String() string

func (*TrafficTargetSpec_KubeService) XXX_DiscardUnknown 

func (m *TrafficTargetSpec_KubeService) XXX_DiscardUnknown()

func (*TrafficTargetSpec_KubeService) XXX_Marshal 

func (m *TrafficTargetSpec_KubeService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetSpec_KubeService) XXX_Merge 

func (m *TrafficTargetSpec_KubeService) XXX_Merge(src proto.Message)

func (*TrafficTargetSpec_KubeService) XXX_Size 

func (m *TrafficTargetSpec_KubeService) XXX_Size() int

func (*TrafficTargetSpec_KubeService) XXX_Unmarshal 

func (m *TrafficTargetSpec_KubeService) XXX_Unmarshal(b []byte) error

type TrafficTargetSpec_KubeService_ 

type TrafficTargetSpec_KubeService_ struct {
	KubeService *TrafficTargetSpec_KubeService `protobuf:"bytes,1,opt,name=kube_service,json=kubeService,proto3,oneof" json:"kube_service,omitempty"`
}

func (*TrafficTargetSpec_KubeService_) Equal 

func (this *TrafficTargetSpec_KubeService_) Equal(that interface{}) bool

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TrafficTargetSpec_KubeService_KubeServicePort) Descriptor 

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

func (*TrafficTargetSpec_KubeService_KubeServicePort) Equal 

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

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetAppProtocol 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) GetAppProtocol() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetName 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) GetName() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetPort 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) GetPort() uint32

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetProtocol 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) GetProtocol() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoMessage 

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoMessage()

func (*TrafficTargetSpec_KubeService_KubeServicePort) Reset 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) Reset()

func (*TrafficTargetSpec_KubeService_KubeServicePort) String 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) String() string

func (*TrafficTargetSpec_KubeService_KubeServicePort) XXX_DiscardUnknown 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) XXX_DiscardUnknown()

func (*TrafficTargetSpec_KubeService_KubeServicePort) XXX_Marshal 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetSpec_KubeService_KubeServicePort) XXX_Merge 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) XXX_Merge(src proto.Message)

func (*TrafficTargetSpec_KubeService_KubeServicePort) XXX_Size 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) XXX_Size() int

func (*TrafficTargetSpec_KubeService_KubeServicePort) XXX_Unmarshal 

func (m *TrafficTargetSpec_KubeService_KubeServicePort) XXX_Unmarshal(b []byte) error

type TrafficTargetSpec_KubeService_Subset 

type TrafficTargetSpec_KubeService_Subset struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Subsets for routing, based on labels.

func (*TrafficTargetSpec_KubeService_Subset) Descriptor 

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

func (*TrafficTargetSpec_KubeService_Subset) Equal 

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

func (*TrafficTargetSpec_KubeService_Subset) GetValues 

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

func (*TrafficTargetSpec_KubeService_Subset) ProtoMessage 

func (*TrafficTargetSpec_KubeService_Subset) ProtoMessage()

func (*TrafficTargetSpec_KubeService_Subset) Reset 

func (m *TrafficTargetSpec_KubeService_Subset) Reset()

func (*TrafficTargetSpec_KubeService_Subset) String 

func (m *TrafficTargetSpec_KubeService_Subset) String() string

func (*TrafficTargetSpec_KubeService_Subset) XXX_DiscardUnknown 

func (m *TrafficTargetSpec_KubeService_Subset) XXX_DiscardUnknown()

func (*TrafficTargetSpec_KubeService_Subset) XXX_Marshal 

func (m *TrafficTargetSpec_KubeService_Subset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetSpec_KubeService_Subset) XXX_Merge 

func (m *TrafficTargetSpec_KubeService_Subset) XXX_Merge(src proto.Message)

func (*TrafficTargetSpec_KubeService_Subset) XXX_Size 

func (m *TrafficTargetSpec_KubeService_Subset) XXX_Size() int

func (*TrafficTargetSpec_KubeService_Subset) XXX_Unmarshal 

func (m *TrafficTargetSpec_KubeService_Subset) XXX_Unmarshal(b []byte) error

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"`
	// The remote fully qualified domain
	RemoteFqdn           string   `protobuf:"bytes,6,opt,name=remote_fqdn,json=remoteFqdn,proto3" json:"remote_fqdn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TrafficTargetStatus) DeepCopyInto 

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

DeepCopyInto for the TrafficTarget.Status

func (*TrafficTargetStatus) Descriptor 

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

func (*TrafficTargetStatus) Equal 

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

func (*TrafficTargetStatus) GetAppliedAccessPolicies 

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

func (*TrafficTargetStatus) GetAppliedTrafficPolicies 

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

func (*TrafficTargetStatus) GetLocalFqdn 

func (m *TrafficTargetStatus) GetLocalFqdn() string

func (*TrafficTargetStatus) GetObservedGeneration 

func (m *TrafficTargetStatus) GetObservedGeneration() int64

func (*TrafficTargetStatus) GetRemoteFqdn 

func (m *TrafficTargetStatus) GetRemoteFqdn() string

func (*TrafficTargetStatus) MarshalJSON 

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

MarshalJSON is a custom marshaler for TrafficTargetStatus

func (*TrafficTargetStatus) ProtoMessage 

func (*TrafficTargetStatus) ProtoMessage()

func (*TrafficTargetStatus) Reset 

func (m *TrafficTargetStatus) Reset()

func (*TrafficTargetStatus) String 

func (m *TrafficTargetStatus) String() string

func (*TrafficTargetStatus) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for TrafficTargetStatus

func (*TrafficTargetStatus) XXX_DiscardUnknown 

func (m *TrafficTargetStatus) XXX_DiscardUnknown()

func (*TrafficTargetStatus) XXX_Marshal 

func (m *TrafficTargetStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetStatus) XXX_Merge 

func (m *TrafficTargetStatus) XXX_Merge(src proto.Message)

func (*TrafficTargetStatus) XXX_Size 

func (m *TrafficTargetStatus) XXX_Size() int

func (*TrafficTargetStatus) XXX_Unmarshal 

func (m *TrafficTargetStatus) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) Equal 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) GetObservedGeneration 

func (m *TrafficTargetStatus_AppliedAccessPolicy) GetObservedGeneration() int64

func (*TrafficTargetStatus_AppliedAccessPolicy) GetRef 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) GetSpec 

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

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoMessage 

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoMessage()

func (*TrafficTargetStatus_AppliedAccessPolicy) Reset 

func (m *TrafficTargetStatus_AppliedAccessPolicy) Reset()

func (*TrafficTargetStatus_AppliedAccessPolicy) String 

func (m *TrafficTargetStatus_AppliedAccessPolicy) String() string

func (*TrafficTargetStatus_AppliedAccessPolicy) XXX_DiscardUnknown 

func (m *TrafficTargetStatus_AppliedAccessPolicy) XXX_DiscardUnknown()

func (*TrafficTargetStatus_AppliedAccessPolicy) XXX_Marshal 

func (m *TrafficTargetStatus_AppliedAccessPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetStatus_AppliedAccessPolicy) XXX_Merge 

func (m *TrafficTargetStatus_AppliedAccessPolicy) XXX_Merge(src proto.Message)

func (*TrafficTargetStatus_AppliedAccessPolicy) XXX_Size 

func (m *TrafficTargetStatus_AppliedAccessPolicy) XXX_Size() int

func (*TrafficTargetStatus_AppliedAccessPolicy) XXX_Unmarshal 

func (m *TrafficTargetStatus_AppliedAccessPolicy) XXX_Unmarshal(b []byte) error

type TrafficTargetStatus_AppliedFederation 

type TrafficTargetStatus_AppliedFederation struct {
	//*
	//For any workload that this traffic target has federated to (i.e., any Workload whose ref appears in `federated_to_workloads`),
	//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.
	MulticlusterDnsName string `protobuf:"bytes,1,opt,name=multicluster_dns_name,json=multiclusterDnsName,proto3" json:"multicluster_dns_name,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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*TrafficTargetStatus_AppliedFederation) Descriptor 

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

func (*TrafficTargetStatus_AppliedFederation) Equal 

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

func (*TrafficTargetStatus_AppliedFederation) GetFederatedToMeshes 

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

func (*TrafficTargetStatus_AppliedFederation) GetMulticlusterDnsName 

func (m *TrafficTargetStatus_AppliedFederation) GetMulticlusterDnsName() string

func (*TrafficTargetStatus_AppliedFederation) ProtoMessage 

func (*TrafficTargetStatus_AppliedFederation) ProtoMessage()

func (*TrafficTargetStatus_AppliedFederation) Reset 

func (m *TrafficTargetStatus_AppliedFederation) Reset()

func (*TrafficTargetStatus_AppliedFederation) String 

func (m *TrafficTargetStatus_AppliedFederation) String() string

func (*TrafficTargetStatus_AppliedFederation) XXX_DiscardUnknown 

func (m *TrafficTargetStatus_AppliedFederation) XXX_DiscardUnknown()

func (*TrafficTargetStatus_AppliedFederation) XXX_Marshal 

func (m *TrafficTargetStatus_AppliedFederation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetStatus_AppliedFederation) XXX_Merge 

func (m *TrafficTargetStatus_AppliedFederation) XXX_Merge(src proto.Message)

func (*TrafficTargetStatus_AppliedFederation) XXX_Size 

func (m *TrafficTargetStatus_AppliedFederation) XXX_Size() int

func (*TrafficTargetStatus_AppliedFederation) XXX_Unmarshal 

func (m *TrafficTargetStatus_AppliedFederation) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) Equal 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetObservedGeneration 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) GetObservedGeneration() int64

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetRef 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) GetSpec 

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

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoMessage 

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoMessage()

func (*TrafficTargetStatus_AppliedTrafficPolicy) Reset 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) Reset()

func (*TrafficTargetStatus_AppliedTrafficPolicy) String 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) String() string

func (*TrafficTargetStatus_AppliedTrafficPolicy) XXX_DiscardUnknown 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) XXX_DiscardUnknown()

func (*TrafficTargetStatus_AppliedTrafficPolicy) XXX_Marshal 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTargetStatus_AppliedTrafficPolicy) XXX_Merge 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) XXX_Merge(src proto.Message)

func (*TrafficTargetStatus_AppliedTrafficPolicy) XXX_Size 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) XXX_Size() int

func (*TrafficTargetStatus_AppliedTrafficPolicy) XXX_Unmarshal 

func (m *TrafficTargetStatus_AppliedTrafficPolicy) XXX_Unmarshal(b []byte) error

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

* 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 

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

func (*WorkloadSpec) Equal 

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

func (*WorkloadSpec) GetAppMesh 

func (m *WorkloadSpec) GetAppMesh() *WorkloadSpec_AppMesh

func (*WorkloadSpec) GetKubernetes 

func (m *WorkloadSpec) GetKubernetes() *WorkloadSpec_KubernetesWorkload

func (*WorkloadSpec) GetMesh 

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

func (m *WorkloadSpec) Reset()

func (*WorkloadSpec) String 

func (m *WorkloadSpec) String() string

func (*WorkloadSpec) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for WorkloadSpec

func (*WorkloadSpec) XXX_DiscardUnknown 

func (m *WorkloadSpec) XXX_DiscardUnknown()

func (*WorkloadSpec) XXX_Marshal 

func (m *WorkloadSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadSpec) XXX_Merge 

func (m *WorkloadSpec) XXX_Merge(src proto.Message)

func (*WorkloadSpec) XXX_OneofWrappers 

func (*WorkloadSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkloadSpec) XXX_Size 

func (m *WorkloadSpec) XXX_Size() int

func (*WorkloadSpec) XXX_Unmarshal 

func (m *WorkloadSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

Information relevant to AppMesh-injected workloads.

func (*WorkloadSpec_AppMesh) Descriptor 

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

func (*WorkloadSpec_AppMesh) Equal 

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

func (*WorkloadSpec_AppMesh) GetPorts 

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

func (*WorkloadSpec_AppMesh) GetVirtualNodeName 

func (m *WorkloadSpec_AppMesh) GetVirtualNodeName() string

func (*WorkloadSpec_AppMesh) ProtoMessage 

func (*WorkloadSpec_AppMesh) ProtoMessage()

func (*WorkloadSpec_AppMesh) Reset 

func (m *WorkloadSpec_AppMesh) Reset()

func (*WorkloadSpec_AppMesh) String 

func (m *WorkloadSpec_AppMesh) String() string

func (*WorkloadSpec_AppMesh) XXX_DiscardUnknown 

func (m *WorkloadSpec_AppMesh) XXX_DiscardUnknown()

func (*WorkloadSpec_AppMesh) XXX_Marshal 

func (m *WorkloadSpec_AppMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadSpec_AppMesh) XXX_Merge 

func (m *WorkloadSpec_AppMesh) XXX_Merge(src proto.Message)

func (*WorkloadSpec_AppMesh) XXX_Size 

func (m *WorkloadSpec_AppMesh) XXX_Size() int

func (*WorkloadSpec_AppMesh) XXX_Unmarshal 

func (m *WorkloadSpec_AppMesh) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

k8s application container ports.

func (*WorkloadSpec_AppMesh_ContainerPort) Descriptor 

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

func (*WorkloadSpec_AppMesh_ContainerPort) Equal 

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

func (*WorkloadSpec_AppMesh_ContainerPort) GetPort 

func (m *WorkloadSpec_AppMesh_ContainerPort) GetPort() uint32

func (*WorkloadSpec_AppMesh_ContainerPort) GetProtocol 

func (m *WorkloadSpec_AppMesh_ContainerPort) GetProtocol() string

func (*WorkloadSpec_AppMesh_ContainerPort) ProtoMessage 

func (*WorkloadSpec_AppMesh_ContainerPort) ProtoMessage()

func (*WorkloadSpec_AppMesh_ContainerPort) Reset 

func (m *WorkloadSpec_AppMesh_ContainerPort) Reset()

func (*WorkloadSpec_AppMesh_ContainerPort) String 

func (m *WorkloadSpec_AppMesh_ContainerPort) String() string

func (*WorkloadSpec_AppMesh_ContainerPort) XXX_DiscardUnknown 

func (m *WorkloadSpec_AppMesh_ContainerPort) XXX_DiscardUnknown()

func (*WorkloadSpec_AppMesh_ContainerPort) XXX_Marshal 

func (m *WorkloadSpec_AppMesh_ContainerPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadSpec_AppMesh_ContainerPort) XXX_Merge 

func (m *WorkloadSpec_AppMesh_ContainerPort) XXX_Merge(src proto.Message)

func (*WorkloadSpec_AppMesh_ContainerPort) XXX_Size 

func (m *WorkloadSpec_AppMesh_ContainerPort) XXX_Size() int

func (*WorkloadSpec_AppMesh_ContainerPort) XXX_Unmarshal 

func (m *WorkloadSpec_AppMesh_ContainerPort) XXX_Unmarshal(b []byte) error

type WorkloadSpec_Kubernetes 

type WorkloadSpec_Kubernetes struct {
	Kubernetes *WorkloadSpec_KubernetesWorkload `protobuf:"bytes,1,opt,name=kubernetes,proto3,oneof" json:"kubernetes,omitempty"`
}

func (*WorkloadSpec_Kubernetes) Equal 

func (this *WorkloadSpec_Kubernetes) Equal(that interface{}) bool

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Information describing a Kubernetes-based workload (e.g. a Deployment or DaemonSet).

func (*WorkloadSpec_KubernetesWorkload) Descriptor 

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

func (*WorkloadSpec_KubernetesWorkload) Equal 

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

func (*WorkloadSpec_KubernetesWorkload) GetController 

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

func (*WorkloadSpec_KubernetesWorkload) GetPodLabels 

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

func (*WorkloadSpec_KubernetesWorkload) GetServiceAccountName 

func (m *WorkloadSpec_KubernetesWorkload) GetServiceAccountName() string

func (*WorkloadSpec_KubernetesWorkload) ProtoMessage 

func (*WorkloadSpec_KubernetesWorkload) ProtoMessage()

func (*WorkloadSpec_KubernetesWorkload) Reset 

func (m *WorkloadSpec_KubernetesWorkload) Reset()

func (*WorkloadSpec_KubernetesWorkload) String 

func (m *WorkloadSpec_KubernetesWorkload) String() string

func (*WorkloadSpec_KubernetesWorkload) XXX_DiscardUnknown 

func (m *WorkloadSpec_KubernetesWorkload) XXX_DiscardUnknown()

func (*WorkloadSpec_KubernetesWorkload) XXX_Marshal 

func (m *WorkloadSpec_KubernetesWorkload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadSpec_KubernetesWorkload) XXX_Merge 

func (m *WorkloadSpec_KubernetesWorkload) XXX_Merge(src proto.Message)

func (*WorkloadSpec_KubernetesWorkload) XXX_Size 

func (m *WorkloadSpec_KubernetesWorkload) XXX_Size() int

func (*WorkloadSpec_KubernetesWorkload) XXX_Unmarshal 

func (m *WorkloadSpec_KubernetesWorkload) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkloadStatus) DeepCopyInto 

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

DeepCopyInto for the Workload.Status

func (*WorkloadStatus) Descriptor 

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

func (*WorkloadStatus) Equal 

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

func (*WorkloadStatus) GetObservedGeneration 

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

func (m *WorkloadStatus) Reset()

func (*WorkloadStatus) String 

func (m *WorkloadStatus) String() string

func (*WorkloadStatus) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for WorkloadStatus

func (*WorkloadStatus) XXX_DiscardUnknown 

func (m *WorkloadStatus) XXX_DiscardUnknown()

func (*WorkloadStatus) XXX_Marshal 

func (m *WorkloadStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadStatus) XXX_Merge 

func (m *WorkloadStatus) XXX_Merge(src proto.Message)

func (*WorkloadStatus) XXX_Size 

func (m *WorkloadStatus) XXX_Size() int

func (*WorkloadStatus) XXX_Unmarshal 

func (m *WorkloadStatus) XXX_Unmarshal(b []byte) error

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