Versions in this module Expand all Collapse all v2 v2.3.1 Nov 14, 2023 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 + func (br *BlockReader) Skip(off int64) 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 + SkipSaslOnPrivilegedPorts bool + Token *hadoop.TokenProto + func (d *SaslDialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error) v2.3.1-ft Jan 24, 2023
Go to main page