io

Nov 25, 2015

Changes in this version

type BlkputRet

+ ExpiredAt int64

+ type ProgressRecord struct

+ Progresses []BlkputRet

type PutExtra

+ ProgressFile string

Nov 4, 2015

Changes in this version

+ const InvalidCtx

+ var ErrInvalidPutProgress = errors.New("invalid put progress")

+ var ErrPutFailed = errors.New("resumable put failed")

+ var ErrUnmatchedChecksum = errors.New("unmatched checksum")

+ func BlockCount(fsize int64) int

+ func Blockput(c rpc.Client, l rpc.Logger, ret *BlkputRet, body io.Reader, size int) error

+ func Mkblock(c rpc.Client, l rpc.Logger, ret *BlkputRet, blockSize int, body io.Reader, ...) error

+ func Mkfile(c rpc.Client, l rpc.Logger, ret interface{}, key string, hasKey bool, ...) (err error)

+ func NewClient(token string, bindRemoteIp string) rpc.Client

+ func NewClientEx(token string, transport http.RoundTripper, bindRemoteIp string) rpc.Client

+ func Put(c rpc.Client, l rpc.Logger, ret interface{}, key string, f io.ReaderAt, ...) error

+ func PutFile(c rpc.Client, l rpc.Logger, ret interface{}, key, localFile string, ...) (err error)

+ func PutFileWithoutKey(c rpc.Client, l rpc.Logger, ret interface{}, localFile string, extra *PutExtra) (err error)

+ func PutWithoutKey(c rpc.Client, l rpc.Logger, ret interface{}, f io.ReaderAt, fsize int64, ...) error

+ func ResumableBlockput(c rpc.Client, l rpc.Logger, ret *BlkputRet, f io.ReaderAt, blkIdx, blkSize int, ...) (err error)

+ func SetSettings(v *Settings)

+ type BlkputRet struct

+ Checksum string

+ Crc32 uint32

+ Ctx string

+ Host string

+ Offset uint32

+ type PutExtra struct

+ ChunkSize int

+ MimeType string

+ Notify func(blkIdx int, blkSize int, ret *BlkputRet)

+ NotifyErr func(blkIdx int, blkSize int, err error)

+ Params map[string]string

+ Progresses []BlkputRet

+ TryTimes int

+ type PutRet struct

+ Hash string

+ Key string

+ type Settings struct

+ ChunkSize int

+ TaskQsize int

+ TryTimes int

+ Workers int

+ type Transport struct

+ func NewTransport(token string, transport http.RoundTripper) *Transport

+ func (t *Transport) RoundTrip(req *http.Request) (resp *http.Response, err error)