pcapstorage

Documentation

Index

• Constants
• func MigrateV3(u iosrc.URI, pcapuri iosrc.URI) error
• type Info
• type Search
• type Store
  • func Load(ctx context.Context, u iosrc.URI) (*Store, error)
  • func New(root iosrc.URI) *Store
  • func (s *Store) Delete(ctx context.Context) error
  • func (s *Store) Empty() bool
  • func (s *Store) Info(ctx context.Context) (Info, error)
  • func (s *Store) NewSearch(ctx context.Context, req api.PcapSearch) (*Search, error)
  • func (s *Store) PcapURI() iosrc.URI
  • func (s *Store) Update(ctx context.Context, pcapuri iosrc.URI, warningCh chan<- string) error

Constants

const (
	MetaFile = "pcap.json"
)

Functions

func MigrateV3

func MigrateV3(u iosrc.URI, pcapuri iosrc.URI) error

Types

type Info

type Info struct {
	PcapURI  iosrc.URI
	PcapSize int64
	Span     nano.Span
}

type Search

type Search struct {
	*pcap.SearchReader
	io.Closer
}

type Store

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

func Load

func Load(ctx context.Context, u iosrc.URI) (*Store, error)

func New

func New(root iosrc.URI) *Store

func (*Store) Delete

func (s *Store) Delete(ctx context.Context) error

func (*Store) Empty

func (s *Store) Empty() bool

func (*Store) Info

func (s *Store) Info(ctx context.Context) (Info, error)

func (*Store) NewSearch

func (s *Store) NewSearch(ctx context.Context, req api.PcapSearch) (*Search, error)

NewSearch returns a *Search that streams all the packets meeting the provided search request. If pcaps are not supported in this Space, ErrPcapOpsNotSupported is returned.

func (*Store) PcapURI

func (s *Store) PcapURI() iosrc.URI

func (*Store) Update

func (s *Store) Update(ctx context.Context, pcapuri iosrc.URI, warningCh chan<- string) error