Versions in this module Expand all Collapse all v0 v0.2.134 Dec 25, 2019 Changes in this version + const AnnotationBlockStorageCopyFrom + const AnnotationBlockStorageFetchFrom + const AnnotationBlockStorageRequestNodeName + const AnnotationBlockStorageURL + const AnnotationStorageReservedBy + const DownloadBlockStorageHTTPPrefix + func ApplyBlockStorage(ds datastore.Datastore, resource *pprovisioning.BlockStorage) error + func DeleteBlockStorage(ds datastore.Datastore, name string) error + func GetAndPendExistingBlockStorage(tx *transaction.Transaction, ds datastore.Datastore, name string) (*pprovisioning.BlockStorage, error) + func GetBlockStorage(ctx context.Context, req *pprovisioning.GetBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func ListBlockStorages(ctx context.Context, req *pprovisioning.ListBlockStoragesRequest, ...) (*pprovisioning.ListBlockStoragesResponse, error) + func PendNewBlockStorage(tx *transaction.Transaction, ds datastore.Datastore, name string) error + func RegisterBlockStorageAgentServiceServer(s *grpc.Server, srv BlockStorageAgentServiceServer) + func ReleaseStorage(ctx context.Context, tx *transaction.Transaction, na ppool.NodeServiceClient, ...) error + func ReserveStorage(ctx context.Context, tx *transaction.Transaction, na ppool.NodeServiceClient, ...) error + type BlockStorageAPI struct + func CreateBlockStorageAPI(ds datastore.Datastore, na ppool.NodeServiceClient) *BlockStorageAPI + func (a *BlockStorageAPI) CopyBlockStorage(ctx context.Context, req *pprovisioning.CopyBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) CreateBlockStorage(ctx context.Context, req *pprovisioning.CreateBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) DeleteBlockStorage(ctx context.Context, req *pprovisioning.DeleteBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) DownloadBlockStorage(ctx context.Context, req *pprovisioning.DownloadBlockStorageRequest) (*pprovisioning.DownloadBlockStorageResponse, error) + func (a *BlockStorageAPI) FetchBlockStorage(ctx context.Context, req *pprovisioning.FetchBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) GetBlockStorage(ctx context.Context, req *pprovisioning.GetBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) ListBlockStorages(ctx context.Context, req *pprovisioning.ListBlockStoragesRequest) (*pprovisioning.ListBlockStoragesResponse, error) + func (a *BlockStorageAPI) ProxyDownloadBlockStorage(agentPort int, basePath string) func(echo.Context) error + func (a *BlockStorageAPI) PurgeBlockStorage(ctx context.Context, req *pprovisioning.PurgeBlockStorageRequest) (*empty.Empty, error) + func (a *BlockStorageAPI) SetAvailableBlockStorage(ctx context.Context, req *pprovisioning.SetAvailableBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) SetInuseBlockStorage(ctx context.Context, req *pprovisioning.SetInuseBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) SetProtectedBlockStorage(ctx context.Context, req *pprovisioning.SetProtectedBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) UndeleteBlockStorage(ctx context.Context, req *pprovisioning.UndeleteBlockStorageRequest) (*pprovisioning.BlockStorage, error) + func (a *BlockStorageAPI) UpdateBlockStorage(ctx context.Context, req *pprovisioning.UpdateBlockStorageRequest) (*pprovisioning.BlockStorage, error) + type BlockStorageAgentAPI struct + func CreateBlockStorageAgentAPI(basedir string) (*BlockStorageAgentAPI, error) + func (a *BlockStorageAgentAPI) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error) + func (a *BlockStorageAgentAPI) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error) + func (a *BlockStorageAgentAPI) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error) + func (a *BlockStorageAgentAPI) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error) + type BlockStorageAgentServiceClient interface + CreateEmptyBlockStorage func(ctx context.Context, in *CreateEmptyBlockStorageRequest, ...) (*CreateEmptyBlockStorageResponse, error) + DeleteBlockStorage func(ctx context.Context, in *DeleteBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error) + FetchBlockStorage func(ctx context.Context, in *FetchBlockStorageRequest, opts ...grpc.CallOption) (*FetchBlockStorageResponse, error) + ResizeBlockStorage func(ctx context.Context, in *ResizeBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewBlockStorageAgentServiceClient(cc *grpc.ClientConn) BlockStorageAgentServiceClient + type BlockStorageAgentServiceServer interface + CreateEmptyBlockStorage func(context.Context, *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error) + DeleteBlockStorage func(context.Context, *DeleteBlockStorageRequest) (*empty.Empty, error) + FetchBlockStorage func(context.Context, *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error) + ResizeBlockStorage func(context.Context, *ResizeBlockStorageRequest) (*empty.Empty, error) + type CreateEmptyBlockStorageRequest struct + Bytes uint64 + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEmptyBlockStorageRequest) Descriptor() ([]byte, []int) + func (*CreateEmptyBlockStorageRequest) ProtoMessage() + func (m *CreateEmptyBlockStorageRequest) GetBytes() uint64 + func (m *CreateEmptyBlockStorageRequest) GetName() string + func (m *CreateEmptyBlockStorageRequest) Reset() + func (m *CreateEmptyBlockStorageRequest) String() string + func (m *CreateEmptyBlockStorageRequest) XXX_DiscardUnknown() + func (m *CreateEmptyBlockStorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEmptyBlockStorageRequest) XXX_Merge(src proto.Message) + func (m *CreateEmptyBlockStorageRequest) XXX_Size() int + func (m *CreateEmptyBlockStorageRequest) XXX_Unmarshal(b []byte) error + type CreateEmptyBlockStorageResponse struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEmptyBlockStorageResponse) Descriptor() ([]byte, []int) + func (*CreateEmptyBlockStorageResponse) ProtoMessage() + func (m *CreateEmptyBlockStorageResponse) GetPath() string + func (m *CreateEmptyBlockStorageResponse) Reset() + func (m *CreateEmptyBlockStorageResponse) String() string + func (m *CreateEmptyBlockStorageResponse) XXX_DiscardUnknown() + func (m *CreateEmptyBlockStorageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEmptyBlockStorageResponse) XXX_Merge(src proto.Message) + func (m *CreateEmptyBlockStorageResponse) XXX_Size() int + func (m *CreateEmptyBlockStorageResponse) XXX_Unmarshal(b []byte) error + type DeleteBlockStorageRequest struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteBlockStorageRequest) Descriptor() ([]byte, []int) + func (*DeleteBlockStorageRequest) ProtoMessage() + func (m *DeleteBlockStorageRequest) GetPath() string + func (m *DeleteBlockStorageRequest) Reset() + func (m *DeleteBlockStorageRequest) String() string + func (m *DeleteBlockStorageRequest) XXX_DiscardUnknown() + func (m *DeleteBlockStorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteBlockStorageRequest) XXX_Merge(src proto.Message) + func (m *DeleteBlockStorageRequest) XXX_Size() int + func (m *DeleteBlockStorageRequest) XXX_Unmarshal(b []byte) error + type FetchBlockStorageRequest struct + Bytes uint64 + Name string + SourceUrl string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchBlockStorageRequest) Descriptor() ([]byte, []int) + func (*FetchBlockStorageRequest) ProtoMessage() + func (m *FetchBlockStorageRequest) GetBytes() uint64 + func (m *FetchBlockStorageRequest) GetName() string + func (m *FetchBlockStorageRequest) GetSourceUrl() string + func (m *FetchBlockStorageRequest) Reset() + func (m *FetchBlockStorageRequest) String() string + func (m *FetchBlockStorageRequest) XXX_DiscardUnknown() + func (m *FetchBlockStorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchBlockStorageRequest) XXX_Merge(src proto.Message) + func (m *FetchBlockStorageRequest) XXX_Size() int + func (m *FetchBlockStorageRequest) XXX_Unmarshal(b []byte) error + type FetchBlockStorageResponse struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchBlockStorageResponse) Descriptor() ([]byte, []int) + func (*FetchBlockStorageResponse) ProtoMessage() + func (m *FetchBlockStorageResponse) GetPath() string + func (m *FetchBlockStorageResponse) Reset() + func (m *FetchBlockStorageResponse) String() string + func (m *FetchBlockStorageResponse) XXX_DiscardUnknown() + func (m *FetchBlockStorageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchBlockStorageResponse) XXX_Merge(src proto.Message) + func (m *FetchBlockStorageResponse) XXX_Size() int + func (m *FetchBlockStorageResponse) XXX_Unmarshal(b []byte) error + type MockBlockStorageAPI struct + NodeAPI *node.MockNodeAPI + func NewMockBlcokStorageAPI(datastore *memory.MemoryDatastore) *MockBlockStorageAPI + func (a MockBlockStorageAPI) CopyBlockStorage(ctx context.Context, in *pprovisioning.CopyBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) CreateBlockStorage(ctx context.Context, in *pprovisioning.CreateBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) DeleteBlockStorage(ctx context.Context, in *pprovisioning.DeleteBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) DownloadBlockStorage(ctx context.Context, in *pprovisioning.DownloadBlockStorageRequest, ...) (*pprovisioning.DownloadBlockStorageResponse, error) + func (a MockBlockStorageAPI) FactoryBlockStorage(ctx context.Context, nodeName string) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) FetchBlockStorage(ctx context.Context, in *pprovisioning.FetchBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) GetBlockStorage(ctx context.Context, in *pprovisioning.GetBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) ListBlockStorages(ctx context.Context, in *pprovisioning.ListBlockStoragesRequest, ...) (*pprovisioning.ListBlockStoragesResponse, error) + func (a MockBlockStorageAPI) PurgeBlockStorage(ctx context.Context, in *pprovisioning.PurgeBlockStorageRequest, ...) (*empty.Empty, error) + func (a MockBlockStorageAPI) SetAvailableBlockStorage(ctx context.Context, in *pprovisioning.SetAvailableBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) SetInuseBlockStorage(ctx context.Context, in *pprovisioning.SetInuseBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) SetProtectedBlockStorage(ctx context.Context, in *pprovisioning.SetProtectedBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) UndeleteBlockStorage(ctx context.Context, in *pprovisioning.UndeleteBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + func (a MockBlockStorageAPI) UpdateBlockStorage(ctx context.Context, in *pprovisioning.UpdateBlockStorageRequest, ...) (*pprovisioning.BlockStorage, error) + type MockBlockStorageAgentAPI struct + func (a MockBlockStorageAgentAPI) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error) + func (a MockBlockStorageAgentAPI) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error) + func (a MockBlockStorageAgentAPI) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error) + func (a MockBlockStorageAgentAPI) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error) + type MockBlockStorageAgentClient struct + func NewMockBlockStorageAgentClient() *MockBlockStorageAgentClient + func (a MockBlockStorageAgentClient) CreateEmptyBlockStorage(ctx context.Context, in *CreateEmptyBlockStorageRequest, ...) (*CreateEmptyBlockStorageResponse, error) + func (a MockBlockStorageAgentClient) DeleteBlockStorage(ctx context.Context, in *DeleteBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (a MockBlockStorageAgentClient) FetchBlockStorage(ctx context.Context, in *FetchBlockStorageRequest, opts ...grpc.CallOption) (*FetchBlockStorageResponse, error) + func (a MockBlockStorageAgentClient) ResizeBlockStorage(ctx context.Context, in *ResizeBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error) + type ResizeBlockStorageRequest struct + Bytes uint64 + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeBlockStorageRequest) Descriptor() ([]byte, []int) + func (*ResizeBlockStorageRequest) ProtoMessage() + func (m *ResizeBlockStorageRequest) GetBytes() uint64 + func (m *ResizeBlockStorageRequest) GetPath() string + func (m *ResizeBlockStorageRequest) Reset() + func (m *ResizeBlockStorageRequest) String() string + func (m *ResizeBlockStorageRequest) XXX_DiscardUnknown() + func (m *ResizeBlockStorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeBlockStorageRequest) XXX_Merge(src proto.Message) + func (m *ResizeBlockStorageRequest) XXX_Size() int + func (m *ResizeBlockStorageRequest) XXX_Unmarshal(b []byte) error + type UnimplementedBlockStorageAgentServiceServer struct + func (*UnimplementedBlockStorageAgentServiceServer) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error) + func (*UnimplementedBlockStorageAgentServiceServer) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error) + func (*UnimplementedBlockStorageAgentServiceServer) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error) + func (*UnimplementedBlockStorageAgentServiceServer) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error)
Go to main page