1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859 |
- package shell
- import (
- "fmt"
- "io"
- "math"
- "github.com/chrislusf/seaweedfs/weed/filer2"
- "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
- "github.com/chrislusf/seaweedfs/weed/util"
- )
- func init() {
- Commands = append(Commands, &commandFsCat{})
- }
- type commandFsCat struct {
- }
- func (c *commandFsCat) Name() string {
- return "fs.cat"
- }
- func (c *commandFsCat) Help() string {
- return `stream the file content on to the screen
- fs.cat /dir/file_name
- `
- }
- func (c *commandFsCat) Do(args []string, commandEnv *CommandEnv, writer io.Writer) (err error) {
- path, err := commandEnv.parseUrl(findInputDirectory(args))
- if err != nil {
- return err
- }
- if commandEnv.isDirectory(path) {
- return fmt.Errorf("%s is a directory", path)
- }
- dir, name := util.FullPath(path).DirAndName()
- return commandEnv.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
- request := &filer_pb.LookupDirectoryEntryRequest{
- Name: name,
- Directory: dir,
- }
- respLookupEntry, err := filer_pb.LookupEntry(client, request)
- if err != nil {
- return err
- }
- return filer2.StreamContent(commandEnv.MasterClient, writer, respLookupEntry.Entry.Chunks, 0, math.MaxInt64)
- })
- }
|