clustercontroller

Documentation

Index

• type ClusterController
  • func New(id int, user user.User, status chan<- control.UserStatus) (*ClusterController, 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) 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.