runtime

package
v1.8.1 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Access added in v1.8.1 

type Access struct {
	ResourceAccess       resources_access.ResourceAccess
	DataplaneTokenAccess tokens_access.DataplaneTokenAccess
	ZoneTokenAccess      zone_access.ZoneTokenAccess
	EnvoyAdminAccess     access.EnvoyAdminAccess
}

type Builder 

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

Builder represents a multi-step initialization process.

func BuilderFor 

func BuilderFor(appCtx context.Context, cfg kuma_cp.Config) (*Builder, error)

func (*Builder) APIManager 

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

func (*Builder) APIServerAuthenticator added in v1.8.1 

func (b *Builder) APIServerAuthenticator() authn.Authenticator

func (*Builder) Access added in v1.8.1 

func (b *Builder) Access() Access

func (*Builder) AppCtx added in v1.8.1 

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

func (*Builder) Build 

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

func (*Builder) CAProvider added in v1.8.1 

func (b *Builder) CAProvider() secrets.CaProvider

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) 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) ExtraReportsFn added in v1.8.1 

func (b *Builder) ExtraReportsFn() ExtraReportsFn

func (Builder) GetClusterId 

func (i Builder) GetClusterId() string

func (Builder) GetInstanceId 

func (i Builder) GetInstanceId() string

func (Builder) GetStartTime added in v1.8.1 

func (i Builder) GetStartTime() time.Time

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) ResourceValidators added in v1.8.1 

func (b *Builder) ResourceValidators() ResourceValidators

func (*Builder) SecretStore 

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

func (Builder) SetClusterId 

func (i Builder) SetClusterId(clusterId string)

func (*Builder) WithAPIManager 

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

func (*Builder) WithAPIServerAuthenticator added in v1.8.1 

func (b *Builder) WithAPIServerAuthenticator(au authn.Authenticator) *Builder

func (*Builder) WithAccess added in v1.8.1 

func (b *Builder) WithAccess(acc Access) *Builder

func (*Builder) WithCAProvider added in v1.8.1 

func (b *Builder) WithCAProvider(cap secrets.CaProvider) *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) 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) WithExtraReportsFn added in v1.8.1 

func (b *Builder) WithExtraReportsFn(fn ExtraReportsFn) *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) WithResourceValidators added in v1.8.1 

func (b *Builder) WithResourceValidators(rv ResourceValidators) *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
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	Metrics() metrics.Metrics
	EventReaderFactory() events.ListenerFactory
	APIManager() api_server.APIManager
	XDSHooks() *xds_hooks.Hooks
	CAProvider() secrets.CaProvider
	DpServer() *dp_server.DpServer
	ResourceValidators() ResourceValidators
	KDSContext() *kds_context.Context
	APIServerAuthenticator() authn.Authenticator
	Access() Access
}

BuilderContext provides access to Builder's interim state.

type ExtraReportsFn added in v1.8.1 

type ExtraReportsFn func(Runtime) (map[string]string, error)

type ResourceValidators added in v1.8.1 

type ResourceValidators struct {
	Dataplane managers_dataplane.Validator
	Mesh      managers_mesh.MeshValidator
}

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
	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
	CAProvider() secrets.CaProvider
	DpServer() *dp_server.DpServer
	KDSContext() *kds_context.Context
	APIServerAuthenticator() authn.Authenticator
	ResourceValidators() ResourceValidators
	Access() Access
	// AppContext returns a context.Context which tracks the lifetime of the apps, it gets cancelled when the app is starting to shutdown.
	AppContext() context.Context
	ExtraReportsFn() ExtraReportsFn
}

type RuntimeInfo 

type RuntimeInfo interface {
	GetInstanceId() string
	SetClusterId(clusterId string)
	GetClusterId() string
	GetStartTime() time.Time
}

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.