storage

Documentation

Index

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

Variables

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

Types

type Storage

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

func NewStorage

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

func NewStorageFromConfig

func NewStorageFromConfig() (s Storage, err error)