clustercontroller

Documentation

Index

• type ClusterController
  • func New(id int, user user.User, status chan<- control.UserStatus) (*ClusterController, error)
  • func (c *ClusterController) InjectAction(actionID string) error
  • func (c *ClusterController) Run()
  • func (c *ClusterController) SetRate(rate float64) error
  • func (c *ClusterController) Stop()

Types

type ClusterController

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

func New

func New(id int, user user.User, status chan<- control.UserStatus) (*ClusterController, error)

func (*ClusterController) InjectAction

func (c *ClusterController) InjectAction(actionID string) error

InjectAction allows a named UserAction to be injected that is run once, at the next available opportunity. These actions can be injected via the coordinator via CLI or Rest API.

func (*ClusterController) Run

func (c *ClusterController) Run()

Run begins performing a set of actions in a loop with a defined wait in between the actions. It keeps on doing it until Stop is invoked. This is also a blocking function, so it is recommended to invoke it inside a goroutine.

func (*ClusterController) SetRate

func (c *ClusterController) SetRate(rate float64) error

SetRate sets the relative speed of execution of actions by the user.

func (*ClusterController) Stop

func (c *ClusterController) Stop()

Stop stops the controller.