Documentation
¶
Index ¶
- Variables
- func WithRPC(rpc nervous.Controller) option
- func WithRecorder(recorder supbapis.Recorder) option
- type SupbStrategy
- func (r *SupbStrategy) Close() error
- func (r *SupbStrategy) InitFlags(flags *pflag.FlagSet)
- func (r *SupbStrategy) InitViper(viper *viper.Viper)
- func (r *SupbStrategy) Initialize(opts ...option)
- func (r *SupbStrategy) OptionConfig(opts ...option)
- func (r *SupbStrategy) Run()
- func (r *SupbStrategy) ViperConfig(viper *viper.Viper)
Constants ¶
This section is empty.
Variables ¶
View Source
var Executors = map[string]func(ctx context.Context, tryTime, tryInterval int, logger log.Logger, rpc nervous.Controller, meta *m1.SupbStrategyBaseInfo, updateMeta <-chan *m1.SupbStrategyBaseInfo){ "algorithmName": sine.Executor, "car": car.Executor, "simcar": simcar.Executor, }
Functions ¶
func WithRPC ¶
func WithRPC(rpc nervous.Controller) option
func WithRecorder ¶
Types ¶
type SupbStrategy ¶
type SupbStrategy struct {
// contains filtered or unexported fields
}
func NewSupbStrategy ¶
func NewSupbStrategy(ctx context.Context, prefix string) *SupbStrategy
func (*SupbStrategy) Close ¶
func (r *SupbStrategy) Close() error
func (*SupbStrategy) InitFlags ¶
func (r *SupbStrategy) InitFlags(flags *pflag.FlagSet)
func (*SupbStrategy) InitViper ¶
func (r *SupbStrategy) InitViper(viper *viper.Viper)
func (*SupbStrategy) Initialize ¶
func (r *SupbStrategy) Initialize(opts ...option)
func (*SupbStrategy) OptionConfig ¶
func (r *SupbStrategy) OptionConfig(opts ...option)
func (*SupbStrategy) Run ¶
func (r *SupbStrategy) Run()
func (*SupbStrategy) ViperConfig ¶
func (r *SupbStrategy) ViperConfig(viper *viper.Viper)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.