blockstorage

package
v0.2.134 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2019 License: BSD-2-Clause Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const AnnotationBlockStorageCopyFrom = "n0core/provisioning/block_storage/copy_from"
View Source 
const AnnotationBlockStorageFetchFrom = "n0core/provisioning/block_storage/fetch_from"
View Source 
const AnnotationBlockStorageRequestNodeName = "n0core/provisioning/block_storage/request_node_name"
View Source 
const AnnotationBlockStorageURL = "n0core/provisioning/block_storage/url"

Create のときに自動生成、消されると困る

View Source 
const AnnotationStorageReservedBy = "n0core/provisioning/block_storage/reserved_by"
View Source 
const DownloadBlockStorageHTTPPrefix = "/api/block_storage/files"

Variables

This section is empty.

Functions

func ApplyBlockStorage 

func ApplyBlockStorage(ds datastore.Datastore, resource *pprovisioning.BlockStorage) error

func DeleteBlockStorage 

func DeleteBlockStorage(ds datastore.Datastore, name string) error

func GetAndPendExistingBlockStorage 

func GetAndPendExistingBlockStorage(tx *transaction.Transaction, ds datastore.Datastore, name string) (*pprovisioning.BlockStorage, error)

func GetBlockStorage 

func GetBlockStorage(ctx context.Context, req *pprovisioning.GetBlockStorageRequest, ds datastore.Datastore) (*pprovisioning.BlockStorage, error)

func ListBlockStorages 

func ListBlockStorages(ctx context.Context, req *pprovisioning.ListBlockStoragesRequest, ds datastore.Datastore) (*pprovisioning.ListBlockStoragesResponse, error)

func PendNewBlockStorage 

func PendNewBlockStorage(tx *transaction.Transaction, ds datastore.Datastore, name string) error

func RegisterBlockStorageAgentServiceServer 

func RegisterBlockStorageAgentServiceServer(s *grpc.Server, srv BlockStorageAgentServiceServer)

func ReleaseStorage 

func ReleaseStorage(ctx context.Context, tx *transaction.Transaction, na ppool.NodeServiceClient, bs *pprovisioning.BlockStorage) error

Release a block storage on a node using NodeServiceClient.

func ReserveStorage 

func ReserveStorage(ctx context.Context, tx *transaction.Transaction, na ppool.NodeServiceClient, bs *pprovisioning.BlockStorage) error

Reserve a block storage on a node using NodeServiceClient.

Types

type BlockStorageAPI 

type BlockStorageAPI struct {
	// contains filtered or unexported fields
}

func CreateBlockStorageAPI 

func CreateBlockStorageAPI(ds datastore.Datastore, na ppool.NodeServiceClient) *BlockStorageAPI

func (*BlockStorageAPI) CopyBlockStorage 

func (a *BlockStorageAPI) CopyBlockStorage(ctx context.Context, req *pprovisioning.CopyBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) CreateBlockStorage 

func (a *BlockStorageAPI) CreateBlockStorage(ctx context.Context, req *pprovisioning.CreateBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) DeleteBlockStorage 

func (a *BlockStorageAPI) DeleteBlockStorage(ctx context.Context, req *pprovisioning.DeleteBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) DownloadBlockStorage 

func (a *BlockStorageAPI) DownloadBlockStorage(ctx context.Context, req *pprovisioning.DownloadBlockStorageRequest) (*pprovisioning.DownloadBlockStorageResponse, error)

func (*BlockStorageAPI) FetchBlockStorage 

func (a *BlockStorageAPI) FetchBlockStorage(ctx context.Context, req *pprovisioning.FetchBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) GetBlockStorage 

func (a *BlockStorageAPI) GetBlockStorage(ctx context.Context, req *pprovisioning.GetBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) ListBlockStorages 

func (a *BlockStorageAPI) ListBlockStorages(ctx context.Context, req *pprovisioning.ListBlockStoragesRequest) (*pprovisioning.ListBlockStoragesResponse, error)

func (*BlockStorageAPI) ProxyDownloadBlockStorage 

func (a *BlockStorageAPI) ProxyDownloadBlockStorage(agentPort int, basePath string) func(echo.Context) error

TODO: agentPort は Node から取れるようにしたい

func (*BlockStorageAPI) PurgeBlockStorage 

