v1alpha1

package
v0.9.0-rc.5 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2020 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

+groupName=stash.appscode.com

Index

Constants

View Source 
const (
	ResticKey                = "restic.appscode.com"
	LastAppliedConfiguration = ResticKey + "/last-applied-configuration"
	VersionTag               = ResticKey + "/tag"
	// ResourceVersion will be used to trigger restarts for ReplicaSet and RC pods
	ResourceHash = ResticKey + "/resource-hash"
)
View Source 
const (
	ResourceKindRecovery     = "Recovery"
	ResourceSingularRecovery = "recovery"
	ResourcePluralRecovery   = "recoveries"
)
View Source 
const (
	ResourceKindRepository     = "Repository"
	ResourcePluralRepository   = "repositories"
	ResourceSingularRepository = "repository"
)
View Source 
const (
	ResourceKindRestic     = "Restic"
	ResourceSingularRestic = "restic"
	ResourcePluralRestic   = "restics"
)
View Source 
const (
	KindDeployment            = "Deployment"
	KindReplicaSet            = "ReplicaSet"
	KindReplicationController = "ReplicationController"
	KindStatefulSet           = "StatefulSet"
	KindDaemonSet             = "DaemonSet"
	KindPod                   = "Pod"
	KindPersistentVolumeClaim = "PersistentVolumeClaim"
	KindAppBinding            = "AppBinding"
	KindDeploymentConfig      = "DeploymentConfig"
	KindSecret                = "Secret"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: stash.GroupName, Version: "v1alpha1"}

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func StatefulSetPodName 

func StatefulSetPodName(appName, podOrdinal string) (string, error)

Types

type BackupType 

type BackupType string
const (
	BackupOnline  BackupType = "online"  // default, injects sidecar
	BackupOffline BackupType = "offline" // injects init container
)

type FileGroup 

type FileGroup struct {
	// Source of the backup volumeName:path
	Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`
	// Tags of a snapshots
	Tags []string `json:"tags,omitempty" protobuf:"bytes,2,rep,name=tags"`
	// retention policy of snapshots
	RetentionPolicyName string `json:"retentionPolicyName,omitempty" protobuf:"bytes,3,opt,name=retentionPolicyName"`
}

func (*FileGroup) DeepCopy 

func (in *FileGroup) DeepCopy() *FileGroup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileGroup.

func (*FileGroup) DeepCopyInto 

func (in *FileGroup) DeepCopyInto(out *FileGroup)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FileGroup) Descriptor 

func (*FileGroup) Descriptor() ([]byte, []int)

func (*FileGroup) Marshal 

func (m *FileGroup) Marshal() (dAtA []byte, err error)

func (*FileGroup) MarshalTo 

func (m *FileGroup) MarshalTo(dAtA []byte) (int, error)

func (*FileGroup) MarshalToSizedBuffer 

func (m *FileGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileGroup) ProtoMessage 

func (*FileGroup) ProtoMessage()

func (*FileGroup) Reset 

func (m *FileGroup) Reset()

func (*FileGroup) Size 

func (m *FileGroup) Size() (n int)

func (*FileGroup) String 

func (this *FileGroup) String() string

func (*FileGroup) Unmarshal 

func (m *FileGroup) Unmarshal(dAtA []byte) error

func (*FileGroup) XXX_DiscardUnknown 

func (m *FileGroup) XXX_DiscardUnknown()

func (*FileGroup) XXX_Marshal 

func (m *FileGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileGroup) XXX_Merge 

func (m *FileGroup) XXX_Merge(src proto.Message)

func (*FileGroup) XXX_Size 

func (m *FileGroup) XXX_Size() int

func (*FileGroup) XXX_Unmarshal 

func (m *FileGroup) XXX_Unmarshal(b []byte) error

type LocalTypedReference 

type LocalTypedReference struct {
	// Kind of the referent.
	// More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#types-kinds
	// +optional
	Kind string `json:"kind,omitempty" protobuf:"bytes,1,opt,name=kind"`
	// Name of the referent.
	// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names
	// +optional
	Name string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`
	// API version of the referent.
	// +optional
	APIVersion string `json:"apiVersion,omitempty" protobuf:"bytes,3,opt,name=apiVersion"`
}

LocalTypedReference contains enough information to let you inspect or modify the referred object.

func (*LocalTypedReference) Canonicalize 

func (workload *LocalTypedReference) Canonicalize() error

func (*LocalTypedReference) DeepCopy 

func (in *LocalTypedReference) DeepCopy() *LocalTypedReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalTypedReference.

func (*LocalTypedReference) DeepCopyInto 

func (in *LocalTypedReference) DeepCopyInto(out *LocalTypedReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LocalTypedReference) Descriptor 

