runtime

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Builder 

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

Builder represents a multi-step initialization process.

func BuilderFor 

func BuilderFor(cfg kuma_cp.Config, closeCh <-chan struct{}) (*Builder, error)

func (*Builder) APIManager 

func (b *Builder) APIManager() api_server.APIManager

func (*Builder) Build 

func (b *Builder) Build() (Runtime, error)

func (*Builder) CaManagers 

func (b *Builder) CaManagers() core_ca.Managers

func (*Builder) ComponentManager 

func (b *Builder) ComponentManager() component.Manager

func (*Builder) Config 

func (b *Builder) Config() kuma_cp.Config

func (*Builder) ConfigManager 

func (b *Builder) ConfigManager() config_manager.ConfigManager

func (*Builder) ConfigStore 

func (b *Builder) ConfigStore() core_store.ResourceStore

func (*Builder) DNSResolver 

func (b *Builder) DNSResolver() resolver.DNSResolver

func (*Builder) DataSourceLoader 

func (b *Builder) DataSourceLoader() datasource.Loader

func (*Builder) DpServer 

func (b *Builder) DpServer() *dp_server.DpServer

func (*Builder) EventReaderFactory 

func (b *Builder) EventReaderFactory() events.ListenerFactory

func (*Builder) Extensions 

func (b *Builder) Extensions() context.Context

func (Builder) GetClusterId 

func (i Builder) GetClusterId() string

func (Builder) GetInstanceId 

func (i Builder) GetInstanceId() string

func (*Builder) KDSContext 

func (b *Builder) KDSContext() *kds_context.Context

func (*Builder) LeaderInfo 

func (b *Builder) LeaderInfo() component.LeaderInfo

func (*Builder) LookupIP 

func (b *Builder) LookupIP() lookup.LookupIPFunc

func (*Builder) Metrics 

func (b *Builder) Metrics() metrics.Metrics

func (*Builder) ReadOnlyResourceManager 

func (b *Builder) ReadOnlyResourceManager() core_manager.ReadOnlyResourceManager

func (*Builder) ResourceManager 

func (b *Builder) ResourceManager() core_manager.CustomizableResourceManager

func (*Builder) ResourceStore 

func (b *Builder) ResourceStore() core_store.ResourceStore

func (*Builder) SecretStore 

func (b *Builder) SecretStore() store.SecretStore

func (Builder) SetClusterId 

func (i Builder) SetClusterId(clusterId string)

func (*Builder) ShutdownCh 

func (b *Builder) ShutdownCh() <-chan struct{}

func (*Builder) WithAPIManager 

func (b *Builder) WithAPIManager(apim api_server.APIManager) *Builder

func (*Builder) WithCaManager 

func (b *Builder) WithCaManager(name string, cam core_ca.Manager) *Builder

func (*Builder) WithCaManagers 

func (b *Builder) WithCaManagers(cam core_ca.Managers) *Builder

func (*Builder) WithComponentManager 

func (b *Builder) WithComponentManager(cm component.Manager) *Builder

func (*Builder) WithConfigManager 

func (b *Builder) WithConfigManager(configm config_manager.ConfigManager) *Builder

func (*Builder) WithConfigStore 

func (b *Builder) WithConfigStore(cs core_store.ResourceStore) *Builder

func (*Builder) WithDNSResolver 

func (b *Builder) WithDNSResolver(dns resolver.DNSResolver) *Builder

func (*Builder) WithDataSourceLoader 

func (b *Builder) WithDataSourceLoader(loader datasource.Loader) *Builder

func (*Builder) WithDpServer 

func (b *Builder) WithDpServer(dps *dp_server.DpServer) *Builder

func (*Builder) WithEnvoyAdminClient 

func (b *Builder) WithEnvoyAdminClient(eac admin.EnvoyAdminClient) *Builder

func (*Builder) WithEventReaderFactory 

func (b *Builder) WithEventReaderFactory(erf events.ListenerFactory) *Builder

func (*Builder) WithExtension 

func (b *Builder) WithExtension(key interface{}, value interface{}) *Builder

func (*Builder) WithExtensions 

func (b *Builder) WithExtensions(ext context.Context) *Builder

func (*Builder) WithKDSContext 

func (b *Builder) WithKDSContext(kdsctx *kds_context.Context) *Builder

func (*Builder) WithLeaderInfo 

func (b *Builder) WithLeaderInfo(leadInfo component.LeaderInfo) *Builder

func (*Builder) WithLookupIP 

func (b *Builder) WithLookupIP(lif lookup.LookupIPFunc) *Builder

func (*Builder) WithMetrics 

func (b *Builder) WithMetrics(metrics metrics.Metrics) *Builder

func (*Builder) WithReadOnlyResourceManager 

func (b *Builder) WithReadOnlyResourceManager(rom core_manager.ReadOnlyResourceManager) *Builder

func (*Builder) WithResourceManager 

func (b *Builder) WithResourceManager(rm core_manager.CustomizableResourceManager) *Builder

func (*Builder) WithResourceStore 

func (b *Builder) WithResourceStore(rs core_store.ResourceStore) *Builder

func (*Builder) WithSecretStore 

func (b *Builder) WithSecretStore(ss store.SecretStore) *Builder

func (*Builder) WithXDSHooks 

func (b *Builder) WithXDSHooks(xdsh *xds_hooks.Hooks) *Builder

func (*Builder) XDSHooks 

func (b *Builder) XDSHooks() *xds_hooks.Hooks

type BuilderContext 

type BuilderContext interface {
	ComponentManager() component.Manager
	ResourceStore() core_store.ResourceStore
	SecretStore() store.SecretStore
	ConfigStore() core_store.ResourceStore
	ResourceManager() core_manager.CustomizableResourceManager
	Config() kuma_cp.Config
	DataSourceLoader() datasource.Loader
	Extensions() context.Context
	DNSResolver() resolver.DNSResolver
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	Metrics() metrics.Metrics
	EventReaderFactory() events.ListenerFactory
	APIManager() api_server.APIManager
	XDSHooks() *xds_hooks.Hooks
	DpServer() *dp_server.DpServer
	KDSContext() *kds_context.Context
}

BuilderContext provides access to Builder's interim state.

type Runtime 

type Runtime interface {
	RuntimeInfo
	RuntimeContext
	component.Manager
}

Runtime represents initialized application state.

type RuntimeContext 

type RuntimeContext interface {
	Config() kuma_cp.Config
	DataSourceLoader() datasource.Loader
	ResourceManager() core_manager.ResourceManager
	ResourceStore() core_store.ResourceStore
	ReadOnlyResourceManager() core_manager.ReadOnlyResourceManager
	SecretStore() store.SecretStore
	ConfigStore() core_store.ResourceStore
	CaManagers() ca.Managers
	Extensions() context.Context
	DNSResolver() resolver.DNSResolver
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	LookupIP() lookup.LookupIPFunc
	EnvoyAdminClient() admin.EnvoyAdminClient
	Metrics() metrics.Metrics
	EventReaderFactory() events.ListenerFactory
	APIInstaller() api_server.APIInstaller
	XDSHooks() *xds_hooks.Hooks
	DpServer() *dp_server.DpServer
	KDSContext() *kds_context.Context
	ShutdownCh() <-chan struct{}
}

type RuntimeInfo 

type RuntimeInfo interface {
	GetInstanceId() string
	SetClusterId(clusterId string)
	GetClusterId() 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.