proxy

package

v2.5.3 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func GetSocketPath(serviceID string, port int) string

func UnixListenersThread(ctx context.Context, serviceID strfmt.UUID, upstream string, ports []int32)

type Manager struct {
	// contains filtered or unexported fields
}

Manager manages Unix proxy threads for multiple services. Each service gets its own set of Unix socket proxies.

func NewManager(ctx context.Context) *Manager

NewManager creates a new proxy manager.

func (m *Manager) IsRunning(serviceID strfmt.UUID) bool

IsRunning checks if a proxy is running for a service.

func (m *Manager) StartProxy(serviceID strfmt.UUID, upstream string, ports []int32)

StartProxy starts a Unix proxy thread for a service. If a proxy is already running for this service, it will be stopped first.

func (m *Manager) StopAll()

StopAll stops all running proxy threads.

func (m *Manager) StopProxy(serviceID strfmt.UUID)

StopProxy stops the Unix proxy thread for a service.