temporary

godoc

场景

将io.Reader转换成io.ReadSeeker。

1. 数据大小超过maxBufferSize时, 写入到临时文件ioutil.TempFile(fileDir, filePattern).
2. 提供异步操作流程NewAsyncTemporary/NewMustCloseReaderAsyncTemporary, 在调用其他方法之前一定要先使用Await().
3. 数据结果操作.
   • Size() 数据大小
   • Type() TemporaryBuffer | TemporaryFile
   • Name() 当类型为文件(TemporaryFile)时, 返回临时文件名.
   • Bytes() 当类型为缓存(TemporaryBuffer)时, 返回[]byte.

temporary.Temporary

type Temporary interface {
    Await() error
    Size() int64
    Type() string
    Name() string
    Bytes() []byte
    io.Reader
    io.Seeker
    io.Closer
}

同步方式

func NewTemporary(reader io.Reader, maxBufferSize int64, fileDir string, filePattern string) (_ Temporary, err error)

Example

package main
import (
    "github.com/linfangrong/temporary"
)
func main() {
    var (
        temp temporary.Temporary
        err  error
    )
    if temp, err = temporary.NewTemporary(
        reader,      // io.Reader
        2*1024*1204, // maxBufferSize 超过这个长度, 会转化成临时文件
        "/tmp",      // fileDir 临时文件目录
        "*",         // filePattern 文件名生成方式
    ); err != nil {
        // TODO error
        return
    }
    defer temp.Close()
    //
    // temp 可以当做io.ReadSeeker
    // Size() int64
    // io.Reader
    // io.Seeker
    // io.Closer
    //
    // 判断存储方式的类型
    // Type() string
    // Name() string   Type: TemporaryFile
    // Bytes() []byte  Type: TemporaryBuffer
    ...
}

异步方式

func NewAsyncTemporary(reader io.Reader, maxBufferSize int64, fileDir string, filePattern string) (_ Temporary)
func NewMustCloseReaderAsyncTemporary(readcloser io.ReadCloser, maxBufferSize int64, fileDir string, filePattern string) (_ Temporary)