elasticseach

Documentation

Index

• Variables
• type ElasticSearchStorage
  • func New() (*ElasticSearchStorage, error)
  • func (c *ElasticSearchStorage) SearchFlows(filters storage.Filters) ([]*flow.Flow, error)
  • func (c *ElasticSearchStorage) StoreFlows(flows []*flow.Flow) error
• type OldFlow

Variables

var ErrBadConfig = errors.New("elasticseach : Config file is misconfigured, check elasticsearch key format")

Types

type ElasticSearchStorage

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

func New

func New() (*ElasticSearchStorage, error)

func (*ElasticSearchStorage) SearchFlows

func (c *ElasticSearchStorage) SearchFlows(filters storage.Filters) ([]*flow.Flow, error)

func (*ElasticSearchStorage) StoreFlows

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

type OldFlow

type OldFlow struct {
	UUID       string
	LayersPath string
	EtherSrc   string
	EtherDst   string
	Ipv4Src    string
	Ipv4Dst    string
	PortSrc    uint32
	PortDst    uint32
	ID         uint64
	Timestamp  uint64

	ProbeGraphPath string

	IfSrcName      string
	IfSrcType      string
	IfSrcGraphPath string
	IfSrcTenantID  string
	IfSrcVNI       uint64

	IfDstName      string
	IfDstType      string
	IfDstGraphPath string
	IfDstTenantID  string
	IfDstVNI       uint64
}