volume

Documentation

Index

• type VolumeServer
  • func NewVolumeServer() *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)

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)