topolvm: github.com/cybozu-go/topolvm/lvmd/proto Index | Files

package proto

import "github.com/cybozu-go/topolvm/lvmd/proto"

Index

Package Files

lvmd.pb.go

func RegisterLVServiceServer Uses

func RegisterLVServiceServer(s *grpc.Server, srv LVServiceServer)

func RegisterVGServiceServer Uses

func RegisterVGServiceServer(s *grpc.Server, srv VGServiceServer)

type CreateLVRequest Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents the input for CreateLV.

func (*CreateLVRequest) Descriptor Uses

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

func (*CreateLVRequest) GetName Uses

func (m *CreateLVRequest) GetName() string

func (*CreateLVRequest) GetSizeGb Uses

func (m *CreateLVRequest) GetSizeGb() uint64

func (*CreateLVRequest) ProtoMessage Uses

func (*CreateLVRequest) ProtoMessage()

func (*CreateLVRequest) Reset Uses

func (m *CreateLVRequest) Reset()

func (*CreateLVRequest) String Uses

func (m *CreateLVRequest) String() string

func (*CreateLVRequest) XXX_DiscardUnknown Uses

func (m *CreateLVRequest) XXX_DiscardUnknown()

func (*CreateLVRequest) XXX_Marshal Uses

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

func (*CreateLVRequest) XXX_Merge Uses

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

func (*CreateLVRequest) XXX_Size Uses

func (m *CreateLVRequest) XXX_Size() int

func (*CreateLVRequest) XXX_Unmarshal Uses

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

type CreateLVResponse Uses

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 Uses

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

func (*CreateLVResponse) GetVolume Uses

func (m *CreateLVResponse) GetVolume() *LogicalVolume

func (*CreateLVResponse) ProtoMessage Uses

func (*CreateLVResponse) ProtoMessage()

func (*CreateLVResponse) Reset Uses

func (m *CreateLVResponse) Reset()

func (*CreateLVResponse) String Uses

func (m *CreateLVResponse) String() string

func (*CreateLVResponse) XXX_DiscardUnknown Uses

func (m *CreateLVResponse) XXX_DiscardUnknown()

func (*CreateLVResponse) XXX_Marshal Uses

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

func (*CreateLVResponse) XXX_Merge Uses

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

func (*CreateLVResponse) XXX_Size Uses

func (m *CreateLVResponse) XXX_Size() int

func (*CreateLVResponse) XXX_Unmarshal Uses

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

type Empty Uses

type Empty struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor Uses

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

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) Reset Uses

func (m *Empty) Reset()

func (*Empty) String Uses

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown Uses

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal Uses

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

func (*Empty) XXX_Merge Uses

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

func (*Empty) XXX_Size Uses

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal Uses

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

type GetFreeBytesResponse Uses

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 Uses

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

func (*GetFreeBytesResponse) GetFreeBytes Uses

func (m *GetFreeBytesResponse) GetFreeBytes() uint64

func (*GetFreeBytesResponse) ProtoMessage Uses

func (*GetFreeBytesResponse) ProtoMessage()

func (*GetFreeBytesResponse) Reset Uses

func (m *GetFreeBytesResponse) Reset()

func (*GetFreeBytesResponse) String Uses

func (m *GetFreeBytesResponse) String() string

func (*GetFreeBytesResponse) XXX_DiscardUnknown Uses

func (m *GetFreeBytesResponse) XXX_DiscardUnknown()

func (*GetFreeBytesResponse) XXX_Marshal Uses

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

func (*GetFreeBytesResponse) XXX_Merge Uses

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

func (*GetFreeBytesResponse) XXX_Size Uses

func (m *GetFreeBytesResponse) XXX_Size() int

func (*GetFreeBytesResponse) XXX_Unmarshal Uses

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

type GetLVListResponse Uses

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 Uses

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

func (*GetLVListResponse) GetVolumes Uses

func (m *GetLVListResponse) GetVolumes() []*LogicalVolume

func (*GetLVListResponse) ProtoMessage Uses

func (*GetLVListResponse) ProtoMessage()

func (*GetLVListResponse) Reset Uses

func (m *GetLVListResponse) Reset()

func (*GetLVListResponse) String Uses

func (m *GetLVListResponse) String() string

func (*GetLVListResponse) XXX_DiscardUnknown Uses

func (m *GetLVListResponse) XXX_DiscardUnknown()

func (*GetLVListResponse) XXX_Marshal Uses

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

func (*GetLVListResponse) XXX_Merge Uses

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

func (*GetLVListResponse) XXX_Size Uses

func (m *GetLVListResponse) XXX_Size() int

func (*GetLVListResponse) XXX_Unmarshal Uses

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

type LVServiceClient Uses

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 Uses

func NewLVServiceClient(cc *grpc.ClientConn) LVServiceClient

type LVServiceServer Uses

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 Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents a logical volume.

func (*LogicalVolume) Descriptor Uses

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

func (*LogicalVolume) GetDevMajor Uses

