lib

Apr 22, 2024

Changes in this version

type LocalFileSystem

+ func (w LocalFileSystem) Chtimes(name string, atime time.Time, mtime time.Time) error

type PathSpecArgs

+ PreserveTimes bool

type PathSpecEntry

+ Mtime time.Time

type WritableFs

+ Chtimes func(name string, atime time.Time, mtime time.Time) error

Sep 17, 2023

Changes in this version

+ func S3ErrorIsRequestHasExpired(err error) bool

+ func S3ErrorIsRequestTimeout(err error) bool

Sep 15, 2023

Changes in this version

type Transport

+ func DefaultPooledTransport() *Transport

Sep 14, 2023

Changes in this version

+ const BasePart

+ const MinMeterResolution

+ const URLPathSeparator

+ var DefaultClient *http.Client

+ var ErrInvalidMeterParameter = errors.New("meter invalid parameter")

+ var PartSizes = partSizes()

+ func AnyError(callback func(error), functions ...func() error)

+ func Bool(bool bool) *bool

+ func BuildPath(resourcePath string, values interface{}) (string, error)

+ func BuildPathSpecTest(t *testing.T, mutex *sync.Mutex, tt PathSpecTest, sourceFs ReadWriteFs, ...)

+ func ChangeDir(fs ReadWriteFs, relativePath string, fullPath string, mutex *sync.Mutex) (func(), bool, error)

+ func CheckRequired(iStruct interface{}) error

+ func CloseBody(res *http.Response)

+ func CopyAt(dst io.WriterAt, writeOff int64, src io.Reader) (written int64, err error)

+ func CreateError(i interface{}, name string) error

+ func DefaultRetryableHttp(logger Logger, client ...*http.Client) *retryablehttp.Client

+ func DefaultString(a, b string) string

+ func ExpandTilde(path string) string

+ func GetConnectionStatsFromClient(client *http.Client) (map[string]int, bool)

+ func Int64(i int64) *int64

+ func Interface() interface

+ func IsHTML(res *http.Response) bool

+ func IsJSON(res *http.Response) bool

+ func IsNonOkStatus(res *http.Response) bool

+ func IsOkStatus(res *http.Response) bool

+ func IsStatus(status int) func(res *http.Response) error

+ func IsXML(res *http.Response) bool

+ func JSONEmptyValue(v reflect.Type) string

+ func NewReader(ctx context.Context, r io.ReadCloser) io.ReadCloser

+ func NewReaderAt(ctx context.Context, r io.ReaderAt) io.ReaderAt

+ func NonJSONError(res *http.Response) error

+ func NonOkError(res *http.Response) error

+ func NonOkErrorCustom(callbacks ...func(error) error) func(res *http.Response) error

+ func NormalizeForComparison(path string) string

+ func NotStatus(status int) func(res *http.Response) error

+ func PathEscape(path string) (string, error)

+ func ResponseErrors(res *http.Response, errorFunc ...func(res *http.Response) error) error

+ func S3XMLError(res *http.Response) error

+ func String(string string) *string

+ func Time(t time.Time) *time.Time

+ func UnWrapBool(b *bool) bool

+ func UrlJoinNoEscape(paths ...string) string

+ func UrlLastSegment(path string) (rest string, lastSegment string)

+ type Cmd interface

+ Args func() []string

+ Run func() error

+ SetErr func(newErr io.Writer)

+ SetOut func(io.Writer)

+ type ConcurrencyManager interface

+ Done func()

+ RunningCount func() int

+ Wait func()

+ WaitAllDone func()

+ WaitForADone func() bool

+ WaitWithContext func(ctx context.Context) bool

+ type ConcurrencyManagerWithSubWorker interface

+ NewSubWorker func() ConcurrencyManager

+ type Conn struct

+ func (c *Conn) Close() (err error)

+ type ConstrainedWorkGroup struct

+ func NewConstrainedWorkGroup(maxConcurrency int) *ConstrainedWorkGroup

+ func (cw *ConstrainedWorkGroup) Done()

+ func (cw *ConstrainedWorkGroup) Max() int

+ func (cw *ConstrainedWorkGroup) NewSubWorker() ConcurrencyManager

