Documentation ¶
Index ¶
- func GetRAWClusterInfos(storage resources.StorageFactory, meta resources.Metadata) ([]cloudControlRes.AllClusterData, error)
- type CustomLogger
- func (l CustomLogger) Enable(flag bool)
- func (l CustomLogger) Enabled() bool
- func (l CustomLogger) Error(message string)
- func (l CustomLogger) Errorf(format string, args ...interface{})
- func (l CustomLogger) Info(message string)
- func (l CustomLogger) Infof(format string, args ...any)
- func (l CustomLogger) V(level klog.Level) klog.InfoLogger
- func (l CustomLogger) Warn(message string)
- func (l CustomLogger) Warnf(format string, args ...interface{})
- func (l CustomLogger) WithValues(keysAndValues ...interface{}) klog.Logger
- type LocalGo
- type LocalGoClient
- type LocalGoMockClient
- func (l *LocalGoMockClient) Create(name string, config cluster.CreateOption, image string, wait time.Duration, ...) error
- func (l *LocalGoMockClient) Delete(name string, explicitKubeconfigPath string) error
- func (l *LocalGoMockClient) NewProvider(log resources.LoggerFactory, storage resources.StorageFactory, ...)
- type LocalProvider
- func (cloud *LocalProvider) Application(s string) (externalApps bool)
- func (client *LocalProvider) CNI(s string) (externalCNI bool)
- func (*LocalProvider) CreateUploadSSHKeyPair(state resources.StorageFactory) error
- func (*LocalProvider) DelFirewall(state resources.StorageFactory) error
- func (cloud *LocalProvider) DelManagedCluster(storage resources.StorageFactory) error
- func (*LocalProvider) DelNetwork(state resources.StorageFactory) error
- func (*LocalProvider) DelSSHKeyPair(state resources.StorageFactory) error
- func (*LocalProvider) DelVM(resources.StorageFactory, int) error
- func (*LocalProvider) GetHostNameAllWorkerNode() []string
- func (*LocalProvider) GetSecretTokens(resources.StorageFactory) (map[string][]byte, error)
- func (*LocalProvider) GetStateFile(resources.StorageFactory) (string, error)
- func (*LocalProvider) GetStateForHACluster(state resources.StorageFactory) (cloud.CloudResourceState, error)
- func (cloud *LocalProvider) InitState(storage resources.StorageFactory, operation consts.KsctlOperation) error
- func (obj *LocalProvider) IsPresent(storage resources.StorageFactory) error
- func (cloud *LocalProvider) Name(resName string) resources.CloudFactory
- func (*LocalProvider) NewFirewall(state resources.StorageFactory) error
- func (cloud *LocalProvider) NewManagedCluster(storage resources.StorageFactory, noOfNodes int) error
- func (*LocalProvider) NewNetwork(state resources.StorageFactory) error
- func (*LocalProvider) NewVM(resources.StorageFactory, int) error
- func (cloud *LocalProvider) NoOfControlPlane(int, bool) (int, error)
- func (cloud *LocalProvider) NoOfDataStore(int, bool) (int, error)
- func (cloud *LocalProvider) NoOfWorkerPlane(resources.StorageFactory, int, bool) (int, error)
- func (cloud *LocalProvider) Role(consts.KsctlRole) resources.CloudFactory
- func (cloud *LocalProvider) VMType(string) resources.CloudFactory
- func (cloud *LocalProvider) Version(ver string) resources.CloudFactory
- func (cloud *LocalProvider) Visibility(bool) resources.CloudFactory
- type Metadata
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetRAWClusterInfos ¶
func GetRAWClusterInfos(storage resources.StorageFactory, meta resources.Metadata) ([]cloudControlRes.AllClusterData, error)
Types ¶
type CustomLogger ¶
type CustomLogger struct {
Logger resources.LoggerFactory
}
func (CustomLogger) Enable ¶
func (l CustomLogger) Enable(flag bool)
func (CustomLogger) Enabled ¶
func (l CustomLogger) Enabled() bool
func (CustomLogger) Error ¶
func (l CustomLogger) Error(message string)
func (CustomLogger) Errorf ¶
func (l CustomLogger) Errorf(format string, args ...interface{})
func (CustomLogger) Info ¶
func (l CustomLogger) Info(message string)
func (CustomLogger) Infof ¶
func (l CustomLogger) Infof(format string, args ...any)
func (CustomLogger) V ¶
func (l CustomLogger) V(level klog.Level) klog.InfoLogger
func (CustomLogger) Warn ¶
func (l CustomLogger) Warn(message string)
func (CustomLogger) Warnf ¶
func (l CustomLogger) Warnf(format string, args ...interface{})
func (CustomLogger) WithValues ¶
func (l CustomLogger) WithValues(keysAndValues ...interface{}) klog.Logger
type LocalGo ¶
type LocalGo interface { NewProvider(log resources.LoggerFactory, storage resources.StorageFactory, options ...cluster.ProviderOption) Create(name string, config cluster.CreateOption, image string, wait time.Duration, explictPath func() string) error Delete(name string, explicitKubeconfigPath string) error }
func ProvideClient ¶
func ProvideClient() LocalGo
func ProvideMockClient ¶
func ProvideMockClient() LocalGo
type LocalGoClient ¶
type LocalGoClient struct {
// contains filtered or unexported fields
}
func (*LocalGoClient) Create ¶
func (l *LocalGoClient) Create(name string, config cluster.CreateOption, image string, wait time.Duration, explictPath func() string) error
func (*LocalGoClient) Delete ¶
func (l *LocalGoClient) Delete(name string, explicitKubeconfigPath string) error
func (*LocalGoClient) NewProvider ¶
func (l *LocalGoClient) NewProvider(log resources.LoggerFactory, _ resources.StorageFactory, options ...cluster.ProviderOption)
type LocalGoMockClient ¶
type LocalGoMockClient struct {
// contains filtered or unexported fields
}
func (*LocalGoMockClient) Create ¶
func (l *LocalGoMockClient) Create(name string, config cluster.CreateOption, image string, wait time.Duration, explictPath func() string) error
func (*LocalGoMockClient) Delete ¶
func (l *LocalGoMockClient) Delete(name string, explicitKubeconfigPath string) error
func (*LocalGoMockClient) NewProvider ¶
func (l *LocalGoMockClient) NewProvider(log resources.LoggerFactory, storage resources.StorageFactory, options ...cluster.ProviderOption)
type LocalProvider ¶
type LocalProvider struct { ClusterName string `json:"cluster_name"` NoNodes int `json:"no_nodes"` Region string Metadata // contains filtered or unexported fields }
func ReturnLocalStruct ¶
func ReturnLocalStruct(metadata resources.Metadata, state *types.StorageDocument, ClientOption func() LocalGo) (*LocalProvider, error)
func (*LocalProvider) Application ¶
func (cloud *LocalProvider) Application(s string) (externalApps bool)
func (*LocalProvider) CNI ¶
func (client *LocalProvider) CNI(s string) (externalCNI bool)
func (*LocalProvider) CreateUploadSSHKeyPair ¶
func (*LocalProvider) CreateUploadSSHKeyPair(state resources.StorageFactory) error
CreateUploadSSHKeyPair implements resources.CloudFactory.
func (*LocalProvider) DelFirewall ¶
func (*LocalProvider) DelFirewall(state resources.StorageFactory) error
DelFirewall implements resources.CloudFactory.
func (*LocalProvider) DelManagedCluster ¶
func (cloud *LocalProvider) DelManagedCluster(storage resources.StorageFactory) error
DelManagedCluster implements resources.CloudFactory.
func (*LocalProvider) DelNetwork ¶
func (*LocalProvider) DelNetwork(state resources.StorageFactory) error
DelNetwork implements resources.CloudFactory.
func (*LocalProvider) DelSSHKeyPair ¶
func (*LocalProvider) DelSSHKeyPair(state resources.StorageFactory) error
DelSSHKeyPair implements resources.CloudFactory.
func (*LocalProvider) DelVM ¶
func (*LocalProvider) DelVM(resources.StorageFactory, int) error
DelVM implements resources.CloudFactory.
func (*LocalProvider) GetHostNameAllWorkerNode ¶
func (*LocalProvider) GetHostNameAllWorkerNode() []string
func (*LocalProvider) GetSecretTokens ¶
func (*LocalProvider) GetSecretTokens(resources.StorageFactory) (map[string][]byte, error)
GetSecretTokens implements resources.CloudFactory.
func (*LocalProvider) GetStateFile ¶
func (*LocalProvider) GetStateFile(resources.StorageFactory) (string, error)
GetStateFile implements resources.CloudFactory.
func (*LocalProvider) GetStateForHACluster ¶
func (*LocalProvider) GetStateForHACluster(state resources.StorageFactory) (cloud.CloudResourceState, error)
GetStateForHACluster implements resources.CloudFactory.
func (*LocalProvider) InitState ¶
func (cloud *LocalProvider) InitState(storage resources.StorageFactory, operation consts.KsctlOperation) error
InitState implements resources.CloudFactory.
func (*LocalProvider) IsPresent ¶
func (obj *LocalProvider) IsPresent(storage resources.StorageFactory) error
func (*LocalProvider) Name ¶
func (cloud *LocalProvider) Name(resName string) resources.CloudFactory
it will contain the name of the resource to be created
func (*LocalProvider) NewFirewall ¶
func (*LocalProvider) NewFirewall(state resources.StorageFactory) error
NewFirewall implements resources.CloudFactory.
func (*LocalProvider) NewManagedCluster ¶
func (cloud *LocalProvider) NewManagedCluster(storage resources.StorageFactory, noOfNodes int) error
NewManagedCluster implements resources.CloudFactory.
func (*LocalProvider) NewNetwork ¶
func (*LocalProvider) NewNetwork(state resources.StorageFactory) error
NewNetwork implements resources.CloudFactory.
func (*LocalProvider) NewVM ¶
func (*LocalProvider) NewVM(resources.StorageFactory, int) error
NewVM implements resources.CloudFactory.
func (*LocalProvider) NoOfControlPlane ¶
func (cloud *LocalProvider) NoOfControlPlane(int, bool) (int, error)
NoOfControlPlane implements resources.CloudFactory.
func (*LocalProvider) NoOfDataStore ¶
func (cloud *LocalProvider) NoOfDataStore(int, bool) (int, error)
NoOfDataStore implements resources.CloudFactory.
func (*LocalProvider) NoOfWorkerPlane ¶
func (cloud *LocalProvider) NoOfWorkerPlane(resources.StorageFactory, int, bool) (int, error)
NoOfWorkerPlane implements resources.CloudFactory.
func (*LocalProvider) Role ¶
func (cloud *LocalProvider) Role(consts.KsctlRole) resources.CloudFactory
it will contain whether the resource to be created belongs for controlplane component or loadbalancer...
func (*LocalProvider) VMType ¶
func (cloud *LocalProvider) VMType(string) resources.CloudFactory
it will contain which vmType to create
func (*LocalProvider) Version ¶
func (cloud *LocalProvider) Version(ver string) resources.CloudFactory
Version implements resources.CloudFactory.
func (*LocalProvider) Visibility ¶
func (cloud *LocalProvider) Visibility(bool) resources.CloudFactory
whether to have the resource as public or private (i.e. VMs)