internal

package
v0.2.7 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	APP_HOST_FIELD             string = "Host"
	APP_CONFIG_FIELD           string = "Config"
	APP_SERVICE_PROVIDER_FIELD string = "ServiceProvider"
	APP_COMPONENT_INIT_METHOD  string = "Init"

	LOGGER_PREFIX string = "[host] "
)

Variables

This section is empty.

Functions

func RegisterHostModule 

func RegisterHostModule(starter *Starter, host HostModule)

Types

type App 

type App interface {
	Init()
	OnInit()
	OnInitComplete()
	OnStart(ctx context.Context)
	OnStop(ctx context.Context)
}

type AppHostHelper 

type AppHostHelper struct {
	App *AppModule
}

func (*AppHostHelper) OnErrorEventHandler 

func (h *AppHostHelper) OnErrorEventHandler() HostOnErrorEventHandler

type AppModule 

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

func NewAppModule 

func NewAppModule(target interface{}) *AppModule

func (*AppModule) Config 

func (module *AppModule) Config() reflect.Value

func (*AppModule) Field 

func (module *AppModule) Field(name string) reflect.Value

func (*AppModule) Host 

func (module *AppModule) Host() reflect.Value

func (*AppModule) Logger 

func (module *AppModule) Logger() *log.Logger

func (*AppModule) ServiceProvider 

func (module *AppModule) ServiceProvider() reflect.Value

func (*AppModule) TextMapPropagator 

func (module *AppModule) TextMapPropagator() propagation.TextMapPropagator

func (*AppModule) TracerProvider 

func (module *AppModule) TracerProvider() *trace.SeverityTracerProvider

type AppProxy 

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

func (AppProxy) Init 

func (proxy AppProxy) Init()

Init implements App

func (AppProxy) OnInit 

func (proxy AppProxy) OnInit()

OnInit implements App

func (AppProxy) OnInitComplete 

func (proxy AppProxy) OnInitComplete()

OnInitComplete implements App

func (AppProxy) OnStart 

func (proxy AppProxy) OnStart(ctx context.Context)

OnStart implements App

func (AppProxy) OnStop 

func (proxy AppProxy) OnStop(ctx context.Context)

OnStop implements App

type AppService 

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

func (*AppService) Init 

func (s *AppService) Init(service InjectionService)

func (*AppService) InitComplete 

func (s *AppService) InitComplete()

func (*AppService) LoadComponent 

func (s *AppService) LoadComponent()

func (*AppService) LoadConfiguration 

func (s *AppService) LoadConfiguration()

func (*AppService) LoadMiddleware 

func (s *AppService) LoadMiddleware()

func (*AppService) Start 

func (s *AppService) Start(ctx context.Context)

func (*AppService) Stop 

func (s *AppService) Stop(ctx context.Context) error

type AppServiceBuilder 

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

func NewAppServiceBuilder 

func NewAppServiceBuilder(logger *log.Logger) *AppServiceBuilder

func (*AppServiceBuilder) AppModule 

func (builder *AppServiceBuilder) AppModule(app *AppModule) *AppServiceBuilder

func (*AppServiceBuilder) Build 

func (builder *AppServiceBuilder) Build() *AppService

func (*AppServiceBuilder) BuildHostService 

func (builder *AppServiceBuilder) BuildHostService() *HostService

func (*AppServiceBuilder) ConfigureConfigurationAction 

func (builder *AppServiceBuilder) ConfigureConfigurationAction(action ConfigurationLoader) *AppServiceBuilder

func (*AppServiceBuilder) HostModule 

func (builder *AppServiceBuilder) HostModule(host HostModule) *AppServiceBuilder

func (*AppServiceBuilder) Middlewares 

func (builder *AppServiceBuilder) Middlewares(middlewares []Middleware) *AppServiceBuilder

type AppStaterConfigurator 

type AppStaterConfigurator interface {
	ConfigureLogger(logger *log.Logger)
	Logger() *log.Logger
}

type AppStaterConfiguratorProxy 

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

func (AppStaterConfiguratorProxy) ConfigureLogger 

func (proxy AppStaterConfiguratorProxy) ConfigureLogger(logger *log.Logger)

ConfigureLogger implements AppStaterConfigurator

func (AppStaterConfiguratorProxy) Logger 

func (proxy AppStaterConfiguratorProxy) Logger() *log.Logger

ConfigureLogger implements AppStaterConfigurator

type AppTracingConfigurator 

type AppTracingConfigurator interface {
	ConfigureTextMapPropagator()
	ConfigureTracerProvider()
	TextMapPropagator() propagation.TextMapPropagator
	TracerProvider() *trace.SeverityTracerProvider
}

