ct_autoscaler

Documentation

Index

• Constants
• type CTAutoscaler
  • func NewCTAutoscaler(local bool) (*CTAutoscaler, error)
  • func (c *CTAutoscaler) RegisterGCETask(taskId string) error
  • func (c *CTAutoscaler) UnregisterGCETask(taskId string) error
• type ICTAutoscaler
• type MockCTAutoscaler
  • func (m *MockCTAutoscaler) RegisterGCETask(taskId string) error
  • func (m *MockCTAutoscaler) UnregisterGCETask(taskId string) error

Constants

const (
	MIN_CT_INSTANCE_NUM = 1
	MAX_CT_INSTANCE_NUM = 500
)

Types

type CTAutoscaler

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

The CTAutoscaler is a CT friendly wrapper around autoscaler.Autoscaller It does the following:

• Automatically brings up all CT GCE instances when a GCE task is registered and no other GCE tasks are running.
• Automatically brings down all CT GCE instances when there are no registered GCE tasks.

func NewCTAutoscaler

func NewCTAutoscaler(local bool) (*CTAutoscaler, error)

NewCTAutoscaler returns a CT Autoscaler instance.

func (*CTAutoscaler) RegisterGCETask

func (c *CTAutoscaler) RegisterGCETask(taskId string) error

func (*CTAutoscaler) UnregisterGCETask

func (c *CTAutoscaler) UnregisterGCETask(taskId string) error

type ICTAutoscaler

type ICTAutoscaler interface {
	RegisterGCETask(taskId string) error
	UnregisterGCETask(taskId string) error
}

Interface useful for mocking.

type MockCTAutoscaler

type MockCTAutoscaler struct {
	RegisterGCETaskTimesCalled   int
	UnregisterGCETaskTimesCalled int
}

func (*MockCTAutoscaler) RegisterGCETask

func (m *MockCTAutoscaler) RegisterGCETask(taskId string) error

func (*MockCTAutoscaler) UnregisterGCETask

func (m *MockCTAutoscaler) UnregisterGCETask(taskId string) error