Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

hdfs

package module

Go to main page

Versions in this module

v1

v1.0.6

Oct 19, 2022

Changes in this version

+ const RemoveAllFormat

type Client

+ func (c *Client) RemoveAll(path string) error

v1.0.5

Oct 17, 2022

v1.0.2

May 31, 2022

v1.0.1

May 29, 2022

Changes in this version

+ const ContentTypeKey

+ const ContentTypeValue

+ const DefaultFilePerm

+ const MB

type Client

+ func (c *Client) CreateFileWithGoodBlock(path string, data []byte) error

type Option

+ func MinBlockSizeOption(blockSize uint64) Option

v1.0.0

May 29, 2022

Changes in this version

+ const AppendFileFormat

+ const CreateFileFormat

+ const DefaultBlockSize

+ const DefaultBufferSize

+ const DefaultCreateFileFormat

+ const DefaultHost

+ const DefaultPort

+ const DefaultProtocol

+ const DefaultReadFileFormat

+ const DefaultReadLength

+ const DefaultReplication

+ const DefaultUser

+ const GetContentSummaryFormat

+ const GetFileChecksumFormat

+ const GetFileStatusFormat

+ const ListStatusFormat

+ const MkdirPathFormat

+ const ReadFileFormat

+ const TypeDir

+ const TypeFile

+ var DefaultTransport = &http.Transport

+ var ErrBadOptionsDataNodeCannotNull = fmt.Errorf("非法参数, DataNodes为空")

+ var ErrPathIsNotDirectory = fmt.Errorf("传入路径不是目录")

+ func GetErrFromBody(response *http.Response) error

+ type Client struct

+ func New(opts ...Option) *Client

+ func (c *Client) Append(path string, bufferSize uint, data []byte) error

+ func (c *Client) Create(path string, data []byte) error

+ func (c *Client) CreateFile(path string, overwrite bool, blockSize uint64, permission os.FileMode, ...) error

+ func (c *Client) GetContentSummary(dirname string) (*ContentSummary, error)

+ func (c *Client) GetFileChecksum(path string) (*FileChecksum, error)

+ func (c *Client) GetFileStatus(path string) (*FileStatus, error)

+ func (c *Client) ListStatus(path string) ([]FileStatus, error)

+ func (c *Client) Mkdir(dirname string, perm os.FileMode) error

+ func (c *Client) MkdirAll(dirname string, perm os.FileMode) error

+ func (c *Client) Read(path string) ([]byte, error)

+ func (c *Client) ReadFile(path string, offset, length uint64, bufferSize uint) ([]byte, error)

+ func (c *Client) Walk(path string, callback func(prefixPath string, status FileStatus)) error

+ type ContentSummary struct

+ DirectoryCount int64

+ FileCount int64

+ Length int64

+ Quota int64

+ SpaceConsumed int64

+ SpaceQuota int64

+ type FileChecksum struct

+ Algorithm string

+ Bytes string

+ Length int64

+ type FileStatus struct

+ AccesTime int64

+ BlockSize int64

+ Group string

+ Length int64

+ ModificationTime int64

+ Owner string

+ PathSuffix string

+ Permission string

+ Replication int64

+ Type string

+ func (f FileStatus) IsDir() bool

+ type Option func(client *Client)

+ func HostOption(host string) Option

+ func PortOption(port int) Option

+ func ReplicationOption(replication int) Option

+ func SSLOption(SSL bool) Option

+ func TimeoutOption(timeout time.Duration) Option

+ func TransportOption(transport *http.Transport) Option

+ func UserOption(user string) Option