Documentation
¶
Index ¶
- type OrientDBStorage
- func (c *OrientDBStorage) Close()
- func (c *OrientDBStorage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
- func (c *OrientDBStorage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)
- func (c *OrientDBStorage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)
- func (c *OrientDBStorage) Start()
- func (c *OrientDBStorage) Stop()
- func (c *OrientDBStorage) StoreFlows(flows []*flow.Flow) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OrientDBStorage ¶
type OrientDBStorage struct {
// contains filtered or unexported fields
}
OrientDBStorage describes a OrientDB database client
func New ¶
func New(backend string) (*OrientDBStorage, error)
New creates a new OrientDB database client
func (*OrientDBStorage) SearchFlows ¶
func (c *OrientDBStorage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
SearchFlows search flow matching filters in the database
func (*OrientDBStorage) SearchMetrics ¶
func (c *OrientDBStorage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)
SearchMetrics searches flow metrics matching filters in the database
func (*OrientDBStorage) SearchRawPackets ¶ added in v0.16.0
func (c *OrientDBStorage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)
SearchRawPackets searches flow raw packets matching filters in the database
func (*OrientDBStorage) StoreFlows ¶
func (c *OrientDBStorage) StoreFlows(flows []*flow.Flow) error
StoreFlows pushes a set of flows in the database
Source Files
¶
- orientdb.go
Click to show internal directories.
Click to hide internal directories.