rpc

Jun 22, 2018

Changes in this version

+ var ErrEndOfBlock = errors.New("The amount of data to be written is more than is left in the block.")

+ var ErrInvalidSeqno = errors.New("Invalid ack sequence number")

+ type BlockReader struct

+ func NewBlockReader(block *hdfs.LocatedBlockProto, offset int64, clientName string) *BlockReader

+ func (br *BlockReader) Close() error

+ func (br *BlockReader) Read(b []byte) (int, error)

+ type BlockWriter struct

+ func NewBlockWriter(block *hdfs.LocatedBlockProto, namenode *NamenodeConnection, blockSize int64) *BlockWriter

+ func (bw *BlockWriter) Close() error

+ func (bw *BlockWriter) Flush() error

+ func (bw *BlockWriter) Write(b []byte) (int, error)

+ type ChecksumReader struct

+ func NewChecksumReader(block *hdfs.LocatedBlockProto) *ChecksumReader

+ func (cr *ChecksumReader) ReadChecksum() ([]byte, error)

+ type NamenodeConnection struct

+ func NewNamenodeConnection(address string, user string) (*NamenodeConnection, error)

+ func NewNamenodeConnectionWithOptions(options NamenodeConnectionOptions) (*NamenodeConnection, error)

+ func WrapNamenodeConnection(conn net.Conn, user string) (*NamenodeConnection, error)

+ func (c *NamenodeConnection) ClientName() string

+ func (c *NamenodeConnection) Close() error

+ func (c *NamenodeConnection) Execute(method string, req proto.Message, resp proto.Message) error

+ type NamenodeConnectionOptions struct

+ Addresses []string

+ User string

+ type NamenodeError struct

+ Code int

+ Exception string

+ Message string

+ Method string

+ func (err *NamenodeError) Desc() string

+ func (err *NamenodeError) Error() string