Documentation
¶
Index ¶
Constants ¶
View Source
const ( DATA_SHARDS = 4 PARITY_SHARDS = 2 ALL_SHARDS = DATA_SHARDS + PARITY_SHARDS BLOCK_PER_SHARD = 8000 BLOCK_SIZE = BLOCK_PER_SHARD * DATA_SHARDS )
Variables ¶
This section is empty.
Functions ¶
func NewEncoder ¶
Types ¶
type RSGetStream ¶
type RSGetStream struct {
// contains filtered or unexported fields
}
func NewRSGetStream ¶
func (*RSGetStream) Close ¶
func (s *RSGetStream) Close()
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)
type RSResumableGetStream ¶
type RSResumableGetStream struct {
// contains filtered or unexported fields
}
func NewRSResumableGetStream ¶
func NewRSResumableGetStream(dataServers []string, uuids []string, size int64) (*RSResumableGetStream, 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
func (*RSResumablePutStream) ToToken ¶
func (s *RSResumablePutStream) ToToken() string
Source Files
Click to show internal directories.
Click to hide internal directories.