orientdb

Documentation

Index

• type Storage
  • func New(backend string) (*Storage, error)
  • func (c *Storage) Close()
  • func (c *Storage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
  • func (c *Storage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)
  • func (c *Storage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string][]*flow.RawPacket, error)
  • func (c *Storage) Start()
  • func (c *Storage) Stop()
  • func (c *Storage) StoreFlows(flows []*flow.Flow) error

Types

type Storage

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

Storage describes a OrientDB database client

func New

func New(backend string) (*Storage, error)

New creates a new OrientDB database client

func (*Storage) Close

func (c *Storage) Close()

Close the database client

func (*Storage) SearchFlows

func (c *Storage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)

SearchFlows search flow matching filters in the database

func (*Storage) SearchMetrics

func (c *Storage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)

SearchMetrics searches flow metrics matching filters in the database

func (*Storage) SearchRawPackets

func (c *Storage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string][]*flow.RawPacket, error)

SearchRawPackets searches flow raw packets matching filters in the database

func (*Storage) Start

func (c *Storage) Start()

Start the database client

func (*Storage) Stop

func (c *Storage) Stop()

Stop the database client

func (*Storage) StoreFlows

func (c *Storage) StoreFlows(flows []*flow.Flow) error

StoreFlows pushes a set of flows in the database