func (*LocalTypedReference) Descriptor() ([]byte, []int)

func (LocalTypedReference) GetRepositoryCRDName 

func (workload LocalTypedReference) GetRepositoryCRDName(podName, nodeName string) string

func (LocalTypedReference) HostnamePrefix 

func (workload LocalTypedReference) HostnamePrefix(podName, nodeName string) (hostname, prefix string, err error)

func (*LocalTypedReference) Marshal 

func (m *LocalTypedReference) Marshal() (dAtA []byte, err error)

func (*LocalTypedReference) MarshalTo 

func (m *LocalTypedReference) MarshalTo(dAtA []byte) (int, error)

func (*LocalTypedReference) MarshalToSizedBuffer 

func (m *LocalTypedReference) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LocalTypedReference) ProtoMessage 

func (*LocalTypedReference) ProtoMessage()

func (*LocalTypedReference) Reset 

func (m *LocalTypedReference) Reset()

func (*LocalTypedReference) Size 

func (m *LocalTypedReference) Size() (n int)

func (*LocalTypedReference) String 

func (this *LocalTypedReference) String() string

func (*LocalTypedReference) Unmarshal 

func (m *LocalTypedReference) Unmarshal(dAtA []byte) error

func (*LocalTypedReference) XXX_DiscardUnknown 

func (m *LocalTypedReference) XXX_DiscardUnknown()

func (*LocalTypedReference) XXX_Marshal 

func (m *LocalTypedReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalTypedReference) XXX_Merge 

func (m *LocalTypedReference) XXX_Merge(src proto.Message)

func (*LocalTypedReference) XXX_Size 

func (m *LocalTypedReference) XXX_Size() int

func (*LocalTypedReference) XXX_Unmarshal 

func (m *LocalTypedReference) XXX_Unmarshal(b []byte) error

type Recovery 

type Recovery struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              RecoverySpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status            RecoveryStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=recoveries,singular=recovery,shortName=rec,categories={storage,appscode,all} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Repository-NS",type="string",JSONPath=".spec.repository.namespace" +kubebuilder:printcolumn:name="Repository-Name",type="string",JSONPath=".spec.repository.name" +kubebuilder:printcolumn:name="Snapshot",type="string",JSONPath=".spec.snapshot" +kubebuilder:printcolumn:name="Phase",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (Recovery) CustomResourceDefinition 

func (_ Recovery) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*Recovery) DeepCopy 

func (in *Recovery) DeepCopy() *Recovery

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Recovery.

func (*Recovery) DeepCopyInto 

func (in *Recovery) DeepCopyInto(out *Recovery)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Recovery) DeepCopyObject 

func (in *Recovery) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Recovery) Descriptor 

func (*Recovery) Descriptor() ([]byte, []int)

func (Recovery) IsValid 

func (r Recovery) IsValid() error

func (*Recovery) Marshal 

func (m *Recovery) Marshal() (dAtA []byte, err error)

func (*Recovery) MarshalTo 

func (m *Recovery) MarshalTo(dAtA []byte) (int, error)

func (*Recovery) MarshalToSizedBuffer 

func (m *Recovery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Recovery) ProtoMessage 

func (*Recovery) ProtoMessage()

func (*Recovery) Reset 

func (m *Recovery) Reset()

func (*Recovery) Size 

func (m *Recovery) Size() (n int)

func (*Recovery) String 

func (this *Recovery) String() string

func (*Recovery) Unmarshal 

func (m *Recovery) Unmarshal(dAtA []byte) error

func (*Recovery) XXX_DiscardUnknown 

func (m *Recovery) XXX_DiscardUnknown()

func (*Recovery) XXX_Marshal 

func (m *Recovery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Recovery) XXX_Merge 

func (m *Recovery) XXX_Merge(src proto.Message)

func (*Recovery) XXX_Size 

func (m *Recovery) XXX_Size() int

func (*Recovery) XXX_Unmarshal 

func (m *Recovery) XXX_Unmarshal(b []byte) error

type RecoveryList 

type RecoveryList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Recovery `json:"items,omitempty" protobuf:"bytes,2,rep,name=items"`
}

func (*RecoveryList) DeepCopy 

func (in *RecoveryList) DeepCopy() *RecoveryList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RecoveryList.

func (*RecoveryList) DeepCopyInto 

func (in *RecoveryList) DeepCopyInto(out *RecoveryList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RecoveryList) DeepCopyObject 

func (in *RecoveryList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*RecoveryList) Descriptor 

func (*RecoveryList) Descriptor() ([]byte, []int)

func (*RecoveryList) Marshal 

func (m *RecoveryList) Marshal() (dAtA []byte, err error)

func (*RecoveryList) MarshalTo 

