storage

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 3, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

ErrNoStorageConfigured error no storage has been configured

Functions

This section is empty.

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.Metric, error)
	SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)
	Stop()
}

Storage interface a flow storage mechanism

func NewStorage 

func NewStorage(backend string, etcdClient *etcd.Client) (s Storage, err error)

NewStorage creates a new flow storage based on the backend

func NewStorageFromConfig 

func NewStorageFromConfig(etcdClient *etcd.Client) (s Storage, err error)

NewStorageFromConfig creates a new storage based configuration

Source Files

  • storage.go

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.