export

Documentation

Index

• type AppID
• type IAppConfig
• type IClusterGlobalConfig
• type IConfig
• type IGlobalConfig
• type ILogic
• type IService
• type IServiceConfig
• type IServiceConfigInApp
• type IServiceGlobalConfig
• type LogicID
• type Payload
• type ServiceID

Types

type AppID

type AppID = int

type IAppConfig

type IAppConfig interface {
	IConfig

	GetPprofIP() string
	GetPprofPort() int
	GetEndpointIP() string
	GetEndpointPort() int
	EachServiceConfig(func(index int, iServiceConfig IServiceConfigInApp) (continued bool))
	GetServiceConfigByIndex(index int) (IServiceConfigInApp, bool)
	AddServiceConfig(iServiceConfig IServiceConfigInApp)
	GetLogDir() string
	GetStartServiceIntervalMSec() time.Duration
	GetStopServiceIntervalMSec() time.Duration
	GetExitWaitSec() time.Duration
	Clone() IServiceConfig
}

type IClusterGlobalConfig

type IClusterGlobalConfig interface {
	IGlobalConfig
	Clone() IClusterGlobalConfig
}

type IConfig

type IConfig interface {
	TidyAndCheck() error
	GetID() int
	SetID(id int)
}

type IGlobalConfig

type IGlobalConfig interface {
	TidyAndCheck() error
}

type ILogic

type ILogic interface {
	ID() LogicID
	Init() (err error)
	Run()
	Finish()
	OnActorTerminated(who *actor.PID, ctx actor.Context)
	OnPulse(ctx actor.Context)
}

type IService

type IService interface {
	Init(appConfig IAppConfig, serviceID ServiceID, startedWg *sync.WaitGroup, stoppedWg *sync.WaitGroup, args ...interface{}) error
	Run(ctx actor.Context, pprofAddress string, args ...interface{}) error
	Stop() error
}

type IServiceConfig

type IServiceConfig interface {
	IConfig
	Clone() IServiceConfig
}

type IServiceConfigInApp

type IServiceConfigInApp interface {
	GetName() string
	GetID() ServiceID
	Clone() IServiceConfigInApp
}

type IServiceGlobalConfig

type IServiceGlobalConfig interface {
	IGlobalConfig
	Clone() IServiceGlobalConfig
}

type LogicID

type LogicID = int

type Payload

type Payload = int

type ServiceID

type ServiceID = int