Documentation
¶
Overview ¶
Package importer provides business access to the importer's kubernetes API.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DoguControl ¶ added in v0.0.3
type DoguControl struct {
// contains filtered or unexported fields
}
func NewDoguControl ¶ added in v0.0.3
func NewDoguControl(doguCli DoguInterface) *DoguControl
NewDoguControl creates a new client that operates on dogu deployments on the importer system.
func (*DoguControl) StartAll ¶ added in v0.0.3
func (dc *DoguControl) StartAll(ctx context.Context) error
StartAll starts all dogus in the importer system.
func (*DoguControl) StartDogu ¶ added in v0.0.3
func (dc *DoguControl) StartDogu(ctx context.Context, doguName string) error
StartDogu starts the given dogu in the importer system.
type DoguInterface ¶
type DoguInterface interface {
// List takes label and field selectors and returns the list of Dogus that match those selectors.
List(ctx context.Context, opts metav1.ListOptions) (result *doguV2.DoguList, err error)
// Get returns a single dogu CR if it exists in the k8s cluster.
Get(ctx context.Context, name string, opts metav1.GetOptions) (*doguV2.Dogu, error)
// UpdateSpecWithRetry tries to update the provided dogu with the given update function and returns the updated
// copy. If a conflict happens, the update will be retried with the same function.
UpdateSpecWithRetry(ctx context.Context, dogu *doguV2.Dogu, updateFunc func(spec doguV2.DoguSpec) doguV2.DoguSpec, opts metav1.UpdateOptions) (*doguV2.Dogu, error)
}
type K8sClients ¶ added in v0.0.3
type K8sClients struct {
Pvc corev1.PersistentVolumeClaimInterface
Pod corev1.PodInterface
Job batchv1.JobInterface
ConfigMap corev1.ConfigMapInterface
Secret corev1.SecretInterface
Dogu doguLibClient.DoguInterface
DoguControl *DoguControl
Component componentEcoClient.ComponentInterface
BackupSchedule backupEcosystem.BackupScheduleInterface
}
func CreateK8SClientSet ¶ added in v0.0.3
func CreateK8SClientSet(k8sRestConfig *rest.Config, namespace string) (K8sClients, error)
Click to show internal directories.
Click to hide internal directories.