Documentation
¶
Index ¶
- Variables
- func StartChunkServer()
- type ChunkServer
- func (s *ChunkServer) ChunkWatcher()
- func (s *ChunkServer) CreateChunk(ctx context.Context, file *pb.FileChunkData) (*pb.GenericResponse, error)
- func (s *ChunkServer) CreateFile(stream pb.ChunkServer_CreateFileServer) error
- func (s *ChunkServer) KeepAlive()
- func (s *ChunkServer) ReadFile(req *pb.ReadFileRequest, stream pb.ChunkServer_ReadFileServer) error
- func (s *ChunkServer) RemoveFile(ctx context.Context, file *pb.File) (*pb.GenericResponse, error)
- func (s *ChunkServer) SyncChunk(chunkUUID string)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrFailedWrite = errors.New("failed to write file or chunk") ErrFailedWriteMeta = errors.New("failed to sync metadata of file or chunk") ErrFailedGetFile = errors.New("failed to get file or chunk") ErrFileNotExist = errors.New("file or chunk not exist") ErrAlreadyExist = errors.New("file or chunk already exist") )
Functions ¶
Types ¶
type ChunkServer ¶
type ChunkServer struct {
// contains filtered or unexported fields
}
func (*ChunkServer) ChunkWatcher ¶
func (s *ChunkServer) ChunkWatcher()
func (*ChunkServer) CreateChunk ¶
func (s *ChunkServer) CreateChunk(ctx context.Context, file *pb.FileChunkData) (*pb.GenericResponse, error)
func (*ChunkServer) CreateFile ¶
func (s *ChunkServer) CreateFile(stream pb.ChunkServer_CreateFileServer) error
func (*ChunkServer) KeepAlive ¶
func (s *ChunkServer) KeepAlive()
func (*ChunkServer) ReadFile ¶
func (s *ChunkServer) ReadFile(req *pb.ReadFileRequest, stream pb.ChunkServer_ReadFileServer) error
func (*ChunkServer) RemoveFile ¶
func (s *ChunkServer) RemoveFile(ctx context.Context, file *pb.File) (*pb.GenericResponse, error)
func (*ChunkServer) SyncChunk ¶
func (s *ChunkServer) SyncChunk(chunkUUID string)
Source Files
Click to show internal directories.
Click to hide internal directories.