rs

Documentation

Index

• Constants
• func NewDecoder(readers []io.Reader, writers []io.Writer, size int64) *decoder
• func NewEncoder(writers []io.Writer) *encoder
• type RSGetStream
  • func NewRSGetStream(locateInfo map[int]string, dataServers []string, hash string, size int64) (*RSGetStream, error)
  • func (s *RSGetStream) Close()
  • func (d RSGetStream) Read(p []byte) (n int, err error)
  • func (s *RSGetStream) Seek(offset int64, whence int) (int64, error)
• type RSPutStream
  • func NewRSPutStream(dataServers []string, hash string, size int64) (*RSPutStream, error)
  • func (s *RSPutStream) Commit(success bool)
  • func (e RSPutStream) Flush()
  • func (e RSPutStream) Write(p []byte) (n int, err error)
• type RSResumableGetStream
  • func NewRSResumableGetStream(dataServers []string, uuids []string, size int64) (*RSResumableGetStream, error)
  • func (d RSResumableGetStream) Read(p []byte) (n int, err error)
• type RSResumablePutStream
  • func NewRSResumablePutStream(dataServers []string, name, hash string, size int64) (*RSResumablePutStream, error)
  • func NewRSResumablePutStreamFromToken(token string) (*RSResumablePutStream, error)
  • func (s *RSResumablePutStream) CurrentSize() int64
  • func (e RSResumablePutStream) Flush()
  • func (s *RSResumablePutStream) ToToken() string
  • func (e RSResumablePutStream) Write(p []byte) (n int, err error)

Constants

const (
	DATA_SHARDS     = 4
	PARITY_SHARDS   = 2
	ALL_SHARDS      = DATA_SHARDS + PARITY_SHARDS
	BLOCK_PER_SHARD = 8 * 1 << 10
	BLOCK_SIZE      = BLOCK_PER_SHARD * DATA_SHARDS
)

Functions

func NewDecoder

func NewDecoder(readers []io.Reader, writers []io.Writer, size int64) *decoder

func NewEncoder

func NewEncoder(writers []io.Writer) *encoder

Types

type RSGetStream

type RSGetStream struct {
	// contains filtered or unexported fields
}

func NewRSGetStream

func NewRSGetStream(locateInfo map[int]string, dataServers []string, hash string, size int64) (*RSGetStream, error)

func (*RSGetStream) Close

func (s *RSGetStream) Close()

func (RSGetStream) Read

func (d RSGetStream) Read(p []byte) (n int, err error)

func (*RSGetStream) Seek

func (s *RSGetStream) Seek(offset int64, whence int) (int64, error)

return 1, 0 为正常

type RSPutStream

type RSPutStream struct {
	// contains filtered or unexported fields
}

func NewRSPutStream

func NewRSPutStream(dataServers []string, hash string, size int64) (*RSPutStream, error)

func (*RSPutStream) Commit

func (s *RSPutStream) Commit(success bool)

func (RSPutStream) Flush

func (e RSPutStream) Flush()

func (RSPutStream) Write

func (e RSPutStream) Write(p []byte) (n int, err error)

type RSResumableGetStream

type RSResumableGetStream struct {
	// contains filtered or unexported fields
}

func NewRSResumableGetStream

func NewRSResumableGetStream(dataServers []string, uuids []string, size int64) (*RSResumableGetStream, error)

func (RSResumableGetStream) Read

func (d RSResumableGetStream) Read(p []byte) (n int, err error)

type RSResumablePutStream

type RSResumablePutStream struct {
	*RSPutStream
	// contains filtered or unexported fields
}

func NewRSResumablePutStream

func NewRSResumablePutStream(dataServers []string, name, hash string, size int64) (*RSResumablePutStream, error)

func NewRSResumablePutStreamFromToken

func NewRSResumablePutStreamFromToken(token string) (*RSResumablePutStream, error)

func (*RSResumablePutStream) CurrentSize

func (s *RSResumablePutStream) CurrentSize() int64

返回第一个临时分片的大小*4， 若超出文件大小，则返回文件大小

func (RSResumablePutStream) Flush

func (e RSResumablePutStream) Flush()

func (*RSResumablePutStream) ToToken

func (s *RSResumablePutStream) ToToken() string

func (RSResumablePutStream) Write

func (e RSResumablePutStream) Write(p []byte) (n int, err error)