Versions in this module Expand all Collapse all v3 v3.0.1 Jul 15, 2019 v3.0.0 Apr 30, 2019 Changes in this version + var ErrEndOfBlock = errors.New("end of block") + var ErrInvalidSeqno = errors.New("invalid ack sequence number") + type BlockReader struct + Block *hdfs.LocatedBlockProto + ClientName string + DialFunc func(ctx context.Context, network, addr string) (net.Conn, error) + Offset int64 + UseDatanodeHostname bool + func (br *BlockReader) Close() error + func (br *BlockReader) Read(b []byte) (int, error) + func (br *BlockReader) SetDeadline(t time.Time) error + type BlockWriter struct + Append bool + Block *hdfs.LocatedBlockProto + BlockSize int64 + ClientName string + DialFunc func(ctx context.Context, network, addr string) (net.Conn, error) + Offset int64 + UseDatanodeHostname bool + func (bw *BlockWriter) Close() error + func (bw *BlockWriter) Flush() error + func (bw *BlockWriter) SetDeadline(t time.Time) error + func (bw *BlockWriter) Write(b []byte) (int, error) + type ChecksumReader struct + Block *hdfs.LocatedBlockProto + DialFunc func(ctx context.Context, network, addr string) (net.Conn, error) + UseDatanodeHostname bool + func (cr *ChecksumReader) ReadChecksum() ([]byte, error) + func (cr *ChecksumReader) SetDeadline(t time.Time) error + type DatanodeError struct + type NamenodeConnection struct + ClientID []byte + ClientName string + User string + func NewNamenodeConnection(options NamenodeConnectionOptions) (*NamenodeConnection, error) + func (c *NamenodeConnection) Close() error + func (c *NamenodeConnection) Execute(method string, req proto.Message, resp proto.Message) error + type NamenodeConnectionOptions struct + Addresses []string + DialFunc func(ctx context.Context, network, addr string) (net.Conn, error) + KerberosClient *krb.Client + KerberosServicePrincipleName string + User string + type NamenodeError struct + func (err *NamenodeError) Desc() string + func (err *NamenodeError) Error() string + func (err *NamenodeError) Exception() string + func (err *NamenodeError) Message() string + func (err *NamenodeError) Method() string