manager

Documentation

Index

• type Event
  • func NewEvent(eventCli record.EventRecorder) Event
• type EventOption
  • func (e *EventOption) CheckCluster(object runtime.Object)
  • func (e *EventOption) CreateCluster(object runtime.Object)
  • func (e *EventOption) EnsureCluster(object runtime.Object)
  • func (e *EventOption) FailedCluster(object runtime.Object, message string)
  • func (e *EventOption) HealthCluster(object runtime.Object)
  • func (e *EventOption) NewNodeAdd(object runtime.Object, message string)
  • func (e *EventOption) NodeRemove(object runtime.Object, message string)
  • func (e *EventOption) UpdateCluster(object runtime.Object, message string)
  • func (e *EventOption) UpgradedCluster(object runtime.Object, message string)
• type Executor
  • func NewExecutor(config *rest.Config) *Executor
  • func (e *Executor) ExecToPod(namespace, podName, containerName, command string, stdin io.Reader) (string, string, error)

Types

type Event

type Event interface {
	// NewSlaveAdd event ClusterScaling
	NewNodeAdd(object runtime.Object, message string)
	// SlaveRemove event ClusterScalingDown
	NodeRemove(object runtime.Object, message string)
	// CreateCluster event ClusterCreating
	CreateCluster(object runtime.Object)
	// UpdateCluster event ClusterUpdating
	UpdateCluster(object runtime.Object, message string)
	// UpgradedCluster event ClusterUpgrading
	UpgradedCluster(object runtime.Object, message string)
	// EnsureCluster event Ensure
	EnsureCluster(object runtime.Object)
	// CheckCluster event CheckAndHeal
	CheckCluster(object runtime.Object)
	// FailedCluster event ClusterFailed
	FailedCluster(object runtime.Object, message string)
	// HealthCluster event ClusterHealthy
	HealthCluster(object runtime.Object)
}

Event the client that push event to kubernetes

func NewEvent

func NewEvent(eventCli record.EventRecorder) Event

NewEvent returns a new Event client

type EventOption

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

EventOption is the Event client interface implementation that using API calls to kubernetes.

func (*EventOption) CheckCluster

func (e *EventOption) CheckCluster(object runtime.Object)

CheckCluster implement the Event.Interface

func (*EventOption) CreateCluster

func (e *EventOption) CreateCluster(object runtime.Object)

CreateCluster implement the Event.Interface

func (*EventOption) EnsureCluster

func (e *EventOption) EnsureCluster(object runtime.Object)

EnsureCluster implement the Event.Interface

func (*EventOption) FailedCluster

func (e *EventOption) FailedCluster(object runtime.Object, message string)

FailedCluster implement the Event.Interface

func (*EventOption) HealthCluster

func (e *EventOption) HealthCluster(object runtime.Object)

HealthCluster implement the Event.Interface

func (*EventOption) NewNodeAdd

func (e *EventOption) NewNodeAdd(object runtime.Object, message string)

NewNodeAdd implement the Event.Interface

func (*EventOption) NodeRemove

func (e *EventOption) NodeRemove(object runtime.Object, message string)

NodeRemove implement the Event.Interface

func (*EventOption) UpdateCluster

func (e *EventOption) UpdateCluster(object runtime.Object, message string)

UpdateCluster implement the Event.Interface

func (*EventOption) UpgradedCluster

func (e *EventOption) UpgradedCluster(object runtime.Object, message string)

UpgradedCluster implement the Event.Interface

type Executor

type Executor struct {
	Clientset kubernetes.Clientset
	Config    rest.Config
}

func NewExecutor

func NewExecutor(config *rest.Config) *Executor

func (*Executor) ExecToPod

func (e *Executor) ExecToPod(namespace, podName, containerName, command string, stdin io.Reader) (string, string, error)