v1alpha2

package
v0.12.4 Latest Latest
Warning

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

Go to latest
Published: Feb 2, 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

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 (*MeshSpec_ConsulConnectMesh) ProtoMessage

func (*MeshSpec_ConsulConnectMesh) ProtoMessage()

func (*MeshSpec_ConsulConnectMesh) ProtoReflect added in v0.10.8

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

func (*MeshSpec_Istio_IngressGatewayInfo) 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 (*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 (*MeshStatus_AppliedFailoverService) GetSpec

func (*MeshStatus_AppliedFailoverService) ProtoMessage

func (*MeshStatus_AppliedFailoverService) ProtoMessage()

func (*MeshStatus_AppliedFailoverService) ProtoReflect added in v0.10.8

func (*MeshStatus_AppliedFailoverService) Reset

func (*MeshStatus_AppliedFailoverService) 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 (*MeshStatus_AppliedVirtualMesh) GetSpec

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage

func (*MeshStatus_AppliedVirtualMesh) ProtoMessage()

func (*MeshStatus_AppliedVirtualMesh) ProtoReflect added in v0.10.8

func (*MeshStatus_AppliedVirtualMesh) Reset

func (x *MeshStatus_AppliedVirtualMesh) Reset()

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

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 (*TrafficTargetSpec_KubeService) GetLabels

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

func (*TrafficTargetSpec_KubeService) GetPorts

func (*TrafficTargetSpec_KubeService) GetRef

func (*TrafficTargetSpec_KubeService) GetSubsets

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

func (x *TrafficTargetSpec_KubeService) Reset()

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

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 (*TrafficTargetSpec_KubeService_EndpointsSubset) GetPorts added in v0.12.0

func (*TrafficTargetSpec_KubeService_EndpointsSubset) ProtoMessage added in v0.12.0

func (*TrafficTargetSpec_KubeService_EndpointsSubset) ProtoReflect added in v0.12.0

func (*TrafficTargetSpec_KubeService_EndpointsSubset) Reset added in v0.12.0

func (*TrafficTargetSpec_KubeService_EndpointsSubset) String added in v0.12.0

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

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 (*TrafficTargetSpec_KubeService_KubeServicePort) GetName

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetPort

func (*TrafficTargetSpec_KubeService_KubeServicePort) GetProtocol

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoMessage

func (*TrafficTargetSpec_KubeService_KubeServicePort) ProtoReflect added in v0.10.8

func (*TrafficTargetSpec_KubeService_KubeServicePort) Reset

func (*TrafficTargetSpec_KubeService_KubeServicePort) 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 (*TrafficTargetSpec_KubeService_Subset) ProtoMessage

func (*TrafficTargetSpec_KubeService_Subset) ProtoMessage()

func (*TrafficTargetSpec_KubeService_Subset) ProtoReflect added in v0.10.8

func (*TrafficTargetSpec_KubeService_Subset) Reset

func (*TrafficTargetSpec_KubeService_Subset) 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 (*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 (*TrafficTargetStatus_AppliedAccessPolicy) GetSpec

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoMessage

func (*TrafficTargetStatus_AppliedAccessPolicy) ProtoReflect added in v0.10.8

func (*TrafficTargetStatus_AppliedAccessPolicy) Reset

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

func (*TrafficTargetStatus_AppliedFederation) 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 (*TrafficTargetStatus_AppliedTrafficPolicy) GetSpec

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoMessage

func (*TrafficTargetStatus_AppliedTrafficPolicy) ProtoReflect added in v0.10.8

func (*TrafficTargetStatus_AppliedTrafficPolicy) Reset

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

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

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

func (*WorkloadSpec_KubernetesWorkload) 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 (*WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration added in v0.12.3

func (x *WorkloadStatus_AppliedAccessLogRecord) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedAccessLogRecord) GetRef added in v0.12.3

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage added in v0.12.3

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoMessage()

func (*WorkloadStatus_AppliedAccessLogRecord) ProtoReflect added in v0.12.3

func (*WorkloadStatus_AppliedAccessLogRecord) Reset added in v0.12.3

func (*WorkloadStatus_AppliedAccessLogRecord) String added in v0.12.3

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 (*WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration added in v0.12.3

func (x *WorkloadStatus_AppliedWasmDeployment) GetObservedGeneration() int64

func (*WorkloadStatus_AppliedWasmDeployment) GetRef added in v0.12.3

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage added in v0.12.3

func (*WorkloadStatus_AppliedWasmDeployment) ProtoMessage()

func (*WorkloadStatus_AppliedWasmDeployment) ProtoReflect added in v0.12.3

func (*WorkloadStatus_AppliedWasmDeployment) Reset added in v0.12.3

func (*WorkloadStatus_AppliedWasmDeployment) String added in v0.12.3

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.

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