backend

package
v0.0.0-...-9ea754e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 13, 2017 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DirectoryWatcher

type DirectoryWatcher struct {
	// contains filtered or unexported fields
}

func CreateAndStartDirectoryWatcher

func CreateAndStartDirectoryWatcher(
	directories []string,
	checkEvery time.Duration) *DirectoryWatcher

func (*DirectoryWatcher) GetNewFilePaths

func (watcher *DirectoryWatcher) GetNewFilePaths() chan string

func (*DirectoryWatcher) Stop

func (watcher *DirectoryWatcher) Stop()

type Indexer

type Indexer struct {
	// contains filtered or unexported fields
}

func CreateAndStartIndexer

func CreateAndStartIndexer(blocks chan *pb.RecordBlock) *Indexer

func (*Indexer) Get

func (indexer *Indexer) Get(
	name, source string,
	startEpochMinute, endEpochMinute int32) map[int32]*pb.CounterValues

func (*Indexer) Stop

func (indexer *Indexer) Stop()

Jump to

Keyboard shortcuts

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