type AppTracingConfiguratorProxy 

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

func (AppTracingConfiguratorProxy) ConfigureTextMapPropagator 

func (proxy AppTracingConfiguratorProxy) ConfigureTextMapPropagator()

ConfigureTextMapPropagator implements tracing.AppTracingConfigurator

func (AppTracingConfiguratorProxy) ConfigureTracerProvider 

func (proxy AppTracingConfiguratorProxy) ConfigureTracerProvider()

ConfigureTracerProvider implements tracing.AppTracingConfigurator

func (AppTracingConfiguratorProxy) TextMapPropagator 

func (proxy AppTracingConfiguratorProxy) TextMapPropagator() propagation.TextMapPropagator

TextMapPropagator implements tracing.AppTracingConfigurator

func (AppTracingConfiguratorProxy) TracerProvider 

func (proxy AppTracingConfiguratorProxy) TracerProvider() *trace.SeverityTracerProvider

TracerProvider implements tracing.AppTracingConfigurator

type ComponentService 

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

func NewComponentService 

func NewComponentService(logger *log.Logger) *ComponentService

func (*ComponentService) RegisterComponent 

func (m *ComponentService) RegisterComponent(component Runable)

func (*ComponentService) Start 

func (m *ComponentService) Start()

func (*ComponentService) Stop 

func (m *ComponentService) Stop()

type ConfigurationLoader 

type ConfigurationLoader func(service *config.ConfigurationService)

type Host 

type Host interface {
	Start(ctx context.Context)
	Stop(ctx context.Context) error
}

type HostModule 

type HostModule interface {
	Init(host Host, app *AppModule)
	InitComplete(host Host, app *AppModule)
	DescribeHostType() reflect.Type
	ConfigureLogger(logflags int, w io.Writer)
}

func NopHostServiceInstance 

func NopHostServiceInstance() HostModule

type HostOnErrorEventHandler 

type HostOnErrorEventHandler interface {
	OnError(err error) (disposed bool)
}

type HostService 

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

func (*HostService) ConfigureLogger 

func (m *HostService) ConfigureLogger(logflags int, w io.Writer)

func (*HostService) Init 

func (m *HostService) Init(app *AppModule)

func (*HostService) InitComplete 

func (m *HostService) InitComplete(app *AppModule)

func (*HostService) Start 

func (m *HostService) Start(ctx context.Context)

func (*HostService) Stop 

func (m *HostService) Stop(ctx context.Context) error

type InjectionService 

type InjectionService interface {
	// contains filtered or unexported methods
}

type Middleware 

type Middleware interface {
	Init(app *AppModule)
}

type NopHostModule 

type NopHostModule struct{}

func (NopHostModule) ConfigureLogger 

func (s NopHostModule) ConfigureLogger(logflags int, w io.Writer)

func (NopHostModule) DescribeHostType 

func (s NopHostModule) DescribeHostType() reflect.Type

func (NopHostModule) Init 

func (s NopHostModule) Init(host Host, app *AppModule)

func (NopHostModule) InitComplete 

func (s NopHostModule) InitComplete(host Host, app *AppModule)

func (NopHostModule) OnError 

func (s NopHostModule) OnError(err error)

type ReflectHelper 

type ReflectHelper reflect.Value

func (ReflectHelper) As 

func (f ReflectHelper) As(typ reflect.Type) ReflectHelper

func (ReflectHelper) MakeGetter 

func (f ReflectHelper) MakeGetter() interface{}

func (ReflectHelper) Value 

func (f ReflectHelper) Value() reflect.Value

type Runable 

type Runable interface {
	Runner() Runner
}

type Runner 

type Runner interface {
	Start()
	Stop()
}

type Starter 

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

func NewStarter 

func NewStarter(app interface{}) *Starter

func (*Starter) ConfigureConfiguration 

func (s *Starter) ConfigureConfiguration(action ConfigurationLoader) *Starter

func (*Starter) Middlewares 

func (s *Starter) Middlewares(middlewares ...Middleware) *Starter

func (*Starter) Run 

func (s *Starter) Run()

func (*Starter) Start 

func (s *Starter) Start(ctx context.Context) error

func (*Starter) Stop 

func (s *Starter) Stop(ctx context.Context) error

type StarterLogger 

type StarterLogger struct {
	Flags  int
	Logger *fxevent.ConsoleLogger
}

func (*StarterLogger) LogEvent 

func (l *StarterLogger) LogEvent(event fxevent.Event)

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.