ifaceS3

Documentation

Index

• func Move(f io.ReadSeeker, sess *session.Session, fromTime, toTime, key, bucket string, ...) error
• type ReaderUncompress
  • func NewReaderUncompress(sess *session.Session, bucket string) *ReaderUncompress
  • func (r *ReaderUncompress) Close()
  • func (r *ReaderUncompress) Get(key string) ([]byte, error)
  • func (r *ReaderUncompress) Read(b []byte) (int, error)
  • func (r *ReaderUncompress) WriteAt(b []byte, offset int64) (int, error)
• type WriteCompress
  • func NewWriteCompress(path string, fn func(name string, f *os.File) error) (*WriteCompress, error)
  • func (s *WriteCompress) Close() (err error)
  • func (s *WriteCompress) WriteFile(f *os.FileInfo) (err error)

Functions

func Move

func Move(f io.ReadSeeker, sess *session.Session, fromTime, toTime, key, bucket string, fullpathFn, pathFn func(t time.Time) string) error

Types

type ReaderUncompress

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

func NewReaderUncompress

func NewReaderUncompress(sess *session.Session, bucket string) *ReaderUncompress

func (*ReaderUncompress) Close

func (r *ReaderUncompress) Close()

func (*ReaderUncompress) Get

func (r *ReaderUncompress) Get(key string) ([]byte, error)

func (*ReaderUncompress) Read

func (r *ReaderUncompress) Read(b []byte) (int, error)

func (*ReaderUncompress) WriteAt

func (r *ReaderUncompress) WriteAt(b []byte, offset int64) (int, error)

type WriteCompress

type WriteCompress struct {
	RecDone int
	// contains filtered or unexported fields
}

WriteCompress is an structure to create gz files with limits of lines and size

func NewWriteCompress

func NewWriteCompress(path string, fn func(name string, f *os.File) error) (*WriteCompress, error)

NewWriteCompress create a pointer and start the temp file and the gz interface

func (*WriteCompress) Close

func (s *WriteCompress) Close() (err error)

Close the temp file and the gz interface. The gz will be returned to the pool

func (*WriteCompress) WriteFile

func (s *WriteCompress) WriteFile(f *os.FileInfo) (err error)

Write a file in tar