Documentation ¶
Overview ¶
nolint: gocritic
nolint: gocritic
nolint: gocritic
nolint: gocritic
nolint: gocritic
Index ¶
- func AppendNonNil[T any](data []T, i *T) []T
- func FindPortName(pod *v1.Pod, name string) (int32, bool)
- func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)
- func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition)
- func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition
- func IsPodPending(pod *v1.Pod) bool
- func IsPodReady(pod *v1.Pod) bool
- func IsPodReadyConditionTrue(status v1.PodStatus) bool
- func IsPodRunning(pod *v1.Pod) bool
- func MeshConfigCollection(ConfigMaps krt.Collection[*v1.ConfigMap], options Options) krt.Singleton[MeshConfig]
- func PolicyCollections(AuthzPolicies krt.Collection[*securityclient.AuthorizationPolicy], ...) (krt.Collection[model.WorkloadAuthorization], ...)
- func PushXds[T any](xds model.XDSUpdater, f func(T) model.ConfigKey) func(events []krt.Event[T], initialSync bool)
- func WaypointsCollection(Gateways krt.Collection[*v1beta1.Gateway], ...) krt.Collection[Waypoint]
- type InboundBinding
- type Index
- type LookupNetwork
- type MeshConfig
- type Options
- type Waypoint
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppendNonNil ¶
func AppendNonNil[T any](data []T, i *T) []T
func GetPodCondition ¶
func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)
func GetPodConditionFromList ¶
func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition)
GetPodConditionFromList extracts the provided condition from the given list of condition and returns the index of the condition and the condition. Returns -1 and nil if the condition is not present.
func GetPodReadyCondition ¶
func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition
func IsPodPending ¶
func IsPodReady ¶
IsPodReady is copied from kubernetes/pkg/api/v1/pod/utils.go
func IsPodReadyConditionTrue ¶
IsPodReadyConditionTrue returns true if a pod is ready; false otherwise.
func IsPodRunning ¶
func MeshConfigCollection ¶
func MeshConfigCollection(ConfigMaps krt.Collection[*v1.ConfigMap], options Options) krt.Singleton[MeshConfig]
func PolicyCollections ¶
func PolicyCollections( AuthzPolicies krt.Collection[*securityclient.AuthorizationPolicy], PeerAuths krt.Collection[*securityclient.PeerAuthentication], MeshConfig krt.Singleton[MeshConfig], Waypoints krt.Collection[Waypoint], Pods krt.Collection[*v1.Pod], ) (krt.Collection[model.WorkloadAuthorization], krt.Collection[model.WorkloadAuthorization])
func WaypointsCollection ¶
func WaypointsCollection( Gateways krt.Collection[*v1beta1.Gateway], GatewayClasses krt.Collection[*v1beta1.GatewayClass], Pods krt.Collection[*v1.Pod], ) krt.Collection[Waypoint]
Types ¶
type InboundBinding ¶
type InboundBinding struct { Port uint32 Protocol workloadapi.ApplicationTunnel_Protocol }
type Index ¶
type Index interface { Lookup(key string) []model.AddressInfo All() []model.AddressInfo WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo ServicesForWaypoint(key model.WaypointKey) []model.ServiceInfo SyncAll() HasSynced() bool model.AmbientIndexes }
type MeshConfig ¶
type MeshConfig struct {
*meshapi.MeshConfig
}
func (MeshConfig) Equals ¶
func (m MeshConfig) Equals(other MeshConfig) bool
func (MeshConfig) ResourceName ¶
func (m MeshConfig) ResourceName() string
type Options ¶
type Options struct { Client kubeclient.Client Revision string SystemNamespace string DomainSuffix string ClusterID cluster.ID XDSUpdater model.XDSUpdater LookupNetwork LookupNetwork }
type Waypoint ¶
type Waypoint struct { krt.Named // Addresses this Waypoint is reachable by. For stock Istio waypoints, this // is is usually the VIP. Tere will always be at least one address in this // list. Addresses []netip.Addr // DefaultBinding for an inbound zTunnel to use to connect to a Waypoint it captures. // This is applied to the Workloads that are instances of the current Waypoint. DefaultBinding InboundBinding // TrafficType controls whether Service or Workload can reference this // waypoint. Must be one of "all", "service", "workload". TrafficType string // ServiceAccounts from instances of the waypoint. // This only handles Pods. If we wish to support non-pod waypoints, we'll // want to index ServiceEntry/WorkloadEntry or possibly allow specifying // the ServiceAccounts directly on a Gateway resource. ServiceAccounts []string }
func (Waypoint) ResourceName ¶
Click to show internal directories.
Click to hide internal directories.