konnectivity

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AgentName      = "konnectivity-agent"
	CertCommonName = "system:konnectivity-server"
	AgentNamespace = core.NamespaceSystem
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Agent 

type Agent struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*Agent) CleanUp 

func (r *Agent) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*Agent) CreateOrUpdate 

func (r *Agent) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*Agent) Define 

func (r *Agent) Define(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (err error)

func (*Agent) GetHistogram 

func (r *Agent) GetHistogram() prometheus.Histogram

func (*Agent) GetName 

func (r *Agent) GetName() string

func (*Agent) ShouldCleanup 

func (r *Agent) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*Agent) ShouldStatusBeUpdated 

func (r *Agent) ShouldStatusBeUpdated(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) bool

func (*Agent) UpdateTenantControlPlaneStatus 

func (r *Agent) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type CertificateResource 

type CertificateResource struct {
	Client                  client.Client
	CertExpirationThreshold time.Duration
	// contains filtered or unexported fields
}

func (*CertificateResource) CleanUp 

func (r *CertificateResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*CertificateResource) CreateOrUpdate 

func (r *CertificateResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*CertificateResource) Define 

func (r *CertificateResource) Define(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

func (*CertificateResource) GetHistogram 

func (r *CertificateResource) GetHistogram() prometheus.Histogram

func (*CertificateResource) GetName 

func (r *CertificateResource) GetName() string

func (*CertificateResource) ShouldCleanup 

func (r *CertificateResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*CertificateResource) ShouldStatusBeUpdated 

func (r *CertificateResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*CertificateResource) UpdateTenantControlPlaneStatus 

func (r *CertificateResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type ClusterRoleBindingResource 

type ClusterRoleBindingResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*ClusterRoleBindingResource) CleanUp 

func (r *ClusterRoleBindingResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*ClusterRoleBindingResource) CreateOrUpdate 

func (r *ClusterRoleBindingResource) CreateOrUpdate(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ClusterRoleBindingResource) Define 

func (r *ClusterRoleBindingResource) Define(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (err error)

func (*ClusterRoleBindingResource) GetHistogram 

func (r *ClusterRoleBindingResource) GetHistogram() prometheus.Histogram

func (*ClusterRoleBindingResource) GetName 

func (r *ClusterRoleBindingResource) GetName() string

func (*ClusterRoleBindingResource) ShouldCleanup 

func (r *ClusterRoleBindingResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*ClusterRoleBindingResource) ShouldStatusBeUpdated 

func (r *ClusterRoleBindingResource) ShouldStatusBeUpdated(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) bool

func (*ClusterRoleBindingResource) UpdateTenantControlPlaneStatus 

func (r *ClusterRoleBindingResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type Connection 

type Connection struct {
	ProxyProtocol ProtocolType `json:"proxyProtocol,omitempty"`
	Transport     *Transport   `json:"transport,omitempty"`
}

Connection provides the configuration for a single egress selection client connection.

func (*Connection) DeepCopy 

func (in *Connection) DeepCopy() *Connection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Connection.

func (*Connection) DeepCopyInto 

func (in *Connection) DeepCopyInto(out *Connection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EgressSelection 

type EgressSelection struct {
	Name       string     `json:"name"`
	Connection Connection `json:"connection"`
}

EgressSelection provides the configuration for a single egress selection client.

func (*EgressSelection) DeepCopy 

func (in *EgressSelection) DeepCopy() *EgressSelection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EgressSelection.

func (*EgressSelection) DeepCopyInto 

func (in *EgressSelection) DeepCopyInto(out *EgressSelection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EgressSelectorConfiguration 

type EgressSelectorConfiguration struct {
	metav1.TypeMeta  `json:",inline"`
	EgressSelections []EgressSelection `json:"egressSelections"`
}

EgressSelectorConfiguration provides versioned configuration for egress selector clients.

func (*EgressSelectorConfiguration) DeepCopy 

func (in *EgressSelectorConfiguration) DeepCopy() *EgressSelectorConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EgressSelectorConfiguration.

func (*EgressSelectorConfiguration) DeepCopyInto 

func (in *EgressSelectorConfiguration) DeepCopyInto(out *EgressSelectorConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EgressSelectorConfiguration) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type EgressSelectorConfigurationResource 

type EgressSelectorConfigurationResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*EgressSelectorConfigurationResource) CleanUp 

func (r *EgressSelectorConfigurationResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*EgressSelectorConfigurationResource) CreateOrUpdate 

func (r *EgressSelectorConfigurationResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*EgressSelectorConfigurationResource) Define 

func (r *EgressSelectorConfigurationResource) Define(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

func (*EgressSelectorConfigurationResource) GetHistogram 

func (r *EgressSelectorConfigurationResource) GetHistogram() prometheus.Histogram

func (*EgressSelectorConfigurationResource) GetName 

func (r *EgressSelectorConfigurationResource) GetName() string

func (*EgressSelectorConfigurationResource) ShouldCleanup 

func (r *EgressSelectorConfigurationResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*EgressSelectorConfigurationResource) ShouldStatusBeUpdated 

func (r *EgressSelectorConfigurationResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*EgressSelectorConfigurationResource) UpdateTenantControlPlaneStatus 

func (r *EgressSelectorConfigurationResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type KubeconfigResource 

type KubeconfigResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*KubeconfigResource) CleanUp 

func (r *KubeconfigResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*KubeconfigResource) CreateOrUpdate 

func (r *KubeconfigResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubeconfigResource) Define 

func (r *KubeconfigResource) Define(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

func (*KubeconfigResource) GetHistogram 

func (r *KubeconfigResource) GetHistogram() prometheus.Histogram

func (*KubeconfigResource) GetName 

func (r *KubeconfigResource) GetName() string

func (*KubeconfigResource) ShouldCleanup 

func (r *KubeconfigResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*KubeconfigResource) ShouldStatusBeUpdated 

func (r *KubeconfigResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*KubeconfigResource) UpdateTenantControlPlaneStatus 

func (r *KubeconfigResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type KubernetesDeploymentResource 

type KubernetesDeploymentResource struct {
	Builder builder.Konnectivity
	Client  client.Client
	// contains filtered or unexported fields
}

func (*KubernetesDeploymentResource) CleanUp 

func (r *KubernetesDeploymentResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesDeploymentResource) CreateOrUpdate 

func (r *KubernetesDeploymentResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesDeploymentResource) Define 

func (r *KubernetesDeploymentResource) Define(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

func (*KubernetesDeploymentResource) GetHistogram 

func (r *KubernetesDeploymentResource) GetHistogram() prometheus.Histogram

func (*KubernetesDeploymentResource) GetName 

func (r *KubernetesDeploymentResource) GetName() string

func (*KubernetesDeploymentResource) ShouldCleanup 

func (r *KubernetesDeploymentResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*KubernetesDeploymentResource) ShouldStatusBeUpdated 

func (r *KubernetesDeploymentResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*KubernetesDeploymentResource) UpdateTenantControlPlaneStatus 

func (r *KubernetesDeploymentResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type KubernetesKonnectivityGatewayResource 

type KubernetesKonnectivityGatewayResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*KubernetesKonnectivityGatewayResource) CleanUp 

func (r *KubernetesKonnectivityGatewayResource) CleanUp(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesKonnectivityGatewayResource) CreateOrUpdate 

func (r *KubernetesKonnectivityGatewayResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesKonnectivityGatewayResource) Define 

func (r *KubernetesKonnectivityGatewayResource) Define(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) error

func (*KubernetesKonnectivityGatewayResource) GetHistogram 

func (r *KubernetesKonnectivityGatewayResource) GetHistogram() prometheus.Histogram

func (*KubernetesKonnectivityGatewayResource) GetName 

func (r *KubernetesKonnectivityGatewayResource) GetName() string

func (*KubernetesKonnectivityGatewayResource) ShouldCleanup 

func (r *KubernetesKonnectivityGatewayResource) ShouldCleanup(tcp *stewardv1alpha1.TenantControlPlane) bool

func (*KubernetesKonnectivityGatewayResource) ShouldStatusBeUpdated 

func (r *KubernetesKonnectivityGatewayResource) ShouldStatusBeUpdated(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) bool

func (*KubernetesKonnectivityGatewayResource) UpdateTenantControlPlaneStatus 

func (r *KubernetesKonnectivityGatewayResource) UpdateTenantControlPlaneStatus(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) error

type ProtocolType 

type ProtocolType string

ProtocolType is the type of the proxy protocol used for egress selection. 

const (
	// ProtocolHTTPConnect uses HTTP CONNECT as the proxy protocol.
	ProtocolHTTPConnect ProtocolType = "HTTPConnect"
	// ProtocolGRPC uses GRPC as the proxy protocol.
	ProtocolGRPC ProtocolType = "GRPC"
	// ProtocolDirect establishes a direct connection without proxy.
	ProtocolDirect ProtocolType = "Direct"
)

type ServiceAccountResource 

type ServiceAccountResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*ServiceAccountResource) CleanUp 

func (r *ServiceAccountResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*ServiceAccountResource) CreateOrUpdate 

func (r *ServiceAccountResource) CreateOrUpdate(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ServiceAccountResource) Define 

func (r *ServiceAccountResource) Define(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (err error)

func (*ServiceAccountResource) GetHistogram 

func (r *ServiceAccountResource) GetHistogram() prometheus.Histogram

func (*ServiceAccountResource) GetName 

func (r *ServiceAccountResource) GetName() string

func (*ServiceAccountResource) ShouldCleanup 

func (r *ServiceAccountResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*ServiceAccountResource) ShouldStatusBeUpdated 

func (r *ServiceAccountResource) ShouldStatusBeUpdated(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) bool

func (*ServiceAccountResource) UpdateTenantControlPlaneStatus 

func (r *ServiceAccountResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type ServiceResource 

type ServiceResource struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*ServiceResource) CleanUp 

func (r *ServiceResource) CleanUp(ctx context.Context, _ *stewardv1alpha1.TenantControlPlane) (bool, error)

func (*ServiceResource) CreateOrUpdate 

func (r *ServiceResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ServiceResource) Define 

func (r *ServiceResource) Define(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

func (*ServiceResource) GetHistogram 

func (r *ServiceResource) GetHistogram() prometheus.Histogram

func (*ServiceResource) GetName 

func (r *ServiceResource) GetName() string

func (*ServiceResource) ShouldCleanup 

func (r *ServiceResource) ShouldCleanup(tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*ServiceResource) ShouldStatusBeUpdated 

func (r *ServiceResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) bool

func (*ServiceResource) UpdateTenantControlPlaneStatus 

func (r *ServiceResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *stewardv1alpha1.TenantControlPlane) error

type TCPTransport 

type TCPTransport struct {
	URL string `json:"url,omitempty"`
}

TCPTransport provides the information to connect to a TCP endpoint.

func (*TCPTransport) DeepCopy 

func (in *TCPTransport) DeepCopy() *TCPTransport

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TCPTransport.

func (*TCPTransport) DeepCopyInto 

func (in *TCPTransport) DeepCopyInto(out *TCPTransport)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Transport 

type Transport struct {
	TCP *TCPTransport `json:"tcp,omitempty"`
	UDS *UDSTransport `json:"uds,omitempty"`
}

Transport defines the transport configurations we support for egress selector.

func (*Transport) DeepCopy 

func (in *Transport) DeepCopy() *Transport

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transport.

func (*Transport) DeepCopyInto 

func (in *Transport) DeepCopyInto(out *Transport)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UDSTransport 

type UDSTransport struct {
	UDSName string `json:"udsName,omitempty"`
}

UDSTransport provides the information to connect to a Unix Domain Socket endpoint.

func (*UDSTransport) DeepCopy 

func (in *UDSTransport) DeepCopy() *UDSTransport

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDSTransport.

func (*UDSTransport) DeepCopyInto 

func (in *UDSTransport) DeepCopyInto(out *UDSTransport)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

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.