runtime

package
v0.0.0-...-ed9dbbb Latest Latest
Warning

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

Go to latest
Published: Dec 19, 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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL