installer

Documentation

Index

• Constants
• type AssertsResource
  • func NewAssertsResource() *AssertsResource
  • func (c *AssertsResource) WebService() *restful.WebService
• type Auth
• type Basic
• type Business
• type Cert
• type ClusterProgress
• type ClusterProgressStatus
• type Config
• type CreateClusterPara
• type ESMonitor
• type ExternalInfluxDBMonitor
• type Gateway
• type HA
  • func (ha *HA) VIP() string
• type InfluxDBMonitor
• type Keepalived
• type LocalInfluxDBMonitor
• type Monitor
• type OIDCAuth
• type Registry
  • func (r *Registry) Domain() string
  • func (r *Registry) Namespace() string
  • func (r *Registry) Prefix() string
  • func (r *Registry) UseDevRegistry() bool
• type SSH
• type SSHResource
  • func NewSSHResource() *SSHResource
  • func (c *SSHResource) WebService() *restful.WebService
• type SelfSignedCert
• type TKE
  • func NewTKE(config *config.Config) *TKE
  • func (t *TKE) GetClientset(name string, dnsDomain string) (tkeclientset.Interface, error)
  • func (t *TKE) Run()
  • func (t *TKE) SetClusterDefault(cluster *platformv1.Cluster, config *Config)
  • func (t *TKE) SetConfigDefault(config *Config)
  • func (t *TKE) ValidateCertAndKey(certificate []byte, privateKey []byte, dnsNames []string) *errors.StatusError
  • func (t *TKE) ValidateConfig(config Config) *errors.StatusError
  • func (t *TKE) WebService() *restful.WebService
• type TKEAuth
• type TKEHA
• type TKERegistry
• type ThirdPartyCert
• type ThirdPartyHA
• type ThirdPartyRegistry

Constants

const (
	StatusUnknown = "Unknown"
	StatusDoing   = "Doing"
	StatusSuccess = "Success"
	StatusFailed  = "Failed"
)

Types

type AssertsResource

type AssertsResource struct {
}

AssertsResource is the REST layer

func NewAssertsResource

func NewAssertsResource() *AssertsResource

NewAssertsResource create a AssertsResource

func (*AssertsResource) WebService

func (c *AssertsResource) WebService() *restful.WebService

WebService creates a new service that can handle REST requests for AssertsResource

type Auth

type Auth struct {
	TKEAuth  *TKEAuth  `json:"tke,omitempty"`
	OIDCAuth *OIDCAuth `json:"oidc,omitempty"`
}

type Basic

type Basic struct {
	Username string `json:"username"`
	Password []byte `json:"password"`
}

type Business

type Business struct {
}

type Cert

type Cert struct {
	SelfSignedCert *SelfSignedCert `json:"selfSigned,omitempty"`
	ThirdPartyCert *ThirdPartyCert `json:"thirdParty,omitempty"`
}

type ClusterProgress

type ClusterProgress struct {
	Status     ClusterProgressStatus `json:"status"`
	Data       string                `json:"data"`
	URL        string                `json:"url,omitempty"`
	Username   string                `json:"username,omitempty"`
	Password   []byte                `json:"password,omitempty"`
	CACert     []byte                `json:"caCert,omitempty"`
	Hosts      []string              `json:"hosts,omitempty"`
	Servers    []string              `json:"servers,omitempty"`
	Kubeconfig []byte                `json:"kubeconfig,omitempty"`
}

ClusterProgress use for findClusterProgress

type ClusterProgressStatus

type ClusterProgressStatus string

ClusterProgressStatus use for ClusterProgress

type Config

type Config struct {
	Basic    *Basic    `json:"basic"`
	Auth     Auth      `json:"auth"`
	Registry Registry  `json:"registry"`
	Business *Business `json:"business,omitempty"`
	Monitor  *Monitor  `json:"monitor,omitempty"`
	HA       *HA       `json:"ha,omitempty"`
	Gateway  *Gateway  `json:"gateway,omitempty"`
}

Config is the installer config

type CreateClusterPara

type CreateClusterPara struct {
	Cluster platformv1.Cluster `json:"cluster"`
	Config  Config             `json:"Config"`
}

CreateClusterPara for create cluster parameter

type ESMonitor

type ESMonitor struct {
	URL      string `json:"url" validate:"required"`
	Username string `json:"username" validate:"required"`
	Password []byte `json:"password" validate:"required"`
}

type ExternalInfluxDBMonitor

type ExternalInfluxDBMonitor struct {
	URL      string `json:"url" validate:"required"`
	Username string `json:"username" validate:"required"`
	Password []byte `json:"password" validate:"required"`
}

type Gateway

type Gateway struct {
	Domain string `json:"domain"`
	Cert   *Cert  `json:"cert"`
}

type HA

type HA struct {
	TKEHA        *TKEHA        `json:"tke,omitempty"`
	ThirdPartyHA *ThirdPartyHA `json:"thirdParty,omitempty"`
}

func (*HA) VIP

func (ha *HA) VIP() string

type InfluxDBMonitor

type InfluxDBMonitor struct {
	LocalInfluxDBMonitor    *LocalInfluxDBMonitor    `json:"local,omitempty"`
	ExternalInfluxDBMonitor *ExternalInfluxDBMonitor `json:"external,omitempty"`
}

type Keepalived

type Keepalived struct {
	VIP string `json:"vip,omitempty"`
}

type LocalInfluxDBMonitor

type LocalInfluxDBMonitor struct {
}

type Monitor

type Monitor struct {
	ESMonitor       *ESMonitor       `json:"es,omitempty"`
	InfluxDBMonitor *InfluxDBMonitor `json:"influxDB,omitempty"`
}

type OIDCAuth

type OIDCAuth struct {
	IssuerURL string `json:"issuerURL" validate:"required"`
	ClientID  string `json:"clientID" validate:"required"`
	CACert    []byte `json:"caCert"`
}

type Registry

type Registry struct {
	TKERegistry        *TKERegistry        `json:"tke,omitempty"`
	ThirdPartyRegistry *ThirdPartyRegistry `json:"thirdParty,omitempty"`
}

Registry for remote registry

func (*Registry) Domain

func (r *Registry) Domain() string

func (*Registry) Namespace

func (r *Registry) Namespace() string

func (*Registry) Prefix

func (r *Registry) Prefix() string

func (*Registry) UseDevRegistry

func (r *Registry) UseDevRegistry() bool

type SSH

type SSH struct {
	Status string `json:"status,omitempty"`
}

SSH for test ssh result

type SSHResource

type SSHResource struct {
}

SSHResource is the REST layer to the Cluster domain

func NewSSHResource

func NewSSHResource() *SSHResource

NewSSHResource create a SSHResource

func (*SSHResource) WebService

func (c *SSHResource) WebService() *restful.WebService

WebService creates a new service that can handle REST requests for SSHResource.

type SelfSignedCert

type SelfSignedCert struct {
}

type TKE

type TKE struct {
	Config  *config.Config           `json:"config"`
	Para    *CreateClusterPara       `json:"para"`
	Cluster *clusterprovider.Cluster `json:"cluster"`
	Step    int                      `json:"step"`
	// contains filtered or unexported fields
}

ClusterResource is the REST layer to the Cluster domain

func NewTKE

func NewTKE(config *config.Config) *TKE

func (*TKE) GetClientset

func (t *TKE) GetClientset(name string, dnsDomain string) (tkeclientset.Interface, error)

GetClientset return the clientset of component

func (*TKE) Run

func (t *TKE) Run()

func (*TKE) SetClusterDefault

func (t *TKE) SetClusterDefault(cluster *platformv1.Cluster, config *Config)

func (*TKE) SetConfigDefault

func (t *TKE) SetConfigDefault(config *Config)

func (*TKE) ValidateCertAndKey

func (t *TKE) ValidateCertAndKey(certificate []byte, privateKey []byte, dnsNames []string) *errors.StatusError

func (*TKE) ValidateConfig

func (t *TKE) ValidateConfig(config Config) *errors.StatusError

func (*TKE) WebService

func (t *TKE) WebService() *restful.WebService

WebService creates a new service that can handle REST requests for ClusterResource.

type TKEAuth

type TKEAuth struct {
	TenantID string `json:"tenantID"`
	Username string `json:"username"`
	Password []byte `json:"password"`
}

type TKEHA

type TKEHA struct {
	VIP string `json:"vip" validate:"required"`
}

type TKERegistry

type TKERegistry struct {
	Domain    string `json:"domain" validate:"hostname_rfc1123"`
	Namespace string `json:"namespace"`
	Username  string `json:"username"`
	Password  []byte `json:"password"`
}

type ThirdPartyCert

type ThirdPartyCert struct {
	Certificate []byte `json:"certificate" validate:"required"`
	PrivateKey  []byte `json:"privateKey" validate:"required"`
}

type ThirdPartyHA

type ThirdPartyHA struct {
	VIP   string `json:"vip" validate:"required"`
	VPort int32  `json:"vport"`
}

type ThirdPartyRegistry

type ThirdPartyRegistry struct {
	Domain    string `json:"domain" validate:"required"`
	Namespace string `json:"namespace" validate:"required"`
	Username  string `json:"username" validate:"required"`
	Password  []byte `json:"password" validate:"required"`
}