orientdb

Documentation

Index

• type OrientDBStorage
  • func New() (*OrientDBStorage, error)
  • 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.TimedMetric, error)
  • func (c *OrientDBStorage) Start()
  • func (c *OrientDBStorage) Stop()
  • func (c *OrientDBStorage) StoreFlows(flows []*flow.Flow) error

Types

type OrientDBStorage

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

OrientDBStorage describes a OrientDB database client

func New

func New() (*OrientDBStorage, error)

New creates a new OrientDB database client

func (*OrientDBStorage) Close

func (c *OrientDBStorage) Close()

Close the 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.TimedMetric, error)

SearchMetrics search flow metrics matching filters in the database

func (*OrientDBStorage) Start

func (c *OrientDBStorage) Start()

Start the database client

func (*OrientDBStorage) Stop

func (c *OrientDBStorage) Stop()

Stop the database client

func (*OrientDBStorage) StoreFlows

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

StoreFlows push a set of flows in the database