event

Documentation

Index

• type Event
  • func (e Event) String() string
• type EventHandler
  • func NewEventHandler() EventHandler
• type EventManager
  • func (e *EventManager) Append(event fsnotify.Event, sum string)
  • func (e *EventManager) Pop() fsnotify.Event
  • func (e *EventManager) Process() []Event
  • func (e *EventManager) StackLength() int
• type Type
  • func (e Type) String() string

Types

type Event

type Event struct {
	Type     Type
	FromPath connector.Path
	ToPath   connector.Path
}

func (Event) String

func (e Event) String() string

type EventHandler

type EventHandler interface {
	StackLength() int
	Append(event fsnotify.Event, sum string)
	Pop() fsnotify.Event

	Process() []Event
	// contains filtered or unexported methods
}

func NewEventHandler

func NewEventHandler() EventHandler

type EventManager

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

Since OS events arrive synchronously and some events alone do not make sense, there was a need to set up a queue structure. Watchers written for OS periodically push events to the EventManager's stack and periodically handle these events within the Process method.

func (*EventManager) Append

func (e *EventManager) Append(event fsnotify.Event, sum string)

func (*EventManager) Pop

func (e *EventManager) Pop() fsnotify.Event

func (*EventManager) Process

func (e *EventManager) Process() []Event

This is where Event Manager processes the events in the main bus.Stack piece by piece. Determining the maximum number of events to be processed;

It is determined by how many events the operating system will send for a file transaction.

func (*EventManager) StackLength

func (e *EventManager) StackLength() int

type Type

type Type string

const (
	Remove Type = "remove"
	Write  Type = "write"
	Create Type = "create"
	Rename Type = "rename"
	Move   Type = "move"
)

func (Type) String

func (e Type) String() string