filters

Documentation

Overview

Package filters provides batchers and filters to analyze and simplify sync events

Index

• type Batch
  • func NewBatch() (batch *Batch)
  • func (b *Batch) String() string
  • func (b *Batch) Zaps() []zapcore.Field
• type BatchProcessStatus
• type BatchedEvent
• type BidirectionalBatch
• type EchoFilter
  • func NewEchoFilter() (ef *EchoFilter)
  • func (f *EchoFilter) CreateFilter() (in chan common.EventInfo, out chan common.EventInfo)
  • func (f *EchoFilter) ListenLocksEvents()
• type EventsBatcher
  • func NewEventsBatcher(ctx context.Context, source common.PathSyncSource, ...) *EventsBatcher
  • func (ev *EventsBatcher) BatchEvents(in chan common.EventInfo, out chan *Batch, duration time.Duration)
  • func (ev *EventsBatcher) FilterBatch(batch *Batch)
  • func (ev *EventsBatcher) ProcessEvents(events []common.EventInfo)
  • func (ev *EventsBatcher) RegisterEventChannel(out chan common.ProcessorEvent)
• type LockEvent
• type UnlockEvent

Types

type Batch

type Batch struct {
	CreateFiles            map[string]*BatchedEvent
	CreateFolders          map[string]*BatchedEvent
	Deletes                map[string]*BatchedEvent
	FileMoves              map[string]*BatchedEvent
	FolderMoves            map[string]*BatchedEvent
	SessionProvider        sync.SessionProvider
	SessionProviderContext context.Context
	StatusChan             chan BatchProcessStatus
}

func NewBatch

func NewBatch() (batch *Batch)

func (*Batch) String

func (b *Batch) String() string

func (*Batch) Zaps

func (b *Batch) Zaps() []zapcore.Field

type BatchProcessStatus

type BatchProcessStatus struct {
	IsError      bool
	StatusString string
	Progress     float32
}

type BatchedEvent

type BatchedEvent struct {
	EventInfo sync.EventInfo
	Node      *tree.Node
	Key       string
	Source    sync.PathSyncSource
	Target    sync.PathSyncTarget
}

type BidirectionalBatch

type BidirectionalBatch struct {
	Left  *Batch
	Right *Batch
}

type EchoFilter

type EchoFilter struct {
	LockEvents   chan LockEvent
	UnlockEvents chan UnlockEvent
	// contains filtered or unexported fields
}

func NewEchoFilter

func NewEchoFilter() (ef *EchoFilter)

func (*EchoFilter) CreateFilter

func (f *EchoFilter) CreateFilter() (in chan common.EventInfo, out chan common.EventInfo)

func (*EchoFilter) ListenLocksEvents

func (f *EchoFilter) ListenLocksEvents()

type EventsBatcher

type EventsBatcher struct {
	Source common.PathSyncSource
	Target common.PathSyncTarget
	// contains filtered or unexported fields
}

func NewEventsBatcher

func NewEventsBatcher(ctx context.Context, source common.PathSyncSource, target common.PathSyncTarget) *EventsBatcher

func (*EventsBatcher) BatchEvents

func (ev *EventsBatcher) BatchEvents(in chan common.EventInfo, out chan *Batch, duration time.Duration)

func (*EventsBatcher) FilterBatch

func (ev *EventsBatcher) FilterBatch(batch *Batch)

func (*EventsBatcher) ProcessEvents

func (ev *EventsBatcher) ProcessEvents(events []common.EventInfo)

func (*EventsBatcher) RegisterEventChannel

func (ev *EventsBatcher) RegisterEventChannel(out chan common.ProcessorEvent)

type LockEvent

type LockEvent struct {
	Source      common.PathSyncSource
	Path        string
	OperationId string
}

type UnlockEvent

type UnlockEvent struct {
	Source common.PathSyncSource
	Path   string
}