runtime

package
v0.0.0-...-0a426dc Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2024 License: Apache-2.0 Imports: 28 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(appCtx context.Context, cfg dubbo_cp.Config) (*Builder, error)

func (*Builder) AdminRegistry 

func (b *Builder) AdminRegistry() *registry.Registry

func (*Builder) AppCtx 

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

func (*Builder) AppRegCtx 

func (b *Builder) AppRegCtx() *registry.ApplicationContext

func (*Builder) Build 

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

func (*Builder) ComponentManager 

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

func (*Builder) Config 

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

func (*Builder) ConfigCenter 

func (b *Builder) ConfigCenter() config_center.DynamicConfiguration

func (*Builder) ConfigManager 

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

func (*Builder) ConfigStore 

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

func (*Builder) DDSContext 

func (b *Builder) DDSContext() *dds_context.Context

func (*Builder) DataplaneCache 

func (b *Builder) DataplaneCache() *sync.Map

func (*Builder) DpServer 

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

func (*Builder) EventBus 

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

func (*Builder) Extensions 

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

func (Builder) GetClusterId 

func (i Builder) GetClusterId() string

func (Builder) GetDeployMode 

func (i Builder) GetDeployMode() core.DeployMode

func (Builder) GetInstanceId 

func (i Builder) GetInstanceId() string

func (Builder) GetMode 

func (i Builder) GetMode() core.CpMode

func (Builder) GetStartTime 

func (i Builder) GetStartTime() time.Time

func (*Builder) Governance 

func (b *Builder) Governance() governance.GovernanceConfig

func (*Builder) InfRegCtx 

func (b *Builder) InfRegCtx() *registry.InterfaceContext

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

func (b *Builder) MetadataReportCenter() report.MetadataReport

func (*Builder) ReadOnlyResourceManager 

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

func (*Builder) RegClient 

func (b *Builder) RegClient() reg_client.RegClient

func (*Builder) RegistryCenter 

func (b *Builder) RegistryCenter() dubboRegistry.Registry

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

func (b *Builder) ServiceDiscovery() dubboRegistry.ServiceDiscovery

func (Builder) SetClusterId 

func (i Builder) SetClusterId(clusterId string)

func (*Builder) Transactions 

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

func (*Builder) WithAdminRegistry 

func (b *Builder) WithAdminRegistry(ag *registry.Registry) *Builder

func (*Builder) WithAppRegCtx 

func (b *Builder) WithAppRegCtx(ctx *registry.ApplicationContext) *Builder

func (*Builder) WithComponentManager 

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

func (*Builder) WithConfigCenter 

func (b *Builder) WithConfigCenter(cc config_center.DynamicConfiguration) *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) WithDDSContext 

func (b *Builder) WithDDSContext(ddsctx *dds_context.Context) *Builder

func (*Builder) WithDataSourceLoader 

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

func (*Builder) WithDataplaneCache 

func (b *Builder) WithDataplaneCache(cache *sync.Map) *Builder

func (*Builder) WithDpServer 

func (b *Builder) WithDpServer(dps *dp_server.DpServer) *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) WithGovernanceConfig 

func (b *Builder) WithGovernanceConfig(gc governance.GovernanceConfig) *Builder

func (*Builder) WithInfRegCtx 

func (b *Builder) WithInfRegCtx(ctx *registry.InterfaceContext) *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) WithMetadataReport 

func (b *Builder) WithMetadataReport(mr report.MetadataReport) *Builder

func (*Builder) WithReadOnlyResourceManager 

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

func (*Builder) WithRegClient 

func (b *Builder) WithRegClient(regClient reg_client.RegClient) *Builder

func (*Builder) WithRegistryCenter 

func (b *Builder) WithRegistryCenter(rg dubboRegistry.Registry) *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) WithServiceDiscovery 

func (b *Builder) WithServiceDiscovery(discovery dubboRegistry.ServiceDiscovery) *Builder

func (*Builder) WithTransactions 

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

type BuilderContext 

type BuilderContext interface {
	ComponentManager() component.Manager
	ResourceStore() core_store.CustomizableResourceStore
	Transactions() core_store.Transactions
	ConfigStore() core_store.ResourceStore
	ResourceManager() core_manager.CustomizableResourceManager
	Config() dubbo_cp.Config
	RegistryCenter() dubboRegistry.Registry
	RegClient() reg_client.RegClient
	MetadataReportCenter() report.MetadataReport
	AdminRegistry() *registry.Registry
	ServiceDiscovery() dubboRegistry.ServiceDiscovery
	ConfigCenter() config_center.DynamicConfiguration
	Governance() governance.GovernanceConfig
	Extensions() context.Context
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	EventBus() events.EventBus
	DpServer() *dp_server.DpServer
	DataplaneCache() *sync.Map
	DDSContext() *dds_context.Context
	ResourceValidators() ResourceValidators
	AppRegCtx() *registry.ApplicationContext
	InfRegCtx() *registry.InterfaceContext
}

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() dubbo_cp.Config
	ResourceManager() core_manager.ResourceManager
	Transactions() core_store.Transactions
	ReadOnlyResourceManager() core_manager.ReadOnlyResourceManager
	ConfigStore() core_store.ResourceStore
	Extensions() context.Context
	ConfigManager() config_manager.ConfigManager
	LeaderInfo() component.LeaderInfo
	EventBus() events.EventBus
	DpServer() *dp_server.DpServer
	DataplaneCache() *sync.Map
	DDSContext() *dds_context.Context
	RegistryCenter() dubboRegistry.Registry
	ServiceDiscovery() dubboRegistry.ServiceDiscovery
	MetadataReportCenter() report.MetadataReport
	Governance() governance.GovernanceConfig
	ConfigCenter() config_center.DynamicConfiguration
	AdminRegistry() *registry.Registry
	RegClient() reg_client.RegClient
	ResourceValidators() ResourceValidators
	// 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
	XDS() xds_runtime.XDSRuntimeContext
	MeshCache() *mesh.Cache
}

type RuntimeInfo 

type RuntimeInfo interface {
	GetInstanceId() string
	SetClusterId(clusterId string)
	GetClusterId() string
	GetStartTime() time.Time
	GetMode() core.CpMode
	GetDeployMode() core.DeployMode
}

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.