runtime

Documentation

Index

• func Annul(name string)
• func Notify(n *database.Notification)
• func Register(name string) chan *database.Notification
• func Run(w string)
• func StartOperate(cluster *database.Cluster, config *LaunchParameters) error
• func StopOperate()
• type LaunchParameters
• type RunningStatus
  • func RetrieveStatus(clusterID string) (*RunningStatus, error)
• type Runtime

Functions

func Annul

func Annul(name string)

Annul - annul a websocket client

func Notify

func Notify(n *database.Notification)

Notify - notify to runtime a ansible callback message

func Register

func Register(name string) chan *database.Notification

Register - register a websocket client for receive notification

func Run

func Run(w string)

Run - start command & runtime

func StartOperate

func StartOperate(cluster *database.Cluster, config *LaunchParameters) error

StartOperate - start operate a cluster

func StopOperate

func StopOperate()

StopOperate - stop a cluser's operation

Types

type LaunchParameters

type LaunchParameters struct {
	Operation  string            `json:"operation"`
	Components []string          `json:"components"`
	Cluster    *database.Cluster `json:"-"`
}

LaunchParameters - needed when start operate a cluser

type RunningStatus

type RunningStatus struct {
	Stages       []string `json:"stages"`
	CurrentStage string   `json:"currentStage"`
}

RunningStatus - record a cluster running status

func RetrieveStatus

func RetrieveStatus(clusterID string) (*RunningStatus, error)

RetrieveStatus - retrieve a cluster runtime status

type Runtime

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

Runtime all cluster in Runtime wschans should have cluster name as key if want to support multiple clusters be installing currently