func (m *RecoveryList) MarshalTo(dAtA []byte) (int, error)

func (*RecoveryList) MarshalToSizedBuffer 

func (m *RecoveryList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoveryList) ProtoMessage 

func (*RecoveryList) ProtoMessage()

func (*RecoveryList) Reset 

func (m *RecoveryList) Reset()

func (*RecoveryList) Size 

func (m *RecoveryList) Size() (n int)

func (*RecoveryList) String 

func (this *RecoveryList) String() string

func (*RecoveryList) Unmarshal 

func (m *RecoveryList) Unmarshal(dAtA []byte) error

func (*RecoveryList) XXX_DiscardUnknown 

func (m *RecoveryList) XXX_DiscardUnknown()

func (*RecoveryList) XXX_Marshal 

func (m *RecoveryList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoveryList) XXX_Merge 

func (m *RecoveryList) XXX_Merge(src proto.Message)

func (*RecoveryList) XXX_Size 

func (m *RecoveryList) XXX_Size() int

func (*RecoveryList) XXX_Unmarshal 

func (m *RecoveryList) XXX_Unmarshal(b []byte) error

type RecoveryPhase 

type RecoveryPhase string
const (
	RecoveryPending   RecoveryPhase = "Pending"
	RecoveryRunning   RecoveryPhase = "Running"
	RecoverySucceeded RecoveryPhase = "Succeeded"
	RecoveryFailed    RecoveryPhase = "Failed"
	RecoveryUnknown   RecoveryPhase = "Unknown"
)

type RecoverySpec 

type RecoverySpec struct {
	Repository core.ObjectReference `json:"repository" protobuf:"bytes,1,opt,name=repository"`
	// Snapshot to recover. Default is latest snapshot.
	// +optional
	Snapshot         string                      `json:"snapshot,omitempty" protobuf:"bytes,2,opt,name=snapshot"`
	Paths            []string                    `json:"paths,omitempty" protobuf:"bytes,3,rep,name=paths"`
	RecoveredVolumes []store.LocalSpec           `json:"recoveredVolumes,omitempty" protobuf:"bytes,4,rep,name=recoveredVolumes"`
	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty" protobuf:"bytes,5,rep,name=imagePullSecrets"`

	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,6,rep,name=nodeSelector"`
}

func (*RecoverySpec) DeepCopy 

func (in *RecoverySpec) DeepCopy() *RecoverySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RecoverySpec.

func (*RecoverySpec) DeepCopyInto 

func (in *RecoverySpec) DeepCopyInto(out *RecoverySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RecoverySpec) Descriptor 

func (*RecoverySpec) Descriptor() ([]byte, []int)

func (*RecoverySpec) Marshal 

func (m *RecoverySpec) Marshal() (dAtA []byte, err error)

func (*RecoverySpec) MarshalTo 

func (m *RecoverySpec) MarshalTo(dAtA []byte) (int, error)

func (*RecoverySpec) MarshalToSizedBuffer 

func (m *RecoverySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverySpec) ProtoMessage 

func (*RecoverySpec) ProtoMessage()

func (*RecoverySpec) Reset 

func (m *RecoverySpec) Reset()

func (*RecoverySpec) Size 

func (m *RecoverySpec) Size() (n int)

func (*RecoverySpec) String 

func (this *RecoverySpec) String() string

func (*RecoverySpec) Unmarshal 

func (m *RecoverySpec) Unmarshal(dAtA []byte) error

func (*RecoverySpec) XXX_DiscardUnknown 

func (m *RecoverySpec) XXX_DiscardUnknown()

func (*RecoverySpec) XXX_Marshal 

func (m *RecoverySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoverySpec) XXX_Merge 

func (m *RecoverySpec) XXX_Merge(src proto.Message)

func (*RecoverySpec) XXX_Size 

func (m *RecoverySpec) XXX_Size() int

func (*RecoverySpec) XXX_Unmarshal 

func (m *RecoverySpec) XXX_Unmarshal(b []byte) error

type RecoveryStatus 

type RecoveryStatus struct {
	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
	// resource's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64          `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	Phase              RecoveryPhase  `json:"phase,omitempty" protobuf:"bytes,2,opt,name=phase,casttype=RecoveryPhase"`
	Stats              []RestoreStats `json:"stats,omitempty" protobuf:"bytes,3,rep,name=stats"`
}

func (*RecoveryStatus) DeepCopy 

func (in *RecoveryStatus) DeepCopy() *RecoveryStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RecoveryStatus.

func (*RecoveryStatus) DeepCopyInto 

func (in *RecoveryStatus) DeepCopyInto(out *RecoveryStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RecoveryStatus) Descriptor 

func (*RecoveryStatus) Descriptor() ([]byte, []int)

