Versions in this module Expand all Collapse all v0 v0.66.2 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
Go to main page