uklam

package module

v0.0.0-...-9e7368d Latest Latest Go to latest Published: Jun 13, 2017 License: MIT Imports: 6 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/eaciit/uklam

Links

Open Source Insights

README ¶

uklam

File system walker workflow library

Documentation ¶

Index ¶

Constants
func DefaultRefreshDuration() time.Duration
func FSCopy(source, dst string, ismove bool) error
func FSWalkFn(dw IDataWalker, in toolkit.M) *toolkit.Result
func SetDefaultRefreshDuration(t time.Duration)
type FSWalker
- func NewFS(path string) *FSWalker
type IDataWalker
type WalkerStatusEnum

Constants ¶

View Source

const (
	WalkerIdle        WalkerStatusEnum = 0
	WalkerRunning                      = 1
	WalkerRunningDone                  = 10
	WalkerStop                         = 100
)

Variables ¶

This section is empty.

Functions ¶

func DefaultRefreshDuration ¶

func DefaultRefreshDuration() time.Duration

func FSCopy ¶

func FSCopy(source, dst string, ismove bool) error

FSCopy copy file from source to dst

func FSWalkFn ¶

func FSWalkFn(dw IDataWalker, in toolkit.M) *toolkit.Result

func SetDefaultRefreshDuration ¶

func SetDefaultRefreshDuration(t time.Duration)

Types ¶

type FSWalker ¶

type FSWalker struct {
	sync.RWMutex

	Setting         *toolkit.M
	RefreshDuration time.Duration
	CheckFn         func(IDataWalker, toolkit.M) *toolkit.Result
	WalkFn          func(IDataWalker, toolkit.M) *toolkit.Result
	EachFn          func(IDataWalker, toolkit.M, os.FileInfo, *toolkit.Result)
	Status          WalkerStatusEnum
	// contains filtered or unexported fields
}

func NewFS ¶

func NewFS(path string) *FSWalker

func (*FSWalker) Host ¶

func (fs *FSWalker) Host() string

func (*FSWalker) Log ¶

func (fs *FSWalker) Log() *toolkit.LogEngine

func (*FSWalker) NewData ¶

func (fs *FSWalker) NewData() bool

func (*FSWalker) SetHost ¶

func (fs *FSWalker) SetHost(h string)

func (*FSWalker) SetIdle ¶

func (fs *FSWalker) SetIdle() error

func (*FSWalker) SetLog ¶

func (fs *FSWalker) SetLog(l *toolkit.LogEngine)

func (*FSWalker) Start ¶

func (fs *FSWalker) Start()

func (*FSWalker) Stop ¶

func (fs *FSWalker) Stop()

func (*FSWalker) Walk ¶

func (fs *FSWalker) Walk() error

type IDataWalker ¶

type IDataWalker interface {
	SetHost(string)
	Host() string
}

type WalkerStatusEnum ¶

type WalkerStatusEnum int

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL