Versions in this module Expand all Collapse all v0 v0.6.0 Nov 30, 2017 Changes in this version + func RegisterBackupItemActionServer(s *grpc.Server, srv BackupItemActionServer) + func RegisterBlockStoreServer(s *grpc.Server, srv BlockStoreServer) + func RegisterObjectStoreServer(s *grpc.Server, srv ObjectStoreServer) + func RegisterRestoreItemActionServer(s *grpc.Server, srv RestoreItemActionServer) + type AppliesToResponse struct + ExcludedNamespaces []string + ExcludedResources []string + IncludedNamespaces []string + IncludedResources []string + Selector string + func (*AppliesToResponse) Descriptor() ([]byte, []int) + func (*AppliesToResponse) ProtoMessage() + func (m *AppliesToResponse) GetExcludedNamespaces() []string + func (m *AppliesToResponse) GetExcludedResources() []string + func (m *AppliesToResponse) GetIncludedNamespaces() []string + func (m *AppliesToResponse) GetIncludedResources() []string + func (m *AppliesToResponse) GetSelector() string + func (m *AppliesToResponse) Reset() + func (m *AppliesToResponse) String() string + type BackupItemActionClient interface + AppliesTo func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AppliesToResponse, 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, *Empty) (*AppliesToResponse, error) + Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + type BlockStoreClient 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 *InitRequest, opts ...grpc.CallOption) (*Empty, error) + IsVolumeReady func(ctx context.Context, in *IsVolumeReadyRequest, opts ...grpc.CallOption) (*IsVolumeReadyResponse, error) + SetVolumeID func(ctx context.Context, in *SetVolumeIDRequest, opts ...grpc.CallOption) (*SetVolumeIDResponse, error) + func NewBlockStoreClient(cc *grpc.ClientConn) BlockStoreClient + type BlockStoreServer 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, *InitRequest) (*Empty, error) + IsVolumeReady func(context.Context, *IsVolumeReadyRequest) (*IsVolumeReadyResponse, error) + SetVolumeID func(context.Context, *SetVolumeIDRequest) (*SetVolumeIDResponse, 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 + Ttl int64 + func (*CreateSignedURLRequest) Descriptor() ([]byte, []int) + func (*CreateSignedURLRequest) ProtoMessage() + func (m *CreateSignedURLRequest) GetBucket() string + func (m *CreateSignedURLRequest) GetKey() 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 + Tags map[string]string + VolumeAZ string + VolumeID string + func (*CreateSnapshotRequest) Descriptor() ([]byte, []int) + func (*CreateSnapshotRequest) ProtoMessage() + 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 + SnapshotID string + VolumeAZ string + VolumeType string + func (*CreateVolumeRequest) Descriptor() ([]byte, []int) + func (*CreateVolumeRequest) ProtoMessage() + func (m *CreateVolumeRequest) GetIops() int64 + 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 + func (*DeleteObjectRequest) Descriptor() ([]byte, []int) + func (*DeleteObjectRequest) ProtoMessage() + func (m *DeleteObjectRequest) GetBucket() string + func (m *DeleteObjectRequest) GetKey() string + func (m *DeleteObjectRequest) Reset() + func (m *DeleteObjectRequest) String() string + type DeleteSnapshotRequest struct + SnapshotID string + func (*DeleteSnapshotRequest) Descriptor() ([]byte, []int) + func (*DeleteSnapshotRequest) ProtoMessage() + 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 + func (*ExecuteRequest) Descriptor() ([]byte, []int) + func (*ExecuteRequest) ProtoMessage() + func (m *ExecuteRequest) GetBackup() []byte + func (m *ExecuteRequest) GetItem() []byte + 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 + func (*GetObjectRequest) Descriptor() ([]byte, []int) + func (*GetObjectRequest) ProtoMessage() + func (m *GetObjectRequest) GetBucket() string + func (m *GetObjectRequest) GetKey() string + func (m *GetObjectRequest) Reset() + func (m *GetObjectRequest) String() string + type GetVolumeIDRequest struct + PersistentVolume []byte + func (*GetVolumeIDRequest) Descriptor() ([]byte, []int) + func (*GetVolumeIDRequest) ProtoMessage() + func (m *GetVolumeIDRequest) GetPersistentVolume() []byte + 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 + VolumeAZ string + VolumeID string + func (*GetVolumeInfoRequest) Descriptor() ([]byte, []int) + func (*GetVolumeInfoRequest) ProtoMessage() + 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 InitRequest struct + Config map[string]string + func (*InitRequest) Descriptor() ([]byte, []int) + func (*InitRequest) ProtoMessage() + func (m *InitRequest) GetConfig() map[string]string + func (m *InitRequest) Reset() + func (m *InitRequest) String() string + type IsVolumeReadyRequest struct + VolumeAZ string + VolumeID string + func (*IsVolumeReadyRequest) Descriptor() ([]byte, []int) + func (*IsVolumeReadyRequest) ProtoMessage() + func (m *IsVolumeReadyRequest) GetVolumeAZ() string + func (m *IsVolumeReadyRequest) GetVolumeID() string + func (m *IsVolumeReadyRequest) Reset() + func (m *IsVolumeReadyRequest) String() string + type IsVolumeReadyResponse struct + Ready bool + func (*IsVolumeReadyResponse) Descriptor() ([]byte, []int) + func (*IsVolumeReadyResponse) ProtoMessage() + func (m *IsVolumeReadyResponse) GetReady() bool + func (m *IsVolumeReadyResponse) Reset() + func (m *IsVolumeReadyResponse) String() string + type ListCommonPrefixesRequest struct + Bucket string + Delimiter string + func (*ListCommonPrefixesRequest) Descriptor() ([]byte, []int) + func (*ListCommonPrefixesRequest) ProtoMessage() + func (m *ListCommonPrefixesRequest) GetBucket() string + func (m *ListCommonPrefixesRequest) GetDelimiter() 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 + Prefix string + func (*ListObjectsRequest) Descriptor() ([]byte, []int) + func (*ListObjectsRequest) ProtoMessage() + func (m *ListObjectsRequest) GetBucket() 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 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 *InitRequest, 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) + PutObject func(ctx context.Context, opts ...grpc.CallOption) (ObjectStore_PutObjectClient, error) + func NewObjectStoreClient(cc *grpc.ClientConn) ObjectStoreClient + 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, *InitRequest) (*Empty, error) + ListCommonPrefixes func(context.Context, *ListCommonPrefixesRequest) (*ListCommonPrefixesResponse, error) + ListObjects func(context.Context, *ListObjectsRequest) (*ListObjectsResponse, 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 PutObjectRequest struct + Body []byte + Bucket string + Key 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) 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 RestoreExecuteRequest struct + Item []byte + Restore []byte + func (*RestoreExecuteRequest) Descriptor() ([]byte, []int) + func (*RestoreExecuteRequest) ProtoMessage() + func (m *RestoreExecuteRequest) GetItem() []byte + func (m *RestoreExecuteRequest) GetRestore() []byte + func (m *RestoreExecuteRequest) Reset() + func (m *RestoreExecuteRequest) String() string + type RestoreExecuteResponse struct + Item []byte + Warning string + func (*RestoreExecuteResponse) Descriptor() ([]byte, []int) + func (*RestoreExecuteResponse) ProtoMessage() + func (m *RestoreExecuteResponse) GetItem() []byte + func (m *RestoreExecuteResponse) GetWarning() string + func (m *RestoreExecuteResponse) Reset() + func (m *RestoreExecuteResponse) String() string + type RestoreItemActionClient interface + AppliesTo func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AppliesToResponse, error) + Execute func(ctx context.Context, in *RestoreExecuteRequest, opts ...grpc.CallOption) (*RestoreExecuteResponse, error) + func NewRestoreItemActionClient(cc *grpc.ClientConn) RestoreItemActionClient + type RestoreItemActionServer interface + AppliesTo func(context.Context, *Empty) (*AppliesToResponse, error) + Execute func(context.Context, *RestoreExecuteRequest) (*RestoreExecuteResponse, error) + type SetVolumeIDRequest struct + PersistentVolume []byte + VolumeID string + func (*SetVolumeIDRequest) Descriptor() ([]byte, []int) + func (*SetVolumeIDRequest) ProtoMessage() + func (m *SetVolumeIDRequest) GetPersistentVolume() []byte + 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