Versions in this module Expand all Collapse all v0 v0.0.0 Feb 25, 2025 Changes in this version + func Sync(ctx context.Context, cfg SyncConfig) + type ConfigManager interface + Deregister func(proxyID proxycfg.ProxyID, source proxycfg.ProxySource) + Register func(proxyID proxycfg.ProxyID, service *structs.NodeService, ...) error + RegisteredProxies func(source proxycfg.ProxySource) []proxycfg.ProxyID + Watch func(id proxycfg.ProxyID) (<-chan *proxycfg.ConfigSnapshot, proxycfg.CancelFunc) + type ConfigSource struct + func NewConfigSource(cfgMgr ConfigManager) *ConfigSource + func (m *ConfigSource) Watch(serviceID structs.ServiceID, nodeName string, _ string) (<-chan *proxycfg.ConfigSnapshot, limiter.SessionTerminatedChan, ...) + type MockConfigManager struct + func NewMockConfigManager(t mockConstructorTestingTNewMockConfigManager) *MockConfigManager + func (_m *MockConfigManager) Deregister(proxyID proxycfg.ProxyID, source proxycfg.ProxySource) + func (_m *MockConfigManager) Register(proxyID proxycfg.ProxyID, service *structs.NodeService, ...) error + func (_m *MockConfigManager) RegisteredProxies(source proxycfg.ProxySource) []proxycfg.ProxyID + func (_m *MockConfigManager) Watch(id proxycfg.ProxyID) (<-chan *proxycfg.ConfigSnapshot, proxycfg.CancelFunc) + type SyncConfig struct + Logger hclog.Logger + Manager ConfigManager + NodeName string + ResyncFrequency time.Duration + State *local.State + Tokens *token.Store
Go to main page