cluster

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BackupPointFuzzyFilter added in v1.4.0

func BackupPointFuzzyFilter(obj runtime.Object, q *query.Query) []runtime.Object

func DNSFuzzyFilter added in v1.4.0

func DNSFuzzyFilter(obj runtime.Object, q *query.Query) []runtime.Object

func RegionFuzzyFilter added in v1.4.0

func RegionFuzzyFilter(obj runtime.Object, q *query.Query) []runtime.Object

func RegistryFuzzyFilter added in v1.4.0

func RegistryFuzzyFilter(obj runtime.Object, q *query.Query) []runtime.Object

func TemplateFuzzyFilter added in v1.4.0

func TemplateFuzzyFilter(obj runtime.Object, q *query.Query) []runtime.Object

Types

type BackupPointReader

type BackupPointReader interface {
	ListBackupPoints(ctx context.Context, query *query.Query) (*v1.BackupPointList, error)
	GetBackupPoint(ctx context.Context, name string, resourceVersion string) (*v1.BackupPoint, error)
	WatchBackupPoints(ctx context.Context, query *query.Query) (watch.Interface, error)
	BackupPointReaderEx
}

type BackupPointReaderEx

type BackupPointReaderEx interface {
	ListBackupPointEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetBackupPointEx(ctx context.Context, name string, resourceVersion string) (*v1.BackupPoint, error)
}

type BackupPointWriter

type BackupPointWriter interface {
	CreateBackupPoint(ctx context.Context, backupPoint *v1.BackupPoint) (*v1.BackupPoint, error)
	UpdateBackupPoint(ctx context.Context, backupPoint *v1.BackupPoint) (*v1.BackupPoint, error)
	DeleteBackupPoint(ctx context.Context, name string) error
}

type BackupReader

type BackupReader interface {
	ListBackups(ctx context.Context, query *query.Query) (*v1.BackupList, error)
	WatchBackups(ctx context.Context, query *query.Query) (watch.Interface, error)
	GetBackup(ctx context.Context, cluster string, name string) (*v1.Backup, error)
	BackupReaderEx
}

type BackupReaderEx

type BackupReaderEx interface {
	ListBackupEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetBackupEx(ctx context.Context, cluster string, name string) (*v1.Backup, error)
}

type BackupWriter

type BackupWriter interface {
	CreateBackup(ctx context.Context, backup *v1.Backup) (*v1.Backup, error)
	UpdateBackup(ctx context.Context, backup *v1.Backup) (*v1.Backup, error)
	DeleteBackup(ctx context.Context, name string) error
}

type CloudProviderEx added in v1.2.0

type CloudProviderEx interface {
	GetCloudProviderEx(ctx context.Context, name string, resourceVersion string) (*v1.CloudProvider, error)
	ListCloudProvidersEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
}

type CloudProviderReader added in v1.2.0

type CloudProviderReader interface {
	GetCloudProvider(ctx context.Context, name string) (*v1.CloudProvider, error)
	ListCloudProviders(ctx context.Context, query *query.Query) (*v1.CloudProviderList, error)
	WatchCloudProviders(ctx context.Context, query *query.Query) (watch.Interface, error)
	CloudProviderEx
}

type CloudProviderWriter added in v1.2.0

type CloudProviderWriter interface {
	CreateCloudProvider(ctx context.Context, cp *v1.CloudProvider) (*v1.CloudProvider, error)
	UpdateCloudProvider(ctx context.Context, cp *v1.CloudProvider) (*v1.CloudProvider, error)
	DeleteCloudProvider(ctx context.Context, name string) error
}

type ClusterReader

type ClusterReader interface {
	ListClusters(ctx context.Context, query *query.Query) (*v1.ClusterList, error)
	WatchClusters(ctx context.Context, query *query.Query) (watch.Interface, error)
	GetCluster(ctx context.Context, name string) (*v1.Cluster, error)
	ClusterReaderEx
}

type ClusterReaderEx

type ClusterReaderEx interface {
	GetClusterEx(ctx context.Context, name string, resourceVersion string) (*v1.Cluster, error)
	ListClusterEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
}

type ClusterWriter

type ClusterWriter interface {
	CreateCluster(ctx context.Context, cluster *v1.Cluster) (*v1.Cluster, error)
	UpdateCluster(ctx context.Context, cluster *v1.Cluster) (*v1.Cluster, error)
	DeleteCluster(ctx context.Context, name string) error
}

type CronBackupReader

type CronBackupReader interface {
	ListCronBackups(ctx context.Context, query *query.Query) (*v1.CronBackupList, error)
	GetCronBackup(ctx context.Context, name string, resourceVersion string) (*v1.CronBackup, error)
	WatchCronBackups(ctx context.Context, query *query.Query) (watch.Interface, error)
	CronBackupReaderEx
}

type CronBackupReaderEx

type CronBackupReaderEx interface {
	ListCronBackupEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetCronBackupEx(ctx context.Context, name string, resourceVersion string) (*v1.CronBackup, error)
}

type CronBackupWriter

type CronBackupWriter interface {
	CreateCronBackup(ctx context.Context, cronBackup *v1.CronBackup) (*v1.CronBackup, error)
	UpdateCronBackup(ctx context.Context, cronBackup *v1.CronBackup) (*v1.CronBackup, error)
	DeleteCronBackup(ctx context.Context, name string) error
	DeleteCronBackupCollection(ctx context.Context, query *query.Query) error
}

type DNSReader

