file

package

v5.3.1+incompatible Latest Latest Go to latest Published: Apr 12, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/MerlinDMC/beats

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

func IsSameFile(path string, info os.FileInfo) bool
func ReadOpen(path string) (*os.File, error)
func SafeFileRotate(path, tempfile string) error
type File
- func (f *File) IsSameFile(f2 *File) bool
type State
- func NewState(fileInfo os.FileInfo, path string) State
- func (s *State) IsEmpty() bool
type StateOS
- func GetOSState(info os.FileInfo) StateOS
- func (fs StateOS) IsSame(state StateOS) bool
type States
- func NewStates() *States

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsSameFile ¶

func IsSameFile(path string, info os.FileInfo) bool

IsSameFile checks if the given File path corresponds with the FileInfo given

func ReadOpen ¶

func ReadOpen(path string) (*os.File, error)

ReadOpen opens a file for reading only

func SafeFileRotate ¶

func SafeFileRotate(path, tempfile string) error

SafeFileRotate safely rotates an existing file under path and replaces it with the tempfile

Types ¶

type File ¶

type File struct {
	File     *os.File
	FileInfo os.FileInfo
	Path     string
	State    *State
}

func (*File) IsSameFile ¶

func (f *File) IsSameFile(f2 *File) bool

Checks if the two files are the same.

type State ¶

type State struct {
	Source      string      `json:"source"`
	Offset      int64       `json:"offset"`
	Finished    bool        `json:"-"` // harvester state
	Fileinfo    os.FileInfo `json:"-"` // the file info
	FileStateOS StateOS
	Timestamp   time.Time     `json:"timestamp"`
	TTL         time.Duration `json:"ttl"`
}

State is used to communicate the reading state of a file

func NewState ¶

func NewState(fileInfo os.FileInfo, path string) State

NewState creates a new file state

func (*State) IsEmpty ¶

func (s *State) IsEmpty() bool

IsEmpty returns true if the state is empty

type StateOS ¶

type StateOS struct {
	Inode  uint64 `json:"inode,"`
	Device uint64 `json:"device,"`
}

func GetOSState ¶

func GetOSState(info os.FileInfo) StateOS

GetOSState returns the FileStateOS for non windows systems

func (StateOS) IsSame ¶

func (fs StateOS) IsSame(state StateOS) bool

IsSame file checks if the files are identical

type States ¶

type States struct {
	sync.Mutex
	// contains filtered or unexported fields
}

States handles list of FileState

func NewStates ¶

func NewStates() *States

func (*States) Cleanup ¶

func (s *States) Cleanup() int

Cleanup cleans up the state array. All states which are older then `older` are removed The number of states that were cleaned up is returned

func (*States) Copy ¶

func (s *States) Copy() *States

Copy create a new copy of the states object

func (*States) Count ¶

func (s *States) Count() int

Count returns number of states

func (*States) FindPrevious ¶

func (s *States) FindPrevious(newState State) State

func (*States) GetStates ¶

func (s *States) GetStates() []State

Returns a copy of the file states

func (*States) SetStates ¶

func (s *States) SetStates(states []State)

SetStates overwrites all internal states with the given states array

func (*States) Update ¶

func (s *States) Update(newState State)

Update updates a state. If previous state didn't exist, new one is created

Source Files ¶

View all Source files

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