func (m *LogicalVolume) GetDevMajor() uint32

func (*LogicalVolume) GetDevMinor Uses

func (m *LogicalVolume) GetDevMinor() uint32

func (*LogicalVolume) GetName Uses

func (m *LogicalVolume) GetName() string

func (*LogicalVolume) GetSizeGb Uses

func (m *LogicalVolume) GetSizeGb() uint64

func (*LogicalVolume) ProtoMessage Uses

func (*LogicalVolume) ProtoMessage()

func (*LogicalVolume) Reset Uses

func (m *LogicalVolume) Reset()

func (*LogicalVolume) String Uses

func (m *LogicalVolume) String() string

func (*LogicalVolume) XXX_DiscardUnknown Uses

func (m *LogicalVolume) XXX_DiscardUnknown()

func (*LogicalVolume) XXX_Marshal Uses

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

func (*LogicalVolume) XXX_Merge Uses

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

func (*LogicalVolume) XXX_Size Uses

func (m *LogicalVolume) XXX_Size() int

func (*LogicalVolume) XXX_Unmarshal Uses

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

type RemoveLVRequest Uses

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

Represents the input for RemoveLV.

func (*RemoveLVRequest) Descriptor Uses

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

func (*RemoveLVRequest) GetName Uses

func (m *RemoveLVRequest) GetName() string

func (*RemoveLVRequest) ProtoMessage Uses

func (*RemoveLVRequest) ProtoMessage()

func (*RemoveLVRequest) Reset Uses

func (m *RemoveLVRequest) Reset()

func (*RemoveLVRequest) String Uses

func (m *RemoveLVRequest) String() string

func (*RemoveLVRequest) XXX_DiscardUnknown Uses

func (m *RemoveLVRequest) XXX_DiscardUnknown()

func (*RemoveLVRequest) XXX_Marshal Uses

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

func (*RemoveLVRequest) XXX_Merge Uses

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

func (*RemoveLVRequest) XXX_Size Uses

func (m *RemoveLVRequest) XXX_Size() int

func (*RemoveLVRequest) XXX_Unmarshal Uses

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

type ResizeLVRequest Uses

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"`
    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 Uses

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

func (*ResizeLVRequest) GetName Uses

func (m *ResizeLVRequest) GetName() string

func (*ResizeLVRequest) GetSizeGb Uses

func (m *ResizeLVRequest) GetSizeGb() uint64

func (*ResizeLVRequest) ProtoMessage Uses

func (*ResizeLVRequest) ProtoMessage()

func (*ResizeLVRequest) Reset Uses

func (m *ResizeLVRequest) Reset()

func (*ResizeLVRequest) String Uses

func (m *ResizeLVRequest) String() string

func (*ResizeLVRequest) XXX_DiscardUnknown Uses

func (m *ResizeLVRequest) XXX_DiscardUnknown()

func (*ResizeLVRequest) XXX_Marshal Uses

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

func (*ResizeLVRequest) XXX_Merge Uses

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

func (*ResizeLVRequest) XXX_Size Uses

func (m *ResizeLVRequest) XXX_Size() int

func (*ResizeLVRequest) XXX_Unmarshal Uses

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

type VGServiceClient Uses

type VGServiceClient interface {
    // Get the list of logical volumes in the volume group.
    GetLVList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetLVListResponse, error)
    // Get the free space of the volume group in bytes.
    GetFreeBytes(ctx context.Context, in *Empty, 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 Uses

func NewVGServiceClient(cc *grpc.ClientConn) VGServiceClient

type VGServiceServer Uses

type VGServiceServer interface {
    // Get the list of logical volumes in the volume group.
    GetLVList(context.Context, *Empty) (*GetLVListResponse, error)
    // Get the free space of the volume group in bytes.
    GetFreeBytes(context.Context, *Empty) (*GetFreeBytesResponse, error)
    // Stream the volume group metrics.
    Watch(*Empty, VGService_WatchServer) error
}

VGServiceServer is the server API for VGService service.

type VGService_WatchClient Uses

type VGService_WatchClient interface {
    Recv() (*WatchResponse, error)
    grpc.ClientStream
}

type VGService_WatchServer Uses

type VGService_WatchServer interface {
    Send(*WatchResponse) error
    grpc.ServerStream
}

type WatchResponse Uses

type WatchResponse 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 stream output from Watch.

func (*WatchResponse) Descriptor Uses

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

func (*WatchResponse) GetFreeBytes Uses

func (m *WatchResponse) GetFreeBytes() uint64

func (*WatchResponse) ProtoMessage Uses

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset Uses

func (m *WatchResponse) Reset()

func (*WatchResponse) String Uses

func (m *WatchResponse) String() string

func (*WatchResponse) XXX_DiscardUnknown Uses

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal Uses

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

func (*WatchResponse) XXX_Merge Uses

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

func (*WatchResponse) XXX_Size Uses

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal Uses

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

Package proto imports 5 packages (graph) and is imported by 4 packages. Updated 2019-06-13. Refresh now. Tools for package owners.