type DNSReader interface {
	ListDomains(ctx context.Context, query *query.Query) (*v1.DomainList, error)
	GetDomain(ctx context.Context, name string) (*v1.Domain, error)
	WatchDomain(ctx context.Context, query *query.Query) (watch.Interface, error)
	DNSReaderEx
}

type DNSReaderEx

type DNSReaderEx interface {
	ListRecordsEx(ctx context.Context, name, subdomain string, query *query.Query) (*models.PageableResponse, error)
	ListDomainsEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
}

type DNSWriter

type DNSWriter interface {
	CreateDomain(ctx context.Context, domain *v1.Domain) (*v1.Domain, error)
	UpdateDomain(ctx context.Context, domain *v1.Domain) (*v1.Domain, error)
	DeleteDomain(ctx context.Context, name string) error
}

type NodeReader

type NodeReader interface {
	ListNodes(ctx context.Context, query *query.Query) (*v1.NodeList, error)
	WatchNodes(ctx context.Context, query *query.Query) (watch.Interface, error)
	GetNode(ctx context.Context, name string) (*v1.Node, error)
	NodeReaderEx
}

type NodeReaderEx

type NodeReaderEx interface {
	GetNodeEx(ctx context.Context, name string, resourceVersion string) (*v1.Node, error)
	ListNodesEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
}

type NodeWriter

type NodeWriter interface {
	UpdateNode(ctx context.Context, node *v1.Node) (*v1.Node, error)
	CreateNode(ctx context.Context, node *v1.Node) (*v1.Node, error)
	DeleteNode(ctx context.Context, name string) error
}

type Operator

func NewClusterOperator

func NewClusterOperator(clusterStorage, nodeStorage, regionStorage, backupStorage, recoveryStorage, backupPointStorage,
	cronBackupStorage, dnsStorage, templateStorage, cloudProviderStorage, registryStorage rest.StandardStorage) Operator

type RecoveryReader

type RecoveryReader interface {
	ListRecoveries(ctx context.Context, query *query.Query) (*v1.RecoveryList, error)
	WatchRecoveries(ctx context.Context, query *query.Query) (watch.Interface, error)
	GetRecovery(ctx context.Context, cluster string, name string) (*v1.Recovery, error)
	RecoveryReaderEx
}

type RecoveryReaderEx

type RecoveryReaderEx interface {
	ListRecoveryEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetRecoveryEx(ctx context.Context, cluster string, name string) (*v1.Recovery, error)
}

type RecoveryWriter

type RecoveryWriter interface {
	CreateRecovery(ctx context.Context, recovery *v1.Recovery) (*v1.Recovery, error)
	UpdateRecovery(ctx context.Context, recovery *v1.Recovery) (*v1.Recovery, error)
	DeleteRecovery(ctx context.Context, name string) error
}

type RegionReader

type RegionReader interface {
	ListRegions(ctx context.Context, query *query.Query) (*v1.RegionList, error)
	GetRegion(ctx context.Context, name string) (*v1.Region, error)
	WatchRegions(ctx context.Context, query *query.Query) (watch.Interface, error)
	RegionReaderEx
}

type RegionReaderEx

type RegionReaderEx interface {
	ListRegionEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetRegionEx(ctx context.Context, name string, resourceVersion string) (*v1.Region, error)
}

type RegionWriter

type RegionWriter interface {
	CreateRegion(ctx context.Context, region *v1.Region) (*v1.Region, error)
	DeleteRegion(ctx context.Context, name string) error
}

type RegistryEx added in v1.3.1

type RegistryEx interface {
	GetRegistryEx(ctx context.Context, name string, resourceVersion string) (*v1.Registry, error)
	ListRegistriesEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
}

type RegistryReader added in v1.3.1

type RegistryReader interface {
	GetRegistry(ctx context.Context, name string) (*v1.Registry, error)
	ListRegistries(ctx context.Context, query *query.Query) (*v1.RegistryList, error)
	WatchRegistries(ctx context.Context, query *query.Query) (watch.Interface, error)
	RegistryEx
}

type RegistryWriter added in v1.3.1

type RegistryWriter interface {
	CreateRegistry(ctx context.Context, r *v1.Registry) (*v1.Registry, error)
	UpdateRegistry(ctx context.Context, r *v1.Registry) (*v1.Registry, error)
	DeleteRegistry(ctx context.Context, name string) error
}

type TemplateReader

type TemplateReader interface {
	ListTemplates(ctx context.Context, query *query.Query) (*v1.TemplateList, error)
	WatchTemplates(ctx context.Context, query *query.Query) (watch.Interface, error)
	GetTemplate(ctx context.Context, name string) (*v1.Template, error)
	TemplateReaderEx
}

type TemplateReaderEx

type TemplateReaderEx interface {
	ListTemplatesEx(ctx context.Context, query *query.Query) (*models.PageableResponse, error)
	GetTemplateEx(ctx context.Context, name string, resourceVersion string) (*v1.Template, error)
}

type TemplateWriter

type TemplateWriter interface {
	CreateTemplate(ctx context.Context, template *v1.Template) (*v1.Template, error)
	UpdateTemplate(ctx context.Context, template *v1.Template) (*v1.Template, error)
	DeleteTemplate(ctx context.Context, name string) error
	DeleteTemplateCollection(ctx context.Context, query *query.Query) error
}

Directories

Path Synopsis
Package mock_cluster is a generated GoMock package.
Package mock_cluster is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL