runtime

package
v2.13.1 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2026 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Access 

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

type Builder 

type Builder struct {
	RuntimeInfo
	// 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 

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

func (*Builder) APIWebServiceCustomize 

func (b *Builder) APIWebServiceCustomize() []func(*restful.WebService) error

func (*Builder) Access 

func (b *Builder) Access() Access

func (*Builder) AppCtx 

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

func (*Builder) Build 

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

func (*Builder) CAProvider 

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) EnvoyAdminClient 

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

func (*Builder) EventBus 

func (b *Builder) EventBus() events.EventBus

func (*Builder) Extensions 

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

func (*Builder) ExtraReportsFn 

func (b *Builder) ExtraReportsFn() ExtraReportsFn

func (*Builder) GlobalInsightService 

func (b *Builder) GlobalInsightService() globalinsight.GlobalInsightService

func (*Builder) IdentityProviders added in v2.12.4 

func (b *Builder) IdentityProviders() providers.IdentityProviders

func (*Builder) InterCPClientPool 

func (b *Builder) InterCPClientPool() *client.Pool

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) MeshCache 

func (b *Builder) MeshCache() *mesh.Cache

func (*Builder) Metrics 

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

func (*Builder) PgxConfigCustomizationFn 

func (b *Builder) PgxConfigCustomizationFn() config.PgxConfigCustomization

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.CustomizableResourceStore

func (*Builder) ResourceValidators 

func (b *Builder) ResourceValidators() ResourceValidators

func (*Builder) SecretStore 

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

func (*Builder) Tenants 

func (b *Builder) Tenants() multitenant.Tenants

func (*Builder) TokenIssuers 

func (b *Builder) TokenIssuers() builtin.TokenIssuers

func (*Builder) Transactions 

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

func (*Builder) WithAPIManager 

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

func (*Builder) WithAPIServerAuthenticator 

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

func (*Builder) WithAPIWebServiceCustomize 

func (b *Builder) WithAPIWebServiceCustomize(customize func(*restful.WebService) error) *Builder

func (*Builder) WithAccess 

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

func (*Builder) WithCAProvider 

func (b *Builder) WithCAProvider(c 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) WithEventBus 

func (b *Builder) WithEventBus(erf events.EventBus) *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 

func (b *Builder) WithExtraReportsFn(fn ExtraReportsFn) *Builder

func (*Builder) WithGlobalInsightService 

func (b *Builder) WithGlobalInsightService(gis globalinsight.GlobalInsightService) *Builder

func (*Builder) WithIdentityProviders added in v2.12.4 

func (b *Builder) WithIdentityProviders(name string, identityProviders providers.IdentityProvider) *Builder

func (*Builder) WithInterCPClientPool 

func (b *Builder) WithInterCPClientPool(interCpPool *client.Pool) *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) WithMeshCache 

func (b *Builder) WithMeshCache(meshCache *mesh.Cache) *Builder

func (*Builder) WithMetrics 

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

func (*Builder) WithMultitenancy 

func (b *Builder) WithMultitenancy(tenants multitenant.Tenants) *Builder

func (*Builder) WithPgxConfigCustomizationFn 

func (b *Builder) WithPgxConfigCustomizationFn(pgxConfigCustomizationFn config.PgxConfigCustomization) *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.CustomizableResourceStore) *Builder

func (*Builder) WithResourceValidators 

func (b *Builder) WithResourceValidators(rv ResourceValidators) *Builder

func (*Builder) WithSecretStore 

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

func (*Builder) WithTokenIssuers 

func (b *Builder) WithTokenIssuers(tokenIssuers builtin.TokenIssuers) *Builder

func (*Builder) WithTransactions 

func (b *Builder) WithTransactions(txs core_store.Transactions) *Builder

func (*Builder) WithXDS 

func (b *Builder) WithXDS(xds xds_runtime.XDSRuntimeContext) *Builder

func (*Builder) XDS 

func (b *Builder) XDS() xds_runtime.XDSRuntimeContext

type BuilderContext 

type BuilderContext interface {
	ComponentManager() component.Manager
	ResourceStore() core_store.CustomizableResourceStore
	Transactions() core_store.Transactions
	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
	EventBus() events.EventBus
	APIManager() api_server.APIManager
	CAProvider() secrets.CaProvider
	DpServer() *dp_server.DpServer
	ResourceValidators() ResourceValidators
	KDSContext() *kds_context.Context
	APIServerAuthenticator() authn.Authenticator
	Access() Access
	TokenIssuers() builtin.TokenIssuers
	MeshCache() *mesh.Cache
	InterCPClientPool() *client.Pool
	PgxConfigCustomizationFn() config.PgxConfigCustomization
	Tenants() multitenant.Tenants
}

BuilderContext provides access to Builder's interim state.

type ExtraReportsFn 

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

type ResourceValidators 

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
	Transactions() core_store.Transactions
	ReadOnlyResourceManager() core_manager.ReadOnlyResourceManager
	SecretStore() store.SecretStore
	ConfigStore() core_store.ResourceStore
	GlobalInsightService() globalinsight.GlobalInsightService
	CaManagers() ca.Managers
	Extensions() context.Context
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	LookupIP() lookup.LookupIPFunc
	EnvoyAdminClient() admin.EnvoyAdminClient
	Metrics() metrics.Metrics
	EventBus() events.EventBus
	APIInstaller() api_server.APIInstaller
	XDS() xds_runtime.XDSRuntimeContext
	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
	TokenIssuers() builtin.TokenIssuers
	MeshCache() *mesh.Cache
	InterCPClientPool() *client.Pool
	PgxConfigCustomizationFn() config.PgxConfigCustomization
	Tenants() multitenant.Tenants
	APIWebServiceCustomize() func(ws *restful.WebService) error
	IdentityProviders() providers.IdentityProviders
}

type RuntimeInfo 

type RuntimeInfo interface {
	GetInstanceId() string
	SetClusterInfo(clusterId string, clusterCreationTime time.Time)
	GetClusterId() string
	GetClusterCreationTime() time.Time
	GetStartTime() time.Time
	GetMode() config_core.CpMode
}

func NewRuntimeInfo added in v2.10.9 

func NewRuntimeInfo(instanceId string, mode config_core.CpMode) RuntimeInfo

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.