Documentation ¶
Index ¶
- type VolumeServer
- func (vs *VolumeServer) DeleteChunk(ctx context.Context, req *vpb.DeleteChunkRequest) (*vpb.DeleteChunkResponse, error)
- func (vs *VolumeServer) GetChunk(ctx context.Context, req *vpb.GetChunkRequest) (*vpb.GetChunkResponse, error)
- func (vs *VolumeServer) Ping(ctx context.Context, req *vpb.PingRequest) (*vpb.PingResponse, error)
- func (vs *VolumeServer) PutChunk(ctx context.Context, req *vpb.PutChunkRequest) (*vpb.PutChunkResponse, error)
- func (vs *VolumeServer) VolumeStatus(ctx context.Context, req *vpb.VolumeStatusRequest) (*vpb.VolumeStatusResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VolumeServer ¶
type VolumeServer struct { ID string TotalChunkCount uint64 Size uint64 Used uint64 ChunksSet map[int64]uint64 // chunkid -> size Host string Port int // contains filtered or unexported fields }
func NewVolumeServer ¶
func NewVolumeServer() *VolumeServer
func (*VolumeServer) DeleteChunk ¶
func (vs *VolumeServer) DeleteChunk(ctx context.Context, req *vpb.DeleteChunkRequest) (*vpb.DeleteChunkResponse, error)
func (*VolumeServer) GetChunk ¶
func (vs *VolumeServer) GetChunk(ctx context.Context, req *vpb.GetChunkRequest) (*vpb.GetChunkResponse, error)
func (*VolumeServer) Ping ¶
func (vs *VolumeServer) Ping(ctx context.Context, req *vpb.PingRequest) (*vpb.PingResponse, error)
func (*VolumeServer) PutChunk ¶
func (vs *VolumeServer) PutChunk(ctx context.Context, req *vpb.PutChunkRequest) (*vpb.PutChunkResponse, error)
func (*VolumeServer) VolumeStatus ¶
func (vs *VolumeServer) VolumeStatus(ctx context.Context, req *vpb.VolumeStatusRequest) (*vpb.VolumeStatusResponse, error)
Click to show internal directories.
Click to hide internal directories.