func (*RecoveryStatus) Marshal 

func (m *RecoveryStatus) Marshal() (dAtA []byte, err error)

func (*RecoveryStatus) MarshalTo 

func (m *RecoveryStatus) MarshalTo(dAtA []byte) (int, error)

func (*RecoveryStatus) MarshalToSizedBuffer 

func (m *RecoveryStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoveryStatus) ProtoMessage 

func (*RecoveryStatus) ProtoMessage()

func (*RecoveryStatus) Reset 

func (m *RecoveryStatus) Reset()

func (*RecoveryStatus) Size 

func (m *RecoveryStatus) Size() (n int)

func (*RecoveryStatus) String 

func (this *RecoveryStatus) String() string

func (*RecoveryStatus) Unmarshal 

func (m *RecoveryStatus) Unmarshal(dAtA []byte) error

func (*RecoveryStatus) XXX_DiscardUnknown 

func (m *RecoveryStatus) XXX_DiscardUnknown()

func (*RecoveryStatus) XXX_Marshal 

func (m *RecoveryStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoveryStatus) XXX_Merge 

func (m *RecoveryStatus) XXX_Merge(src proto.Message)

func (*RecoveryStatus) XXX_Size 

func (m *RecoveryStatus) XXX_Size() int

func (*RecoveryStatus) XXX_Unmarshal 

func (m *RecoveryStatus) XXX_Unmarshal(b []byte) error

type Repository 

type Repository struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              RepositorySpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status            RepositoryStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=repositories,singular=repository,shortName=repo,categories={stash,appscode} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Integrity",type="boolean",JSONPath=".status.integrity" +kubebuilder:printcolumn:name="Size",type="string",JSONPath=".status.totalSize" +kubebuilder:printcolumn:name="Snapshot-Count",type="integer",JSONPath=".status.snapshotCount" +kubebuilder:printcolumn:name="Last-Successful-Backup",type="date",format="date-time",JSONPath=".status.lastBackupTime" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (Repository) CustomResourceDefinition 

func (_ Repository) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*Repository) DeepCopy 

func (in *Repository) DeepCopy() *Repository

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Repository.

func (*Repository) DeepCopyInto 

func (in *Repository) DeepCopyInto(out *Repository)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Repository) DeepCopyObject 

func (in *Repository) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Repository) Descriptor 

func (*Repository) Descriptor() ([]byte, []int)

func (Repository) IsValid 

func (r Repository) IsValid() error

func (*Repository) Marshal 

func (m *Repository) Marshal() (dAtA []byte, err error)

func (*Repository) MarshalTo 

func (m *Repository) MarshalTo(dAtA []byte) (int, error)

func (*Repository) MarshalToSizedBuffer 

func (m *Repository) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Repository) ProtoMessage 

func (*Repository) ProtoMessage()

func (*Repository) Reset 

func (m *Repository) Reset()

func (*Repository) Size 

func (m *Repository) Size() (n int)

func (*Repository) String 

func (this *Repository) String() string

func (*Repository) Unmarshal 

func (m *Repository) Unmarshal(dAtA []byte) error

func (*Repository) XXX_DiscardUnknown 

func (m *Repository) XXX_DiscardUnknown()

func (*Repository) XXX_Marshal 

func (m *Repository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Repository) XXX_Merge 

func (m *Repository) XXX_Merge(src proto.Message)

func (*Repository) XXX_Size 

func (m *Repository) XXX_Size() int

func (*Repository) XXX_Unmarshal 

func (m *Repository) XXX_Unmarshal(b []byte) error

type RepositoryList 

type RepositoryList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Repository `json:"items,omitempty" protobuf:"bytes,2,rep,name=items"`
}

func (*RepositoryList) DeepCopy 

func (in *RepositoryList) DeepCopy() *RepositoryList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RepositoryList.

func (*RepositoryList) DeepCopyInto 

func (in *RepositoryList) DeepCopyInto(out *RepositoryList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RepositoryList) DeepCopyObject 

func (in *RepositoryList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*RepositoryList) Descriptor 

func (*RepositoryList) Descriptor() ([]byte, []int)

func (*RepositoryList) Marshal 

func (m *RepositoryList) Marshal() (dAtA []byte, err error)

func (*RepositoryList) MarshalTo 

func (m *RepositoryList) MarshalTo(dAtA []byte) (int, error)

func (*RepositoryList) MarshalToSizedBuffer 

func (m *RepositoryList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepositoryList) ProtoMessage 

func (*RepositoryList) ProtoMessage()

func (*RepositoryList) Reset 

func (m *RepositoryList) Reset()

func (*RepositoryList) Size 

func (m *RepositoryList) Size() (n int)

func (*RepositoryList) String 

