Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rw

package

Go to main page

Versions in this module

v0

v0.10.2

Mar 6, 2025

v0.10.1

Mar 6, 2025

v0.10.0

Mar 4, 2025

Changes in this version

type Cfg

+ func (c *Cfg) UnmarshalJSON(data []byte) error

+ func (c *Cfg) UnmarshalYAML(data []byte) error

v0.9.28

Feb 28, 2025

v0.9.27

Feb 28, 2025

v0.9.26

Feb 28, 2025

v0.9.25

Feb 26, 2025

v0.9.24

Feb 19, 2025

v0.9.23

Feb 19, 2025

v0.9.22

Feb 18, 2025

v0.9.21

Feb 18, 2025

v0.9.20

Feb 14, 2025

v0.9.19

Feb 14, 2025

Changes in this version

+ const CompressLevelBest

+ const CompressLevelBetter

+ const CompressLevelFast

+ const CompressTypeGzip

+ const CompressTypeNop

+ const CompressTypeSnappy

+ const CompressTypeZstd

+ const TypeCompress

+ var CreateBase = newBase

+ var ErrChecksumNotMatch = errors.New("checksum not match")

+ func ApplyCommonCfgToRW(rw RW, cfg *ExtraCfg)

+ func FileExtFromCompressCfg(c *CompressCfg) string

+ func NewCmdCfg() *cmd.Cfg

+ func NewGzipReader(r io.ReadCloser, cfg *CompressCfg) io.ReadCloser

+ func NewGzipWritter(w io.WriteCloser, cfg *CompressCfg) io.WriteCloser

+ func NewSnappyReader(r io.ReadCloser, _ *CompressCfg) io.ReadCloser

+ func NewSnappyWriter(w io.WriteCloser, cfg *CompressCfg) io.WriteCloser

+ func NewZstdReader(r io.ReadCloser, cfg *CompressCfg) io.ReadCloser

+ func NewZstdWriter(w io.WriteCloser, cfg *CompressCfg) io.WriteCloser

+ type Cfg struct

+ Cfg any

+ ExtraCfg *ExtraCfg

+ Role Role

+ Type Type

+ type Cmd struct

+ func NewCmd() *Cmd

+ func (c *Cmd) GetCfg() any

+ func (c *Cmd) Init() error

+ func (c *Cmd) Start() error

+ func (c *Cmd) Stop() error

+ func (c *Cmd) Type() any

+ type Compress struct

+ func NewCompress() *Compress

+ func (c *Compress) Close() error

+ func (c *Compress) GetCfg() any

+ func (c *Compress) Init() error

+ func (c *Compress) NestReader(r io.ReadCloser) error

+ func (c *Compress) NestWriter(w io.WriteCloser) error

+ func (c *Compress) Type() any

+ type CompressCfg struct

+ Concurrency int

+ Level CompressLevel

+ Type CompressType

+ func NewCompressCfg() *CompressCfg

+ type CompressLevel string

+ type CompressType string

+ type Copy struct

+ func NewCopy() *Copy

+ func (cp *Copy) GetCfg() any

+ func (cp *Copy) Init() error

+ func (cp *Copy) Start() error

+ func (cp *Copy) Stop() error

+ func (cp *Copy) Type() any

+ type CopyCfg struct

+ BufSize int

+ func NewCopyCfg() *CopyCfg

+ type ExtraCfg struct

+ AsyncChanBufSize int

+ BufSize int

+ Checksum string

+ Deadline int

+ EnableAsync bool

+ EnableCalcHash bool

+ EnableMonitorSpeed bool

+ EnableRateLimit bool

+ HashAlgo string

+ RateLimiterCfg *ratelimit.RateLimiterCfg

+ type File struct

+ func NewFile() *File

+ func (f *File) GetCfg() any

+ func (f *File) Init() error

+ func (f *File) Type() any

+ type FileCfg struct

+ Path string

+ Perm uint32

+ func NewFileCfg() *FileCfg

+ type Ftp struct

+ func (f *Ftp) GetCfg() any

+ func (f *Ftp) Init() error

+ func (f *Ftp) Type() any

+ type FtpCfg struct

+ Addr string

+ Path string

+ Pwd string

+ Retry int

+ Timeout int

+ User string

+ func NewFtpCfg() *FtpCfg

+ type Nop struct

+ func NewNop() *Nop

+ func (n *Nop) GetCfg() any

+ func (n *Nop) Type() any

+ type NopCfg struct

+ func NewNopCfg() *NopCfg

+ type Null struct

+ func NewNull() *Null

+ func (f *Null) GetCfg() any

+ func (f *Null) Init() error

+ func (f *Null) Type() any

+ type NullCfg struct

+ func NewNullCfg() *NullCfg

+ type OSS struct

+ func (o *OSS) GetCfg() any

+ func (o *OSS) Init() error

+ func (o *OSS) Type() any

+ type OSSCfg struct

+ Ak string

+ Append bool

+ Region string

+ Retry int

+ Sk string

+ Timeout int

+ URL string

+ func NewOSSCfg() *OSSCfg

+ type RW interface

+ As func(Role)

+ AsReader func()

+ AsStarter func()

+ AsWriter func()

+ AsyncChanCap func() int

+ AsyncChanLen func() int

+ EnableCalcHash func(hashAlgo string)

+ EnableChecksum func(checksum string, hashAlgo string)

+ EnableMonitorSpeed func()

+ EnableRateLimit func(ratelimit.RxTxRateLimiter)

+ EnableReadBuf func(bufSize int, async bool, asyncChanBufSize int)

+ EnableWriteBuf func(bufSize int, deadline int, async bool, asyncChanBufSize int)

+ Flush func() error

+ Hash func() string

+ HookRead func(...ReadHook)

+ HookWrite func(...WriteHook)

+ Is func(Role) bool

+ IsAsyncOrDeadline func() bool

+ IsReader func() bool

+ IsStarter func() bool

+ IsWriter func() bool

+ NestReader func(io.ReadCloser) error

+ NestWriter func(io.WriteCloser) error

+ Nread func() uint64

+ Nwrite func() uint64

+ Reader func() io.ReadCloser

+ Role func() Role

+ Writer func() io.WriteCloser

+ func CreateRW(rwCfg *Cfg) (RW, error)

+ func NewFtp() RW

+ func NewOSS() RW

+ func NewSSH() RW

+ type ReadHook func(n int, bs []byte, err error, cost int64, misc ...any) error

+ type Role string

+ const RoleReader

+ const RoleStarter

+ const RoleWriter

+ type SSH struct

+ func (s *SSH) Close() error

+ func (s *SSH) GetCfg() any

+ func (s *SSH) Init() error

+ func (s *SSH) Start() error

+ func (s *SSH) Stop() error

+ func (s *SSH) Type() any

+ type SSHCfg struct

+ Addr string

+ Path string

+ PrivateKey string

+ Pwd string

+ Timeout int

+ User string

+ func NewSSHCfg() *SSHCfg

+ type Tail struct

+ func NewTail() *Tail

+ func (t *Tail) GetCfg() any

+ func (t *Tail) Init() error

+ func (t *Tail) Stop() error

+ func (t *Tail) Type() any

+ type TailCfg struct

+ Path string

+ Pos int64

+ func NewTailCfg() *TailCfg

+ type Type string

+ const TypeCmd

+ const TypeCopy

+ const TypeFile

+ const TypeFtp

+ const TypeNop

+ const TypeNull

+ const TypeOss

+ const TypeSSH

+ const TypeTail

+ type WriteHook func(n int, bs []byte, err error, cost int64, misc ...any) error