tcpproxy

package
v0.3.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// Namespace is where tcp-proxy resources are deployed inside the tenant cluster.
	Namespace = "kube-system"

	// DeploymentName is the name of the tcp-proxy Deployment.
	DeploymentName = "steward-tcp-proxy"

	// ServiceName is the name of the tcp-proxy Service.
	ServiceName = "steward-tcp-proxy"

	// ServiceAccountName is the name of the tcp-proxy ServiceAccount.
	ServiceAccountName = "steward-tcp-proxy"

	// ClusterRoleName is the name of the tcp-proxy ClusterRole.
	ClusterRoleName = "steward:tcp-proxy"

	// ClusterRoleBindingName is the name of the tcp-proxy ClusterRoleBinding.
	ClusterRoleBindingName = "steward:tcp-proxy"

	// DefaultImage is the default container image for tcp-proxy.
	// TLS termination mode for Ingress/Gateway, passthrough for LoadBalancer/NodePort.
	DefaultImage = "ghcr.io/butlerdotdev/steward-tcp-proxy:v0.2.0"

	// ProxyPort is the port tcp-proxy listens on for proxied connections.
	ProxyPort = 6443

	// HealthPort is the port for health check endpoints.
	HealthPort = 8080

	// MetricsPort is the port for Prometheus metrics.
	MetricsPort = 9090

	// AppLabel is the app label value used for pod selection.
	AppLabel = "steward-tcp-proxy"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Agent 

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

Agent manages the tcp-proxy Deployment inside the tenant cluster.

func (*Agent) CleanUp 

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

func (*Agent) CreateOrUpdate 

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

func (*Agent) Define 

func (r *Agent) Define(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) 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(tcp *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, tcp *stewardv1alpha1.TenantControlPlane) error

type ClusterRoleBindingResource 

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

ClusterRoleBindingResource manages the tcp-proxy ClusterRoleBinding inside the tenant cluster.

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, tcp *stewardv1alpha1.TenantControlPlane) 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(tcp *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, tcp *stewardv1alpha1.TenantControlPlane) error

type ClusterRoleResource 

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

ClusterRoleResource manages the tcp-proxy ClusterRole inside the tenant cluster.

func (*ClusterRoleResource) CleanUp 

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

func (*ClusterRoleResource) CreateOrUpdate 

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

func (*ClusterRoleResource) Define 

func (r *ClusterRoleResource) Define(ctx context.Context, tcp *stewardv1alpha1.TenantControlPlane) error

func (*ClusterRoleResource) GetHistogram 

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

func (*ClusterRoleResource) GetName 

func (r *ClusterRoleResource) GetName() string

func (*ClusterRoleResource) ShouldCleanup 

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

func (*ClusterRoleResource) ShouldStatusBeUpdated 

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

func (*ClusterRoleResource) UpdateTenantControlPlaneStatus 

func (r *ClusterRoleResource) UpdateTenantControlPlaneStatus(_ context.Context, tcp *stewardv1alpha1.TenantControlPlane) error

type ServiceAccountResource 

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

ServiceAccountResource manages the tcp-proxy ServiceAccount inside the tenant cluster.

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, tcp *stewardv1alpha1.TenantControlPlane) 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(tcp *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, tcp *stewardv1alpha1.TenantControlPlane) error

type ServiceResource 

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

ServiceResource manages the tcp-proxy ClusterIP Service inside the tenant cluster.

func (*ServiceResource) CleanUp 

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

func (*ServiceResource) CreateOrUpdate 

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

func (*ServiceResource) Define 

func (r *ServiceResource) Define(ctx context.Context, tcp *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(tcp *stewardv1alpha1.TenantControlPlane) bool

func (*ServiceResource) ShouldStatusBeUpdated 

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

func (*ServiceResource) UpdateTenantControlPlaneStatus 

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

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.