func (this *RepositoryList) String() string

func (*RepositoryList) Unmarshal 

func (m *RepositoryList) Unmarshal(dAtA []byte) error

func (*RepositoryList) XXX_DiscardUnknown 

func (m *RepositoryList) XXX_DiscardUnknown()

func (*RepositoryList) XXX_Marshal 

func (m *RepositoryList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepositoryList) XXX_Merge 

func (m *RepositoryList) XXX_Merge(src proto.Message)

func (*RepositoryList) XXX_Size 

func (m *RepositoryList) XXX_Size() int

func (*RepositoryList) XXX_Unmarshal 

func (m *RepositoryList) XXX_Unmarshal(b []byte) error

type RepositorySpec 

type RepositorySpec struct {
	// Backend specify the storage where backed up snapshot will be stored
	Backend store.Backend `json:"backend,omitempty" protobuf:"bytes,1,opt,name=backend"`
	// If true, delete respective restic repository
	// +optional
	WipeOut bool `json:"wipeOut,omitempty" protobuf:"varint,2,opt,name=wipeOut"`
}

func (*RepositorySpec) DeepCopy 

func (in *RepositorySpec) DeepCopy() *RepositorySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RepositorySpec.

func (*RepositorySpec) DeepCopyInto 

func (in *RepositorySpec) DeepCopyInto(out *RepositorySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RepositorySpec) Descriptor 

func (*RepositorySpec) Descriptor() ([]byte, []int)

func (*RepositorySpec) Marshal 

func (m *RepositorySpec) Marshal() (dAtA []byte, err error)

func (*RepositorySpec) MarshalTo 

func (m *RepositorySpec) MarshalTo(dAtA []byte) (int, error)

func (*RepositorySpec) MarshalToSizedBuffer 

func (m *RepositorySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepositorySpec) ProtoMessage 

func (*RepositorySpec) ProtoMessage()

func (*RepositorySpec) Reset 

func (m *RepositorySpec) Reset()

func (*RepositorySpec) Size 

func (m *RepositorySpec) Size() (n int)

func (*RepositorySpec) String 

func (this *RepositorySpec) String() string

func (*RepositorySpec) Unmarshal 

func (m *RepositorySpec) Unmarshal(dAtA []byte) error

func (*RepositorySpec) XXX_DiscardUnknown 

func (m *RepositorySpec) XXX_DiscardUnknown()

func (*RepositorySpec) XXX_Marshal 

func (m *RepositorySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepositorySpec) XXX_Merge 

func (m *RepositorySpec) XXX_Merge(src proto.Message)

func (*RepositorySpec) XXX_Size 

func (m *RepositorySpec) XXX_Size() int

func (*RepositorySpec) XXX_Unmarshal 

func (m *RepositorySpec) XXX_Unmarshal(b []byte) error

type RepositoryStatus 

type RepositoryStatus struct {
	// ObservedGeneration is the most recent generation observed for this Repository. It corresponds to the
	// Repository's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// FirstBackupTime indicates the timestamp when the first backup was taken
	FirstBackupTime *metav1.Time `json:"firstBackupTime,omitempty" protobuf:"bytes,2,opt,name=firstBackupTime"`
	// LastBackupTime indicates the timestamp when the latest backup was taken
	LastBackupTime *metav1.Time `json:"lastBackupTime,omitempty" protobuf:"bytes,3,opt,name=lastBackupTime"`
	// Integrity shows result of repository integrity check after last backup
	Integrity *bool `json:"integrity,omitempty" protobuf:"varint,4,opt,name=integrity"`
	// TotalSize show size of repository after last backup
	TotalSize string `json:"totalSize,omitempty" protobuf:"bytes,11,opt,name=totalSize"`
	// SnapshotCount shows number of snapshots stored in the repository
	SnapshotCount int64 `json:"snapshotCount,omitempty" protobuf:"varint,6,opt,name=snapshotCount"`
	// SnapshotsRemovedOnLastCleanup shows number of old snapshots cleaned up according to retention policy on last backup session
	SnapshotsRemovedOnLastCleanup int64 `json:"snapshotsRemovedOnLastCleanup,omitempty" protobuf:"varint,7,opt,name=snapshotsRemovedOnLastCleanup"`

	// Deprecated
	LastSuccessfulBackupTime *metav1.Time `json:"lastSuccessfulBackupTime,omitempty" protobuf:"bytes,8,opt,name=lastSuccessfulBackupTime"`
	// Deprecated
	LastBackupDuration string `json:"lastBackupDuration,omitempty" protobuf:"bytes,9,opt,name=lastBackupDuration"`
	// Deprecated
	BackupCount int64 `json:"backupCount,omitempty" protobuf:"varint,10,opt,name=backupCount"`
}

