strategies

Documentation

Index

• Variables
• func WithRPC(rpc nervous.Controller) option
• func WithRecorder(recorder supbapis.Recorder) option
• type SupbStrategy
  • func NewSupbStrategy(ctx context.Context, prefix string) *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)

Variables

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

func WithRecorder(recorder supbapis.Recorder) option

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)