filter

Documentation

Index

• func StartFilterStream(sending chan<- []byte, receiving <-chan []byte)
• type FSFilter
  • func (f FSFilter) Start(c FilterConfig, sending chan<- []byte, receiving <-chan []byte)
• type Filter
• type FilterConfig
  • func GetFilterConfig(fileName string) (FilterConfig, error)
• type NOPFilter
  • func (N NOPFilter) Start(c FilterConfig, sending chan<- []byte, receiving <-chan []byte)
• type ZachsInotifyData

Functions

func StartFilterStream

func StartFilterStream(sending chan<- []byte, receiving <-chan []byte)

Types

type FSFilter

type FSFilter struct{}

func (FSFilter) Start

func (f FSFilter) Start(c FilterConfig, sending chan<- []byte, receiving <-chan []byte)

type Filter

type Filter interface {
	Start(c FilterConfig, sending chan<- []byte, receiving <-chan []byte)
}

type FilterConfig

type FilterConfig struct {
	Ignore []string `json:"ignore"`
}

func GetFilterConfig

func GetFilterConfig(fileName string) (FilterConfig, error)

type NOPFilter

type NOPFilter struct{}

func (NOPFilter) Start

func (N NOPFilter) Start(c FilterConfig, sending chan<- []byte, receiving <-chan []byte)

type ZachsInotifyData

type ZachsInotifyData struct {
	Date     string `json:"DATE"`
	Event    string `json:"EVENT"`
	FilePath string `json:"PATH"`
	Type     string `json:"TYPE"`
}