Documentation
¶
Index ¶
Constants ¶
View Source
const WriteoutsChanDepth = 100
WriteoutsChanDepth defines a default depth for sending writeouts over the writeout channel
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GoDBHandler ¶
GoDBHandler denotes a GoDB writeout handler
func NewGoDBHandler ¶
func NewGoDBHandler(path string, encoderType encoders.Type) *GoDBHandler
NewGoDBHandler instantiates a new GoDB handler
func (*GoDBHandler) HandleWriteout ¶
func (h *GoDBHandler) HandleWriteout(ctx context.Context, timestamp time.Time, writeoutChan <-chan capturetypes.TaggedAggFlowMap) <-chan struct{}
HandleWriteout provides access to writeouts to a GoDB via a channel
func (*GoDBHandler) WithPermissions ¶
func (h *GoDBHandler) WithPermissions(permissions fs.FileMode) *GoDBHandler
WithPermissions sets explicit permissions for the underlying GoDB
func (*GoDBHandler) WithSyslogWriting ¶
func (h *GoDBHandler) WithSyslogWriting(b bool) *GoDBHandler
WithSyslogWriting enables / disables explicit writing to Syslog facilities
type Handler ¶
type Handler interface {
// HandleWriteout provides access to writeouts via a channel
HandleWriteout(ctx context.Context, timestamp time.Time, writeoutChan <-chan capturetypes.TaggedAggFlowMap) <-chan struct{}
}
Handler defines a generic interface for handling writeouts
Source Files
Click to show internal directories.
Click to hide internal directories.