Versions in this module Expand all Collapse all v1 v1.4.0-rc1 Oct 19, 2018 v1.3.0 Oct 11, 2018 Changes in this version + var ErrStarted = errors.New("manager was already run") + var ErrStopped = errors.New("manager stopped") + func TestCacheWithTypes(t testing.T, types *TestCacheTypes) *cache.Cache + func TestCerts(t testing.T) (*structs.IndexedCARoots, *structs.IssuedCert) + func TestIntentions(t testing.T) *structs.IndexedIntentionMatches + func TestLeafForCA(t testing.T, ca *structs.CARoot) *structs.IssuedCert + func TestUpstreamNodes(t testing.T) structs.CheckServiceNodes + type CancelFunc func() + type ConfigSnapshot struct + Address string + Leaf *structs.IssuedCert + Port int + Proxy structs.ConnectProxyConfig + ProxyID string + Roots *structs.IndexedCARoots + UpstreamEndpoints map[string]structs.CheckServiceNodes + func TestConfigSnapshot(t testing.T) *ConfigSnapshot + func (s *ConfigSnapshot) Clone() (*ConfigSnapshot, error) + func (s *ConfigSnapshot) Valid() bool + type ControllableCacheType struct + func NewControllableCacheType(t testing.T) *ControllableCacheType + func (ct *ControllableCacheType) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + func (ct *ControllableCacheType) Set(value interface{}) + func (ct *ControllableCacheType) SupportsBlocking() bool + type Manager struct + func NewManager(cfg ManagerConfig) (*Manager, error) + func (m *Manager) Close() error + func (m *Manager) Run() error + func (m *Manager) Watch(proxyID string) (<-chan *ConfigSnapshot, CancelFunc) + type ManagerConfig struct + Cache *cache.Cache + Logger *log.Logger + Source *structs.QuerySource + State *local.State + type TestCacheTypes struct + func NewTestCacheTypes(t testing.T) *TestCacheTypes
Go to main page