Versions in this module Expand all Collapse all v2 v2.4.0 Jul 15, 2023 v2.3.0 Feb 9, 2022 Changes in this version type BlockReader + func (br *BlockReader) Skip(off int64) error v2.2.1 Feb 5, 2022 Changes in this version type SaslDialer + SkipSaslOnPrivilegedPorts bool v2.2.0 Dec 30, 2020 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 SaslDialer struct + DialFunc func(ctx context.Context, network, addr string) (net.Conn, error) + EnforceQop string + Key *hdfs.DataEncryptionKeyProto + Token *hadoop.TokenProto + func (d *SaslDialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
Go to main page