func (*RepositoryStatus) DeepCopy 

func (in *RepositoryStatus) DeepCopy() *RepositoryStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RepositoryStatus.

func (*RepositoryStatus) DeepCopyInto 

func (in *RepositoryStatus) DeepCopyInto(out *RepositoryStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RepositoryStatus) Descriptor 

func (*RepositoryStatus) Descriptor() ([]byte, []int)

func (*RepositoryStatus) Marshal 

func (m *RepositoryStatus) Marshal() (dAtA []byte, err error)

func (*RepositoryStatus) MarshalTo 

func (m *RepositoryStatus) MarshalTo(dAtA []byte) (int, error)

func (*RepositoryStatus) MarshalToSizedBuffer 

func (m *RepositoryStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepositoryStatus) ProtoMessage 

func (*RepositoryStatus) ProtoMessage()

func (*RepositoryStatus) Reset 

func (m *RepositoryStatus) Reset()

func (*RepositoryStatus) Size 

func (m *RepositoryStatus) Size() (n int)

func (*RepositoryStatus) String 

func (this *RepositoryStatus) String() string

func (*RepositoryStatus) Unmarshal 

func (m *RepositoryStatus) Unmarshal(dAtA []byte) error

func (*RepositoryStatus) XXX_DiscardUnknown 

func (m *RepositoryStatus) XXX_DiscardUnknown()

func (*RepositoryStatus) XXX_Marshal 

func (m *RepositoryStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepositoryStatus) XXX_Merge 

func (m *RepositoryStatus) XXX_Merge(src proto.Message)

func (*RepositoryStatus) XXX_Size 

func (m *RepositoryStatus) XXX_Size() int

func (*RepositoryStatus) XXX_Unmarshal 

func (m *RepositoryStatus) XXX_Unmarshal(b []byte) error

type Restic 

type Restic struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              ResticSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=restics,singular=restic,shortName=rst,categories={stash,appscode,all} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Selector",type="string",JSONPath=".spec.selector" +kubebuilder:printcolumn:name="Schedule",type="string",JSONPath=".spec.schedule" +kubebuilder:printcolumn:name="Backup-Type",type="string",JSONPath=".spec.type",priority=10 +kubebuilder:printcolumn:name="Paused",type="boolean",JSONPath=".spec.paused" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (Restic) CustomResourceDefinition 

func (_ Restic) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*Restic) DeepCopy 

func (in *Restic) DeepCopy() *Restic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Restic.

func (*Restic) DeepCopyInto 

func (in *Restic) DeepCopyInto(out *Restic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Restic) DeepCopyObject 

func (in *Restic) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Restic) Descriptor 

func (*Restic) Descriptor() ([]byte, []int)

func (Restic) GetSpecHash 

func (r Restic) GetSpecHash() string

func (Restic) IsValid 

func (r Restic) IsValid() error

func (*Restic) Marshal 

func (m *Restic) Marshal() (dAtA []byte, err error)

func (*Restic) MarshalTo 

func (m *Restic) MarshalTo(dAtA []byte) (int, error)

func (*Restic) MarshalToSizedBuffer 

func (m *Restic) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Restic) ProtoMessage 

func (*Restic) ProtoMessage()

func (*Restic) Reset 

func (m *Restic) Reset()

func (*Restic) Size 

func (m *Restic) Size() (n int)

func (*Restic) String 

func (this *Restic) String() string

func (*Restic) Unmarshal 

func (m *Restic) Unmarshal(dAtA []byte) error

func (*Restic) XXX_DiscardUnknown 

func (m *Restic) XXX_DiscardUnknown()

func (*Restic) XXX_Marshal 

func (m *Restic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Restic) XXX_Merge 

func (m *Restic) XXX_Merge(src proto.Message)

func (*Restic) XXX_Size 

func (m *Restic) XXX_Size() int

func (*Restic) XXX_Unmarshal 

func (m *Restic) XXX_Unmarshal(b []byte) error

type ResticList 

type ResticList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Restic `json:"items,omitempty" protobuf:"bytes,2,rep,name=items"`
}

func (*ResticList) DeepCopy 

func (in *ResticList) DeepCopy() *ResticList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResticList.

func (*ResticList) DeepCopyInto 

func (in *ResticList) DeepCopyInto(out *ResticList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ResticList) DeepCopyObject 

func (in *ResticList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ResticList) Descriptor 

func (*ResticList) Descriptor() ([]byte, []int)

func (*ResticList) Marshal 

func (m *ResticList) Marshal() (dAtA []byte, err error)

func (*ResticList) MarshalTo 

func (m *ResticList) MarshalTo(dAtA []byte) (int, error)

func (*ResticList) MarshalToSizedBuffer 

