Versions in this module Expand all Collapse all v1 v1.3.1 Mar 10, 2020 Changes in this version + func RegisterBackupItemActionServer(s *grpc.Server, srv BackupItemActionServer) + func RegisterObjectStoreServer(s *grpc.Server, srv ObjectStoreServer) + func RegisterPluginListerServer(s *grpc.Server, srv PluginListerServer) + func RegisterRestoreItemActionServer(s *grpc.Server, srv RestoreItemActionServer) + func RegisterVolumeSnapshotterServer(s *grpc.Server, srv VolumeSnapshotterServer) + type BackupItemActionAppliesToRequest struct + Plugin string + func (*BackupItemActionAppliesToRequest) Descriptor() ([]byte, []int) + func (*BackupItemActionAppliesToRequest) ProtoMessage() + func (m *BackupItemActionAppliesToRequest) GetPlugin() string + func (m *BackupItemActionAppliesToRequest) Reset() + func (m *BackupItemActionAppliesToRequest) String() string + type BackupItemActionAppliesToResponse struct + ResourceSelector *ResourceSelector + func (*BackupItemActionAppliesToResponse) Descriptor() ([]byte, []int) + func (*BackupItemActionAppliesToResponse) ProtoMessage() + func (m *BackupItemActionAppliesToResponse) GetResourceSelector() *ResourceSelector + func (m *BackupItemActionAppliesToResponse) Reset() + func (m *BackupItemActionAppliesToResponse) String() string + type BackupItemActionClient interface + AppliesTo func(ctx context.Context, in *BackupItemActionAppliesToRequest, ...) (*BackupItemActionAppliesToResponse, error) + Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) + func NewBackupItemActionClient(cc *grpc.ClientConn) BackupItemActionClient + type BackupItemActionServer interface + AppliesTo func(context.Context, *BackupItemActionAppliesToRequest) (*BackupItemActionAppliesToResponse, error) + Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + type Bytes struct + Data []byte + func (*Bytes) Descriptor() ([]byte, []int) + func (*Bytes) ProtoMessage() + func (m *Bytes) GetData() []byte + func (m *Bytes) Reset() + func (m *Bytes) String() string + type CreateSignedURLRequest struct + Bucket string + Key string + Plugin string + Ttl int64 + func (*CreateSignedURLRequest) Descriptor() ([]byte, []int) + func (*CreateSignedURLRequest) ProtoMessage() + func (m *CreateSignedURLRequest) GetBucket() string + func (m *CreateSignedURLRequest) GetKey() string + func (m *CreateSignedURLRequest) GetPlugin() string + func (m *CreateSignedURLRequest) GetTtl() int64 + func (m *CreateSignedURLRequest) Reset() + func (m *CreateSignedURLRequest) String() string + type CreateSignedURLResponse struct + Url string + func (*CreateSignedURLResponse) Descriptor() ([]byte, []int) + func (*CreateSignedURLResponse) ProtoMessage() + func (m *CreateSignedURLResponse) GetUrl() string + func (m *CreateSignedURLResponse) Reset() + func (m *CreateSignedURLResponse) String() string + type CreateSnapshotRequest struct + Plugin string + Tags map[string]string + VolumeAZ string + VolumeID string + func (*CreateSnapshotRequest) Descriptor() ([]byte, []int) + func (*CreateSnapshotRequest) ProtoMessage() + func (m *CreateSnapshotRequest) GetPlugin() string + func (m *CreateSnapshotRequest) GetTags() map[string]string + func (m *CreateSnapshotRequest) GetVolumeAZ() string + func (m *CreateSnapshotRequest) GetVolumeID() string + func (m *CreateSnapshotRequest) Reset() + func (m *CreateSnapshotRequest) String() string + type CreateSnapshotResponse struct + SnapshotID string + func (*CreateSnapshotResponse) Descriptor() ([]byte, []int) + func (*CreateSnapshotResponse) ProtoMessage() + func (m *CreateSnapshotResponse) GetSnapshotID() string + func (m *CreateSnapshotResponse) Reset() + func (m *CreateSnapshotResponse) String() string + type CreateVolumeRequest struct + Iops int64 + Plugin string + SnapshotID string + VolumeAZ string + VolumeType string + func (*CreateVolumeRequest) Descriptor() ([]byte, []int) + func (*CreateVolumeRequest) ProtoMessage() + func (m *CreateVolumeRequest) GetIops() int64 + func (m *CreateVolumeRequest) GetPlugin() string + func (m *CreateVolumeRequest) GetSnapshotID() string + func (m *CreateVolumeRequest) GetVolumeAZ() string + func (m *CreateVolumeRequest) GetVolumeType() string + func (m *CreateVolumeRequest) Reset() + func (m *CreateVolumeRequest) String() string + type CreateVolumeResponse struct + VolumeID string + func (*CreateVolumeResponse) Descriptor() ([]byte, []int) + func (*CreateVolumeResponse) ProtoMessage() + func (m *CreateVolumeResponse) GetVolumeID() string + func (m *CreateVolumeResponse) Reset() + func (m *CreateVolumeResponse) String() string + type DeleteObjectRequest struct + Bucket string + Key string + Plugin string + func (*DeleteObjectRequest) Descriptor() ([]byte, []int) + func (*DeleteObjectRequest) ProtoMessage() + func (m *DeleteObjectRequest) GetBucket() string + func (m *DeleteObjectRequest) GetKey() string + func (m *DeleteObjectRequest) GetPlugin() string + func (m *DeleteObjectRequest) Reset() + func (m *DeleteObjectRequest) String() string + type DeleteSnapshotRequest struct + Plugin string + SnapshotID string + func (*DeleteSnapshotRequest) Descriptor() ([]byte, []int) + func (*DeleteSnapshotRequest) ProtoMessage() + func (m *DeleteSnapshotRequest) GetPlugin() string + func (m *DeleteSnapshotRequest) GetSnapshotID() string + func (m *DeleteSnapshotRequest) Reset() + func (m *DeleteSnapshotRequest) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type ExecuteRequest struct + Backup []byte + Item []byte + Plugin string + func (*ExecuteRequest) Descriptor() ([]byte, []int) + func (*ExecuteRequest) ProtoMessage() + func (m *ExecuteRequest) GetBackup() []byte + func (m *ExecuteRequest) GetItem() []byte + func (m *ExecuteRequest) GetPlugin() string + func (m *ExecuteRequest) Reset() + func (m *ExecuteRequest) String() string + type ExecuteResponse struct + AdditionalItems []*ResourceIdentifier + Item []byte + func (*ExecuteResponse) Descriptor() ([]byte, []int) + func (*ExecuteResponse) ProtoMessage() + func (m *ExecuteResponse) GetAdditionalItems() []*ResourceIdentifier + func (m *ExecuteResponse) GetItem() []byte + func (m *ExecuteResponse) Reset() + func (m *ExecuteResponse) String() string + type GetObjectRequest struct + Bucket string + Key string + Plugin string + func (*GetObjectRequest) Descriptor() ([]byte, []int) + func (*GetObjectRequest) ProtoMessage() + func (m *GetObjectRequest) GetBucket() string + func (m *GetObjectRequest) GetKey() string + func (m *GetObjectRequest) GetPlugin() string + func (m *GetObjectRequest) Reset() + func (m *GetObjectRequest) String() string + type GetVolumeIDRequest struct + PersistentVolume []byte + Plugin string + func (*GetVolumeIDRequest) Descriptor() ([]byte, []int) + func (*GetVolumeIDRequest) ProtoMessage() + func (m *GetVolumeIDRequest) GetPersistentVolume() []byte + func (m *GetVolumeIDRequest) GetPlugin() string + func (m *GetVolumeIDRequest) Reset() + func (m *GetVolumeIDRequest) String() string + type GetVolumeIDResponse struct + VolumeID string + func (*GetVolumeIDResponse) Descriptor() ([]byte, []int) + func (*GetVolumeIDResponse) ProtoMessage() + func (m *GetVolumeIDResponse) GetVolumeID() string + func (m *GetVolumeIDResponse) Reset() + func (m *GetVolumeIDResponse) String() string + type GetVolumeInfoRequest struct + Plugin string + VolumeAZ string + VolumeID string + func (*GetVolumeInfoRequest) Descriptor() ([]byte, []int) + func (*GetVolumeInfoRequest) ProtoMessage() + func (m *GetVolumeInfoRequest) GetPlugin() string + func (m *GetVolumeInfoRequest) GetVolumeAZ() string + func (m *GetVolumeInfoRequest) GetVolumeID() string + func (m *GetVolumeInfoRequest) Reset() + func (m *GetVolumeInfoRequest) String() string + type GetVolumeInfoResponse struct + Iops int64 + VolumeType string + func (*GetVolumeInfoResponse) Descriptor() ([]byte, []int) + func (*GetVolumeInfoResponse) ProtoMessage() + func (m *GetVolumeInfoResponse) GetIops() int64 + func (m *GetVolumeInfoResponse) GetVolumeType() string + func (m *GetVolumeInfoResponse) Reset() + func (m *GetVolumeInfoResponse) String() string + type ListCommonPrefixesRequest struct + Bucket string + Delimiter string + Plugin string + Prefix string + func (*ListCommonPrefixesRequest) Descriptor() ([]byte, []int) + func (*ListCommonPrefixesRequest) ProtoMessage() + func (m *ListCommonPrefixesRequest) GetBucket() string + func (m *ListCommonPrefixesRequest) GetDelimiter() string + func (m *ListCommonPrefixesRequest) GetPlugin() string + func (m *ListCommonPrefixesRequest) GetPrefix() string + func (m *ListCommonPrefixesRequest) Reset() + func (m *ListCommonPrefixesRequest) String() string + type ListCommonPrefixesResponse struct + Prefixes []string + func (*ListCommonPrefixesResponse) Descriptor() ([]byte, []int) + func (*ListCommonPrefixesResponse) ProtoMessage() + func (m *ListCommonPrefixesResponse) GetPrefixes() []string + func (m *ListCommonPrefixesResponse) Reset() + func (m *ListCommonPrefixesResponse) String() string + type ListObjectsRequest struct + Bucket string + Plugin string + Prefix string + func (*ListObjectsRequest) Descriptor() ([]byte, []int) + func (*ListObjectsRequest) ProtoMessage() + func (m *ListObjectsRequest) GetBucket() string + func (m *ListObjectsRequest) GetPlugin() string + func (m *ListObjectsRequest) GetPrefix() string + func (m *ListObjectsRequest) Reset() + func (m *ListObjectsRequest) String() string + type ListObjectsResponse struct + Keys []string + func (*ListObjectsResponse) Descriptor() ([]byte, []int) + func (*ListObjectsResponse) ProtoMessage() + func (m *ListObjectsResponse) GetKeys() []string + func (m *ListObjectsResponse) Reset() + func (m *ListObjectsResponse) String() string + type ListPluginsResponse struct + Plugins []*PluginIdentifier + func (*ListPluginsResponse) Descriptor() ([]byte, []int) + func (*ListPluginsResponse) ProtoMessage() + func (m *ListPluginsResponse) GetPlugins() []*PluginIdentifier + func (m *ListPluginsResponse) Reset() + func (m *ListPluginsResponse) String() string + type ObjectExistsRequest struct + Bucket string + Key string + Plugin string + func (*ObjectExistsRequest) Descriptor() ([]byte, []int) + func (*ObjectExistsRequest) ProtoMessage() + func (m *ObjectExistsRequest) GetBucket() string + func (m *ObjectExistsRequest) GetKey() string + func (m *ObjectExistsRequest) GetPlugin() string + func (m *ObjectExistsRequest) Reset() + func (m *ObjectExistsRequest) String() string + type ObjectExistsResponse struct + Exists bool + func (*ObjectExistsResponse) Descriptor() ([]byte, []int) + func (*ObjectExistsResponse) ProtoMessage() + func (m *ObjectExistsResponse) GetExists() bool + func (m *ObjectExistsResponse) Reset() + func (m *ObjectExistsResponse) String() string + type ObjectStoreClient interface + CreateSignedURL func(ctx context.Context, in *CreateSignedURLRequest, opts ...grpc.CallOption) (*CreateSignedURLResponse, error) + DeleteObject func(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*Empty, error) + GetObject func(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (ObjectStore_GetObjectClient, error) + Init func(ctx context.Context, in *ObjectStoreInitRequest, opts ...grpc.CallOption) (*Empty, error) + ListCommonPrefixes func(ctx context.Context, in *ListCommonPrefixesRequest, opts ...grpc.CallOption) (*ListCommonPrefixesResponse, error) + ListObjects func(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error) + ObjectExists func(ctx context.Context, in *ObjectExistsRequest, opts ...grpc.CallOption) (*ObjectExistsResponse, error) + PutObject func(ctx context.Context, opts ...grpc.CallOption) (ObjectStore_PutObjectClient, error) + func NewObjectStoreClient(cc *grpc.ClientConn) ObjectStoreClient + type ObjectStoreInitRequest struct + Config map[string]string + Plugin string + func (*ObjectStoreInitRequest) Descriptor() ([]byte, []int) + func (*ObjectStoreInitRequest) ProtoMessage() + func (m *ObjectStoreInitRequest) GetConfig() map[string]string + func (m *ObjectStoreInitRequest) GetPlugin() string + func (m *ObjectStoreInitRequest) Reset() + func (m *ObjectStoreInitRequest) String() string + type ObjectStoreServer interface + CreateSignedURL func(context.Context, *CreateSignedURLRequest) (*CreateSignedURLResponse, error) + DeleteObject func(context.Context, *DeleteObjectRequest) (*Empty, error) + GetObject func(*GetObjectRequest, ObjectStore_GetObjectServer) error + Init func(context.Context, *ObjectStoreInitRequest) (*Empty, error) + ListCommonPrefixes func(context.Context, *ListCommonPrefixesRequest) (*ListCommonPrefixesResponse, error) + ListObjects func(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error) + ObjectExists func(context.Context, *ObjectExistsRequest) (*ObjectExistsResponse, error) + PutObject func(ObjectStore_PutObjectServer) error + type ObjectStore_GetObjectClient interface + Recv func() (*Bytes, error) + type ObjectStore_GetObjectServer interface + Send func(*Bytes) error + type ObjectStore_PutObjectClient interface + CloseAndRecv func() (*Empty, error) + Send func(*PutObjectRequest) error + type ObjectStore_PutObjectServer interface + Recv func() (*PutObjectRequest, error) + SendAndClose func(*Empty) error + type PluginIdentifier struct + Command string + Kind string + Name string + func (*PluginIdentifier) Descriptor() ([]byte, []int) + func (*PluginIdentifier) ProtoMessage() + func (m *PluginIdentifier) GetCommand() string + func (m *PluginIdentifier) GetKind() string + func (m *PluginIdentifier) GetName() string + func (m *PluginIdentifier) Reset() + func (m *PluginIdentifier) String() string + type PluginListerClient interface + ListPlugins func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPluginsResponse, error) + func NewPluginListerClient(cc *grpc.ClientConn) PluginListerClient + type PluginListerServer interface + ListPlugins func(context.Context, *Empty) (*ListPluginsResponse, error) + type PutObjectRequest struct + Body []byte + Bucket string + Key string + Plugin string + func (*PutObjectRequest) Descriptor() ([]byte, []int) + func (*PutObjectRequest) ProtoMessage() + func (m *PutObjectRequest) GetBody() []byte + func (m *PutObjectRequest) GetBucket() string + func (m *PutObjectRequest) GetKey() string + func (m *PutObjectRequest) GetPlugin() string + func (m *PutObjectRequest) Reset() + func (m *PutObjectRequest) String() string + type ResourceIdentifier struct + Group string + Name string + Namespace string + Resource string + func (*ResourceIdentifier) Descriptor() ([]byte, []int) + func (*ResourceIdentifier) ProtoMessage() + func (m *ResourceIdentifier) GetGroup() string + func (m *ResourceIdentifier) GetName() string + func (m *ResourceIdentifier) GetNamespace() string + func (m *ResourceIdentifier) GetResource() string + func (m *ResourceIdentifier) Reset() + func (m *ResourceIdentifier) String() string + type ResourceSelector struct + ExcludedNamespaces []string + ExcludedResources []string + IncludedNamespaces []string + IncludedResources []string + Selector string + func (*ResourceSelector) Descriptor() ([]byte, []int) + func (*ResourceSelector) ProtoMessage() + func (m *ResourceSelector) GetExcludedNamespaces() []string + func (m *ResourceSelector) GetExcludedResources() []string + func (m *ResourceSelector) GetIncludedNamespaces() []string + func (m *ResourceSelector) GetIncludedResources() []string + func (m *ResourceSelector) GetSelector() string + func (m *ResourceSelector) Reset() + func (m *ResourceSelector) String() string + type RestoreItemActionAppliesToRequest struct + Plugin string + func (*RestoreItemActionAppliesToRequest) Descriptor() ([]byte, []int) + func (*RestoreItemActionAppliesToRequest) ProtoMessage() + func (m *RestoreItemActionAppliesToRequest) GetPlugin() string + func (m *RestoreItemActionAppliesToRequest) Reset() + func (m *RestoreItemActionAppliesToRequest) String() string + type RestoreItemActionAppliesToResponse struct + ResourceSelector *ResourceSelector + func (*RestoreItemActionAppliesToResponse) Descriptor() ([]byte, []int) + func (*RestoreItemActionAppliesToResponse) ProtoMessage() + func (m *RestoreItemActionAppliesToResponse) GetResourceSelector() *ResourceSelector + func (m *RestoreItemActionAppliesToResponse) Reset() + func (m *RestoreItemActionAppliesToResponse) String() string + type RestoreItemActionClient interface + AppliesTo func(ctx context.Context, in *RestoreItemActionAppliesToRequest, ...) (*RestoreItemActionAppliesToResponse, error) + Execute func(ctx context.Context, in *RestoreItemActionExecuteRequest, ...) (*RestoreItemActionExecuteResponse, error) + func NewRestoreItemActionClient(cc *grpc.ClientConn) RestoreItemActionClient + type RestoreItemActionExecuteRequest struct + Item []byte + ItemFromBackup []byte + Plugin string + Restore []byte + func (*RestoreItemActionExecuteRequest) Descriptor() ([]byte, []int) + func (*RestoreItemActionExecuteRequest) ProtoMessage() + func (m *RestoreItemActionExecuteRequest) GetItem() []byte + func (m *RestoreItemActionExecuteRequest) GetItemFromBackup() []byte + func (m *RestoreItemActionExecuteRequest) GetPlugin() string + func (m *RestoreItemActionExecuteRequest) GetRestore() []byte + func (m *RestoreItemActionExecuteRequest) Reset() + func (m *RestoreItemActionExecuteRequest) String() string + type RestoreItemActionExecuteResponse struct + AdditionalItems []*ResourceIdentifier + Item []byte + SkipRestore bool + func (*RestoreItemActionExecuteResponse) Descriptor() ([]byte, []int) + func (*RestoreItemActionExecuteResponse) ProtoMessage() + func (m *RestoreItemActionExecuteResponse) GetAdditionalItems() []*ResourceIdentifier + func (m *RestoreItemActionExecuteResponse) GetItem() []byte + func (m *RestoreItemActionExecuteResponse) GetSkipRestore() bool + func (m *RestoreItemActionExecuteResponse) Reset() + func (m *RestoreItemActionExecuteResponse) String() string + type RestoreItemActionServer interface + AppliesTo func(context.Context, *RestoreItemActionAppliesToRequest) (*RestoreItemActionAppliesToResponse, error) + Execute func(context.Context, *RestoreItemActionExecuteRequest) (*RestoreItemActionExecuteResponse, error) + type SetVolumeIDRequest struct + PersistentVolume []byte + Plugin string + VolumeID string + func (*SetVolumeIDRequest) Descriptor() ([]byte, []int) + func (*SetVolumeIDRequest) ProtoMessage() + func (m *SetVolumeIDRequest) GetPersistentVolume() []byte + func (m *SetVolumeIDRequest) GetPlugin() string + func (m *SetVolumeIDRequest) GetVolumeID() string + func (m *SetVolumeIDRequest) Reset() + func (m *SetVolumeIDRequest) String() string + type SetVolumeIDResponse struct + PersistentVolume []byte + func (*SetVolumeIDResponse) Descriptor() ([]byte, []int) + func (*SetVolumeIDResponse) ProtoMessage() + func (m *SetVolumeIDResponse) GetPersistentVolume() []byte + func (m *SetVolumeIDResponse) Reset() + func (m *SetVolumeIDResponse) String() string + type Stack struct + Frames []*StackFrame + func (*Stack) Descriptor() ([]byte, []int) + func (*Stack) ProtoMessage() + func (m *Stack) GetFrames() []*StackFrame + func (m *Stack) Reset() + func (m *Stack) String() string + type StackFrame struct + File string + Function string + Line int32 + func (*StackFrame) Descriptor() ([]byte, []int) + func (*StackFrame) ProtoMessage() + func (m *StackFrame) GetFile() string + func (m *StackFrame) GetFunction() string + func (m *StackFrame) GetLine() int32 + func (m *StackFrame) Reset() + func (m *StackFrame) String() string + type VolumeSnapshotterClient interface + CreateSnapshot func(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*CreateSnapshotResponse, error) + CreateVolumeFromSnapshot func(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error) + DeleteSnapshot func(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*Empty, error) + GetVolumeID func(ctx context.Context, in *GetVolumeIDRequest, opts ...grpc.CallOption) (*GetVolumeIDResponse, error) + GetVolumeInfo func(ctx context.Context, in *GetVolumeInfoRequest, opts ...grpc.CallOption) (*GetVolumeInfoResponse, error) + Init func(ctx context.Context, in *VolumeSnapshotterInitRequest, opts ...grpc.CallOption) (*Empty, error) + SetVolumeID func(ctx context.Context, in *SetVolumeIDRequest, opts ...grpc.CallOption) (*SetVolumeIDResponse, error) + func NewVolumeSnapshotterClient(cc *grpc.ClientConn) VolumeSnapshotterClient + type VolumeSnapshotterInitRequest struct + Config map[string]string + Plugin string + func (*VolumeSnapshotterInitRequest) Descriptor() ([]byte, []int) + func (*VolumeSnapshotterInitRequest) ProtoMessage() + func (m *VolumeSnapshotterInitRequest) GetConfig() map[string]string + func (m *VolumeSnapshotterInitRequest) GetPlugin() string + func (m *VolumeSnapshotterInitRequest) Reset() + func (m *VolumeSnapshotterInitRequest) String() string + type VolumeSnapshotterServer interface + CreateSnapshot func(context.Context, *CreateSnapshotRequest) (*CreateSnapshotResponse, error) + CreateVolumeFromSnapshot func(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error) + DeleteSnapshot func(context.Context, *DeleteSnapshotRequest) (*Empty, error) + GetVolumeID func(context.Context, *GetVolumeIDRequest) (*GetVolumeIDResponse, error) + GetVolumeInfo func(context.Context, *GetVolumeInfoRequest) (*GetVolumeInfoResponse, error) + Init func(context.Context, *VolumeSnapshotterInitRequest) (*Empty, error) + SetVolumeID func(context.Context, *SetVolumeIDRequest) (*SetVolumeIDResponse, error)