proxy

package
v0.66.2 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2026 License: BSD-3-Clause, AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Overview

Package proxy is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller 

type Controller interface {
	SendServiceUpdateToCluster(ctx context.Context, accountID string, update *proto.ProxyMapping, clusterAddr string)
	GetOIDCValidationConfig() OIDCValidationConfig
	RegisterProxyToCluster(ctx context.Context, clusterAddr, proxyID string) error
	UnregisterProxyFromCluster(ctx context.Context, clusterAddr, proxyID string) error
	GetProxiesForCluster(clusterAddr string) []string
}

Controller is responsible for managing proxy clusters and routing service updates.

type Manager 

type Manager interface {
	Connect(ctx context.Context, proxyID, clusterAddress, ipAddress string) error
	Disconnect(ctx context.Context, proxyID string) error
	Heartbeat(ctx context.Context, proxyID string) error
	GetActiveClusterAddresses(ctx context.Context) ([]string, error)
	CleanupStale(ctx context.Context, inactivityDuration time.Duration) error
}

Manager defines the interface for proxy operations

type MockController 

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

MockController is a mock of Controller interface.

func NewMockController 

func NewMockController(ctrl *gomock.Controller) *MockController

NewMockController creates a new mock instance.

func (*MockController) EXPECT 

func (m *MockController) EXPECT() *MockControllerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockController) GetOIDCValidationConfig 

func (m *MockController) GetOIDCValidationConfig() OIDCValidationConfig

GetOIDCValidationConfig mocks base method.

func (*MockController) GetProxiesForCluster 

func (m *MockController) GetProxiesForCluster(clusterAddr string) []string

GetProxiesForCluster mocks base method.

func (*MockController) RegisterProxyToCluster 

func (m *MockController) RegisterProxyToCluster(ctx context.Context, clusterAddr, proxyID string) error

RegisterProxyToCluster mocks base method.

func (*MockController) SendServiceUpdateToCluster 

func (m *MockController) SendServiceUpdateToCluster(ctx context.Context, accountID string, update *proto.ProxyMapping, clusterAddr string)

SendServiceUpdateToCluster mocks base method.

func (*MockController) UnregisterProxyFromCluster 

func (m *MockController) UnregisterProxyFromCluster(ctx context.Context, clusterAddr, proxyID string) error

UnregisterProxyFromCluster mocks base method.

type MockControllerMockRecorder 

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

MockControllerMockRecorder is the mock recorder for MockController.

func (*MockControllerMockRecorder) GetOIDCValidationConfig 

func (mr *MockControllerMockRecorder) GetOIDCValidationConfig() *gomock.Call

GetOIDCValidationConfig indicates an expected call of GetOIDCValidationConfig.

func (*MockControllerMockRecorder) GetProxiesForCluster 

func (mr *MockControllerMockRecorder) GetProxiesForCluster(clusterAddr interface{}) *gomock.Call

GetProxiesForCluster indicates an expected call of GetProxiesForCluster.

func (*MockControllerMockRecorder) RegisterProxyToCluster 

func (mr *MockControllerMockRecorder) RegisterProxyToCluster(ctx, clusterAddr, proxyID interface{}) *gomock.Call

RegisterProxyToCluster indicates an expected call of RegisterProxyToCluster.

func (*MockControllerMockRecorder) SendServiceUpdateToCluster 

func (mr *MockControllerMockRecorder) SendServiceUpdateToCluster(ctx, accountID, update, clusterAddr interface{}) *gomock.Call

SendServiceUpdateToCluster indicates an expected call of SendServiceUpdateToCluster.

func (*MockControllerMockRecorder) UnregisterProxyFromCluster 

func (mr *MockControllerMockRecorder) UnregisterProxyFromCluster(ctx, clusterAddr, proxyID interface{}) *gomock.Call

UnregisterProxyFromCluster indicates an expected call of UnregisterProxyFromCluster.

type MockManager 

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

MockManager is a mock of Manager interface.

func NewMockManager 

func NewMockManager(ctrl *gomock.Controller) *MockManager

NewMockManager creates a new mock instance.

func (*MockManager) CleanupStale 

func (m *MockManager) CleanupStale(ctx context.Context, inactivityDuration time.Duration) error

CleanupStale mocks base method.

func (*MockManager) Connect 

func (m *MockManager) Connect(ctx context.Context, proxyID, clusterAddress, ipAddress string) error

Connect mocks base method.

func (*MockManager) Disconnect 

func (m *MockManager) Disconnect(ctx context.Context, proxyID string) error

Disconnect mocks base method.

func (*MockManager) EXPECT 

func (m *MockManager) EXPECT() *MockManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockManager) GetActiveClusterAddresses 

func (m *MockManager) GetActiveClusterAddresses(ctx context.Context) ([]string, error)

GetActiveClusterAddresses mocks base method.

func (*MockManager) Heartbeat 

func (m *MockManager) Heartbeat(ctx context.Context, proxyID string) error

Heartbeat mocks base method.

type MockManagerMockRecorder 

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

MockManagerMockRecorder is the mock recorder for MockManager.

func (*MockManagerMockRecorder) CleanupStale 

func (mr *MockManagerMockRecorder) CleanupStale(ctx, inactivityDuration interface{}) *gomock.Call

CleanupStale indicates an expected call of CleanupStale.

func (*MockManagerMockRecorder) Connect 

func (mr *MockManagerMockRecorder) Connect(ctx, proxyID, clusterAddress, ipAddress interface{}) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockManagerMockRecorder) Disconnect 

func (mr *MockManagerMockRecorder) Disconnect(ctx, proxyID interface{}) *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockManagerMockRecorder) GetActiveClusterAddresses 

func (mr *MockManagerMockRecorder) GetActiveClusterAddresses(ctx interface{}) *gomock.Call

GetActiveClusterAddresses indicates an expected call of GetActiveClusterAddresses.

func (*MockManagerMockRecorder) Heartbeat 

func (mr *MockManagerMockRecorder) Heartbeat(ctx, proxyID interface{}) *gomock.Call

Heartbeat indicates an expected call of Heartbeat.

type OIDCValidationConfig 

type OIDCValidationConfig struct {
	Issuer             string
	Audiences          []string
	KeysLocation       string
	MaxTokenAgeSeconds int64
}

OIDCValidationConfig contains the OIDC configuration needed for token validation.

type Proxy 

type Proxy struct {
	ID             string    `gorm:"primaryKey;type:varchar(255)"`
	ClusterAddress string    `gorm:"type:varchar(255);not null;index:idx_proxy_cluster_status"`
	IPAddress      string    `gorm:"type:varchar(45)"`
	LastSeen       time.Time `gorm:"not null;index:idx_proxy_last_seen"`
	ConnectedAt    *time.Time
	DisconnectedAt *time.Time
	Status         string `gorm:"type:varchar(20);not null;index:idx_proxy_cluster_status"`
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

Proxy represents a reverse proxy instance

func (Proxy) TableName 

func (Proxy) TableName() string

Source Files

View all Source files

Directories

Path Synopsis

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.