Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNotFound - ErrNotFound = errors.New("ErrNotFound") )
Functions ¶
This section is empty.
Types ¶
type Buffer ¶
type Buffer interface {
Append(*collection.Document) error
AppendBatch(...collection.Document) error
Flush() error
Flusher() func()
Close()
}
Buffer -
func DefaultBuffer ¶
func DefaultBuffer(collec *collection.Collection, outputs map[string]output.Interface) Buffer
DefaultBuffer creates a new buffer
func RedisBuffer ¶
func RedisBuffer(collec *collection.Collection, redisCfg *config.Redis, outputs map[string]output.Interface) Buffer
RedisBuffer -
type Collector ¶
type Collector interface {
Collect(collectionName collection.Name, docBytes []byte) error
CollectBatch(collectionName collection.Name, docBytesSlice ...[]byte) error
}
Collector collects documents
type Dispatcher ¶
type Dispatcher interface {
Dispatch(document *collection.Document) error
DispatchBatch(documents ...collection.Document) error
}
Dispatcher dispatches documents
Source Files
Click to show internal directories.
Click to hide internal directories.