+ func (cw *ConstrainedWorkGroup) RemainingCapacity() int

+ func (cw *ConstrainedWorkGroup) RunningCount() int

+ func (cw *ConstrainedWorkGroup) Wait()

+ func (cw *ConstrainedWorkGroup) WaitAllDone()

+ func (cw *ConstrainedWorkGroup) WaitForADone() bool

+ func (cw *ConstrainedWorkGroup) WaitWithContext(ctx context.Context) bool

+ type DirEntry struct

+ func DirEntryWalkFile(d fs.DirEntry, path string, err error) (DirEntry, error)

+ func (d DirEntry) Err() error

+ func (d DirEntry) Path() string

+ type ErrorWithOriginalResponse struct

+ func (u ErrorWithOriginalResponse) OriginalResponse() interface{}

+ func (u ErrorWithOriginalResponse) ProcessError(data []byte, err error, t interface{}) error

+ type ExeCmd struct

+ func (e ExeCmd) Args() []string

+ func (e ExeCmd) Run() error

+ func (e ExeCmd) SetErr(w io.Writer)

+ func (e ExeCmd) SetOut(w io.Writer)

+ type ExportValues struct

+ func (m ExportValues) ToJSON() (io.Reader, error)

+ func (m ExportValues) ToValues() (url.Values, error)

+ type FSWithContext interface

+ WithContext func(ctx context.Context) fs.FS

+ type FileWithContext interface

+ WithContext func(ctx context.Context) fs.File

+ type IsDir interface

+ IsDir func() bool

+ type IterChan struct

+ Error atomic.Value

+ Send chan T

+ SendError chan error

+ Start func(*IterChan[T])

+ Stop context.CancelFunc

+ func (i *IterChan[T]) Current() interface{}

+ func (i *IterChan[T]) Err() error

+ func (i *IterChan[T]) Init(ctx context.Context) *IterChan[T]

+ func (i *IterChan[T]) Next() bool

+ func (i *IterChan[T]) Resource() T

+ type KeyedMutex struct

+ func NewKeyedMutex() KeyedMutex

+ func (s KeyedMutex) Lock(key interface{})

+ func (s KeyedMutex) Unlock(key interface{})

+ type LocalFileSystem struct

+ func (w LocalFileSystem) Chdir(dir string) error

+ func (w LocalFileSystem) Create(path string) (io.WriteCloser, error)

+ func (w LocalFileSystem) Getwd() (string, error)

+ func (w LocalFileSystem) MkdirAll(path string, mode fs.FileMode) error

+ func (w LocalFileSystem) MkdirTemp(dir, pattern string) (string, error)

+ func (w LocalFileSystem) Open(path string) (fs.File, error)

+ func (w LocalFileSystem) PathJoin(paths ...string) string

+ func (w LocalFileSystem) PathSeparator() string

+ func (w LocalFileSystem) RelPath(parent, child string) (string, error)

+ func (w LocalFileSystem) Remove(path string) error

+ func (w LocalFileSystem) RemoveAll(path string) error

+ func (w LocalFileSystem) SplitPath(path string) (string, string)

+ func (w LocalFileSystem) TempDir() string

+ type Logger interface

+ Printf func(string, ...interface{})

+ type Map struct

+ func (m *Map[T]) Delete(key any)

+ func (m *Map[T]) Load(key any) (value T, ok bool)

+ func (m *Map[T]) Store(key any, value T)

+ type Meter struct

+ func NewMeter(resolution, sample time.Duration) (*Meter, error)

+ func (m *Meter) BitRate(tc time.Time) infounit.BitRate

+ func (m *Meter) Close(tc time.Time)

+ func (m *Meter) Record(tc time.Time, b infounit.ByteCount)

+ func (m *Meter) Start(tc time.Time)

+ func (m *Meter) Total(tc time.Time) (infounit.ByteCount, time.Duration, infounit.BitRate)

+ type MeterItem struct

+ type NullLogger struct

+ func (n NullLogger) Printf(_ string, _ ...interface{})

+ type Params struct

+ Params interface{}

+ func (p Params) ToJSON() (io.Reader, error)

