Versions in this module Expand all Collapse all v1 v1.2.0 Feb 14, 2024 v1.1.1 Feb 1, 2024 v1.1.0 Jul 14, 2023 v1.0.1 Jun 13, 2023 Changes in this version + const AnnLegacyService + const AnnProviderRegistrationUID + func AddOwnerReference(meta metav1.Object, ref metav1.OwnerReference) + func ContainsOwnerReference(meta metav1.Object) bool + func GetOwnerRefByKind(meta metav1.Object, kind string) []metav1.OwnerReference + func GetOwnerReference(meta metav1.Object, UID string) (metav1.OwnerReference, bool) + func GetOwnerReferences(meta metav1.Object) []metav1.OwnerReference + func RemoveOwnerReference(meta metav1.Object, UID string) + func ToResourceID(apiVersion, kind, namespace, name string) string + func VolumeProvisioner(pv *corev1.PersistentVolume) string type BuildInfo + func (info BuildInfo) String() string v1.0.0 Dec 31, 2022 Changes in this version + const KahuSnapshot + func VolumeProvider(pv *corev1.PersistentVolume) string v0 v0.1.2 Dec 5, 2022 v0.1.1 Nov 25, 2022 Changes in this version + const AnnBackupLocationParam + const Backup + const BackupLocation + const BackupLocationServiceAnnotation + const ClusterRole + const ClusterRoleBinding + const Configmap + const DaemonSet + const Deployment + const Endpoint + const EndpointSlice + const Event + const EventCancelVolRestoreFailed + const EventOwnerNotDeleted + const InsecureAnnotation + const NamespaceAnnotation + const NamespaceEnv + const Node + const PV + const PVC + const Pod + const Replicaset + const Role + const RoleBinding + const SC + const Secret + const Service + const ServiceAccount + const StatefulSet + const VBC + const VolumeSnapshot + var DeletionHandlingMetaNamespaceKeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + var GVKBackup = schema.GroupVersionKind + var GVKPersistentVolumeClaim = schema.GroupVersionKind + var GVKRestore = schema.GroupVersionKind + var SupportedCsiDrivers = []string + var SupportedResourceList = []string + func AddGRPCRequestID(ctx context.Context, method string, req, reply interface{}, ...) error + func CheckBackupSupport(pv corev1.PersistentVolume) error + func CheckServerUnavailable(err error) bool + func Contains(s []string, str string) bool + func ContainsAnnotation(meta metav1.Object, annotation string) bool + func ContainsFinalizer(meta metav1.Object, finalizer string) bool + func FileToResource(filePath string) *pb.Resource + func FindMatchedStrings(kind string, allList []string, includeList, excludeList []kahuapi.ResourceSpec) []string + func GetAnnotation(meta metav1.Object, annotation string) (string, bool) + func GetBackupIdentifier(backup *kahuapi.Backup, backupLocation *kahuapi.BackupLocation, ...) (*pb.BackupIdentifier, error) + func GetBackupLocation(logger log.FieldLogger, locationName string, ...) (*kahuapi.BackupLocation, error) + func GetBackupParameters(logger log.FieldLogger, backupName, backupLocationName string, ...) (map[string]string, error) + func GetDynamicClient(config *restclient.Config) (dynamic.Interface, error) + func GetGRPCConnection(endpoint string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error) + func GetK8sClient(config *restclient.Config) (*kubernetes.Clientset, error) + func GetMetaserviceBackupClient(address string, port uint) metaservice.MetaService_BackupClient + func GetMetaserviceClient(grpcConnection *grpc.ClientConn) metaservice.MetaServiceClient + func GetMetaserviceDeleteClient(address string, port uint) metaservice.MetaServiceClient + func GetProvider(logger log.FieldLogger, providerName string, ...) (*kahuapi.Provider, error) + func GetResultantItems(allList, includeList, excludeList []string) []string + func GetSubItemStrings(allList []string, input string, isRegex bool) []string + func GetgrpcConn(address string, port uint) (*grpc.ClientConn, error) + func Probe(conn grpc.ClientConnInterface, timeout time.Duration) error + func RemoveAnnotation(meta metav1.Object, annotation string) + func RemoveFinalizer(meta metav1.Object, finalizer string) + func RemoveItem(s []string, r string) []string + func SetAnnotation(meta metav1.Object, annotation, value string) + func SetFinalizer(meta metav1.Object, finalizer string) + func SetupSignalHandler(cancel context.CancelFunc) + func StoreClean(store Store, obj interface{}, className string) error + func StoreRevisionUpdate(store Store, obj interface{}, className string) (bool, error) + func ValidateNamespace(includesList, excludesList []string) []error + type BuildInfo struct + BuildDate string + Compiler string + GitCommit string + GitTreeState string + GitVersion string + GoVersion string + Platform string + func GetBuildInfo() BuildInfo + func (info BuildInfo) Print() + type KeyFunc func(obj interface{}) (string, error) + type Store interface + Add func(obj interface{}, value interface{}) error + Delete func(obj interface{}) error + Get func(obj interface{}) (item interface{}, exists bool, err error) + List func() []interface{} + ListKeys func() []string + Update func(obj interface{}, value interface{}) error + func NewStore(keyFunc KeyFunc) Store + type StoreError struct + Err error + Obj interface{} + func (k StoreError) Error() string v0.1.0 Jun 21, 2022 v0.0.1 May 31, 2022 Changes in this version + func EnableLogTimeStamp() + func EnsureNamespaceExistsAndIsReady(namespace string, client corev1client.NamespaceInterface) (bool, error) + func GetConfig(kubeConfig string) (config *restclient.Config, err error) + func LoadConfig() (kahuConfig, error) + func NamespaceAndName(objMeta metav1.Object) string + func ResourceToFile(resource *pb.Resource) string + func ValidateIncludesExcludes(includesList, excludesList []string) []error + func ValidateNamespaceIncludesExcludes(includesList, excludesList []string) []error + type IncludesExcludes struct + func GenerateIncludesExcludes(includes, excludes []string, mapFunc func(string) string) *IncludesExcludes + func NewIncludesExcludes() *IncludesExcludes + func (ie *IncludesExcludes) Excludes(excludes ...string) *IncludesExcludes + func (ie *IncludesExcludes) ExcludesString() string + func (ie *IncludesExcludes) GetExcludes() []string + func (ie *IncludesExcludes) GetIncludes() []string + func (ie *IncludesExcludes) IncludeEverything() bool + func (ie *IncludesExcludes) Includes(includes ...string) *IncludesExcludes + func (ie *IncludesExcludes) IncludesString() string + func (ie *IncludesExcludes) ShouldInclude(s string) bool
Go to main page