func (m *ResticList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResticList) ProtoMessage 

func (*ResticList) ProtoMessage()

func (*ResticList) Reset 

func (m *ResticList) Reset()

func (*ResticList) Size 

func (m *ResticList) Size() (n int)

func (*ResticList) String 

func (this *ResticList) String() string

func (*ResticList) Unmarshal 

func (m *ResticList) Unmarshal(dAtA []byte) error

func (*ResticList) XXX_DiscardUnknown 

func (m *ResticList) XXX_DiscardUnknown()

func (*ResticList) XXX_Marshal 

func (m *ResticList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResticList) XXX_Merge 

func (m *ResticList) XXX_Merge(src proto.Message)

func (*ResticList) XXX_Size 

func (m *ResticList) XXX_Size() int

func (*ResticList) XXX_Unmarshal 

func (m *ResticList) XXX_Unmarshal(b []byte) error

type ResticSpec 

type ResticSpec struct {
	Selector   metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,1,opt,name=selector"`
	FileGroups []FileGroup          `json:"fileGroups,omitempty" protobuf:"bytes,2,rep,name=fileGroups"`
	Backend    store.Backend        `json:"backend,omitempty" protobuf:"bytes,3,opt,name=backend"`
	Schedule   string               `json:"schedule,omitempty" protobuf:"bytes,4,opt,name=schedule"`
	// Pod volumes to mount into the sidecar container's filesystem.
	VolumeMounts []core.VolumeMount `json:"volumeMounts,omitempty" protobuf:"bytes,5,rep,name=volumeMounts"`
	// Compute Resources required by the sidecar container.
	Resources         core.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,6,opt,name=resources"`
	RetentionPolicies []RetentionPolicy         `json:"retentionPolicies,omitempty" protobuf:"bytes,7,rep,name=retentionPolicies"`
	// https://github.com/stashed/stash/issues/225
	Type BackupType `json:"type,omitempty" protobuf:"bytes,8,opt,name=type,casttype=BackupType"`
	//Indicates that the Restic is paused from taking backup. Default value is 'false'
	// +optional
	Paused bool `json:"paused,omitempty" protobuf:"varint,9,opt,name=paused"`
	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty" protobuf:"bytes,10,rep,name=imagePullSecrets"`
}

func (*ResticSpec) DeepCopy 

func (in *ResticSpec) DeepCopy() *ResticSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResticSpec.

func (*ResticSpec) DeepCopyInto 

func (in *ResticSpec) DeepCopyInto(out *ResticSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ResticSpec) Descriptor 

func (*ResticSpec) Descriptor() ([]byte, []int)

func (*ResticSpec) Marshal 

func (m *ResticSpec) Marshal() (dAtA []byte, err error)

func (*ResticSpec) MarshalTo 

func (m *ResticSpec) MarshalTo(dAtA []byte) (int, error)

func (*ResticSpec) MarshalToSizedBuffer 

func (m *ResticSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResticSpec) ProtoMessage 

func (*ResticSpec) ProtoMessage()

func (*ResticSpec) Reset 

func (m *ResticSpec) Reset()

func (*ResticSpec) Size 

func (m *ResticSpec) Size() (n int)

func (*ResticSpec) String 

func (this *ResticSpec) String() string

func (*ResticSpec) Unmarshal 

func (m *ResticSpec) Unmarshal(dAtA []byte) error

func (*ResticSpec) XXX_DiscardUnknown 

func (m *ResticSpec) XXX_DiscardUnknown()

func (*ResticSpec) XXX_Marshal 

func (m *ResticSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResticSpec) XXX_Merge 

func (m *ResticSpec) XXX_Merge(src proto.Message)

func (*ResticSpec) XXX_Size 

func (m *ResticSpec) XXX_Size() int

func (*ResticSpec) XXX_Unmarshal 

func (m *ResticSpec) XXX_Unmarshal(b []byte) error

type RestoreStats 

type RestoreStats struct {
	Path     string        `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`
	Phase    RecoveryPhase `json:"phase,omitempty" protobuf:"bytes,2,opt,name=phase,casttype=RecoveryPhase"`
	Duration string        `json:"duration,omitempty" protobuf:"bytes,3,opt,name=duration"`
}

func (*RestoreStats) DeepCopy 

func (in *RestoreStats) DeepCopy() *RestoreStats

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RestoreStats.

func (*RestoreStats) DeepCopyInto 

func (in *RestoreStats) DeepCopyInto(out *RestoreStats)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RestoreStats) Descriptor 

func (*RestoreStats) Descriptor() ([]byte, []int)

func (*RestoreStats) Marshal 

func (m *RestoreStats) Marshal() (dAtA []byte, err error)

func (*RestoreStats) MarshalTo 

func (m *RestoreStats) MarshalTo(dAtA []byte) (int, error)

func (*RestoreStats) MarshalToSizedBuffer 

func (m *RestoreStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RestoreStats) ProtoMessage 

func (*RestoreStats) ProtoMessage()

func (*RestoreStats) Reset 

func (m *RestoreStats) Reset()

func (*RestoreStats) Size 

func (m *RestoreStats) Size() (n int)

func (*RestoreStats) String 

func (this *RestoreStats) String() string

func (*RestoreStats) Unmarshal 

func (m *RestoreStats) Unmarshal(dAtA []byte) error

func (*RestoreStats) XXX_DiscardUnknown 

func (m *RestoreStats) XXX_DiscardUnknown()

func (*RestoreStats) XXX_Marshal 

func (m *RestoreStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreStats) XXX_Merge 

func (m *RestoreStats) XXX_Merge(src proto.Message)

func (*RestoreStats) XXX_Size 

func (m *RestoreStats) XXX_Size() int

func (*RestoreStats) XXX_Unmarshal 

func (m *RestoreStats) XXX_Unmarshal(b []byte) error

type RetentionPolicy 

type RetentionPolicy struct {
	Name        string   `json:"name" protobuf:"bytes,1,opt,name=name"`
	KeepLast    int64    `json:"keepLast,omitempty" protobuf:"varint,2,opt,name=keepLast"`
	KeepHourly  int64    `json:"keepHourly,omitempty" protobuf:"varint,3,opt,name=keepHourly"`
	KeepDaily   int64    `json:"keepDaily,omitempty" protobuf:"varint,4,opt,name=keepDaily"`
	KeepWeekly  int64    `json:"keepWeekly,omitempty" protobuf:"varint,5,opt,name=keepWeekly"`
	KeepMonthly int64    `json:"keepMonthly,omitempty" protobuf:"varint,6,opt,name=keepMonthly"`
	KeepYearly  int64    `json:"keepYearly,omitempty" protobuf:"varint,7,opt,name=keepYearly"`
	KeepTags    []string `json:"keepTags,omitempty" protobuf:"bytes,8,rep,name=keepTags"`
	Prune       bool     `json:"prune" protobuf:"varint,9,opt,name=prune"`
	DryRun      bool     `json:"dryRun,omitempty" protobuf:"varint,10,opt,name=dryRun"`
}

func (*RetentionPolicy) DeepCopy 

func (in *RetentionPolicy) DeepCopy() *RetentionPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionPolicy.

func (*RetentionPolicy) DeepCopyInto 

func (in *RetentionPolicy) DeepCopyInto(out *RetentionPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RetentionPolicy) Descriptor 

func (*RetentionPolicy) Descriptor() ([]byte, []int)

func (*RetentionPolicy) Marshal 

func (m *RetentionPolicy) Marshal() (dAtA []byte, err error)

func (*RetentionPolicy) MarshalTo 

func (m *RetentionPolicy) MarshalTo(dAtA []byte) (int, error)

func (*RetentionPolicy) MarshalToSizedBuffer 

func (m *RetentionPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetentionPolicy) ProtoMessage 

func (*RetentionPolicy) ProtoMessage()

func (*RetentionPolicy) Reset 

func (m *RetentionPolicy) Reset()

func (*RetentionPolicy) Size 

func (m *RetentionPolicy) Size() (n int)

func (*RetentionPolicy) String 

func (this *RetentionPolicy) String() string

func (*RetentionPolicy) Unmarshal 

func (m *RetentionPolicy) Unmarshal(dAtA []byte) error

func (*RetentionPolicy) XXX_DiscardUnknown 

func (m *RetentionPolicy) XXX_DiscardUnknown()

func (*RetentionPolicy) XXX_Marshal 

func (m *RetentionPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetentionPolicy) XXX_Merge 

func (m *RetentionPolicy) XXX_Merge(src proto.Message)

func (*RetentionPolicy) XXX_Size 

func (m *RetentionPolicy) XXX_Size() int

func (*RetentionPolicy) XXX_Unmarshal 

func (m *RetentionPolicy) XXX_Unmarshal(b []byte) error

type RetentionStrategy 

type RetentionStrategy string
const (
	KeepLast    RetentionStrategy = "--keep-last"
	KeepHourly  RetentionStrategy = "--keep-hourly"
	KeepDaily   RetentionStrategy = "--keep-daily"
	KeepWeekly  RetentionStrategy = "--keep-weekly"
	KeepMonthly RetentionStrategy = "--keep-monthly"
	KeepYearly  RetentionStrategy = "--keep-yearly"
	KeepTag     RetentionStrategy = "--keep-tag"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.