proxy

May 14, 2026

Changes in this version

+ const StatusConnected

+ const StatusDisconnected

type Cluster

+ ID string

+ SelfHosted bool

type Manager

+ CountAccountProxies func(ctx context.Context, accountID string) (int64, error)

+ DeleteAccountCluster func(ctx context.Context, clusterAddress, accountID string) error

+ GetAccountProxy func(ctx context.Context, accountID string) (*Proxy, error)

+ GetActiveClusterAddressesForAccount func(ctx context.Context, accountID string) ([]string, error)

+ IsClusterAddressAvailable func(ctx context.Context, clusterAddress, accountID string) (bool, error)

type MockManager

+ func (m *MockManager) CountAccountProxies(ctx context.Context, accountID string) (int64, error)

+ func (m *MockManager) DeleteAccountCluster(ctx context.Context, clusterAddress, accountID string) error

+ func (m *MockManager) GetAccountProxy(ctx context.Context, accountID string) (*Proxy, error)

+ func (m *MockManager) GetActiveClusterAddressesForAccount(ctx context.Context, accountID string) ([]string, error)

+ func (m *MockManager) IsClusterAddressAvailable(ctx context.Context, clusterAddress, accountID string) (bool, error)

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) CountAccountProxies(ctx, accountID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) DeleteAccountCluster(ctx, clusterAddress, accountID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) GetAccountProxy(ctx, accountID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) GetActiveClusterAddressesForAccount(ctx, accountID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) IsClusterAddressAvailable(ctx, clusterAddress, accountID interface{}) *gomock.Call

type Proxy

+ AccountID *string

May 5, 2026

Changes in this version

type Proxy

+ SessionID string

Apr 20, 2026

Changes in this version

type Capabilities

+ SupportsCrowdsec *bool

type Manager

+ ClusterSupportsCrowdSec func(ctx context.Context, clusterAddr string) *bool

type MockManager

+ func (m *MockManager) ClusterSupportsCrowdSec(ctx context.Context, clusterAddr string) *bool

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) ClusterSupportsCrowdSec(ctx, clusterAddr interface{}) *gomock.Call

Apr 1, 2026

Changes in this version

+ type Capabilities struct

+ RequireSubdomain *bool

+ SupportsCustomPorts *bool

type Manager

+ ClusterRequireSubdomain func(ctx context.Context, clusterAddr string) *bool

+ ClusterSupportsCustomPorts func(ctx context.Context, clusterAddr string) *bool

type MockManager

+ func (m *MockManager) ClusterRequireSubdomain(ctx context.Context, clusterAddr string) *bool

+ func (m *MockManager) ClusterSupportsCustomPorts(ctx context.Context, clusterAddr string) *bool

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) ClusterRequireSubdomain(ctx, clusterAddr interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) ClusterSupportsCustomPorts(ctx, clusterAddr interface{}) *gomock.Call

type Proxy

+ Capabilities Capabilities

Mar 23, 2026

Changes in this version

+ type Cluster struct

+ Address string

+ ConnectedProxies int

type Controller

+ ClusterRequireSubdomain func(clusterAddr string) *bool

+ ClusterSupportsCustomPorts func(clusterAddr string) *bool

type Manager

+ GetActiveClusters func(ctx context.Context) ([]Cluster, error)

type MockController

+ func (m *MockController) ClusterRequireSubdomain(clusterAddr string) *bool

+ func (m *MockController) ClusterSupportsCustomPorts(clusterAddr string) *bool

type MockControllerMockRecorder

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

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

type MockManager

+ func (m *MockManager) GetActiveClusters(ctx context.Context) ([]Cluster, error)

type MockManagerMockRecorder

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

Mar 4, 2026

Changes in this version

+ type Controller interface

+ GetOIDCValidationConfig func() OIDCValidationConfig

+ GetProxiesForCluster func(clusterAddr string) []string

+ RegisterProxyToCluster func(ctx context.Context, clusterAddr, proxyID string) error

+ SendServiceUpdateToCluster func(ctx context.Context, accountID string, update *proto.ProxyMapping, ...)

+ UnregisterProxyFromCluster func(ctx context.Context, clusterAddr, proxyID string) error

+ type Manager interface

+ CleanupStale func(ctx context.Context, inactivityDuration time.Duration) error

+ Connect func(ctx context.Context, proxyID, clusterAddress, ipAddress string) error

+ Disconnect func(ctx context.Context, proxyID string) error

+ GetActiveClusterAddresses func(ctx context.Context) ([]string, error)

+ Heartbeat func(ctx context.Context, proxyID string) error

+ type MockController struct

+ func NewMockController(ctrl *gomock.Controller) *MockController

+ func (m *MockController) EXPECT() *MockControllerMockRecorder

+ func (m *MockController) GetOIDCValidationConfig() OIDCValidationConfig

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

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

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

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

+ type MockControllerMockRecorder struct

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

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

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

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

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

+ type MockManager struct

+ func NewMockManager(ctrl *gomock.Controller) *MockManager

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

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

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

+ func (m *MockManager) EXPECT() *MockManagerMockRecorder

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

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

+ type MockManagerMockRecorder struct

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

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

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

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

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

+ type OIDCValidationConfig struct

+ Audiences []string

+ Issuer string

+ KeysLocation string

+ MaxTokenAgeSeconds int64

+ type Proxy struct

+ ClusterAddress string

+ ConnectedAt *time.Time

+ CreatedAt time.Time

+ DisconnectedAt *time.Time

+ ID string

+ IPAddress string

+ LastSeen time.Time

+ Status string

+ UpdatedAt time.Time

+ func (Proxy) TableName() string