func (a *BlockStorageAPI) PurgeBlockStorage(ctx context.Context, req *pprovisioning.PurgeBlockStorageRequest) (*empty.Empty, error)

func (*BlockStorageAPI) SetAvailableBlockStorage 

func (a *BlockStorageAPI) SetAvailableBlockStorage(ctx context.Context, req *pprovisioning.SetAvailableBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) SetInuseBlockStorage 

func (a *BlockStorageAPI) SetInuseBlockStorage(ctx context.Context, req *pprovisioning.SetInuseBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) SetProtectedBlockStorage 

func (a *BlockStorageAPI) SetProtectedBlockStorage(ctx context.Context, req *pprovisioning.SetProtectedBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) UndeleteBlockStorage 

func (a *BlockStorageAPI) UndeleteBlockStorage(ctx context.Context, req *pprovisioning.UndeleteBlockStorageRequest) (*pprovisioning.BlockStorage, error)

func (*BlockStorageAPI) UpdateBlockStorage 

func (a *BlockStorageAPI) UpdateBlockStorage(ctx context.Context, req *pprovisioning.UpdateBlockStorageRequest) (*pprovisioning.BlockStorage, error)

Update a blocok storage: update its request bytes, limit bytes, and request node, a node to host the block storage.

type BlockStorageAgentAPI 

type BlockStorageAgentAPI struct {
	// contains filtered or unexported fields
}

func CreateBlockStorageAgentAPI 

func CreateBlockStorageAgentAPI(basedir string) (*BlockStorageAgentAPI, error)

func (*BlockStorageAgentAPI) CreateEmptyBlockStorage 

func (a *BlockStorageAgentAPI) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error)

func (*BlockStorageAgentAPI) DeleteBlockStorage 

func (a *BlockStorageAgentAPI) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error)

func (*BlockStorageAgentAPI) FetchBlockStorage 

func (a *BlockStorageAgentAPI) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error)

タイムアウトが心配

func (*BlockStorageAgentAPI) ResizeBlockStorage 

func (a *BlockStorageAgentAPI) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error)

type BlockStorageAgentServiceClient 

