storage

Documentation

Index

• Variables
• type Storage
  • func NewStorage(backend string) (s Storage, err error)
  • func NewStorageFromConfig() (s Storage, err error)

Variables

var (
	ErrNoStorageConfigured = errors.New("No storage backend has been configured")
)

ErrNoStorageConfigured error no storage has been configured

Types

type Storage

type Storage interface {
	Start()
	StoreFlows(flows []*flow.Flow) error
	SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
	SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]*common.TimedMetric, error)
	Stop()
}

Storage interface a flow storage mechanism

func NewStorage

func NewStorage(backend string) (s Storage, err error)

NewStorage creates a new flow storage based on the backend

func NewStorageFromConfig

func NewStorageFromConfig() (s Storage, err error)

NewStorageFromConfig creates a new storage based configuration