+ func (p Params) ToValues() (url.Values, error)

+ type Path struct

+ Path string

+ Separator string

+ func NewUrlPath(path string) Path

+ func (p Path) ConvertEmptyToRoot() Path

+ func (p Path) EndingSlash() bool

+ func (p Path) Join(str ...string) Path

+ func (p Path) NormalizePathSystemForAPI() Path

+ func (p Path) PathSeparator() string

+ func (p Path) Pop() string

+ func (p Path) PruneEndingSlash() Path

+ func (p Path) PruneStartingSlash() Path

+ func (p Path) String() string

+ func (p Path) SwitchPathSeparator(separator string) Path

+ type PathSpecArgs struct

+ Dest string

+ Src string

+ type PathSpecEntry struct

+ Dir bool

+ Preexisting bool

+ type PathSpecTest struct

+ Args PathSpecArgs

+ Dest []PathSpecEntry

+ Name string

+ Src []PathSpecEntry

+ func PathSpec(srcPathSeparator string, destPathSeparator string) []PathSpecTest

+ type ProgressWriter struct

+ ProgressWatcher func(int64)

+ func (w ProgressWriter) Close() error

+ func (w ProgressWriter) Write(p []byte) (n int, err error)

+ func (w ProgressWriter) WriteAt(p []byte, off int64) (n int, err error)

+ type Queue struct

+ func (q *Queue[T]) Clear()

+ func (q *Queue[T]) Init(size int) *Queue[T]

+ func (q *Queue[T]) Len() int

+ func (q *Queue[T]) Pop() T

+ func (q *Queue[T]) Push(item T)

+ type ReadWriteFs interface

+ type ReaderAtCloser interface

+ type Resource struct

+ Entity UnmarshalJSON

+ Method string

+ Params interface{}

+ Path string

+ func (r Resource) Out() (ResourceOut, error)

+ type ResourceOut struct

+ type ResponseError struct

+ StatusCode int

+ func (r ResponseError) Error() string

+ type S3Error struct

+ Code string

+ HostId string

+ Message string

+ RequestId string

+ XMLName xml.Name

+ func (s S3Error) Empty() bool

+ func (s S3Error) Error() string

+ type Signal struct

+ C chan bool

+ func (s *Signal) Call()

+ func (s *Signal) Called() bool

+ func (s *Signal) Clear()

+ func (s *Signal) Init() *Signal

+ type StatefulDirectory interface

+ Chdir func(string) error

+ Getwd func() (string, error)

+ type SubWorker struct

+ func (sw *SubWorker) Done()

+ func (sw *SubWorker) RunningCount() int

+ func (sw *SubWorker) Wait()

+ func (sw *SubWorker) WaitAllDone()

+ func (sw *SubWorker) WaitForADone() bool

+ func (sw *SubWorker) WaitWithContext(ctx context.Context) bool

+ type Transport struct

+ Connections map[string]int

+ func (t *Transport) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ func (t *Transport) GetConnectionStats() map[string]int

+ type UnmarshalJSON interface

+ UnmarshalJSON func(data []byte) error

+ type Values interface

+ ToJSON func() (io.Reader, error)

+ ToValues func() (url.Values, error)

+ type Walk struct

+ ConcurrencyManager ConcurrencyManagerWithSubWorker

+ ListDirectories bool

+ Root string

+ WalkFile func(d fs.DirEntry, path string, err error) (T, error)

+ func (w *Walk[T]) Walk(parentCtx context.Context) *IterChan[T]

+ type WithContextReader interface

+ WithContext func(context.Context) interface{}

+ type WithContextReaderAt interface

+ WithContext func(context.Context) interface{}

+ type WritableFs interface

+ Create func(string) (io.WriteCloser, error)

+ MkdirAll func(string, fs.FileMode) error

+ MkdirTemp func(dir, pattern string) (string, error)

+ PathJoin func(...string) string

+ PathSeparator func() string

+ RelPath func(parent, child string) (string, error)

+ Remove func(string) error

+ RemoveAll func(string) error

+ SplitPath func(path string) (string, string)

+ TempDir func() string

+ type WriterAndAt interface