type BlockStorageAgentServiceClient interface {
	CreateEmptyBlockStorage(ctx context.Context, in *CreateEmptyBlockStorageRequest, opts ...grpc.CallOption) (*CreateEmptyBlockStorageResponse, error)
	FetchBlockStorage(ctx context.Context, in *FetchBlockStorageRequest, opts ...grpc.CallOption) (*FetchBlockStorageResponse, error)
	DeleteBlockStorage(ctx context.Context, in *DeleteBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ResizeBlockStorage(ctx context.Context, in *ResizeBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

BlockStorageAgentServiceClient is the client API for BlockStorageAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBlockStorageAgentServiceClient 

func NewBlockStorageAgentServiceClient(cc *grpc.ClientConn) BlockStorageAgentServiceClient

type BlockStorageAgentServiceServer 

type BlockStorageAgentServiceServer interface {
	CreateEmptyBlockStorage(context.Context, *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error)
	FetchBlockStorage(context.Context, *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error)
	DeleteBlockStorage(context.Context, *DeleteBlockStorageRequest) (*empty.Empty, error)
	ResizeBlockStorage(context.Context, *ResizeBlockStorageRequest) (*empty.Empty, error)
}

BlockStorageAgentServiceServer is the server API for BlockStorageAgentService service.

type CreateEmptyBlockStorageRequest 

type CreateEmptyBlockStorageRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateEmptyBlockStorageRequest) Descriptor 

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

func (*CreateEmptyBlockStorageRequest) GetBytes 

func (m *CreateEmptyBlockStorageRequest) GetBytes() uint64

func (*CreateEmptyBlockStorageRequest) GetName 

func (m *CreateEmptyBlockStorageRequest) GetName() string

func (*CreateEmptyBlockStorageRequest) ProtoMessage 

func (*CreateEmptyBlockStorageRequest) ProtoMessage()

func (*CreateEmptyBlockStorageRequest) Reset 

func (m *CreateEmptyBlockStorageRequest) Reset()

func (*CreateEmptyBlockStorageRequest) String 

func (m *CreateEmptyBlockStorageRequest) String() string

func (*CreateEmptyBlockStorageRequest) XXX_DiscardUnknown 

func (m *CreateEmptyBlockStorageRequest) XXX_DiscardUnknown()

func (*CreateEmptyBlockStorageRequest) XXX_Marshal 

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

func (*CreateEmptyBlockStorageRequest) XXX_Merge 

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

func (*CreateEmptyBlockStorageRequest) XXX_Size 

func (m *CreateEmptyBlockStorageRequest) XXX_Size() int

func (*CreateEmptyBlockStorageRequest) XXX_Unmarshal 

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

type CreateEmptyBlockStorageResponse 

type CreateEmptyBlockStorageResponse struct {
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateEmptyBlockStorageResponse) Descriptor 

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

func (*CreateEmptyBlockStorageResponse) GetPath 

func (m *CreateEmptyBlockStorageResponse) GetPath() string

func (*CreateEmptyBlockStorageResponse) ProtoMessage 

func (*CreateEmptyBlockStorageResponse) ProtoMessage()

func (*CreateEmptyBlockStorageResponse) Reset 

func (m *CreateEmptyBlockStorageResponse) Reset()

func (*CreateEmptyBlockStorageResponse) String 

func (m *CreateEmptyBlockStorageResponse) String() string

func (*CreateEmptyBlockStorageResponse) XXX_DiscardUnknown 

func (m *CreateEmptyBlockStorageResponse) XXX_DiscardUnknown()

func (*CreateEmptyBlockStorageResponse) XXX_Marshal 

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

func (*CreateEmptyBlockStorageResponse) XXX_Merge 

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

func (*CreateEmptyBlockStorageResponse) XXX_Size 

func (m *CreateEmptyBlockStorageResponse) XXX_Size() int

func (*CreateEmptyBlockStorageResponse) XXX_Unmarshal 

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

type DeleteBlockStorageRequest 

type DeleteBlockStorageRequest struct {
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteBlockStorageRequest) Descriptor 

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

func (*DeleteBlockStorageRequest) GetPath 

func (m *DeleteBlockStorageRequest) GetPath() string

func (*DeleteBlockStorageRequest) ProtoMessage 

func (*DeleteBlockStorageRequest) ProtoMessage()

func (*DeleteBlockStorageRequest) Reset 

func (m *DeleteBlockStorageRequest) Reset()

func (*DeleteBlockStorageRequest) String 

func (m *DeleteBlockStorageRequest) String() string

func (*DeleteBlockStorageRequest) XXX_DiscardUnknown 

func (m *DeleteBlockStorageRequest) XXX_DiscardUnknown()

func (*DeleteBlockStorageRequest) XXX_Marshal 

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

func (*DeleteBlockStorageRequest) XXX_Merge 

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

func (*DeleteBlockStorageRequest) XXX_Size 

func (m *DeleteBlockStorageRequest) XXX_Size() int

func (*DeleteBlockStorageRequest) XXX_Unmarshal 

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

type FetchBlockStorageRequest 

type FetchBlockStorageRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	SourceUrl            string   `protobuf:"bytes,3,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchBlockStorageRequest) Descriptor 

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

func (*FetchBlockStorageRequest) GetBytes 

func (m *FetchBlockStorageRequest) GetBytes() uint64

func (*FetchBlockStorageRequest) GetName 

func (m *FetchBlockStorageRequest) GetName() string

func (*FetchBlockStorageRequest) GetSourceUrl 

func (m *FetchBlockStorageRequest) GetSourceUrl() string

func (*FetchBlockStorageRequest) ProtoMessage 

func (*FetchBlockStorageRequest) ProtoMessage()

func (*FetchBlockStorageRequest) Reset 

func (m *FetchBlockStorageRequest) Reset()

func (*FetchBlockStorageRequest) String 

func (m *FetchBlockStorageRequest) String() string

func (*FetchBlockStorageRequest) XXX_DiscardUnknown 

func (m *FetchBlockStorageRequest) XXX_DiscardUnknown()

func (*FetchBlockStorageRequest) XXX_Marshal 

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

func (*FetchBlockStorageRequest) XXX_Merge 

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

func (*FetchBlockStorageRequest) XXX_Size 

func (m *FetchBlockStorageRequest) XXX_Size() int

func (*FetchBlockStorageRequest) XXX_Unmarshal 

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

type FetchBlockStorageResponse 

type FetchBlockStorageResponse struct {
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchBlockStorageResponse) Descriptor 

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

func (*FetchBlockStorageResponse) GetPath 

func (m *FetchBlockStorageResponse) GetPath() string

func (*FetchBlockStorageResponse) ProtoMessage 

func (*FetchBlockStorageResponse) ProtoMessage()

func (*FetchBlockStorageResponse) Reset 

func (m *FetchBlockStorageResponse) Reset()

func (*FetchBlockStorageResponse) String 

func (m *FetchBlockStorageResponse) String() string

func (*FetchBlockStorageResponse) XXX_DiscardUnknown 

func (m *FetchBlockStorageResponse) XXX_DiscardUnknown()

func (*FetchBlockStorageResponse) XXX_Marshal 

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

func (*FetchBlockStorageResponse) XXX_Merge 

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

func (*FetchBlockStorageResponse) XXX_Size 

func (m *FetchBlockStorageResponse) XXX_Size() int

func (*FetchBlockStorageResponse) XXX_Unmarshal 

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

type MockBlockStorageAPI 

type MockBlockStorageAPI struct {
	NodeAPI *node.MockNodeAPI
	// contains filtered or unexported fields
}

func NewMockBlcokStorageAPI 

func NewMockBlcokStorageAPI(datastore *memory.MemoryDatastore) *MockBlockStorageAPI

func (MockBlockStorageAPI) CopyBlockStorage 

func (a MockBlockStorageAPI) CopyBlockStorage(ctx context.Context, in *pprovisioning.CopyBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) CreateBlockStorage 

func (a MockBlockStorageAPI) CreateBlockStorage(ctx context.Context, in *pprovisioning.CreateBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) DeleteBlockStorage 

func (a MockBlockStorageAPI) DeleteBlockStorage(ctx context.Context, in *pprovisioning.DeleteBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) DownloadBlockStorage 

func (a MockBlockStorageAPI) DownloadBlockStorage(ctx context.Context, in *pprovisioning.DownloadBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.DownloadBlockStorageResponse, error)

func (MockBlockStorageAPI) FactoryBlockStorage 

func (a MockBlockStorageAPI) FactoryBlockStorage(ctx context.Context, nodeName string) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) FetchBlockStorage 

func (a MockBlockStorageAPI) FetchBlockStorage(ctx context.Context, in *pprovisioning.FetchBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) GetBlockStorage 

func (a MockBlockStorageAPI) GetBlockStorage(ctx context.Context, in *pprovisioning.GetBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) ListBlockStorages 

func (a MockBlockStorageAPI) ListBlockStorages(ctx context.Context, in *pprovisioning.ListBlockStoragesRequest, opts ...grpc.CallOption) (*pprovisioning.ListBlockStoragesResponse, error)

func (MockBlockStorageAPI) PurgeBlockStorage 

func (a MockBlockStorageAPI) PurgeBlockStorage(ctx context.Context, in *pprovisioning.PurgeBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockBlockStorageAPI) SetAvailableBlockStorage 

func (a MockBlockStorageAPI) SetAvailableBlockStorage(ctx context.Context, in *pprovisioning.SetAvailableBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) SetInuseBlockStorage 

func (a MockBlockStorageAPI) SetInuseBlockStorage(ctx context.Context, in *pprovisioning.SetInuseBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) SetProtectedBlockStorage 

func (a MockBlockStorageAPI) SetProtectedBlockStorage(ctx context.Context, in *pprovisioning.SetProtectedBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) UndeleteBlockStorage 

func (a MockBlockStorageAPI) UndeleteBlockStorage(ctx context.Context, in *pprovisioning.UndeleteBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

func (MockBlockStorageAPI) UpdateBlockStorage 

func (a MockBlockStorageAPI) UpdateBlockStorage(ctx context.Context, in *pprovisioning.UpdateBlockStorageRequest, opts ...grpc.CallOption) (*pprovisioning.BlockStorage, error)

type MockBlockStorageAgentAPI 

type MockBlockStorageAgentAPI struct{}

func (MockBlockStorageAgentAPI) CreateEmptyBlockStorage 

func (a MockBlockStorageAgentAPI) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error)

func (MockBlockStorageAgentAPI) DeleteBlockStorage 

func (a MockBlockStorageAgentAPI) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error)

func (MockBlockStorageAgentAPI) FetchBlockStorage 

func (a MockBlockStorageAgentAPI) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error)

func (MockBlockStorageAgentAPI) ResizeBlockStorage 

func (a MockBlockStorageAgentAPI) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error)

type MockBlockStorageAgentClient 

type MockBlockStorageAgentClient struct {
	// contains filtered or unexported fields
}

func NewMockBlockStorageAgentClient 

func NewMockBlockStorageAgentClient() *MockBlockStorageAgentClient

func (MockBlockStorageAgentClient) CreateEmptyBlockStorage 

func (a MockBlockStorageAgentClient) CreateEmptyBlockStorage(ctx context.Context, in *CreateEmptyBlockStorageRequest, opts ...grpc.CallOption) (*CreateEmptyBlockStorageResponse, error)

func (MockBlockStorageAgentClient) DeleteBlockStorage 

func (a MockBlockStorageAgentClient) DeleteBlockStorage(ctx context.Context, in *DeleteBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockBlockStorageAgentClient) FetchBlockStorage 

func (a MockBlockStorageAgentClient) FetchBlockStorage(ctx context.Context, in *FetchBlockStorageRequest, opts ...grpc.CallOption) (*FetchBlockStorageResponse, error)

func (MockBlockStorageAgentClient) ResizeBlockStorage 

func (a MockBlockStorageAgentClient) ResizeBlockStorage(ctx context.Context, in *ResizeBlockStorageRequest, opts ...grpc.CallOption) (*empty.Empty, error)

type ResizeBlockStorageRequest 

type ResizeBlockStorageRequest struct {
	Bytes                uint64   `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeBlockStorageRequest) Descriptor 

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

func (*ResizeBlockStorageRequest) GetBytes 

func (m *ResizeBlockStorageRequest) GetBytes() uint64

func (*ResizeBlockStorageRequest) GetPath 

func (m *ResizeBlockStorageRequest) GetPath() string

func (*ResizeBlockStorageRequest) ProtoMessage 

func (*ResizeBlockStorageRequest) ProtoMessage()

func (*ResizeBlockStorageRequest) Reset 

func (m *ResizeBlockStorageRequest) Reset()

func (*ResizeBlockStorageRequest) String 

func (m *ResizeBlockStorageRequest) String() string

func (*ResizeBlockStorageRequest) XXX_DiscardUnknown 

func (m *ResizeBlockStorageRequest) XXX_DiscardUnknown()

func (*ResizeBlockStorageRequest) XXX_Marshal 

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

func (*ResizeBlockStorageRequest) XXX_Merge 

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

func (*ResizeBlockStorageRequest) XXX_Size 

func (m *ResizeBlockStorageRequest) XXX_Size() int

func (*ResizeBlockStorageRequest) XXX_Unmarshal 

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

type UnimplementedBlockStorageAgentServiceServer 

type UnimplementedBlockStorageAgentServiceServer struct {
}

UnimplementedBlockStorageAgentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBlockStorageAgentServiceServer) CreateEmptyBlockStorage 

func (*UnimplementedBlockStorageAgentServiceServer) CreateEmptyBlockStorage(ctx context.Context, req *CreateEmptyBlockStorageRequest) (*CreateEmptyBlockStorageResponse, error)

func (*UnimplementedBlockStorageAgentServiceServer) DeleteBlockStorage 

func (*UnimplementedBlockStorageAgentServiceServer) DeleteBlockStorage(ctx context.Context, req *DeleteBlockStorageRequest) (*empty.Empty, error)

func (*UnimplementedBlockStorageAgentServiceServer) FetchBlockStorage 

func (*UnimplementedBlockStorageAgentServiceServer) FetchBlockStorage(ctx context.Context, req *FetchBlockStorageRequest) (*FetchBlockStorageResponse, error)

func (*UnimplementedBlockStorageAgentServiceServer) ResizeBlockStorage 

func (*UnimplementedBlockStorageAgentServiceServer) ResizeBlockStorage(ctx context.Context, req *ResizeBlockStorageRequest) (*empty.Empty, error)

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.