openshift

Documentation

Index

• func FigureStdout(stdout string, columns map[string][]interface{}) (result []map[string]interface{}, err error)
• func GenerateOCLoginCMD(server string, username string, password string, clusterid string, ...) string
• func OcLogin(ocLoginAtter OcAttributes) (string, error)
• func RestartMUOPods(connection *client.Connection, clusterID string) error
• func RetryCMDRun(cmd string, timeout time.Duration) (string, error)
• func WaitClusterUpgradeFinished(connection *client.Connection, clusterID string) error
• func WaitForOperatorsToBeReady(connection *client.Connection, clusterID string, timeout int) error
• func WaitForUpgradePolicyToState(connection *client.Connection, clusterID string, policyID string, state string, ...) error
• type Console
  • func NewConsole(clusterID string, connection *client.Connection) (console *Console, err error)
  • func (c *Console) Config(kubeConfig string) (*Console, error)
  • func (c *Console) GetClusterVersion() (version string, err error)
  • func (c *Console) GetPods(namespace ...string) ([]*Pod, error)
  • func (c *Console) IsConfiged() bool
• type OcAttributes
• type Pod

Functions

func FigureStdout

func FigureStdout(stdout string, columns map[string][]interface{}) (result []map[string]interface{}, err error)

will return [map["NAME":"ip-10-0-130-210.us-east-2.compute.internal","STATUS":"Ready","ROLES":"worker"...]]

func GenerateOCLoginCMD

func GenerateOCLoginCMD(server string, username string, password string, clusterid string, additioanlFlags ...string) string

func OcLogin

func OcLogin(ocLoginAtter OcAttributes) (string, error)

func RestartMUOPods

func RestartMUOPods(connection *client.Connection, clusterID string) error

func RetryCMDRun

func RetryCMDRun(cmd string, timeout time.Duration) (string, error)

func WaitClusterUpgradeFinished

func WaitClusterUpgradeFinished(connection *client.Connection, clusterID string) error

func WaitForOperatorsToBeReady

func WaitForOperatorsToBeReady(connection *client.Connection, clusterID string, timeout int) error

func WaitForUpgradePolicyToState

func WaitForUpgradePolicyToState(connection *client.Connection, clusterID string, policyID string, state string, timeout int) error

WaitForUpgradePolicyToState will time out after <timeout> minutes Be careful for state completed. Make sure the automatic policy is in status of other status rather than pending

Types

type Console

type Console struct {
	ClusterName string
	ClusterID   string
	KubePath    string
	Private     bool
}

Console is openshift webconsole struct

func NewConsole

func NewConsole(clusterID string, connection *client.Connection) (console *Console, err error)

NewConsole need clusterID and connection passed. Will return the console with login=true

func (*Console) Config

func (c *Console) Config(kubeConfig string) (*Console, error)

Config will return the console which had been configured

func (*Console) GetClusterVersion

func (c *Console) GetClusterVersion() (version string, err error)

GetClusterVersion will return the Cluster version

func (*Console) GetPods

func (c *Console) GetPods(namespace ...string) ([]*Pod, error)

GetPods function will return list of *Pod with informations If namespace passed as parameter, will return the pod list of the specified namespace

func (*Console) IsConfiged

func (c *Console) IsConfiged() bool

IsConfiged will return whether the config file of the console is existed

type OcAttributes

type OcAttributes struct {
	Server          string
	Username        string
	Password        string
	ClusterID       string
	AdditioanlFlags []string
	Timeout         time.Duration
}

type Pod

type Pod struct {
	Name      string `json:"name,omitempty"`
	IP        string `json:"ip,omitempty"`
	Status    string `json:"status,omitempty"`
	StartTime string `json:"startTime,omitempty"`
	HostIP    string `json:"hostIP,omitempty"`
}

Pod struct is struct that contains info