Documentation ¶
Index ¶
- func RegisterLVServiceServer(s *grpc.Server, srv LVServiceServer)
- func RegisterVGServiceServer(s *grpc.Server, srv VGServiceServer)
- type CreateLVRequest
- func (*CreateLVRequest) Descriptor() ([]byte, []int)
- func (m *CreateLVRequest) GetDeviceClass() string
- func (m *CreateLVRequest) GetName() string
- func (m *CreateLVRequest) GetSizeGb() uint64
- func (m *CreateLVRequest) GetTags() []string
- func (*CreateLVRequest) ProtoMessage()
- func (m *CreateLVRequest) Reset()
- func (m *CreateLVRequest) String() string
- func (m *CreateLVRequest) XXX_DiscardUnknown()
- func (m *CreateLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateLVRequest) XXX_Merge(src proto.Message)
- func (m *CreateLVRequest) XXX_Size() int
- func (m *CreateLVRequest) XXX_Unmarshal(b []byte) error
- type CreateLVResponse
- func (*CreateLVResponse) Descriptor() ([]byte, []int)
- func (m *CreateLVResponse) GetVolume() *LogicalVolume
- func (*CreateLVResponse) ProtoMessage()
- func (m *CreateLVResponse) Reset()
- func (m *CreateLVResponse) String() string
- func (m *CreateLVResponse) XXX_DiscardUnknown()
- func (m *CreateLVResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateLVResponse) XXX_Merge(src proto.Message)
- func (m *CreateLVResponse) XXX_Size() int
- func (m *CreateLVResponse) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type GetFreeBytesRequest
- func (*GetFreeBytesRequest) Descriptor() ([]byte, []int)
- func (m *GetFreeBytesRequest) GetDeviceClass() string
- func (*GetFreeBytesRequest) ProtoMessage()
- func (m *GetFreeBytesRequest) Reset()
- func (m *GetFreeBytesRequest) String() string
- func (m *GetFreeBytesRequest) XXX_DiscardUnknown()
- func (m *GetFreeBytesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFreeBytesRequest) XXX_Merge(src proto.Message)
- func (m *GetFreeBytesRequest) XXX_Size() int
- func (m *GetFreeBytesRequest) XXX_Unmarshal(b []byte) error
- type GetFreeBytesResponse
- func (*GetFreeBytesResponse) Descriptor() ([]byte, []int)
- func (m *GetFreeBytesResponse) GetFreeBytes() uint64
- func (*GetFreeBytesResponse) ProtoMessage()
- func (m *GetFreeBytesResponse) Reset()
- func (m *GetFreeBytesResponse) String() string
- func (m *GetFreeBytesResponse) XXX_DiscardUnknown()
- func (m *GetFreeBytesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFreeBytesResponse) XXX_Merge(src proto.Message)
- func (m *GetFreeBytesResponse) XXX_Size() int
- func (m *GetFreeBytesResponse) XXX_Unmarshal(b []byte) error
- type GetLVListRequest
- func (*GetLVListRequest) Descriptor() ([]byte, []int)
- func (m *GetLVListRequest) GetDeviceClass() string
- func (*GetLVListRequest) ProtoMessage()
- func (m *GetLVListRequest) Reset()
- func (m *GetLVListRequest) String() string
- func (m *GetLVListRequest) XXX_DiscardUnknown()
- func (m *GetLVListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLVListRequest) XXX_Merge(src proto.Message)
- func (m *GetLVListRequest) XXX_Size() int
- func (m *GetLVListRequest) XXX_Unmarshal(b []byte) error
- type GetLVListResponse
- func (*GetLVListResponse) Descriptor() ([]byte, []int)
- func (m *GetLVListResponse) GetVolumes() []*LogicalVolume
- func (*GetLVListResponse) ProtoMessage()
- func (m *GetLVListResponse) Reset()
- func (m *GetLVListResponse) String() string
- func (m *GetLVListResponse) XXX_DiscardUnknown()
- func (m *GetLVListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLVListResponse) XXX_Merge(src proto.Message)
- func (m *GetLVListResponse) XXX_Size() int
- func (m *GetLVListResponse) XXX_Unmarshal(b []byte) error
- type LVServiceClient
- type LVServiceServer
- type LogicalVolume
- func (*LogicalVolume) Descriptor() ([]byte, []int)
- func (m *LogicalVolume) GetDevMajor() uint32
- func (m *LogicalVolume) GetDevMinor() uint32
- func (m *LogicalVolume) GetName() string
- func (m *LogicalVolume) GetSizeGb() uint64
- func (m *LogicalVolume) GetTags() []string
- func (*LogicalVolume) ProtoMessage()
- func (m *LogicalVolume) Reset()
- func (m *LogicalVolume) String() string
- func (m *LogicalVolume) XXX_DiscardUnknown()
- func (m *LogicalVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogicalVolume) XXX_Merge(src proto.Message)
- func (m *LogicalVolume) XXX_Size() int
- func (m *LogicalVolume) XXX_Unmarshal(b []byte) error
- type RemoveLVRequest
- func (*RemoveLVRequest) Descriptor() ([]byte, []int)
- func (m *RemoveLVRequest) GetDeviceClass() string
- func (m *RemoveLVRequest) GetName() string
- func (*RemoveLVRequest) ProtoMessage()
- func (m *RemoveLVRequest) Reset()
- func (m *RemoveLVRequest) String() string
- func (m *RemoveLVRequest) XXX_DiscardUnknown()
- func (m *RemoveLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveLVRequest) XXX_Merge(src proto.Message)
- func (m *RemoveLVRequest) XXX_Size() int
- func (m *RemoveLVRequest) XXX_Unmarshal(b []byte) error
- type ResizeLVRequest
- func (*ResizeLVRequest) Descriptor() ([]byte, []int)
- func (m *ResizeLVRequest) GetDeviceClass() string
- func (m *ResizeLVRequest) GetName() string
- func (m *ResizeLVRequest) GetSizeGb() uint64
- func (*ResizeLVRequest) ProtoMessage()
- func (m *ResizeLVRequest) Reset()
- func (m *ResizeLVRequest) String() string
- func (m *ResizeLVRequest) XXX_DiscardUnknown()
- func (m *ResizeLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResizeLVRequest) XXX_Merge(src proto.Message)
- func (m *ResizeLVRequest) XXX_Size() int
- func (m *ResizeLVRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedLVServiceServer
- func (*UnimplementedLVServiceServer) CreateLV(ctx context.Context, req *CreateLVRequest) (*CreateLVResponse, error)
- func (*UnimplementedLVServiceServer) RemoveLV(ctx context.Context, req *RemoveLVRequest) (*Empty, error)
- func (*UnimplementedLVServiceServer) ResizeLV(ctx context.Context, req *ResizeLVRequest) (*Empty, error)
- type UnimplementedVGServiceServer
- func (*UnimplementedVGServiceServer) GetFreeBytes(ctx context.Context, req *GetFreeBytesRequest) (*GetFreeBytesResponse, error)
- func (*UnimplementedVGServiceServer) GetLVList(ctx context.Context, req *GetLVListRequest) (*GetLVListResponse, error)
- func (*UnimplementedVGServiceServer) Watch(req *Empty, srv VGService_WatchServer) error
- type VGServiceClient
- type VGServiceServer
- type VGService_WatchClient
- type VGService_WatchServer
- type WatchItem
- func (*WatchItem) Descriptor() ([]byte, []int)
- func (m *WatchItem) GetDeviceClass() string
- func (m *WatchItem) GetFreeBytes() uint64
- func (*WatchItem) ProtoMessage()
- func (m *WatchItem) Reset()
- func (m *WatchItem) String() string
- func (m *WatchItem) XXX_DiscardUnknown()
- func (m *WatchItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchItem) XXX_Merge(src proto.Message)
- func (m *WatchItem) XXX_Size() int
- func (m *WatchItem) XXX_Unmarshal(b []byte) error
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)
- func (m *WatchResponse) GetFreeBytes() uint64
- func (m *WatchResponse) GetItems() []*WatchItem
- func (*WatchResponse) ProtoMessage()
- func (m *WatchResponse) Reset()
- func (m *WatchResponse) String() string
- func (m *WatchResponse) XXX_DiscardUnknown()
- func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchResponse) XXX_Merge(src proto.Message)
- func (m *WatchResponse) XXX_Size() int
- func (m *WatchResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterLVServiceServer ¶
func RegisterLVServiceServer(s *grpc.Server, srv LVServiceServer)
func RegisterVGServiceServer ¶
func RegisterVGServiceServer(s *grpc.Server, srv VGServiceServer)
Types ¶
type CreateLVRequest ¶
type CreateLVRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` SizeGb uint64 `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` DeviceClass string `protobuf:"bytes,4,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the input for CreateLV.
func (*CreateLVRequest) Descriptor ¶
func (*CreateLVRequest) Descriptor() ([]byte, []int)
func (*CreateLVRequest) GetDeviceClass ¶ added in v0.5.0
func (m *CreateLVRequest) GetDeviceClass() string
func (*CreateLVRequest) GetName ¶
func (m *CreateLVRequest) GetName() string
func (*CreateLVRequest) GetSizeGb ¶
func (m *CreateLVRequest) GetSizeGb() uint64
func (*CreateLVRequest) GetTags ¶ added in v0.3.0
func (m *CreateLVRequest) GetTags() []string
func (*CreateLVRequest) ProtoMessage ¶
func (*CreateLVRequest) ProtoMessage()
func (*CreateLVRequest) Reset ¶
func (m *CreateLVRequest) Reset()
func (*CreateLVRequest) String ¶
func (m *CreateLVRequest) String() string
func (*CreateLVRequest) XXX_DiscardUnknown ¶
func (m *CreateLVRequest) XXX_DiscardUnknown()
func (*CreateLVRequest) XXX_Marshal ¶
func (m *CreateLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateLVRequest) XXX_Merge ¶
func (m *CreateLVRequest) XXX_Merge(src proto.Message)
func (*CreateLVRequest) XXX_Size ¶
func (m *CreateLVRequest) XXX_Size() int
func (*CreateLVRequest) XXX_Unmarshal ¶
func (m *CreateLVRequest) XXX_Unmarshal(b []byte) error
type CreateLVResponse ¶
type CreateLVResponse struct { Volume *LogicalVolume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the response of CreateLV.
func (*CreateLVResponse) Descriptor ¶
func (*CreateLVResponse) Descriptor() ([]byte, []int)
func (*CreateLVResponse) GetVolume ¶
func (m *CreateLVResponse) GetVolume() *LogicalVolume
func (*CreateLVResponse) ProtoMessage ¶
func (*CreateLVResponse) ProtoMessage()
func (*CreateLVResponse) Reset ¶
func (m *CreateLVResponse) Reset()
func (*CreateLVResponse) String ¶
func (m *CreateLVResponse) String() string
func (*CreateLVResponse) XXX_DiscardUnknown ¶
func (m *CreateLVResponse) XXX_DiscardUnknown()
func (*CreateLVResponse) XXX_Marshal ¶
func (m *CreateLVResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateLVResponse) XXX_Merge ¶
func (m *CreateLVResponse) XXX_Merge(src proto.Message)
func (*CreateLVResponse) XXX_Size ¶
func (m *CreateLVResponse) XXX_Size() int
func (*CreateLVResponse) XXX_Unmarshal ¶
func (m *CreateLVResponse) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type GetFreeBytesRequest ¶ added in v0.5.0
type GetFreeBytesRequest struct { DeviceClass string `protobuf:"bytes,1,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetFreeBytesRequest) Descriptor ¶ added in v0.5.0
func (*GetFreeBytesRequest) Descriptor() ([]byte, []int)
func (*GetFreeBytesRequest) GetDeviceClass ¶ added in v0.5.0
func (m *GetFreeBytesRequest) GetDeviceClass() string
func (*GetFreeBytesRequest) ProtoMessage ¶ added in v0.5.0
func (*GetFreeBytesRequest) ProtoMessage()
func (*GetFreeBytesRequest) Reset ¶ added in v0.5.0
func (m *GetFreeBytesRequest) Reset()
func (*GetFreeBytesRequest) String ¶ added in v0.5.0
func (m *GetFreeBytesRequest) String() string
func (*GetFreeBytesRequest) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *GetFreeBytesRequest) XXX_DiscardUnknown()
func (*GetFreeBytesRequest) XXX_Marshal ¶ added in v0.5.0
func (m *GetFreeBytesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFreeBytesRequest) XXX_Merge ¶ added in v0.5.0
func (m *GetFreeBytesRequest) XXX_Merge(src proto.Message)
func (*GetFreeBytesRequest) XXX_Size ¶ added in v0.5.0
func (m *GetFreeBytesRequest) XXX_Size() int
func (*GetFreeBytesRequest) XXX_Unmarshal ¶ added in v0.5.0
func (m *GetFreeBytesRequest) XXX_Unmarshal(b []byte) error
type GetFreeBytesResponse ¶
type GetFreeBytesResponse struct { FreeBytes uint64 `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the response of GetFreeBytes.
func (*GetFreeBytesResponse) Descriptor ¶
func (*GetFreeBytesResponse) Descriptor() ([]byte, []int)
func (*GetFreeBytesResponse) GetFreeBytes ¶
func (m *GetFreeBytesResponse) GetFreeBytes() uint64
func (*GetFreeBytesResponse) ProtoMessage ¶
func (*GetFreeBytesResponse) ProtoMessage()
func (*GetFreeBytesResponse) Reset ¶
func (m *GetFreeBytesResponse) Reset()
func (*GetFreeBytesResponse) String ¶
func (m *GetFreeBytesResponse) String() string
func (*GetFreeBytesResponse) XXX_DiscardUnknown ¶
func (m *GetFreeBytesResponse) XXX_DiscardUnknown()
func (*GetFreeBytesResponse) XXX_Marshal ¶
func (m *GetFreeBytesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFreeBytesResponse) XXX_Merge ¶
func (m *GetFreeBytesResponse) XXX_Merge(src proto.Message)
func (*GetFreeBytesResponse) XXX_Size ¶
func (m *GetFreeBytesResponse) XXX_Size() int
func (*GetFreeBytesResponse) XXX_Unmarshal ¶
func (m *GetFreeBytesResponse) XXX_Unmarshal(b []byte) error
type GetLVListRequest ¶ added in v0.5.0
type GetLVListRequest struct { DeviceClass string `protobuf:"bytes,1,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLVListRequest) Descriptor ¶ added in v0.5.0
func (*GetLVListRequest) Descriptor() ([]byte, []int)
func (*GetLVListRequest) GetDeviceClass ¶ added in v0.5.0
func (m *GetLVListRequest) GetDeviceClass() string
func (*GetLVListRequest) ProtoMessage ¶ added in v0.5.0
func (*GetLVListRequest) ProtoMessage()
func (*GetLVListRequest) Reset ¶ added in v0.5.0
func (m *GetLVListRequest) Reset()
func (*GetLVListRequest) String ¶ added in v0.5.0
func (m *GetLVListRequest) String() string
func (*GetLVListRequest) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *GetLVListRequest) XXX_DiscardUnknown()
func (*GetLVListRequest) XXX_Marshal ¶ added in v0.5.0
func (m *GetLVListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLVListRequest) XXX_Merge ¶ added in v0.5.0
func (m *GetLVListRequest) XXX_Merge(src proto.Message)
func (*GetLVListRequest) XXX_Size ¶ added in v0.5.0
func (m *GetLVListRequest) XXX_Size() int
func (*GetLVListRequest) XXX_Unmarshal ¶ added in v0.5.0
func (m *GetLVListRequest) XXX_Unmarshal(b []byte) error
type GetLVListResponse ¶
type GetLVListResponse struct { Volumes []*LogicalVolume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the response of GetLVList.
func (*GetLVListResponse) Descriptor ¶
func (*GetLVListResponse) Descriptor() ([]byte, []int)
func (*GetLVListResponse) GetVolumes ¶
func (m *GetLVListResponse) GetVolumes() []*LogicalVolume
func (*GetLVListResponse) ProtoMessage ¶
func (*GetLVListResponse) ProtoMessage()
func (*GetLVListResponse) Reset ¶
func (m *GetLVListResponse) Reset()
func (*GetLVListResponse) String ¶
func (m *GetLVListResponse) String() string
func (*GetLVListResponse) XXX_DiscardUnknown ¶
func (m *GetLVListResponse) XXX_DiscardUnknown()
func (*GetLVListResponse) XXX_Marshal ¶
func (m *GetLVListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLVListResponse) XXX_Merge ¶
func (m *GetLVListResponse) XXX_Merge(src proto.Message)
func (*GetLVListResponse) XXX_Size ¶
func (m *GetLVListResponse) XXX_Size() int
func (*GetLVListResponse) XXX_Unmarshal ¶
func (m *GetLVListResponse) XXX_Unmarshal(b []byte) error
type LVServiceClient ¶
type LVServiceClient interface { // Create a logical volume. CreateLV(ctx context.Context, in *CreateLVRequest, opts ...grpc.CallOption) (*CreateLVResponse, error) // Remove a logical volume. RemoveLV(ctx context.Context, in *RemoveLVRequest, opts ...grpc.CallOption) (*Empty, error) // Resize a logical volume. ResizeLV(ctx context.Context, in *ResizeLVRequest, opts ...grpc.CallOption) (*Empty, error) }
LVServiceClient is the client API for LVService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLVServiceClient ¶
func NewLVServiceClient(cc grpc.ClientConnInterface) LVServiceClient
type LVServiceServer ¶
type LVServiceServer interface { // Create a logical volume. CreateLV(context.Context, *CreateLVRequest) (*CreateLVResponse, error) // Remove a logical volume. RemoveLV(context.Context, *RemoveLVRequest) (*Empty, error) // Resize a logical volume. ResizeLV(context.Context, *ResizeLVRequest) (*Empty, error) }
LVServiceServer is the server API for LVService service.
type LogicalVolume ¶
type LogicalVolume struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` SizeGb uint64 `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` DevMajor uint32 `protobuf:"varint,3,opt,name=dev_major,json=devMajor,proto3" json:"dev_major,omitempty"` DevMinor uint32 `protobuf:"varint,4,opt,name=dev_minor,json=devMinor,proto3" json:"dev_minor,omitempty"` Tags []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a logical volume.
func (*LogicalVolume) Descriptor ¶
func (*LogicalVolume) Descriptor() ([]byte, []int)
func (*LogicalVolume) GetDevMajor ¶
func (m *LogicalVolume) GetDevMajor() uint32
func (*LogicalVolume) GetDevMinor ¶
func (m *LogicalVolume) GetDevMinor() uint32
func (*LogicalVolume) GetName ¶
func (m *LogicalVolume) GetName() string
func (*LogicalVolume) GetSizeGb ¶
func (m *LogicalVolume) GetSizeGb() uint64
func (*LogicalVolume) GetTags ¶ added in v0.3.0
func (m *LogicalVolume) GetTags() []string
func (*LogicalVolume) ProtoMessage ¶
func (*LogicalVolume) ProtoMessage()
func (*LogicalVolume) Reset ¶
func (m *LogicalVolume) Reset()
func (*LogicalVolume) String ¶
func (m *LogicalVolume) String() string
func (*LogicalVolume) XXX_DiscardUnknown ¶
func (m *LogicalVolume) XXX_DiscardUnknown()
func (*LogicalVolume) XXX_Marshal ¶
func (m *LogicalVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogicalVolume) XXX_Merge ¶
func (m *LogicalVolume) XXX_Merge(src proto.Message)
func (*LogicalVolume) XXX_Size ¶
func (m *LogicalVolume) XXX_Size() int
func (*LogicalVolume) XXX_Unmarshal ¶
func (m *LogicalVolume) XXX_Unmarshal(b []byte) error
type RemoveLVRequest ¶
type RemoveLVRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DeviceClass string `protobuf:"bytes,2,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the input for RemoveLV.
func (*RemoveLVRequest) Descriptor ¶
func (*RemoveLVRequest) Descriptor() ([]byte, []int)
func (*RemoveLVRequest) GetDeviceClass ¶ added in v0.5.0
func (m *RemoveLVRequest) GetDeviceClass() string
func (*RemoveLVRequest) GetName ¶
func (m *RemoveLVRequest) GetName() string
func (*RemoveLVRequest) ProtoMessage ¶
func (*RemoveLVRequest) ProtoMessage()
func (*RemoveLVRequest) Reset ¶
func (m *RemoveLVRequest) Reset()
func (*RemoveLVRequest) String ¶
func (m *RemoveLVRequest) String() string
func (*RemoveLVRequest) XXX_DiscardUnknown ¶
func (m *RemoveLVRequest) XXX_DiscardUnknown()
func (*RemoveLVRequest) XXX_Marshal ¶
func (m *RemoveLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveLVRequest) XXX_Merge ¶
func (m *RemoveLVRequest) XXX_Merge(src proto.Message)
func (*RemoveLVRequest) XXX_Size ¶
func (m *RemoveLVRequest) XXX_Size() int
func (*RemoveLVRequest) XXX_Unmarshal ¶
func (m *RemoveLVRequest) XXX_Unmarshal(b []byte) error
type ResizeLVRequest ¶
type ResizeLVRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` SizeGb uint64 `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` DeviceClass string `protobuf:"bytes,3,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the input for ResizeLV.
The volume must already exist. The volume size will be set to exactly "size_gb".
func (*ResizeLVRequest) Descriptor ¶
func (*ResizeLVRequest) Descriptor() ([]byte, []int)
func (*ResizeLVRequest) GetDeviceClass ¶ added in v0.5.0
func (m *ResizeLVRequest) GetDeviceClass() string
func (*ResizeLVRequest) GetName ¶
func (m *ResizeLVRequest) GetName() string
func (*ResizeLVRequest) GetSizeGb ¶
func (m *ResizeLVRequest) GetSizeGb() uint64
func (*ResizeLVRequest) ProtoMessage ¶
func (*ResizeLVRequest) ProtoMessage()
func (*ResizeLVRequest) Reset ¶
func (m *ResizeLVRequest) Reset()
func (*ResizeLVRequest) String ¶
func (m *ResizeLVRequest) String() string
func (*ResizeLVRequest) XXX_DiscardUnknown ¶
func (m *ResizeLVRequest) XXX_DiscardUnknown()
func (*ResizeLVRequest) XXX_Marshal ¶
func (m *ResizeLVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResizeLVRequest) XXX_Merge ¶
func (m *ResizeLVRequest) XXX_Merge(src proto.Message)
func (*ResizeLVRequest) XXX_Size ¶
func (m *ResizeLVRequest) XXX_Size() int
func (*ResizeLVRequest) XXX_Unmarshal ¶
func (m *ResizeLVRequest) XXX_Unmarshal(b []byte) error
type UnimplementedLVServiceServer ¶ added in v0.2.1
type UnimplementedLVServiceServer struct { }
UnimplementedLVServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedLVServiceServer) CreateLV ¶ added in v0.2.1
func (*UnimplementedLVServiceServer) CreateLV(ctx context.Context, req *CreateLVRequest) (*CreateLVResponse, error)
func (*UnimplementedLVServiceServer) RemoveLV ¶ added in v0.2.1
func (*UnimplementedLVServiceServer) RemoveLV(ctx context.Context, req *RemoveLVRequest) (*Empty, error)
func (*UnimplementedLVServiceServer) ResizeLV ¶ added in v0.2.1
func (*UnimplementedLVServiceServer) ResizeLV(ctx context.Context, req *ResizeLVRequest) (*Empty, error)
type UnimplementedVGServiceServer ¶ added in v0.2.1
type UnimplementedVGServiceServer struct { }
UnimplementedVGServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedVGServiceServer) GetFreeBytes ¶ added in v0.2.1
func (*UnimplementedVGServiceServer) GetFreeBytes(ctx context.Context, req *GetFreeBytesRequest) (*GetFreeBytesResponse, error)
func (*UnimplementedVGServiceServer) GetLVList ¶ added in v0.2.1
func (*UnimplementedVGServiceServer) GetLVList(ctx context.Context, req *GetLVListRequest) (*GetLVListResponse, error)
func (*UnimplementedVGServiceServer) Watch ¶ added in v0.2.1
func (*UnimplementedVGServiceServer) Watch(req *Empty, srv VGService_WatchServer) error
type VGServiceClient ¶
type VGServiceClient interface { // Get the list of logical volumes in the volume group. GetLVList(ctx context.Context, in *GetLVListRequest, opts ...grpc.CallOption) (*GetLVListResponse, error) // Get the free space of the volume group in bytes. GetFreeBytes(ctx context.Context, in *GetFreeBytesRequest, opts ...grpc.CallOption) (*GetFreeBytesResponse, error) // Stream the volume group metrics. Watch(ctx context.Context, in *Empty, opts ...grpc.CallOption) (VGService_WatchClient, error) }
VGServiceClient is the client API for VGService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewVGServiceClient ¶
func NewVGServiceClient(cc grpc.ClientConnInterface) VGServiceClient
type VGServiceServer ¶
type VGServiceServer interface { // Get the list of logical volumes in the volume group. GetLVList(context.Context, *GetLVListRequest) (*GetLVListResponse, error) // Get the free space of the volume group in bytes. GetFreeBytes(context.Context, *GetFreeBytesRequest) (*GetFreeBytesResponse, error) // Stream the volume group metrics. Watch(*Empty, VGService_WatchServer) error }
VGServiceServer is the server API for VGService service.
type VGService_WatchClient ¶
type VGService_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type VGService_WatchServer ¶
type VGService_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type WatchItem ¶ added in v0.5.0
type WatchItem struct { FreeBytes uint64 `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"` DeviceClass string `protobuf:"bytes,2,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WatchItem) Descriptor ¶ added in v0.5.0
func (*WatchItem) GetDeviceClass ¶ added in v0.5.0
func (*WatchItem) GetFreeBytes ¶ added in v0.5.0
func (*WatchItem) ProtoMessage ¶ added in v0.5.0
func (*WatchItem) ProtoMessage()
func (*WatchItem) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *WatchItem) XXX_DiscardUnknown()
func (*WatchItem) XXX_Marshal ¶ added in v0.5.0
func (*WatchItem) XXX_Unmarshal ¶ added in v0.5.0
type WatchResponse ¶
type WatchResponse struct { FreeBytes uint64 `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"` Items []*WatchItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents the stream output from Watch.
func (*WatchResponse) Descriptor ¶
func (*WatchResponse) Descriptor() ([]byte, []int)
func (*WatchResponse) GetFreeBytes ¶
func (m *WatchResponse) GetFreeBytes() uint64
func (*WatchResponse) GetItems ¶ added in v0.5.0
func (m *WatchResponse) GetItems() []*WatchItem
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) Reset ¶
func (m *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (m *WatchResponse) String() string
func (*WatchResponse) XXX_DiscardUnknown ¶
func (m *WatchResponse) XXX_DiscardUnknown()
func (*WatchResponse) XXX_Marshal ¶
func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchResponse) XXX_Merge ¶
func (m *WatchResponse) XXX_Merge(src proto.Message)
func (*WatchResponse) XXX_Size ¶
func (m *WatchResponse) XXX_Size() int
func (*WatchResponse) XXX_Unmarshal ¶
func (m *WatchResponse) XXX_Unmarshal(b []byte) error