manager_strategies

Documentation

Index

• Constants
• type StrategiesManager
  • func NewStrategiesManager(ctx context.Context, d StrategiesRecorder, user, userToken string) *StrategiesManager
  • func (r *StrategiesManager) DeleteRunningStrategy(guid string) error
  • func (r *StrategiesManager) DeleteStaticStrategy(name string) error
  • func (r *StrategiesManager) ExistRunningStrategy(guid string) bool
  • func (r *StrategiesManager) ExistStaticStrategy(name string) bool
  • func (r *StrategiesManager) GetRunningStrategy(guid string) (*strategies.Strategy, error)
  • func (r *StrategiesManager) GetStaticStrategy(name string) (*strategies.Strategy, error)
  • func (r *StrategiesManager) ListRunningStrategy() map[string]*strategies.Strategy
  • func (r *StrategiesManager) ListRunningStrategyReturnList() []*strategies.Strategy
  • func (r *StrategiesManager) ListStaticStrategy() map[string]*strategies.Strategy
  • func (r *StrategiesManager) ListStaticStrategyReturnList() []*strategies.Strategy
  • func (r *StrategiesManager) LoadStaticStrategy(name string) error
  • func (r *StrategiesManager) PullStaticStrategy(name string) (string, error)
  • func (r *StrategiesManager) PushStaticStrategy(data string) error
  • func (r *StrategiesManager) StopRunningStrategy(guid string) error
  • func (r *StrategiesManager) UpdateRunningStrategy(guid string, s *strategies.Strategy) error
  • func (r *StrategiesManager) UpdateStaticStrategy(name string, s *strategies.Strategy) error
  • func (r *StrategiesManager) UploadRunningStrategy(guid string) error
• type StrategiesRecorder

Constants

const (
	StaticStrategiesSavePathPrefixFormat  = "/repository/superbahnManager/strategies/static/%v/"
	RunningStrategiesSavePathPrefixFormat = "/repository/superbahnManager/strategies/running/%v/"
)

Types

type StrategiesManager

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

func NewStrategiesManager

func NewStrategiesManager(ctx context.Context, d StrategiesRecorder, user, userToken string) *StrategiesManager

func (*StrategiesManager) DeleteRunningStrategy

func (r *StrategiesManager) DeleteRunningStrategy(guid string) error

func (*StrategiesManager) DeleteStaticStrategy

func (r *StrategiesManager) DeleteStaticStrategy(name string) error

func (*StrategiesManager) ExistRunningStrategy

func (r *StrategiesManager) ExistRunningStrategy(guid string) bool

func (*StrategiesManager) ExistStaticStrategy

func (r *StrategiesManager) ExistStaticStrategy(name string) bool

func (*StrategiesManager) GetRunningStrategy

func (r *StrategiesManager) GetRunningStrategy(guid string) (*strategies.Strategy, error)

func (*StrategiesManager) GetStaticStrategy

func (r *StrategiesManager) GetStaticStrategy(name string) (*strategies.Strategy, error)

func (*StrategiesManager) ListRunningStrategy

func (r *StrategiesManager) ListRunningStrategy() map[string]*strategies.Strategy

func (*StrategiesManager) ListRunningStrategyReturnList

func (r *StrategiesManager) ListRunningStrategyReturnList() []*strategies.Strategy

func (*StrategiesManager) ListStaticStrategy

func (r *StrategiesManager) ListStaticStrategy() map[string]*strategies.Strategy

func (*StrategiesManager) ListStaticStrategyReturnList

func (r *StrategiesManager) ListStaticStrategyReturnList() []*strategies.Strategy

func (*StrategiesManager) LoadStaticStrategy

func (r *StrategiesManager) LoadStaticStrategy(name string) error

func (*StrategiesManager) PullStaticStrategy

func (r *StrategiesManager) PullStaticStrategy(name string) (string, error)

func (*StrategiesManager) PushStaticStrategy

func (r *StrategiesManager) PushStaticStrategy(data string) error

func (*StrategiesManager) StopRunningStrategy

func (r *StrategiesManager) StopRunningStrategy(guid string) error

func (*StrategiesManager) UpdateRunningStrategy

func (r *StrategiesManager) UpdateRunningStrategy(guid string, s *strategies.Strategy) error

func (*StrategiesManager) UpdateStaticStrategy

func (r *StrategiesManager) UpdateStaticStrategy(name string, s *strategies.Strategy) error

func (*StrategiesManager) UploadRunningStrategy

func (r *StrategiesManager) UploadRunningStrategy(guid string) error

type StrategiesRecorder

type StrategiesRecorder interface {
	Put(string, string) error
	Get(string) ([]byte, error)
	GetWithPrefix(string) (map[string][]byte, error)
	Del(string) error
}